renkang/xj-platform
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

屏蔽发短信日志

Browse Source
This commit is contained in:
lianlonggang
2026-02-02 12:44:46 +08:00
parent 24b1967ba9
commit fe014a56c8
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jeecg-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/impl/SmsSendMsgHandle.java
+3 -3
View File
@@ -53,9 +53,9 @@ public class SmsSendMsgHandle implements ISendMsgHandle {
@Override @Override
public Result<?> sendCqSms(int pageSize,boolean isBatch){ public Result<?> sendCqSms(int pageSize,boolean isBatch){
String logSuffix = isBatch?"[群发]":"[单发]"; // String logSuffix = isBatch?"[群发]":"[单发]";
//调用短信接口发送短信 //调用短信接口发送短信
log.info("查询未发送和发送失败的短信"+logSuffix); // log.info("查询未发送和发送失败的短信"+logSuffix);
//根据单发和群发拼接查询 //根据单发和群发拼接查询
LambdaQueryWrapper<SysMessage> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SysMessage> queryWrapper = new LambdaQueryWrapper<>();
if(!isBatch){ if(!isBatch){
@@ -69,7 +69,7 @@ public class SmsSendMsgHandle implements ISendMsgHandle {
queryWrapper.orderByAsc(SysMessage::getCreateTime).last("limit "+pageSize); queryWrapper.orderByAsc(SysMessage::getCreateTime).last("limit "+pageSize);
//查询需要发送的数据 //查询需要发送的数据
List<SysMessage> sysMessages = sysMessageService.getBaseMapper().selectList(queryWrapper); List<SysMessage> sysMessages = sysMessageService.getBaseMapper().selectList(queryWrapper);
log.info("开始发送短信("+sysMessages.size()+")"+logSuffix); // log.info("开始发送短信("+sysMessages.size()+")"+logSuffix);
// 2.执行发送短信任务 // 2.执行发送短信任务
for (SysMessage sysMessage : sysMessages) { for (SysMessage sysMessage : sysMessages) {
ThreadUtil.safeSleep(100);//防止并发，休眠0.1秒 ThreadUtil.safeSleep(100);//防止并发，休眠0.1秒