电视剧，导入代码优化

sql/update.sql

@@ -0,0 +1,13 @@
+-- 电视剧导入，统计sql处理，保留最新数据
+DELETE t1 FROM ad_theatre_tv_stat t1,
+(
+	select name,`media_name`,`theatre_time`,`show_date`,
+	max(id) id FROM ad_theatre_tv_stat group by
+	name,`media_name`,`theatre_time`,`show_date`
+	having count(*) >1
+) t2 WHERE t1.name = t2.name and
+ t1.media_name = t2.media_name and t1.theatre_time = t2.theatre_time and t1.show_date = t2.show_date
+ AND t1.id < t2.id
+
+
+

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

@@ -35,7 +35,9 @@ import javax.servlet.http.HttpServletResponse;
 import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
 
 /**
  * 剧场管理
@@ -262,11 +264,18 @@ public class AdTheatreController extends BaseController{
 			}
 			// 入库
 			List<AdTheatre> adTheatres = adTheatreService.batchAdd(list, tvList);
-
+			//电视剧分组
+			Map<String,List<AdTheatre>> map = list.stream().collect(Collectors.groupingBy(b -> b.getName()));
+			for (Map.Entry<String, List<AdTheatre>> entry : map.entrySet()) {
+				if(CollectionUtils.isNotEmpty(entry.getValue())){
+					CompletableFuture[] completableFutures = entry.getValue().stream().map(x -> CompletableFuture.runAsync(() -> {
+						adTheatreTvStatService.saveStatByTheatreTv(x);
+					}, taskExecutor)).toArray(CompletableFuture[]::new);
+					CompletableFuture.allOf(completableFutures).join();
+				}
+			}
 			// 判断执行结果
 			if (adTheatres != null) {
-				//异步统计数据
-				asyncBatchSaveStatByTheatreTv(adTheatres);
 				request.setAttribute("repeat", 0);
 				request.setAttribute("code", Constants.CODE_SUCCESS);
 				request.setAttribute("msg", msg);
@@ -283,13 +292,4 @@ public class AdTheatreController extends BaseController{
 		request.setAttribute("msg", msg);
 		return returnHtml;
 	}
-
-	// 异步统计数据
-	private void asyncBatchSaveStatByTheatreTv(List<AdTheatre> adTheatres) {
-		CompletableFuture.runAsync(() -> {
-			for (AdTheatre adTheatre:adTheatres) {
-				adTheatreTvStatService.saveStatByTheatreTv(adTheatre);
-			}
-		}, taskExecutor);
-	}
 }