|
@@ -9,13 +9,17 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.fuzamei.constant.OperationType;
|
|
|
import com.fuzamei.constant.Roles;
|
|
|
+import com.fuzamei.entity.OperationHistoryAdmin;
|
|
|
import com.fuzamei.entity.Role;
|
|
|
import com.fuzamei.entity.User;
|
|
|
import com.fuzamei.mapperInterface.ReceivingClerkMapper;
|
|
|
import com.fuzamei.mapperInterface.UserMapper;
|
|
|
import com.fuzamei.service.UserService;
|
|
|
import com.fuzamei.util.PageDTO;
|
|
|
+import com.fuzamei.util.blockchain.BlockChainUtil;
|
|
|
|
|
|
@Service
|
|
|
public class UserServiceImpl implements UserService {
|
|
@@ -24,7 +28,8 @@ public class UserServiceImpl implements UserService {
|
|
|
private UserMapper userMapper;
|
|
|
@Autowired
|
|
|
private ReceivingClerkMapper receivingClerkMapper;
|
|
|
-
|
|
|
+ @Autowired
|
|
|
+ private BlockChainUtil blockChainUtil;
|
|
|
/**
|
|
|
* 查询所有角色
|
|
|
*/
|
|
@@ -45,50 +50,93 @@ public class UserServiceImpl implements UserService {
|
|
|
return pageDtO;
|
|
|
}
|
|
|
/**
|
|
|
- * 添加用户信息
|
|
|
+ * 【添加用户信息】
|
|
|
*/
|
|
|
@Override
|
|
|
@Transactional(rollbackFor=Exception.class)
|
|
|
public void insertUsers(User user){
|
|
|
-
|
|
|
- user.setCreateTime(System.currentTimeMillis());
|
|
|
- user.setUpdateTime(System.currentTimeMillis());
|
|
|
+ Long currentTime = System.currentTimeMillis();//得到当前系统时间
|
|
|
+ //做添加操作时set一个添加时间和更新时间
|
|
|
+ user.setCreateTime(currentTime);
|
|
|
+ user.setUpdateTime(currentTime);
|
|
|
userMapper.insertUsers(user);
|
|
|
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据用户id查询用户是否存在
|
|
|
- */
|
|
|
- @Override
|
|
|
- public List<User> findUserById(User user) {
|
|
|
- return userMapper.findUserById(user);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<User> findUserByuserIdandusername(User user){
|
|
|
- return userMapper.findUserByuserIdandusername(user);
|
|
|
+
|
|
|
+ //往{操作记录}表插入数据
|
|
|
+ String sign = user.getSign();
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
+ Map<String,Object> map = JSON.parseObject(sign, Map.class);
|
|
|
+ String hash = (String) map.get("sid");
|
|
|
+ user.setUserId(user.getUserId());//操作人
|
|
|
+ user.setOperationTypeId(OperationType.ADD);//操作类型 (添加)
|
|
|
+ user.setUserIdb(user.getUserId());//被操作人账号 TODO??????????????待
|
|
|
+ user.setOperationTime(currentTime);//操作时间
|
|
|
+ user.setHash(hash);//操作hash
|
|
|
+ userMapper.insertOperationHistory(user);
|
|
|
+
|
|
|
+ /*boolean flag = blockChainUtil.sendBlockChain(user.getSign());//发送签名直接转发到区块链
|
|
|
+ if(!flag) {
|
|
|
+ throw new RuntimeException("区块链操作失败1");
|
|
|
+ }*/
|
|
|
+
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
+ * 【编辑修改】
|
|
|
* 根据u用户id 编辑修改,角色,账号,密码,名称,信息
|
|
|
*/
|
|
|
@Override
|
|
|
@Transactional(rollbackFor=Exception.class)
|
|
|
public void updateAccountByUserId(User user) {
|
|
|
- user.setUpdateTime(System.currentTimeMillis());
|
|
|
+ //【编辑账户信息】
|
|
|
+ Long currentTime = System.currentTimeMillis();//得到当前系统时间
|
|
|
+ user.setUpdateTime(currentTime);
|
|
|
userMapper.updateAccountByUserId(user);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ //往【操作记录】表插入数据
|
|
|
+ String sign = user.getSign();
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
+ Map<String,Object> map = JSON.parseObject(sign, Map.class);
|
|
|
+ String hash = (String) map.get("sid");
|
|
|
+ user.setOperatorId(user.getUserId());//操作人id
|
|
|
+ user.setOperationTypeId(OperationType.EDIT);//操作类型 (编辑修改)
|
|
|
+ user.setBeOperatedId(user.getUserId());//被操作人账号id TODO??????????????待
|
|
|
+ user.setOperationTime(currentTime);//操作时间
|
|
|
+ user.setHash(hash);//操作hash
|
|
|
+ userMapper.insertOperationHistory(user);
|
|
|
+
|
|
|
+ /*boolean flag = blockChainUtil.sendBlockChain(user.getSign());//发送签名直接转发到区块链
|
|
|
+ if(!flag) {
|
|
|
+ throw new RuntimeException("区块链操作失败2");
|
|
|
+ }*/
|
|
|
+
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 批量删除
|
|
|
- */
|
|
|
+
|
|
|
+ /**
|
|
|
+ ** 批量删除【删除】----------TODO
|
|
|
+ */
|
|
|
@Override
|
|
|
@Transactional(rollbackFor=Exception.class)
|
|
|
public void deleteFromUserId(String userIds) {
|
|
|
- String[] strs=userIds.split(",");
|
|
|
- userMapper.deleteFromUserId(strs);
|
|
|
+ String[] strs=userIds.split(",");
|
|
|
+ userMapper.deleteFromUserId(strs);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据用户id查询用户是否存在
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public List<User> findUserById(User user) {
|
|
|
+ return userMapper.findUserById(user);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<User> findUserByuserIdandusername(User user){
|
|
|
+ return userMapper.findUserByuserIdandusername(user);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -102,6 +150,5 @@ public class UserServiceImpl implements UserService {
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
}
|