From 8cb5d3440208a3be3e772e65f1bd0ec63031ba62 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期三, 17 十二月 2025 08:37:14 +0800
Subject: [PATCH] feat: 增加服务单派发通知
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java | 133 ++++++++++++++-----------------------------
1 files changed, 44 insertions(+), 89 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
index ddc34de..e94af7a 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SysUserServiceImpl.java
@@ -28,7 +28,6 @@
import com.ruoyi.system.mapper.SysUserPostMapper;
import com.ruoyi.system.mapper.SysUserRoleMapper;
import com.ruoyi.system.service.ISysConfigService;
-import com.ruoyi.system.service.ISysDeptService;
import com.ruoyi.system.service.ISysUserService;
/**
@@ -58,9 +57,6 @@
@Autowired
private ISysConfigService configService;
-
- @Autowired
- private ISysDeptService deptService;
@Autowired
protected Validator validator;
@@ -127,18 +123,6 @@
{
return userMapper.selectUserByPhonenumber(phonenumber);
}
-
- /**
- * 閫氳繃鐢ㄦ埛ID鏌ヨ鐢ㄦ埛
- *
- * @param userId 鐢ㄦ埛ID
- * @return 鐢ㄦ埛瀵硅薄淇℃伅
- */
- @Override
- public SysUser selectUserById(Long userId)
- {
- return userMapper.selectUserById(userId);
- }
/**
* 閫氳繃寰俊OpenID鏌ヨ鐢ㄦ埛
@@ -177,6 +161,18 @@
}
/**
+ * 閫氳繃鐢ㄦ埛ID鏌ヨ鐢ㄦ埛
+ *
+ * @param userId 鐢ㄦ埛ID
+ * @return 鐢ㄦ埛瀵硅薄淇℃伅
+ */
+ @Override
+ public SysUser selectUserById(Long userId)
+ {
+ return userMapper.selectUserById(userId);
+ }
+
+ /**
* 鏌ヨ鐢ㄦ埛鎵�灞炶鑹茬粍
*
* @param userName 鐢ㄦ埛鍚�
@@ -190,7 +186,7 @@
{
return StringUtils.EMPTY;
}
- return list.stream().map(SysRole::getRoleName).collect(Collectors.joining(","));
+ return list.stream().map(SysRole::getRoleName).reduce((x, y) -> x + "," + y).orElse(StringUtils.EMPTY);
}
/**
@@ -217,7 +213,7 @@
* @return 缁撴灉
*/
@Override
- public boolean checkUserNameUnique(SysUser user)
+ public Boolean checkUserNameUnique(SysUser user)
{
Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
SysUser info = userMapper.checkUserNameUnique(user.getUserName());
@@ -235,7 +231,7 @@
* @return
*/
@Override
- public boolean checkPhoneUnique(SysUser user)
+ public Boolean checkPhoneUnique(SysUser user)
{
Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
SysUser info = userMapper.checkPhoneUnique(user.getPhonenumber());
@@ -253,7 +249,7 @@
* @return
*/
@Override
- public boolean checkEmailUnique(SysUser user)
+ public Boolean checkEmailUnique(SysUser user)
{
Long userId = StringUtils.isNull(user.getUserId()) ? -1L : user.getUserId();
SysUser info = userMapper.checkEmailUnique(user.getEmail());
@@ -445,10 +441,10 @@
public void insertUserPost(SysUser user)
{
Long[] posts = user.getPostIds();
- if (StringUtils.isNotEmpty(posts))
+ if (StringUtils.isNotNull(posts))
{
// 鏂板鐢ㄦ埛涓庡矖浣嶇鐞�
- List<SysUserPost> list = new ArrayList<SysUserPost>(posts.length);
+ List<SysUserPost> list = new ArrayList<SysUserPost>();
for (Long postId : posts)
{
SysUserPost up = new SysUserPost();
@@ -456,7 +452,10 @@
up.setPostId(postId);
list.add(up);
}
- userPostMapper.batchUserPost(list);
+ if (list.size() > 0)
+ {
+ userPostMapper.batchUserPost(list);
+ }
}
}
@@ -468,10 +467,10 @@
*/
public void insertUserRole(Long userId, Long[] roleIds)
{
- if (StringUtils.isNotEmpty(roleIds))
+ if (StringUtils.isNotNull(roleIds))
{
// 鏂板鐢ㄦ埛涓庤鑹茬鐞�
- List<SysUserRole> list = new ArrayList<SysUserRole>(roleIds.length);
+ List<SysUserRole> list = new ArrayList<SysUserRole>();
for (Long roleId : roleIds)
{
SysUserRole ur = new SysUserRole();
@@ -479,7 +478,10 @@
ur.setRoleId(roleId);
list.add(ur);
}
- userRoleMapper.batchUserRole(list);
+ if (list.size() > 0)
+ {
+ userRoleMapper.batchUserRole(list);
+ }
}
}
@@ -513,7 +515,6 @@
for (Long userId : userIds)
{
checkUserAllowed(new SysUser(userId));
- checkUserDataScope(userId);
}
// 鍒犻櫎鐢ㄦ埛涓庤鑹插叧鑱�
userRoleMapper.deleteUserRole(userIds);
@@ -541,6 +542,7 @@
int failureNum = 0;
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
+ String password = configService.selectConfigByKey("sys.user.initPassword");
for (SysUser user : userList)
{
try
@@ -550,73 +552,18 @@
if (StringUtils.isNull(u))
{
BeanValidators.validateWithException(validator, user);
- deptService.checkDeptDataScope(user.getDeptId());
-
- // 鏍￠獙鎵嬫満鍙峰敮涓�鎬�
- if (StringUtils.isNotEmpty(user.getPhonenumber()))
- {
- SysUser phoneCheck = userMapper.checkPhoneUnique(user.getPhonenumber());
- if (StringUtils.isNotNull(phoneCheck))
- {
- failureNum++;
- failureMsg.append("<br/>" + failureNum + "銆佽处鍙� " + user.getUserName() + " 瀵煎叆澶辫触锛氭墜鏈哄彿鐮� " + user.getPhonenumber() + " 宸茶鐢ㄦ埛 " + phoneCheck.getUserName() + " 浣跨敤");
- continue;
- }
- }
-
- // 鏍￠獙閭鍞竴鎬�
- if (StringUtils.isNotEmpty(user.getEmail()))
- {
- SysUser emailCheck = userMapper.checkEmailUnique(user.getEmail());
- if (StringUtils.isNotNull(emailCheck))
- {
- failureNum++;
- failureMsg.append("<br/>" + failureNum + "銆佽处鍙� " + user.getUserName() + " 瀵煎叆澶辫触锛氶偖绠� " + user.getEmail() + " 宸茶鐢ㄦ埛 " + emailCheck.getUserName() + " 浣跨敤");
- continue;
- }
- }
-
- String password = configService.selectConfigByKey("sys.user.initPassword");
user.setPassword(SecurityUtils.encryptPassword(password));
user.setCreateBy(operName);
- userMapper.insertUser(user);
+ this.insertUser(user);
successNum++;
successMsg.append("<br/>" + successNum + "銆佽处鍙� " + user.getUserName() + " 瀵煎叆鎴愬姛");
}
else if (isUpdateSupport)
{
BeanValidators.validateWithException(validator, user);
- checkUserAllowed(u);
- checkUserDataScope(u.getUserId());
- deptService.checkDeptDataScope(user.getDeptId());
-
- // 鏍￠獙鎵嬫満鍙峰敮涓�鎬э紙鎺掗櫎鑷繁锛�
- if (StringUtils.isNotEmpty(user.getPhonenumber()))
- {
- SysUser phoneCheck = userMapper.checkPhoneUnique(user.getPhonenumber());
- if (StringUtils.isNotNull(phoneCheck) && !phoneCheck.getUserId().equals(u.getUserId()))
- {
- failureNum++;
- failureMsg.append("<br/>" + failureNum + "銆佽处鍙� " + user.getUserName() + " 鏇存柊澶辫触锛氭墜鏈哄彿鐮� " + user.getPhonenumber() + " 宸茶鐢ㄦ埛 " + phoneCheck.getUserName() + " 浣跨敤");
- continue;
- }
- }
-
- // 鏍￠獙閭鍞竴鎬э紙鎺掗櫎鑷繁锛�
- if (StringUtils.isNotEmpty(user.getEmail()))
- {
- SysUser emailCheck = userMapper.checkEmailUnique(user.getEmail());
- if (StringUtils.isNotNull(emailCheck) && !emailCheck.getUserId().equals(u.getUserId()))
- {
- failureNum++;
- failureMsg.append("<br/>" + failureNum + "銆佽处鍙� " + user.getUserName() + " 鏇存柊澶辫触锛氶偖绠� " + user.getEmail() + " 宸茶鐢ㄦ埛 " + emailCheck.getUserName() + " 浣跨敤");
- continue;
- }
- }
-
user.setUserId(u.getUserId());
user.setUpdateBy(operName);
- userMapper.updateUser(user);
+ this.updateUser(user);
successNum++;
successMsg.append("<br/>" + successNum + "銆佽处鍙� " + user.getUserName() + " 鏇存柊鎴愬姛");
}
@@ -655,10 +602,18 @@
@Override
public List<SysUser> selectUsersByBranchDeptIds(List<Long> branchDeptIds)
{
- if (branchDeptIds == null || branchDeptIds.isEmpty()) {
- return new ArrayList<>();
- }
-
return userMapper.selectUsersByBranchDeptIds(branchDeptIds);
}
-}
+
+ /**
+ * 鏍规嵁serviceOrderClass鎴杁ispatchOrderClass鏌ヨ鍏锋湁canViewAllConsult鏉冮檺鐨勭敤鎴�
+ *
+ * @param orderClass serviceOrderClass鎴杁ispatchOrderClass
+ * @return 鐢ㄦ埛鍒楄〃
+ */
+ @Override
+ public List<SysUser> selectUsersByOrderClassAndCanViewAllConsult(String orderClass)
+ {
+ return userMapper.selectUsersByOrderClassAndCanViewAllConsult(orderClass);
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.1