push

ad72a12d · zhangxingmin · eb5a1876 · ad72a12d · ad72a12d · ad72a12d
Commit ad72a12d authored Mar 20, 2026 by zhangxingmin
7 changed files
--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAdditionalServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAdditionalServiceImpl.java
@@ -81,6 +81,7 @@ public class ApiAdditionalServiceImpl implements ApiAdditionalService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiProductPlanAdditionalInfoDto apiProductPlanAdditionalInfoDto) {
        List<ApiProductPlanAdditionalInfoDto> list = new ArrayList<>();
        list.add(apiProductPlanAdditionalInfoDto);
@@ -100,6 +101,7 @@ public class ApiAdditionalServiceImpl implements ApiAdditionalService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiProductPlanAdditionalInfoDto apiProductPlanAdditionalInfoDto) {
        //编辑预约入参字段校验 - 产品计划信息字段校验 - 编辑产品附加险信息单个对象字段校验
        apiAppointmentCheckService.checkEditApiProductPlanAdditionalInfoDto(apiProductPlanAdditionalInfoDto);
@@ -134,6 +136,7 @@ public class ApiAdditionalServiceImpl implements ApiAdditionalService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String additionalBizId) {
        //校验附加险信息是否存在
        Result<Additional> result = checkAdditionalIsExist(additionalBizId);
@@ -183,6 +186,7 @@ public class ApiAdditionalServiceImpl implements ApiAdditionalService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result batchEditAdditionalData(ApiProductPlanInfoDto productPlanInfoDto, String planBizId) {
        if (Objects.isNull(productPlanInfoDto)
                || ( !Objects.isNull(productPlanInfoDto)

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAgentDetailFycServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAgentDetailFycServiceImpl.java
@@ -13,6 +13,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import java.math.BigDecimal;
 import java.util.ArrayList;
@@ -35,6 +36,7 @@ public class ApiAgentDetailFycServiceImpl implements ApiAgentDetailFycService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveAgentDetailFyc(GenerateAgentDetailFycDto dto) {
        List<AlgorithmResDto> algorithmResDtoList = dto.getAlgorithmResDtoList();
        List<AgentDetailFyc> agentDetailFycList = new ArrayList<>();

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAgentReferralRelationServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAgentReferralRelationServiceImpl.java
@@ -9,6 +9,7 @@ import com.yd.csf.service.model.AgentReferralRelation;
 import com.yd.csf.service.service.IAgentReferralRelationService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -25,6 +26,7 @@ public class ApiAgentReferralRelationServiceImpl implements ApiAgentReferralRela
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result save(ApiAgentReferralRelationSaveRequest request) {
        //先删后新增
        iAgentReferralRelationService.del(request.getAgentIdList(), request.getReferrerId());

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentFileServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentFileServiceImpl.java
@@ -47,6 +47,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.web.multipart.MultipartFile;
 import java.util.*;
@@ -138,6 +139,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiAppointmentFileAddRequest request) {
        //获取Security上下文当前用户的登录信息
        AuthUserDto authUserDto = SecurityUtil.getCurrentLoginUser();
@@ -155,6 +157,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiAppointmentFileEditRequest request) {
        Result<AppointmentFile> result = checkAppointmentFileIsExist(request.getAppointmentFileBizId());
        AppointmentFile appointmentFile = result.getData();
@@ -169,6 +172,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String appointmentFileBizId) {
        Result<AppointmentFile> result = checkAppointmentFileIsExist(appointmentFileBizId);
        AppointmentFile appointmentFile = result.getData();
@@ -182,6 +186,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result download(String appointmentFileBizId) {
        return null;
    }
@@ -192,6 +197,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<String> itineraryPdf(String appointmentBizId) {
        String url = "";
        //查询redis缓存的字典列表信息
@@ -238,6 +244,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiAppointmentExportExcelResponse> appointmentExportExcel(String appointmentBizId) {
        Map<String, Object> data = new HashMap<>();
        try {
@@ -365,6 +372,7 @@ public class ApiAppointmentFileServiceImpl implements ApiAppointmentFileService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiAppointmentImportExcelResponse> appointmentImportExcel(MultipartFile file,
                                                                            ApiAppointmentImportExcelRequest request) {

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentLogServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentLogServiceImpl.java
@@ -11,6 +11,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 @Service
 @Slf4j
@@ -25,6 +26,7 @@ public class ApiAppointmentLogServiceImpl implements ApiAppointmentLogService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<String> saveAppointmentLog(Appointment appointment) {
        AppointmentLog appointmentLog = new AppointmentLog();
        BeanUtils.copyProperties(appointment,appointmentLog);

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentReferrerLogServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentReferrerLogServiceImpl.java
@@ -11,6 +11,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -29,6 +30,7 @@ public class ApiAppointmentReferrerLogServiceImpl implements ApiAppointmentRefer
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveAppointmentReferrerLogList(List<ApiAppointmentReferrerDto> referrerDtoList,
                                                 String appointmentLogBizId) {
        if (CollectionUtils.isEmpty(referrerDtoList)) {

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentServiceImpl.java
@@ -280,6 +280,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     * @param appointmentBizId
     * @return
     */
+    @Transactional(rollbackFor = Exception.class)
    public Result addRelObjectMaterialList(String appointmentBizId,
                                           List<ApiAppointmentMaterialDto> dtoList) {
        //添加-单个对象和材料列表关系信息
@@ -497,6 +498,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     * 更新关联的FNA状态为"待签单"
     * @param fnaBizId FNA业务ID
     */
+    @Transactional(rollbackFor = Exception.class)
    private void updateFnaStatusToPendingSignature(String fnaBizId) {
        if (StringUtils.isBlank(fnaBizId)) {
            return;
@@ -514,6 +516,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result editStorage(ApiAppointmentEditStorageRequest request) {
        //校验预约信息-客户和fna入参
        apiAppointmentCheckService.checkCustomerAndFna(request.getApiAppointmentInfoDto(), "预约信息-");
@@ -1175,6 +1178,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result editStatus(ApiAppointmentEditStatusRequest request) {
        //校验预约信息是否存在
        Result<Appointment> result = checkAppointmentIsExist(request.getAppointmentBizId());
@@ -1196,6 +1200,7 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
     * 取消预约-更新新单跟进状态为取消预约
     * @return
     */
+    @Transactional(rollbackFor = Exception.class)
    public Result editFollowStatus(String appointmentBizId) {
        List<PolicyFollow> followList = policyFollowService.queryListByAppointmentBizId(appointmentBizId);
        if (!CollectionUtils.isEmpty(followList)) {