package com.talentcard.server.business.admin;

import java.util.List;
import java.util.Map;

import com.talentcard.server.business.DatabaseRows;
import com.talentcard.server.common.BusinessException;
import com.talentcard.server.common.ErrorCode;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class ProtocolSettingAdminService {
    private static final Map<String, String> PROTOCOLS = Map.of(
            "talent_user_agreement", "用户协议-人才",
            "merchant_user_agreement", "用户协议-商户",
            "talent_privacy_policy", "隐私与权限-人才",
            "merchant_privacy_policy", "隐私与权限-商户"
    );
    private static final Map<String, AgreementSyncTarget> AGREEMENT_SYNC_TARGETS = Map.of(
            "talent_user_agreement", new AgreementSyncTarget("app_agreement", "user", "用户协议", "2026.07"),
            "talent_privacy_policy", new AgreementSyncTarget("app_agreement", "privacy", "隐私与权限", "2026.07"),
            "merchant_user_agreement", new AgreementSyncTarget("merchant_agreement", "user", "用户协议", "1.0.0"),
            "merchant_privacy_policy", new AgreementSyncTarget("merchant_agreement", "privacy", "隐私与权限", "1.0.0")
    );

    private final JdbcTemplate jdbc;

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

    @Transactional(readOnly = true)
    public Map<String, Object> detail(String key) {
        String title = title(key);
        List<Map<String, Object>> rows = DatabaseRows.normalize(jdbc.queryForList(
                "select protocol_key, title, content_html, updated_at from admin_protocol_setting where protocol_key = ?", key));
        if (rows.isEmpty()) return Map.of("key", key, "title", title, "contentHtml", "");
        return rows.get(0);
    }

    @Transactional
    public Map<String, Object> save(String key, String contentHtml) {
        String title = title(key);
        String content = contentHtml == null ? "" : contentHtml.trim();
        if (content.length() > 100_000) throw new BusinessException(ErrorCode.BAD_REQUEST, "协议内容不能超过 100000 个字符");
        jdbc.update("""
                insert into admin_protocol_setting(protocol_key, title, content_html)
                values (?, ?, ?)
                on duplicate key update title = values(title), content_html = values(content_html)
                """, key, title, content);
        syncAgreement(key, content);
        return detail(key);
    }

    private String title(String key) {
        String title = PROTOCOLS.get(key);
        if (title == null) throw new BusinessException(ErrorCode.BAD_REQUEST, "不支持的协议类型");
        return title;
    }

    private void syncAgreement(String key, String contentHtml) {
        AgreementSyncTarget target = AGREEMENT_SYNC_TARGETS.get(key);
        if (target == null) return;
        jdbc.update("""
                insert into %s(agreement_type, title, version, effective_date, content_html, status)
                values (?, ?, ?, current_date, ?, 1)
                on duplicate key update title = values(title), content_html = values(content_html)
                """.formatted(target.tableName), target.agreementType, target.title, target.defaultVersion, contentHtml);
    }

    private static final class AgreementSyncTarget {
        private final String tableName;
        private final String agreementType;
        private final String title;
        private final String defaultVersion;

        private AgreementSyncTarget(String tableName, String agreementType, String title, String defaultVersion) {
            this.tableName = tableName;
            this.agreementType = agreementType;
            this.title = title;
            this.defaultVersion = defaultVersion;
        }
    }
}