From 586837f1f65d754da788a7aa507bfdd442d237fe Mon Sep 17 00:00:00 2001 From: tianwenbo Date: Tue, 7 Mar 2023 16:15:13 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=20sonar=E3=80=91=20SendMsgJob.java?= =?UTF-8?q?=20=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/jero/modules/message/job/SendMsgJob.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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) {