push

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/PolicyFollowServiceImpl.java

@@ -1349,6 +1349,9 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         // 2. 更新受保人表
         updateInsurantNameFields(pageSize);
 
+        // 3. 更新客户表
+        updateInsurantNameFields(pageSize);
+
         log.info("投保人/受保人名字冗余字段更新完成");
         return Result.success("更新成功");
     }
@@ -1446,5 +1449,51 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             pageNo++;
         }
     }
+
+    /**
+     * 批量处理 customer 的 nameSc 和 nameEnLc
+     */
+    private void updateCustomerNameFields(int pageSize) {
+        int pageNo = 1;
+        while (true) {
+            Page<Customer> page = new Page<>(pageNo, pageSize);
+            Page<Customer> resultPage = customerService.page(page);
+            List<Customer> records = resultPage.getRecords();
+            if (CollUtil.isEmpty(records)) {
+                break;
+            }
+
+            List<Customer> toUpdate = new ArrayList<>();
+            for (Customer entity : records) {
+                boolean changed = false;
+
+                if (StringUtils.isNotBlank(entity.getNameCn())) {
+                    String nameSc = ChineseTextConverter.traditionalToSimplified(entity.getNameCn());
+                    if (!nameSc.equals(entity.getNameSc())) {
+                        entity.setNameSc(nameSc);
+                        changed = true;
+                    }
+                }
+
+                if (StringUtils.isNotBlank(entity.getNamePyEn())) {
+                    String nameEnLc = EnglishTextUtil.toLowerCase(entity.getNamePyEn());
+                    if (!nameEnLc.equals(entity.getNameEnLc())) {
+                        entity.setNameEnLc(nameEnLc);
+                        changed = true;
+                    }
+                }
+
+                if (changed) {
+                    entity.setUpdateTime(new Date());
+                    toUpdate.add(entity);
+                }
+            }
+
+            if (!toUpdate.isEmpty()) {
+                customerService.updateBatchById(toUpdate);
+            }
+            pageNo++;
+        }
+    }
 }