-- 充电桩订单「所属公司 / 所属车队」历史数据回填脚本（仅白名单订单）
|
-- 前置：已执行 20260929_charging_order_company_fleet.sql（两列已存在）
|
-- 数据来源：charging_pile_account.t_app_user_whitelist（含 company_id / fleet_id / del_flag / status），
|
-- 订单侧 whitelist_id 为建单时白名单记录 ID 快照，直接按 id 关联，无需经手机号中转。
|
-- 范围：仅回填 is_whitelist = 1 的白名单用户充电订单；非白名单订单无归属来源，两列保持 NULL。
|
-- 执行方式：MyCat 不支持跨逻辑库 UPDATE JOIN，故分三步人工执行：
|
-- 步骤1 在 charging_pile_account 生成 UPDATE 语句（单库只读查询）；
|
-- 步骤2 把步骤1 结果集逐行复制到 charging_pile_order 执行（whitelist_id 非分片键，语句广播到各分片，无匹配分片零影响）；
|
-- 步骤3 回查校验。
|
-- 语义与幂等：
|
-- * 仅回填 company_id IS NULL 的历史订单行，不覆盖上线后新建订单的建单时快照；
|
-- * 同一白名单用户重复执行结果一致（写入白名单当前归属）；
|
-- * 白名单未分配公司且未分配车队时不生成语句，其历史订单两列保持 NULL。
|
|
-- ============ 步骤 0：前置检查（charging_pile_account，只读） ============
|
USE `charging_pile_account`;
|
|
SELECT COUNT(1) AS assignable_whitelist_count
|
FROM `t_app_user_whitelist`
|
WHERE `del_flag` = 0 AND `status` = 1 AND (`company_id` IS NOT NULL OR `fleet_id` IS NOT NULL);
|
|
SELECT COUNT(1) AS unassigned_whitelist_count
|
FROM `t_app_user_whitelist`
|
WHERE `del_flag` = 0 AND `status` = 1 AND `company_id` IS NULL AND `fleet_id` IS NULL;
|
|
-- ============ 步骤 1：生成回填语句（charging_pile_account，只读） ============
|
-- 复制结果集 backfill_sql 列全部内容，粘贴到 charging_pile_order 逐行执行
|
SELECT CONCAT('UPDATE `t_charging_order` SET `company_id` = ', IFNULL(w.`company_id`, 'NULL'),
|
', `fleet_id` = ', IFNULL(w.`fleet_id`, 'NULL'),
|
' WHERE `whitelist_id` = ', w.`id`, ' AND `is_whitelist` = 1 AND `company_id` IS NULL;') AS backfill_sql
|
FROM `t_app_user_whitelist` w
|
WHERE w.`del_flag` = 0
|
AND w.`status` = 1
|
AND (w.`company_id` IS NOT NULL OR w.`fleet_id` IS NOT NULL)
|
ORDER BY w.`id`;
|
|
-- ============ 步骤 2：在 charging_pile_order 执行步骤1 生成的语句 ============
|
-- 示例（白名单记录 id = 1 归属公司 12、车队 3）：
|
-- USE `charging_pile_order`;
|
-- UPDATE `t_charging_order` SET `company_id` = 12, `fleet_id` = 3 WHERE `whitelist_id` = 1 AND `is_whitelist` = 1 AND `company_id` IS NULL;
|
|
-- ============ 步骤 3：回查校验（charging_pile_order） ============
|
USE `charging_pile_order`;
|
|
-- 白名单订单盘点：总数 / 已回填公司 / 已回填车队 / 两者皆空
|
SELECT COUNT(1) AS whitelist_order_total,
|
SUM(CASE WHEN `company_id` IS NOT NULL THEN 1 ELSE 0 END) AS company_filled,
|
SUM(CASE WHEN `fleet_id` IS NOT NULL THEN 1 ELSE 0 END) AS fleet_filled,
|
SUM(CASE WHEN `company_id` IS NULL AND `fleet_id` IS NULL THEN 1 ELSE 0 END) AS unassigned
|
FROM `t_charging_order`
|
WHERE `is_whitelist` = 1;
|
|
-- 以下跨逻辑库比对请【直连后端 MySQL 实例】执行（代理不支持跨库 JOIN）：
|
-- 归属公司与白名单用户不一致的订单（回填后应为 0；上线后白名单改归属导致新建订单不同属预期）
|
-- SELECT COUNT(1) AS snapshot_diff_count
|
-- FROM `charging_pile_order`.`t_charging_order` o
|
-- JOIN `charging_pile_account`.`t_app_user_whitelist` w ON w.`id` = o.`whitelist_id`
|
-- WHERE o.`del_flag` = 0
|
-- AND o.`is_whitelist` = 1
|
-- AND o.`company_id` IS NOT NULL
|
-- AND w.`company_id` <> o.`company_id`;
|
