package com.thhy.usercore.modules.sys.syslog.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.thhy.general.entity.SysLogVo;
import com.thhy.usercore.modules.sys.syslog.entity.UrlInfo;
import com.thhy.usercore.modules.sys.syslog.mapper.SysLogsMapper;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
@RocketMQMessageListener(topic = "syslog",consumerGroup = "pipe")
public class LogExecController implements RocketMQListener<String> {

    @Autowired
    private SysLogsMapper logsMapper;

    @Override
    public void onMessage(String o) {
        System.out.println("接受到消息"+o);
        SysLogVo sysLogVo = JSON.toJavaObject(JSONObject.parseObject(o),SysLogVo.class);
        UrlInfo urlInfo = logsMapper.queryDetailByUrl(sysLogVo.getLogUrl());
        if (urlInfo!=null) {
            sysLogVo.setOpModules(urlInfo.getUrlName()!=null? urlInfo.getUrlName() : "");
            sysLogVo.setOpDesc(urlInfo.getUrlDesc()!=null? urlInfo.getUrlDesc() : "");
        }
        logsMapper.insert(sysLogVo);
    }
}