开关锁

aijinhui

2024-01-14 e9582af916d019c4695b0aaf9665039be1bd6ea1

开关锁

 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java

@@ -80,7 +80,7 @@
            /*String carName = MapUtil.getStrVal(gpsMap, "carName","");//获取车牌号
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            System.out.println(sdf.format(new Date()));*/
            log.debug(String.format("   ---->收到定位数据:%s",JSON.toJSONString(gpsMap)));
            log.debug(String.format("   ---->----收到定位数据如下:%s",JSON.toJSONString(gpsMap)));
            String carId = (String)gpsMap.get("carId");
            ((ArdSyCarDayServiceImpl)SpringUtils.getBean("ardSyCarDayServiceImpl")).insertArdSyCarDay(carId);//新增车辆上报时间
            Map<String,Object> result = ((ArdSyCarServiceImpl)SpringUtils.getBean("ardSyCarServiceImpl")).getArdSyCarAndDeptByCarId(carId);//查询车辆及部门

 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java

@@ -375,15 +375,17 @@
//        MqttCustomerClient mqttCustomerClient = new MqttCustomerClient();
//        mqttCustomerClient.connect(lockTypeParam.getCarId()+"change"+UUID.randomUUID());
//        mqttCustomerClient.pushlish(ardSyCarRtu.getTopicPublish(),mapString);
        try {
            while(true){
                TimeUnit.SECONDS.sleep(5);
        int min = lockTypeParam.getNum() -5;  int max = lockTypeParam.getNum() +5;
        while(true){
            ArdSyCarLock ardSyCarLockLoop = lockMapper.selectById(lockTypeParam.getLockId());
            Double currentInfo =  ardSyCarLockLoop.getCurrentInfo();
            int d = (int) ((int)(currentInfo*150/138.3 - 4)/0.16);
            if(d >= min && d <= max){
                break;
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
//                TimeUnit.SECONDS.sleep(5);
        }
        return AjaxResult.success("开关锁命令发送成功,发送进度为"+lockTypeParam.getNum());
        return AjaxResult.success("开关锁成功,进度为"+lockTypeParam.getNum());
    }

    @Override

 ard-work/src/main/java/com/ruoyi/utils/qymqtt/AutoMqtt.java

@@ -36,7 +36,7 @@
                EmqClient emqClient = new EmqClient(carId+"mqttSubscribe"+UUID.randomUUID());
                emqClient.connect();
                emqClient.subscribe(subscribe, QosEnum.QoS2);
                log.info("订阅主题："+subscribe);
                log.debug("订阅主题："+subscribe);
            }catch (Exception e) {
                e.printStackTrace();
            }