优化

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

@@ -411,6 +411,7 @@ CREATE TABLE IF NOT EXISTS ord_order (
   id BIGINT UNSIGNED NOT NULL COMMENT '订单ID（雪花ID）',
   tenant_id BIGINT UNSIGNED NOT NULL COMMENT '数据所属租户ID',
   order_no VARCHAR(32) NOT NULL COMMENT '租户内唯一订单号',
+  inbound_code VARCHAR(40) NULL COMMENT '客户提交后生成的入仓码，草稿为空',
   customer_id BIGINT UNSIGNED NULL COMMENT '客户逻辑ID',
   customer_name VARCHAR(128) NOT NULL COMMENT '下单时客户名称快照',
   status VARCHAR(24) NOT NULL DEFAULT 'DRAFT' COMMENT '订单业务状态',
@@ -449,6 +450,7 @@ CREATE TABLE IF NOT EXISTS ord_order (
   version INT NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
   PRIMARY KEY (id),
   UNIQUE KEY uk_order_tenant_no (tenant_id, order_no),
+  UNIQUE KEY uk_order_tenant_inbound_code (tenant_id, inbound_code),
   KEY idx_order_tenant_status_time (tenant_id, status, created_at),
   KEY idx_order_tenant_customer (tenant_id, customer_id),
   KEY idx_order_tenant_warehouse (tenant_id, destination_warehouse_id)
@@ -2213,6 +2215,30 @@ PREPARE carrier_name_statement FROM @carrier_name_sql;
 EXECUTE carrier_name_statement;
 DEALLOCATE PREPARE carrier_name_statement;
 
+-- 客户提交时由 Order 固定入仓码；审核通过后 Firstleg 沿用该码创建正式入库单。
+SET @inbound_code_exists := (
+  SELECT COUNT(*) FROM information_schema.columns
+  WHERE table_schema = DATABASE() AND table_name = 'ord_order' AND column_name = 'inbound_code'
+);
+SET @inbound_code_sql := IF(@inbound_code_exists = 0,
+  'ALTER TABLE ord_order ADD COLUMN inbound_code VARCHAR(40) NULL COMMENT ''客户提交后生成的入仓码，草稿为空'' AFTER order_no',
+  'SELECT 1');
+PREPARE inbound_code_statement FROM @inbound_code_sql;
+EXECUTE inbound_code_statement;
+DEALLOCATE PREPARE inbound_code_statement;
+
+SET @inbound_code_index_exists := (
+  SELECT COUNT(*) FROM information_schema.statistics
+  WHERE table_schema = DATABASE() AND table_name = 'ord_order'
+    AND index_name = 'uk_order_tenant_inbound_code'
+);
+SET @inbound_code_index_sql := IF(@inbound_code_index_exists = 0,
+  'ALTER TABLE ord_order ADD UNIQUE KEY uk_order_tenant_inbound_code (tenant_id, inbound_code)',
+  'SELECT 1');
+PREPARE inbound_code_index_statement FROM @inbound_code_index_sql;
+EXECUTE inbound_code_index_statement;
+DEALLOCATE PREPARE inbound_code_index_statement;
+
 -- ============================================================================
 -- 来源：firstleg\src\main\resources\db\phase2-inbound-schema.sql
 -- ============================================================================
@@ -2294,6 +2320,12 @@ CREATE TABLE IF NOT EXISTS fl_inbound_order (
   CONSTRAINT fk_inbound_task FOREIGN KEY (task_id) REFERENCES fl_fulfillment_task (id)
 ) ENGINE=InnoDB COMMENT='二期头程入库单聚合根和列表查询快照';
 
+UPDATE baiyue_order.ord_order o
+LEFT JOIN baiyue_firstleg.fl_inbound_order i
+  ON i.tenant_id = o.tenant_id AND i.order_id = o.id AND i.deleted = 0
+   SET o.inbound_code = COALESCE(i.inbound_code, CONCAT('RK-', o.id))
+ WHERE o.deleted = 0 AND o.status <> 'DRAFT' AND o.inbound_code IS NULL;
+
 CREATE TABLE IF NOT EXISTS fl_inbound_pickup_snapshot (
   id BIGINT UNSIGNED NOT NULL COMMENT '提货信息快照ID',
   tenant_id BIGINT UNSIGNED NOT NULL COMMENT '数据所属租户ID',
@@ -3440,6 +3472,7 @@ CALL unified_assert_table('baiyue_audit', 'sys_audit_log');
 CALL unified_assert_table('baiyue_event_bridge', 'bridge_inbox');
 CALL unified_assert_column('baiyue_order', 'ord_order', 'carrier_id');
 CALL unified_assert_column('baiyue_order', 'ord_order', 'carrier_name');
+CALL unified_assert_column('baiyue_order', 'ord_order', 'inbound_code');
 CALL unified_assert_column('baiyue_firstleg', 'fl_inbound_pallet_allocation', 'warehouse_resource_tenant_id');
 CALL unified_assert_column('baiyue_firstleg', 'fl_inbound_measurement_item', 'external_detail_no');
 CALL unified_assert_column('baiyue_file', 'file_export_task', 'execution_deadline_at');
@@ -4733,6 +4766,21 @@ DROP PROCEDURE IF EXISTS unified_assert_final_extensions;
 DELIMITER $$
 CREATE PROCEDURE unified_assert_final_extensions()
 BEGIN
+  IF (SELECT COUNT(*) FROM information_schema.statistics
+       WHERE table_schema = 'baiyue_order' AND table_name = 'ord_order'
+         AND index_name = 'uk_order_tenant_inbound_code') <> 2 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：订单入仓码唯一索引未正确创建';
+  END IF;
+  IF EXISTS (
+    SELECT 1 FROM baiyue_order.ord_order
+     WHERE deleted = 0
+       AND ((status = 'DRAFT' AND inbound_code IS NOT NULL)
+         OR (status <> 'DRAFT' AND inbound_code IS NULL))
+  ) THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：订单状态与入仓码数据不一致';
+  END IF;
   IF (SELECT COUNT(*) FROM information_schema.tables
        WHERE table_schema = 'baiyue_firstleg'
          AND table_name IN ('fl_preload_plan', 'fl_split_operation',