Browse Source

fix: 修复无事务

huangzqa 1 year ago
parent
commit
4b2cc1eccc

+ 4 - 0
approve-core-service/src/main/java/com/dragonsoft/dcuc/approve/service/impl/ApproveOrgInfoServiceImpl.java

@@ -16,6 +16,7 @@ import com.dragonsoft.duceap.core.search.Searchable;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Collection;
 import java.util.Date;
@@ -62,6 +63,9 @@ public class ApproveOrgInfoServiceImpl extends ServiceImpl<ApproveOrgInfoMapper,
         return approveOrgInfoMapper.selectOne(lambdaQueryWrapper);
     }
 
+    @Transactional(
+            rollbackFor = {Exception.class}
+    )
     @Override
     public void saveAllList(Collection<ApproveOrgInfo> saveList) {
         if (CollUtil.isEmpty(saveList)) {

+ 4 - 0
approve-core-service/src/main/java/com/dragonsoft/dcuc/approve/service/impl/ApproveSecurityWarningUserServiceImpl.java

@@ -10,6 +10,7 @@ import com.dragonsoft.dcuc.approve.model.ApproveSecurityWarningUser;
 import com.dragonsoft.dcuc.approve.service.IApproveSecurityWarningUserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.Collections;
@@ -35,6 +36,9 @@ public class ApproveSecurityWarningUserServiceImpl extends ServiceImpl<ApproveSe
         this.approveSecurityWarningUserMapper = approveSecurityWarningUserMapper;
     }
 
+    @Transactional(
+            rollbackFor = {Exception.class}
+    )
     @Override
     public void saveAllWarningUser(String warningId, Date riskCreateTime, List<String> userList) {
         Assert.notBlank(warningId);

+ 4 - 0
approve-core-service/src/main/java/com/dragonsoft/dcuc/approve/service/impl/ApproveUserInfoServiceImpl.java

@@ -16,6 +16,7 @@ import com.dragonsoft.duceap.core.search.Searchable;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -62,6 +63,9 @@ public class ApproveUserInfoServiceImpl extends ServiceImpl<ApproveUserInfoMappe
         return approveUserInfoMapper.selectOne(lambdaQueryWrapper);
     }
 
+    @Transactional(
+            rollbackFor = {Exception.class}
+    )
     @Override
     public void saveAllList(Collection<ApproveUserInfo> saveList) {
         if (CollUtil.isEmpty(saveList)) {