fix(phase3): route carrier queries and repair schedule updates
This commit is contained in:
+1
-1
@@ -52,7 +52,7 @@ public interface PortScheduleMapper extends BaseMapper<PortScheduleEntity> {
|
||||
observed_at=#{value.observedAt},expires_at=#{value.expiresAt},remark=#{value.remark},
|
||||
updated_by=#{operatorId},updated_by_name=#{operatorName},updated_at=CURRENT_TIMESTAMP(3),version=version+1
|
||||
WHERE id=#{value.id} AND customer_id=#{value.customerId} AND ocean_booking_id=#{value.oceanBookingId}
|
||||
AND (container_booking_id<=>#{value.containerBookingId}) AND version=#{expectedVersion}
|
||||
AND (container_booking_id <=> #{value.containerBookingId}) AND version=#{expectedVersion}
|
||||
""")
|
||||
int updateSchedule(@Param("value") PortScheduleEntity value,
|
||||
@Param("expectedVersion") int expectedVersion,
|
||||
|
||||
+3
-2
@@ -32,8 +32,9 @@ class PortScheduleMapperContractTest {
|
||||
.contains("version=version+1")
|
||||
.contains("customer_id=#{value.customerId}")
|
||||
.contains("ocean_booking_id=#{value.oceanBookingId}")
|
||||
.contains("container_booking_id<=>#{value.containerBookingId}")
|
||||
.contains("version=#{expectedVersion}");
|
||||
.contains("container_booking_id <=> #{value.containerBookingId}")
|
||||
.contains("version=#{expectedVersion}")
|
||||
.doesNotContain("<=>");
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
Reference in New Issue
Block a user