新单跟进v2

yd-csf-api/src/main/java/com/yd/csf/api/controller/ApiPolicyFollowController.java

@@ -721,12 +721,13 @@ public class ApiPolicyFollowController {
     /**
      * 查询保单号列表
      *
+     * @param policyNo 保单号
      * @return 保单号列表
      */
     @GetMapping("/policyNos")
     @Operation(summary = "查询保单号列表")
-    public Result<List<String>> queryPolicyNumbers() {
-        List<String> policyNumbers = policyFollowService.queryPolicyNumbers();
+    public Result<List<String>> queryPolicyNumbers(@RequestParam String policyNo) {
+        List<String> policyNumbers = policyFollowService.queryPolicyNumbers(policyNo);
         return Result.success(policyNumbers);
     }
 }
\ No newline at end of file

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

@@ -770,6 +770,8 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     }
 
     private void savePolicyBroker(String fnaBizId, String policyBizId) {
+        log.info("同步保存保单转介人, fnaBizId: {}, policyBizId: {}", fnaBizId, policyBizId);
+
         FnaForm fnaForm = fnaFormService.getByFnaFormBizId(fnaBizId);
         if (Objects.isNull(fnaForm)) {
             return;
@@ -779,6 +781,8 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
             List<PolicyBroker> brokerList = GSONUtil.fromJson((String) fnaForm.getBrokerList(), new TypeToken<List<PolicyBroker>>() {
             }.getType());
 
+            log.info("转介人列表: {}", brokerList);
+
             if (ObjectUtils.isNotEmpty(brokerList)) {
                 if (brokerList.get(0) != null && !Objects.isNull(brokerList.get(0).getPolicyBizId())) {
                     // 先删除旧的转介人

yd-csf-service/src/main/java/com/yd/csf/service/service/PolicyFollowService.java

@@ -75,5 +75,11 @@ public interface PolicyFollowService extends IService<PolicyFollow> {
      */
     Boolean batchSaveBrokers(BrokerBatchSaveRequest brokerBatchSaveRequest);
 
-    List<String> queryPolicyNumbers();
+    /**
+     * 查询保单号列表
+     *
+     * @param policyNo 保单号
+     * @return 保单号列表
+     */
+    List<String> queryPolicyNumbers(String policyNo);
 }

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

@@ -814,11 +814,12 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
     }
 
     @Override
-    public List<String> queryPolicyNumbers() {
-        return policyFollowService.lambdaQuery()
-                .select(PolicyFollow::getPolicyNo)
-                .isNotNull(PolicyFollow::getPolicyNo)
-                .list()
+    public List<String> queryPolicyNumbers(String policyNo) {
+        QueryWrapper<PolicyFollow> queryWrapper = new QueryWrapper<>();
+        queryWrapper.select("policyNo");
+        queryWrapper.like(ObjectUtils.isNotEmpty(policyNo), "policy_no", policyNo);
+        queryWrapper.isNotNull("policy_no");
+        return policyFollowService.list(queryWrapper)
                 .stream()
                 .map(PolicyFollow::getPolicyNo)
                 .collect(Collectors.toList());