下发修改

src/main/java/com/aps/service/impl/LanuchServiceImpl.java

@@ -335,22 +335,23 @@ public class LanuchServiceImpl implements LanuchService {
 //                .eq(ProdProcessExec::getSceneId, sceneId)
 //                .list();
         List<Entry>  entrys= chromosome.getAllOperations();
-        // 查询当前场景已存在的 dispatch 记录
+        // 查询全表中已存在的、未删除的 dispatch 记录（不再按场景区分）
         List<Dispatch> existingDispatches = dispatchService.lambdaQuery()
-                .eq(Dispatch::getSceneId, sceneId)
                 .eq(Dispatch::getIsDeleted, 0L)
                 .list();
 
-        // 构建现有记录的映射 (executeId + routingDetailId 作为唯一标识)
+        // 构建现有记录的映射 (mesCode + routingDetailId 作为全局唯一标识)
         Map<String, Dispatch> existingDispatchMap = existingDispatches.stream()
                 .collect(Collectors.toMap(
-                        dispatch -> dispatch.getExecuteId() + "_" + dispatch.getRoutingDetailId(),
+                        dispatch -> dispatch.getMesCode() + "_" + dispatch.getRoutingDetailId(),
                         dispatch -> dispatch,
                         (existing, replacement) -> existing
                 ));
 
         List<Dispatch> toUpdateDispatches = new ArrayList<>();
         List<Dispatch> toInsertDispatches = new ArrayList<>();
+        // 记录已经处理过的 key，避免同一个 MES_CODE + ROUTING_DETAIL_ID 在一次下发中生成多条记录
+        Set<String> processedDispatchKeys = new HashSet<>();
 
         // 遍历GAScheduleResult结果并转换为dispatch
         for (GAScheduleResult gaResult : chromosome.getResult()) {
@@ -364,7 +365,12 @@ public class LanuchServiceImpl implements LanuchService {
                 continue;
             }
 
-            String dispatchKey = entry1.getId() + "_" + entry1.getRoutingDetailId();
+            // 只根据 MES_CODE(=orderId) + ROUTING_DETAIL_ID 唯一确定一条 dispatch
+            String dispatchKey = gaResult.getOrderId() + "_" + entry1.getRoutingDetailId();
+            // 如果本次下发中已经处理过这个 key，则直接跳过，避免生成重复数据
+            if (processedDispatchKeys.contains(dispatchKey)) {
+                continue;
+            }
             Dispatch existingDispatch = existingDispatchMap.get(dispatchKey);
             Dispatch dispatch;
 
@@ -408,6 +414,30 @@ public class LanuchServiceImpl implements LanuchService {
                 dispatch.setPartTaskReadyId(partTaskReadyId);
             }
             dispatch.setShopid(entry1.getDepartmentId());
+
+            // 标记该 key 已处理，后续相同 key 不再生成新记录
+            processedDispatchKeys.add(dispatchKey);
+
+            // 验证时间冲突：查所有场景该设备的dispatch，防止跨场景占用同一时间段
+            List<Dispatch> equipDispatches = dispatchService.lambdaQuery()
+                    .eq(Dispatch::getIsDeleted, 0L)
+                    .eq(Dispatch::getEquipId, dispatch.getEquipId())
+                    .list();
+            for (Dispatch existing : equipDispatches) {
+                if (existing.getMesCode() != null
+                        && existing.getMesCode().equals(dispatch.getMesCode())) {
+                    continue; // 同一工单，允许
+                }
+                if (dispatch.getBeginTime() != null && dispatch.getEndTime() != null
+                        && existing.getBeginTime() != null && existing.getEndTime() != null
+                        && dispatch.getBeginTime().isBefore(existing.getEndTime())
+                        && dispatch.getEndTime().isAfter(existing.getBeginTime())) {
+                    throw new RuntimeException(String.format(
+                            "下发失败：设备%d在%s-%s已被工单%s占用，新工单%s无法下发",
+                            dispatch.getEquipId(), existing.getBeginTime(), existing.getEndTime(),
+                            existing.getMesCode(), dispatch.getMesCode()));
+                }
+            }
         }
 
         // 批量更新和插入 dispatch