|
@@ -162,6 +162,9 @@ public class PushConsumer {
|
|
|
timeMessages.add(timeMessage);
|
|
|
});
|
|
|
log.info("消息记录列表:" + timeMessages.toString());
|
|
|
- timeMessageService.saveBatch(timeMessages);
|
|
|
+ if (!timeMessages.isEmpty()) {
|
|
|
+ log.info("消息不为空,保存消息到消息中心");
|
|
|
+ timeMessageService.saveBatch(timeMessages);
|
|
|
+ }
|
|
|
}
|
|
|
}
|