/**
 * 异常日志堆栈-用于非运行时异常的告警提示
 * @author fanht
 * @date 2022-03-21  17:28
 * @versio 1.0
 */
@Component
public class MarketingLogFilter extends TurboFilter {

    /**rocketmq异常信息打印*/
    private static final String ROCKETMQ_ERROR = "rocketmq";

    @Resource
    private SimpleBufferTriggerUtils simpleBufferTriggerUtils;

    @Resource
    private OptionalAlarmUriUtils optionalAlarmUriUtils;

    @Resource
    private DingdingAlarmUtil dingdingAlarmUtil;
    @Override
    public FilterReply decide(Marker marker, Logger logger, Level level, String s, Object[] objects, Throwable throwable) {
        if(logger.getName().contains("rocketmq")){
            System.out.println("mq error:" + (Optional.of(logger).map(l->l.getName()).orElse(null))+ ",throwable:" + Optional.ofNullable(throwable).map(t->t.getMessage()).orElse(null));
        }
        if(dingdingAlarmUtil==null){
            dingdingAlarmUtil = ApplicationContext.getBean(DingdingAlarmUtil.class);
        }
        //todo 如果是非运行时异常 发送钉钉告警。排除运行时异常
        if(throwable != null && StringUtils.isNotEmpty(throwable.getMessage()) && level.equals(Level.ERROR)){
            if(optionalAlarmUriUtils == null){
                optionalAlarmUriUtils = ApplicationContext.getBean(OptionalAlarmUriUtils.class);
            }
            if(!optionalAlarmUriUtils.isExistUri(logger.getName())){
                if(simpleBufferTriggerUtils == null){
                    simpleBufferTriggerUtils =  ApplicationContext.getBean(SimpleBufferTriggerUtils.class);
                }
                simpleBufferTriggerUtils.proceErrorAlarm(Tag.builder().applicationName(dingdingAlarmUtil.getApplicationName())
                        .env(dingdingAlarmUtil.getEnv())
                        .ip(IpUtil.initIp())
                        .traceId(MDC.get(TraceUtils.TRACE_ID))
                        .requestUri(logger.getName())
                        .exMessage(JSONObject.toJSON(throwable.getMessage().length() >500 ?
                                throwable.getMessage().substring(0,500).toString():throwable.getMessage()).toString())
                        .build());
            }
        }else if(Level.ERROR.equals(level) && logger.getName().contains(ROCKETMQ_ERROR)){
            //如果是mq的异常 也要进行告警
            if(!optionalAlarmUriUtils.isExistUri(logger.getName())){
                String exMessage = Optional.ofNullable(s).orElse("") + Optional.ofNullable(objects).map(t->t[0]).orElse(null);
                simpleBufferTriggerUtils.proceErrorAlarm(Tag.builder().applicationName(dingdingAlarmUtil.getApplicationName())
                        .env(dingdingAlarmUtil.getEnv()).ip(IpUtil.initIp()).requestUri(logger.getName()).traceId(MDC.get(TraceUtils.TRACE_ID))
                        .exMessage(Optional.ofNullable(exMessage).map(t->t.length()>500?t.substring(0,500):t).orElse(""))
                        .build());
            }
        }
        //todo 如果接入kafka,则此处需要需要改为NEUTRAL，以防止kakfa的多次打印
        return FilterReply.NEUTRAL;
    }
}

Component
public class TurboFilterReRegistrar {

    private final MarketingLogFilter marketingLogFilter;

    public TurboFilterReRegistrar(MarketingLogFilter marketingLogFilter) {
        this.marketingLogFilter = marketingLogFilter;
    }

    /**
     * 监听 Refresh 完成事件（包括 Nacos 配置刷新）
     */
    @EventListener
    public void handleRefresh(RefreshScopeRefreshedEvent event) {
        reRegisterTurboFilter();
    }

    /**
     * 也监听 Context Refreshed（兜底，确保启动时也注册）
     */
    @EventListener
    public void handleContextRefreshed(ContextRefreshedEvent event) {
        reRegisterTurboFilter();
    }

    private void reRegisterTurboFilter() {
        try {
            ILoggerFactory factory = LoggerFactory.getILoggerFactory();
            if (factory instanceof LoggerContext) {
                LoggerContext context = (LoggerContext) factory;

                // 检查是否已存在，避免重复注册（TurboFilter 没有 equals/hashCode，简单用类型判断）
                boolean alreadyRegistered = context.getTurboFilterList().stream()
                    .anyMatch(f -> f.getClass() == MarketingLogFilter.class);

                if (!alreadyRegistered) {
                    context.addTurboFilter(marketingLogFilter);
                    System.out.println("✅ Re-registered MarketingLogFilter after refresh");
                } else {
                    // 如果已存在，可能是同一个实例，无需操作
                    System.out.println("ℹ️ MarketingLogFilter already registered");
                }
            }
        } catch (Exception e) {
            System.err.println("❌ Failed to re-register TurboFilter: " + e.getMessage());
            e.printStackTrace();
        }
    }
}