package jnpf.dmsIntegration.audit;

import jnpf.audit.model.AuditEventDTO;
import jnpf.audit.sdk.AuditClient;
import jnpf.audit.sdk.AuditContextCollector;
import jnpf.audit.sdk.AuditEventPublisher;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/** 后台业务任务的显式审计入口；无需伪造浏览器请求或登录会话。 */
@Component
public class DmsSystemAudit {
    private final ObjectProvider<AuditEventPublisher> publishers;
    private final boolean enabled;

    public DmsSystemAudit(ObjectProvider<AuditEventPublisher> publishers,
                          @Value("${audit.enabled:true}") boolean enabled) {
        this.publishers = publishers;
        this.enabled = enabled;
    }

    public void record(AuditEventDTO event) {
        if (!enabled) return;
        if (!"0".equals(event.getOperatorId()) || event.getTenantId() == null || event.getTenantId().trim().isEmpty())
            throw new IllegalArgumentException("系统审计必须指定执行用户0和真实租户");
        // 使用 SDK 的显式入口与事务缓冲/失败落盘能力；前端请求来源过滤不适用于后台任务。
        AuditClient client = new AuditClient(new AuditContextCollector("jnpf-dms"), publishers.getObject(), true);
        client.record(event);
    }
}