From de2ba205c3752992c27777a93823f6292e58d7c3 Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期四, 14 九月 2023 15:54:15 +0800
Subject: [PATCH] zjh 2023/09/14---2
---
ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjAsyncServiceImpl.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjAsyncServiceImpl.java b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjAsyncServiceImpl.java
index d1e678d..fb094cd 100644
--- a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjAsyncServiceImpl.java
+++ b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjAsyncServiceImpl.java
@@ -24,6 +24,8 @@
import java.math.RoundingMode;
import java.nio.charset.StandardCharsets;
import java.util.*;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
@@ -857,6 +859,36 @@
}
}
+ @Override
+ @Async("async")
+ public void saveNewReservationConfirm(List<TjReservation> rightList) {
+ long l = System.currentTimeMillis();
+ if(null !=rightList && rightList.size()>0){
+ //鍒涘缓绾跨▼姹�
+ ExecutorService threadPool = Executors.newFixedThreadPool(rightList.size());
+ for (TjReservation reservation : rightList) {
+ //鍒犻櫎涔嬪墠鐨勬暟鎹�
+ transitionService.deletedTbTransitionByCusId(reservation.getIdCard());
+ //鑾峰彇绾跨▼
+ threadPool.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ transitionService.saveTemoTransitionByGroupingId(reservation.getIdCard(),reservation.getGroupingId());
+
+ threadPool.shutdown();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ });
+ }
+ }
+ long ll = System.currentTimeMillis();
+
+ System.out.println("杩欐浠ｇ爜鎵ц鏃堕棿涓�"+ (ll-l));
+ }
+
private void getTjPackageListsByMan(List<TjPackage> tjPackageList) {
if (null != tjPackageList && tjPackageList.size() > 0) {
for (TjPackage aPackage : tjPackageList) {
--
Gitblit v1.8.0