新添加设备订单超时时间间隔代码逻辑实现200231201wmz

wangmengzhao

2023-12-01 cbdf1e550c73c90c01ec0c792eb7bfe96dcc910f

 wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/controller/ToolController.java

@@ -30,6 +30,7 @@
import com.ruoyi.iot.util.VelocityInitializer;
import com.ruoyi.iot.util.VelocityUtils;
import com.ruoyi.system.service.ISysUserService;
import com.taosdata.jdbc.utils.OSUtils;
import io.jsonwebtoken.Claims;
import io.jsonwebtoken.Jwts;
import io.swagger.annotations.Api;
@@ -115,6 +116,15 @@
        return getDataTable(list);
    }

    /**
     * 授权
     *
     * @param clientid
     * @param username
     * @param password
     * @return
     * @throws Exception
     */
    @ApiOperation("mqtt认证")
    @PostMapping("/mqtt/auth")
    public ResponseEntity mqttAuth(@RequestParam String clientid, @RequestParam String username, @RequestParam String password) throws Exception {
@@ -173,6 +183,11 @@
    }


    /**
     * emqx发给后台消息处理方法
     *
     * @param model
     */
    @ApiOperation("mqtt钩子处理")
    @PostMapping("/mqtt/webhook")
    public void webHookProcess(@RequestBody MqttClientConnectModel model) {
@@ -188,7 +203,6 @@
            String deviceNumber = clientArray[1];
            Long productId = Long.valueOf(clientArray[2]);
            Long userId = Long.valueOf(clientArray[3]);

            Device device = deviceService.selectShortDeviceBySerialNumber(deviceNumber);
            // 设备状态（1-未激活，2-禁用，3-在线，4-离线）
            if (model.getAction().equals("client_disconnected")) {