diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/job/SendMsgJob.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/job/SendMsgJob.java index 30b7b014..30447ab1 100644 --- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/job/SendMsgJob.java +++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/job/SendMsgJob.java @@ -33,11 +33,11 @@ public class SendMsgJob implements Job { log.info(String.format(" jero-boot 发送消息任务 SendMsgJob ! 时间:" + DateUtils.getTimestamp())); // 1.读取消息中心数据,只查询未发送的和发送失败不超过次数的 - QueryWrapper queryWrapper = new QueryWrapper(); + QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("es_send_status", SendMsgStatusEnum.WAIT.getCode()) .or(i -> i.eq("es_send_status", SendMsgStatusEnum.FAIL.getCode()).lt("es_send_num", 6)); List sysMessages = sysMessageService.list(queryWrapper); - System.out.println(sysMessages); + log.info(sysMessages.toString()); // 2.根据不同的类型走不通的发送实现类 for (SysMessage sysMessage : sysMessages) { ISendMsgHandle sendMsgHandle = null; @@ -58,7 +58,7 @@ public class SendMsgJob implements Job { throw new NullPointerException(); } sendMsgHandle.SendMsg(sysMessage.getEsReceiver(), sysMessage.getEsTitle(), - sysMessage.getEsContent().toString()); + sysMessage.getEsContent()); // 发送消息成功 sysMessage.setEsSendStatus(SendMsgStatusEnum.SUCCESS.getCode()); } catch (Exception e) {