fix container customer snapshot schema migration

deploy/sql/头程数据库统一增量-MySQL8.sql

@@ -4938,6 +4938,21 @@ BEGIN
     ALTER TABLE fl_container_booking ADD COLUMN merged_into_container_booking_id BIGINT UNSIGNED NULL
       COMMENT '真实柜被模拟柜吸收后的目标稳定柜次ID' AFTER record_status;
   END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND column_name='customer_id') THEN
+    ALTER TABLE fl_container_booking ADD COLUMN customer_id BIGINT UNSIGNED NULL
+      COMMENT '已关联真实订舱指定的客户范围' AFTER ocean_booking_requirement_id;
+  END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND column_name='customer_name') THEN
+    ALTER TABLE fl_container_booking ADD COLUMN customer_name VARCHAR(128) NULL
+      COMMENT '已关联真实订舱客户名称快照' AFTER customer_id;
+  END IF;
+  UPDATE fl_container_booking container_booking
+  JOIN fl_ocean_booking ocean_booking ON ocean_booking.id=container_booking.ocean_booking_id
+     SET container_booking.customer_id=COALESCE(container_booking.customer_id,ocean_booking.customer_id),
+         container_booking.customer_name=COALESCE(container_booking.customer_name,ocean_booking.customer_name)
+   WHERE container_booking.customer_id IS NULL OR container_booking.customer_name IS NULL;
   IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
       AND table_name='fl_container_booking' AND index_name='uk_container_booking_container_no') THEN
     ALTER TABLE fl_container_booking ADD UNIQUE KEY uk_container_booking_container_no (container_no);
@@ -15390,11 +15405,17 @@ BEGIN
   IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema='baiyue_firstleg' AND table_name='fl_container_booking' AND column_name='ocean_booking_requirement_id') THEN
     ALTER TABLE baiyue_firstleg.fl_container_booking ADD COLUMN ocean_booking_requirement_id BIGINT UNSIGNED NULL COMMENT '来源订舱箱型需求ID' AFTER ocean_booking_id;
   END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema='baiyue_firstleg' AND table_name='fl_container_booking' AND column_name='customer_id') THEN
+    ALTER TABLE baiyue_firstleg.fl_container_booking ADD COLUMN customer_id BIGINT UNSIGNED NULL COMMENT '已关联真实订舱指定的客户范围' AFTER ocean_booking_requirement_id;
+  END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema='baiyue_firstleg' AND table_name='fl_container_booking' AND column_name='customer_name') THEN
+    ALTER TABLE baiyue_firstleg.fl_container_booking ADD COLUMN customer_name VARCHAR(128) NULL COMMENT '已关联真实订舱客户名称快照' AFTER customer_id;
+  END IF;
   UPDATE baiyue_firstleg.fl_container_booking c JOIN baiyue_firstleg.fl_ocean_booking_container_allocation a ON a.container_booking_id=c.id
     JOIN baiyue_firstleg.fl_ocean_booking b ON b.id=a.ocean_booking_id
-     SET c.ocean_booking_id=b.id,c.ocean_booking_requirement_id=a.requirement_id,c.channel_code=COALESCE(c.channel_code,b.channel_code),c.channel_name=COALESCE(c.channel_name,b.channel_name)
+     SET c.ocean_booking_id=b.id,c.ocean_booking_requirement_id=a.requirement_id,c.channel_code=COALESCE(c.channel_code,b.channel_code),c.channel_name=COALESCE(c.channel_name,b.channel_name),c.customer_id=COALESCE(c.customer_id,b.customer_id),c.customer_name=COALESCE(c.customer_name,b.customer_name)
    WHERE c.ocean_booking_id IS NULL OR c.ocean_booking_requirement_id IS NULL
-      OR c.channel_code IS NULL OR c.channel_name IS NULL;
+      OR c.channel_code IS NULL OR c.channel_name IS NULL OR c.customer_id IS NULL OR c.customer_name IS NULL;
   IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema='baiyue_firstleg' AND table_name='fl_loading_pick_task' AND column_name='container_booking_id') THEN
     ALTER TABLE baiyue_firstleg.fl_loading_pick_task ADD COLUMN container_booking_id BIGINT UNSIGNED NULL COMMENT '稳定柜次ID' AFTER loading_plan_id;
   END IF;

firstleg/src/main/resources/db/phase3-smart-loading-schema.sql

@@ -132,6 +132,21 @@ BEGIN
     ALTER TABLE fl_container_booking ADD COLUMN merged_into_container_booking_id BIGINT UNSIGNED NULL
       COMMENT '真实柜被模拟柜吸收后的目标稳定柜次ID' AFTER record_status;
   END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND column_name='customer_id') THEN
+    ALTER TABLE fl_container_booking ADD COLUMN customer_id BIGINT UNSIGNED NULL
+      COMMENT '已关联真实订舱指定的客户范围' AFTER ocean_booking_requirement_id;
+  END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND column_name='customer_name') THEN
+    ALTER TABLE fl_container_booking ADD COLUMN customer_name VARCHAR(128) NULL
+      COMMENT '已关联真实订舱客户名称快照' AFTER customer_id;
+  END IF;
+  UPDATE fl_container_booking container_booking
+  JOIN fl_ocean_booking ocean_booking ON ocean_booking.id=container_booking.ocean_booking_id
+     SET container_booking.customer_id=COALESCE(container_booking.customer_id,ocean_booking.customer_id),
+         container_booking.customer_name=COALESCE(container_booking.customer_name,ocean_booking.customer_name)
+   WHERE container_booking.customer_id IS NULL OR container_booking.customer_name IS NULL;
   IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
       AND table_name='fl_container_booking' AND column_name='unloading_completed_at') THEN
     ALTER TABLE fl_container_booking ADD COLUMN unloading_completed_at DATETIME(3) NULL

firstleg/src/test/java/com/baiyue/firstleg/repository/SmartLoadingSqlContractTest.java

@@ -76,6 +76,19 @@ class SmartLoadingSqlContractTest {
             .contains("version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号'");
     }
 
+    @Test
+    @DisplayName("存量货柜迁移补齐BaseMapper所需客户快照列")
+    void shouldMigrateContainerCustomerSnapshotColumns() throws Exception {
+        for (String sql : Set.of(migration(), unifiedMigration())) {
+            assertThat(sql)
+                .contains("ADD COLUMN customer_id BIGINT UNSIGNED NULL")
+                .contains("ADD COLUMN customer_name VARCHAR(128) NULL")
+                .contains("JOIN fl_ocean_booking ocean_booking ON ocean_booking.id=container_booking.ocean_booking_id")
+                .contains("container_booking.customer_id=COALESCE(container_booking.customer_id,ocean_booking.customer_id)")
+                .contains("container_booking.customer_name=COALESCE(container_booking.customer_name,ocean_booking.customer_name)");
+        }
+    }
+
     @Test
     @DisplayName("仓库备注使用计划先行与明细单表CAS并允许已拣明细仅改备注")
     void shouldUpdateWarehouseRemarkWithoutMultiTableTriggerConflict() throws Exception {