优化

anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busdeliveredapply/BusDeliveredApplyService.java

@@ -812,15 +812,13 @@ public class BusDeliveredApplyService extends MybatisBaseService<BusDeliveredApp
             updateFlowFiled(BeanUtil.beanToMap(resultBean.getData()));
             if ("Event_end".equals(resultBean.getData().getTaskDefKey())) {
                 baseMapper.updateStateBySid(3, bv.getBusinessSid());
-
-                //==============================修改车辆的持久状态组装数据
                 try {
                     ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
                             .setNameFormat("demo-pool-%d").build();
-                    ExecutorService pool = new ThreadPoolExecutor(2, 100,
-                            0L, TimeUnit.MILLISECONDS,
+                    ExecutorService pool = new ThreadPoolExecutor(1, 10,
+                            1000, TimeUnit.MILLISECONDS,
                             new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
-                    Future future1 = pool.submit(() -> {
+                    Future future0 = pool.submit(() -> {
                         List<BaseVehicleStateDto> dtoList = new ArrayList<>();
                         List<String> vinSidList = busDeliveredApplyDetailsService.selectVinSidByApplySid(bv.getBusinessSid());
                         vinSidList.removeAll(Collections.singleton(null));
@@ -834,15 +832,6 @@ public class BusDeliveredApplyService extends MybatisBaseService<BusDeliveredApp
                             ResultBean busVehicleStateResultBean = baseVehicleStateFeign.saveOrUpdate(dtoList);
                         }
                     });
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-                try {
-                    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
-                            .setNameFormat("demo-pool-%d").build();
-                    ExecutorService pool = new ThreadPoolExecutor(1, 10,
-                            1000, TimeUnit.MILLISECONDS,
-                            new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
                     List<BusDeliveredApplyDetails> detailsList = busDeliveredApplyDetailsService.selectByApplySid(busDeliveredApply.getSid());
                     ResultBean<AppOrderDetailsVo> orderDetailsVoResultBean = busSalesOrderService.getSaleOrderDetailsByContractNo(busDeliveredApply.getContractNo());
                     if (!orderDetailsVoResultBean.getSuccess()) {
@@ -1012,6 +1001,7 @@ public class BusDeliveredApplyService extends MybatisBaseService<BusDeliveredApp
         }
         dto.setAppBusHandoverPrepareVehicleDtos(dtos);
         busHandoverPrepareService.addHandoverPrepare(dto);
+        log.info("推送待交车准备数据结束啦~~~~~~~~~~~~~~~~~~~~~~~~==============================");
     }
 
     /**