push

e0bc7b13 · zhangxingmin · 9377a733 · e0bc7b13 · e0bc7b13 · e0bc7b13
Commit e0bc7b13 authored Mar 20, 2026 by zhangxingmin
21 changed files
--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentUserSignLogServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentUserSignLogServiceImpl.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 ApiAppointmentUserSignLogServiceImpl implements ApiAppointmentUserS
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveAppointmentUserSignLogList(List<ApiAppointmentUserSignDto> userSignDtoList,
                                                 String appointmentLogBizId) {
        if (CollectionUtils.isEmpty(userSignDtoList)) {

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiBeneficiaryServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiBeneficiaryServiceImpl.java
@@ -83,6 +83,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiBeneficiaryInfoDto apiBeneficiaryInfoDto) {
        List<ApiBeneficiaryInfoDto> list = new ArrayList<>();
        list.add(apiBeneficiaryInfoDto);
@@ -99,6 +100,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiBeneficiaryInfoDto apiBeneficiaryInfoDto) {
        //编辑预约入参字段校验 - 编辑单个受益人信息字段校验
        apiAppointmentCheckService.checkEditApiBeneficiaryInfoDto(apiBeneficiaryInfoDto);
@@ -118,6 +120,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result batchEdit(ApiBatchEditBeneficiaryRequest request) {
        apiAppointmentCheckService.checkEditApiBeneficiaryInfoDtoList(request.getApiBeneficiaryInfoDtoList());
        //批量编辑受益人信息表数据
@@ -131,6 +134,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String beneficiaryBizId) {
        //校验受益人信息是否存在
        Result<Beneficiary> result = checkBeneficiaryIsExist(beneficiaryBizId);
@@ -177,6 +181,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result batchEditBeneficiaryData(List<ApiBeneficiaryInfoDto> list,String appointmentBizId) {
        if (CollectionUtils.isEmpty(list)){
            //为空放行

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiCommissionRuleConfigServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiCommissionRuleConfigServiceImpl.java
@@ -21,6 +21,7 @@ import com.yd.csf.service.service.ICommissionRuleConfigService;
 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;
@@ -65,6 +66,7 @@ public class ApiCommissionRuleConfigServiceImpl implements ApiCommissionRuleConf
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiCommissionRuleConfigAddRequest request) {
        //校验基本法名称的唯一性
        List<CommissionRuleConfig> list = iCommissionRuleConfigService.queryList(CommissionRuleConfigDto.builder()
@@ -88,6 +90,7 @@ public class ApiCommissionRuleConfigServiceImpl implements ApiCommissionRuleConf
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiCommissionRuleConfigEditRequest request) {
        //校验基本法配置信息是否存在
        Result<CommissionRuleConfig> result = checkCommissionRuleConfigIsExist(request.getRuleBizId());
@@ -113,6 +116,7 @@ public class ApiCommissionRuleConfigServiceImpl implements ApiCommissionRuleConf
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String ruleBizId) {
        return null;
    }

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiConditionConfigServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiConditionConfigServiceImpl.java
@@ -23,6 +23,7 @@ import com.yd.csf.service.service.IConditionTypeService;
 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.Objects;
@@ -72,6 +73,7 @@ public class ApiConditionConfigServiceImpl implements ApiConditionConfigService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiConditionConfigAddRequest request) {
        //校验条件名称唯一性
        List<ConditionConfig> conditionConfigList = iConditionConfigService.queryList(ConditionConfigDto.builder()
@@ -96,6 +98,7 @@ public class ApiConditionConfigServiceImpl implements ApiConditionConfigService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiConditionConfigEditRequest request) {
        Result<ConditionConfig> result = checkConditionConfigIsExist(request.getConditionBizId());
        ConditionConfig conditionConfig = result.getData();
@@ -120,6 +123,7 @@ public class ApiConditionConfigServiceImpl implements ApiConditionConfigService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String conditionBizId) {
        return null;
    }

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiConditionTypeServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiConditionTypeServiceImpl.java
@@ -21,6 +21,7 @@ import com.yd.csf.service.service.IConditionTypeService;
 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.Objects;
@@ -63,6 +64,7 @@ public class ApiConditionTypeServiceImpl implements ApiConditionTypeService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiConditionTypeAddRequest request) {
        //校验条件类型名称唯一性
        List<ConditionType> conditionTypeList = iConditionTypeService.queryList(ConditionTypeDto.builder()
@@ -86,6 +88,7 @@ public class ApiConditionTypeServiceImpl implements ApiConditionTypeService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiConditionTypeEditRequest request) {
        Result<ConditionType> result = checkConditionTypeIsExist(request.getConditionTypeBizId());
        ConditionType conditionType = result.getData();
@@ -109,6 +112,7 @@ public class ApiConditionTypeServiceImpl implements ApiConditionTypeService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String conditionTypeBizId) {
        return null;
    }

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiExpectedFortuneServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiExpectedFortuneServiceImpl.java
@@ -120,6 +120,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiGenerateExpectedFortuneResponse> generate(ApiGenerateExpectedFortuneRequest request) {
        //查询当前保单号是否正在执行预计发佣的缓存，有值就说明正在执行，无值说明执行完毕或者没有执行。
        String value = redisUtil.getCacheObject(RedisConstants.EXPECTED_FORTUNE + request.getPolicyNo());
@@ -185,6 +186,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     * @param request
     * @return
     */
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiGenerateExpectedFortuneResponse> generateSync(ApiGenerateExpectedFortuneRequest request) {
        //查询当前保单号是否正在执行预计发佣的缓存，有值就说明正在执行，无值说明执行完毕或者没有执行。
        String value = redisUtil.getCacheObject(RedisConstants.EXPECTED_FORTUNE + request.getPolicyNo());
@@ -281,6 +283,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiGenerateExpectedFortuneResponse> generateWithLogAndRedis(ApiGenerateExpectedFortuneRequest request) {
        try {
            Result<ApiGenerateExpectedFortuneResponse> result = generate(request);
@@ -321,6 +324,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ApiGenerateExpectedFortuneResponse> generateSyncWithLogAndRedis(ApiGenerateExpectedFortuneRequest request) {
        try {
            Result<ApiGenerateExpectedFortuneResponse> result = generateSync(request);
@@ -362,6 +366,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     */
    @Override
    @Async("commonAsyncExecutor")
+    @Transactional(rollbackFor = Exception.class)
    public Result execute(List<QueryPolicyAndBrokerDto> queryPolicyAndBrokerDtoList,
                          List<CommissionRuleBinding> commissionRuleBindingList,
                          String policyNo,
@@ -427,6 +432,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
        });
    }
+    @Transactional(rollbackFor = Exception.class)
    private void updateHkdAmountBatch(List<ExpectedFortune> expectedFortuneList, String policyCurrency, List<ApiAnnouncementCommissionRatioListResponse> announcementRatioList) {
        log.info("------------------------开始计算默认结算汇率、港币金额----------------------");
@@ -471,6 +477,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
     * @param policyNo
     * @return
     */
+    @Transactional(rollbackFor = Exception.class)
    public Result executeSync(List<QueryPolicyAndBrokerDto> queryPolicyAndBrokerDtoList,
                              String policyNo, List<ApiAnnouncementCommissionRatioListResponse> announcementRatioList,Integer paymentTerm) {
        log.info("同步处理-> 遍历保单转介人列表信息 -> 调用基本法算出预计发佣列表->入参queryPolicyAndBrokerDtoList：{}",JSON.toJSONString(queryPolicyAndBrokerDtoList));
@@ -556,6 +563,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
        return commissionRuleBindingList;
     }
+    @Transactional(rollbackFor = Exception.class)
    private List<ExpectedFortune> updatePayableNoBatch(String policyNo) {
        // 查询最新一条有 payableNo 记录
        ExpectedFortune latest = iExpectedFortuneService.getOne(
@@ -849,6 +857,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
    }
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Boolean add(List<ExpectedFortuneAddRequest> fortuneAddRequestList) {
        if (CollectionUtils.isEmpty(fortuneAddRequestList)) {
            return true;
@@ -969,6 +978,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService 
    }
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public void exportExpectedFortune(ApiExpectedFortunePageRequest request, HttpServletResponse response) {
        // 查询数据
        QueryWrapper<ExpectedFortune> queryWrapper = this.getQueryWrapper(request);

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiFormulaConfigServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiFormulaConfigServiceImpl.java
@@ -23,6 +23,7 @@ import com.yd.csf.service.service.IFormulaConfigService;
 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.Objects;
@@ -69,6 +70,7 @@ public class ApiFormulaConfigServiceImpl implements ApiFormulaConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiFormulaConfigAddRequest request) {
        //校验公式名称唯一性
        List<FormulaConfig> formulaConfigList = iFormulaConfigService.queryList(FormulaConfigDto.builder()
@@ -94,6 +96,7 @@ public class ApiFormulaConfigServiceImpl implements ApiFormulaConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiFormulaConfigEditRequest request) {
        Result<FormulaConfig> result = checkFormulaConfigIsExist(request.getFormulaBizId());
        FormulaConfig formulaConfig = result.getData();
@@ -119,6 +122,7 @@ public class ApiFormulaConfigServiceImpl implements ApiFormulaConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String formulaBizId) {
        return null;
    }

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiInsurantServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiInsurantServiceImpl.java
@@ -109,6 +109,7 @@ public class ApiInsurantServiceImpl implements ApiInsurantService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiInsurantInfoDto apiInsurantInfoDto) {
        //编辑预约入参字段校验 - 受保人信息字段校验
        apiAppointmentCheckService.checkEditApiInsurantInfoDto(apiInsurantInfoDto);
@@ -225,6 +226,7 @@ public class ApiInsurantServiceImpl implements ApiInsurantService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<Insurant> editInsurantData(ApiInsurantInfoDto dto, String appointmentBizId) {
        if (Objects.isNull(dto)){
            //受保人信息对象不能为空

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPolicyReceiptServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPolicyReceiptServiceImpl.java
@@ -21,6 +21,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 java.util.ArrayList;
@@ -79,6 +80,7 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiPolicyReceiptAddRequest request) {
        //校验保单信息是否存在
        Policy policy = policyService.queryOne(request.getPolicyNo());
@@ -101,6 +103,7 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiPolicyReceiptEditRequest request) {
        //校验保单回执信息是否存在
        PolicyReceipt policyReceipt = iPolicyReceiptService.queryOne(request.getPolicyReceiptBizId());
@@ -127,6 +130,7 @@ public class ApiPolicyReceiptServiceImpl implements ApiPolicyReceiptService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result editReceiptStatus(String policyReceiptBizId, String receiptStatus) {
        PolicyReceipt policyReceipt = iPolicyReceiptService.queryOne(policyReceiptBizId);
        if (Objects.isNull(policyReceipt)) {

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPolicyholderServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPolicyholderServiceImpl.java
@@ -101,6 +101,7 @@ public class ApiPolicyholderServiceImpl implements ApiPolicyholderService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiPolicyholderInfoDto apiPolicyholderInfoDto) {
        //编辑预约入参字段校验 - 投保人信息字段校验
        apiAppointmentCheckService.checkEditApiPolicyholderInfoDto(apiPolicyholderInfoDto);
@@ -165,6 +166,7 @@ public class ApiPolicyholderServiceImpl implements ApiPolicyholderService {
     * @param apiCertificateDtoList
     * @return
     */
+    @Transactional(rollbackFor = Exception.class)
    public Result addRelObjectCertificateList(String objectBizId,
                                              String objectType,
                                              String objectTableName,
@@ -187,6 +189,7 @@ public class ApiPolicyholderServiceImpl implements ApiPolicyholderService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<Policyholder> editPolicyholderData(ApiPolicyholderInfoDto dto, String appointmentBizId) {
        if (Objects.isNull(dto)) {
            //投保人信息对象不能为空

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumReconciliationServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumReconciliationServiceImpl.java
@@ -724,6 +724,7 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiPremiumReconciliationAddRequest request) {
        //根据当前Policy保单信息里面的生效日期、付款频率、缴费宽限期，校验当天是否在缴费期内，不在缴费期内不能保费对账 TODO 校验待定
        //保费对账信息
@@ -816,6 +817,7 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiPremiumReconciliationDto request) {
        if (StringUtils.isBlank(request.getPremiumReconciliationBizId())) {
            throw new BusinessException("保费对账记录表唯一业务ID不能为空");

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumRemittanceFileServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumRemittanceFileServiceImpl.java
@@ -17,6 +17,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 java.util.ArrayList;
 import java.util.List;
@@ -48,6 +49,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiPremiumRemittanceFileDto request) {
        if (StringUtils.isBlank(request.getPremiumRemittanceBizId())) {
            throw new BusinessException("保费对账-汇款记录表唯一业务ID不能为空");
@@ -66,6 +68,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiPremiumRemittanceFileDto request) {
        if (StringUtils.isBlank(request.getPremiumRemittanceBizId())) {
            throw new BusinessException("保费对账-汇款记录表唯一业务ID不能为空");
@@ -86,6 +89,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String premiumRemittanceFileBizId) {
        Result<PremiumRemittanceFile> result = checkPremiumRemittanceFileIsExist(premiumRemittanceFileBizId);
        PremiumRemittanceFile file = result.getData();
@@ -100,6 +104,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result addPremiumRemittanceFileList(List<ApiPremiumRemittanceFileDto> apiPremiumRemittanceFileDtoList,
                                               String premiumRemittanceBizId) {
        if (CollectionUtils.isEmpty(apiPremiumRemittanceFileDtoList)) {
@@ -124,6 +129,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result savePremiumRemittanceFileList(List<ApiPremiumRemittanceFileDto> apiPremiumRemittanceFileDtoList,
                                                String premiumRemittanceBizId) {
        //先删后新增
@@ -149,6 +155,7 @@ public class ApiPremiumRemittanceFileServiceImpl implements ApiPremiumRemittance
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result delByPremiumRemittanceBizId(String premiumRemittanceBizId) {
        iPremiumRemittanceFileService.delByPremiumRemittanceBizId(premiumRemittanceBizId);
        return Result.success();

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumRemittanceServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiPremiumRemittanceServiceImpl.java
@@ -20,6 +20,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 java.util.ArrayList;
 import java.util.Arrays;
@@ -55,6 +56,7 @@ public class ApiPremiumRemittanceServiceImpl implements ApiPremiumRemittanceServ
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiPremiumRemittanceDto request) {
        if (StringUtils.isBlank(request.getPremiumReconciliationBizId())) {
            throw new BusinessException("保费对账记录表唯一业务ID不能为空");
@@ -72,6 +74,7 @@ public class ApiPremiumRemittanceServiceImpl implements ApiPremiumRemittanceServ
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiPremiumRemittanceDto request) {
        if (StringUtils.isBlank(request.getPremiumRemittanceBizId())) {
            throw new BusinessException("保费对账-汇款记录表唯一业务ID不能为空");
@@ -112,6 +115,7 @@ public class ApiPremiumRemittanceServiceImpl implements ApiPremiumRemittanceServ
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String premiumRemittanceBizId) {
        checkPremiumRemittanceIsExist(premiumRemittanceBizId);
        //删除保费对账汇款记录附件列表
@@ -128,6 +132,7 @@ public class ApiPremiumRemittanceServiceImpl implements ApiPremiumRemittanceServ
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result addPremiumRemittanceList(List<ApiPremiumRemittanceDto> apiPremiumRemittanceDtoList,
                                            String premiumReconciliationBizId) {
        if (CollectionUtils.isEmpty(apiPremiumRemittanceDtoList)) {

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiProductPlanServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiProductPlanServiceImpl.java
@@ -81,6 +81,7 @@ public class ApiProductPlanServiceImpl implements ApiProductPlanService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<String> edit(ApiProductPlanMainInfoDto apiProductPlanMainInfoDto) {
        //编辑预约入参字段校验 - 产品计划信息字段校验 - 产品计划主信息字段校验
@@ -102,6 +103,7 @@ public class ApiProductPlanServiceImpl implements ApiProductPlanService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result editPlan(ApiProductPlanInfoDto apiProductPlanInfoDto) {
        //编辑产品计划主体信息
        Result<String> result = edit(apiProductPlanInfoDto.getApiProductPlanMainInfoDto());
@@ -146,6 +148,7 @@ public class ApiProductPlanServiceImpl implements ApiProductPlanService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<ProductPlan> editProductPlanData(ApiProductPlanInfoDto productPlanInfoDto, String appointmentBizId) {
        if (Objects.isNull(productPlanInfoDto)
                || ( !Objects.isNull(productPlanInfoDto) && Objects.isNull(productPlanInfoDto.getApiProductPlanMainInfoDto()))){

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectConditionServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectConditionServiceImpl.java
@@ -12,6 +12,7 @@ import com.yd.csf.service.service.IRelObjectConditionService;
 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.ArrayList;
 import java.util.List;
@@ -32,6 +33,7 @@ public class ApiRelObjectConditionServiceImpl implements ApiRelObjectConditionSe
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveRelList(ApiRelObjectConditionDto dto) {
        //先删后新增
        iRelObjectConditionService.del(dto);

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectFormulaServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectFormulaServiceImpl.java
@@ -13,6 +13,7 @@ import com.yd.csf.service.service.IRelObjectFormulaService;
 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.ArrayList;
 import java.util.List;
@@ -60,6 +61,7 @@ public class ApiRelObjectFormulaServiceImpl implements ApiRelObjectFormulaServic
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveRelList(ApiRelObjectFormulaDto dto) {
        //先删后新增
        RelObjectFormulaDto relObjectFormulaDto = new RelObjectFormulaDto();
@@ -86,6 +88,7 @@ public class ApiRelObjectFormulaServiceImpl implements ApiRelObjectFormulaServic
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveObjectList(List<ApiRelObjectFormulaDto> objectList, String formulaBizId) {
        //先删后新增
        iRelObjectFormulaService.delObjectList(formulaBizId);

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectSqlServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRelObjectSqlServiceImpl.java
@@ -13,6 +13,7 @@ import com.yd.csf.service.service.IRelObjectSqlService;
 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.ArrayList;
 import java.util.List;
@@ -28,6 +29,7 @@ public class ApiRelObjectSqlServiceImpl implements ApiRelObjectSqlService {
    private ICommissionSqlTemplateService iCommissionSqlTemplateService;
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveRelList(ApiRelObjectSqlDto dto) {
        //先删后新增
        RelObjectSqlDto relObjectSqlDto = new RelObjectSqlDto();

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRuleItemConfigServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiRuleItemConfigServiceImpl.java
@@ -24,6 +24,7 @@ import com.yd.csf.service.service.IRuleItemConfigService;
 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.ArrayList;
 import java.util.List;
@@ -79,6 +80,7 @@ public class ApiRuleItemConfigServiceImpl implements ApiRuleItemConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiRuleItemConfigAddRequest request) {
        //校验基本法项目名称的唯一性
        List<RuleItemConfig> list = iRuleItemConfigService.queryList(RuleItemConfigDto.builder()
@@ -115,6 +117,7 @@ public class ApiRuleItemConfigServiceImpl implements ApiRuleItemConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiRuleItemConfigEditRequest request) {
        Result<RuleItemConfig>  result = checkRuleItemConfigIsExist(request.getRuleItemBizId());
        RuleItemConfig ruleItemConfig = result.getData();
@@ -150,6 +153,7 @@ public class ApiRuleItemConfigServiceImpl implements ApiRuleItemConfigService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String ruleItemBizId) {
        return null;
    }

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiSecondHolderServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiSecondHolderServiceImpl.java
@@ -55,6 +55,7 @@ public class ApiSecondHolderServiceImpl implements ApiSecondHolderService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiSecondHolderInfoDto apiSecondHolderInfoDto) {
        //编辑预约入参字段校验 - 第二持有人信息字段校验
        apiAppointmentCheckService.checkEditApiSecondHolderInfoDto(apiSecondHolderInfoDto);
@@ -97,6 +98,7 @@ public class ApiSecondHolderServiceImpl implements ApiSecondHolderService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result<SecondHolder> editSecondHolderData(ApiSecondHolderInfoDto dto, String appointmentBizId) {
        if (Objects.isNull(dto)){
            //为空

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiTaxationServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiTaxationServiceImpl.java
@@ -13,6 +13,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.ArrayList;
@@ -32,6 +33,7 @@ public class ApiTaxationServiceImpl implements ApiTaxationService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result saveTaxationList(ApiObjectTaxationDto dto) {
        //先删后新增
        iTaxationService.delByObjectBizId(dto.getObjectBizId());

--- a/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiVariableServiceImpl.java
+++ b/yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiVariableServiceImpl.java
@@ -30,6 +30,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 java.util.ArrayList;
@@ -93,6 +94,7 @@ public class ApiVariableServiceImpl implements ApiVariableService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result add(ApiVariableAddRequest request) {
        //校验变量中文名唯一性
        List<Variable> variableList = iVariableService.queryList(VariableDto.builder()
@@ -150,6 +152,7 @@ public class ApiVariableServiceImpl implements ApiVariableService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result edit(ApiVariableEditRequest request) {
        //校验变量信息是否存在
        Result<Variable> result = checkVariableIsExist(request.getVariableBizId());
@@ -209,6 +212,7 @@ public class ApiVariableServiceImpl implements ApiVariableService {
     * @return
     */
    @Override
+    @Transactional(rollbackFor = Exception.class)
    public Result del(String variableBizId) {
        return null;
    }