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);
|
}
|
}
|
