fix(javaTest): close invalid history inputs explicitly

javaTest/src/main/java/com/ft546/wcs/shadow/history/simulation/HistoricalSimulationInputFactory.java

@@ -52,12 +52,20 @@ public final class HistoricalSimulationInputFactory {
                 failures.add(new HistoricalSimulationFailure(id, record, "INVALID_TASK_TYPE"));
                 continue;
             }
-            PhysicalEndpointResolver.ResolvedEndpoints endpoints = endpointResolver.resolve(
-                    record, compiled.getPassableSites());
+            PhysicalEndpointResolver.ResolvedEndpoints endpoints;
+            try {
+                endpoints = endpointResolver.resolve(record, compiled.getPassableSites());
+            } catch (IllegalArgumentException ex) {
+                // 未知地图端点不能进入调度循环；保留原始记录并形成可归档的输入失败。
+                failures.add(new HistoricalSimulationFailure(id, record,
+                        "UNKNOWN_MAP_SITE:" + ex.getMessage()));
+                continue;
+            }
             if (compiled.getComponentId(endpoints.getSource())
                     != compiled.getComponentId(endpoints.getTarget())) {
                 // 两端地图连通性是调度启动前的硬约束，跨断开区域不能靠等待或选车解决。
-                throw new IllegalArgumentException("unreachable physical endpoints for " + id);
+                failures.add(new HistoricalSimulationFailure(id, record, "NO_ROUTE"));
+                continue;
             }
             tasks.add(new HistoricalSimulationTask(id, record, type,
                     record.getPriority() == null ? Integer.MAX_VALUE : record.getPriority(),

javaTest/src/test/java/com/ft546/wcs/shadow/history/simulation/HistoricalDispatchSimulatorTest.java

@@ -141,6 +141,36 @@ class HistoricalDispatchSimulatorTest {
         assertEquals(0, result.getInvariants().totalSafetyViolations());
     }
 
+    @Test
+    void doesNotAssignTaskBeforeCreateDateArrival() {
+        HistoricalDispatchSimulationResult result = new HistoricalDispatchSimulator().simulate(
+                futureArrivalInput(), SimulationConfig.defaults(), DeterministicFaultPlan.none());
+
+        long expectedArrival = result.getTaskResults().stream()
+                .filter(task -> "FUTURE".equals(task.getSimulationTaskId()))
+                .findFirst().orElseThrow(AssertionError::new).getArrivalMillis();
+        assertTrue(expectedArrival > 0L);
+        assertTrue(result.getEvents().stream()
+                .filter(event -> "FUTURE".equals(event.getTaskId())
+                        && "ASSIGN".equals(event.getType()))
+                .allMatch(event -> event.getSimulationMillis() >= expectedArrival));
+        assertEquals(2, result.getCompletedCount());
+    }
+
+    @Test
+    void closesKnownButPermanentlyUnreachableTaskAsFailed() {
+        HistoricalDispatchSimulationResult result = new HistoricalDispatchSimulator().simulate(
+                unreachableInput(), SimulationConfig.defaults(), DeterministicFaultPlan.none());
+
+        SimulationTaskResult failed = result.getTaskResults().get(0);
+        assertEquals(SimulationTaskStatus.FAILED, failed.getStatus());
+        assertEquals("NO_ROUTE", failed.getReason());
+        assertTrue(result.getEvents().stream().noneMatch(event ->
+                "UNREACHABLE".equals(event.getTaskId())
+                        && ("ASSIGN".equals(event.getType()) || "COMPLETE".equals(event.getType()))));
+        assertEquals(0, result.getCompletedCount());
+    }
+
     /**
      * 验证“moves idle blockers node by node and completes both business directions”场景，确保相关业务规则和断言成立。
      *
@@ -347,6 +377,51 @@ class HistoricalDispatchSimulatorTest {
                 traffic, vehicles);
     }
 
+    private HistoricalSimulationInput futureArrivalInput() {
+        GridMap grid = new GridMap();
+        grid.addSite(new Site("A", 1, 0, 0, "TEST"));
+        grid.addSite(new Site("B", 1, 1, 0, "TEST"));
+        grid.connect("A", "B");
+        LinkedHashSet<String> nodes = new LinkedHashSet<String>(Arrays.asList("A", "B"));
+        LinkedHashSet<TrafficMapCompiler.EdgeDefinition> edges =
+                new LinkedHashSet<TrafficMapCompiler.EdgeDefinition>();
+        edges.add(new TrafficMapCompiler.EdgeDefinition("A", "B"));
+        EffectiveTrafficMap traffic = new TrafficMapCompiler().compile(
+                new TrafficMapCompiler.MapDefinition("FUTURE", 1L, "TEST", true,
+                        "test", "test", nodes, edges, Collections.emptyMap(),
+                        Collections.emptySet(), Collections.emptySet()));
+        List<HistoricalSimulationTask> tasks = Arrays.asList(
+                customTask("NOW", "A", "B", 2, 0, Arrays.asList("A", "B")),
+                customTask("FUTURE", "A", "B", 1, 20, Arrays.asList("A", "B")));
+        return new HistoricalSimulationInput(tasks, Collections.emptyList(), grid, traffic,
+                Collections.singletonList(new VehicleSnapshot(
+                        "1", 1, "A", 5, 1, 100, true, true, false)));
+    }
+
+    private HistoricalSimulationInput unreachableInput() {
+        GridMap grid = new GridMap();
+        for (String node : Arrays.asList("A", "B", "C", "D")) {
+            grid.addSite(new Site(node, 1, node.charAt(0) - 'A', 0, "TEST"));
+        }
+        grid.connect("A", "B");
+        grid.connect("C", "D");
+        LinkedHashSet<String> nodes = new LinkedHashSet<String>(Arrays.asList("A", "B", "C", "D"));
+        LinkedHashSet<TrafficMapCompiler.EdgeDefinition> edges =
+                new LinkedHashSet<TrafficMapCompiler.EdgeDefinition>();
+        edges.add(new TrafficMapCompiler.EdgeDefinition("A", "B"));
+        edges.add(new TrafficMapCompiler.EdgeDefinition("C", "D"));
+        EffectiveTrafficMap traffic = new TrafficMapCompiler().compile(
+                new TrafficMapCompiler.MapDefinition("UNREACHABLE", 1L, "TEST", true,
+                        "test", "test", nodes, edges, Collections.emptyMap(),
+                        Collections.emptySet(), Collections.emptySet()));
+        HistoricalSimulationTask task = customTask("UNREACHABLE", "A", "D", 1, 0,
+                Arrays.asList("A", "D"));
+        return new HistoricalSimulationInput(Collections.singletonList(task),
+                Collections.emptyList(), grid, traffic,
+                Collections.singletonList(new VehicleSnapshot(
+                        "1", 1, "A", 5, 1, 100, true, true, false)));
+    }
+
     /**
      * 验证“blocked three vehicle corridor input”场景，确保相关业务规则和断言成立。
      *

javaTest/src/test/java/com/ft546/wcs/shadow/history/simulation/HistoricalSimulationInputFactoryTest.java

@@ -104,6 +104,26 @@ class HistoricalSimulationInputFactoryTest {
         assertEquals(originalInput.getTrafficMap().getEdges(), changedInput.getTrafficMap().getEdges());
     }
 
+    @Test
+    void convertsUnknownPhysicalEndpointIntoExplicitFailedInput() {
+        HistoricalQueueDataset original = new HistoricalQueueLoader().load(
+                getClass().getClassLoader(), "shadow/history");
+        HistoricalQueueRecord first = original.getRecords().get(0);
+        List<HistoricalQueueRecord> changedRecords =
+                new ArrayList<HistoricalQueueRecord>(original.getRecords());
+        changedRecords.set(0, new HistoricalQueueRecord(first.getGuid(), first.getTaskNo(),
+                first.getTaskType(), first.getPriority(), "UNKNOWN_SITE", first.getEndSite(),
+                first.getPathInfo(), first.getCreateDate(), first.getFinishDate(), first.getAgvId()));
+
+        HistoricalSimulationInput changed = new HistoricalSimulationInputFactory().create(
+                copyWithRecords(original, changedRecords));
+
+        assertEquals(239, changed.getTasks().size());
+        assertEquals(1, changed.getFailedInputs().size());
+        assertTrue(changed.getFailedInputs().get(0).getReason().startsWith("UNKNOWN_MAP_SITE:"));
+        assertEquals(240, changed.allSimulationIds().size());
+    }
+
     /**
      * 验证“copy with records”场景，确保相关业务规则和断言成立。
      *