order_site/docs/寄卖系统迁移079上库前检查.sql

-- 迁移 079 上库前 / 上库后检查脚本（只读，可直接在生产库执行）
--
-- 迁移文件：apps/backend/src/db/migrations/079_drop_consignment_collect_links.sql
-- 已在全新空库验证：001 → 079 可一次性跑通（79 条迁移全部记录在 schema_migrations）。
-- 生产库上库前请先跑完「上库前」四段检查。

-- ============================ 上库前 ============================

-- 1. 同一张工单被多件现货同时绑定？
--    会让唯一索引 uniq_consignment_inventories_bound_work_order 创建失败。
--    迁移自带清理（保留工单 material 里记录的那一件，其余解绑回库），
--    但有数据时请先确认"保留哪一件"与工单 material.consignment.inventoryId 一致。
--    期望：0 行。
SELECT
  ci.bound_work_order_id,
  COUNT(*) AS bound_rows,
  ARRAY_AGG(ci.id ORDER BY ci.id) AS inventory_ids,
  MAX(NULLIF(wo.material_json -> 'consignment' ->> 'inventoryId', '')) AS material_inventory_id
FROM consignment_inventories ci
JOIN work_orders wo ON wo.id = ci.bound_work_order_id
WHERE ci.bound_work_order_id IS NOT NULL
  AND ci.status = 'consumed'
GROUP BY ci.bound_work_order_id
HAVING COUNT(*) > 1;

-- 2. 同一提报单重复冻结了发布押金？
--    会让唯一索引 uniq_worker_wallet_ledgers_consignment_publish_freeze 创建失败。
--    期望：0 行。注意 079 自身会先去重再建索引——每组（打手+提报单）保留最早一条冻结流水，
--    多余行改 payload 标记 kind=consignment_publish_superseded（移出押金口径与索引范围，
--    原行留审计）并按 LEAST(多冻总额, 冻结池实有) 退还押金、写 consignment_publish_dedup_refund
--    修正流水。所以有行也能建起索引；但若该提报单的押金此前已被释放/没收过，
--    自动退款会重复退（见 2.1），必须先人工确认。
SELECT
  payload_json ->> 'consignmentSubmissionId' AS submission_id,
  COUNT(*) AS freeze_rows,
  SUM(ABS(amount)) AS frozen_fen
FROM worker_wallet_ledgers
WHERE ledger_type = 'deposit_freeze'
  AND payload_json ->> 'kind' = 'consignment_publish'
GROUP BY 1
HAVING COUNT(*) > 1;

-- 2.1（只读）重复退款风险：同提报单有多条冻结流水，且该提报单的押金已经被释放/没收过。
--     判据：already_settled_fen > 0 时，079 的自动退款会把「已经退过的钱」再退一次——
--     钱从同一打手其它提报单的冻结额里出，之后那张单释放/没收会因为
--     frozen < outstanding 抛 consignment_deposit_balance_inconsistent（接口 500）。
--     命中就必须先人工处理，不要直接上库。safe_refund_should_be_fen = 应当退还的金额。
--     期望：0 行。
WITH fr AS (
  SELECT worker_id, payload_json ->> 'consignmentSubmissionId' AS sub, id, ABS(amount) AS amt
  FROM worker_wallet_ledgers
  WHERE ledger_type = 'deposit_freeze'
    AND COALESCE(payload_json ->> 'kind', '') = 'consignment_publish'
    AND COALESCE(payload_json ->> 'consignmentSubmissionId', '') <> ''
),
g AS (
  SELECT
    worker_id,
    sub,
    COUNT(*) AS freeze_rows,
    SUM(amt) AS freeze_total_fen,
    (ARRAY_AGG(amt ORDER BY id ASC))[1] AS kept_fen
  FROM fr
  GROUP BY 1, 2
),
s AS (
  SELECT
    worker_id,
    payload_json ->> 'consignmentSubmissionId' AS sub,
    COALESCE(SUM(CASE WHEN ledger_type IN ('deposit_release', 'deposit_deduction')
                      THEN ABS(amount) ELSE 0 END), 0) AS settled_fen
  FROM worker_wallet_ledgers
  WHERE COALESCE(payload_json ->> 'kind', '') = 'consignment_publish'
    AND COALESCE(payload_json ->> 'consignmentSubmissionId', '') <> ''
  GROUP BY 1, 2
)
SELECT
  g.worker_id,
  g.sub AS submission_id,
  g.freeze_rows,
  g.freeze_total_fen - g.kept_fen AS dup_fen,
  COALESCE(s.settled_fen, 0) AS already_settled_fen,
  COALESCE(w.frozen_deposit_amount, 0) AS wallet_frozen_fen,
  LEAST(g.freeze_total_fen - g.kept_fen, COALESCE(w.frozen_deposit_amount, 0))
    AS migration_will_refund_fen,
  GREATEST(0, (g.freeze_total_fen - COALESCE(s.settled_fen, 0)) - g.kept_fen)
    AS safe_refund_should_be_fen
FROM g
LEFT JOIN s ON s.worker_id = g.worker_id AND s.sub = g.sub
LEFT JOIN worker_wallets w ON w.worker_id = g.worker_id
WHERE g.freeze_rows > 1
  AND COALESCE(s.settled_fen, 0) > 0
ORDER BY 1, 2;

-- 3. 待删除对象的影响面（收集链接渠道下线）。
--    用 DO 块 + 动态 SQL，保证"表/列已被删掉"时脚本也能跑（否则会直接报错中断）。
DO $$
DECLARE
  n bigint;
BEGIN
  IF to_regclass('public.consignment_collect_links') IS NOT NULL THEN
    EXECUTE 'SELECT COUNT(*) FROM consignment_collect_links' INTO n;
    RAISE NOTICE '[3.1] 收集链接表仍存在，共 % 行；删除后不可恢复', n;
  ELSE
    RAISE NOTICE '[3.1] 收集链接表不存在（079 已执行或从未创建）';
  END IF;

  IF EXISTS (
    SELECT 1 FROM information_schema.columns
    WHERE table_name = 'consignment_submissions' AND column_name = 'link_id'
  ) THEN
    EXECUTE 'SELECT COUNT(*) FROM consignment_submissions WHERE link_id IS NOT NULL' INTO n;
    RAISE NOTICE '[3.2] 提报单 link_id 仍存在，共 % 行有引用；删除后不可恢复', n;
  ELSE
    RAISE NOTICE '[3.2] 提报单 link_id 不存在（079 已执行或从未创建）';
  END IF;
END
$$;

-- 3.3 来源枚举分布（迁移会把 collection_link 归并为 worker_portal）
SELECT source_type, COUNT(*) FROM consignment_inventories GROUP BY source_type ORDER BY 1;

-- 4. 历史遗留的"已出库但无工单绑定"现货（079 之前 worker_deposit 占库不写绑定）
--    这些行不会随撤单自动解绑，需要运营在寄卖仓库手动【退回复库】。
SELECT COUNT(*) AS legacy_consumed_without_binding
FROM consignment_inventories
WHERE status = 'consumed' AND bound_work_order_id IS NULL;

-- ============================ 上库后 ============================

-- 5. 结构校验：新列 / 新索引 / 枚举约束是否就位
SELECT
  EXISTS (
    SELECT 1 FROM information_schema.columns
    WHERE table_name = 'consignment_inventories' AND column_name = 'assigned_worker_id'
  ) AS has_assigned_worker_id,
  EXISTS (
    SELECT 1 FROM pg_indexes WHERE indexname = 'uniq_consignment_inventories_bound_work_order'
  ) AS has_bound_work_order_unique,
  EXISTS (
    SELECT 1 FROM pg_indexes
    WHERE indexname = 'uniq_worker_wallet_ledgers_consignment_publish_freeze'
  ) AS has_ledger_freeze_unique,
  EXISTS (
    SELECT 1 FROM information_schema.tables WHERE table_name = 'consignment_collect_links'
  ) AS collect_links_table_still_exists,
  EXISTS (
    SELECT 1 FROM information_schema.columns
    WHERE table_name = 'consignment_submissions' AND column_name = 'link_id'
  ) AS submissions_link_id_still_exists;

SELECT pg_get_constraintdef(oid) AS source_type_check
FROM pg_constraint
WHERE conname = 'consignment_inventories_source_type_check';

-- 6. 绑定一致性总览（上库后运营巡检用）
SELECT
  ci.id,
  ci.inventory_no,
  ci.status,
  ci.bound_work_order_id,
  wo.status AS work_order_status,
  ci.allocation_status,
  ci.assigned_worker_id,
  ci.worker_id AS seller_worker_id
FROM consignment_inventories ci
LEFT JOIN work_orders wo ON wo.id = ci.bound_work_order_id
WHERE ci.status = 'consumed'
ORDER BY ci.updated_at DESC
LIMIT 50;

-- 7. 发布押金挂账巡检：台账未释放金额是否超过钱包冻结额（按打手）
WITH ledger AS (
  SELECT
    worker_id,
    COALESCE(SUM(CASE WHEN ledger_type = 'deposit_freeze' THEN ABS(amount) ELSE 0 END), 0)
      - COALESCE(SUM(CASE WHEN ledger_type = 'deposit_release' THEN ABS(amount) ELSE 0 END), 0)
      - COALESCE(SUM(CASE WHEN ledger_type = 'deposit_deduction' THEN ABS(amount) ELSE 0 END), 0)
      AS outstanding_fen
  FROM worker_wallet_ledgers
  WHERE payload_json ->> 'kind' = 'consignment_publish'
  GROUP BY worker_id
)
SELECT
  l.worker_id,
  l.outstanding_fen,
  w.frozen_deposit_amount AS wallet_frozen_fen
FROM ledger l
JOIN worker_wallets w ON w.worker_id = l.worker_id
WHERE l.outstanding_fen > 0
  AND l.outstanding_fen > w.frozen_deposit_amount;