package com.talentcard.server.business.admin;

import static org.assertj.core.api.Assertions.assertThat;

import java.nio.charset.StandardCharsets;
import java.util.Map;
import java.util.UUID;

import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.CsvSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.core.io.ClassPathResource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.transaction.annotation.Transactional;

@SpringBootTest
@ActiveProfiles("test")
@Transactional
class PremiumServiceMerchantTypeTests {

    @Autowired
    private JdbcTemplate jdbc;

    @Autowired
    private AdminBusinessService service;

    @ParameterizedTest
    @CsvSource({
            "children, 子女托管, CHILD_ENTRUSTMENT",
            "approval, 行政审批, ADMIN_APPROVAL",
            "employment, 配偶推荐就业, SPOUSE_EMPLOYMENT"
    })
    void migratedTypeAgreesAcrossListFiltersDetailAndEditing(String code, String label, String businessType)
            throws Exception {
        long id = insertMerchant("service", "other", 0);
        insertMapping(id, code, businessType, 0);

        migrate();
        Map<String, Object> detail = service.merchant(id);
        assertThat(detail).containsEntry("merchantType", label).containsEntry("merchantTypeCode", code);
        String name = (String) detail.get("merchantName");
        assertList(id, name, null, code, label, 1);
        assertList(id, name, label, code, label, 1);
        assertList(id, name, code, code, label, 1);
        assertList(id, name, "food", code, label, 0);

        // The edit page submits the display name returned by the detail endpoint.
        Map<String, Object> saved = service.updateMerchant(id, new MerchantUpdateRequest(
                name + " edited", (String) detail.get("merchantType"), "Test contact", "13800000000",
                "Test address", null, null, "营业中", (byte) 0, 0, (byte) 1,
                null, null, (byte) 0, null, null, null, null, null, null, null, (byte) 0, null, null));
        assertThat(saved).containsEntry("merchantType", label).containsEntry("merchantTypeCode", code);
        assertThat(jdbc.queryForMap(
                "select category_key, business_type, deleted from premium_topic_merchant where merchant_id = ?", id))
                .containsEntry("category_key", code).containsEntry("business_type", businessType);
        assertThat(jdbc.queryForObject(
                "select deleted from premium_topic_merchant where merchant_id = ?", Integer.class, id)).isZero();
        assertList(id, name + " edited", label, code, label, 1);

        // Reapplying the repair must also preserve a subsequent explicit type edit.
        jdbc.update("update merchant set merchant_type = '餐饮服务', merchant_type_code = 'food' where id = ?", id);
        migrate();
        assertThat(service.merchant(id))
                .containsEntry("merchantType", "餐饮服务").containsEntry("merchantTypeCode", "food");
    }

    @Test
    void repairIsIdempotentAndLeavesUnrelatedOrDeletedRecordsUntouched() throws Exception {
        long fixed = insertMerchant("service", "other", 0);
        insertMapping(fixed, "children", "CHILD_ENTRUSTMENT", 0);
        long unmapped = insertMerchant("service", "other", 0);
        long deletedMerchant = insertMerchant("service", "other", 1);
        insertMapping(deletedMerchant, "children", "CHILD_ENTRUSTMENT", 0);
        long deletedMapping = insertMerchant("service", "other", 0);
        insertMapping(deletedMapping, "approval", "ADMIN_APPROVAL", 1);
        long unsupportedMapping = insertMerchant("service", "other", 0);
        insertMapping(unsupportedMapping, "finance", "FINANCE", 0);
        long explicitCode = insertMerchant("service", "food", 0);
        insertMapping(explicitCode, "employment", "SPOUSE_EMPLOYMENT", 0);
        long explicitName = insertMerchant("LOCAL_TEST", "other", 0);
        insertMapping(explicitName, "children", "CHILD_ENTRUSTMENT", 0);

        migrate();
        Map<String, Object> repaired = jdbc.queryForMap("select * from merchant where id = ?", fixed);
        migrate();
        assertThat(jdbc.queryForMap("select * from merchant where id = ?", fixed)).isEqualTo(repaired);
        assertType(fixed, "子女托管", "children");
        for (long id : new long[]{unmapped, deletedMerchant, deletedMapping, unsupportedMapping}) {
            assertType(id, "service", "other");
        }
        assertType(explicitCode, "service", "food");
        assertType(explicitName, "LOCAL_TEST", "other");
    }

    private void assertList(long id, String name, String filter, String code, String label, int expected) {
        var page = service.merchants(name, null, filter, null, null, null, null, 1, 10);
        assertThat(page.total()).isEqualTo(expected);
        assertThat(page.records()).hasSize(expected);
        if (expected == 1) {
            assertThat(page.records().get(0))
                    .containsEntry("id", id).containsEntry("merchantType", label).containsEntry("merchantTypeCode", code);
        }
    }

    private void assertType(long id, String label, String code) {
        assertThat(jdbc.queryForMap("select merchant_type, merchant_type_code from merchant where id = ?", id))
                .containsEntry("merchant_type", label).containsEntry("merchant_type_code", code);
    }

    private long insertMerchant(String label, String code, int deleted) {
        jdbc.update("""
                insert into merchant(merchant_name, merchant_type, merchant_type_code, address, deleted)
                values (?, ?, ?, 'Test address', ?)
                """, "premium-type-" + UUID.randomUUID(), label, code, deleted);
        return jdbc.queryForObject("select last_insert_id()", Long.class);
    }

    private void insertMapping(long id, String category, String businessType, int deleted) {
        jdbc.update("""
                insert into premium_topic_merchant(merchant_id, category_key, business_type, deleted)
                values (?, ?, ?, ?)
                """, id, category, businessType, deleted);
    }

    private void migrate() throws Exception {
        jdbc.execute(new ClassPathResource("db/migration/V157__backfill_premium_service_merchant_types.sql")
                .getContentAsString(StandardCharsets.UTF_8));
    }
}