mqtt指令发布

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

@@ -50,6 +50,10 @@ public class MqttCommandJob {
         return ReturnT.SUCCESS;
     }
 
+    public static void main(String[] args) {
+        System.out.println(DataTime.getStringAround(0, 0, 0, 0, 0, (~(30 + 1))));
+    }
+
     /**
      * 指令数据闭环
      *
@@ -65,7 +69,7 @@ public class MqttCommandJob {
                 : 30;
         LambdaEsQueryWrapper<MqttCommand> lambdaEsQueryWrapper = new LambdaEsQueryWrapper<MqttCommand>()
                 .in(MqttCommand::getStatus, Arrays.asList(MqttCommandStatusEnum.COMMAND_SEND.getKey()))
-                .le(MqttCommand::getTimeout, DataTime.getStringAround(0, 0, 0, 0, 0, (~(threshold - 1))));
+                .le(MqttCommand::getSendTime, DataTime.getStringAround(0, 0, 0, 0, threshold, 0));
         List<MqttCommand> mqttCommands = mqttCommandMapper.selectList(lambdaEsQueryWrapper);
         if (mqttCommands.size() == 0) {
             return ReturnT.SUCCESS;