package com.talentcard.server.business.payment;

import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

/**
 * Ledger for money facts that disagree with local state.
 *
 * <p>A callback or a provider query may describe a payment that local business rules refuse to
 * accept: another merchant, another amount, another order, a cancelled order or a payment whose
 * merchant binding is missing. Those cases must never be silently dropped and never auto-fulfil the
 * order, so every one of them is recorded as an open row an administrator can inspect.
 */
@Service
public class PaymentIssueRecorder {

    static final String PROVIDER = "HUIFU";

    private final JdbcTemplate jdbc;

    public PaymentIssueRecorder(JdbcTemplate jdbc) {
        this.jdbc = jdbc;
    }

    public void issue(String type, String businessNo, String orderNo, String expected, String actual, long amount, String message) {
        jdbc.update("""
                insert into payment_reconciliation_issue(issue_type, provider, business_no, order_no, expected_status, actual_status, amount, detail_message)
                values (?, ?, ?, ?, ?, ?, ?, ?)
                on duplicate key update detected_at = now(), expected_status = values(expected_status), actual_status = values(actual_status), amount = values(amount), detail_message = values(detail_message)
                """, type, PROVIDER, businessNo, emptyToNull(orderNo), emptyToNull(expected), emptyToNull(actual), amount, truncate(message));
    }

    /**
     * 把一笔业务仍未结的问题记为已解决。
     *
     * <p>唯一键是 {@code (issue_type, provider, business_no, status)}，而同一笔业务会被「解掉、又出现、
     * 再解掉」（对账每一轮都可能把同一条问题关掉再开出来）。直接把 open 行改成 resolved 会撞上已经存在
     * 的那条 resolved 行，所以先把上一条结论行清掉再落新结论。删除是有条件的：只有当确实存在一条 open 行
     * （也就是真的要有新结论）时才动它，人工写下的结论不会因为一次无关的对账轮次被抹掉。
     */
    public void resolve(String type, String businessNo, String by) {
        List<Long> superseded = jdbc.queryForList("""
                select r.id from payment_reconciliation_issue r
                where r.issue_type = ? and r.provider = ? and r.business_no = ? and r.status = 'resolved'
                  and exists (select 1 from payment_reconciliation_issue open_issue
                              where open_issue.issue_type = r.issue_type and open_issue.provider = r.provider
                                and open_issue.business_no = r.business_no and open_issue.status = 'open')
                """, Long.class, type, PROVIDER, businessNo);
        for (Long id : superseded) jdbc.update("delete from payment_reconciliation_issue where id = ?", id);
        jdbc.update("update payment_reconciliation_issue set status = 'resolved', resolved_at = now(), resolved_by = ? where issue_type = ? and provider = ? and business_no = ? and status = 'open'", by, type, PROVIDER, businessNo);
    }

    private String emptyToNull(String value) { return value == null || value.isBlank() ? null : value; }

    private String truncate(String value) { if (value == null) return ""; return value.length() > 500 ? value.substring(0, 500) : value; }
}