From c64b5cd48be1fda8830e7ac881c843e0cafc93f9 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期六, 31 八月 2024 08:53:41 +0800
Subject: [PATCH] 添加批量更新用户
---
se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java | 8 ++++++++
se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java | 6 ++++--
se-modules/se-system/src/main/java/com/se/system/service/impl/SysUserServiceImpl.java | 17 +++++++++++------
3 files changed, 23 insertions(+), 8 deletions(-)
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
index 191be7b..b38cd56 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
@@ -40,6 +40,14 @@
}
}
+ public void updateUsers(List<SysUser> list) {
+ try {
+ System.out.println("updateUsers");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+
public void deleteUser(SysUser user) {
try {
System.out.println("deleteUser");
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
index e795be0..e76767c 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
@@ -43,8 +43,10 @@
});
}
- public void updateUserStatus(SysUser user) {
- updateUser(user);
+ public void updateUsers(List<SysUser> list) {
+ CompletableFuture.runAsync(() -> {
+ isimUserService.updateUsers(list);
+ });
}
public void deleteUser(SysUser user) {
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/SysUserServiceImpl.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/SysUserServiceImpl.java
index de8df48..7244cf4 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/SysUserServiceImpl.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/SysUserServiceImpl.java
@@ -318,7 +318,7 @@
public int updateUserStatus(SysUser user) {
int rows = userMapper.updateUser(user);
if (rows > 0) {
- syncUserService.updateUserStatus(user);
+ syncUserService.updateUser(user);
}
return rows;
}
@@ -483,9 +483,11 @@
}
int successNum = 0;
int failureNum = 0;
+ List<SysUser> insertList = new ArrayList<>();
+ List<SysUser> updateList = new ArrayList<>();
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
- List<SysUser> list = new ArrayList<>();
+
for (SysUser user : userList) {
try {
// 楠岃瘉鏄惁瀛樺湪杩欎釜鐢ㄦ埛
@@ -497,7 +499,7 @@
user.setPassword(SecurityUtils.encryptPassword(password));
user.setCreateBy(operName);
if (userMapper.insertUser(user) > 0) {
- list.add(user);
+ insertList.add(user);
}
successNum++;
successMsg.append("<br/>" + successNum + "銆佽处鍙� " + user.getUserName() + " 瀵煎叆鎴愬姛");
@@ -509,7 +511,7 @@
user.setUserId(u.getUserId());
user.setUpdateBy(operName);
if (userMapper.updateUser(user) > 0) {
- syncUserService.updateUser(user);
+ updateList.add(user);
}
successNum++;
successMsg.append("<br/>" + successNum + "銆佽处鍙� " + user.getUserName() + " 鏇存柊鎴愬姛");
@@ -524,8 +526,11 @@
log.error(msg, e);
}
}
- if (list.size() > 0) {
- syncUserService.insertUsers(list);
+ if (insertList.size() > 0) {
+ syncUserService.insertUsers(insertList);
+ }
+ if (updateList.size() > 0) {
+ syncUserService.updateUsers(updateList);
}
if (failureNum > 0) {
failureMsg.insert(0, "寰堟姳姝夛紝瀵煎叆澶辫触锛佸叡 " + failureNum + " 鏉℃暟鎹牸寮忎笉姝ｇ‘锛岄敊璇涓嬶細");
--
Gitblit v1.9.3