楚江erp：草稿要车单审核通过逻辑调整

@@ -519,6 +519,25 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
                 // 生成要车单
                 CreateRequestCarTicketVo ticketCreateVo = packRequestCarTicket(draftRequestCarTicket, requestCarPlanId, variable);
                 requestCarTicketService.create(ticketCreateVo);
+                // 处理发货单
+                List<String> orderIds = shipmentsPlanDetailService.getOrderIdByShipmentOrderId(ticketCreateVo.getShipmentsOrderId());
+                List<DraftRequestCarTicket> draftRequestCarTicketList = draftRequestCarTicketService.listByOrderId(orderIds);
+                if (CollectionUtils.isNotEmpty(draftRequestCarTicketList)) {
+                    boolean flag = true;
+                    for (DraftRequestCarTicket draftTicket : draftRequestCarTicketList) {
+                        if (businessId.equals(draftTicket.getId())) {
+                            continue;
+                        }
+                        if (!"PASS".equals(draftTicket.getStatus())) {
+                            flag = false;
+                            break;
+                        }
+                    }
+                    if (flag) {
+                        // 更新订货单状态（草稿转为正常）
+                        shipmentsOrderInfoService.updateStatus(ticketCreateVo.getShipmentsOrderId(), "UN_SHIPMENTS");
+                    }
+                }
             }
         } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
@@ -574,8 +593,6 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             String loadingTime = minTime.format(formatter);
             ticketVo.setLoadingTime(loadingTime);
             redisHandler.del("GET_SHIPMENTS_ORDER_ID_" + draftRequestCarTicket.getId());
-            // 更新订货单状态（草稿转为正常）
-            shipmentsOrderInfoService.updateStatus(ticketVo.getShipmentsOrderId(), "UN_SHIPMENTS");
         }
         return ticketVo;
     }

@@ -559,6 +559,20 @@ public class ShipmentsPlanDetailServiceImpl extends BaseMpServiceImpl<ShipmentsP
         getBaseMapper().delete(updateWrapper);
     }
 
+    @Override
+    public List<String> getOrderIdByShipmentOrderId(String shipmentOrderId) {
+        if (StringUtils.isBlank(shipmentOrderId)) {
+            return Collections.emptyList();
+        }
+        LambdaQueryWrapper<ShipmentsPlanDetail> queryWrapper = Wrappers.lambdaQuery(ShipmentsPlanDetail.class);
+        queryWrapper.eq(ShipmentsPlanDetail::getShipmentOrderId, shipmentOrderId);
+        List<ShipmentsPlanDetail> detailList = getBaseMapper().selectList(queryWrapper);
+        if (CollectionUtils.isEmpty(detailList)) {
+            return Collections.emptyList();
+        }
+        return detailList.stream().map(ShipmentsPlanDetail::getOrderId).distinct().collect(Collectors.toList());
+    }
+
 
     /**
      * 封装发货计划明细数据

@@ -154,4 +154,12 @@ public interface ShipmentsPlanDetailService extends BaseMpService<ShipmentsPlanD
      * @param orderIds  订货单ID集合
      */
     void delByOrderIds(List<String> orderIds);
+
+    /**
+     * 根据发货单ID获取所有订货单
+     *
+     * @param shipmentOrderId   发货单ID
+     * @return                  List<String>
+     */
+    List<String> getOrderIdByShipmentOrderId(String shipmentOrderId);
 }