package jnpf.audit.sdk.aspect;

import com.alibaba.fastjson.JSON;

import java.io.Serializable;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/** AuditLog 批量主键归一化、逐记录 diff 与快照契约检查。 */
public final class AuditLogBatchDiffChecks {

    private static int passed;
    private static int failed;

    public static void main(String[] args) {
        List<Serializable> ids = AuditLogAspect.normalizeSerializableIds(
                Arrays.asList(" row-1 ", "row-2", "", "row-1", null));
        check("批量主键去空、去重并保持顺序",
                ids.equals(Arrays.asList("row-1", "row-2")));
        check("逗号分隔主键可归一化",
                AuditLogAspect.normalizeSerializableIds("row-1,row-2")
                        .equals(Arrays.asList("row-1", "row-2")));

        List<Serializable> tenIds = AuditLogAspect.normalizeSerializableIds(
                new String[] {"row-1", "row-2", "row-3", "row-4", "row-5",
                        "row-6", "row-7", "row-8", "row-9", "row-10"});
        Map<Serializable, Map<String, Object>> before = new LinkedHashMap<>();
        Map<Serializable, Map<String, Object>> after = new LinkedHashMap<>();
        for (Serializable id : tenIds) {
            before.put(id, row("pending"));
            after.put(id, row("done"));
        }

        String fieldDiffs = AuditLogAspect.batchFieldDiffs(
                "lims_task", tenIds, before, after);
        List<Map> diffs = JSON.parseArray(fieldDiffs, Map.class);
        check("10条记录修改同一字段保留10条差异", diffs.size() == 10);
        check("每条差异携带物理表和记录主键",
                diffs.stream().allMatch(item -> "lims_task".equals(item.get("targetTable"))
                        && item.get("targetId") != null));
        check("批量差异保留真实前后值",
                diffs.stream().allMatch(item -> "pending".equals(item.get("oldData"))
                        && "done".equals(item.get("newData"))));

        String snapshot = AuditLogAspect.batchSnapshot(tenIds, after);
        List<Map> snapshots = JSON.parseArray(snapshot, Map.class);
        check("批量操作后快照保留10条记录", snapshots.size() == 10);
        check("每条快照按 targetId 包装数据",
                snapshots.stream().allMatch(item -> item.get("targetId") != null
                        && item.get("data") instanceof Map));

        System.out.println("=== AuditLog 批量差异检查：" + passed + " 通过 / " + failed + " 失败 ===");
        if (failed > 0) {
            System.exit(1);
        }
    }

    private static Map<String, Object> row(String status) {
        Map<String, Object> row = new LinkedHashMap<>();
        row.put("status", status);
        return row;
    }

    private static void check(String name, boolean ok) {
        if (ok) {
            passed++;
            System.out.println("  [PASS] " + name);
        } else {
            failed++;
            System.out.println("  [FAIL] " + name);
        }
    }

    private AuditLogBatchDiffChecks() {
    }
}