-- 企业优惠快照改造（order库）：三张订单表新增「企业优惠方式/折扣率/计费模板」快照列
-- 目的：
--   企业账户（白名单/企业卡/VIN）订单建单时把当时生效的公司优惠设置固化到订单快照列；
--   结算与补偿重算时优先读订单快照（快照为空的历史订单才实时查询并回填），保证：
--     1) 建单后公司优惠设置变更（换折扣率/换模板）不影响历史订单的结算金额与对账口径；
--     2) 方式3（按优惠单价收费）的计费模板被修改/删除时，补偿重算与首次结算口径一致，不降级为原价。
-- 新增列（允许 NULL，历史订单走「实时查询 + 回填」兼容路径）：
--   preferential_type           企业优惠方式快照（1=不优惠，2=按比例优惠，3=按优惠单价收费）
--   service_discount_rate       服务费优惠比例快照（%，方式2使用）
--   billing_template_id         计费模板ID快照（方式3使用）
--   billing_template_snapshot   计费模板明细快照JSON（方式3使用，抵抗模板后续变更/删除）
--   preferential_snapshot_time  优惠快照固化时间
-- 创建日期: 2026-09-30
-- 目标库：charging_pile_order
--   分片表：t_charging_order、t_vin_charging_order、t_card_charging_order（Mycat 逻辑表，物理分表逐片执行）
-- 执行方式：
--   1) 首选「小节 A」经数据库代理（MyCat 8066）执行，代理会把 DDL 广播到全部物理分表；
--   2) 代理不支持分片表 DDL 时，改用「小节 B」直连后端 MySQL 实例执行（存储过程，逐物理分表，幂等）；
--   3) 最后执行「小节 C」回查校验。
-- 幂等说明：小节 A 为裸 ALTER，重复执行会报 Duplicate column，忽略即可（以小节 C 回查为准）；
--           小节 B 先查 information_schema 再变更，可重复执行。

-- ============ 小节 A：经代理执行（推荐） ============
USE `charging_pile_order`;

ALTER TABLE `t_charging_order`
  ADD COLUMN `preferential_type` tinyint(4) DEFAULT NULL COMMENT '企业优惠方式快照（1=不优惠，2=按比例优惠，3=按优惠单价收费；NULL=建单时未固化）',
  ADD COLUMN `service_discount_rate` decimal(5,2) DEFAULT NULL COMMENT '服务费优惠比例快照（%，方式2使用）',
  ADD COLUMN `billing_template_id` int(11) DEFAULT NULL COMMENT '计费模板ID快照（方式3使用）',
  ADD COLUMN `billing_template_snapshot` text COMMENT '计费模板明细快照JSON（方式3使用，抵抗模板后续变更/删除）',
  ADD COLUMN `preferential_snapshot_time` datetime DEFAULT NULL COMMENT '优惠快照固化时间';

ALTER TABLE `t_vin_charging_order`
  ADD COLUMN `preferential_type` tinyint(4) DEFAULT NULL COMMENT '企业优惠方式快照（1=不优惠，2=按比例优惠，3=按优惠单价收费；NULL=建单时未固化）',
  ADD COLUMN `service_discount_rate` decimal(5,2) DEFAULT NULL COMMENT '服务费优惠比例快照（%，方式2使用）',
  ADD COLUMN `billing_template_id` int(11) DEFAULT NULL COMMENT '计费模板ID快照（方式3使用）',
  ADD COLUMN `billing_template_snapshot` text COMMENT '计费模板明细快照JSON（方式3使用，抵抗模板后续变更/删除）',
  ADD COLUMN `preferential_snapshot_time` datetime DEFAULT NULL COMMENT '优惠快照固化时间';

ALTER TABLE `t_card_charging_order`
  ADD COLUMN `preferential_type` tinyint(4) DEFAULT NULL COMMENT '企业优惠方式快照（1=不优惠，2=按比例优惠，3=按优惠单价收费；NULL=建单时未固化）',
  ADD COLUMN `service_discount_rate` decimal(5,2) DEFAULT NULL COMMENT '服务费优惠比例快照（%，方式2使用）',
  ADD COLUMN `billing_template_id` int(11) DEFAULT NULL COMMENT '计费模板ID快照（方式3使用）',
  ADD COLUMN `billing_template_snapshot` text COMMENT '计费模板明细快照JSON（方式3使用，抵抗模板后续变更/删除）',
  ADD COLUMN `preferential_snapshot_time` datetime DEFAULT NULL COMMENT '优惠快照固化时间';

-- ============ 小节 B：直连后端 MySQL 实例执行（代理不可用时分表执行，幂等） ============
USE `charging_pile_order`;

DROP PROCEDURE IF EXISTS `add_company_preferential_snapshot`;
DELIMITER $$
CREATE PROCEDURE `add_company_preferential_snapshot`()
BEGIN
    DECLARE done INT DEFAULT 0;
    DECLARE target_table VARCHAR(64);
    DECLARE column_exists INT DEFAULT 0;

    -- 覆盖逻辑表（若物理存在）与 TBPARTITION 物理分表
    DECLARE table_cursor CURSOR FOR
        SELECT t.table_name
        FROM information_schema.tables t
        WHERE t.table_schema = DATABASE()
          AND t.table_name REGEXP '^t_charging_order(_[0-9]+)?$|^t_vin_charging_order(_[0-9]+)?$|^t_card_charging_order(_[0-9]+)?$';

    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;

    OPEN table_cursor;
    table_loop: LOOP
        FETCH table_cursor INTO target_table;
        IF done = 1 THEN
            LEAVE table_loop;
        END IF;

        SELECT COUNT(*) INTO column_exists
        FROM information_schema.columns
        WHERE table_schema = DATABASE()
          AND table_name = target_table
          AND column_name = 'preferential_type';
        IF column_exists = 0 THEN
            SET @ddl = CONCAT('ALTER TABLE `', target_table, '` ADD COLUMN `preferential_type` tinyint(4) DEFAULT NULL COMMENT ''企业优惠方式快照（1=不优惠，2=按比例优惠，3=按优惠单价收费；NULL=建单时未固化）''');
            PREPARE stmt FROM @ddl;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;

        SELECT COUNT(*) INTO column_exists
        FROM information_schema.columns
        WHERE table_schema = DATABASE()
          AND table_name = target_table
          AND column_name = 'service_discount_rate';
        IF column_exists = 0 THEN
            SET @ddl = CONCAT('ALTER TABLE `', target_table, '` ADD COLUMN `service_discount_rate` decimal(5,2) DEFAULT NULL COMMENT ''服务费优惠比例快照（%，方式2使用）''');
            PREPARE stmt FROM @ddl;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;

        SELECT COUNT(*) INTO column_exists
        FROM information_schema.columns
        WHERE table_schema = DATABASE()
          AND table_name = target_table
          AND column_name = 'billing_template_id';
        IF column_exists = 0 THEN
            SET @ddl = CONCAT('ALTER TABLE `', target_table, '` ADD COLUMN `billing_template_id` int(11) DEFAULT NULL COMMENT ''计费模板ID快照（方式3使用）''');
            PREPARE stmt FROM @ddl;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;

        SELECT COUNT(*) INTO column_exists
        FROM information_schema.columns
        WHERE table_schema = DATABASE()
          AND table_name = target_table
          AND column_name = 'billing_template_snapshot';
        IF column_exists = 0 THEN
            SET @ddl = CONCAT('ALTER TABLE `', target_table, '` ADD COLUMN `billing_template_snapshot` text COMMENT ''计费模板明细快照JSON（方式3使用，抵抗模板后续变更/删除）''');
            PREPARE stmt FROM @ddl;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;

        SELECT COUNT(*) INTO column_exists
        FROM information_schema.columns
        WHERE table_schema = DATABASE()
          AND table_name = target_table
          AND column_name = 'preferential_snapshot_time';
        IF column_exists = 0 THEN
            SET @ddl = CONCAT('ALTER TABLE `', target_table, '` ADD COLUMN `preferential_snapshot_time` datetime DEFAULT NULL COMMENT ''优惠快照固化时间''');
            PREPARE stmt FROM @ddl;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;
    END LOOP;
    CLOSE table_cursor;
END$$
DELIMITER ;

CALL `add_company_preferential_snapshot`();
DROP PROCEDURE IF EXISTS `add_company_preferential_snapshot`;

-- ============ 小节 C：回查校验 ============
-- 1) 列存在性与注释（三张订单表均应覆盖逻辑表与全部物理分表）：
--    SELECT table_name, column_name, column_type, column_comment
--    FROM information_schema.columns
--    WHERE table_schema = 'charging_pile_order'
--      AND column_name IN ('preferential_type', 'service_discount_rate', 'billing_template_id',
--                          'billing_template_snapshot', 'preferential_snapshot_time')
--    ORDER BY table_name, column_name;
--    预期：三张订单表及各自物理分表均存在 5 列，column_comment 中文无乱码
-- 2) 历史订单快照为空（走实时查询 + 回填兼容路径）：
--    SELECT COUNT(*) FROM t_charging_order WHERE preferential_type IS NULL;
--    预期：等于存量订单数