From be5d8ae0a86b754e0ef42e56c138cc2da5b2e6e1 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 6 Sep 2021 13:30:09 +0800 Subject: [PATCH] msg --- .../main/java/com/iformall/schedule/MsgSendingSchedule.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/MsgSendingSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/MsgSendingSchedule.java index c647d56b7..d3eba07f8 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/MsgSendingSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/MsgSendingSchedule.java @@ -55,7 +55,7 @@ public class MsgSendingSchedule { for (WxMsg msg : list) { //sendmsg(msg); msg.setStatus(EnumMsgStatus.MSG_STATUS_SENDED.getCode()); - if(wxMsg.getWay() == EnumSendWay.TAG.getCode()){ + if(EnumSendWay.TAG.getCode().equals(wxMsg.getWay())){ if (wxMsg.getExpectSendNumber().intValue() > 1000) { WxMsgService.batchSendMsg(wxMsg, null, null); } else { @@ -64,8 +64,10 @@ public class MsgSendingSchedule { mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(),null); } - }else if(msg.getWay() == EnumSendWay.APPINFOR.getCode()){ + }else if(EnumSendWay.APPINFOR.getCode().equals(msg.getWay())){ WxMsgService.batchSendAppinfo(msg); + }else{ + break; } wxMsgMapper.updateById(msg);