添加批量更新用户

13693261870

2024-08-31 c64b5cd48be1fda8830e7ac881c843e0cafc93f9

添加批量更新用户

 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");

 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) {

 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 + " 条数据格式不正确，错误如下：");