温度设置指令添加最高、最低预警值

device-api-service/src/main/java/com/xy/service/MqttServiceImpl.java

@@ -115,12 +115,11 @@ public class MqttServiceImpl extends ServiceImpl<MqttCommandMapper, MqttCommand>
         QueryWrapper<MqttCommand> wrapper = new QueryWrapper<MqttCommand>()
                 .select(String.format("max(%s) as %s", sn, sn));
         MqttCommand mqttCommand = getOne(wrapper);
-        if (mqttCommand == null) {
-            return;
+        if (mqttCommand != null) {
+            redisService.setAtomic(CommConsts.CMD_ATOM_SN, mqttCommand.getSn() + 1);
+            MqttCommand byId = getById(mqttCommand.getSn());
+            redisService.setAtomic(CommConsts.CMD_ATOM_WK_SN, byId.getWkSn() + 1);
         }
-        redisService.setAtomic(CommConsts.CMD_ATOM_SN, mqttCommand.getSn() + 1);
-        MqttCommand byId = getById(mqttCommand.getSn());
-        redisService.setAtomic(CommConsts.CMD_ATOM_WK_SN, byId.getWkSn() + 1);
         snInit = true;
     }