zjh
2023-09-14 3194e189b44e22cf293c6cd88d9af854a287077d
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) {