From 3794effa1e9e78e82e81253d6a6d54ad6db89b7e Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期六, 16 十二月 2023 17:07:07 +0800
Subject: [PATCH] 同步accoutId
---
ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java | 65 +++++++++++++++++---------------
1 files changed, 35 insertions(+), 30 deletions(-)
diff --git a/ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java b/ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java
index 941f271..dc42646 100644
--- a/ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java
+++ b/ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java
@@ -33,10 +33,7 @@
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Set;
+import java.util.*;
@Slf4j
@@ -72,7 +69,7 @@
@Autowired
private UmsAdminRoleRelationService umsAdminRoleRelationService;
- //@Scheduled(cron = "0 0 00 * * ?")
+ @Scheduled(cron = "40 50 16 * * ?")
@Transactional(rollbackFor = Exception.class)
public void run() {
log.info("寮�濮嬪悓姝ヤ换鍔�");
@@ -114,12 +111,14 @@
/**
// * 鏍规嵁缁勭粐code 鏌ヨ 閫氳褰曚汉鍛樹俊鎭�
// */
- Set<DingUserInfo> dingList = dingCommon.getPersonInfoByOrgCode();
- //鏌ヨ鎵�鏈夌敤鎴�
- List<UmsAdmin> userList = umsAdminService.list();
//鏌ヨ鐢ㄦ埛缁勭粐鍏宠仈琛�
List<UmsDepartManage> empOrgList = departManageService.list();
- Iterator<DingUserInfo> iterator = dingList.iterator();
+ //鏌ヨ鎵�鏈夌敤鎴�
+ Set<DingUserInfo> dingList = dingCommon.getPersonInfoByOrgCode();
+ Set<DingUserInfo> dingUsers = new HashSet<>(dingList);
+ log.info("dinglistStart----->{}",dingList);
+ List<UmsAdmin> userList = umsAdminService.list();
+ Iterator<DingUserInfo> iterator = dingUsers.iterator();
while (iterator.hasNext()) {
DingUserInfo dingUserInfo = iterator.next();
//鍒ゆ柇鐢ㄦ埛鏄惁瀛樺湪锛岃緭鍑烘柊鐢ㄦ埛
@@ -137,9 +136,12 @@
}
}
}
+
+
+ log.info("dinglistEnd----->{}",dingUsers);
ArrayList<UmsAdminRoleRelation> relations = new ArrayList<>();
// log.info(TAG + " elapsed time:" + timer.interval());
- for (DingUserInfo dingUserInfo : dingList) {
+ for (DingUserInfo dingUserInfo : dingUsers) {
//1.娣诲姞鐢ㄦ埛
UmsAdmin user = new UmsAdmin();
//璐﹀彿
@@ -151,6 +153,9 @@
user.setNickName(dingUserInfo.getEmployeeName());
}
//code
+ //accountId
+ log.info("鍛樺伐璐︽埛id{}",dingUserInfo.getAccountId());
+ user.setAccountId(dingUserInfo.getAccountId());
//澶村儚
user.setIcon(dingUserInfo.getGovEmpAvatar());
//濮撳悕
@@ -168,26 +173,26 @@
//鐘舵�佷负鍋滅敤锛堜笉鍙敤鐘舵�侊級鐐瑰嚮鐧诲綍鍚庢墠鑳戒娇鐢�
user.setStatus(1);
umsAdminService.save(user);
- //鍛樺伐淇℃伅锛屽叧鑱旂粍缁�
- UmsDepartManage departManage = new UmsDepartManage();
- departManage.setDepartId(dingUserInfo.getOrgId());
- departManage.setIsLeader(0);
- departManage.setUserId(dingUserInfo.getUserId());
- departManageService.saveOrUpdate(departManage);
- //瑙掕壊淇℃伅
- List<String> roleCode = dingUserInfo.getRoleCodeList();
- if (CollectionUtils.isNotEmpty(roleCode)) {
- List<UmsRole> roleList = roleService.getRoleListByCodes(roleCode);
- roleList.forEach(item -> {
- UmsAdminRoleRelation relation = new UmsAdminRoleRelation();
- relation.setAdminId(dingUserInfo.getUserId());
- relation.setRoleId(item.getId());
- relations.add(relation);
- });
- }
- }
- if (CollUtil.isNotEmpty(relations)) {
- umsAdminRoleRelationService.saveBatch(relations, IService.DEFAULT_BATCH_SIZE);
+// //鍛樺伐淇℃伅锛屽叧鑱旂粍缁�
+// UmsDepartManage departManage = new UmsDepartManage();
+// departManage.setDepartId(dingUserInfo.getOrgId());
+// departManage.setIsLeader(0);
+// departManage.setUserId(dingUserInfo.getUserId());
+// departManageService.saveOrUpdate(departManage);
+// //瑙掕壊淇℃伅
+// List<String> roleCode = dingUserInfo.getRoleCodeList();
+// if (CollectionUtils.isNotEmpty(roleCode)) {
+// List<UmsRole> roleList = roleService.getRoleListByCodes(roleCode);
+// roleList.forEach(item -> {
+// UmsAdminRoleRelation relation = new UmsAdminRoleRelation();
+// relation.setAdminId(dingUserInfo.getUserId());
+// relation.setRoleId(item.getId());
+// relations.add(relation);
+// });
+// }
+// }
+// if (CollUtil.isNotEmpty(relations)) {
+// umsAdminRoleRelationService.saveBatch(relations, IService.DEFAULT_BATCH_SIZE);
}
log.info("鍚屾浠诲姟缁撴潫");
// log.info(TAG + "update user size " + dingList.size());
--
Gitblit v1.8.0