package com.dsh.other.audit;

import com.dsh.other.entity.SysAccountAuditLog;
import com.dsh.other.service.SysAccountAuditLogService;
import feign.Logger;
import feign.Request;
import org.slf4j.LoggerFactory;

import java.util.UUID;

/** 将本服务发起的 Feign 调用同步写入统一审计表，不记录请求正文。 */
public class FeignAuditLogger extends Logger {
    private final org.slf4j.Logger logger = LoggerFactory.getLogger(FeignAuditLogger.class);
    private final SysAccountAuditLogService auditLogService;

    /**
     * 构造 Feign 审计日志器。
     *
     * @param auditLogService 审计日志服务
     */
    public FeignAuditLogger(SysAccountAuditLogService auditLogService) {
        this.auditLogService = auditLogService;
    }

    @Override protected void log(String configKey, String format, Object... args) { logger.debug(methodTag(configKey) + format, args); }
    @Override protected void logRequest(String configKey, Level logLevel, Request request) {
        try {
            SysAccountAuditLog auditLog = new SysAccountAuditLog();
            auditLog.setTraceId(UUID.randomUUID().toString().replace("-", ""));
            auditLog.setSourceService("mb-cloud-other");
            auditLog.setSourceType("FEIGN");
            auditLog.setOperationType("FEIGN_CALL");
            auditLog.setRiskLevel(AuditLogSupport.riskLevel(request.url(), "FEIGN_CALL"));
            auditLog.setOperationName(configKey);
            auditLog.setRequestMethod(request.httpMethod().name());
            auditLog.setRequestUri(request.url());
            auditLog.setRequestParams(request.body() == null ? null : "bodyBytes=" + request.body().length + ", contentType=" + request.headers().get("Content-Type"));
            auditLogService.append(auditLog);
        } catch (Exception e) { logger.error("Feign审计日志写入失败, configKey={}", configKey, e); }
        super.logRequest(configKey, logLevel, request);
    }
}