|
@@ -139,7 +139,7 @@ public class PushConsumer {
|
|
|
*/
|
|
|
private void saveMessage(PushMessage pushMessage) {
|
|
|
List<String> toList = pushMessage.getToList();
|
|
|
- List<UserAccount> userAccounts = userAccountService.list(Wrappers.<UserAccount>query().in(!toList.isEmpty(),"device_flag", toList));
|
|
|
+ List<UserAccount> userAccounts = userAccountService.list(Wrappers.<UserAccount>query().in(!toList.isEmpty(), "device_flag", toList));
|
|
|
List<TimeMessage> timeMessages = new ArrayList<>();
|
|
|
for (UserAccount userAccount : userAccounts) {
|
|
|
TimeMessage timeMessage = new TimeMessage();
|
|
@@ -160,11 +160,11 @@ public class PushConsumer {
|
|
|
break;
|
|
|
}
|
|
|
timeMessage.setDeviceModel(userAccount.getDeviceModel());
|
|
|
- timeMessage.setUserId(10000L);
|
|
|
+ timeMessage.setCreateUserId(10000L);
|
|
|
timeMessage.setCreateTime(LocalDateTime.now());
|
|
|
timeMessages.add(timeMessage);
|
|
|
}
|
|
|
- log.info("消息记录列表:"+timeMessages.toString());
|
|
|
+ log.info("消息记录列表:" + timeMessages.toString());
|
|
|
timeMessageService.saveBatch(timeMessages);
|
|
|
}
|
|
|
}
|