网关日志添加

common-lib/src/main/java/com/mortals/xhx/module/MessageProducer.java

@@ -3,18 +3,27 @@ package com.mortals.xhx.module;
 import com.alibaba.fastjson.JSON;
 import com.mortals.xhx.common.keys.QueueKey;
 import com.mortals.xhx.common.pdu.access.AccessLogPdu;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
 
 @Component
+@Slf4j
 public class MessageProducer {
 
     @Autowired
     private RabbitTemplate rabbitTemplate;
 
     public void syncAccessSend(AccessLogPdu accessLogPdu) {
+
+        if (!ObjectUtils.isEmpty(accessLogPdu)) {
+            if (log.isDebugEnabled()) {
+                log.debug("accessLog==>{}", JSON.toJSONString(accessLogPdu));
+            }
             rabbitTemplate.convertAndSend(QueueKey.EXCHANGE, QueueKey.ACCESS_LOG_QUEUE, JSON.toJSONString(accessLogPdu));
         }
+    }
 
 }