日志只执行１次

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -129,6 +129,9 @@ public class MqServiceImpl implements MqService, InitializingBean {
      */
     @Override
     public String log(MessageLogReqVo req) {
+        if (StringHelper.isEmpty(req.getMessageId()) || StringHelper.isEmpty(req.getQueue())) {
+            return StringHelper.EMPTY;
+        }
         MessageLogRemoveReqVo loadReq = new MessageLogRemoveReqVo(req.getQueue(), req.getMessageId());
         MessageLogVo load = messageLogDao.load(loadReq, MessageLogVo.class);
         if (load != null) {
@@ -147,6 +150,9 @@ public class MqServiceImpl implements MqService, InitializingBean {
      */
     @Override
     public String logRemove(MessageLogRemoveReqVo req) {
+        if (StringHelper.isEmpty(req.getMessageId()) || StringHelper.isEmpty(req.getQueue())) {
+            return StringHelper.EMPTY;
+        }
         messageLogDao.load(req, MessageLogVo.class);
         return req.getMessageId();
     }