| | |
| | | * @return 同步结果 |
| | | */ |
| | | @Override |
| | | @Transactional |
| | | |
| | | public AjaxResult syncOaUsers(List<UserSyncDTO> oaUsers) |
| | | { |
| | | try |
| | |
| | | return AjaxResult.warn("传入的用户数据为空"); |
| | | } |
| | | |
| | | log.info("开始同步 {} 条OA用户数据到 MySQL 数据库...", oaUsers.size()); |
| | | // log.info("开始同步 {} 条OA用户数据到 MySQL 数据库...", oaUsers.size()); |
| | | |
| | | int createdCount = 0; |
| | | int updatedCount = 0; |
| | |
| | | // 用户已存在,更新信息 |
| | | updateExistingUser(existingUser, dto, deptId); |
| | | updatedCount++; |
| | | log.info("更新用户: {} ({}), oaUserId: {}", |
| | | dto.getNickName(), dto.getUserName(), dto.getOaUserId()); |
| | | // log.info("更新用户: {} ({}), oaUserId: {}", |
| | | // dto.getNickName(), dto.getUserName(), dto.getOaUserId()); |
| | | } |
| | | else |
| | | { |
| | |
| | | userByName.setUpdateBy("sync"); |
| | | sysUserMapper.updateUser(userByName); |
| | | updatedCount++; |
| | | log.info("更新已存在用户名的用户: {} ({}), 设置oaUserId: {}", |
| | | dto.getNickName(), dto.getUserName(), dto.getOaUserId()); |
| | | // log.info("更新已存在用户名的用户: {} ({}), 设置oaUserId: {}", |
| | | // dto.getNickName(), dto.getUserName(), dto.getOaUserId()); |
| | | } |
| | | else |
| | | { |
| | | // 创建新用户 |
| | | createNewUser(dto, deptId); |
| | | createdCount++; |
| | | log.info("创建新用户: {} ({}), oaUserId: {}, deptId: {}", |
| | | dto.getNickName(), dto.getUserName(), dto.getOaUserId(), deptId); |
| | | // log.info("创建新用户: {} ({}), oaUserId: {}, deptId: {}", |
| | | // dto.getNickName(), dto.getUserName(), dto.getOaUserId(), deptId); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | String message = String.format("同步完成!创建用户: %d, 更新用户: %d, 跳过: %d, 失败: %d", |
| | | createdCount, updatedCount, skippedCount, errorCount); |
| | | log.info(message); |
| | | // log.info(message); |
| | | |
| | | Map<String, Object> result = new HashMap<>(); |
| | | result.put("created", createdCount); |