push

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

@@ -13,8 +13,10 @@ import com.yd.csf.feign.request.policyreceipt.ApiPolicyReceiptPageRequest;
 import com.yd.csf.feign.response.policyreceipt.ApiPolicyReceiptDetailResponse;
 import com.yd.csf.feign.response.policyreceipt.ApiPolicyReceiptDetailResponse;
 import com.yd.csf.feign.response.policyreceipt.ApiPolicyReceiptPageResponse;
 import com.yd.csf.feign.response.policyreceipt.ApiPolicyReceiptPageResponse;
 import com.yd.csf.service.model.Policy;
 import com.yd.csf.service.model.Policy;
+import com.yd.csf.service.model.PolicyFollow;
 import com.yd.csf.service.model.PolicyReceipt;
 import com.yd.csf.service.model.PolicyReceipt;
 import com.yd.csf.service.service.IPolicyReceiptService;
 import com.yd.csf.service.service.IPolicyReceiptService;
+import com.yd.csf.service.service.PolicyFollowService;
 import com.yd.csf.service.service.PolicyService;
 import com.yd.csf.service.service.PolicyService;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -24,8 +26,10 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.CollectionUtils;
 
 
+import java.time.ZoneId;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.Objects;
 import java.util.Objects;
 
 
 @Slf4j
 @Slf4j
@@ -38,6 +42,9 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
     @Autowired
     @Autowired
     private PolicyService policyService;
     private PolicyService policyService;
 
 
+    @Autowired
+    private PolicyFollowService policyFollowService;
+
     /**
     /**
      * 分页列表查询-保单回执信息
      * 分页列表查询-保单回执信息
      * @param request
      * @param request
@@ -94,6 +101,10 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
         policyReceipt.setReceiptStatus(request.getReceiptStatus());
         policyReceipt.setReceiptStatus(request.getReceiptStatus());
         policyReceipt.setPolicyHolderSignature(!CollectionUtils.isEmpty(request.getPolicyHolderSignatureList()) ? String.join(";", request.getPolicyHolderSignatureList()) : "");
         policyReceipt.setPolicyHolderSignature(!CollectionUtils.isEmpty(request.getPolicyHolderSignatureList()) ? String.join(";", request.getPolicyHolderSignatureList()) : "");
         iPolicyReceiptService.saveOrUpdate(policyReceipt);
         iPolicyReceiptService.saveOrUpdate(policyReceipt);
+
+        //更新新单跟进回执信息
+        updateReceiptToPolicyFollow(policyReceipt);
+
         return Result.success();
         return Result.success();
     }
     }
 
 
@@ -120,6 +131,10 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
         policyReceipt.setReceiptStatus(request.getReceiptStatus());
         policyReceipt.setReceiptStatus(request.getReceiptStatus());
         policyReceipt.setPolicyHolderSignature(!CollectionUtils.isEmpty(request.getPolicyHolderSignatureList()) ? String.join(";", request.getPolicyHolderSignatureList()) : "");
         policyReceipt.setPolicyHolderSignature(!CollectionUtils.isEmpty(request.getPolicyHolderSignatureList()) ? String.join(";", request.getPolicyHolderSignatureList()) : "");
         iPolicyReceiptService.saveOrUpdate(policyReceipt);
         iPolicyReceiptService.saveOrUpdate(policyReceipt);
+
+        //更新新单跟进回执信息
+        updateReceiptToPolicyFollow(policyReceipt);
+
         return Result.success();
         return Result.success();
     }
     }
 
 
@@ -141,4 +156,27 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
         return Result.success();
         return Result.success();
     }
     }
 
 
+    /**
+     * 更新新单跟进信息的回执信息
+     * @param policyReceipt
+     * @return
+     */
+    public Result updateReceiptToPolicyFollow(PolicyReceipt policyReceipt) {
+        PolicyFollow policyFollow = policyFollowService.queryOneByPolicyNo(policyReceipt.getPolicyNo());
+        if (policyFollow == null) {
+            throw new BusinessException("新单跟进信息不存在");
+        }
+        if ("CONFIRMED".equals(policyReceipt.getReceiptStatus())) {
+            //回执状态为已确认时，更新新单跟进信息的回执状态和回执日期
+            policyFollow.setReceiptStatus(policyReceipt.getReceiptStatus());
+            policyFollow.setReceiptDate(policyReceipt.getReceiptDate() != null ? Date.from(policyReceipt.getReceiptDate().atZone(ZoneId.systemDefault()).toInstant()) : null);
+        }else if ("UNCONFIRMED".equals(policyReceipt.getReceiptStatus())) {
+            //回执状态为未确认时，更新新单跟进信息的回执状态
+            policyFollow.setReceiptStatus(policyReceipt.getReceiptStatus());
+            policyFollow.setReceiptDate(null);
+        }
+        policyFollowService.saveOrUpdate(policyFollow);
+        return Result.success();
+    }
+
 }
 }