提交解绑车辆bug

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/repository/KwtWaybillOrderSubtaskRepository.java

@@ -84,4 +84,13 @@ public class KwtWaybillOrderSubtaskRepository extends ServiceImpl<KwtWaybillOrde
                 .eq(BaseModel::getDelFlag,0)
                 .last("limit 1"));
     }
+
+    public List<KwtWaybillOrderSubtask> findByList(Integer status, Set<Long> billOrderIds, Set<Long> logOrderIds) {
+        return list(Wrappers.<KwtWaybillOrderSubtask>lambdaQuery()
+                .eq(BaseModel::getDelFlag,0)
+                .eq(Objects.nonNull( status),KwtWaybillOrderSubtask::getStatus, status)
+                .in(CollectionUtils.isNotEmpty(logOrderIds),KwtWaybillOrderSubtask::getLOrderId, logOrderIds)
+                .in(CollectionUtils.isNotEmpty(billOrderIds),KwtWaybillOrderSubtask::getWOrderId, billOrderIds)
+        );
+    }
 }

sckw-modules/sckw-transport/src/main/java/com/sckw/transport/service/KwtWaybillOrderV1Service.java

@@ -2984,7 +2984,7 @@ public class KwtWaybillOrderV1Service {
 
         //查询运单信息
         //运单id集合
-        Set<Long> billOrderIds = getBillOrderIds(req,null);
+        Set<Long> billOrderIds = getBillOrderIds(req);
         boolean b = Stream.of(req.getWaybillNo(), req.getTruckNo(), req.getDriverName(), req.getPhone(),
                         req.getLoadStartTime(),req.getLoadEndTime(),req.getUnloadStartTime(),req.getUnloadEndTime())
                         .anyMatch(StringUtils::isNotBlank);
@@ -3279,7 +3279,7 @@ public class KwtWaybillOrderV1Service {
     }
 
     @NotNull
-    private Set<Long> getBillOrderIds(WaybillOrderReq req,Set<Long> logOrderIds) {
+    private Set<Long> getBillOrderIds(WaybillOrderReq req) {
         Set<Long> billOrderIds = Sets.newHashSet();
         KwtWaybillOrder order = getKwtWaybillOrder(req);
         boolean b = Stream.of(req.getWaybillNo(), req.getTruckNo(), req.getDriverName(), req.getPhone()).anyMatch(StringUtils::isNotBlank);
@@ -3314,16 +3314,16 @@ public class KwtWaybillOrderV1Service {
                         .collect(Collectors.toSet()));
             }
         }
-        if (CollectionUtils.isNotEmpty(logOrderIds)){
-            //查询子运单
-            List<KwtWaybillOrderSubtask> waybillOrderSubtasks = kwtWaybillOrderSubtaskRepository.queryByLogIds(new ArrayList<>(logOrderIds));
-            Set<Long> billOrderIdList = Optional.ofNullable(waybillOrderSubtasks).orElse(List.of()).stream()
-                    .map(KwtWaybillOrderSubtask::getWOrderId)
-                    .collect(Collectors.toSet());
-            if (CollectionUtils.isNotEmpty(billOrderIdList)){
-                billOrderIds.addAll(billOrderIdList);
-            }
-        }
+//        if (CollectionUtils.isNotEmpty(logOrderIds)){
+//            //查询子运单
+//            List<KwtWaybillOrderSubtask> waybillOrderSubtasks = kwtWaybillOrderSubtaskRepository.queryByLogIds(new ArrayList<>(logOrderIds));
+//            Set<Long> billOrderIdList = Optional.ofNullable(waybillOrderSubtasks).orElse(List.of()).stream()
+//                    .map(KwtWaybillOrderSubtask::getWOrderId)
+//                    .collect(Collectors.toSet());
+//            if (CollectionUtils.isNotEmpty(billOrderIdList)){
+//                billOrderIds.addAll(billOrderIdList);
+//            }
+//        }
         return billOrderIds;
     }
 
@@ -4277,7 +4277,7 @@ public class KwtWaybillOrderV1Service {
         boolean b1 = !org.apache.commons.lang3.StringUtils.isAllBlank(req.getLogisticsOrderNo(), req.getGoodsName(),
                 req.getCarrierId(), req.getConsignorId());
         if(org.apache.commons.collections4.CollectionUtils.isEmpty(logOrderIds) && b1){
-            Map<Integer, List<KwtWaybillOrder>> stausAndBillOrdersMap = Maps.newHashMap();
+            Map<Integer, List<KwtWaybillOrderSubtask>> stausAndBillOrdersMap = Maps.newHashMap();
             List<StatisticsWaybillResp.OrderBillStatusStatistics> statusStatistics = carWaybillV1Enums.stream()
                     .map(c -> getOrderBillStatusStatistics(c, stausAndBillOrdersMap))
                     .collect(Collectors.toList());
@@ -4286,12 +4286,12 @@ public class KwtWaybillOrderV1Service {
         }
         //查询运单信息
         //运单id集合
-        Set<Long> billOrderIds = getBillOrderIds(req,logOrderIds);
+        Set<Long> billOrderIds = getBillOrderIds(req);
         boolean b = Stream.of(req.getWaybillNo(), req.getTruckNo(), req.getDriverName(), req.getPhone(),
                         req.getLoadStartTime(),req.getLoadEndTime(),req.getUnloadStartTime(),req.getUnloadEndTime())
-                .anyMatch(StringUtils::isNotBlank) || Objects.nonNull(LoginUserHolder.getEntId());
+                .anyMatch(StringUtils::isNotBlank);
         if (org.apache.commons.collections4.CollectionUtils.isEmpty(billOrderIds) && b){
-            Map<Integer, List<KwtWaybillOrder>> stausAndBillOrdersMap = Maps.newHashMap();
+            Map<Integer, List<KwtWaybillOrderSubtask>> stausAndBillOrdersMap = Maps.newHashMap();
             List<StatisticsWaybillResp.OrderBillStatusStatistics> statusStatistics = carWaybillV1Enums.stream()
                     .map(c -> getOrderBillStatusStatistics(c, stausAndBillOrdersMap))
                     .collect(Collectors.toList());
@@ -4299,17 +4299,18 @@ public class KwtWaybillOrderV1Service {
             return statisticsWaybillResp;
         }
 
-        List<KwtWaybillOrder> orders = kwtWaybillOrderRepository.findList(status,billOrderIds,logOrderIds);
-
+       // List<KwtWaybillOrder> orders = kwtWaybillOrderRepository.findList(status,billOrderIds,logOrderIds);
+        //查询子运单
+        List<KwtWaybillOrderSubtask> orders = kwtWaybillOrderSubtaskRepository.findByList(status,billOrderIds,logOrderIds);
         if (CollectionUtils.isEmpty(orders)) {
-            Map<Integer, List<KwtWaybillOrder>> stausAndBillOrdersMap = Maps.newHashMap();
+            Map<Integer, List<KwtWaybillOrderSubtask>> stausAndBillOrdersMap = Maps.newHashMap();
             List<StatisticsWaybillResp.OrderBillStatusStatistics> statusStatistics = carWaybillV1Enums.stream()
                     .map(c -> getOrderBillStatusStatistics(c, stausAndBillOrdersMap))
                     .collect(Collectors.toList());
             statisticsWaybillResp.setOrderStatusStatistics(statusStatistics);
             return statisticsWaybillResp;
         }
-        Map<Integer,List<KwtWaybillOrder>> stausAndBillOrdersMap = orders.stream().collect(Collectors.groupingBy(KwtWaybillOrder::getStatus));
+        Map<Integer,List<KwtWaybillOrderSubtask>> stausAndBillOrdersMap = orders.stream().collect(Collectors.groupingBy(KwtWaybillOrderSubtask::getStatus));
         List<StatisticsWaybillResp.OrderBillStatusStatistics> statusStatis = carWaybillV1Enums.stream()
                 .map(c -> getOrderBillStatusStatistics(c, stausAndBillOrdersMap))
                 .collect(Collectors.toList());
@@ -4318,7 +4319,7 @@ public class KwtWaybillOrderV1Service {
        return statisticsWaybillResp;
     }
 
-    private static StatisticsWaybillResp.OrderBillStatusStatistics getOrderBillStatusStatistics(CarWaybillV1Enum c, Map<Integer, List<KwtWaybillOrder>> finalStausAndBillOrdersMap) {
+    private static StatisticsWaybillResp.OrderBillStatusStatistics getOrderBillStatusStatistics(CarWaybillV1Enum c, Map<Integer, List<KwtWaybillOrderSubtask>> finalStausAndBillOrdersMap) {
         StatisticsWaybillResp.OrderBillStatusStatistics orderBillStatusStatistics = new StatisticsWaybillResp.OrderBillStatusStatistics();
         orderBillStatusStatistics.setOrderStatus(String.valueOf(c.getCode()));
         orderBillStatusStatistics.setOrderStatusDesc(c.getDestination());