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