|
|
|
@@ -55,10 +55,9 @@ public class MsgSendingSchedule { |
|
|
|
for (WxMsg msg : list) { |
|
|
|
//sendmsg(msg); |
|
|
|
msg.setStatus(EnumMsgStatus.MSG_STATUS_SENDED.getCode()); |
|
|
|
logger.info("sendmsg定时任务"+wxMsg.getWay()); |
|
|
|
if(EnumSendWay.TAG.getCode().equals(wxMsg.getWay())){ |
|
|
|
if (wxMsg.getExpectSendNumber().intValue() > 1000) { |
|
|
|
WxMsgService.batchSendMsg(wxMsg, null, null); |
|
|
|
if(EnumSendWay.TAG.getCode().equals(msg.getWay())){ |
|
|
|
if (msg.getExpectSendNumber().intValue() > 1000) { |
|
|
|
WxMsgService.batchSendMsg(msg, null, null); |
|
|
|
} else { |
|
|
|
msg.setMsgType(EnumMsgRecordType.SMS_CALLBACK.getCode()); |
|
|
|
msg.setReceiver(msg.getPhones()); |
|
|
|
@@ -68,7 +67,6 @@ public class MsgSendingSchedule { |
|
|
|
}else if(EnumSendWay.APPINFOR.getCode().equals(msg.getWay())){ |
|
|
|
WxMsgService.batchSendAppinfo(msg); |
|
|
|
}else{ |
|
|
|
logger.info("sendmsg定时任务"+wxMsg.getWay()); |
|
|
|
break; |
|
|
|
} |
|
|
|
wxMsgMapper.updateById(msg); |
|
|
|
|