Merge remote-tracking branch 'origin/test' into test

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

@@ -703,4 +703,192 @@ public class ApiPolicyFollowController {
             log.info("新单跟进-同步生成预计出账记录成功:保单号={}", policyNo);
             log.info("新单跟进-同步生成预计出账记录成功:保单号={}", policyNo);
         }
         }
     }
     }
+
+    /**
+     * 查询产品计划信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 产品计划信息
+     */
+    @GetMapping("/product_plan")
+    @Operation(summary = "查询产品计划信息")
+    public Result<Policy> getProductPlan(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        Policy policy = policyFollowService.getProductPlan(policyBizId);
+        if (policy == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "产品计划信息不存在");
+        }
+        return Result.success(policy);
+    }
+
+    /**
+     * 查询投保人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 投保人信息
+     */
+    @GetMapping("/policyholder")
+    @Operation(summary = "查询投保人信息")
+    public Result<PolicyPolicyholder> getPolicyPolicyholder(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        PolicyPolicyholder policyholder = policyFollowService.getPolicyPolicyholder(policyBizId);
+        if (policyholder == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "投保人信息不存在");
+        }
+        return Result.success(policyholder);
+    }
+
+    /**
+     * 查询受保人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 受保人信息
+     */
+    @GetMapping("/insurant")
+    @Operation(summary = "查询受保人信息")
+    public Result<PolicyInsurant> getPolicyInsurant(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        PolicyInsurant insurant = policyFollowService.getPolicyInsurant(policyBizId);
+        if (insurant == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "受保人信息不存在");
+        }
+        return Result.success(insurant);
+    }
+
+    /**
+     * 查询受益人列表
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 受益人列表
+     */
+    @GetMapping("/beneficiary")
+    @Operation(summary = "查询受益人列表")
+    public Result<List<PolicyBeneficiary>> getPolicyBeneficiaryList(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        List<PolicyBeneficiary> beneficiaryList = policyFollowService.getPolicyBeneficiaryList(policyBizId);
+        return Result.success(beneficiaryList);
+    }
+
+    /**
+     * 查询第二持有人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 第二持有人信息
+     */
+    @GetMapping("/second_holder")
+    @Operation(summary = "查询第二持有人信息")
+    public Result<PolicySecondHolder> getPolicySecondHolder(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        PolicySecondHolder secondHolder = policyFollowService.getPolicySecondHolder(policyBizId);
+        if (secondHolder == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "第二持有人信息不存在");
+        }
+        return Result.success(secondHolder);
+    }
+
+    /**
+     * 查询预约附件列表
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 预约附件列表
+     */
+    @GetMapping("/appointment_files")
+    @Operation(summary = "查询预约附件列表")
+    public Result<List<PolicyAppointmentFile>> getPolicyAppointmentFileList(@RequestParam("policyBizId") String policyBizId) {
+        if (StringUtils.isBlank(policyBizId)) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        List<PolicyAppointmentFile> fileList = policyFollowService.getPolicyAppointmentFileList(policyBizId);
+        return Result.success(fileList);
+    }
+
+    /**
+     * 更新产品计划信息
+     *
+     * @param policyUpdateRequest 产品计划更新请求
+     * @return 是否成功
+     */
+//    @PostMapping("/product_plan/update")
+//    @Operation(summary = "更新产品计划信息")
+//    @Transactional(rollbackFor = Exception.class)
+//    public Result<Boolean> updateProductPlan(@RequestBody PolicyUpdateRequest policyUpdateRequest) {
+//        if (policyUpdateRequest == null || StringUtils.isBlank(policyUpdateRequest.getPolicyBizId())) {
+//            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+//        }
+//        return Result.success(policyFollowService.updateProductPlan(policyUpdateRequest));
+//    }
+
+    /**
+     * 更新投保人信息
+     *
+     * @param policyPolicyholderUpdateRequest 投保人更新请求
+     * @return 是否成功
+     */
+    @PostMapping("/policyholder/update")
+    @Operation(summary = "更新投保人信息")
+    @Transactional(rollbackFor = Exception.class)
+    public Result<Boolean> updatePolicyPolicyholder(@RequestBody PolicyPolicyholderUpdateRequest policyPolicyholderUpdateRequest) {
+        if (policyPolicyholderUpdateRequest == null || StringUtils.isBlank(policyPolicyholderUpdateRequest.getPolicyPolicyholderBizId())) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyPolicyholderBizId不能为空");
+        }
+        return Result.success(policyFollowService.updatePolicyPolicyholder(policyPolicyholderUpdateRequest));
+    }
+
+    /**
+     * 更新受保人信息
+     *
+     * @param policyInsurantUpdateRequest 受保人更新请求
+     * @return 是否成功
+     */
+    @PostMapping("/insurant/update")
+    @Operation(summary = "更新受保人信息")
+    @Transactional(rollbackFor = Exception.class)
+    public Result<Boolean> updatePolicyInsurant(@RequestBody PolicyInsurantUpdateRequest policyInsurantUpdateRequest) {
+        if (policyInsurantUpdateRequest == null || StringUtils.isBlank(policyInsurantUpdateRequest.getPolicyInsurantBizId())) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyInsurantBizId不能为空");
+        }
+        return Result.success(policyFollowService.updatePolicyInsurant(policyInsurantUpdateRequest));
+    }
+
+    /**
+     * 更新受益人列表
+     *
+     * @param policyBeneficiaryListUpdateRequest 受益人列表更新请求
+     * @return 是否成功
+     */
+    @PostMapping("/beneficiary/update")
+    @Operation(summary = "更新受益人列表")
+    @Transactional(rollbackFor = Exception.class)
+    public Result<Boolean> updatePolicyBeneficiaryList(@RequestBody PolicyBeneficiaryListUpdateRequest policyBeneficiaryListUpdateRequest) {
+        if (policyBeneficiaryListUpdateRequest == null || StringUtils.isBlank(policyBeneficiaryListUpdateRequest.getPolicyBizId())) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policyBizId不能为空");
+        }
+        return Result.success(policyFollowService.updatePolicyBeneficiaryList(policyBeneficiaryListUpdateRequest));
+    }
+
+    /**
+     * 更新第二持有人信息
+     *
+     * @param policySecondHolderUpdateRequest 第二持有人更新请求
+     * @return 是否成功
+     */
+    @PostMapping("/second_holder/update")
+    @Operation(summary = "更新第二持有人信息")
+    @Transactional(rollbackFor = Exception.class)
+    public Result<Boolean> updatePolicySecondHolder(@RequestBody PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest) {
+        if (policySecondHolderUpdateRequest == null || StringUtils.isBlank(policySecondHolderUpdateRequest.getPolicySecondHolderBizId())) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), "policySecondHolderBizId不能为空");
+        }
+        return Result.success(policyFollowService.updatePolicySecondHolder(policySecondHolderUpdateRequest));
+    }
 }
 }
\ No newline at end of file

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

@@ -5,8 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yd.csf.service.dto.*;
 import com.yd.csf.service.dto.*;
 import com.yd.csf.service.enums.PolicyFollowStatusEnum;
 import com.yd.csf.service.enums.PolicyFollowStatusEnum;
-import com.yd.csf.service.model.Policy;
-import com.yd.csf.service.model.PolicyFollow;
+import com.yd.csf.service.model.*;
 import com.yd.csf.service.vo.PolicyFollowDetailVO;
 import com.yd.csf.service.vo.PolicyFollowDetailVO;
 import com.yd.csf.service.vo.PolicyFollowVO;
 import com.yd.csf.service.vo.PolicyFollowVO;
 import com.yd.csf.service.vo.PolicyNumberResponseVO;
 import com.yd.csf.service.vo.PolicyNumberResponseVO;
@@ -90,4 +89,92 @@ public interface PolicyFollowService extends IService<PolicyFollow> {
     List<PolicyFollow> queryList(List<String> policyNoList);
     List<PolicyFollow> queryList(List<String> policyNoList);
 
 
     List<PolicyFollow> queryListByAppointmentBizId(String appointmentBizId);
     List<PolicyFollow> queryListByAppointmentBizId(String appointmentBizId);
+
+    /**
+     * 查询产品计划信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 产品计划信息
+     */
+    Policy getProductPlan(String policyBizId);
+
+    /**
+     * 查询投保人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 投保人信息
+     */
+    PolicyPolicyholder getPolicyPolicyholder(String policyBizId);
+
+    /**
+     * 查询受保人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 受保人信息
+     */
+    PolicyInsurant getPolicyInsurant(String policyBizId);
+
+    /**
+     * 查询受益人列表
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 受益人列表
+     */
+    List<PolicyBeneficiary> getPolicyBeneficiaryList(String policyBizId);
+
+    /**
+     * 查询第二持有人信息
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 第二持有人信息
+     */
+    PolicySecondHolder getPolicySecondHolder(String policyBizId);
+
+    /**
+     * 查询预约附件列表
+     *
+     * @param policyBizId 新单跟进业务ID
+     * @return 预约附件列表
+     */
+    List<PolicyAppointmentFile> getPolicyAppointmentFileList(String policyBizId);
+
+    /**
+     * 更新产品计划信息
+     *
+     * @param policyUpdateRequest 产品计划更新请求
+     * @return 是否成功
+     */
+    Boolean updateProductPlan(PolicyUpdateRequest policyUpdateRequest);
+
+    /**
+     * 更新投保人信息
+     *
+     * @param policyPolicyholderUpdateRequest 投保人更新请求
+     * @return 是否成功
+     */
+    Boolean updatePolicyPolicyholder(PolicyPolicyholderUpdateRequest policyPolicyholderUpdateRequest);
+
+    /**
+     * 更新受保人信息
+     *
+     * @param policyInsurantUpdateRequest 受保人更新请求
+     * @return 是否成功
+     */
+    Boolean updatePolicyInsurant(PolicyInsurantUpdateRequest policyInsurantUpdateRequest);
+
+    /**
+     * 更新受益人列表
+     *
+     * @param policyBeneficiaryListUpdateRequest 受益人列表更新请求
+     * @return 是否成功
+     */
+    Boolean updatePolicyBeneficiaryList(PolicyBeneficiaryListUpdateRequest policyBeneficiaryListUpdateRequest);
+
+    /**
+     * 更新第二持有人信息
+     *
+     * @param policySecondHolderUpdateRequest 第二持有人更新请求
+     * @return 是否成功
+     */
+    Boolean updatePolicySecondHolder(PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest);
 }
 }

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

@@ -78,6 +78,8 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
     @Resource
     @Resource
     private PolicyAdditionalService policyAdditionalService;
     private PolicyAdditionalService policyAdditionalService;
     @Resource
     @Resource
+    private PolicyAppointmentFileService policyAppointmentFileService;
+    @Resource
     private IExpectedFortuneService expectedFortuneService;
     private IExpectedFortuneService expectedFortuneService;
     @Autowired
     @Autowired
     private CommissionExpectedService commissionExpectedService;
     private CommissionExpectedService commissionExpectedService;
@@ -959,5 +961,80 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             return null;
             return null;
         }
         }
     }
     }
+
+    @Override
+    public Policy getProductPlan(String policyBizId) {
+        return policyService.getOne(new QueryWrapper<Policy>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    public PolicyPolicyholder getPolicyPolicyholder(String policyBizId) {
+        return policyPolicyholderService.getOne(new QueryWrapper<PolicyPolicyholder>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    public PolicyInsurant getPolicyInsurant(String policyBizId) {
+        return policyInsurantService.getOne(new QueryWrapper<PolicyInsurant>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    public List<PolicyBeneficiary> getPolicyBeneficiaryList(String policyBizId) {
+        return policyBeneficiaryService.list(new QueryWrapper<PolicyBeneficiary>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    public PolicySecondHolder getPolicySecondHolder(String policyBizId) {
+        return policySecondHolderService.getOne(new QueryWrapper<PolicySecondHolder>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    public List<PolicyAppointmentFile> getPolicyAppointmentFileList(String policyBizId) {
+        return policyAppointmentFileService.list(new QueryWrapper<PolicyAppointmentFile>().eq("policy_biz_id", policyBizId).eq("is_deleted", 0));
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean updateProductPlan(PolicyUpdateRequest policyUpdateRequest) {
+        if (policyUpdateRequest == null || StringUtils.isBlank(policyUpdateRequest.getPolicyBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policyBizId不能为空");
+        }
+        return policyService.updatePolicy(policyUpdateRequest);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean updatePolicyPolicyholder(PolicyPolicyholderUpdateRequest policyPolicyholderUpdateRequest) {
+        if (policyPolicyholderUpdateRequest == null || StringUtils.isBlank(policyPolicyholderUpdateRequest.getPolicyPolicyholderBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policyPolicyholderBizId不能为空");
+        }
+        return policyPolicyholderService.update(policyPolicyholderUpdateRequest);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean updatePolicyInsurant(PolicyInsurantUpdateRequest policyInsurantUpdateRequest) {
+        if (policyInsurantUpdateRequest == null || StringUtils.isBlank(policyInsurantUpdateRequest.getPolicyInsurantBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policyInsurantBizId不能为空");
+        }
+        return policyInsurantService.update(policyInsurantUpdateRequest);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean updatePolicyBeneficiaryList(PolicyBeneficiaryListUpdateRequest policyBeneficiaryListUpdateRequest) {
+        if (policyBeneficiaryListUpdateRequest == null || StringUtils.isBlank(policyBeneficiaryListUpdateRequest.getPolicyBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policyBizId不能为空");
+        }
+        return policyBeneficiaryService.updatePolicyBeneficiaryList(policyBeneficiaryListUpdateRequest);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean updatePolicySecondHolder(PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest) {
+        if (policySecondHolderUpdateRequest == null || StringUtils.isBlank(policySecondHolderUpdateRequest.getPolicySecondHolderBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policySecondHolderBizId不能为空");
+        }
+        return policySecondHolderService.updatePolicySecondHolder(policySecondHolderUpdateRequest);
+    }
 }
 }