package com.talentcard.server.business.merchant;

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

import java.math.BigDecimal;
import java.util.List;
import java.util.Map;

import com.talentcard.server.business.PageResult;
import com.talentcard.server.business.merchant.auth.MerchantPrincipal;
import com.talentcard.server.common.BusinessException;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ActiveProfiles;

@SpringBootTest
@ActiveProfiles("test")
class MerchantManagementServiceTests {

    @Autowired
    private JdbcTemplate jdbc;

    @Autowired
    private MerchantManagementService service;

    private Long merchantId;
    private Long storeId;
    private MerchantPrincipal principal;

    @BeforeEach
    void prepareMerchant() {
        String suffix = String.valueOf(System.nanoTime());
        jdbc.update("insert into merchant(merchant_name, address, business_status, status, can_login_merchant_app, deleted) values (?, ?, 'OPEN', 1, 1, 0)",
                "Management test merchant " + suffix, "测试商户地址");
        merchantId = jdbc.queryForObject("select max(id) from merchant", Long.class);
        jdbc.update("insert into merchant_store(merchant_id, store_name, address, status, deleted) values (?, ?, ?, 1, 0)",
                merchantId, "测试门店", "测试门店地址");
        storeId = jdbc.queryForObject("select max(id) from merchant_store", Long.class);
        principal = new MerchantPrincipal(1000L, merchantId, storeId, "operator");
        insertProduct("ONLINE", 1, 2);
        insertProduct("OFFLINE", 0, 2);
        insertProduct("PENDING", 0, 1);
    }

    @Test
    void returnsMerchantScopedProfileAndProducts() {
        Map<String, Object> profile = service.profile(principal);
        PageResult<Map<String, Object>> online = service.products(principal, "online", 1, 10);
        PageResult<Map<String, Object>> offline = service.products(principal, "offline", 1, 10);
        PageResult<Map<String, Object>> review = service.products(principal, "review", 1, 10);

        assertThat(profile).containsEntry("address", "测试门店地址").containsEntry("businessStatus", "open").containsEntry("onlineProductCount", 1L);
        assertThat(online.total()).isEqualTo(1);
        assertThat(offline.total()).isEqualTo(1);
        assertThat(review.total()).isEqualTo(3);
    }

    @Test
    void updatesBusinessHoursAndRejectsOverlaps() {
        Map<String, Object> saved = service.updateBusinessHours(principal, new MerchantBusinessHoursRequest(List.of(
                new MerchantBusinessHoursRequest.Period("08:00", "12:00"),
                new MerchantBusinessHoursRequest.Period("14:00", "18:00")
        )));

        assertThat(saved.get("periods")).asList().hasSize(2);
        assertThatThrownBy(() -> service.updateBusinessHours(principal, new MerchantBusinessHoursRequest(List.of(
                new MerchantBusinessHoursRequest.Period("08:00", "12:00"),
                new MerchantBusinessHoursRequest.Period("11:00", "18:00")
        )))).isInstanceOf(BusinessException.class);
    }

    @Test
    void updatingProductResubmitsForReviewAndPreventsPendingProductFromGoingOnline() {
        Long productId = jdbc.queryForObject("select id from merchant_product where merchant_id = ? and product_no like 'MANAGEMENT-ONLINE-%'", Long.class, merchantId);
        Map<String, Object> updated = service.updateProduct(principal, productId, new MerchantProductUpdateRequest(
                "更新后的商品", new BigDecimal("99.90"), "https://example.com/product.jpg", List.of("https://example.com/product-1.jpg"),
                "更新后的图文详情", Map.of("validity", "30天", "usage", "到店核销")
        ));

        assertThat(updated).containsEntry("status", "offline").containsEntry("auditStatus", "pending");
        assertThatThrownBy(() -> service.updateProductStatus(principal, productId, new MerchantProductStatusRequest("online")))
                .isInstanceOf(BusinessException.class);
    }

    /**
     * 体检医院在后台团单里只有「商品名称 / 封面图 / 可预约时间 / 检查项目」，没有商品金额。
     * 商家端照这套字段保存时：可预约时间要落到 purchase_notice.validPeriod，金额允许为空并按 0（免费）落库。
     */
    @Test
    void savesHealthCheckProductWithoutPriceAndKeepsReservationWindow() {
        jdbc.update("update merchant set merchant_type_code = 'medical' where id = ?", merchantId);
        Long productId = jdbc.queryForObject("select id from merchant_product where merchant_id = ? and product_no like 'MANAGEMENT-ONLINE-%'", Long.class, merchantId);

        Map<String, Object> updated = service.updateProduct(principal, productId, new MerchantProductUpdateRequest(
                "查血", null, "https://example.com/cover.jpg", List.of(),
                "[{\"name\":\"查血\",\"meaning\":\"检查血脂\",\"gender\":[\"男\",\"女\"]}]",
                Map.of("validPeriod", "2026-09-16 至 2026-09-18")
        ));

        assertThat(updated).containsEntry("merchantTypeCode", "medical");
        assertThat((BigDecimal) updated.get("salePrice")).isEqualByComparingTo(BigDecimal.ZERO);
        assertThat((Map<String, String>) updated.get("purchaseNotice"))
                .containsEntry("validPeriod", "2026-09-16 至 2026-09-18");
        Map<String, Object> detail = service.product(principal, productId);
        assertThat(String.valueOf(detail.get("detailText"))).contains("检查血脂");
    }

    /** 非体检医院仍然要有商品金额：商家端少了金额字段时不能静默按免费存下去。 */
    @Test
    void rejectsMissingPriceForNonHealthCheckMerchant() {
        Long productId = jdbc.queryForObject("select id from merchant_product where merchant_id = ? and product_no like 'MANAGEMENT-ONLINE-%'", Long.class, merchantId);

        assertThatThrownBy(() -> service.updateProduct(principal, productId, new MerchantProductUpdateRequest(
                "普通商品", null, "https://example.com/cover.jpg", List.of("https://example.com/product-1.jpg"),
                "图文详情", Map.of()
        ))).isInstanceOf(BusinessException.class).hasMessageContaining("商品金额");
    }

    private void insertProduct(String marker, int status, int auditStatus) {
        jdbc.update("""
                insert into merchant_product(merchant_id, product_no, product_type, product_name, cover_url, original_price, sale_price,
                                             audit_status, status, submit_time, deleted)
                values (?, ?, 'food', ?, '/static/test.jpg', 100.00, 80.00, ?, ?, now(), 0)
                """, merchantId, "MANAGEMENT-" + marker + "-" + System.nanoTime(), marker + " product", auditStatus, status);
    }
}