From af47617d37e85e5b1e1a71bebfb36cc545fcde55 Mon Sep 17 00:00:00 2001
From: chendaofei <857448963@qq.com>
Date: Wed, 8 Jan 2025 13:59:37 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../storage/service/impl/DetectionDataServiceImpl.java       | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/storage/src/main/java/com/njcn/gather/storage/service/impl/DetectionDataServiceImpl.java b/storage/src/main/java/com/njcn/gather/storage/service/impl/DetectionDataServiceImpl.java
index cd40447e..5008cc28 100644
--- a/storage/src/main/java/com/njcn/gather/storage/service/impl/DetectionDataServiceImpl.java
+++ b/storage/src/main/java/com/njcn/gather/storage/service/impl/DetectionDataServiceImpl.java
@@ -11,6 +11,7 @@ import com.njcn.gather.storage.service.AdNonHarmonicService;
 import com.njcn.gather.storage.service.DetectionDataDealService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.stream.Collectors;
@@ -28,6 +29,7 @@ public class DetectionDataServiceImpl extends ReplenishMybatisServiceImpl<Detect
 
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Boolean acceptAdNon(List<AdNonHarmonicResult> adNonHarmonicResultList, String code) {
         String adNonTable = "ad_non_harmonic_";
         DynamicTableNameHandler.setTableName(adNonTable + code);
@@ -41,6 +43,7 @@ public class DetectionDataServiceImpl extends ReplenishMybatisServiceImpl<Detect
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Boolean acceptAd(List<AdHarmonicResult> adHarmonicResultList, String code) {
         String adTable = "ad_harmonic_";
         DynamicTableNameHandler.setTableName(adTable + code);
@@ -55,6 +58,7 @@ public class DetectionDataServiceImpl extends ReplenishMybatisServiceImpl<Detect
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Boolean acceptAdNonResult(List<AdNonHarmonicResult> adNonHarmonicResultList, String code) {
         String adNonTableResult = "ad_non_harmonic_result_";
         DynamicTableNameHandler.setTableName(adNonTableResult + code);
@@ -73,6 +77,7 @@ public class DetectionDataServiceImpl extends ReplenishMybatisServiceImpl<Detect
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Boolean acceptAdResult(List<AdHarmonicResult> adHarmonicResultList, String code) {
         String adTableResult = "ad_harmonic_result_";
         DynamicTableNameHandler.setTableName(adTableResult + code);