新单跟进18

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

+package com.yd.csf.api.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yd.common.enums.ResultCode;
+import com.yd.common.result.Result;
+import com.yd.csf.service.dto.PolicyBeneficiaryQueryRequest;
+import com.yd.csf.service.dto.PolicyBeneficiaryUpdateRequest;
+import com.yd.csf.service.dto.PolicyBeneficiaryAddRequest;
+import com.yd.csf.service.model.PolicyBeneficiary;
+import com.yd.csf.service.service.PolicyBeneficiaryService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
+/**
+ * policy_beneficiary接口
+ *
+ * @author jianan
+ * @since 2025-09-20
+ */
+@RestController
+@RequestMapping("/policy_beneficiary")
+@Tag(name = "保单受益人接口")
+public class ApiPolicyBeneficiaryController {
+
+    @Resource
+    private PolicyBeneficiaryService policyBeneficiaryService;
+
+    /**
+     * 创建保单受益人
+     *
+     * @param policyBeneficiaryAddRequest
+     * @param request
+     * @return
+     */
+    @Operation(summary = "创建保单受益人")
+    @PostMapping("/add")
+    public Result<Map<String, Object>> addPolicyBeneficiary(@RequestBody PolicyBeneficiaryAddRequest policyBeneficiaryAddRequest, HttpServletRequest request) {
+        if (policyBeneficiaryAddRequest == null) {
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), ResultCode.PARAMS_ERROR.getMessage());
+        }
+        return Result.success(policyBeneficiaryService.addPolicyBeneficiary(policyBeneficiaryAddRequest));
+    }
+
+    /**
+     * 删除保单受益人
+     *
+     * @param policyBeneficiaryBizId
+     * @param request
+     * @return
+     */
+    @DeleteMapping("/delete")
+    @Operation(summary = "删除保单受益人")
+    public Result<Boolean> deletePolicyBeneficiary(@RequestParam("policyBeneficiaryBizId") String policyBeneficiaryBizId, HttpServletRequest request) {
+        if (policyBeneficiaryBizId == null || StringUtils.isBlank(policyBeneficiaryBizId)) {
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "policyBeneficiaryBizId不能为空");
+        }
+//        User user = userService.getLoginUser(request);
+//        long id = deleteRequest.getId();
+        // 判断是否存在
+        PolicyBeneficiary policyBeneficiary = policyBeneficiaryService.getByBizId(policyBeneficiaryBizId);
+        if (policyBeneficiary == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), ResultCode.NULL_ERROR.getMessage());
+        }
+        // 仅本人或管理员可删除
+//        if (!oldFna.getUserId().equals(user.getId()) && !userService.isAdmin(request)) {
+//            throw new BusinessException(ErrorCode.NO_AUTH_ERROR);
+//        }
+
+        // 操作数据库
+        return Result.success(policyBeneficiaryService.removeById(policyBeneficiary.getId()));
+    }
+
+    /**
+     * 更新保单受益人（产品计划）
+     *
+     * @param policyUpdateRequest
+     * @return
+     */
+    @PostMapping("/update")
+    @Operation(summary = "更新保单受益人信息")
+    public Result<Boolean> updatePolicyBeneficiary(@RequestBody PolicyBeneficiaryUpdateRequest policyUpdateRequest) {
+        if (policyUpdateRequest == null || StringUtils.isBlank(policyUpdateRequest.getPolicyBeneficiaryBizId())) {
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "policyBeneficiaryBizId不能为空");
+        }
+        return Result.success(policyBeneficiaryService.updatePolicyBeneficiary(policyUpdateRequest));
+    }
+
+    /**
+     * 根据 policyBeneficiaryBizId 获取保单受益人（封装类）
+     *
+     * @param policyBeneficiaryBizId
+     * @return
+     */
+    @GetMapping("/get/vo")
+    @Operation(summary = "根据 policyBeneficiaryBizId 获取保单受益人详情")
+    public Result<PolicyBeneficiary> getPolicyByPolicyBeneficiaryBizId(@RequestParam("policyBeneficiaryBizId") String policyBeneficiaryBizId, HttpServletRequest request) {
+        if (policyBeneficiaryBizId == null) {
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), ResultCode.PARAMS_ERROR.getMessage());
+        }
+        // 查询数据库
+        PolicyBeneficiary policyBeneficiary = policyBeneficiaryService.getByBizId(policyBeneficiaryBizId);
+        if (policyBeneficiary == null) {
+            return Result.fail(ResultCode.NULL_ERROR.getCode(), ResultCode.NULL_ERROR.getMessage());
+        }
+
+        // 获取封装类
+        return Result.success(policyBeneficiary);
+    }
+    
+    /**
+     * 分页获取保单受益人列表
+     *
+     * @param policyBeneficiaryQueryRequest
+     * @param request
+     * @return
+     */
+    @PostMapping("/list")
+    @Operation(summary = "分页获取保单受益人列表")
+    public Result<Page<PolicyBeneficiary>> listPolicyByPage(@RequestBody PolicyBeneficiaryQueryRequest policyBeneficiaryQueryRequest,
+                                                               HttpServletRequest request) {
+        long current = policyBeneficiaryQueryRequest.getPageNo();
+        long size = policyBeneficiaryQueryRequest.getPageSize();
+
+        // 查询数据库
+        QueryWrapper<PolicyBeneficiary> queryWrapper = new QueryWrapper<PolicyBeneficiary>();
+        queryWrapper.eq("policy_biz_id", policyBeneficiaryQueryRequest.getPolicyBizId());
+        queryWrapper.orderByAsc("id");
+        Page<PolicyBeneficiary> PolicyBeneficiaryPage = policyBeneficiaryService.page(new Page<>(current, size),
+                queryWrapper);
+        // 获取封装类
+        return Result.success(PolicyBeneficiaryPage);
+    }
+
+}

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

@@ -4,7 +4,6 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.result.Result;
 import com.yd.common.result.Result;
-import com.yd.csf.service.dao.PolicyMapper;
 import com.yd.csf.service.dto.*;
 import com.yd.csf.service.dto.*;
 
 
 import com.yd.csf.service.model.CommissionExpected;
 import com.yd.csf.service.model.CommissionExpected;
@@ -27,7 +26,7 @@ import javax.servlet.http.HttpServletRequest;
  */
  */
 @RestController
 @RestController
 @RequestMapping("/policy")
 @RequestMapping("/policy")
-@Tag(name = "保单接口")
+@Tag(name = "保单(产品计划)接口")
 public class ApiPolicyController {
 public class ApiPolicyController {
 
 
     @Resource
     @Resource
@@ -38,6 +37,8 @@ public class ApiPolicyController {
     private PolicyPolicyholderService policyPolicyholderService;
     private PolicyPolicyholderService policyPolicyholderService;
     @Resource
     @Resource
     private PolicyInsurantService policyInsurantService;
     private PolicyInsurantService policyInsurantService;
+    @Resource
+    private PolicySecondHolderService policySecondHolderService;
 
 
     /**
     /**
      * 创建保单
      * 创建保单
@@ -128,6 +129,21 @@ public class ApiPolicyController {
         return Result.success(policyInsurantService.update(policyInsurantUpdateRequest));
         return Result.success(policyInsurantService.update(policyInsurantUpdateRequest));
     }
     }
 
 
+     /**
+     * 更新第二持有人信息
+     *
+     * @param policySecondHolderUpdateRequest
+     * @return
+     */
+    @PostMapping("/update_policy_second_holder")
+    @Operation(summary = "更新第二持有人信息")
+    public Result<Boolean> updatePolicySecondHolder(@RequestBody PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest) {
+        if (policySecondHolderUpdateRequest == null || policySecondHolderUpdateRequest.getPolicySecondHolderBizId() == null) {
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "policySecondHolderBizId不能为空");
+        }
+        return Result.success(policySecondHolderService.updatePolicySecondHolder(policySecondHolderUpdateRequest));
+    }
+
     /**
     /**
      * 根据 policyBizId 获取保单（封装类）
      * 根据 policyBizId 获取保单（封装类）
      *
      *

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

+package com.yd.csf.service.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data
+public class PolicyBeneficiaryAddRequest implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 新单跟进业务ID
+     */
+    @Schema(description = "新单跟进业务ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String policyBizId;
+
+    /**
+     * 保单号
+     */
+    @Schema(description = "保单号")
+    private String policyNo;
+
+    /**
+     * 客户类型（字典）(个人或者公司)
+     */
+    @Schema(description = "客户类型（字典）(个人或者公司)")
+    private String customerType;
+
+    /**
+     * 与受保人关系（字典）
+     */
+    @Schema(description = "与受保人关系（字典）")
+    private String insurantRel;
+
+    /**
+     * 受益比例
+     */
+    @Schema(description = "受益比例")
+    private BigDecimal benefitRatio;
+
+    /**
+     * 名字
+     */
+    @Schema(description = "名字")
+    private String name;
+
+    /**
+     * 名字-英文
+     */
+    @Schema(description = "名字-英文")
+    private String nameEn;
+
+    /**
+     * 性别（字典）
+     */
+    @Schema(description = "性别（字典）")
+    private String gender;
+
+    /**
+     * 证件类型（字典）
+     */
+    @Schema(description = "证件类型（字典）")
+    private String documentType;
+
+    /**
+     * 证件号码
+     */
+    @Schema(description = "证件号码")
+    private String idNumber;
+
+    /**
+     * 护照号码
+     */
+    @Schema(description = "护照号码")
+    private String passportNumber;
+
+    /**
+     * 出生日期
+     */
+    @Schema(description = "出生日期")
+    private Date birthTime;
+
+    /**
+     * 公司名称
+     */
+    @Schema(description = "公司名称")
+    private String companyName;
+
+    /**
+     * 公司名称（英文）
+     */
+    @Schema(description = "公司名称（英文）")
+    private String companyNameEn;
+
+    /**
+     * 公司商业登记号码
+     */
+    @Schema(description = "公司商业登记号码")
+    private String companyBusinessNo;
+
+    /**
+     * 公司注册日期
+     */
+    @Schema(description = "公司注册日期")
+    private Date companyRegisterTime;
+
+    /**
+     * 公司注册地区（字典）
+     */
+    @Schema(description = "公司注册地区（字典）")
+    private String companyRegisterRegion;
+
+    /**
+     * 公司电话区号
+     */
+    @Schema(description = "公司电话区号")
+    private String companyMobileCode;
+
+    /**
+     * 公司电话
+     */
+    @Schema(description = "公司电话")
+    private String companyMobile;
+
+    /**
+     * 公司邮箱
+     */
+    @Schema(description = "公司邮箱")
+    private String companyEmail;
+
+    /**
+     * 公司登记地址
+     */
+    @Schema(description = "公司登记地址")
+    private String companyEnterAddress;
+
+    /**
+     * 通讯地址
+     */
+    @Schema(description = "通讯地址")
+    private String mailingAddress;
+
+    /**
+     * 授权代表姓名中文-名字
+     */
+    @Schema(description = "授权代表姓名中文-名字")
+    private String authNameCn;
+
+    /**
+     * 授权代表姓名英文-名字
+     */
+    @Schema(description = "授权代表姓名英文-名字")
+    private String authNameEn;
+
+    /**
+     * 授权代表职称
+     */
+    @Schema(description = "授权代表职称")
+    private String authProfessional;
+
+    /**
+     * 授权代表电话区号
+     */
+    @Schema(description = "授权代表电话区号")
+    private String authMobileCode;
+
+    /**
+     * 授权代表电话
+     */
+    @Schema(description = "授权代表电话")
+    private String authMobile;
+
+    /**
+     * 地址列表（json串）
+     */
+    @Schema(description = "地址列表（json串）")
+    private String addressList;
+
+    /**
+     * 通用备注
+     */
+    @Schema(description = "通用备注")
+    private String remark;
+}

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

+package com.yd.csf.service.dto;
+
+import com.yd.common.dto.PageDto;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class PolicyBeneficiaryQueryRequest extends PageDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 保单业务ID
+     */
+    @Schema(description = "保单业务ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String policyBizId;
+}

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

+package com.yd.csf.service.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class PolicyBeneficiaryUpdateRequest extends PolicyBeneficiaryAddRequest implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 受益人信息表业务ID
+     */
+    @Schema(description = "受益人信息表业务ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    private String policyBeneficiaryBizId;
+}

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

+package com.yd.csf.service.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class PolicySecondHolderUpdateRequest implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 第二持有人业务ID
+     */
+    private String policySecondHolderBizId;
+}

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

 package com.yd.csf.service.service;
 package com.yd.csf.service.service;
 
 
+import com.yd.csf.service.dto.PolicyBeneficiaryAddRequest;
+import com.yd.csf.service.dto.PolicyBeneficiaryUpdateRequest;
 import com.yd.csf.service.model.PolicyBeneficiary;
 import com.yd.csf.service.model.PolicyBeneficiary;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.IService;
 
 
+import java.util.Map;
+
 /**
 /**
 * @author Zhang Jianan
 * @author Zhang Jianan
 * @description 针对表【policy_beneficiary(受益人信息表)】的数据库操作Service
 * @description 针对表【policy_beneficiary(受益人信息表)】的数据库操作Service
@@ -10,4 +14,9 @@ import com.baomidou.mybatisplus.extension.service.IService;
 */
 */
 public interface PolicyBeneficiaryService extends IService<PolicyBeneficiary> {
 public interface PolicyBeneficiaryService extends IService<PolicyBeneficiary> {
 
 
+    Map<String, Object> addPolicyBeneficiary(PolicyBeneficiaryAddRequest policyBeneficiaryAddRequest);
+
+    PolicyBeneficiary getByBizId(String policyBeneficiaryBizId);
+
+    Boolean updatePolicyBeneficiary(PolicyBeneficiaryUpdateRequest policyUpdateRequest);
 }
 }

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

 package com.yd.csf.service.service;
 package com.yd.csf.service.service;
 
 
+import com.yd.csf.service.dto.PolicySecondHolderUpdateRequest;
 import com.yd.csf.service.model.PolicySecondHolder;
 import com.yd.csf.service.model.PolicySecondHolder;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.IService;
 
 
@@ -10,4 +11,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
 */
 */
 public interface PolicySecondHolderService extends IService<PolicySecondHolder> {
 public interface PolicySecondHolderService extends IService<PolicySecondHolder> {
 
 
+    Boolean updatePolicySecondHolder(PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest);
 }
 }

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

 package com.yd.csf.service.service.impl;
 package com.yd.csf.service.service.impl;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yd.common.enums.ResultCode;
+import com.yd.common.exception.BusinessException;
+import com.yd.common.utils.RandomStringGenerator;
+import com.yd.csf.service.dto.PolicyBeneficiaryAddRequest;
+import com.yd.csf.service.dto.PolicyBeneficiaryUpdateRequest;
+import com.yd.csf.service.model.PolicyAdditional;
 import com.yd.csf.service.model.PolicyBeneficiary;
 import com.yd.csf.service.model.PolicyBeneficiary;
 import com.yd.csf.service.service.PolicyBeneficiaryService;
 import com.yd.csf.service.service.PolicyBeneficiaryService;
 import com.yd.csf.service.dao.PolicyBeneficiaryMapper;
 import com.yd.csf.service.dao.PolicyBeneficiaryMapper;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
+import java.util.Collections;
+import java.util.Date;
+import java.util.Map;
+
 /**
 /**
 * @author Zhang Jianan
 * @author Zhang Jianan
 * @description 针对表【policy_beneficiary(受益人信息表)】的数据库操作Service实现
 * @description 针对表【policy_beneficiary(受益人信息表)】的数据库操作Service实现
@@ -15,6 +27,51 @@ import org.springframework.stereotype.Service;
 public class PolicyBeneficiaryServiceImpl extends ServiceImpl<PolicyBeneficiaryMapper, PolicyBeneficiary>
 public class PolicyBeneficiaryServiceImpl extends ServiceImpl<PolicyBeneficiaryMapper, PolicyBeneficiary>
     implements PolicyBeneficiaryService{
     implements PolicyBeneficiaryService{
 
 
+    @Override
+    public Map<String, Object> addPolicyBeneficiary(PolicyBeneficiaryAddRequest policyBeneficiaryAddRequest) {
+        // 校验请求参数
+        if (policyBeneficiaryAddRequest == null) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), ResultCode.PARAMS_ERROR.getMessage());
+        }
+        // 转换为实体类
+        PolicyBeneficiary policyBeneficiary = new PolicyBeneficiary();
+        BeanUtils.copyProperties(policyBeneficiaryAddRequest, policyBeneficiary);
+
+        policyBeneficiary.setPolicyBeneficiaryBizId(RandomStringGenerator.generateBizId16("policy_beneficiary"));
+
+        Date now = new Date();
+        policyBeneficiary.setCreateTime(now);
+        policyBeneficiary.setUpdateTime(now);
+        // 保存到数据库
+        this.saveOrUpdate(policyBeneficiary);
+
+        // 返回结果
+        return Collections.singletonMap("policyBeneficiaryBizId", policyBeneficiary.getPolicyBeneficiaryBizId());
+    }
+
+    @Override
+    public PolicyBeneficiary getByBizId(String policyBeneficiaryBizId) {
+        return this.getOne(new QueryWrapper<PolicyBeneficiary>().eq("policy_beneficiary_biz_id", policyBeneficiaryBizId));
+    }
+
+    @Override
+    public Boolean updatePolicyBeneficiary(PolicyBeneficiaryUpdateRequest policyUpdateRequest) {
+        // 校验请求参数
+        if (policyUpdateRequest == null) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), ResultCode.PARAMS_ERROR.getMessage());
+        }
+        // 校验 policyBeneficiaryBizId 是否存在
+        PolicyBeneficiary policyBeneficiary = this.getByBizId(policyUpdateRequest.getPolicyBeneficiaryBizId());
+        if (policyBeneficiary == null) {
+            throw new BusinessException(ResultCode.NULL_ERROR.getCode(), ResultCode.NULL_ERROR.getMessage());
+        }
+        // 转换为实体类
+        BeanUtils.copyProperties(policyUpdateRequest, policyBeneficiary, "policyBeneficiaryBizId", "policyBizId", "id");
+        policyBeneficiary.setUpdateTime(new Date());
+
+        // 更新数据库
+        return this.updateById(policyBeneficiary);
+    }
 }
 }
 
 
 
 

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

@@ -8,6 +8,7 @@ import com.yd.csf.service.dto.PolicyInsurantUpdateRequest;
 import com.yd.csf.service.model.PolicyInsurant;
 import com.yd.csf.service.model.PolicyInsurant;
 import com.yd.csf.service.service.PolicyInsurantService;
 import com.yd.csf.service.service.PolicyInsurantService;
 import com.yd.csf.service.dao.PolicyInsurantMapper;
 import com.yd.csf.service.dao.PolicyInsurantMapper;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
@@ -24,8 +25,8 @@ public class PolicyInsurantServiceImpl extends ServiceImpl<PolicyInsurantMapper,
 
 
     @Override
     @Override
     public boolean update(PolicyInsurantUpdateRequest policyInsurantUpdateRequest) {
     public boolean update(PolicyInsurantUpdateRequest policyInsurantUpdateRequest) {
-        if (policyInsurantUpdateRequest == null || policyInsurantUpdateRequest.getPolicyInsurantBizId() == null) {
-            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), ResultCode.PARAMS_ERROR.getMessage());
+        if (policyInsurantUpdateRequest == null || StringUtils.isBlank(policyInsurantUpdateRequest.getPolicyInsurantBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policyInsurantBizId不能为空");
         }
         }
         PolicyInsurant policyInsurant = this.getOne(new QueryWrapper<PolicyInsurant>().eq("policy_insurant_biz_id", policyInsurantUpdateRequest.getPolicyInsurantBizId()));
         PolicyInsurant policyInsurant = this.getOne(new QueryWrapper<PolicyInsurant>().eq("policy_insurant_biz_id", policyInsurantUpdateRequest.getPolicyInsurantBizId()));
         if (policyInsurant == null) {
         if (policyInsurant == null) {

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

 package com.yd.csf.service.service.impl;
 package com.yd.csf.service.service.impl;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yd.common.enums.ResultCode;
+import com.yd.common.exception.BusinessException;
+import com.yd.csf.service.dto.PolicySecondHolderUpdateRequest;
 import com.yd.csf.service.model.PolicySecondHolder;
 import com.yd.csf.service.model.PolicySecondHolder;
 import com.yd.csf.service.service.PolicySecondHolderService;
 import com.yd.csf.service.service.PolicySecondHolderService;
 import com.yd.csf.service.dao.PolicySecondHolderMapper;
 import com.yd.csf.service.dao.PolicySecondHolderMapper;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
+import java.util.Date;
+
 /**
 /**
 * @author Zhang Jianan
 * @author Zhang Jianan
 * @description 针对表【policy_second_holder(第二持有人信息表)】的数据库操作Service实现
 * @description 针对表【policy_second_holder(第二持有人信息表)】的数据库操作Service实现
@@ -15,6 +23,19 @@ import org.springframework.stereotype.Service;
 public class PolicySecondHolderServiceImpl extends ServiceImpl<PolicySecondHolderMapper, PolicySecondHolder>
 public class PolicySecondHolderServiceImpl extends ServiceImpl<PolicySecondHolderMapper, PolicySecondHolder>
     implements PolicySecondHolderService{
     implements PolicySecondHolderService{
 
 
+    @Override
+    public Boolean updatePolicySecondHolder(PolicySecondHolderUpdateRequest policySecondHolderUpdateRequest) {
+        if (policySecondHolderUpdateRequest == null || StringUtils.isBlank(policySecondHolderUpdateRequest.getPolicySecondHolderBizId())) {
+            throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "policySecondHolderBizId不能为空");
+        }
+        PolicySecondHolder policySecondHolder = this.getOne(new QueryWrapper<PolicySecondHolder>().eq("policy_second_holder_biz_id", policySecondHolderUpdateRequest.getPolicySecondHolderBizId()));
+        if (policySecondHolder == null) {
+            throw new BusinessException(ResultCode.NULL_ERROR.getCode(), ResultCode.NULL_ERROR.getMessage());
+        }
+        BeanUtils.copyProperties(policySecondHolderUpdateRequest, policySecondHolder, "policyBizId", "policySecondHolderBizId", "id");
+        policySecondHolder.setUpdateTime(new Date());
+        return this.updateById(policySecondHolder);
+    }
 }
 }
 
 
 
 

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

@@ -30,9 +30,6 @@ import java.util.stream.Collectors;
 public class PolicyServiceImpl extends ServiceImpl<PolicyMapper, Policy>
 public class PolicyServiceImpl extends ServiceImpl<PolicyMapper, Policy>
     implements PolicyService{
     implements PolicyService{
 
 
-    @Resource
-    private PolicyPolicyholderService policyPolicyholderService;
-
     @Override
     @Override
     public QueryWrapper<Policy> getQueryWrapper(PolicyQueryRequest policyQueryRequest) {
     public QueryWrapper<Policy> getQueryWrapper(PolicyQueryRequest policyQueryRequest) {
         QueryWrapper<Policy> queryWrapper = new QueryWrapper<>();
         QueryWrapper<Policy> queryWrapper = new QueryWrapper<>();