业务日志添加

log-manager/src/main/java/com/mortals/xhx/base/framework/aspect/OperlogAspect.java

@@ -4,11 +4,14 @@ import java.util.Date;
 
 import javax.servlet.http.HttpServletRequest;
 
+import com.mortals.framework.model.OperateLogPdu;
+import com.mortals.xhx.base.system.message.MessageProducer;
 import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.annotation.AfterReturning;
 import org.aspectj.lang.annotation.Aspect;
 import org.aspectj.lang.annotation.Before;
 import org.aspectj.lang.annotation.Pointcut;
+import org.checkerframework.checker.units.qual.A;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -33,12 +36,27 @@ public class OperlogAspect extends FileLogServiceImpl   implements ILogService {
 
     @Autowired
     private OperLogService operLogService;
+    @Autowired
+    private MessageProducer messageProducer;
 
     @Override
     public void doHandlerLog(String platformMark, Long userId, String userName, String loginName, String requestUrl,
                              String content, String ip, Date logDate) {
         super.doHandlerLog(platformMark, userId, userName, loginName, requestUrl, content, ip, logDate);
         operLogService.insertOperLog(ip, requestUrl, userId, userName, loginName, content);
+
+        OperateLogPdu operateLogPdu = new OperateLogPdu();
+        operateLogPdu.initAttrValue();
+        operateLogPdu.setIp(ip);
+        operateLogPdu.setRequestUrl(requestUrl);
+        operateLogPdu.setUserId(userId);
+        operateLogPdu.setUserName(userName);
+        operateLogPdu.setLoginName(loginName);
+        operateLogPdu.setPlatformMark(platformMark);
+        operateLogPdu.setLogDate(logDate);
+        operateLogPdu.setContent(content);
+        operateLogPdu.setOperType(1);
+        messageProducer.syncOperSend(operateLogPdu);
     }
 
     @Override

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/AccessMessageConsumerListener.java

@@ -69,7 +69,7 @@ public class AccessMessageConsumerListener {
 
     @RabbitHandler
     public void onMessage(List<AccessLogEntity> messages) {
-        log.info("[Access onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
+        log.info("[Access onMessage][消息数量：{}]",  messages.size());
         List<AccessLogEntity> collect = messages.stream().map(entity -> {
             try {
                // AccessLogEntity entity =null;

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/BizMessageConsumerListener.java

@@ -36,7 +36,7 @@ public class BizMessageConsumerListener {
 
     @RabbitHandler
     public void onMessage(List<BizLogEntity> messages) {
-        log.info("[Biz onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName()+Thread.currentThread().getId(), messages.size());
+        log.info("[Biz onMessage][消息数量：{}]",  messages.size());
         List<BizLogEntity> collect = messages.stream().map(entity -> {
            // BizLogEntity entity = JSON.parseObject(new String(str, Charset.defaultCharset()), BizLogEntity.class);
             entity.setId(IdUtil.getSnowflake(0, 1).nextId());

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/ErrorMessageConsumerListener.java

@@ -42,7 +42,7 @@ public class ErrorMessageConsumerListener {
 
     @RabbitHandler
     public void onMessage(List<ErrorLogEntity> messages) {
-        log.info("[Error onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
+        log.info("[Error onMessage][消息数量：{}]", messages.size());
         messages.stream().peek(entity -> {
             entity.setCreateUserId(1L);
             entity.setCreateTime(new Date());

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/OperateMessageConsumerListener.java

@@ -54,7 +54,7 @@ public class OperateMessageConsumerListener {
 
     @RabbitHandler
     public void onMessage(List<OperateLogEntity> messages) {
-        log.info("[Oper onMessage][线程编号:{} 消息数量：{}]", Thread.currentThread().getName() + Thread.currentThread().getId(), messages.size());
+        log.info("[Oper onMessage][消息数量：{}]", messages.size());
         List<OperateLogEntity> collect = messages.stream().map(entity -> {
             //OperateLogEntity entity = JSON.parseObject(new String(str), OperateLogEntity.class);
             entity.setId(IdUtil.getSnowflake(0, 1).nextId());

log-manager/src/test/java/com/mortals/httpclient/biz/BizLogController.http

@@ -15,7 +15,6 @@ client.global.set("authToken", JSON.parse(response.body).data.token);
 
 ###业务日志列表
 POST {{baseUrl}}/biz/log/list
-Authorization: {{authToken}}
 Content-Type: application/json
 
 {