部门数据同步逻辑优化

duty-service/src/main/java/cn/com/taiji/duty/task/TimeTask.java

@@ -357,6 +357,7 @@ public class TimeTask {
 
         List<String> stringList = dutyRoleAccounts.parallelStream().map(DutyRoleAccount::getUdAccountUuid).filter(Objects::nonNull).distinct().collect(Collectors.toList());
         List<DutyAccount> accounts = new ArrayList<>();
+        List<DutyAccount> accountList = new ArrayList<>();
         // 用户信息请求
         stringList.forEach(t -> {
             ResponseEntity<JSONObject> responseEntity = restTemplate.exchange(idaasUrlPrefix + userInfoApi + "?userUuid=" + t, HttpMethod.GET, entity, JSONObject.class);
@@ -370,12 +371,13 @@ public class TimeTask {
             } else {
                 accounts.add(account);
             }
+            accountList.add(account);
         });
         if (accounts.size() > 0) {
             accountService.saveBatch(accounts);
         }
 
-        List<String> collect = accounts.parallelStream().map(DutyAccount::getOuUuid).filter(Objects::nonNull).distinct().collect(Collectors.toList());
+        List<String> collect = accountList.parallelStream().map(DutyAccount::getOuUuid).filter(Objects::nonNull).distinct().collect(Collectors.toList());
         List<DutyDepartment> departments = new ArrayList<>();
         // 用户信息请求
         collect.forEach(f -> {