AiDOPWarehouse/server/Admin.NET.Web.Entry/UpdateScripts/1.0.508.sql

-- =====================================================================================
-- 1.0.508  ·  S0 MASTER DATA PLATFORM · PHASE 2 · C2 参考字典（8 个 ref_*）
--
-- C2-1 独立字典（各自 staging）：
--   BarCodeType           → mdp_stg_s0_label_type        → ref_label_type
--   ImageType             → mdp_stg_s0_sop_file_type     → ref_sop_file_type
--   qms_quality_base_type → mdp_stg_s0_quality_base_type → ref_quality_base_type
-- C2-2 qms 字典族（**共用 mdp_stg_s0_qms_dict**，靠 source_table 隔离，同 Location/LocationShelf 范式）：
--   qms_sampscheme / qms_inspectionitems / qms_inspection_method
--   qms_inspectionfreq / qms_inspectioninstru → ref_*
--
-- 身份口径（沿用 D-025）：一律 tenant_id + 业务码；Domain/company/factory 均 LEGACY_SCOPE，不入唯一键。
--
-- 🔴 本组落地时实测出的两个框架地雷（写在这里免得下次重踩）：
--   ① bit(1) 源列若用 Int，对账每轮必挂：CAST(b'1' AS CHAR)=0x01 而 CAST(1 AS CHAR)=0x31。
--      PriorityCode.OrderBy 正是 bit(1) —— 故 PriorityCode 整表本批缓做。
--   ② qms 的 FSTATUS/FENABLE 是 varchar，值域含 `已审核`/`已启用`/`A`/`ENABLED`/`INVALID_STATUS`。
--      用 BoolTrue 会命中可辨识性守卫：4 张表整表归零；qms_inspectionfreq.FENABLE 恰好存活 8/13
--      —— 部分静默丢失，最难发现。⇒ 10 个状态列一律 Str 原样透传。
--
-- 边界：不动源表、不动 S0 CRUD、不动前端、不碰 mdp_std_*、不复用任何 DOPDEMORQ staging。
-- =====================================================================================

-- ── 一、贴源表（4 张；UK 含 source_system，D-022 的结构性防串源前提）──

CREATE TABLE IF NOT EXISTS `mdp_stg_s0_label_type` (
  `id`              bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`       bigint       NOT NULL DEFAULT 0,
  `factory_id`      bigint       DEFAULT NULL,
  `source_system`   varchar(50)  NOT NULL DEFAULT 'AIDOPDEV_MYSQL',
  `source_table`    varchar(100) NOT NULL,
  `source_row_id`   varchar(100) NOT NULL,
  `source_biz_key`  varchar(300) DEFAULT NULL,
  `sync_batch_id`   varchar(100) NOT NULL,
  `sync_time`       datetime     NOT NULL,
  `process_status`  varchar(20)  NOT NULL DEFAULT 'PENDING',
  `raw_data`        json         NOT NULL,
  `process_message` varchar(500) DEFAULT NULL,
  `update_time`     datetime     DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  `create_time`     datetime     DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_stg_s0_label_type` (`tenant_id`,`source_system`,`source_table`,`source_row_id`),
  KEY `idx_stg_s0_label_type_biz` (`source_biz_key`),
  KEY `idx_stg_s0_label_type_batch` (`tenant_id`,`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 贴源：标签类型（源 BarCodeType）';

CREATE TABLE IF NOT EXISTS `mdp_stg_s0_sop_file_type` (
  `id`              bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`       bigint       NOT NULL DEFAULT 0,
  `factory_id`      bigint       DEFAULT NULL,
  `source_system`   varchar(50)  NOT NULL DEFAULT 'AIDOPDEV_MYSQL',
  `source_table`    varchar(100) NOT NULL,
  `source_row_id`   varchar(100) NOT NULL,
  `source_biz_key`  varchar(300) DEFAULT NULL,
  `sync_batch_id`   varchar(100) NOT NULL,
  `sync_time`       datetime     NOT NULL,
  `process_status`  varchar(20)  NOT NULL DEFAULT 'PENDING',
  `raw_data`        json         NOT NULL,
  `process_message` varchar(500) DEFAULT NULL,
  `update_time`     datetime     DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  `create_time`     datetime     DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_stg_s0_sop_file_type` (`tenant_id`,`source_system`,`source_table`,`source_row_id`),
  KEY `idx_stg_s0_sop_file_type_biz` (`source_biz_key`),
  KEY `idx_stg_s0_sop_file_type_batch` (`tenant_id`,`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 贴源：SOP 文件类型（源 ImageType）';

CREATE TABLE IF NOT EXISTS `mdp_stg_s0_quality_base_type` (
  `id`              bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`       bigint       NOT NULL DEFAULT 0,
  `factory_id`      bigint       DEFAULT NULL,
  `source_system`   varchar(50)  NOT NULL DEFAULT 'AIDOPDEV_MYSQL',
  `source_table`    varchar(100) NOT NULL,
  `source_row_id`   varchar(100) NOT NULL,
  `source_biz_key`  varchar(300) DEFAULT NULL,
  `sync_batch_id`   varchar(100) NOT NULL,
  `sync_time`       datetime     NOT NULL,
  `process_status`  varchar(20)  NOT NULL DEFAULT 'PENDING',
  `raw_data`        json         NOT NULL,
  `process_message` varchar(500) DEFAULT NULL,
  `update_time`     datetime     DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  `create_time`     datetime     DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_stg_s0_quality_base_type` (`tenant_id`,`source_system`,`source_table`,`source_row_id`),
  KEY `idx_stg_s0_quality_base_type_biz` (`source_biz_key`),
  KEY `idx_stg_s0_quality_base_type_batch` (`tenant_id`,`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 贴源：质量基础类型（源 qms_quality_base_type）';

CREATE TABLE IF NOT EXISTS `mdp_stg_s0_qms_dict` (
  `id`              bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`       bigint       NOT NULL DEFAULT 0,
  `factory_id`      bigint       DEFAULT NULL,
  `source_system`   varchar(50)  NOT NULL DEFAULT 'AIDOPDEV_MYSQL',
  `source_table`    varchar(100) NOT NULL,
  `source_row_id`   varchar(100) NOT NULL,
  `source_biz_key`  varchar(300) DEFAULT NULL,
  `sync_batch_id`   varchar(100) NOT NULL,
  `sync_time`       datetime     NOT NULL,
  `process_status`  varchar(20)  NOT NULL DEFAULT 'PENDING',
  `raw_data`        json         NOT NULL,
  `process_message` varchar(500) DEFAULT NULL,
  `update_time`     datetime     DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  `create_time`     datetime     DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_stg_s0_qms_dict` (`tenant_id`,`source_system`,`source_table`,`source_row_id`),
  KEY `idx_stg_s0_qms_dict_biz` (`source_biz_key`),
  KEY `idx_stg_s0_qms_dict_batch` (`tenant_id`,`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 贴源：qms 字典族（5 个源表共用，靠 source_table 隔离）';

-- ── 二、参考表（8 张）──

CREATE TABLE IF NOT EXISTS `ref_label_type` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `label_type_code`   varchar(100) NOT NULL COMMENT '标签类型码（**唯一业务键**）← $.bar_type',
  `label_class`       varchar(50) DEFAULT NULL COMMENT '← $.class',
  `input_string`      varchar(1000) DEFAULT NULL COMMENT '← $.input_string',
  `domain_code`       varchar(50) DEFAULT NULL COMMENT 'LEGACY_SCOPE ← $.domain_code；**不是身份**',
  `company_id`        bigint      DEFAULT NULL COMMENT 'LEGACY_SCOPE ← $.company_ref_id',
  `factory_id`        bigint      DEFAULT NULL COMMENT 'LEGACY_SCOPE ← $.factory_ref_id',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.update_time',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_label_type` (`tenant_id`,`label_type_code`),
  KEY `idx_ref_label_type_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：标签类型。源 BarCodeType，FULL REPLACE。';

CREATE TABLE IF NOT EXISTS `ref_sop_file_type` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `file_type_code`    varchar(100) NOT NULL COMMENT 'SOP 文件类型码（**唯一业务键**）← $.image_type_id',
  `file_type_name`    varchar(255) DEFAULT NULL COMMENT '← $.descr',
  `domain_code`       varchar(50) DEFAULT NULL COMMENT 'LEGACY_SCOPE ← $.domain（注意源物理列叫 domain）',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_sop_file_type` (`tenant_id`,`file_type_code`),
  KEY `idx_ref_sop_file_type_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：SOP 文件类型。源 ImageType。**源表无任何时间列，故无 source_updated_at，不得回填**。';

CREATE TABLE IF NOT EXISTS `ref_quality_base_type` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `type_category`     varchar(100) NOT NULL COMMENT '类别（**业务键第一段**）← $.type_category',
  `type_code`         varchar(100) NOT NULL COMMENT '编码（**业务键第二段**）← $.type_code',
  `short_name`        varchar(200) DEFAULT NULL COMMENT '← $.short_name',
  `full_name`         varchar(255) DEFAULT NULL COMMENT '← $.full_name',
  `remark`            varchar(500) DEFAULT NULL COMMENT '← $.remark',
  `is_active`         tinyint(1)  NOT NULL COMMENT '← $.is_active',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.modify_time',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_quality_base_type` (`tenant_id`,`type_category`,`type_code`),
  KEY `idx_ref_quality_base_type_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：质量基础类型。源 qms_quality_base_type。键为两段（CRUD 查重即按 category+code）。';

CREATE TABLE IF NOT EXISTS `ref_sampling_scheme` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `scheme_code`       varchar(255) NOT NULL COMMENT '抽样方案码（**唯一业务键**）← $.FNUMBER',
  `scheme_name`       varchar(255) DEFAULT NULL COMMENT '← $.FNAME',
  `sampling_type`     varchar(255) DEFAULT NULL COMMENT '← $.FSAMPLINGTYPE',
  `inspection_level`  varchar(255) DEFAULT NULL COMMENT '← $.FINSPECTIONLEVEL',
  `strictness`        varchar(255) DEFAULT NULL COMMENT '← $.FSTRICTNESS',
  `aql_value`         varchar(255) DEFAULT NULL COMMENT '← $.FAQLVALUE（源为 varchar，保持 Str）',
  `inspection_type`   varchar(255) DEFAULT NULL COMMENT '← $.FINSPECTIONTYPE',
  `status_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FSTATUS；值域含中文，禁 BoolTrue',
  `enable_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FENABLE；同上',
  `remark`            varchar(255) DEFAULT NULL COMMENT '← $.FCOMMENT',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.FMODIFYTIME',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_sampling_scheme` (`tenant_id`,`scheme_code`),
  KEY `idx_ref_sampling_scheme_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：抽样方案。源 qms_sampscheme。';

CREATE TABLE IF NOT EXISTS `ref_inspection_item` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `item_code`         varchar(255) NOT NULL COMMENT '检验项目码（**唯一业务键**）← $.FNUMBER',
  `item_name`         varchar(255) DEFAULT NULL COMMENT '← $.FNAME',
  `check_method_id`   bigint      DEFAULT NULL COMMENT '← $.FCHECKMETHOD；**源侧代理主键 id，非业务键**，不可用于 dim 解析',
  `check_basis_id`    bigint      DEFAULT NULL COMMENT '← $.FCHECKBASIS；同上',
  `status_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FSTATUS',
  `enable_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FENABLE',
  `remark`            varchar(255) DEFAULT NULL COMMENT '← $.FCOMMENT',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.FMODIFYTIME',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_inspection_item` (`tenant_id`,`item_code`),
  KEY `idx_ref_inspection_item_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：检验项目。源 qms_inspectionitems。';

CREATE TABLE IF NOT EXISTS `ref_inspection_method` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `method_code`       varchar(255) NOT NULL COMMENT '检验方法码（**唯一业务键**）← $.FNUMBER',
  `method_name`       varchar(255) DEFAULT NULL COMMENT '← $.FNAME',
  `control_strategy`  varchar(255) DEFAULT NULL COMMENT '← $.FCTRLSTRATEGY',
  `status_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FSTATUS',
  `enable_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FENABLE',
  `remark`            varchar(255) DEFAULT NULL COMMENT '← $.FCOMMENT',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.FMODIFYTIME',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_inspection_method` (`tenant_id`,`method_code`),
  KEY `idx_ref_inspection_method_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：检验方法。源 qms_inspection_method。';

CREATE TABLE IF NOT EXISTS `ref_inspection_frequency` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `frequency_code`    varchar(255) NOT NULL COMMENT '检验频次码（**唯一业务键**）← $.FNUMBER',
  `frequency_name`    varchar(255) DEFAULT NULL COMMENT '← $.FNAME',
  `remark`            varchar(255) DEFAULT NULL COMMENT '🔴 ← $.FREMARK（本表叫 FREMARK，**不是** FCOMMENT）',
  `status_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FSTATUS；值域 A/ENABLED',
  `enable_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FENABLE；值域 1/ENABLED —— BoolTrue 会存活 8 丢 5，最阴',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.FMODIFYTIME',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_inspection_frequency` (`tenant_id`,`frequency_code`),
  KEY `idx_ref_inspection_frequency_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：检验频次。源 qms_inspectionfreq。';

CREATE TABLE IF NOT EXISTS `ref_inspection_instrument` (
  `id`                bigint       NOT NULL AUTO_INCREMENT,
  `tenant_id`         bigint       NOT NULL,
  `instrument_code`   varchar(255) NOT NULL COMMENT '量检具码（**唯一业务键**）← $.FNUMBER',
  `instrument_name`   varchar(255) DEFAULT NULL COMMENT '← $.FNAME',
  `model`             varchar(255) DEFAULT NULL COMMENT '← $.FMODEL',
  `specification`     varchar(255) DEFAULT NULL COMMENT '← $.FSPECIFICATION',
  `manufacturer`      varchar(255) DEFAULT NULL COMMENT '← $.FMANUFACTURER',
  `gauge_category`    varchar(255) DEFAULT NULL COMMENT '← $.gauge_category（源自有 snake_case 列）',
  `calibration_cycle_days` int         DEFAULT NULL COMMENT '← $.calibration_cycle_days',
  `next_calibration_date` varchar(50) DEFAULT NULL COMMENT '← $.next_calibration_date；源是 varchar 存日期串，**Str 透传不用 DateTimeSec**',
  `status_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FSTATUS',
  `enable_code`       varchar(255) DEFAULT NULL COMMENT '🔴 Str 透传 ← $.FENABLE',
  `remark`            varchar(255) DEFAULT NULL COMMENT '← $.FCOMMENT',
  `source_updated_at` datetime    DEFAULT NULL COMMENT '← $.FMODIFYTIME',
  `source_system`     varchar(50)  NOT NULL,
  `source_biz_key`    varchar(300) NOT NULL,
  `sync_batch_id`     varchar(64)  NOT NULL,
  `sync_time`         datetime     NOT NULL,
  `create_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `update_time`       datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_ref_inspection_instrument` (`tenant_id`,`instrument_code`),
  KEY `idx_ref_inspection_instrument_batch` (`sync_batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S0 参考字典：量检具。源 qms_inspectioninstru。';

-- ── 三、mdp_entity 入站配置（8 条，全 FULL / incr_column=NULL）──
-- biz_key_expr 必须与 Definition.SourceBizKeyColumns 逐字一致，否则 AssertEntityContractAsync 当场报漂移。

SET @src_id = (SELECT `id` FROM `mdp_source` WHERE `source_code` = 'AIDOPDEV_MYSQL' LIMIT 1);

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_LABEL_TYPE', 'S0 标签类型字典入站', 'TABLE',
       'BarCodeType', 'mdp_stg_s0_label_type', 'FULL', NULL, 5000,
       'bar_type', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_LABEL_TYPE');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_SOP_FILE_TYPE', 'S0 SOP 文件类型字典入站', 'TABLE',
       'ImageType', 'mdp_stg_s0_sop_file_type', 'FULL', NULL, 5000,
       'image_type_id', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_SOP_FILE_TYPE');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_QUALITY_BASE_TYPE', 'S0 质量基础类型字典入站', 'TABLE',
       'qms_quality_base_type', 'mdp_stg_s0_quality_base_type', 'FULL', NULL, 5000,
       'type_category,type_code', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_QUALITY_BASE_TYPE');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_SAMPLING_SCHEME', 'S0 抽样方案字典入站', 'TABLE',
       'qms_sampscheme', 'mdp_stg_s0_qms_dict', 'FULL', NULL, 5000,
       'FNUMBER', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_SAMPLING_SCHEME');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_INSPECTION_ITEM', 'S0 检验项目字典入站', 'TABLE',
       'qms_inspectionitems', 'mdp_stg_s0_qms_dict', 'FULL', NULL, 5000,
       'FNUMBER', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_INSPECTION_ITEM');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_INSPECTION_METHOD', 'S0 检验方法字典入站', 'TABLE',
       'qms_inspection_method', 'mdp_stg_s0_qms_dict', 'FULL', NULL, 5000,
       'FNUMBER', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_INSPECTION_METHOD');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_INSPECTION_FREQUENCY', 'S0 检验频次字典入站', 'TABLE',
       'qms_inspectionfreq', 'mdp_stg_s0_qms_dict', 'FULL', NULL, 5000,
       'FNUMBER', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_INSPECTION_FREQUENCY');

INSERT INTO `mdp_entity`
  (`tenant_id`,`source_id`,`entity_code`,`entity_name`,`entity_type`,
   `source_table_name`,`target_table_name`,`sync_mode`,`incr_column`,`batch_size`,
   `biz_key_expr`,`status`,`create_time`,`update_time`)
SELECT 0, @src_id, 'S0_INSPECTION_INSTRUMENT', 'S0 量检具字典入站', 'TABLE',
       'qms_inspectioninstru', 'mdp_stg_s0_qms_dict', 'FULL', NULL, 5000,
       'FNUMBER', 1, NOW(), NOW()
WHERE @src_id IS NOT NULL
  AND NOT EXISTS (SELECT 1 FROM `mdp_entity` WHERE `entity_code` = 'S0_INSPECTION_INSTRUMENT');

-- ── 回滚（注释，非可执行）──
-- DROP TABLE IF EXISTS `ref_inspection_instrument`,`ref_inspection_frequency`,`ref_inspection_method`,
--   `ref_inspection_item`,`ref_sampling_scheme`,`ref_quality_base_type`,`ref_sop_file_type`,`ref_label_type`;
-- DROP TABLE IF EXISTS `mdp_stg_s0_qms_dict`,`mdp_stg_s0_quality_base_type`,
--   `mdp_stg_s0_sop_file_type`,`mdp_stg_s0_label_type`;
-- DELETE FROM `mdp_entity` WHERE `tenant_id`=0 AND `entity_code` IN
--   ('S0_LABEL_TYPE','S0_SOP_FILE_TYPE','S0_QUALITY_BASE_TYPE','S0_SAMPLING_SCHEME',
--    'S0_INSPECTION_ITEM','S0_INSPECTION_METHOD','S0_INSPECTION_FREQUENCY','S0_INSPECTION_INSTRUMENT');