diff --git a/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/impl/SmsSendMsgHandle.java b/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/impl/SmsSendMsgHandle.java index 8ff9b65..eeeea0b 100644 --- a/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/impl/SmsSendMsgHandle.java +++ b/jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/impl/SmsSendMsgHandle.java @@ -53,9 +53,9 @@ public class SmsSendMsgHandle implements ISendMsgHandle { @Override public Result sendCqSms(int pageSize,boolean isBatch){ - String logSuffix = isBatch?"[群发]":"[单发]"; +// String logSuffix = isBatch?"[群发]":"[单发]"; //调用短信接口发送短信 - log.info("查询未发送和发送失败的短信"+logSuffix); +// log.info("查询未发送和发送失败的短信"+logSuffix); //根据单发和群发拼接查询 LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); if(!isBatch){ @@ -69,7 +69,7 @@ public class SmsSendMsgHandle implements ISendMsgHandle { queryWrapper.orderByAsc(SysMessage::getCreateTime).last("limit "+pageSize); //查询需要发送的数据 List sysMessages = sysMessageService.getBaseMapper().selectList(queryWrapper); - log.info("开始发送短信("+sysMessages.size()+")"+logSuffix); +// log.info("开始发送短信("+sysMessages.size()+")"+logSuffix); // 2.执行发送短信任务 for (SysMessage sysMessage : sysMessages) { ThreadUtil.safeSleep(100);//防止并发,休眠0.1秒