push

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAdditionalServiceImpl.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;
 import java.util.List;
@@ -148,6 +149,7 @@ public class ApiAdditionalServiceImpl implements ApiAdditionalService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result batchAddAdditionalData(ApiProductPlanInfoDto productPlanInfoDto, String planBizId) {
         if (Objects.isNull(productPlanInfoDto)
                 || ( !Objects.isNull(productPlanInfoDto)

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentReferrerServiceImpl.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.ArrayList;
@@ -31,6 +32,7 @@ public class ApiAppointmentReferrerServiceImpl implements ApiAppointmentReferrer
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result saveAppointmentReferrerList(List<ApiAppointmentReferrerDto> referrerDtoList,
                                               String appointmentBizId) {
         if (CollectionUtils.isEmpty(referrerDtoList)) {

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentUserSignServiceImpl.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;
@@ -33,6 +34,7 @@ public class ApiAppointmentUserSignServiceImpl implements ApiAppointmentUserSign
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result saveAppointmentUserSignList(List<ApiAppointmentUserSignDto> userSignDtoList, String appointmentBizId) {
         if (CollectionUtils.isEmpty(userSignDtoList)) {
             return Result.success();

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiBeneficiaryServiceImpl.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.List;
@@ -145,6 +146,7 @@ public class ApiBeneficiaryServiceImpl implements ApiBeneficiaryService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result batchAddBeneficiaryData(List<ApiBeneficiaryInfoDto> apiBeneficiaryInfoDtoList,
                                                        String appointmentBizId) {
         if (CollectionUtils.isEmpty(apiBeneficiaryInfoDtoList)){

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

@@ -28,6 +28,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;
@@ -123,6 +124,7 @@ public class ApiInsurantServiceImpl implements ApiInsurantService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result<Insurant> addInsurantData(ApiInsurantInfoDto dto, String appointmentBizId) {
         if (Objects.isNull(dto)){
             //为空设置，方便新建暂存公用方法

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

@@ -23,6 +23,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;
@@ -115,6 +116,7 @@ public class ApiPolicyholderServiceImpl implements ApiPolicyholderService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result<Policyholder> addPolicyholderData(ApiPolicyholderInfoDto dto, String appointmentBizId) {
         if (Objects.isNull(dto)){
             //为空设置，方便新建暂存公用方法

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

@@ -18,6 +18,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 java.util.List;
 import java.util.Objects;
@@ -115,6 +116,7 @@ public class ApiProductPlanServiceImpl implements ApiProductPlanService {
      * @param appointmentBizId
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Result<ProductPlan> addProductPlanData(ApiProductPlanInfoDto productPlanInfoDto,String appointmentBizId) {
         if (Objects.isNull(productPlanInfoDto)) {
             //为空设置，方便新建暂存公用方法

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

@@ -15,6 +15,8 @@ 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 java.util.Objects;
 
 /**
@@ -71,6 +73,7 @@ public class ApiSecondHolderServiceImpl implements ApiSecondHolderService {
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Result<SecondHolder> addSecondHolderData(ApiSecondHolderInfoDto dto, String appointmentBizId) {
         if (Objects.isNull(dto)){
             //为空设置，方便新建暂存公用方法