新单跟进同步预约信息

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

@@ -6,9 +6,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.gson.reflect.TypeToken;
 import com.yd.auth.core.dto.AuthUserDto;
 import com.yd.auth.core.utils.SecurityUtil;
-import com.yd.base.feign.client.relobjectcertificate.ApiRelObjectCertificateFeignClient;
-import com.yd.base.feign.dto.ApiCertificateDto;
-import com.yd.base.feign.request.relobjectcertificate.ApiRelObjectCertificateListAddRequest;
 import com.yd.common.constant.CodeGeneratorConstants;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.ResultCode;
@@ -46,7 +43,6 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import javax.validation.constraints.NotBlank;
 import java.time.ZoneId;
 import java.util.ArrayList;
 import java.util.Date;
@@ -143,6 +139,8 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     private FnaFormService fnaFormService;
     @Resource
     private PolicyBrokerService policyBrokerService;
+    @Resource
+    private PolicyAppointmentFileService policyAppointmentFileService;
 
     /**
      * 预约分页查询
@@ -760,13 +758,10 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
 
         // 同步保存保单产品计划附加险
         savePolicyAdditional(apiProductPlanAdditionalInfoDtoList, policyBizId);
-
         // 同步转介人
         savePolicyBroker(appointment.getFnaBizId(), policyBizId);
-
-//        // 同步保存保单（产品计划）
-//        savePolicy(productPlan, apiPolicyholderInfoDto, apiInsurantInfoDto, apiProductPlanMainInfoDto, policyBizId, policyTransfer);
-
+        // 同步保存保单（产品计划）
+        savePolicy(productPlan, apiPolicyholderInfoDto, apiInsurantInfoDto, apiProductPlanMainInfoDto, policyBizId, policyTransfer);
         // 同步保存保单投保人
         savePolicyPolicyholder(apiPolicyholderInfoDto, policyBizId);
         // 同步保存保单受保人
@@ -786,10 +781,15 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
 
     private void savePolicyAppointmentAttachment(List<ApiAppointmentFileDto> apiAppointmentFileDtoList, String policyBizId) {
         if (ObjectUtils.isNotEmpty(apiAppointmentFileDtoList)) {
+            List<PolicyAppointmentFile> policyAppointmentFileList = new ArrayList<>();
             apiAppointmentFileDtoList.forEach(apiAppointmentFileDto -> {
-//                apiAppointmentFileDto.setPolicyBizId(policyBizId);
+                PolicyAppointmentFile policyAppointmentFile = new PolicyAppointmentFile();
+                BeanUtils.copyProperties(apiAppointmentFileDto, policyAppointmentFile);
+                policyAppointmentFile.setId(null);
+                policyAppointmentFile.setPolicyBizId(policyBizId);
+                policyAppointmentFileList.add(policyAppointmentFile);
             });
-//            policyAppointmentFileService.saveOrUpdateBatch(apiAppointmentFileDtoList);
+            policyAppointmentFileService.saveOrUpdateBatch(policyAppointmentFileList);
         }
     }
 

yd-csf-service/src/main/java/com/yd/csf/service/dao/PolicyAppointmentFileMapper.java

+package com.yd.csf.service.dao;
+
+import com.yd.csf.service.model.PolicyAppointmentFile;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Zhang Jianan
+* @description 针对表【policy_appointment_file(新单跟进预约附件信息表)】的数据库操作Mapper
+* @createDate 2026-02-28 16:40:45
+* @Entity generator.domain.PolicyAppointmentFile
+*/
+public interface PolicyAppointmentFileMapper extends BaseMapper<PolicyAppointmentFile> {
+
+}
+
+
+
+

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

+package com.yd.csf.service.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 新单跟进预约附件信息表
+ * @TableName policy_appointment_file
+ */
+@TableName(value ="policy_appointment_file")
+@Data
+public class PolicyAppointmentFile implements Serializable {
+    /**
+     * 
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 新单跟进业务ID
+     */
+    private String policyBizId;
+
+    /**
+     * 保单号
+     */
+    private String policyNo;
+
+    /**
+     * 预约信息主表唯一业务ID
+     */
+    private String appointmentBizId;
+
+    /**
+     * 中台文件元数据表唯一业务ID
+     */
+    private String ossFileBizId;
+
+    /**
+     * 预约附件信息表唯一业务ID
+     */
+    private String appointmentFileBizId;
+
+    /**
+     * 预约-材料信息表唯一业务ID
+     */
+    private String appointmentMaterialBizId;
+
+    /**
+     * 文件名
+     */
+    private String fileName;
+
+    /**
+     * 文件访问路径
+     */
+    private String fileUrl;
+
+    /**
+     * 通用备注
+     */
+    private String remark;
+
+    /**
+     * 删除标识: 0-正常, 1-删除
+     */
+    private Integer isDeleted;
+
+    /**
+     * 创建人ID
+     */
+    private String creatorId;
+
+    /**
+     * 创建人名称
+     */
+    private String creatorName;
+
+    /**
+     * 更新人ID
+     */
+    private String updaterId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.yd.csf.service.service;
+
+import com.yd.csf.service.model.PolicyAppointmentFile;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Zhang Jianan
+* @description 针对表【policy_appointment_file(新单跟进预约附件信息表)】的数据库操作Service
+* @createDate 2026-02-28 16:40:45
+*/
+public interface PolicyAppointmentFileService extends IService<PolicyAppointmentFile> {
+
+}

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

@@ -22,7 +22,6 @@ import com.yd.csf.service.enums.FnaStatusEnum;
 import com.yd.csf.service.model.Customer;
 import com.yd.csf.service.model.Fna;
 import com.yd.csf.service.model.FnaForm;
-import com.yd.csf.service.model.Fortune;
 import com.yd.csf.service.service.CustomerService;
 import com.yd.csf.service.service.FnaFormService;
 import com.yd.csf.service.service.FnaService;

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

+package com.yd.csf.service.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yd.csf.service.model.PolicyAppointmentFile;
+import com.yd.csf.service.dao.PolicyAppointmentFileMapper;
+import com.yd.csf.service.service.PolicyAppointmentFileService;
+import org.springframework.stereotype.Service;
+
+/**
+* @author Zhang Jianan
+* @description 针对表【policy_appointment_file(新单跟进预约附件信息表)】的数据库操作Service实现
+* @createDate 2026-02-28 16:40:45
+*/
+@Service
+public class PolicyAppointmentFileServiceImpl extends ServiceImpl<PolicyAppointmentFileMapper, PolicyAppointmentFile>
+    implements PolicyAppointmentFileService {
+
+}
+
+
+
+

yd-csf-service/src/main/resources/mappers/PolicyAppointmentFileMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yd.csf.service.dao.PolicyAppointmentFileMapper">
+
+    <resultMap id="BaseResultMap" type="com.yd.csf.service.model.PolicyAppointmentFile">
+            <id property="id" column="id" />
+            <result property="policyBizId" column="policy_biz_id" />
+            <result property="policyNo" column="policy_no" />
+            <result property="appointmentBizId" column="appointment_biz_id" />
+            <result property="ossFileBizId" column="oss_file_biz_id" />
+            <result property="appointmentFileBizId" column="appointment_file_biz_id" />
+            <result property="appointmentMaterialBizId" column="appointment_material_biz_id" />
+            <result property="fileName" column="file_name" />
+            <result property="fileUrl" column="file_url" />
+            <result property="remark" column="remark" />
+            <result property="isDeleted" column="is_deleted" />
+            <result property="creatorId" column="creator_id" />
+            <result property="creatorName" column="creator_name" />
+            <result property="updaterId" column="updater_id" />
+            <result property="createTime" column="create_time" />
+            <result property="updateTime" column="update_time" />
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,policy_biz_id,policy_no,appointment_biz_id,oss_file_biz_id,appointment_file_biz_id,
+        appointment_material_biz_id,file_name,file_url,remark,is_deleted,
+        creator_id,creator_name,updater_id,create_time,update_time
+    </sql>
+</mapper>