push

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentServiceImpl.java

@@ -710,6 +710,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
                 && !response.getApiAppointmentInfoDto().getUserSignDtoList().isEmpty()) {
             ApiAppointmentUserSignDto firstSigner = response.getApiAppointmentInfoDto().getUserSignDtoList().get(0);
             follow.setSigner(firstSigner.getName());
+            follow.setSignerSc(ChineseTextConverter.traditionalToSimplified(firstSigner.getName()));
             follow.setSignerBizId(firstSigner.getAppointmentUserSignBizId());
             follow.setPracticeCode(firstSigner.getPracticeCode());
         }

yd-csf-service/src/main/java/com/yd/csf/service/model/PolicyFollow.java

@@ -75,6 +75,11 @@ public class PolicyFollow implements Serializable {
     private String signer;
 
     /**
+     * 签单人（简体）
+     */
+    private String signerSc;
+
+    /**
      * 签单人业务id
      */
     private String signerBizId;

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

@@ -169,7 +169,7 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         }
         if (StringUtils.isNotEmpty(policyFollowQueryRequest.getInsured())) queryWrapper.like("insured", policyFollowQueryRequest.getInsured());
         //签单人
-        if (StringUtils.isNotEmpty(policyFollowQueryRequest.getSigner())) queryWrapper.like("signer", policyFollowQueryRequest.getSigner());
+        if (StringUtils.isNotEmpty(policyFollowQueryRequest.getSigner())) queryWrapper.like("signer_sc", ChineseTextConverter.traditionalToSimplified(policyFollowQueryRequest.getSigner()));
         //转介人（保单转介人表）
         if (StringUtils.isNotEmpty(policyFollowQueryRequest.getBrokerName())) {
             List<PolicyBroker> policyBrokerList = policyBrokerService.queryList(QueryPolicyBrokerDto.builder().brokerName(policyFollowQueryRequest.getBrokerName()).build());
@@ -379,6 +379,7 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         String loginUserId = currentLoginUser.getId().toString();
         policyFollow.setUpdaterId(loginUserId);
         policyFollow.setUpdateTime(new Date());
+        policyFollow.setSignerSc(ChineseTextConverter.traditionalToSimplified(policyFollowDto.getSigner()));
 
         try {
             boolean result = updateById(policyFollow);
@@ -1362,6 +1363,9 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         // 3. 更新客户表
         updateCustomerNameFields(pageSize);
 
+        // 4. 更新新单跟进表
+        updateSignerScFields(pageSize);
+
         log.info("投保人/受保人名字冗余字段更新完成");
         return Result.success("更新成功");
     }
@@ -1386,23 +1390,23 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
                 // 繁体 → 简体
                 if (StringUtils.isNotBlank(entity.getName())) {
                     String nameSc = ChineseTextConverter.traditionalToSimplified(entity.getName());
-                    if (!nameSc.equals(entity.getNameSc())) {
+//                    if (!nameSc.equals(entity.getNameSc())) {
                         entity.setNameSc(nameSc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 // 英文 → 小写
                 if (StringUtils.isNotBlank(entity.getNameEn())) {
                     String nameEnLc = EnglishTextUtil.toLowerCaseSafe(entity.getNameEn());
-                    if (!nameEnLc.equals(entity.getNameEnLc())) {
+//                    if (!nameEnLc.equals(entity.getNameEnLc())) {
                         entity.setNameEnLc(nameEnLc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 if (changed) {
-                    entity.setUpdateTime(new Date()); // 可选，记录更新时间
+//                    entity.setUpdateTime(new Date()); // 可选，记录更新时间
                     toUpdate.add(entity);
                 }
             }
@@ -1433,22 +1437,22 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
 
                 if (StringUtils.isNotBlank(entity.getName())) {
                     String nameSc = ChineseTextConverter.traditionalToSimplified(entity.getName());
-                    if (!nameSc.equals(entity.getNameSc())) {
+//                    if (!nameSc.equals(entity.getNameSc())) {
                         entity.setNameSc(nameSc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 if (StringUtils.isNotBlank(entity.getNameEn())) {
                     String nameEnLc = EnglishTextUtil.toLowerCaseSafe(entity.getNameEn());
-                    if (!nameEnLc.equals(entity.getNameEnLc())) {
+//                    if (!nameEnLc.equals(entity.getNameEnLc())) {
                         entity.setNameEnLc(nameEnLc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 if (changed) {
-                    entity.setUpdateTime(new Date());
+//                    entity.setUpdateTime(new Date());
                     toUpdate.add(entity);
                 }
             }
@@ -1479,22 +1483,22 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
 
                 if (StringUtils.isNotBlank(entity.getNameCn())) {
                     String nameSc = ChineseTextConverter.traditionalToSimplified(entity.getNameCn());
-                    if (!nameSc.equals(entity.getNameSc())) {
+//                    if (!nameSc.equals(entity.getNameSc())) {
                         entity.setNameSc(nameSc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 if (StringUtils.isNotBlank(entity.getNamePyEn())) {
                     String nameEnLc = EnglishTextUtil.toLowerCaseSafe(entity.getNamePyEn());
-                    if (!nameEnLc.equals(entity.getNameEnLc())) {
+//                    if (!nameEnLc.equals(entity.getNameEnLc())) {
                         entity.setNameEnLc(nameEnLc);
                         changed = true;
-                    }
+//                    }
                 }
 
                 if (changed) {
-                    entity.setUpdateTime(new Date());
+//                    entity.setUpdateTime(new Date());
                     toUpdate.add(entity);
                 }
             }
@@ -1505,5 +1509,41 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             pageNo++;
         }
     }
+
+    /**
+     * 批量处理 PolicyFollow 的 signerSc
+     */
+    private void updateSignerScFields(int pageSize) {
+        int pageNo = 1;
+        while (true) {
+            Page<PolicyFollow> page = new Page<>(pageNo, pageSize);
+            Page<PolicyFollow> resultPage = policyFollowService.page(page);
+            List<PolicyFollow> records = resultPage.getRecords();
+            if (CollUtil.isEmpty(records)) {
+                break;
+            }
+
+            List<PolicyFollow> toUpdate = new ArrayList<>();
+            for (PolicyFollow entity : records) {
+                boolean changed = false;
+
+                if (StringUtils.isNotBlank(entity.getSigner())) {
+                    String nameSc = ChineseTextConverter.traditionalToSimplified(entity.getSigner());
+                    entity.setSignerSc(nameSc);
+                    changed = true;
+                }
+
+                if (changed) {
+//                    entity.setUpdateTime(new Date());
+                    toUpdate.add(entity);
+                }
+            }
+
+            if (!toUpdate.isEmpty()) {
+                policyFollowService.updateBatchById(toUpdate);
+            }
+            pageNo++;
+        }
+    }
 }