新单跟进同步预约信息6

yd-csf-service/src/main/java/com/yd/csf/service/dto/PolicyFollowDto.java

@@ -152,6 +152,9 @@ public class PolicyFollowDto implements Serializable {
     @Schema(description = "对账公司")
     private String reconciliationCompany;
 
+    @Schema(description = "对账公司编码")
+    private String reconciliationCode;
+
     @Schema(description = "对账公司业务id")
     private String reconciliationCompanyBizId;
 

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

@@ -241,6 +241,11 @@ public class PolicyFollow implements Serializable {
     private String reconciliationCompany;
 
     /**
+     * 对账公司编码
+     */
+    private String reconciliationCompanyCode;
+
+    /**
      * 对账公司业务id
      */
     private String reconciliationCompanyBizId;

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

@@ -89,6 +89,8 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
     private FnaService fnaService;
     @Resource
     private ApiInsuranceReconciliationCompanyFeignClient apiInsuranceReconciliationCompanyFeignClient;
+    @Resource
+    private CustomerService customerService;
 
 
     @Override
@@ -199,6 +201,9 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
 
         // 复制属性，排除系统字段
         BeanUtils.copyProperties(policyFollowDto, policyFollow, "id", "policyBizId", "brokerList");
+        if (StringUtils.isNotBlank(policyFollowDto.getReconciliationCode())) {
+            policyFollow.setReconciliationCompanyCode(policyFollowDto.getReconciliationCode());
+        }
 
         // 检查保单号是否从空变为有值
         String oldPolicyNo = policyFollow.getPolicyNo();
@@ -493,6 +498,7 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             policy.setPaymentTerm(policyFollow.getIssueNumber());
             policy.setUnderwritingDate(changePolicyFollowStatusRequest.getUnderwritingDate());
             policy.setEffectiveDate(changePolicyFollowStatusRequest.getEffectiveDate());
+            policy.setPolicyHolderAge(calculatePolicyHolderAge(policyFollow.getCustomerBizId()));
 
             if (ObjectUtils.isEmpty(policy.getInsuranceCompany()) || ObjectUtils.isEmpty(policy.getReconciliationCompanyBizId())) {
                 // 获取保单产品信息，填充对账公司相关字段
@@ -541,6 +547,18 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         return true;
     }
 
+    private Integer calculatePolicyHolderAge(String customerBizId) {
+        Customer customer = customerService.getByCustomerBizId(customerBizId);
+        if (customer == null) {
+            throw new BusinessException("客户不存在");
+        }
+        if (customer.getBirthday() == null) {
+            throw new BusinessException("客户生日不能为空");
+        }
+        // 根据生日计算年龄
+        return DateUtil.ageOfNow(customer.getBirthday());
+    }
+
     /**
      * 调用对账公司 feignclient，查询对账公司编码
      */