4.1.23 中建主数据同步添加更新存量用户错误手机号

platomix-gmetry-system-api/pom.xml

@@ -10,7 +10,7 @@
     <!--    日期和版本号需要同时升级-->
     <!--    4.2.64-2024.07.22->4.2.65-2024.07.22->4.2.66-2024.07.23-->
     <artifactId>platomix-gmetry-system-api</artifactId>
-    <version>4.1.22-20241226</version>
+    <version>4.1.23-20241226</version>
     <dependencies>
         <dependency>
             <groupId>com.platomix</groupId>

platomix-gmetry-system-api/src/main/java/org/springblade/zhonnjian/task/FileToOssMonthTask.java

@@ -53,8 +53,9 @@ public class FileToOssMonthTask {
 
 
 
-    //@Scheduled(cron = "0 0 1 * * ?")  // 每天凌晨1:00执行
-    @Scheduled(fixedRate = 10000000)
+
+    //@Scheduled(fixedRate = 10000000)
+    @Scheduled(cron = "0 0 1 * * ?")  // 每天凌晨1:00执行
     public void syncDeptAndUserFromMdm() {
         String startTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
         log.info("开始同步MDM组织架构数据，开始时间：{}", startTime);
@@ -232,22 +233,9 @@ public class FileToOssMonthTask {
                 String thirdUserId = userJson.getString("USER_ID");
                 String deptCode = userJson.getString("DEPT"); // 部门的MDM编码
                 String credentialNo = userJson.getString("CREDENTIAL_NO"); //身份证号
-                try {
-                    //花名册同步手机号
-                    /*if(StringUtils.isNotBlank(credentialNo)){
-                        UserInfoHuamingce one = userInfoHuamingceService.getOne(new LambdaQueryWrapper<UserInfoHuamingce>()
-                                .eq(UserInfoHuamingce::getZhengJianHaoma, credentialNo)
-                        );
-                        if(one != null && !phoneNum.equals(one.getShouJihao())){
-                            String shouJihao = one.getShouJihao();
-                            one.setShouJihao(phoneNum);;
-                            boolean update = userInfoHuamingceService.updateById(one);
-                            if(update){
-                                log.info("花名册人员{}手机号更新，原手机号: {} ,现手机号：{}", one.getYuanGongXingming(),shouJihao,phoneNum);
-                            }
-                        }
-                    }*/
+                String phoneNum = userJson.getString("PHONE_NUM"); //手机号
 
+                try {
                     // 查询现有用户
                     BladeUser existingUser = bladeUserService.getOne(new LambdaQueryWrapper<BladeUser>()
                             .eq(BladeUser::getThirdUserId, thirdUserId)
@@ -297,6 +285,20 @@ public class FileToOssMonthTask {
                             }
                         }
 
+                        // 更新用户账号信息及手机号信息
+                        if (!phoneNum.equals(existingUser.getAccount())) {
+                            // 更新用户身份证信息
+                            boolean updated = bladeUserService.lambdaUpdate()
+                                    .eq(BladeUser::getId, existingUser.getId())
+                                    .eq(BladeUser::getIsDeleted, 0)
+                                    .set(BladeUser::getAccount, phoneNum)
+                                    .set(BladeUser::getPhone, phoneNum)
+                                    .update();
+                            if (updated) {
+                                log.info("更新用户[{}] 的账号及手机号：原手机号 = {}，现手机号 = {}", existingUser.getName(),existingUser.getAccount(),phoneNum);
+                            }
+                        }
+
                         // 检查并更新部门关系
                         BladeUserDept userDept = bladeUserDeptService.getOne(new LambdaQueryWrapper<BladeUserDept>()
                                 .eq(BladeUserDept::getUserId, existingUser.getId().toString())