【fix sonar】 SendMsgJob.java 文件

This commit is contained in:
tianwenbo
2023-03-07 16:15:13 +08:00
parent e132883a72
commit 586837f1f6
@@ -33,11 +33,11 @@ public class SendMsgJob implements Job {
log.info(String.format(" jero-boot 发送消息任务 SendMsgJob ! 时间:" + DateUtils.getTimestamp()));
// 1.读取消息中心数据,只查询未发送的和发送失败不超过次数的
QueryWrapper<SysMessage> queryWrapper = new QueryWrapper<SysMessage>();
QueryWrapper<SysMessage> 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<SysMessage> 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) {