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

SET NAMES utf8mb4;
USE baiyue_firstleg;

/* 装柜证据、PDA 拣货复核和派送完成。五类证据按有效记录计数，同类型允许多图追加；作废记录保留审计。 */
CREATE TABLE IF NOT EXISTS fl_loading_evidence (
  id BIGINT UNSIGNED NOT NULL COMMENT '装柜证据记录ID',
  tenant_id BIGINT UNSIGNED NOT NULL COMMENT '客户ID和数据隔离键',
  inbound_id BIGINT UNSIGNED NOT NULL COMMENT '关联入库单逻辑ID',
  evidence_type VARCHAR(32) NOT NULL COMMENT 'PHOTO_STEP_1空仓/PHOTO_STEP_2半仓/PHOTO_STEP_3满仓/PHOTO_STEP_4锁仓/SEAL带锁码照',
  file_id BIGINT UNSIGNED NOT NULL COMMENT 'File 服务逻辑文件ID',
  file_name VARCHAR(255) NULL COMMENT '上传时文件名称快照',
  seal_no VARCHAR(64) NULL COMMENT '锁码文本；带锁码照必填，客户不可见',
  remark VARCHAR(1000) NULL COMMENT '证据补充说明',
  status VARCHAR(16) NOT NULL DEFAULT 'ACTIVE' COMMENT '证据状态：ACTIVE有效、VOID已作废；错误照片保留记录不硬删除',
  void_reason VARCHAR(500) NULL COMMENT '照片作废原因',
  voided_by BIGINT UNSIGNED NULL COMMENT '执行作废的平台操作人ID',
  voided_by_name VARCHAR(64) NULL COMMENT '执行作废的平台操作人姓名快照',
  voided_at DATETIME(3) NULL COMMENT '照片作废时间',
  version INT NOT NULL DEFAULT 0 COMMENT '乐观锁版本号，每次更新递增',
  created_by BIGINT UNSIGNED NOT NULL COMMENT '上传证据的操作人ID',
  created_by_name VARCHAR(64) NULL COMMENT '上传证据的操作人姓名快照',
  updated_by BIGINT UNSIGNED NOT NULL COMMENT '最后修改操作人ID',
  updated_by_name VARCHAR(64) 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 '证据记录最后更新时间',
  PRIMARY KEY (id),
  KEY idx_loading_evidence_type (tenant_id, inbound_id, evidence_type, status),
  KEY idx_loading_evidence_seal (tenant_id, seal_no, status),
  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='订单装柜空仓/半仓/满仓/锁仓/带锁码照证据';

/* Repeatable migration for installations that already created the single-slot table. */
DROP PROCEDURE IF EXISTS phase3_loading_add_column;
DELIMITER $$
CREATE PROCEDURE phase3_loading_add_column(IN p_column VARCHAR(64), IN p_definition VARCHAR(512))
BEGIN
  IF NOT EXISTS (
    SELECT 1 FROM information_schema.columns
    WHERE table_schema=DATABASE() AND table_name='fl_loading_evidence' AND column_name=p_column
  ) THEN
    SET @phase3_loading_ddl = CONCAT('ALTER TABLE fl_loading_evidence ADD COLUMN `', p_column, '` ', p_definition);
    PREPARE phase3_loading_stmt FROM @phase3_loading_ddl;
    EXECUTE phase3_loading_stmt;
    DEALLOCATE PREPARE phase3_loading_stmt;
  END IF;
END$$
DELIMITER ;
CALL phase3_loading_add_column('status', 'VARCHAR(16) NOT NULL DEFAULT ''ACTIVE'' COMMENT ''证据状态：ACTIVE有效、VOID已作废；错误照片保留记录不硬删除''');
CALL phase3_loading_add_column('void_reason', 'VARCHAR(500) NULL COMMENT ''照片作废原因''');
CALL phase3_loading_add_column('voided_by', 'BIGINT UNSIGNED NULL COMMENT ''执行作废的平台操作人ID''');
CALL phase3_loading_add_column('voided_by_name', 'VARCHAR(64) NULL COMMENT ''执行作废的平台操作人姓名快照''');
CALL phase3_loading_add_column('voided_at', 'DATETIME(3) NULL COMMENT ''照片作废时间''');
DROP PROCEDURE IF EXISTS phase3_loading_add_column;

SET @phase3_loading_has_legacy_type_index = (
  SELECT COUNT(*) FROM information_schema.statistics
  WHERE table_schema=DATABASE() AND table_name='fl_loading_evidence' AND index_name='uk_loading_evidence_type'
);
SET @phase3_loading_drop_legacy_type_index = IF(@phase3_loading_has_legacy_type_index > 0,
  'ALTER TABLE fl_loading_evidence DROP INDEX uk_loading_evidence_type', 'SELECT 1');
PREPARE phase3_loading_drop_stmt FROM @phase3_loading_drop_legacy_type_index;
EXECUTE phase3_loading_drop_stmt;
DEALLOCATE PREPARE phase3_loading_drop_stmt;

SET @phase3_loading_has_type_index = (
  SELECT COUNT(*) FROM information_schema.statistics
  WHERE table_schema=DATABASE() AND table_name='fl_loading_evidence' AND index_name='idx_loading_evidence_type'
);
SET @phase3_loading_add_type_index = IF(@phase3_loading_has_type_index = 0,
  'ALTER TABLE fl_loading_evidence ADD KEY idx_loading_evidence_type (tenant_id, inbound_id, evidence_type, status)', 'SELECT 1');
PREPARE phase3_loading_type_stmt FROM @phase3_loading_add_type_index;
EXECUTE phase3_loading_type_stmt;
DEALLOCATE PREPARE phase3_loading_type_stmt;

SET @phase3_loading_has_legacy_seal_index = (
  SELECT COUNT(*) FROM information_schema.statistics
  WHERE table_schema=DATABASE() AND table_name='fl_loading_evidence' AND index_name='uk_loading_evidence_seal'
);
SET @phase3_loading_drop_legacy_seal_index = IF(@phase3_loading_has_legacy_seal_index > 0,
  'ALTER TABLE fl_loading_evidence DROP INDEX uk_loading_evidence_seal', 'SELECT 1');
PREPARE phase3_loading_drop_seal_stmt FROM @phase3_loading_drop_legacy_seal_index;
EXECUTE phase3_loading_drop_seal_stmt;
DEALLOCATE PREPARE phase3_loading_drop_seal_stmt;

SET @phase3_loading_has_seal_index = (
  SELECT COUNT(*) FROM information_schema.statistics
  WHERE table_schema=DATABASE() AND table_name='fl_loading_evidence' AND index_name='idx_loading_evidence_seal'
);
SET @phase3_loading_add_seal_index = IF(@phase3_loading_has_seal_index = 0,
  'ALTER TABLE fl_loading_evidence ADD KEY idx_loading_evidence_seal (tenant_id, seal_no, status)', 'SELECT 1');
PREPARE phase3_loading_seal_stmt FROM @phase3_loading_add_seal_index;
EXECUTE phase3_loading_seal_stmt;
DEALLOCATE PREPARE phase3_loading_seal_stmt;

CREATE TABLE IF NOT EXISTS fl_loading_operation (
  id BIGINT UNSIGNED NOT NULL COMMENT '装柜写操作记录ID',
  tenant_id BIGINT UNSIGNED NOT NULL COMMENT '客户ID和数据隔离键',
  inbound_id BIGINT UNSIGNED NOT NULL COMMENT '操作目标入库单逻辑ID',
  operator_id BIGINT UNSIGNED NOT NULL COMMENT '执行写操作的平台用户ID',
  operation VARCHAR(48) NOT NULL COMMENT '装柜或证据写操作类型',
  idempotency_key VARCHAR(128) NOT NULL COMMENT '客户端幂等键，同一操作重试复用',
  request_hash CHAR(64) NOT NULL COMMENT '规范化请求内容SHA-256摘要',
  status VARCHAR(16) NOT NULL DEFAULT 'PROCESSING' COMMENT '幂等处理状态：PROCESSING处理中、SUCCESS成功、FAILED失败',
  result_json JSON NULL COMMENT '成功结果或失败信息JSON快照，用于幂等重放',
  created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '操作声明创建时间',
  completed_at DATETIME(3) NULL COMMENT '操作完成时间',
  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_inbound_loading_pick_task (
  id BIGINT UNSIGNED NOT NULL COMMENT '入库单级PDA拣货任务ID',
  tenant_id BIGINT UNSIGNED NOT NULL COMMENT '客户ID和数据隔离键',
  inbound_id BIGINT UNSIGNED NOT NULL COMMENT '关联入库单逻辑ID',
  status VARCHAR(24) NOT NULL DEFAULT 'PENDING' COMMENT '任务状态：PENDING待拣货、IN_PROGRESS拣货中、COMPLETED已完成',
  version INT NOT NULL DEFAULT 0 COMMENT '乐观锁版本号，每次更新递增',
  expected_count INT UNSIGNED NULL COMMENT '计划应拣箱数',
  picked_count INT UNSIGNED NULL COMMENT '实际已拣箱数',
  remark VARCHAR(1000) NULL COMMENT '拣货结果或异常补充说明',
  updated_by BIGINT UNSIGNED NOT NULL COMMENT '最后操作人ID',
  updated_by_name VARCHAR(64) NULL 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_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拣货任务及结果';