test(firstleg): align cabinet evidence SQL contracts

This commit is contained in:
2026-08-31 18:31:39 +08:00
parent 60d45613c7
commit 838bd93bc4
4 changed files with 54 additions and 56 deletions
@@ -58,10 +58,9 @@ class OutboundDispatchReadMapperContractTest {
assertThat(sql)
.contains("plan.id=#{loadingPlanId}", "plan.container_booking_id=#{containerBookingId}")
.contains("item.loading_plan_id=plan.id", "item.deleted=0")
.contains("evidence.inbound_id=item.inbound_id", "evidence.tenant_id=item.account_id")
.contains("evidence.container_booking_id=plan.container_booking_id")
.contains("COUNT(DISTINCT CASE", "evidence.evidence_type")
.doesNotContain("WHERE tenant_id=#{tenantId}", "inbound_id=#{inboundId}");
.doesNotContain("item.loading_plan_id=plan.id", "evidence.inbound_id", "evidence.tenant_id");
}
@Test
@@ -45,12 +45,11 @@ class Phase3FinalUnifiedSqlContractTest {
.contains("trg_inbound_split_detail_before_update")
.contains("trg_inbound_split_detail_before_delete")
.contains("CHECK (action_type IN ('CLAIM', 'ASSIGN', 'ITEM_CLAIM', 'ITEM_ASSIGN', 'REVIEW', 'BATCH', 'COMPLETE_LOADING'))")
.contains("phase3_loading_evidence_add_column")
.contains("DROP INDEX uk_loading_evidence_type")
.contains("DROP INDEX uk_loading_evidence_seal")
.contains("ADD KEY idx_loading_evidence_type (tenant_id,inbound_id,evidence_type,status)")
.contains("ADD KEY idx_loading_evidence_seal (tenant_id,seal_no,status)")
.contains("column_name IN ('status','void_reason','voided_by','voided_by_name','voided_at')")
.contains("CREATE TABLE IF NOT EXISTS fl_loading_cabinet_evidence")
.contains("UNIQUE KEY uk_cabinet_evidence_active (container_booking_id,evidence_type,active_flag)")
.contains("UNIQUE KEY uk_cabinet_evidence_operation (source_task_id,operation_key)")
.contains("column_name IN ('container_booking_id','source_task_id','active_flag','operation_key','request_hash')")
.doesNotContain("CREATE TABLE IF NOT EXISTS fl_loading_evidence", "phase3_loading_evidence_add_column")
.contains("CALL assert_phase3_final_schema()")
.contains("trg_port_schedule_history_before_update")
.contains("trg_port_schedule_history_before_delete")
@@ -154,7 +153,7 @@ class Phase3FinalUnifiedSqlContractTest {
.contains("存在缺失中文注释的业务字段")
.doesNotContain("CREATE PROCEDURE upgrade_column_comment");
assertThat(count(sql, "CALL queue_table_comment(")).isEqualTo(144);
assertThat(count(sql, "CALL queue_column_comment(")).isGreaterThanOrEqualTo(2394);
assertThat(count(sql, "CALL queue_column_comment(")).isGreaterThanOrEqualTo(2380);
assertThat(sql)
.contains("CALL queue_column_comment('baiyue_firstleg', 'fl_inbound_fee_detail', 'supplier_id'")
.contains("CALL queue_column_comment('baiyue_firstleg', 'fl_inbound_fee_detail', 'supplier_name'")