电视剧，统计电视剧数据，添加事务

src/main/java/com/ylcm/sys/controller/AdTheatreController.java

@@ -268,7 +268,7 @@ public class AdTheatreController extends BaseController{
 			Map<String,List<AdTheatre>> mapList = adTheatres.stream().collect(Collectors.groupingBy(b -> b.getName()));
             // 同步
 			CompletableFuture[] completableFutures = mapList.keySet().stream().map(x -> CompletableFuture.runAsync(() -> {
-				batchSaveStatByTheatreTv(mapList.get(x));
+				adTheatreTvStatService.batchSaveStatByTheatreTv(mapList.get(x));
 			}, taskExecutor)).toArray(CompletableFuture[]::new);
 			CompletableFuture.allOf(completableFutures).join();
 
@@ -291,10 +291,4 @@ public class AdTheatreController extends BaseController{
 		return returnHtml;
 	}
 
-	// 顺序处理数据统计
-	private void batchSaveStatByTheatreTv(List<AdTheatre> adTheatres){
-		for(AdTheatre adTheatre : adTheatres){
-			adTheatreTvStatService.saveStatByTheatreTv(adTheatre);
-		}
-	}
 }

src/main/java/com/ylcm/sys/service/AdTheatreTvStatService.java

@@ -95,4 +95,10 @@ public interface AdTheatreTvStatService extends IService<AdTheatreTvStat> {
 	 * @param oldFirstTheme
 	 */
 	void batchUpdateByName(String newName, String oldName, String firstTheme, String oldFirstTheme, String secondTheme);
+
+	/**
+	 * 批量同步统计数据
+	 * @param adTheatres
+	 */
+	void batchSaveStatByTheatreTv(List<AdTheatre> adTheatres);
 }

src/main/java/com/ylcm/sys/service/impl/AdTheatreTvStatServiceImpl.java

@@ -417,4 +417,12 @@ public class AdTheatreTvStatServiceImpl extends ServiceImpl<AdTheatreTvStatMappe
 
 		baseMapper.update(adTheatreTvStat, statQueryWrapper);
 	}
+
+	@Override
+	@Transactional(rollbackFor = Exception.class)
+	public void batchSaveStatByTheatreTv(List<AdTheatre> adTheatres) {
+		for(AdTheatre adTheatre : adTheatres){
+			saveStatByTheatreTv(adTheatre);
+		}
+	}
 }