清淤

aijinhui

2023-12-14 c503c5d336b7219c1bff1f59b4176e4e49f2c3f2

清淤

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

@@ -466,11 +466,11 @@
//                            map.put("res", String.valueOf(System.currentTimeMillis()));
//                            String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                            String mapString = "{\"A01\":110000,\"A02\":110000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                            log.info("自动解封："+mapString);
                            log.debug("自动解封："+mapString);
                            EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                            emqClient.connect();
                            emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                            log.info("车辆"+carId+"解封命令发送成功！");
                            log.debug("车辆"+carId+"解封命令发送成功！");
                            //                mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"解封");
                        }
                    }
@@ -501,7 +501,7 @@
//                                    map.put("res", String.valueOf(System.currentTimeMillis()));
//                                    String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                                    String mapString = "{\""+key+"\":0.01,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                                    log.info("自动关锁："+mapString);
                                    log.debug("自动关锁："+mapString);
                                    EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                    emqClient.connect();
                                    emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
@@ -527,7 +527,7 @@
                                EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                emqClient.connect();
                                emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                                log.info("车辆"+carId+"施封命令发送成功！");
                                log.debug("车辆"+carId+"施封命令发送成功！");
                                //                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"施封");
                            }
                        }

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

@@ -258,7 +258,7 @@
//            map.put("res", String.valueOf(System.currentTimeMillis()));
//            String mapString = JSON.toJSONString(map);
            String mapString = "{\"A01\":110000,\"A02\":110000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
            log.info("解封："+mapString);
            log.debug("解封："+mapString);
            EmqClient emqClient = new EmqClient(rtuTypeParam.getCarId()+"mqttPublish"+UUID.randomUUID());
            emqClient.connect();
            emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
@@ -290,7 +290,7 @@
//                    map.put("res", String.valueOf(System.currentTimeMillis()));
//                    String mapString = JSON.toJSONString(map);
                    String mapString = "{\""+key+"\":0.01,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                    log.info("关锁："+mapString);
                    log.debug("关锁："+mapString);
                    EmqClient emqClient = new EmqClient(rtuTypeParam.getCarId()+"mqttPublish"+UUID.randomUUID());
                    emqClient.connect();
                    emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
@@ -355,7 +355,7 @@
//        map.put("res", String.valueOf(System.currentTimeMillis()));
//        String mapString = JSON.toJSONString(map);
        String mapString = "{\""+key+"\":"+lockState+",\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
        log.info("开关锁："+mapString);
        log.debug("开关锁："+mapString);
        EmqClient emqClient = new EmqClient(lockTypeParam.getCarId()+"mqttPublish"+UUID.randomUUID());
        emqClient.connect();
        emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);