package jnpf.dmsIntegration.audit;

import jnpf.audit.AuditConsts;
import jnpf.audit.diff.AuditFieldDiff;
import jnpf.audit.model.AuditEventDTO;
import jnpf.audit.sdk.AuditClient;
import jnpf.util.JsonUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.web.context.request.RequestContextHolder;

import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.Map;

/** DMS 后端直接变更的审计；不再次记录原生表单的创建/编辑。 */
@Component
@RequiredArgsConstructor
public class DmsBusinessChangeAudit {
    private final ObjectProvider<AuditClient> clients;
    private final DmsSystemAudit systemAudit;

    /** 调用方在实际写入成功后提交旧/新事实；SDK 在事务提交后投递，回滚不投递。 */
    public void record(String tenantId, String action, String label, String table, String id,
                       Map<String, Object> before, Map<String, Object> after,
                       String reason, Map<String, Object> context) {
        String differences = AuditFieldDiff.diff(before, after, Collections.emptySet());
        if ("[]".equals(differences)) return;
        AuditEventDTO event = AuditEventDTO.builder()
                .tenantId(tenantId).eventType(AuditConsts.TYPE_DATA_CHANGE)
                .actionCode(action).actionLabel(label).bizModule("DMS").bizType("DMS_BUSINESS_CHANGE")
                .bizCode(id).targetTable(table).targetId(id).recordTitle(label + " · " + id)
                .fieldDiffs(differences).dataSnapshot(JsonUtil.getObjectToString(after))
                .reason(reason).extra(JsonUtil.getObjectToString(context))
                .relatedSigns(DmsAuditRequestSignResolver.resolve(context)).sourceLayer(3).build();
        if (RequestContextHolder.getRequestAttributes() == null) {
            // 自动执行者与批准来源分开；批准人等来源身份由调用方放在 context。
            event.setOperatorId("0");
            event.setOperatorName("系统自动执行");
            systemAudit.record(event);
        } else {
            clients.ifAvailable(client -> client.record(event));
        }
    }

    /** 允许空值，保持旧/新事实中未设置的字段；调用方只选取本次业务变化字段。 */
    public static Map<String, Object> values(Object... pairs) {
        if (pairs.length % 2 != 0) throw new IllegalArgumentException("审计字段必须成对");
        Map<String, Object> result = new LinkedHashMap<>();
        for (int i = 0; i < pairs.length; i += 2) result.put((String) pairs[i], pairs[i + 1]);
        return result;
    }
}