diff --git a/firstleg/src/test/java/com/baiyue/firstleg/portschedule/repository/PortScheduleMapperContractTest.java b/firstleg/src/test/java/com/baiyue/firstleg/portschedule/repository/PortScheduleMapperContractTest.java index 747b5582a..69897438a 100644 --- a/firstleg/src/test/java/com/baiyue/firstleg/portschedule/repository/PortScheduleMapperContractTest.java +++ b/firstleg/src/test/java/com/baiyue/firstleg/portschedule/repository/PortScheduleMapperContractTest.java @@ -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"); } }