Explorar o código

接单生成们门卫数据

donglang hai 2 meses
pai
achega
ace90b237a

+ 21 - 21
sckw-modules/sckw-transport/src/main/java/com/sckw/transport/handler/TakingOrderHandler.java

@@ -137,29 +137,29 @@ public class TakingOrderHandler extends AbstractWaybillOrderHandler<OrderCircula
      * @param truckLoadVolume
      */
     private void createGatekeeperWaybillOrder(KwtWaybillOrder waybillOrder, RTruckVo truck, BigDecimal truckLoadVolume) {
-        KwtGatekeeperWaybillOrder gatekeeper = new KwtGatekeeperWaybillOrder();
-        gatekeeper.setEntId(waybillOrder.getEntId());
-        gatekeeper.setWOrderId(waybillOrder.getId());
-        gatekeeper.setWOrderNo(waybillOrder.getWOrderNo());
-        gatekeeper.setLOrderId(waybillOrder.getLOrderId());
-        // 查询商品信息
-        KwtLogisticsOrderGoods orderGoods = logisticsOrderGoodsRepository.queryByLogOrderId(waybillOrder.getLOrderId());
-        if (orderGoods != null) {
-            gatekeeper.setGoodsId(orderGoods.getGoodsId());
-            gatekeeper.setGoodsName(orderGoods.getGoodsName());
-        }
-        gatekeeper.setStatus(GatekeeperStatusEnum.PENDING_ENTRY.getCode());
-        gatekeeper.setWaybillAcceptTime(waybillOrder.getCreateTime());
-        gatekeeper.setTruckType(truck.getTruckType());
-        gatekeeper.setEntrustAmount(truckLoadVolume);
-        gatekeeper.setCarAxis(truck.getCarAxis());
-        gatekeeper.setLegalLoad(truck.getLegalLoad());
-        gatekeeper.setCreateTime(new Date());
-        gatekeeper.setCreateUser(waybillOrder.getDriverId());
-        gatekeeper.setUpdateUser(waybillOrder.getDriverId());
-
         CompletableFuture.runAsync(() -> {
             try {
+                KwtGatekeeperWaybillOrder gatekeeper = new KwtGatekeeperWaybillOrder();
+                gatekeeper.setEntId(waybillOrder.getEntId());
+                gatekeeper.setWOrderId(waybillOrder.getId());
+                gatekeeper.setWOrderNo(waybillOrder.getWOrderNo());
+                gatekeeper.setLOrderId(waybillOrder.getLOrderId());
+                // 查询商品信息
+                KwtLogisticsOrderGoods orderGoods = logisticsOrderGoodsRepository.queryByLogOrderId(waybillOrder.getLOrderId());
+                if (orderGoods != null) {
+                    gatekeeper.setGoodsId(orderGoods.getGoodsId());
+                    gatekeeper.setGoodsName(orderGoods.getGoodsName());
+                }
+                gatekeeper.setStatus(GatekeeperStatusEnum.PENDING_ENTRY.getCode());
+                gatekeeper.setWaybillAcceptTime(waybillOrder.getCreateTime());
+                gatekeeper.setTruckType(truck.getTruckType());
+                gatekeeper.setEntrustAmount(truckLoadVolume);
+                gatekeeper.setCarAxis(truck.getCarAxis());
+                gatekeeper.setLegalLoad(truck.getLegalLoad());
+                gatekeeper.setCreateTime(new Date());
+                gatekeeper.setCreateUser(waybillOrder.getDriverId());
+                gatekeeper.setUpdateUser(waybillOrder.getDriverId());
+
                 log.debug("开始异步保存门卫订单数据,运单ID:{}", waybillOrder.getId());
                 gatekeeperWaybillOrderRepository.save(gatekeeper);
                 log.debug("门卫订单数据保存成功");