package jnpf.limsService.impl;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.PropertyNamingStrategies;
import jnpf.audit.AuditConsts;
import jnpf.audit.model.AuditEventDTO;
import jnpf.audit.sdk.AuditClient;
import jnpf.base.ModuleApi;
import jnpf.limsEntity.print.LimsPrintAuditParam;
import jnpf.limsEntity.print.LimsPrintAuditTarget;
import jnpf.util.JsonUtil;
import org.springframework.beans.factory.support.StaticListableBeanFactory;

import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Map;

/** Lightweight checks for the one-click-to-one-print-event mapping. */
public class LimsPrintAuditServiceImplChecks {

    public static void main(String[] args) {
        checkCamelCaseDeserialization();
        checkSinglePrint();
        checkBatchPrintAndDeduplication();
        checkBatchRecordsOnce();
        checkOptionalTemplate();
        checkMenuMappingAndFallback();
        checkInvalidInputs();
    }

    private static void checkCamelCaseDeserialization() {
        String json = "{\"requestId\":\"123e4567e89b12d3a456426614174000\","
                + "\"printName\":\"仪器设备标签\",\"templateId\":\"template-1\","
                + "\"recordTitle\":\"仪器设备标签\",\"targetTable\":\"lims_shebei_yiqi_xinxi\","
                + "\"bizType\":\"DEVICE_LABEL\",\"source\":\"LIST_PRINT\","
                + "\"targets\":[{\"id\":\"record-1\",\"bizCode\":\"SB-001\",\"title\":\"设备一\"}]}";
        ObjectMapper mapper = new ObjectMapper();
        mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
        try {
            LimsPrintAuditParam param = mapper.readValue(json, LimsPrintAuditParam.class);
            require("123e4567e89b12d3a456426614174000".equals(param.getRequestId()),
                    "camelCase requestId must override the global snake-case strategy");
            require("仪器设备标签".equals(param.getPrintName()), "camelCase printName must be deserialized");
            require("lims_shebei_yiqi_xinxi".equals(param.getTargetTable()),
                    "camelCase targetTable must be deserialized");
            require(param.getTargets() != null && param.getTargets().size() == 1,
                    "camelCase targets must be deserialized");
            require("SB-001".equals(param.getTargets().get(0).getBizCode()),
                    "nested camelCase bizCode must be deserialized");
        } catch (Exception e) {
            throw new AssertionError("camelCase print audit payload must be deserialized", e);
        }
    }

    private static void checkSinglePrint() {
        LimsPrintAuditParam param = baseParam();
        param.setTargets(Collections.singletonList(target("record-1", "BG-001", "检验报告 BG-001")));

        AuditEventDTO event = LimsPrintAuditServiceImpl.buildEvent(param);
        Map<String, Object> extra = extra(event);

        require(AuditConsts.TYPE_PRINT.equals(event.getEventType()), "event type must be PRINT");
        require("PRINT".equals(event.getActionCode()), "action code must be PRINT");
        require("发起打印".equals(event.getActionLabel()), "action label must describe initiation");
        require(Integer.valueOf(3).equals(event.getSourceLayer()), "explicit print events must use layer 3");
        require("PRINT-123e4567e89b12d3a456426614174000".equals(event.getClientEventId()),
                "request UUID must produce a stable client event id");
        require(event.getClientEventId().equals(event.getOperationId()), "operation id must correlate the same click");
        require("record-1".equals(event.getTargetId()), "single print must expose its target id");
        require("BG-001".equals(event.getBizCode()), "single print must expose its business code");
        require("SAMPLE_REPORT".equals(event.getBizType()), "frontend bizType must be retained");
        require("SINGLE".equals(extra.get("printMode")), "single print mode is incorrect");
        require(Integer.valueOf(1).equals(extra.get("printCount")), "single print count is incorrect");
    }

    private static void checkBatchPrintAndDeduplication() {
        LimsPrintAuditParam param = baseParam();
        param.setRecordTitle("检验报告");
        param.setTargets(Arrays.asList(
                target("record-1", "BG-001", "第一份"),
                target("record-2", null, "第二份"),
                target("record-1", "SHOULD-NOT-REPLACE", "重复项")));

        AuditEventDTO event = LimsPrintAuditServiceImpl.buildEvent(param);
        Map<String, Object> extra = extra(event);
        List<?> targets = (List<?>) extra.get("printTargets");
        List<?> subTitles = (List<?>) extra.get("recordSubTitles");

        require(event.getTargetId() == null, "batch print must not impersonate the first target");
        require(event.getBizCode() == null, "batch print must not expose one target's business code");
        require("检验报告（批量打印 2 条）".equals(event.getRecordTitle()), "batch title must use the deduplicated count");
        require("BATCH".equals(extra.get("printMode")), "batch print mode is incorrect");
        require(Integer.valueOf(2).equals(extra.get("printCount")), "duplicate ids must be counted once");
        require(targets.size() == 2, "batch event must contain all deduplicated targets in one DTO");
        require(Arrays.asList("BG-001", "第二份").equals(subTitles), "target summaries must preserve stable order");
    }

    private static void checkOptionalTemplate() {
        LimsPrintAuditParam param = baseParam();
        param.setTemplateId(null);
        param.setBizType(null);
        param.setTargets(Collections.singletonList(target("record-1", null, null)));

        AuditEventDTO event = LimsPrintAuditServiceImpl.buildEvent(param);
        Map<String, Object> extra = extra(event);

        require(!extra.containsKey("templateId"), "custom print must not require a template id");
        require("LIMS_PRINT".equals(event.getBizType()), "missing bizType must use the print fallback");
    }

    private static void checkBatchRecordsOnce() {
        CountingAuditClient client = new CountingAuditClient();
        StaticListableBeanFactory factory = new StaticListableBeanFactory();
        factory.addBean("auditClient", client);
        LimsPrintAuditServiceImpl service = new LimsPrintAuditServiceImpl(
                factory.getBeanProvider(AuditClient.class), factory.getBeanProvider(ModuleApi.class));
        LimsPrintAuditParam param = baseParam();
        param.setTargets(Arrays.asList(
                target("record-1", "BG-001", null),
                target("record-2", "BG-002", null)));

        service.record(param);

        require(client.recordCount == 1, "one batch click must invoke AuditClient.record exactly once");
        require(client.event != null && "BATCH".equals(extra(client.event).get("printMode")),
                "the single submitted event must contain the complete batch");
    }

    private static void checkMenuMappingAndFallback() {
        LimsPrintAuditParam param = baseParam();
        param.setTargets(Collections.singletonList(target("record-1", null, null)));

        AuditEventDTO resolved = LimsPrintAuditServiceImpl.buildEvent(
                param, LimsPrintAuditServiceImpl.MenuContext.resolved("menu-1", "检验报告菜单"));
        Map<String, Object> resolvedExtra = extra(resolved);
        require("检验报告菜单".equals(resolved.getBizModule()), "resolved menu must become the business module");
        require("MENU".equals(resolved.getEntryType()), "resolved menu must set entry type");
        require("menu-1".equals(resolved.getEntryId()), "resolved menu must retain entry id");
        require("检验报告菜单".equals(resolved.getEntryName()), "resolved menu must retain entry name");
        require("RESOLVED".equals(resolvedExtra.get("menuResolution")), "menu resolution status is incorrect");

        AuditEventDTO unresolved = LimsPrintAuditServiceImpl.buildEvent(
                param, LimsPrintAuditServiceImpl.MenuContext.unresolved("menu-2"));
        require("表单详情打印".equals(unresolved.getBizModule()), "unresolved menu must use the source label fallback");
        require("MENU".equals(unresolved.getEntryType()), "an unresolved header must still identify a menu entry");
        require("menu-2".equals(unresolved.getEntryId()), "an unresolved header must retain its menu id");
        require(unresolved.getEntryName() == null, "unresolved menu must not invent an entry name");

        AuditEventDTO missing = LimsPrintAuditServiceImpl.buildEvent(param);
        require("表单详情打印".equals(missing.getBizModule()), "missing menu must use the source label fallback");
        require(missing.getEntryType() == null && missing.getEntryId() == null, "missing menu must leave entry fields empty");
    }

    private static void checkInvalidInputs() {
        LimsPrintAuditParam invalidUuid = baseParam();
        invalidUuid.setRequestId("not-a-uuid");
        invalidUuid.setTargets(Collections.singletonList(target("record-1", null, null)));
        requireThrows(() -> LimsPrintAuditServiceImpl.buildEvent(invalidUuid), "invalid UUID must be rejected");

        LimsPrintAuditParam invalidTable = baseParam();
        invalidTable.setTargetTable("lims_report;drop table audit_events");
        invalidTable.setTargets(Collections.singletonList(target("record-1", null, null)));
        requireThrows(() -> LimsPrintAuditServiceImpl.buildEvent(invalidTable), "invalid table name must be rejected");
    }

    private static LimsPrintAuditParam baseParam() {
        LimsPrintAuditParam param = new LimsPrintAuditParam();
        param.setRequestId("123e4567-e89b-12d3-a456-426614174000");
        param.setPrintName("检验报告");
        param.setTemplateId("report-template");
        param.setTargetTable("lims_sample_report");
        param.setBizType("SAMPLE_REPORT");
        param.setSource("REPORT_VIEW");
        return param;
    }

    private static LimsPrintAuditTarget target(String id, String bizCode, String title) {
        LimsPrintAuditTarget target = new LimsPrintAuditTarget();
        target.setId(id);
        target.setBizCode(bizCode);
        target.setTitle(title);
        return target;
    }

    @SuppressWarnings("unchecked")
    private static Map<String, Object> extra(AuditEventDTO event) {
        return JsonUtil.getJsonToBean(event.getExtra(), Map.class);
    }

    private static void requireThrows(Runnable action, String message) {
        try {
            action.run();
            throw new AssertionError(message);
        } catch (IllegalArgumentException ignored) {
            // Expected validation failure.
        }
    }

    private static void require(boolean condition, String message) {
        if (!condition) {
            throw new AssertionError(message);
        }
    }

    private static final class CountingAuditClient extends AuditClient {
        private AuditEventDTO event;
        private int recordCount;

        private CountingAuditClient() {
            super(null, null, false);
        }

        @Override
        public void record(AuditEventDTO dto) {
            recordCount++;
            event = dto;
        }
    }
}