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 | 153 ++++++++++++++++++++++++++------------------------
1 files changed, 80 insertions(+), 73 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 5add3ac..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,6 +123,42 @@
{
return userMapper.selectUserByPhonenumber(phonenumber);
}
+
+ /**
+ * 閫氳繃寰俊OpenID鏌ヨ鐢ㄦ埛
+ *
+ * @param openId 寰俊OpenID
+ * @return 鐢ㄦ埛瀵硅薄淇℃伅
+ */
+ @Override
+ public SysUser selectUserByOpenId(String openId)
+ {
+ return userMapper.selectUserByOpenId(openId);
+ }
+
+ /**
+ * 閫氳繃浼佷笟寰俊鐢ㄦ埛ID鏌ヨ鐢ㄦ埛
+ *
+ * @param qyWechatUserId 浼佷笟寰俊鐢ㄦ埛ID
+ * @return 鐢ㄦ埛瀵硅薄淇℃伅
+ */
+ @Override
+ public SysUser selectUserByQyWechatUserId(String qyWechatUserId)
+ {
+ return userMapper.selectUserByQyWechatUserId(qyWechatUserId);
+ }
+
+ /**
+ * 鏍规嵁oaUserId鏌ヨ鐢ㄦ埛
+ *
+ * @param oaUserId SQL Server涓殑OA鐢ㄦ埛ID
+ * @return 鐢ㄦ埛淇℃伅
+ */
+ @Override
+ public SysUser selectUserByOaUserId(Integer oaUserId)
+ {
+ return userMapper.selectUserByOaUserId(oaUserId);
+ }
/**
* 閫氳繃鐢ㄦ埛ID鏌ヨ鐢ㄦ埛
@@ -154,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);
}
/**
@@ -181,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());
@@ -199,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());
@@ -217,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());
@@ -409,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();
@@ -420,7 +452,10 @@
up.setPostId(postId);
list.add(up);
}
- userPostMapper.batchUserPost(list);
+ if (list.size() > 0)
+ {
+ userPostMapper.batchUserPost(list);
+ }
}
}
@@ -432,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();
@@ -443,7 +478,10 @@
ur.setRoleId(roleId);
list.add(ur);
}
- userRoleMapper.batchUserRole(list);
+ if (list.size() > 0)
+ {
+ userRoleMapper.batchUserRole(list);
+ }
}
}
@@ -477,7 +515,6 @@
for (Long userId : userIds)
{
checkUserAllowed(new SysUser(userId));
- checkUserDataScope(userId);
}
// 鍒犻櫎鐢ㄦ埛涓庤鑹插叧鑱�
userRoleMapper.deleteUserRole(userIds);
@@ -505,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
@@ -514,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() + " 鏇存柊鎴愬姛");
}
@@ -609,4 +592,28 @@
}
return successMsg.toString();
}
-}
+
+ /**
+ * 鏍规嵁鍒嗗叕鍙窱D鍒楄〃鏌ヨ鐢ㄦ埛锛堝寘鍚垎鍏徃鍙婂叾鎵�鏈夊瓙閮ㄩ棬鐨勭敤鎴凤級
+ *
+ * @param branchDeptIds 鍒嗗叕鍙窱D鍒楄〃
+ * @return 鐢ㄦ埛鍒楄〃
+ */
+ @Override
+ public List<SysUser> selectUsersByBranchDeptIds(List<Long> branchDeptIds)
+ {
+ 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