李进 2 роки тому
батько
коміт
bac392fb2d

+ 5 - 2
device-api-service/src/main/java/com/xy/job/MqttCommandJob.java

@@ -47,9 +47,12 @@ public class MqttCommandJob {
                 : sysDictRedis != null ? Integer.valueOf(sysDictRedis.getValue())
                 : 30;
         LambdaQueryWrapper<MqttCommand> lambdaQueryWrapper = new LambdaQueryWrapper<MqttCommand>()
-                .le(MqttCommand::getSendTime, DataTime.getStringAround(0, 0, (~(saveDay - 1)), 0, 0, 0));
+                .le(MqttCommand::getSendTime, DataTime.getStringAround(0, 0, (~(saveDay - 1)), 0, 0, 0))
+                .last("limit 10000");
         Integer count = mqttCommandMapper.delete(lambdaQueryWrapper);
-        log.info("已清除指令数据:{}条", count);
+        if (count > 0) {
+            log.info("已清除指令数据:{}条", count);
+        }
         return ReturnT.SUCCESS;
     }