|
|
@ -97,6 +97,7 @@ public class MessagePushRecordServiceImpl extends BaseServiceImpl<MessagePushRec |
|
|
|
if (MessageConstants.IMMEDIATELY.equals(request.getPushType())) { |
|
|
|
if (MessageConstants.IMMEDIATELY.equals(request.getPushType())) { |
|
|
|
request.setPlanTime(now); |
|
|
|
request.setPlanTime(now); |
|
|
|
request.setPushTime(now); |
|
|
|
request.setPushTime(now); |
|
|
|
|
|
|
|
request.setStatus(MessageConstants.NOT_PUSH); |
|
|
|
// 立即推送消息
|
|
|
|
// 立即推送消息
|
|
|
|
if (this.save(request) && Func.isNotEmpty(request.getId())) { |
|
|
|
if (this.save(request) && Func.isNotEmpty(request.getId())) { |
|
|
|
return this.send(request.getId()); |
|
|
|
return this.send(request.getId()); |
|
|
|