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

SET NAMES utf8mb4;

CREATE DATABASE IF NOT EXISTS baiyue_firstleg
  DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci;
USE baiyue_firstleg;

-- 兼容已执行二期初始化的存量库：PDA 拣货需要累计每个托盘分配已拣箱数。
DROP PROCEDURE IF EXISTS phase3_add_allocation_picked_count;
DELIMITER $$
CREATE PROCEDURE phase3_add_allocation_picked_count()
BEGIN
  IF EXISTS (
      SELECT 1 FROM information_schema.tables
       WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_pallet_allocation'
  ) AND NOT EXISTS (
      SELECT 1 FROM information_schema.columns
       WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_pallet_allocation'
         AND column_name = 'picked_package_count'
  ) THEN
    ALTER TABLE fl_inbound_pallet_allocation
      ADD COLUMN picked_package_count INT UNSIGNED NOT NULL DEFAULT 0
      COMMENT '已拣货箱数' AFTER allocated_package_count;
  END IF;
END$$
DELIMITER ;
CALL phase3_add_allocation_picked_count();
DROP PROCEDURE phase3_add_allocation_picked_count;

CREATE TABLE IF NOT EXISTS fl_document_sequence (
  sequence_key VARCHAR(32) NOT NULL COMMENT '单据类型与北京时间日期组合键，例如CAB:20260818',
  current_value INT UNSIGNED NOT NULL COMMENT '该类型当日已分配的最大序号',
  PRIMARY KEY (sequence_key),
  CONSTRAINT chk_fl_document_sequence_value CHECK (current_value > 0)
) ENGINE=InnoDB COMMENT='头程履约业务单号日序列；生成YYMMDD加四位当日序号';

CREATE TABLE IF NOT EXISTS fl_container_booking (
  id BIGINT UNSIGNED NOT NULL COMMENT '货柜预订ID（雪花ID）',
  booking_no VARCHAR(40) NOT NULL COMMENT '平台唯一货柜预订单号',
  container_no VARCHAR(64) NULL COMMENT '集装箱号；确认前允许修订',
  cabinet_no VARCHAR(64) NOT NULL COMMENT '平台唯一内部柜号',
  source_type VARCHAR(24) NOT NULL DEFAULT 'SIMULATION' COMMENT '记录来源：SIMULATION内部模拟柜、OCEAN_BOOKING订舱真实柜',
  record_status VARCHAR(16) NOT NULL DEFAULT 'ACTIVE' COMMENT '记录状态：ACTIVE可操作、MERGED已合并历史',
  merged_into_container_booking_id BIGINT UNSIGNED NULL COMMENT '真实柜被模拟柜吸收后的目标稳定柜次ID',
  channel_code VARCHAR(64) NULL COMMENT '订舱渠道编码快照；存量回填前禁止混装',
  channel_name VARCHAR(128) NULL COMMENT '订舱渠道名称快照',
  ocean_booking_id BIGINT UNSIGNED NULL COMMENT '来源订舱ID',
  ocean_booking_requirement_id BIGINT UNSIGNED NULL COMMENT '来源订舱箱型需求ID',
  customer_id BIGINT UNSIGNED NULL COMMENT '已关联真实订舱指定的客户范围',
  customer_name VARCHAR(128) NULL COMMENT '已关联真实订舱客户名称快照',
  warehouse_id BIGINT UNSIGNED NOT NULL COMMENT '装柜仓库ID；平台公共资源',
  warehouse_name VARCHAR(128) NOT NULL COMMENT '装柜仓库名称快照',
  bill_of_lading_no VARCHAR(128) NULL COMMENT '提单号',
  vessel_name VARCHAR(128) NULL COMMENT '船名快照',
  voyage_no VARCHAR(64) NULL COMMENT '航次；确认前允许修订',
  container_type VARCHAR(32) NOT NULL COMMENT '平台固定柜型：20GP、40GP、40HC、40NR、45HC',
  shipping_company_id BIGINT UNSIGNED NULL COMMENT '船司ID快照',
  shipping_company_name VARCHAR(128) NULL COMMENT '船司名称快照',
  departure_port_code VARCHAR(32) NULL COMMENT '起运港编码快照',
  departure_port_name VARCHAR(128) NULL COMMENT '起运港名称快照',
  destination_port_code VARCHAR(32) NULL COMMENT '目的港编码快照',
  destination_port_name VARCHAR(128) NULL COMMENT '目的港名称快照',
  destination_warehouse_code VARCHAR(64) NULL COMMENT '目的仓编码快照',
  destination_warehouse_name VARCHAR(128) NULL COMMENT '目的仓名称快照',
  capacity_cbm DECIMAL(18,4) NULL COMMENT '货柜容量m3',
  max_weight_kg DECIMAL(18,3) NULL COMMENT '货柜最大承重kg',
  terminal_trucking_company_id BIGINT UNSIGNED NULL COMMENT '码头拖车Supplier逻辑ID快照；历史数据无法推导时为空',
  terminal_trucking_company VARCHAR(128) NULL COMMENT '码头拖车公司名称快照',
  loading_at DATETIME(3) NULL COMMENT '计划或实际装柜时间',
  estimated_sailing_at DATETIME(3) NULL COMMENT '预计开船时间',
  actual_sailing_at DATETIME(3) NULL COMMENT '实际开船时间',
  estimated_port_arrival_at DATETIME(3) NULL COMMENT '预计到港时间',
  actual_port_arrival_at DATETIME(3) NULL COMMENT '实际到港时间',
  estimated_warehouse_arrival_at DATETIME(3) NULL COMMENT '预计到仓时间',
  actual_warehouse_arrival_at DATETIME(3) NULL COMMENT '实际到仓时间',
  created_by BIGINT UNSIGNED NOT NULL COMMENT '创建人ID',
  created_by_name VARCHAR(64) NULL COMMENT '创建人名称快照',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  updated_by BIGINT UNSIGNED NOT NULL COMMENT '最后修改人ID',
  updated_by_name VARCHAR(64) NULL COMMENT '最后修改人名称快照',
  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '货柜资料最后更新时间',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_container_booking_no (booking_no),
  UNIQUE KEY uk_container_booking_cabinet (cabinet_no),
  UNIQUE KEY uk_container_booking_container_no (container_no),
  KEY idx_container_booking_merge (record_status,merged_into_container_booking_id),
  KEY idx_container_booking_warehouse (warehouse_id, updated_at, id),
  KEY idx_container_booking_voyage (voyage_no, updated_at),
  KEY idx_container_booking_transit_summary (actual_sailing_at, actual_warehouse_arrival_at, ocean_booking_id, container_type),
  CONSTRAINT chk_container_booking_source CHECK (source_type IN ('SIMULATION','OCEAN_BOOKING')),
  CONSTRAINT chk_container_booking_record_status CHECK (record_status IN ('ACTIVE','MERGED')),
  CONSTRAINT chk_container_booking_capacity CHECK (capacity_cbm IS NULL OR capacity_cbm > 0),
  CONSTRAINT chk_container_booking_weight CHECK (max_weight_kg IS NULL OR max_weight_kg > 0)
) ENGINE=InnoDB COMMENT='平台货柜预订资料；预装状态唯一来源为装柜计划';

DROP PROCEDURE IF EXISTS phase3_container_real_unit_columns;
DELIMITER $$
CREATE PROCEDURE phase3_container_real_unit_columns()
BEGIN
  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND column_name='source_type') THEN
    ALTER TABLE fl_container_booking ADD COLUMN source_type VARCHAR(24) NOT NULL DEFAULT 'SIMULATION'
      COMMENT '记录来源：SIMULATION内部模拟柜、OCEAN_BOOKING订舱真实柜' AFTER cabinet_no;
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND column_name='record_status') THEN
    ALTER TABLE fl_container_booking ADD COLUMN record_status VARCHAR(16) NOT NULL DEFAULT 'ACTIVE'
      COMMENT '记录状态：ACTIVE可操作、MERGED已合并历史' AFTER source_type;
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND column_name='merged_into_container_booking_id') THEN
    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.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);
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND index_name='idx_container_booking_merge') THEN
    ALTER TABLE fl_container_booking ADD KEY idx_container_booking_merge (record_status,merged_into_container_booking_id);
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.table_constraints WHERE constraint_schema=DATABASE()
      AND table_name='fl_container_booking' AND constraint_name='chk_container_booking_source') THEN
    ALTER TABLE fl_container_booking ADD CONSTRAINT chk_container_booking_source
      CHECK (source_type IN ('SIMULATION','OCEAN_BOOKING'));
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.table_constraints WHERE constraint_schema=DATABASE()
      AND table_name='fl_container_booking' AND constraint_name='chk_container_booking_record_status') THEN
    ALTER TABLE fl_container_booking ADD CONSTRAINT chk_container_booking_record_status
      CHECK (record_status IN ('ACTIVE','MERGED'));
  END IF;
END$$
DELIMITER ;
CALL phase3_container_real_unit_columns();
DROP PROCEDURE phase3_container_real_unit_columns;

-- 触发器创建前先收敛旧库货柜供应商ID列；历史名称无法反推ID，保持NULL。
DROP PROCEDURE IF EXISTS phase3_container_supplier_snapshot_add_column;
DELIMITER $$
CREATE PROCEDURE phase3_container_supplier_snapshot_add_column()
BEGIN
  IF NOT EXISTS (SELECT 1 FROM information_schema.columns
      WHERE table_schema=DATABASE() AND table_name='fl_container_booking'
        AND column_name='terminal_trucking_company_id') THEN
    ALTER TABLE fl_container_booking
      ADD COLUMN terminal_trucking_company_id BIGINT UNSIGNED NULL COMMENT '码头拖车Supplier逻辑ID快照；历史数据无法推导时为空' AFTER max_weight_kg;
  END IF;
END$$
DELIMITER ;
CALL phase3_container_supplier_snapshot_add_column();
DROP PROCEDURE phase3_container_supplier_snapshot_add_column;

CREATE TABLE IF NOT EXISTS fl_loading_plan (
  id BIGINT UNSIGNED NOT NULL COMMENT '智能装柜计划ID（雪花ID）',
  plan_no VARCHAR(40) NOT NULL COMMENT '平台唯一装柜计划号',
  container_booking_id BIGINT UNSIGNED NOT NULL COMMENT '货柜预订ID',
  plan_status VARCHAR(24) NOT NULL DEFAULT 'EDITING' COMMENT '装柜计划状态：EDITING编辑中、LOADING装柜中、COMPLETED装柜完成；建议须经人工确认',
  push_idempotency_key VARCHAR(128) NULL COMMENT '推送预装幂等键',
  preload_pushed_by BIGINT UNSIGNED NULL COMMENT '推送预装操作人ID',
  preload_pushed_by_name VARCHAR(64) NULL COMMENT '推送预装操作人名称快照',
  preload_pushed_at DATETIME(3) NULL COMMENT '开始装柜并进入LOADING的时间',
  preload_completed_by BIGINT UNSIGNED NULL COMMENT '预装完成操作人ID',
  preload_completed_by_name VARCHAR(64) NULL COMMENT '预装完成操作人名称快照',
  preload_completed_at DATETIME(3) NULL COMMENT '预装完成时间',
  confirmed_by BIGINT UNSIGNED NULL COMMENT '确认操作人ID',
  confirmed_by_name VARCHAR(64) NULL COMMENT '确认操作人名称快照',
  confirmed_at DATETIME(3) NULL COMMENT '确认时间',
  remark VARCHAR(500) NULL COMMENT '平台装柜计划备注',
  created_by BIGINT UNSIGNED NOT NULL COMMENT '创建人ID',
  created_by_name VARCHAR(64) NULL COMMENT '创建人名称快照',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  updated_by BIGINT UNSIGNED NOT NULL COMMENT '最后修改人ID',
  updated_by_name VARCHAR(64) NULL COMMENT '最后修改人名称快照',
  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '装柜计划最后更新时间',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_plan_no (plan_no),
  UNIQUE KEY uk_loading_plan_booking (container_booking_id),
  UNIQUE KEY uk_loading_plan_push_key (push_idempotency_key),
  KEY idx_loading_plan_status (plan_status, updated_at, id),
  CONSTRAINT fk_loading_plan_booking FOREIGN KEY (container_booking_id)
    REFERENCES fl_container_booking (id),
  CONSTRAINT chk_loading_plan_status
    CHECK (plan_status IN ('EDITING', 'LOADING', 'COMPLETED'))
) ENGINE=InnoDB COMMENT='平台智能装柜计划与唯一预装状态源';

CREATE TABLE IF NOT EXISTS fl_loading_plan_item (
  id BIGINT UNSIGNED NOT NULL COMMENT '装柜计划明细ID（雪花ID）',
  loading_plan_id BIGINT UNSIGNED NOT NULL COMMENT '智能装柜计划ID',
  account_id BIGINT UNSIGNED NOT NULL COMMENT '客户账号ID；装柜业务唯一客户归属字段',
  customer_name VARCHAR(128) NOT NULL COMMENT '客户名称快照',
  inbound_id BIGINT UNSIGNED NOT NULL COMMENT 'Firstleg入库单ID',
  inbound_detail_id BIGINT UNSIGNED NOT NULL COMMENT '订单货物或入库货物明细ID，不建立跨库外键',
  order_id BIGINT UNSIGNED NOT NULL COMMENT '订单服务订单ID快照，不建立跨库外键',
  order_no VARCHAR(32) NOT NULL COMMENT '订单号快照',
  inbound_code VARCHAR(40) NOT NULL COMMENT '入仓码快照',
  destination_warehouse_id BIGINT UNSIGNED NULL COMMENT '目的仓ID快照',
  destination_warehouse_code VARCHAR(64) NULL COMMENT '目的仓编码快照',
  destination_warehouse_name VARCHAR(128) NULL COMMENT '目的仓名称快照',
  sku_code VARCHAR(128) NULL COMMENT 'SKU编码快照',
  product_name_zh VARCHAR(255) NULL COMMENT '中文品名快照',
  product_name_en VARCHAR(255) NULL COMMENT '英文品名快照',
  product_image_file_id BIGINT UNSIGNED NULL COMMENT '产品图片File对象ID',
  product_image_url VARCHAR(1000) NULL COMMENT '产品图片访问地址快照',
  package_count INT UNSIGNED NOT NULL COMMENT '本次装柜箱数',
  product_quantity INT UNSIGNED NULL COMMENT '产品总数量',
  units_per_carton INT UNSIGNED NULL COMMENT '每箱产品数',
  pallet_count INT UNSIGNED NULL COMMENT '托盘数',
  gross_weight_kg DECIMAL(18,3) NULL COMMENT '本次装柜毛重kg',
  net_weight_kg DECIMAL(18,3) NULL COMMENT '本次装柜净重kg',
  dimensional_weight_kg DECIMAL(18,3) NULL COMMENT '本次装柜材积重kg',
  volume_cbm DECIMAL(18,4) NULL COMMENT '本次装柜体积m3',
  fba_tracking_no VARCHAR(128) NULL COMMENT 'FBA追踪号快照',
  shipment_no VARCHAR(128) NULL COMMENT '货件编号快照',
  shipping_mark VARCHAR(500) NULL COMMENT '唛头快照',
  load_sequence INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '装柜顺序',
  position_snapshot JSON NULL COMMENT '智能装柜位置与摆放结果快照',
  internal_remark VARCHAR(1000) NULL COMMENT '平台内部备注',
  customer_remark VARCHAR(1000) NULL COMMENT '客户备注快照',
  warehouse_remark VARCHAR(1000) NULL COMMENT '仓库备注快照',
  frozen_at DATETIME(3) NULL COMMENT '装柜完成后的永久冻结时间',
  frozen_by BIGINT UNSIGNED NULL COMMENT '冻结操作人ID',
  removed_by BIGINT UNSIGNED NULL COMMENT '推送前逻辑删除操作人ID',
  removed_by_name VARCHAR(64) NULL COMMENT '推送前逻辑删除操作人名称快照',
  removed_at DATETIME(3) NULL COMMENT '推送前逻辑删除时间',
  deleted TINYINT(1) NOT NULL DEFAULT 0 COMMENT '推送前逻辑删除标记；冻结后不可修改',
  active_inbound_detail_id BIGINT UNSIGNED GENERATED ALWAYS AS (CASE WHEN deleted = 0 THEN inbound_detail_id ELSE NULL END) STORED COMMENT '未删除明细唯一锁；删除后返回NULL释放分配资格',
  created_by BIGINT UNSIGNED NOT NULL COMMENT '创建人ID',
  created_by_name VARCHAR(64) NULL COMMENT '创建人名称快照',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  updated_by BIGINT UNSIGNED NOT NULL COMMENT '最后修改人ID',
  updated_by_name VARCHAR(64) NULL COMMENT '最后修改人名称快照',
  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '装柜明细最后更新时间',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_item_plan_detail (loading_plan_id, active_inbound_detail_id),
  KEY idx_loading_item_active_detail (account_id, active_inbound_detail_id),
  KEY idx_loading_item_plan (loading_plan_id, deleted, load_sequence, id),
  KEY idx_loading_item_account (account_id, created_at, id),
  KEY idx_loading_item_inbound (account_id, inbound_id, deleted),
  KEY idx_loading_item_order (account_id, order_id, deleted),
  CONSTRAINT fk_loading_item_plan FOREIGN KEY (loading_plan_id) REFERENCES fl_loading_plan (id),
  CONSTRAINT chk_loading_item_account CHECK (account_id > 0),
  CONSTRAINT chk_loading_item_package CHECK (package_count > 0),
  CONSTRAINT chk_loading_item_product_quantity CHECK (product_quantity IS NULL OR product_quantity > 0),
  CONSTRAINT chk_loading_item_units CHECK (units_per_carton IS NULL OR units_per_carton > 0),
  CONSTRAINT chk_loading_item_pallet CHECK (pallet_count IS NULL OR pallet_count >= 0),
  CONSTRAINT chk_loading_item_weight CHECK (
    (gross_weight_kg IS NULL OR gross_weight_kg >= 0)
    AND (net_weight_kg IS NULL OR net_weight_kg >= 0)
    AND (dimensional_weight_kg IS NULL OR dimensional_weight_kg >= 0)
  ),
  CONSTRAINT chk_loading_item_volume CHECK (volume_cbm IS NULL OR volume_cbm >= 0),
  CONSTRAINT chk_loading_item_deleted CHECK (deleted IN (0, 1))
) ENGINE=InnoDB COMMENT='智能装柜客户货物明细；客户归属仅在明细层';

-- 目的港清关和出口报关均为柜次级简单文件事实：上传资料后由平台一键完成。
CREATE TABLE IF NOT EXISTS fl_container_document (
  id BIGINT UNSIGNED NOT NULL COMMENT '货柜文件关联ID（雪花ID）',
  container_booking_id BIGINT UNSIGNED NOT NULL COMMENT '货柜预订ID',
  document_type VARCHAR(32) NOT NULL COMMENT '文件类型：DESTINATION_CLEARANCE目的港清关、CUSTOMS_DECLARATION出口报关、DELIVERY_ORDER提货单、PICKUP_ORDER取货单',
  file_id BIGINT UNSIGNED NOT NULL COMMENT 'File服务文件ID，不建立跨库外键',
  file_name VARCHAR(255) NOT NULL COMMENT '文件名称快照',
  file_hash VARCHAR(64) NULL COMMENT 'File服务SHA-256快照',
  file_url VARCHAR(1000) NULL COMMENT '文件访问地址快照',
  uploaded_by BIGINT UNSIGNED NOT NULL COMMENT '上传操作人ID',
  uploaded_by_name VARCHAR(64) NULL COMMENT '上传操作人名称快照',
  completed_by BIGINT UNSIGNED NULL COMMENT '一键完成操作人ID',
  completed_by_name VARCHAR(64) NULL COMMENT '一键完成操作人名称快照',
  completed_at DATETIME(3) NULL COMMENT '一键完成时间',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '货柜文件关联最后更新时间',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_container_document_type (container_booking_id, document_type),
  KEY idx_container_document_file (file_id),
  CONSTRAINT fk_container_document_booking FOREIGN KEY (container_booking_id)
    REFERENCES fl_container_booking (id),
  CONSTRAINT chk_container_document_type
    CHECK (document_type IN ('DESTINATION_CLEARANCE', 'CUSTOMS_DECLARATION', 'DELIVERY_ORDER', 'PICKUP_ORDER'))
) ENGINE=InnoDB COMMENT='平台货柜清关、DO与PU文件关联';

CREATE TABLE IF NOT EXISTS fl_container_exception_history (
  id BIGINT UNSIGNED NOT NULL, container_booking_id BIGINT UNSIGNED NOT NULL,
  action VARCHAR(16) NOT NULL, reason VARCHAR(500) NOT NULL,
  operator_id BIGINT UNSIGNED NOT NULL, operator_name VARCHAR(64) NULL,
  operation_id VARCHAR(128) NOT NULL, request_hash CHAR(64) NOT NULL,
  occurred_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3), PRIMARY KEY(id),
  UNIQUE KEY uk_container_exception_operation(container_booking_id,operator_id,operation_id),
  KEY idx_container_exception_history(container_booking_id,occurred_at,id),
  CONSTRAINT fk_container_exception_booking FOREIGN KEY(container_booking_id) REFERENCES fl_container_booking(id),
  CONSTRAINT chk_container_exception_action CHECK(action IN ('MARK','CANCEL'))
) ENGINE=InnoDB COMMENT='货柜异常标记及取消原因历史';

DROP TRIGGER IF EXISTS trg_container_exception_history_before_update;
DROP TRIGGER IF EXISTS trg_container_exception_history_before_delete;
DELIMITER $$
CREATE TRIGGER trg_container_exception_history_before_update BEFORE UPDATE ON fl_container_exception_history FOR EACH ROW
BEGIN SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT='货柜异常历史不可修改'; END$$
CREATE TRIGGER trg_container_exception_history_before_delete BEFORE DELETE ON fl_container_exception_history FOR EACH ROW
BEGIN SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT='货柜异常历史不可删除'; END$$
DELIMITER ;

CREATE TABLE IF NOT EXISTS fl_loading_plan_history (
  id BIGINT UNSIGNED NOT NULL COMMENT '装柜操作历史ID（雪花ID）',
  loading_plan_id BIGINT UNSIGNED NOT NULL COMMENT '智能装柜计划ID',
  loading_plan_item_id BIGINT UNSIGNED NULL COMMENT '装柜计划明细ID',
  operation_id VARCHAR(128) NOT NULL COMMENT '操作幂等ID',
  action_type VARCHAR(32) NOT NULL COMMENT '动作类型：CREATE_PLAN创建计划、ADD_ITEM新增明细、ADJUST_ITEM调整明细、REMOVE_ITEM移除明细、START_LOADING开始装柜、COMPLETE_LOADING完成装柜、PICK_ITEM拣货',
  from_status VARCHAR(24) NULL COMMENT '变更前状态',
  to_status VARCHAR(24) NULL COMMENT '变更后状态',
  before_snapshot JSON NULL COMMENT '变更前快照',
  after_snapshot JSON NULL COMMENT '变更后快照',
  operator_id BIGINT UNSIGNED NOT NULL COMMENT '操作人ID',
  operator_name VARCHAR(64) NULL COMMENT '操作人名称快照',
  operation_reason VARCHAR(500) NULL COMMENT '操作原因',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '操作时间',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_history_operation (operation_id),
  KEY idx_loading_history_plan (loading_plan_id, created_at, id),
  KEY idx_loading_history_item (loading_plan_item_id, created_at, id),
  CONSTRAINT fk_loading_history_plan FOREIGN KEY (loading_plan_id) REFERENCES fl_loading_plan (id),
  CONSTRAINT fk_loading_history_item FOREIGN KEY (loading_plan_item_id)
    REFERENCES fl_loading_plan_item (id)
) ENGINE=InnoDB COMMENT='智能装柜追加式不可变操作历史';

-- fl_loading_pick_task 曾被另一套入库汇总模型复用。先按字段签名识别并迁走，
-- 再创建智能装柜任务表；未知或混合结构必须人工处理，禁止静默套用错误表型。
DROP PROCEDURE IF EXISTS migrate_legacy_loading_pick_task;
DELIMITER $$
CREATE PROCEDURE migrate_legacy_loading_pick_task()
BEGIN
  DECLARE source_exists INT DEFAULT 0;
  DECLARE source_total_columns INT DEFAULT 0;
  DECLARE source_smart_columns INT DEFAULT 0;
  DECLARE source_inbound_columns INT DEFAULT 0;
  DECLARE target_exists INT DEFAULT 0;
  DECLARE target_total_columns INT DEFAULT 0;
  DECLARE target_inbound_columns INT DEFAULT 0;

  SELECT COUNT(*) INTO source_exists
    FROM information_schema.tables
   WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task';
  IF source_exists = 1 THEN
    SELECT COUNT(*) INTO source_total_columns
      FROM information_schema.columns
     WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task';
    SELECT COUNT(*) INTO source_smart_columns
      FROM information_schema.columns
     WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task' AND (
       (column_name = 'id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'loading_plan_id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'container_no' AND LOWER(column_type) = 'varchar(64)' AND is_nullable = 'NO')
       OR (column_name = 'task_status' AND LOWER(column_type) = 'varchar(16)' AND is_nullable = 'NO' AND column_default = 'LOADING')
       OR (column_name = 'started_by' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'started_by_name' AND LOWER(column_type) = 'varchar(64)' AND is_nullable = 'YES')
       OR (column_name = 'started_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'NO' AND LOWER(column_default) LIKE 'current_timestamp%')
       OR (column_name = 'completed_by' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'YES')
       OR (column_name = 'completed_by_name' AND LOWER(column_type) = 'varchar(64)' AND is_nullable = 'YES')
       OR (column_name = 'completed_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'YES')
       OR (column_name = 'version' AND LOWER(column_type) = 'int unsigned' AND is_nullable = 'NO' AND CAST(column_default AS CHAR) = '0')
     );
    SELECT COUNT(*) INTO source_inbound_columns
      FROM information_schema.columns
     WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task' AND (
       (column_name = 'id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'tenant_id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'inbound_id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'status' AND LOWER(column_type) = 'varchar(24)' AND is_nullable = 'NO' AND column_default = 'PENDING')
       OR (column_name = 'version' AND LOWER(column_type) = 'int' AND is_nullable = 'NO' AND CAST(column_default AS CHAR) = '0')
       OR (column_name = 'expected_count' AND LOWER(column_type) = 'int unsigned' AND is_nullable = 'YES')
       OR (column_name = 'picked_count' AND LOWER(column_type) = 'int unsigned' AND is_nullable = 'YES')
       OR (column_name = 'remark' AND LOWER(column_type) = 'varchar(1000)' AND is_nullable = 'YES')
       OR (column_name = 'updated_by' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
       OR (column_name = 'updated_by_name' AND LOWER(column_type) = 'varchar(64)' AND is_nullable = 'YES')
       OR (column_name = 'created_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'NO' AND LOWER(column_default) LIKE 'current_timestamp%')
       OR (column_name = 'updated_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'NO' AND LOWER(column_default) LIKE 'current_timestamp%' AND LOWER(extra) LIKE '%on update current_timestamp%')
     );

    IF source_total_columns = 11 AND source_smart_columns = 11 AND source_inbound_columns < 12
       AND (SELECT COUNT(*) FROM information_schema.statistics
             WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND index_name = 'uk_loading_pick_task_plan' AND non_unique = 0
               AND seq_in_index = 1 AND column_name = 'loading_plan_id') = 1
       AND (SELECT COUNT(*) FROM information_schema.statistics
             WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND index_name = 'idx_loading_pick_container'
               AND ((seq_in_index = 1 AND column_name = 'container_no')
                 OR (seq_in_index = 2 AND column_name = 'task_status')
                 OR (seq_in_index = 3 AND column_name = 'started_at'))) = 3
       AND (SELECT COUNT(*) FROM information_schema.key_column_usage
             WHERE constraint_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND column_name = 'loading_plan_id' AND referenced_table_name = 'fl_loading_plan'
               AND referenced_column_name = 'id') = 1 THEN
      SET source_exists = 1;
    ELSEIF source_total_columns = 12 AND source_inbound_columns = 12 AND source_smart_columns < 11
       AND (SELECT COUNT(*) FROM information_schema.statistics
             WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND index_name = 'uk_loading_pick_tenant_inbound' AND non_unique = 0
               AND ((seq_in_index = 1 AND column_name = 'tenant_id')
                 OR (seq_in_index = 2 AND column_name = 'inbound_id'))) = 2
       AND (SELECT COUNT(*) FROM information_schema.statistics
             WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND index_name = 'idx_loading_pick_status'
               AND ((seq_in_index = 1 AND column_name = 'tenant_id')
                 OR (seq_in_index = 2 AND column_name = 'status')
                 OR (seq_in_index = 3 AND column_name = 'updated_at'))) = 3
       AND (SELECT COUNT(*) FROM information_schema.key_column_usage
             WHERE constraint_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_pick_task'
               AND column_name = 'inbound_id' AND referenced_table_name = 'fl_inbound_order'
               AND referenced_column_name = 'id') = 1 THEN
      SELECT COUNT(*) INTO target_exists
        FROM information_schema.tables
       WHERE table_schema = 'baiyue_firstleg'
         AND table_name = 'fl_inbound_loading_pick_task';
      IF target_exists = 0 THEN
        RENAME TABLE fl_loading_pick_task TO fl_inbound_loading_pick_task;
      ELSE
        SELECT COUNT(*) INTO target_total_columns
          FROM information_schema.columns
         WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_loading_pick_task';
        SELECT COUNT(*) INTO target_inbound_columns
          FROM information_schema.columns
         WHERE table_schema = 'baiyue_firstleg'
           AND table_name = 'fl_inbound_loading_pick_task' AND (
           (column_name = 'id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
           OR (column_name = 'tenant_id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
           OR (column_name = 'inbound_id' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
           OR (column_name = 'status' AND LOWER(column_type) = 'varchar(24)' AND is_nullable = 'NO' AND column_default = 'PENDING')
           OR (column_name = 'version' AND LOWER(column_type) = 'int' AND is_nullable = 'NO' AND CAST(column_default AS CHAR) = '0')
           OR (column_name = 'expected_count' AND LOWER(column_type) = 'int unsigned' AND is_nullable = 'YES')
           OR (column_name = 'picked_count' AND LOWER(column_type) = 'int unsigned' AND is_nullable = 'YES')
           OR (column_name = 'remark' AND LOWER(column_type) = 'varchar(1000)' AND is_nullable = 'YES')
           OR (column_name = 'updated_by' AND LOWER(column_type) = 'bigint unsigned' AND is_nullable = 'NO')
           OR (column_name = 'updated_by_name' AND LOWER(column_type) = 'varchar(64)' AND is_nullable = 'YES')
           OR (column_name = 'created_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'NO' AND LOWER(column_default) LIKE 'current_timestamp%')
           OR (column_name = 'updated_at' AND data_type = 'datetime' AND datetime_precision = 3 AND is_nullable = 'NO' AND LOWER(column_default) LIKE 'current_timestamp%' AND LOWER(extra) LIKE '%on update current_timestamp%')
         );
        IF target_total_columns <> 12 OR target_inbound_columns <> 12
           OR (SELECT COUNT(*) FROM information_schema.statistics
                WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_loading_pick_task'
                  AND index_name = 'uk_loading_pick_tenant_inbound' AND non_unique = 0
                  AND ((seq_in_index = 1 AND column_name = 'tenant_id')
                    OR (seq_in_index = 2 AND column_name = 'inbound_id'))) <> 2
           OR (SELECT COUNT(*) FROM information_schema.statistics
                WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_loading_pick_task'
                  AND index_name = 'idx_loading_pick_status'
                  AND ((seq_in_index = 1 AND column_name = 'tenant_id')
                    OR (seq_in_index = 2 AND column_name = 'status')
                    OR (seq_in_index = 3 AND column_name = 'updated_at'))) <> 3
           OR (SELECT COUNT(*) FROM information_schema.key_column_usage
                WHERE constraint_schema = 'baiyue_firstleg' AND table_name = 'fl_inbound_loading_pick_task'
                  AND column_name = 'inbound_id' AND referenced_table_name = 'fl_inbound_order'
                  AND referenced_column_name = 'id') <> 1 THEN
          SIGNAL SQLSTATE '45000'
            SET MESSAGE_TEXT = '拣货任务迁移失败：fl_inbound_loading_pick_task 不是完整入库汇总结构';
        END IF;
        INSERT INTO fl_inbound_loading_pick_task
          (id, tenant_id, inbound_id, status, version, expected_count, picked_count,
           remark, updated_by, updated_by_name, created_at, updated_at)
        SELECT source.id, source.tenant_id, source.inbound_id, source.status, source.version,
               source.expected_count, source.picked_count, source.remark, source.updated_by,
               source.updated_by_name, source.created_at, source.updated_at
          FROM fl_loading_pick_task source
          LEFT JOIN fl_inbound_loading_pick_task target
            ON target.id = source.id
         WHERE target.id IS NULL;
        IF EXISTS (
          SELECT 1
            FROM fl_loading_pick_task source
            LEFT JOIN fl_inbound_loading_pick_task target ON target.id = source.id
           WHERE target.id IS NULL
              OR NOT (target.tenant_id <=> source.tenant_id)
              OR NOT (target.inbound_id <=> source.inbound_id)
              OR NOT (target.status <=> source.status)
              OR NOT (target.version <=> source.version)
              OR NOT (target.expected_count <=> source.expected_count)
              OR NOT (target.picked_count <=> source.picked_count)
              OR NOT (target.remark <=> source.remark)
              OR NOT (target.updated_by <=> source.updated_by)
              OR NOT (target.updated_by_name <=> source.updated_by_name)
              OR NOT (target.created_at <=> source.created_at)
              OR NOT (target.updated_at <=> source.updated_at)
        ) THEN
          SIGNAL SQLSTATE '45000'
            SET MESSAGE_TEXT = '拣货任务迁移失败：新旧入库汇总任务存在主键冲突';
        END IF;
        DROP TABLE fl_loading_pick_task;
      END IF;
    ELSE
      SIGNAL SQLSTATE '45000'
        SET MESSAGE_TEXT = '拣货任务迁移失败：fl_loading_pick_task 字段签名未知或混合';
    END IF;
  END IF;
END$$
DELIMITER ;
CALL migrate_legacy_loading_pick_task();
DROP PROCEDURE migrate_legacy_loading_pick_task;

CREATE TABLE IF NOT EXISTS fl_loading_pick_task (
  id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货任务ID',
  loading_plan_id BIGINT UNSIGNED NOT NULL COMMENT '装柜计划ID',
  container_booking_id BIGINT UNSIGNED NOT NULL COMMENT '稳定柜次ID',
  cabinet_no VARCHAR(64) NOT NULL COMMENT '稳定内部柜次号快照',
  container_no VARCHAR(64) NULL COMMENT '废弃兼容字段；不得作为任务身份或随运输号变更重写',
  task_status VARCHAR(16) NOT NULL DEFAULT 'LOADING' COMMENT 'PDA任务状态：LOADING拣货装柜中、COMPLETED已完成',
  started_by BIGINT UNSIGNED NOT NULL COMMENT '开始装柜人',
  started_by_name VARCHAR(64) NULL COMMENT '开始装柜人名称',
  started_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '开始时间',
  completed_by BIGINT UNSIGNED NULL COMMENT '完成装柜人',
  completed_by_name VARCHAR(64) NULL COMMENT '完成装柜人名称',
  completed_at DATETIME(3) NULL COMMENT '完成时间',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_pick_task_plan (loading_plan_id),
  UNIQUE KEY uk_loading_pick_task_booking (container_booking_id),
  KEY idx_loading_pick_container (container_no, task_status, started_at),
  CONSTRAINT fk_loading_pick_task_plan FOREIGN KEY (loading_plan_id) REFERENCES fl_loading_plan (id),
  CONSTRAINT chk_loading_pick_task_status CHECK (task_status IN ('LOADING', 'COMPLETED'))
) ENGINE=InnoDB COMMENT='PDA装柜拣货任务';

CREATE TABLE IF NOT EXISTS fl_loading_pick_item (
  id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货明细ID',
  pick_task_id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货任务ID',
  loading_plan_item_id BIGINT UNSIGNED NOT NULL COMMENT '装柜计划明细ID',
  inbound_id BIGINT UNSIGNED NOT NULL COMMENT '父入库单ID',
  inbound_detail_id BIGINT UNSIGNED NOT NULL COMMENT '订单货物明细ID',
  planned_package_count INT UNSIGNED NOT NULL COMMENT '计划拣货箱数；上层拆分按业务规则向上取整',
  picked_package_count INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '已拣货箱数',
  item_status VARCHAR(16) NOT NULL DEFAULT 'PENDING' COMMENT '拣货明细状态：PENDING待拣、PICKING拣货中、PICKED已拣完、PARTIAL部分拣货、SKIPPED跳拣',
  release_mode VARCHAR(10) NULL COMMENT 'AUTO按比例释放，MANUAL按人工选择释放',
  release_location_ids JSON NULL COMMENT '人工选择释放库位ID；空数组表示明确释放0个',
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT 'PDA拣货明细创建时间',
  updated_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT 'PDA拣货明细最后更新时间',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_pick_item_plan_item (loading_plan_item_id),
  KEY idx_loading_pick_item_task (pick_task_id, item_status, id),
  CONSTRAINT fk_loading_pick_item_task FOREIGN KEY (pick_task_id) REFERENCES fl_loading_pick_task (id),
  CONSTRAINT fk_loading_pick_item_plan_item FOREIGN KEY (loading_plan_item_id) REFERENCES fl_loading_plan_item (id),
  CONSTRAINT chk_loading_pick_item_planned CHECK (planned_package_count > 0),
  CONSTRAINT chk_loading_pick_item_count CHECK (picked_package_count <= planned_package_count),
  CONSTRAINT chk_loading_pick_item_status CHECK (item_status IN ('PENDING', 'PICKING', 'PICKED', 'PARTIAL', 'SKIPPED'))
) ENGINE=InnoDB COMMENT='PDA装柜拣货明细';

CREATE TABLE IF NOT EXISTS fl_loading_pick_history (
  id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货操作历史ID',
  pick_task_id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货任务ID',
  pick_item_id BIGINT UNSIGNED NOT NULL COMMENT 'PDA拣货明细ID',
  operation_id VARCHAR(128) NOT NULL COMMENT '客户端幂等操作号',
  request_hash CHAR(64) NOT NULL COMMENT '完整批量请求内容SHA-256摘要',
  action_type VARCHAR(24) NOT NULL DEFAULT 'PICK' COMMENT '拣货动作：PICK正常拣货、PARTIAL部分拣货、SKIP跳拣',
  picked_package_count INT UNSIGNED NOT NULL COMMENT '本次拣货箱数',
  operation_reason VARCHAR(500) NULL COMMENT '部分拣货或跳拣原因',
  operator_id BIGINT UNSIGNED NOT NULL COMMENT '执行PDA拣货操作的作业员ID',
  operator_name VARCHAR(64) NULL COMMENT '作业员姓名快照',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '不可变拣货操作历史创建时间',
  PRIMARY KEY (id),
  UNIQUE KEY uk_loading_pick_history_operation (operation_id),
  KEY idx_loading_pick_history_item (pick_item_id, created_at),
  CONSTRAINT fk_loading_pick_history_task FOREIGN KEY (pick_task_id) REFERENCES fl_loading_pick_task (id),
  CONSTRAINT fk_loading_pick_history_item FOREIGN KEY (pick_item_id) REFERENCES fl_loading_pick_item (id)
) ENGINE=InnoDB COMMENT='PDA拣货幂等和操作审计历史';

DROP PROCEDURE IF EXISTS repair_phase3_loading_pick_task_foreign_keys;
DELIMITER $$
CREATE PROCEDURE repair_phase3_loading_pick_task_foreign_keys()
BEGIN
  DECLARE item_fk_count INT DEFAULT 0;
  DECLARE item_target_count INT DEFAULT 0;
  DECLARE history_fk_count INT DEFAULT 0;
  DECLARE history_target_count INT DEFAULT 0;
  DECLARE item_drop_clauses TEXT;
  DECLARE history_drop_clauses TEXT;

  IF EXISTS (
    SELECT 1 FROM fl_loading_pick_item item
     LEFT JOIN fl_loading_pick_task task ON task.id = item.pick_task_id
     WHERE task.id IS NULL
  ) THEN
    SIGNAL SQLSTATE '45000'
      SET MESSAGE_TEXT = '柜次PDA明细存在无法迁移到智能装柜任务的引用';
  END IF;
  IF EXISTS (
    SELECT 1 FROM fl_loading_pick_history history
     LEFT JOIN fl_loading_pick_task task ON task.id = history.pick_task_id
     WHERE task.id IS NULL
  ) THEN
    SIGNAL SQLSTATE '45000'
      SET MESSAGE_TEXT = '柜次PDA历史存在无法迁移到智能装柜任务的引用';
  END IF;

  SELECT COUNT(*),
         SUM(k.referenced_table_name = 'fl_loading_pick_task'
             AND k.referenced_column_name = 'id'
             AND (SELECT COUNT(*) FROM information_schema.key_column_usage peer
                   WHERE peer.constraint_schema = k.constraint_schema
                     AND peer.table_name = k.table_name
                     AND peer.constraint_name = k.constraint_name) = 1),
         GROUP_CONCAT(CONCAT('DROP FOREIGN KEY `', REPLACE(k.constraint_name, '`', '``'), '`')
                      ORDER BY k.constraint_name SEPARATOR ', ')
    INTO item_fk_count, item_target_count, item_drop_clauses
    FROM information_schema.key_column_usage k
   WHERE k.constraint_schema = 'baiyue_firstleg'
     AND k.table_name = 'fl_loading_pick_item'
     AND k.column_name = 'pick_task_id'
     AND k.referenced_table_name IS NOT NULL;
  IF item_fk_count <> 1 OR item_target_count <> 1 THEN
    IF item_drop_clauses IS NOT NULL THEN
      SET @phase3_fk_ddl = CONCAT('ALTER TABLE fl_loading_pick_item ', item_drop_clauses);
      PREPARE phase3_fk_statement FROM @phase3_fk_ddl;
      EXECUTE phase3_fk_statement;
      DEALLOCATE PREPARE phase3_fk_statement;
    END IF;
    ALTER TABLE fl_loading_pick_item
      ADD CONSTRAINT fk_loading_pick_item_task
      FOREIGN KEY (pick_task_id) REFERENCES fl_loading_pick_task (id);
  END IF;

  SELECT COUNT(*),
         SUM(k.referenced_table_name = 'fl_loading_pick_task'
             AND k.referenced_column_name = 'id'
             AND (SELECT COUNT(*) FROM information_schema.key_column_usage peer
                   WHERE peer.constraint_schema = k.constraint_schema
                     AND peer.table_name = k.table_name
                     AND peer.constraint_name = k.constraint_name) = 1),
         GROUP_CONCAT(CONCAT('DROP FOREIGN KEY `', REPLACE(k.constraint_name, '`', '``'), '`')
                      ORDER BY k.constraint_name SEPARATOR ', ')
    INTO history_fk_count, history_target_count, history_drop_clauses
    FROM information_schema.key_column_usage k
   WHERE k.constraint_schema = 'baiyue_firstleg'
     AND k.table_name = 'fl_loading_pick_history'
     AND k.column_name = 'pick_task_id'
     AND k.referenced_table_name IS NOT NULL;
  IF history_fk_count <> 1 OR history_target_count <> 1 THEN
    IF history_drop_clauses IS NOT NULL THEN
      SET @phase3_fk_ddl = CONCAT('ALTER TABLE fl_loading_pick_history ', history_drop_clauses);
      PREPARE phase3_fk_statement FROM @phase3_fk_ddl;
      EXECUTE phase3_fk_statement;
      DEALLOCATE PREPARE phase3_fk_statement;
    END IF;
    ALTER TABLE fl_loading_pick_history
      ADD CONSTRAINT fk_loading_pick_history_task
      FOREIGN KEY (pick_task_id) REFERENCES fl_loading_pick_task (id);
  END IF;
END$$
DELIMITER ;
CALL repair_phase3_loading_pick_task_foreign_keys();
DROP PROCEDURE repair_phase3_loading_pick_task_foreign_keys;

DROP TRIGGER IF EXISTS trg_container_booking_before_update;
DELIMITER $$
CREATE TRIGGER trg_container_booking_before_update
BEFORE UPDATE ON fl_container_booking
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status
    FROM fl_loading_plan WHERE container_booking_id = OLD.id;
  IF current_plan_status IN ('LOADING', 'COMPLETED') AND (
       NOT (OLD.id <=> NEW.id) OR NOT (OLD.booking_no <=> NEW.booking_no)
    OR NOT (OLD.cabinet_no <=> NEW.cabinet_no)
    OR NOT (OLD.channel_code <=> NEW.channel_code)
    OR NOT (OLD.channel_name <=> NEW.channel_name)
    OR NOT (OLD.ocean_booking_id <=> NEW.ocean_booking_id)
    OR NOT (OLD.ocean_booking_requirement_id <=> NEW.ocean_booking_requirement_id)
    OR NOT (OLD.warehouse_id <=> NEW.warehouse_id)
    OR NOT (OLD.warehouse_name <=> NEW.warehouse_name)
    OR NOT (OLD.container_type <=> NEW.container_type)
    OR NOT (OLD.shipping_company_id <=> NEW.shipping_company_id)
    OR NOT (OLD.shipping_company_name <=> NEW.shipping_company_name)
    OR NOT (OLD.departure_port_code <=> NEW.departure_port_code)
    OR NOT (OLD.departure_port_name <=> NEW.departure_port_name)
    OR NOT (OLD.destination_port_code <=> NEW.destination_port_code)
    OR NOT (OLD.destination_port_name <=> NEW.destination_port_name)
    OR NOT (OLD.destination_warehouse_code <=> NEW.destination_warehouse_code)
    OR NOT (OLD.destination_warehouse_name <=> NEW.destination_warehouse_name)
    OR NOT (OLD.capacity_cbm <=> NEW.capacity_cbm)
    OR NOT (OLD.max_weight_kg <=> NEW.max_weight_kg)
    OR NOT (OLD.terminal_trucking_company_id <=> NEW.terminal_trucking_company_id)
    OR NOT (OLD.terminal_trucking_company <=> NEW.terminal_trucking_company)
    OR NOT (OLD.loading_at <=> NEW.loading_at)
    OR NOT (OLD.actual_sailing_at <=> NEW.actual_sailing_at)
    OR NOT (OLD.estimated_port_arrival_at <=> NEW.estimated_port_arrival_at)
    OR NOT (OLD.actual_port_arrival_at <=> NEW.actual_port_arrival_at)
    OR NOT (OLD.estimated_warehouse_arrival_at <=> NEW.estimated_warehouse_arrival_at)
    OR NOT (OLD.actual_warehouse_arrival_at <=> NEW.actual_warehouse_arrival_at)
    OR NOT (OLD.created_by <=> NEW.created_by)
    OR NOT (OLD.created_by_name <=> NEW.created_by_name)
    OR NOT (OLD.created_at <=> NEW.created_at)
  ) THEN
    SIGNAL SQLSTATE '45000'
      SET MESSAGE_TEXT = '装柜作业开始后仅允许修改集装箱号与放舱运输数据';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_plan_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_plan_before_update
BEFORE UPDATE ON fl_loading_plan
FOR EACH ROW
BEGIN
  IF OLD.plan_status = 'COMPLETED' THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已完成装柜计划全部只读';
  END IF;
  IF NOT (
       (OLD.plan_status = 'EDITING' AND NEW.plan_status IN ('EDITING', 'LOADING'))
    OR (OLD.plan_status = 'LOADING'
        AND NEW.plan_status IN ('LOADING', 'COMPLETED'))
    OR (OLD.plan_status = 'LOADING' AND NEW.plan_status = 'EDITING'
        AND NOT EXISTS (
          SELECT 1
            FROM fl_loading_pick_item pick_item
            JOIN fl_loading_pick_task pick_task ON pick_task.id = pick_item.pick_task_id
           WHERE pick_task.loading_plan_id = OLD.id
             AND pick_item.picked_package_count > 0
        ))
  ) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜状态只允许单向推进';
  END IF;
  IF OLD.plan_status = 'LOADING' AND (
       NOT (OLD.id <=> NEW.id) OR NOT (OLD.plan_no <=> NEW.plan_no)
    OR NOT (OLD.container_booking_id <=> NEW.container_booking_id)
    OR NOT (OLD.push_idempotency_key <=> NEW.push_idempotency_key)
    OR NOT (OLD.preload_pushed_by <=> NEW.preload_pushed_by)
    OR NOT (OLD.preload_pushed_by_name <=> NEW.preload_pushed_by_name)
    OR NOT (OLD.preload_pushed_at <=> NEW.preload_pushed_at)
    OR NOT (OLD.remark <=> NEW.remark)
    OR NOT (OLD.created_by <=> NEW.created_by)
    OR NOT (OLD.created_by_name <=> NEW.created_by_name)
    OR NOT (OLD.created_at <=> NEW.created_at)
  ) THEN
    SIGNAL SQLSTATE '45000'
      SET MESSAGE_TEXT = '装柜中计划仅允许乐观锁触碰或完成装柜';
  END IF;
  IF OLD.plan_status = NEW.plan_status
     AND OLD.plan_status = 'LOADING' AND (
       NOT (OLD.preload_completed_by <=> NEW.preload_completed_by)
    OR NOT (OLD.preload_completed_by_name <=> NEW.preload_completed_by_name)
    OR NOT (OLD.preload_completed_at <=> NEW.preload_completed_at)
    OR NOT (OLD.confirmed_by <=> NEW.confirmed_by)
    OR NOT (OLD.confirmed_by_name <=> NEW.confirmed_by_name)
    OR NOT (OLD.confirmed_at <=> NEW.confirmed_at)
  ) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '同状态乐观锁触碰不得修改阶段审计字段';
  END IF;
  IF OLD.plan_status = 'EDITING' AND NEW.plan_status = 'LOADING' THEN
    IF NEW.push_idempotency_key IS NULL OR CHAR_LENGTH(TRIM(NEW.push_idempotency_key)) = 0 THEN
      SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '开始装柜必须提供幂等键';
    END IF;
    SET NEW.preload_pushed_at = COALESCE(NEW.preload_pushed_at, CURRENT_TIMESTAMP(3));
  ELSEIF OLD.plan_status = 'LOADING' AND NEW.plan_status = 'COMPLETED' THEN
    IF EXISTS (SELECT 1 FROM fl_loading_plan_item item
               LEFT JOIN fl_loading_pick_item pick_item
                 ON pick_item.loading_plan_item_id = item.id
               LEFT JOIN fl_loading_pick_task pick_task
                 ON pick_task.id = pick_item.pick_task_id
                AND pick_task.loading_plan_id = OLD.id
              WHERE item.loading_plan_id = OLD.id AND item.deleted = 0
                AND (pick_task.id IS NULL
                  OR pick_item.picked_package_count <> item.package_count)) THEN
      SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '仍有未完成拣货明细，不能完成装柜';
    END IF;
    SET NEW.confirmed_at = COALESCE(NEW.confirmed_at, CURRENT_TIMESTAMP(3));
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_plan_after_update;
DELIMITER $$
CREATE TRIGGER trg_loading_plan_after_update
AFTER UPDATE ON fl_loading_plan
FOR EACH ROW
BEGIN
  IF OLD.plan_status = 'LOADING' AND NEW.plan_status = 'COMPLETED' THEN
    UPDATE fl_loading_plan_item
       SET frozen_at = COALESCE(frozen_at, NEW.confirmed_at, CURRENT_TIMESTAMP(3)),
           frozen_by = COALESCE(frozen_by, NEW.updated_by),
           updated_by = NEW.updated_by,
           updated_by_name = NEW.updated_by_name,
           version = version + 1
     WHERE loading_plan_id = NEW.id AND deleted = 0;
    UPDATE fl_loading_pick_task
       SET task_status = 'COMPLETED', completed_by = NEW.updated_by,
           completed_by_name = NEW.updated_by_name, completed_at = CURRENT_TIMESTAMP(3),
           version = version + 1
     WHERE loading_plan_id = NEW.id AND task_status = 'LOADING';
  END IF;
END$$
DELIMITER ;

-- 旧版本在推送预装时即写入 LOADING。仅回收从未发生实际拣货的计划；有实际拣货记录的数据不回退。
UPDATE fl_loading_plan plan
   SET plan_status = 'EDITING',
       updated_at = CURRENT_TIMESTAMP(3),
       version = version + 1
 WHERE plan.plan_status = 'LOADING'
   AND NOT EXISTS (
       SELECT 1
         FROM fl_loading_pick_item pick_item
         JOIN fl_loading_pick_task pick_task ON pick_task.id = pick_item.pick_task_id
        WHERE pick_task.loading_plan_id = plan.id
          AND pick_item.picked_package_count > 0
   );

DROP TRIGGER IF EXISTS trg_loading_item_before_insert;
DELIMITER $$
CREATE TRIGGER trg_loading_item_before_insert
BEFORE INSERT ON fl_loading_plan_item
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status FROM fl_loading_plan WHERE id = NEW.loading_plan_id;
  IF current_plan_status IS NULL OR current_plan_status NOT IN ('EDITING', 'LOADING') THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '仅编辑中或装柜中的计划允许新增明细';
  END IF;
  IF NEW.deleted <> 0 OR NEW.frozen_at IS NOT NULL OR NEW.frozen_by IS NOT NULL THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '新增装柜明细必须为未删除且未冻结状态';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_item_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_item_before_update
BEFORE UPDATE ON fl_loading_plan_item
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status
    FROM fl_loading_plan WHERE id = OLD.loading_plan_id;
  IF current_plan_status = 'LOADING' AND EXISTS (
      SELECT 1 FROM fl_loading_pick_item
       WHERE loading_plan_item_id = OLD.id AND picked_package_count > 0) THEN
    IF NOT (NEW.warehouse_remark <=> OLD.warehouse_remark) THEN
      IF NEW.package_count <> OLD.package_count OR NEW.deleted <> OLD.deleted
        OR NOT (NEW.customer_name <=> OLD.customer_name)
        OR NOT (NEW.inbound_id <=> OLD.inbound_id)
        OR NOT (NEW.inbound_detail_id <=> OLD.inbound_detail_id)
        OR NOT (NEW.order_id <=> OLD.order_id)
        OR NOT (NEW.order_no <=> OLD.order_no)
        OR NOT (NEW.inbound_code <=> OLD.inbound_code)
        OR NOT (NEW.destination_warehouse_id <=> OLD.destination_warehouse_id)
        OR NOT (NEW.destination_warehouse_code <=> OLD.destination_warehouse_code)
        OR NOT (NEW.destination_warehouse_name <=> OLD.destination_warehouse_name)
        OR NOT (NEW.sku_code <=> OLD.sku_code)
        OR NOT (NEW.product_name_zh <=> OLD.product_name_zh)
        OR NOT (NEW.product_name_en <=> OLD.product_name_en)
        OR NOT (NEW.product_image_file_id <=> OLD.product_image_file_id)
        OR NOT (NEW.product_image_url <=> OLD.product_image_url)
        OR NOT (NEW.product_quantity <=> OLD.product_quantity)
        OR NOT (NEW.units_per_carton <=> OLD.units_per_carton)
        OR NOT (NEW.pallet_count <=> OLD.pallet_count)
        OR NOT (NEW.gross_weight_kg <=> OLD.gross_weight_kg)
        OR NOT (NEW.net_weight_kg <=> OLD.net_weight_kg)
        OR NOT (NEW.dimensional_weight_kg <=> OLD.dimensional_weight_kg)
        OR NOT (NEW.volume_cbm <=> OLD.volume_cbm)
        OR NOT (NEW.fba_tracking_no <=> OLD.fba_tracking_no)
        OR NOT (NEW.shipment_no <=> OLD.shipment_no)
        OR NOT (NEW.shipping_mark <=> OLD.shipping_mark)
        OR NOT (NEW.load_sequence <=> OLD.load_sequence)
        OR NOT (NEW.position_snapshot <=> OLD.position_snapshot)
        OR NOT (NEW.internal_remark <=> OLD.internal_remark)
        OR NOT (NEW.customer_remark <=> OLD.customer_remark)
        OR NOT (NEW.frozen_at <=> OLD.frozen_at)
        OR NOT (NEW.frozen_by <=> OLD.frozen_by)
        OR NOT (NEW.removed_by <=> OLD.removed_by)
        OR NOT (NEW.removed_by_name <=> OLD.removed_by_name)
        OR NOT (NEW.removed_at <=> OLD.removed_at) THEN
        SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已有PDA拣货记录的装柜明细修改仓库备注时不得变更其他业务字段';
      END IF;
    ELSEIF NOT EXISTS (
        SELECT 1 FROM fl_loading_pick_item
         WHERE loading_plan_item_id = OLD.id
           AND item_status = 'PARTIAL'
           AND NEW.deleted = 0
           AND NEW.package_count = picked_package_count
    ) OR NEW.deleted <> OLD.deleted
      OR NOT (NEW.customer_name <=> OLD.customer_name)
      OR NOT (NEW.inbound_id <=> OLD.inbound_id)
      OR NOT (NEW.inbound_detail_id <=> OLD.inbound_detail_id)
      OR NOT (NEW.order_id <=> OLD.order_id)
      OR NOT (NEW.order_no <=> OLD.order_no)
      OR NOT (NEW.inbound_code <=> OLD.inbound_code)
      OR NOT (NEW.destination_warehouse_id <=> OLD.destination_warehouse_id)
      OR NOT (NEW.destination_warehouse_code <=> OLD.destination_warehouse_code)
      OR NOT (NEW.destination_warehouse_name <=> OLD.destination_warehouse_name)
      OR NOT (NEW.sku_code <=> OLD.sku_code)
      OR NOT (NEW.product_name_zh <=> OLD.product_name_zh)
      OR NOT (NEW.product_name_en <=> OLD.product_name_en)
      OR NOT (NEW.product_image_file_id <=> OLD.product_image_file_id)
      OR NOT (NEW.product_image_url <=> OLD.product_image_url)
      OR NOT (NEW.product_quantity <=> OLD.product_quantity)
      OR NOT (NEW.units_per_carton <=> OLD.units_per_carton)
      OR NOT (NEW.pallet_count <=> OLD.pallet_count)
      OR NOT (NEW.gross_weight_kg <=> OLD.gross_weight_kg)
      OR NOT (NEW.net_weight_kg <=> OLD.net_weight_kg)
      OR NOT (NEW.dimensional_weight_kg <=> OLD.dimensional_weight_kg)
      OR NOT (NEW.volume_cbm <=> OLD.volume_cbm)
      OR NOT (NEW.fba_tracking_no <=> OLD.fba_tracking_no)
      OR NOT (NEW.shipment_no <=> OLD.shipment_no)
      OR NOT (NEW.shipping_mark <=> OLD.shipping_mark)
      OR NOT (NEW.load_sequence <=> OLD.load_sequence)
      OR NOT (NEW.position_snapshot <=> OLD.position_snapshot)
      OR NOT (NEW.internal_remark <=> OLD.internal_remark)
      OR NOT (NEW.customer_remark <=> OLD.customer_remark)
      OR NOT (NEW.frozen_at <=> OLD.frozen_at)
      OR NOT (NEW.frozen_by <=> OLD.frozen_by)
      OR NOT (NEW.removed_by <=> OLD.removed_by)
      OR NOT (NEW.removed_by_name <=> OLD.removed_by_name)
      OR NOT (NEW.removed_at <=> OLD.removed_at) THEN
      SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已有PDA拣货记录的装柜明细仅允许收敛部分拣货实际箱数';
    END IF;
  END IF;
  IF OLD.frozen_at IS NOT NULL THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜完成后的明细永久冻结';
  END IF;
  IF OLD.deleted = 1 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已删除装柜明细不可恢复或修改';
  END IF;
  IF NEW.loading_plan_id <> OLD.loading_plan_id OR NEW.account_id <> OLD.account_id
     OR NEW.inbound_detail_id <> OLD.inbound_detail_id THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜明细归属键不可修改，请删除后重新分配';
  END IF;
  IF NEW.deleted = 1 THEN
    IF NEW.removed_by IS NULL THEN
      SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '删除装柜明细必须记录操作人';
    END IF;
    SET NEW.removed_at = COALESCE(NEW.removed_at, CURRENT_TIMESTAMP(3));
  ELSEIF NEW.removed_by IS NOT NULL OR NEW.removed_by_name IS NOT NULL OR NEW.removed_at IS NOT NULL THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '删除审计字段只能在逻辑删除时写入';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_pick_task_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_pick_task_before_update
BEFORE UPDATE ON fl_loading_pick_task
FOR EACH ROW
BEGIN
  IF OLD.task_status = 'COMPLETED' THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已完成PDA拣货任务不可修改';
  END IF;
  IF NEW.loading_plan_id <> OLD.loading_plan_id
     OR NOT (NEW.container_booking_id <=> OLD.container_booking_id)
     OR NOT (NEW.cabinet_no <=> OLD.cabinet_no) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'PDA拣货任务稳定归属不可修改';
  END IF;
  IF NOT (OLD.task_status = 'LOADING' AND NEW.task_status IN ('LOADING', 'COMPLETED')) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'PDA拣货任务状态只允许完成';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_pick_item_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_pick_item_before_update
BEFORE UPDATE ON fl_loading_pick_item
FOR EACH ROW
BEGIN
  DECLARE current_task_status VARCHAR(16);
  SELECT MAX(task_status) INTO current_task_status
    FROM fl_loading_pick_task WHERE id = OLD.pick_task_id;
  IF current_task_status = 'COMPLETED' THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜完成后PDA拣货明细不可修改';
  END IF;
  IF NEW.pick_task_id <> OLD.pick_task_id
     OR NEW.loading_plan_item_id <> OLD.loading_plan_item_id
     OR NEW.inbound_id <> OLD.inbound_id
     OR NEW.inbound_detail_id <> OLD.inbound_detail_id THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'PDA拣货明细归属不可修改';
  END IF;
  IF NEW.item_status = 'PARTIAL' AND NOT (
       OLD.item_status IN ('PENDING', 'PICKING')
       AND OLD.picked_package_count < NEW.picked_package_count
       AND NEW.picked_package_count < OLD.planned_package_count
       AND NEW.planned_package_count = OLD.planned_package_count
  ) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '部分拣货必须在计划箱数内增加实际拣出箱数';
  END IF;
  IF NEW.item_status = 'SKIPPED' AND NOT (
       OLD.item_status = 'PENDING'
       AND OLD.picked_package_count = 0
       AND NEW.picked_package_count = 0
       AND NEW.planned_package_count = OLD.planned_package_count
  ) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '跳拣仅允许零拣货的待拣明细';
  END IF;
  IF OLD.item_status = 'PARTIAL' AND NEW.item_status = 'PICKED' AND NOT (
       NEW.picked_package_count = OLD.picked_package_count
       AND NEW.planned_package_count = OLD.picked_package_count
  ) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '部分拣货收敛后计划箱数必须等于实际拣出箱数';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_pick_item_before_delete;
DELIMITER $$
CREATE TRIGGER trg_loading_pick_item_before_delete
BEFORE DELETE ON fl_loading_pick_item
FOR EACH ROW
BEGIN
  DECLARE current_task_status VARCHAR(16);
  SELECT MAX(task_status) INTO current_task_status
    FROM fl_loading_pick_task WHERE id = OLD.pick_task_id;
  IF current_task_status = 'COMPLETED' OR OLD.picked_package_count > 0 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '已拣货或已完成的PDA明细不可删除';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_pick_history_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_pick_history_before_update
BEFORE UPDATE ON fl_loading_pick_history
FOR EACH ROW
BEGIN
  SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'PDA拣货历史不可修改';
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_pick_history_before_delete;
DELIMITER $$
CREATE TRIGGER trg_loading_pick_history_before_delete
BEFORE DELETE ON fl_loading_pick_history
FOR EACH ROW
BEGIN
  SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'PDA拣货历史不可删除';
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_item_before_delete;
DELIMITER $$
CREATE TRIGGER trg_loading_item_before_delete
BEFORE DELETE ON fl_loading_plan_item
FOR EACH ROW
BEGIN
  SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜明细只允许推送前逻辑删除';
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_container_document_before_insert;
DELIMITER $$
CREATE TRIGGER trg_container_document_before_insert
BEFORE INSERT ON fl_container_document
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status FROM fl_loading_plan
   WHERE container_booking_id = NEW.container_booking_id;
  IF current_plan_status = 'COMPLETED'
     AND NEW.document_type NOT IN ('DESTINATION_CLEARANCE', 'CUSTOMS_DECLARATION') THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜完成后货柜文件不可新增';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_container_document_before_update;
DELIMITER $$
CREATE TRIGGER trg_container_document_before_update
BEFORE UPDATE ON fl_container_document
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status FROM fl_loading_plan
   WHERE container_booking_id = OLD.container_booking_id;
  IF current_plan_status = 'COMPLETED'
     AND OLD.document_type NOT IN ('DESTINATION_CLEARANCE', 'CUSTOMS_DECLARATION') THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜完成后货柜文件不可修改';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_container_document_before_delete;
DELIMITER $$
CREATE TRIGGER trg_container_document_before_delete
BEFORE DELETE ON fl_container_document
FOR EACH ROW
BEGIN
  DECLARE current_plan_status VARCHAR(24);
  SELECT MAX(plan_status) INTO current_plan_status FROM fl_loading_plan
   WHERE container_booking_id = OLD.container_booking_id;
  IF current_plan_status = 'COMPLETED' THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜完成后货柜文件不可删除';
  END IF;
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_history_before_update;
DELIMITER $$
CREATE TRIGGER trg_loading_history_before_update
BEFORE UPDATE ON fl_loading_plan_history
FOR EACH ROW
BEGIN
  SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜操作历史不可修改';
END$$
DELIMITER ;

DROP TRIGGER IF EXISTS trg_loading_history_before_delete;
DELIMITER $$
CREATE TRIGGER trg_loading_history_before_delete
BEFORE DELETE ON fl_loading_plan_history
FOR EACH ROW
BEGIN
  SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '装柜操作历史不可删除';
END$$
DELIMITER ;

-- 三期智能装柜、预装清单和装柜清单平台权限；与一期平台根菜单幂等合并。
USE baiyue_iam;
DROP PROCEDURE IF EXISTS relocate_legacy_inbound_loading_permissions;
DELIMITER $$
CREATE PROCEDURE relocate_legacy_inbound_loading_permissions()
BEGIN
  DECLARE legacy_count INT DEFAULT 0;
  IF EXISTS (
    SELECT 1 FROM iam_permission
     WHERE id IN (5102091, 5102092, 5102093, 5102094, 5102096, 5102097, 5102098, 5102099)
       AND permission_code NOT IN (
         'platform:firstleg:container:view', 'platform:firstleg:container:create',
         'platform:firstleg:container:edit', 'platform:firstleg:smart-loading:list',
         'platform:firstleg:smart-loading:create', 'platform:firstleg:smart-loading:assign',
         'platform:firstleg:smart-loading:delete', 'platform:firstleg:smart-loading:push',
         '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'
       )
  ) THEN
    SIGNAL SQLSTATE '45000'
      SET MESSAGE_TEXT = '三期权限迁移失败：5102091-5102099 存在未知权限占用';
  END IF;
  SELECT COUNT(*) INTO legacy_count
    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'
     );
  IF legacy_count > 0 THEN
    IF EXISTS (
      SELECT 1 FROM iam_permission
       WHERE id BETWEEN 5102121 AND 5102129
         AND permission_code <> CASE id
           WHEN 5102121 THEN 'firstleg:inbound:split'
           WHEN 5102122 THEN 'firstleg:inbound:preload'
           WHEN 5102123 THEN 'firstleg:inbound:preload-view'
           WHEN 5102124 THEN 'platform:firstleg:inbound:loading:edit'
           WHEN 5102125 THEN 'platform:firstleg:inbound:loading:view'
           WHEN 5102126 THEN 'platform:firstleg:inbound:loading:complete'
           WHEN 5102127 THEN 'platform:firstleg:inbound:delivery:complete'
           WHEN 5102128 THEN 'platform:firstleg:inbound:picking:edit'
           WHEN 5102129 THEN 'platform:firstleg:inbound:picking:view'
         END
    ) THEN
      SIGNAL SQLSTATE '45000'
        SET MESSAGE_TEXT = '三期权限迁移失败：5102121-5102129 已被其他权限占用';
    END IF;
    DROP TEMPORARY TABLE IF EXISTS tmp_phase3_inbound_role_grant;
    CREATE TEMPORARY TABLE tmp_phase3_inbound_role_grant (
      role_id BIGINT UNSIGNED NOT NULL,
      tenant_id BIGINT UNSIGNED NOT NULL,
      permission_code VARCHAR(128) NOT NULL,
      PRIMARY KEY (role_id, tenant_id, permission_code)
    ) ENGINE=MEMORY;
    INSERT IGNORE INTO tmp_phase3_inbound_role_grant (role_id, tenant_id, permission_code)
    SELECT role_permission.role_id, role_permission.tenant_id, permission.permission_code
      FROM iam_role_permission role_permission
      JOIN iam_permission permission ON permission.id = role_permission.permission_id
     WHERE permission.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'
     );
    DELETE role_permission FROM iam_role_permission role_permission
    JOIN iam_permission permission ON permission.id = role_permission.permission_id
     WHERE permission.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'
     );
    DELETE FROM iam_permission WHERE 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'
    );
    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
      (5102121, 0, 'PLATFORM', 'BUTTON', 5102030, 'firstleg:inbound:split', '智能分柜', NULL, NULL, 140, 'ACTIVE', 1, 0),
      (5102122, 0, 'PLATFORM', 'BUTTON', 5102030, 'firstleg:inbound:preload', '编辑并确认预装清单', NULL, NULL, 150, 'ACTIVE', 1, 0),
      (5102123, 0, 'PLATFORM', 'BUTTON', 5102030, 'firstleg:inbound:preload-view', '查看预装清单', NULL, NULL, 160, 'ACTIVE', 1, 0),
      (5102124, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:loading:edit', '维护装柜证据', NULL, NULL, 170, 'ACTIVE', 1, 0),
      (5102125, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:loading:view', '查看装柜证据', NULL, NULL, 180, 'ACTIVE', 1, 0),
      (5102126, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:loading:complete', '完成装柜', NULL, NULL, 190, 'ACTIVE', 1, 0),
      (5102127, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:delivery:complete', '完成派送', NULL, NULL, 200, 'ACTIVE', 1, 0),
      (5102128, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:picking:edit', '执行拣货', NULL, NULL, 210, 'ACTIVE', 1, 0),
      (5102129, 0, 'PLATFORM', 'BUTTON', 5102030, 'platform:firstleg:inbound:picking:view', '查看拣货任务', NULL, NULL, 220, 'ACTIVE', 1, 0);
    INSERT IGNORE INTO iam_role_permission (role_id, permission_id, tenant_id)
    SELECT grant_row.role_id, permission.id, grant_row.tenant_id
      FROM tmp_phase3_inbound_role_grant grant_row
      JOIN iam_permission permission ON permission.permission_code = grant_row.permission_code
       AND permission.tenant_id = 0 AND permission.app_code = 'PLATFORM';
    DROP TEMPORARY TABLE tmp_phase3_inbound_role_grant;
  END IF;
END$$
DELIMITER ;
CALL relocate_legacy_inbound_loading_permissions();
DROP PROCEDURE relocate_legacy_inbound_loading_permissions;

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
  (5102090, 0, 'PLATFORM', 'MENU', 5102000, 'platform:firstleg:container:list',
   '货柜', '/first-leg/containers', 'GET', 40, 'ACTIVE', 1, 0),
  (5102091, 0, 'PLATFORM', 'BUTTON', 5102090, 'platform:firstleg:container:view',
   '查看货柜', NULL, 'GET', 10, 'ACTIVE', 1, 0),
  (5102092, 0, 'PLATFORM', 'BUTTON', 5102090, 'platform:firstleg:container:create',
   '建立货柜', NULL, 'POST', 20, 'ACTIVE', 1, 0),
  (5102093, 0, 'PLATFORM', 'BUTTON', 5102090, 'platform:firstleg:container:edit',
   '编辑货柜', NULL, 'PUT', 30, 'ACTIVE', 1, 0),
  (5102094, 0, 'PLATFORM', 'MENU', 5102000, 'platform:firstleg:smart-loading:list',
   '智能装柜', '/first-leg/smart-loading', 'GET', 50, 'ACTIVE', 1, 0),
  (5102096, 0, 'PLATFORM', 'BUTTON', 5102094, 'platform:firstleg:smart-loading:create',
   '创建智能装柜计划', NULL, 'POST', 20, 'ACTIVE', 1, 0),
  (5102097, 0, 'PLATFORM', 'BUTTON', 5102094, 'platform:firstleg:smart-loading:assign',
   '分配装柜明细', NULL, 'POST', 30, 'ACTIVE', 1, 0),
  (5102098, 0, 'PLATFORM', 'BUTTON', 5102094, 'platform:firstleg:smart-loading:delete',
   '删除装柜明细', NULL, 'DELETE', 40, 'ACTIVE', 1, 0),
  (5102099, 0, 'PLATFORM', 'BUTTON', 5102094, 'platform:firstleg:smart-loading:push',
   '推送预装', NULL, 'POST', 50, 'ACTIVE', 1, 0),
  (5102100, 0, 'PLATFORM', 'MENU', 5102000, 'platform:firstleg:preload:list',
   '预装清单', '/first-leg/preload-list', 'GET', 60, 'ACTIVE', 1, 0),
  (5102102, 0, 'PLATFORM', 'BUTTON', 5102100, 'platform:firstleg:preload:view',
   '查看预装详情', NULL, 'GET', 20, 'ACTIVE', 1, 0),
  (5102103, 0, 'PLATFORM', 'BUTTON', 5102100, 'platform:firstleg:preload:edit',
   '编辑预装运输字段', NULL, 'PUT', 30, 'ACTIVE', 1, 0),
  (5102104, 0, 'PLATFORM', 'BUTTON', 5102100, 'platform:firstleg:preload:complete',
   '完成预装', NULL, 'POST', 40, 'ACTIVE', 1, 0),
  (5102105, 0, 'PLATFORM', 'BUTTON', 5102100, 'platform:firstleg:preload:confirm',
   '确认预装', NULL, 'POST', 50, 'ACTIVE', 1, 0),
  (5102106, 0, 'PLATFORM', 'MENU', 5102000, 'platform:firstleg:loading-list:list',
   '装柜清单', '/first-leg/loading-list', 'GET', 70, 'ACTIVE', 1, 0),
  (5102108, 0, 'PLATFORM', 'BUTTON', 5102106, 'platform:firstleg:loading-list:view',
   '查看装柜详情', NULL, 'GET', 20, '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 IGNORE INTO iam_role_permission (role_id, permission_id, tenant_id)
SELECT role.id, permission.id, role.tenant_id
FROM iam_role role
 JOIN iam_permission permission
  ON permission.tenant_id = 0
 AND permission.permission_code IN (
   'platform:firstleg:container:list', 'platform:firstleg:container:view',
   'platform:firstleg:container:create',
   'platform:firstleg:container:edit', 'platform:firstleg:smart-loading:list',
   'platform:firstleg:smart-loading:create', 'platform:firstleg:smart-loading:assign',
   'platform:firstleg:smart-loading:delete', 'platform:firstleg:smart-loading:push',
   'platform:firstleg:preload:list', 'platform:firstleg:preload:view',
   'platform:firstleg:preload:edit', 'platform:firstleg:preload:complete',
   'platform:firstleg:preload:confirm', 'platform:firstleg:loading-list:list',
   'platform:firstleg:loading-list:view')
WHERE role.tenant_id = 0
  AND role.role_code IN ('PLATFORM_ADMIN', 'ORDER_OPERATOR');

USE baiyue_firstleg;

DROP PROCEDURE IF EXISTS assert_phase3_smart_loading_schema;

DELETE rp FROM baiyue_iam.iam_role_permission rp
JOIN baiyue_iam.iam_permission p ON p.tenant_id=rp.tenant_id AND p.id=rp.permission_id
WHERE p.permission_code IN ('platform:firstleg:container:view','platform:firstleg:preload:view','platform:firstleg:loading-list:view');
UPDATE baiyue_iam.iam_permission SET status='INACTIVE',deleted=1
WHERE permission_code IN ('platform:firstleg:container:view','platform:firstleg:preload:view','platform:firstleg:loading-list:view');
DELIMITER $$
CREATE PROCEDURE assert_phase3_smart_loading_schema()
BEGIN
  IF (SELECT COUNT(*) FROM information_schema.tables
       WHERE table_schema = 'baiyue_firstleg'
         AND table_name IN ('fl_container_booking', 'fl_loading_plan', 'fl_loading_plan_item',
                            'fl_container_document', 'fl_loading_plan_history',
                            'fl_loading_pick_task', 'fl_loading_pick_item',
                            'fl_loading_pick_history')) <> 8 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：核心表未完整创建';
  END IF;
  IF EXISTS (SELECT 1 FROM fl_loading_plan
              WHERE plan_status NOT IN ('EDITING', 'LOADING', 'COMPLETED')) THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：存在旧装柜状态';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.check_constraints
       WHERE constraint_schema = 'baiyue_firstleg'
         AND constraint_name = 'chk_loading_plan_status'
         AND UPPER(check_clause) LIKE '%EDITING%'
         AND UPPER(check_clause) LIKE '%LOADING%'
         AND UPPER(check_clause) LIKE '%COMPLETED%') <> 1 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_container_booking'
         AND column_name IN ('booking_no', 'cabinet_no', 'warehouse_id', 'bill_of_lading_no',
                             'vessel_name', 'voyage_no', 'container_type', 'capacity_cbm',
                             'max_weight_kg', 'terminal_trucking_company_id', 'terminal_trucking_company')) <> 11 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_loading_plan_item'
         AND column_name IN ('account_id', 'customer_name', 'active_inbound_detail_id', 'frozen_at',
                             'destination_warehouse_name', 'product_name_zh', 'product_name_en',
                             'product_image_file_id', 'pallet_count', 'net_weight_kg',
                             'dimensional_weight_kg', 'product_quantity', 'units_per_carton',
                             'fba_tracking_no', 'shipment_no', 'shipping_mark', 'version')) <> 17 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：明细归属、清单快照或冻结字段缺失';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.statistics
       WHERE table_schema = 'baiyue_firstleg' AND table_name = 'fl_loading_plan_item'
         AND index_name = 'uk_loading_item_plan_detail' AND non_unique = 0) <> 2 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_loading_pick_item'
         AND column_name IN ('pick_task_id', 'loading_plan_item_id', 'inbound_id',
                             'inbound_detail_id', 'planned_package_count',
                             'picked_package_count', 'item_status', 'version')) <> 8 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：PDA拣货明细字段缺失';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.statistics
       WHERE table_schema = 'baiyue_firstleg' AND non_unique = 0
         AND index_name IN ('uk_loading_pick_task_plan',
                            'uk_loading_pick_item_plan_item',
                            'uk_loading_pick_history_operation')) <> 3 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：PDA唯一索引缺失';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.key_column_usage
       WHERE constraint_schema = 'baiyue_firstleg'
         AND table_name = 'fl_loading_pick_item'
         AND column_name = 'pick_task_id'
         AND referenced_table_name IS NOT NULL) <> 1
     OR (SELECT COUNT(*) FROM information_schema.key_column_usage outer_fk
          WHERE outer_fk.constraint_schema = 'baiyue_firstleg'
            AND outer_fk.table_name = 'fl_loading_pick_item'
            AND outer_fk.column_name = 'pick_task_id'
            AND outer_fk.referenced_table_name = 'fl_loading_pick_task'
            AND outer_fk.referenced_column_name = 'id'
            AND (SELECT COUNT(*) FROM information_schema.key_column_usage peer
                  WHERE peer.constraint_schema = outer_fk.constraint_schema
                    AND peer.table_name = outer_fk.table_name
                    AND peer.constraint_name = outer_fk.constraint_name) = 1) <> 1 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：柜次PDA明细任务外键不唯一或指向错误';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.key_column_usage
       WHERE constraint_schema = 'baiyue_firstleg'
         AND table_name = 'fl_loading_pick_history'
         AND column_name = 'pick_task_id'
         AND referenced_table_name IS NOT NULL) <> 1
     OR (SELECT COUNT(*) FROM information_schema.key_column_usage outer_fk
          WHERE outer_fk.constraint_schema = 'baiyue_firstleg'
            AND outer_fk.table_name = 'fl_loading_pick_history'
            AND outer_fk.column_name = 'pick_task_id'
            AND outer_fk.referenced_table_name = 'fl_loading_pick_task'
            AND outer_fk.referenced_column_name = 'id'
            AND (SELECT COUNT(*) FROM information_schema.key_column_usage peer
                  WHERE peer.constraint_schema = outer_fk.constraint_schema
                    AND peer.table_name = outer_fk.table_name
                    AND peer.constraint_name = outer_fk.constraint_name) = 1) <> 1 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：柜次PDA历史任务外键不唯一或指向错误';
  END IF;
  IF (SELECT COUNT(*) FROM information_schema.triggers
       WHERE trigger_schema = 'baiyue_firstleg'
         AND trigger_name IN ('trg_container_booking_before_update',
                              'trg_loading_plan_before_update', 'trg_loading_plan_after_update',
                              'trg_loading_item_before_insert', 'trg_loading_item_before_update',
                              'trg_loading_item_before_delete', 'trg_container_document_before_insert',
                              'trg_container_document_before_update', 'trg_container_document_before_delete',
                              'trg_loading_history_before_update', 'trg_loading_history_before_delete',
                              'trg_loading_pick_task_before_update',
                              'trg_loading_pick_item_before_update',
                              'trg_loading_pick_item_before_delete',
                              'trg_loading_pick_history_before_update',
                              'trg_loading_pick_history_before_delete')) <> 16 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 (
           'platform:firstleg:container:list', 'platform:firstleg:container:view',
           'platform:firstleg:container:create', 'platform:firstleg:container:edit',
           'platform:firstleg:smart-loading:list', 'platform:firstleg:smart-loading:create',
           'platform:firstleg:smart-loading:assign', 'platform:firstleg:smart-loading:delete',
           'platform:firstleg:smart-loading:push', 'platform:firstleg:preload:list',
           'platform:firstleg:preload:view', 'platform:firstleg:preload:edit',
           'platform:firstleg:preload:complete', 'platform:firstleg:preload:confirm',
           'platform:firstleg:loading-list:list', 'platform:firstleg:loading-list:view')) <> 16 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：平台权限资源未完整创建';
  END IF;
  IF (SELECT COUNT(DISTINCT CONCAT(role.role_code, ':', permission.permission_code))
        FROM baiyue_iam.iam_role role
        JOIN baiyue_iam.iam_role_permission grant_row ON grant_row.role_id = role.id
        JOIN baiyue_iam.iam_permission permission ON permission.id = grant_row.permission_id
       WHERE role.tenant_id = 0 AND role.role_code IN ('PLATFORM_ADMIN', 'ORDER_OPERATOR')
         AND permission.tenant_id = 0
         AND permission.permission_code IN (
           'platform:firstleg:container:list', 'platform:firstleg:container:view',
           'platform:firstleg:container:create',
           'platform:firstleg:container:edit', 'platform:firstleg:smart-loading:list',
           'platform:firstleg:smart-loading:create', 'platform:firstleg:smart-loading:assign',
           'platform:firstleg:smart-loading:delete', 'platform:firstleg:smart-loading:push',
           'platform:firstleg:preload:list', 'platform:firstleg:preload:view',
           'platform:firstleg:preload:edit', 'platform:firstleg:preload:complete',
           'platform:firstleg:preload:confirm', 'platform:firstleg:loading-list:list',
           'platform:firstleg:loading-list:view')) <> 32 THEN
    SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '智能装柜迁移失败：平台角色授权未完整写入';
  END IF;
END$$
DELIMITER ;
CALL assert_phase3_smart_loading_schema();
DROP PROCEDURE IF EXISTS assert_phase3_smart_loading_schema;