-- 编号让位（2026-09-17）：本文件原为 V149，与远端已推送的 V149__clear_service_hero_placeholders 撞号，本地让号改为 V152。
-- 支付尝试按「这一次尝试」收敛所需要的两列（判定见 docs/adr/0003）。
--
-- last_reconciled_at  对账任务的公平轮转与退避依据。旧实现按「最早 100 条」取未决流水，一旦积压
--                     超过上限，最新出现的那笔（也就是用户刚卡住的那笔）永远轮不到——而死锁唯一
--                     的自愈通道就是对账。改为「空值优先、升序、带退避」之后每笔都会轮到。
-- close_attempts      关单重试计数。关单回执说「处理中」时支付尝试落在 CLOSING，后台每分钟重试
--                     一次；到上限就不再重试（保留 CANCEL_UNCONFIRMED 盯防与问题记录），避免一条
--                     坏数据让后台永远重试同一笔。
--
-- 这两列必须同样落到开发库：开发库（局域网共享的 talent_card）Flyway 是关闭的、结构不由迁移维护，
-- 所以另有 scripts/dev-schema-v149-payment-attempt.sql（可手工执行的等价 DDL）与
-- scripts/apply-dev-schema.ps1（本机没有 mysql 客户端，用项目已有的 JDBC 驱动执行）。
--
-- 用存储过程按 exists 判断逐列追加，使脚本可以重复执行（本地开发的库常常手工加过列）。
DROP PROCEDURE IF EXISTS add_payment_attempt_convergence_columns;
DELIMITER //
CREATE PROCEDURE add_payment_attempt_convergence_columns()
BEGIN
    IF NOT EXISTS (SELECT 1 FROM information_schema.columns
                   WHERE table_schema = DATABASE() AND table_name = 'payment_transaction'
                     AND column_name = 'last_reconciled_at') THEN
        ALTER TABLE payment_transaction
            ADD COLUMN last_reconciled_at DATETIME DEFAULT NULL COMMENT '最近一次对账处理时间（公平轮转与退避依据）';
    END IF;
    IF NOT EXISTS (SELECT 1 FROM information_schema.columns
                   WHERE table_schema = DATABASE() AND table_name = 'payment_transaction'
                     AND column_name = 'close_attempts') THEN
        ALTER TABLE payment_transaction
            ADD COLUMN close_attempts INT NOT NULL DEFAULT 0 COMMENT '已发出的关单请求次数（重试上限依据）';
    END IF;
    IF NOT EXISTS (SELECT 1 FROM information_schema.statistics
                   WHERE table_schema = DATABASE() AND table_name = 'payment_transaction'
                     AND index_name = 'idx_payment_transaction_reconcile') THEN
        CREATE INDEX idx_payment_transaction_reconcile
            ON payment_transaction (status, last_reconciled_at);
    END IF;
END //
DELIMITER ;
CALL add_payment_attempt_convergence_columns();
DROP PROCEDURE add_payment_attempt_convergence_columns;