test(firstleg): cover public schedule dispatch fallback

2026-09-30 17:58:36 +08:00
parent 8d9d38ed4c
commit 8a957790fc
1 changed files with 4 additions and 3 deletions
@@ -38,14 +38,15 @@ class PortScheduleMapperContractTest {
    }

    @Test
-    void dispatchGateReadsLatestExactCustomerBookingContainerSchedule() throws Exception {
+    void dispatchGateReadsLatestCustomerOrPublicBookingContainerSchedule() throws Exception {
        String sql = PortScheduleMapper.class
            .getMethod("latestForDispatch", long.class, long.class, long.class)
            .getAnnotation(Select.class).value()[0];
        assertThat(sql)
-            .contains("customer_id=#{customerId}")
+            .contains("(customer_id=#{customerId} OR customer_id=0)")
            .contains("ocean_booking_id=#{oceanBookingId}")
            .contains("container_booking_id=#{containerBookingId}")
-            .contains("ORDER BY observed_at DESC,updated_at DESC,id DESC LIMIT 1");
+            .contains("CASE WHEN customer_id=#{customerId} THEN 0 ELSE 1 END")
+            .contains("observed_at DESC,updated_at DESC,id DESC LIMIT 1");
    }
 }