优化

deploy/sql/README.md

@@ -1,10 +1,10 @@
 # 测试环境 SQL 执行说明
 
-## 唯一数据库发布入口
+## 唯一数据库初始化与发布入口
 
-- 固定入口：`头程数据库统一增量-MySQL8.sql`。
-- 该脚本汇总一期、二期当前全部数据库基线、存量升级、IAM 权限资源和最终结构校验，适用于 MySQL 8.0。
-- 后续数据库变更只允许在该文件末尾增加带日期和业务说明的幂等增量区块，不再创建新的部署入口 SQL。
+- 固定入口：`头程数据库统一增量-MySQL8.sql`。文件名保留历史兼容，内容维护为当前完整数据库基线和存量环境兼容升级，不再按日期拆分发布脚本。
+- 该脚本汇总一期、二期及已实现三期出仓能力的数据库基线、存量升级、IAM 权限资源和最终结构校验，适用于 MySQL 8.0。
+- 正式上线前的数据库变更直接维护该文件中的当前基线、存量兼容处理和最终校验，不再创建按日期拆分的发布 SQL；正式上线后的迁移策略在生产发布规范中另行冻结。
 - 模块 `src/main/resources/db/` 下的 SQL 用于开发溯源；`deploy/sql/` 下已有日期文件全部冻结为历史记录，不再单独部署，也不得与固定入口重复执行。
 - 固定入口不包含 `auth/phase1-admin-accounts.sql` 和 `warehouse/warehouse-seed.sql`，不会写入固定密码账号、演示仓库、演示快递公司或演示订单；正式平台公共仓库主数据已内联到固定入口。
 - `warehouse/phase2-pallet-location-schema-migration.sql` 的有效结构已被当前 `phase2-pallet-location-schema.sql` 和后续共享溢出位迁移完整覆盖，因此不重复内联，避免每次部署无条件删除并重建同名唯一索引。
@@ -46,7 +46,43 @@
 
 在 Navicat、DataGrip 或 MySQL 命令行中以“运行脚本”方式完整执行，确保客户端支持 `DELIMITER`。不要只选中局部语句执行。
 
-执行结束后必须看到 `migration_status = PASS`，并确认消息为“一期与二期统一增量执行完成，关键结构与二期权限校验通过”。如果中途出现 `SQLSTATE 45000`，必须按错误中给出的缺失表、字段或权限处理后重新完整执行。
+执行结束后必须看到 `migration_status = PASS`。如果中途出现 `SQLSTATE 45000`，必须按错误中给出的缺失表、字段或权限处理后重新完整执行。
+
+## 三期分柜、预装、拣货与装柜当前基线
+
+- 模块表结构来源：`firstleg/src/main/resources/db/phase3-split-preload-schema.sql`、`firstleg/src/main/resources/db/phase3-loading-delivery-schema.sql`。
+- 三期平台权限直接维护在统一初始化与发布入口中，避免额外增加独立权限脚本。
+- 测试和生产环境仍只执行固定入口 `头程数据库统一增量-MySQL8.sql`，不得再串行执行上述模块脚本。
+- 必须先执行统一增量并取得 `PASS`，再启动或重启 Firstleg Service；否则统一订单摘要查询会因缺少三期操作表而失败。
+- 统一脚本会创建 `fl_preload_plan`、`fl_split_operation`、`fl_loading_evidence`、`fl_loading_operation`、`fl_loading_pick_task`，并补齐 9 项平台操作权限。新增权限默认只授予平台系统管理员，其他角色由平台权限管理按职责配置。
+
+部署前可只读盘点：
+
+```sql
+SELECT table_name
+  FROM information_schema.tables
+ WHERE table_schema = 'baiyue_firstleg'
+   AND table_name IN (
+     'fl_preload_plan', 'fl_split_operation', 'fl_loading_evidence',
+     'fl_loading_operation', 'fl_loading_pick_task'
+   )
+ ORDER BY table_name;
+
+SELECT permission_code
+  FROM baiyue_iam.iam_permission
+ WHERE tenant_id = 0 AND app_code = 'PLATFORM' AND status = 'ACTIVE' AND deleted = 0
+   AND permission_code IN (
+     'firstleg:inbound:split', 'firstleg:inbound:preload',
+     'firstleg:inbound:preload-view',
+     'platform:firstleg:inbound:loading:edit',
+     'platform:firstleg:inbound:loading:view',
+     'platform:firstleg:inbound:loading:complete',
+     'platform:firstleg:inbound:delivery:complete',
+     'platform:firstleg:inbound:picking:edit',
+     'platform:firstleg:inbound:picking:view'
+   )
+ ORDER BY permission_code;
+```
 
 ## 公共导出中心存量升级
 

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

@@ -4503,10 +4503,253 @@ CALL unified_publish_fee_add_index('fl_inbound_fee_detail', 'idx_inbound_fee_pub
   'KEY `idx_inbound_fee_published` (`tenant_id`, `inbound_id`, `publication_status`, `source_fee_version`)');
 DROP PROCEDURE IF EXISTS unified_publish_fee_add_index;
 
+-- ============================================================================
+-- 2026-08-06：三期分柜、预装、拣货、装柜和派送当前基线
+-- ============================================================================
+USE baiyue_firstleg;
+
+CREATE TABLE IF NOT EXISTS fl_preload_plan (
+  id BIGINT UNSIGNED NOT NULL COMMENT '预装清单ID',
+  tenant_id BIGINT UNSIGNED NOT NULL COMMENT '客户隔离ID',
+  inbound_id BIGINT UNSIGNED NOT NULL COMMENT '入库单/订单ID',
+  status VARCHAR(16) NOT NULL DEFAULT 'PENDING' COMMENT 'PENDING/CONFIRMING/CONFIRMED',
+  version INT NOT NULL DEFAULT 0 COMMENT '乐观锁版本',
+  items_json JSON NOT NULL COMMENT '可编辑分柜明细快照',
+  remark VARCHAR(1000) NULL COMMENT '预装备注',
+  created_by BIGINT UNSIGNED NOT NULL,
+  created_by_name VARCHAR(64) NULL,
+  updated_by BIGINT UNSIGNED NOT NULL,
+  updated_by_name VARCHAR(64) NULL,
+  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
+  PRIMARY KEY (id),
+  UNIQUE KEY uk_preload_tenant_inbound (tenant_id, inbound_id),
+  KEY idx_preload_status (tenant_id, status, updated_at),
+  CONSTRAINT fk_preload_inbound FOREIGN KEY (inbound_id) REFERENCES fl_inbound_order (id)
+) ENGINE=InnoDB COMMENT='订单分柜预装清单';
+
+CREATE TABLE IF NOT EXISTS fl_split_operation (
+  id BIGINT UNSIGNED NOT NULL COMMENT '幂等记录ID',
+  tenant_id BIGINT UNSIGNED NOT NULL COMMENT '客户隔离ID',
+  inbound_id BIGINT UNSIGNED NOT NULL,
+  operator_id BIGINT UNSIGNED NOT NULL,
+  operation VARCHAR(40) NOT NULL,
+  idempotency_key VARCHAR(128) NOT NULL,
+  status VARCHAR(16) NOT NULL DEFAULT 'PROCESSING' COMMENT 'PROCESSING/SUCCESS',
+  result_json JSON NULL,
+  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+  PRIMARY KEY (id),
+  UNIQUE KEY uk_split_operation (tenant_id, inbound_id, operator_id, operation, idempotency_key),
+  KEY idx_split_operation_time (tenant_id, inbound_id, created_at),
+  CONSTRAINT fk_split_operation_inbound FOREIGN KEY (inbound_id) REFERENCES fl_inbound_order (id)
+) ENGINE=InnoDB COMMENT='分柜操作幂等与审计索引';
+
+CREATE TABLE IF NOT EXISTS fl_loading_evidence (
+  id BIGINT UNSIGNED NOT NULL,
+  tenant_id BIGINT UNSIGNED NOT NULL,
+  inbound_id BIGINT UNSIGNED NOT NULL,
+  evidence_type VARCHAR(32) NOT NULL COMMENT 'PHOTO_STEP_1..4/SEAL',
+  file_id BIGINT UNSIGNED NULL COMMENT 'File 服务逻辑文件ID',
+  file_name VARCHAR(255) NULL,
+  seal_no VARCHAR(64) NULL,
+  remark VARCHAR(1000) NULL,
+  version INT NOT NULL DEFAULT 0,
+  created_by BIGINT UNSIGNED NOT NULL,
+  created_by_name VARCHAR(64) NULL,
+  updated_by BIGINT UNSIGNED NOT NULL,
+  updated_by_name VARCHAR(64) NULL,
+  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
+  PRIMARY KEY (id),
+  UNIQUE KEY uk_loading_evidence_type (tenant_id, inbound_id, evidence_type),
+  KEY idx_loading_evidence_time (tenant_id, inbound_id, updated_at),
+  CONSTRAINT fk_loading_evidence_inbound FOREIGN KEY (inbound_id) REFERENCES fl_inbound_order (id)
+) ENGINE=InnoDB COMMENT='订单装柜四步照片和铅封证据';
+
+CREATE TABLE IF NOT EXISTS fl_loading_operation (
+  id BIGINT UNSIGNED NOT NULL,
+  tenant_id BIGINT UNSIGNED NOT NULL,
+  inbound_id BIGINT UNSIGNED NOT NULL,
+  operator_id BIGINT UNSIGNED NOT NULL,
+  operation VARCHAR(48) NOT NULL,
+  idempotency_key VARCHAR(128) NOT NULL,
+  request_hash CHAR(64) NOT NULL,
+  status VARCHAR(16) NOT NULL DEFAULT 'PROCESSING',
+  result_json JSON NULL,
+  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+  completed_at DATETIME(3) NULL,
+  PRIMARY KEY (id),
+  UNIQUE KEY uk_loading_operation (tenant_id, inbound_id, operator_id, operation, idempotency_key),
+  KEY idx_loading_operation_time (tenant_id, inbound_id, created_at),
+  CONSTRAINT fk_loading_operation_inbound FOREIGN KEY (inbound_id) REFERENCES fl_inbound_order (id)
+) ENGINE=InnoDB COMMENT='装柜与派送写操作幂等记录';
+
+CREATE TABLE IF NOT EXISTS fl_loading_pick_task (
+  id BIGINT UNSIGNED NOT NULL,
+  tenant_id BIGINT UNSIGNED NOT NULL,
+  inbound_id BIGINT UNSIGNED NOT NULL,
+  status VARCHAR(24) NOT NULL DEFAULT 'PENDING' COMMENT 'PENDING/IN_PROGRESS/COMPLETED',
+  version INT NOT NULL DEFAULT 0,
+  expected_count INT UNSIGNED NULL,
+  picked_count INT UNSIGNED NULL,
+  remark VARCHAR(1000) NULL,
+  updated_by BIGINT UNSIGNED NOT NULL,
+  updated_by_name VARCHAR(64) NULL,
+  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
+  PRIMARY KEY (id),
+  UNIQUE KEY uk_loading_pick_tenant_inbound (tenant_id, inbound_id),
+  KEY idx_loading_pick_status (tenant_id, status, updated_at),
+  CONSTRAINT fk_loading_pick_inbound FOREIGN KEY (inbound_id) REFERENCES fl_inbound_order (id)
+) ENGINE=InnoDB COMMENT='PDA拣货任务及结果';
+
+USE baiyue_iam;
+
+INSERT INTO iam_permission (
+  id, tenant_id, app_code, permission_type, parent_id, permission_code,
+  permission_name, route_path, http_method, sort_no, status, built_in, deleted
+)
+VALUES
+  (5102091, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'firstleg:inbound:split', '智能分柜', NULL, NULL, 140, 'ACTIVE', 1, 0),
+  (5102092, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'firstleg:inbound:preload', '编辑并确认预装清单', NULL, NULL, 150, 'ACTIVE', 1, 0),
+  (5102093, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'firstleg:inbound:preload-view', '查看预装清单', NULL, NULL, 160, 'ACTIVE', 1, 0),
+  (5102094, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:loading:edit', '维护装柜证据', NULL, NULL, 170, 'ACTIVE', 1, 0),
+  (5102095, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:loading:view', '查看装柜证据', NULL, NULL, 180, 'ACTIVE', 1, 0),
+  (5102096, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:loading:complete', '完成装柜', NULL, NULL, 190, 'ACTIVE', 1, 0),
+  (5102097, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:delivery:complete', '完成派送', NULL, NULL, 200, 'ACTIVE', 1, 0),
+  (5102098, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:picking:edit', '执行拣货', NULL, NULL, 210, 'ACTIVE', 1, 0),
+  (5102099, 0, 'PLATFORM', 'BUTTON', 5102030,
+   'platform:firstleg:inbound:picking:view', '查看拣货任务', NULL, NULL, 220, 'ACTIVE', 1, 0)
+ON DUPLICATE KEY UPDATE
+  permission_type = VALUES(permission_type), parent_id = VALUES(parent_id),
+  permission_name = VALUES(permission_name), route_path = VALUES(route_path),
+  http_method = VALUES(http_method), sort_no = VALUES(sort_no),
+  status = 'ACTIVE', built_in = 1, deleted = 0;
+
+INSERT INTO iam_role_permission (role_id, permission_id, tenant_id)
+SELECT 4000001, id, 0
+FROM iam_permission
+WHERE tenant_id = 0 AND app_code = 'PLATFORM'
+  AND permission_code IN (
+    'firstleg:inbound:split',
+    'firstleg:inbound:preload',
+    'firstleg:inbound:preload-view',
+    'platform:firstleg:inbound:loading:edit',
+    'platform:firstleg:inbound:loading:view',
+    'platform:firstleg:inbound:loading:complete',
+    'platform:firstleg:inbound:delivery:complete',
+    'platform:firstleg:inbound:picking:edit',
+    'platform:firstleg:inbound:picking:view'
+  )
+ON DUPLICATE KEY UPDATE tenant_id = VALUES(tenant_id);
+
 DROP PROCEDURE IF EXISTS unified_assert_final_extensions;
 DELIMITER $$
 CREATE PROCEDURE unified_assert_final_extensions()
 BEGIN
+  IF (SELECT COUNT(*) FROM information_schema.tables
+       WHERE table_schema = 'baiyue_firstleg'
+         AND table_name IN ('fl_preload_plan', 'fl_split_operation',
+                            'fl_loading_evidence', 'fl_loading_operation',
+                            'fl_loading_pick_task')) <> 5 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期分柜、预装或装柜表未完整创建';
+  END IF;
+  IF (SELECT COUNT(*) FROM information_schema.columns
+       WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_preload_plan'
+         AND column_name IN ('id', 'tenant_id', 'inbound_id', 'status', 'version',
+                             'items_json', 'remark', 'created_by', 'created_by_name',
+                             'updated_by', 'updated_by_name', 'created_at', 'updated_at')) <> 13
+     OR (SELECT COUNT(*) FROM information_schema.columns
+          WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_split_operation'
+            AND column_name IN ('id', 'tenant_id', 'inbound_id', 'operator_id', 'operation',
+                                'idempotency_key', 'status', 'result_json', 'created_at')) <> 9
+     OR (SELECT COUNT(*) FROM information_schema.columns
+          WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_evidence'
+            AND column_name IN ('id', 'tenant_id', 'inbound_id', 'evidence_type', 'file_id',
+                                'file_name', 'seal_no', 'remark', 'version', 'created_by',
+                                'created_by_name', 'updated_by', 'updated_by_name',
+                                'created_at', 'updated_at')) <> 15
+     OR (SELECT COUNT(*) FROM information_schema.columns
+          WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_operation'
+            AND column_name IN ('id', 'tenant_id', 'inbound_id', 'operator_id', 'operation',
+                                'idempotency_key', 'request_hash', 'status', 'result_json',
+                                'created_at', 'completed_at')) <> 11
+     OR (SELECT COUNT(*) FROM information_schema.columns
+          WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
+            AND column_name IN ('id', 'tenant_id', 'inbound_id', 'status', 'version',
+                                'expected_count', 'picked_count', 'remark', 'updated_by',
+                                'updated_by_name', 'created_at', 'updated_at')) <> 12 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期分柜、预装或装柜关键字段未完整创建';
+  END IF;
+  IF (SELECT COUNT(*) FROM information_schema.columns
+       WHERE table_schema = 'baiyue_firstleg'
+         AND table_name IN ('fl_preload_plan', 'fl_split_operation', 'fl_loading_operation')
+         AND column_name IN ('items_json', 'result_json') AND data_type = 'json') <> 3
+     OR (SELECT COUNT(*) FROM information_schema.columns
+          WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_order'
+            AND column_name = 'process_status' AND character_maximum_length >= 24) <> 1 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期 JSON 字段或入库状态字段类型不兼容';
+  END IF;
+  IF (SELECT COUNT(DISTINCT CONCAT(table_name, '.', index_name))
+        FROM information_schema.statistics
+       WHERE table_schema = 'baiyue_firstleg'
+         AND index_name IN ('uk_preload_tenant_inbound', 'idx_preload_status',
+                            'uk_split_operation', 'idx_split_operation_time',
+                            'uk_loading_evidence_type', 'idx_loading_evidence_time',
+                            'uk_loading_operation', 'idx_loading_operation_time',
+                            'uk_loading_pick_tenant_inbound', 'idx_loading_pick_status')) <> 10 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期分柜、预装或装柜索引未完整创建';
+  END IF;
+  IF (SELECT COUNT(*) FROM information_schema.table_constraints
+       WHERE constraint_schema = 'baiyue_firstleg' AND constraint_type = 'FOREIGN KEY'
+         AND table_name IN ('fl_preload_plan', 'fl_split_operation',
+                            'fl_loading_evidence', 'fl_loading_operation',
+                            'fl_loading_pick_task')) <> 5 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期操作表入库单外键未完整创建';
+  END IF;
+  IF (SELECT COUNT(DISTINCT permission_code) FROM baiyue_iam.iam_permission
+       WHERE tenant_id = 0 AND app_code = 'PLATFORM' AND status = 'ACTIVE' AND deleted = 0
+         AND permission_code IN (
+           'firstleg:inbound:split', 'firstleg:inbound:preload',
+           'firstleg:inbound:preload-view',
+           'platform:firstleg:inbound:loading:edit',
+           'platform:firstleg:inbound:loading:view',
+           'platform:firstleg:inbound:loading:complete',
+           'platform:firstleg:inbound:delivery:complete',
+           'platform:firstleg:inbound:picking:edit',
+           'platform:firstleg:inbound:picking:view')) <> 9 THEN
+    SIGNAL SQLSTATE '45000'
+      SET MESSAGE_TEXT = '统一迁移失败：三期分柜、预装或装柜权限未完整创建';
+  END IF;
+  IF (SELECT COUNT(DISTINCT rp.permission_id)
+        FROM baiyue_iam.iam_role_permission rp
+        JOIN baiyue_iam.iam_permission p ON p.id = rp.permission_id
+       WHERE rp.role_id = 4000001 AND rp.tenant_id = 0
+         AND p.permission_code IN (
+           'firstleg:inbound:split', 'firstleg:inbound:preload',
+           'firstleg:inbound:preload-view',
+           'platform:firstleg:inbound:loading:edit',
+           'platform:firstleg:inbound:loading:view',
+           'platform:firstleg:inbound:loading:complete',
+           'platform:firstleg:inbound:delivery:complete',
+           'platform:firstleg:inbound:picking:edit',
+           'platform:firstleg:inbound:picking:view')) <> 9 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_fee_item', 'fl_inbound_fee_detail')) <> 2 THEN
@@ -4693,4 +4936,4 @@ SELECT COUNT(*) AS unresolved_third_party_calls
  WHERE tenant_id = 0;
 
 SELECT 'PASS' AS migration_status,
-       '统一增量全部执行完成，平台公共资源归0、Warehouse父子回填、费用及可靠审计结构校验通过' AS message;
+       '统一数据库脚本执行完成，三期出仓、费用、公共资源及可靠审计结构校验通过' AS message;