| | |
| | | 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; |
| | |
| | | } |
| | | } |
| | | |
| | | @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) { |