aijinhui
2023-12-15 4269d20178cfab9253aacac15e1c02905c192428
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -479,6 +479,11 @@
                if(fengType==0){
                    //锁开关状态
                    int lockCloseNum = 0;
                    String mapString1 = "{\"A01\":100000,\"A02\":100000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                    System.out.println("自动施封:"+mapString1);
                    EmqClient emqClient1 = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                    emqClient1.connect();
                    emqClient1.publish(ardSyCarRtu.getTopicPublish(),mapString1, QosEnum.QoS2,false);
                    //如果不是施封状态,则发送施封命令
                    if(ardSyCarLocks.get(0).getRelayInfo()!=null){
                        if(ardSyCarLocks.get(0).getRelayInfo()==1){
@@ -522,11 +527,6 @@
//                                map.put("A02", 100000);//断开第二路继电器
//                                map.put("res", String.valueOf(System.currentTimeMillis()));
//                                String mapString = com.alibaba.fastjson.JSON.toJSONString(map);
                                String mapString = "{\"A01\":100000,\"A02\":100000,\"res\":\""+String.valueOf(System.currentTimeMillis())+"\"}";
                                System.out.println("自动施封:"+mapString);
                                EmqClient emqClient = new EmqClient(carId+"mqttPublish"+UUID.randomUUID());
                                emqClient.connect();
                                emqClient.publish(ardSyCarRtu.getTopicPublish(),mapString, QosEnum.QoS2,false);
                                log.debug("车辆"+carId+"施封命令发送成功!");
                                //                    mqttOnce.publishCar(carId,ardSyCarRtu.getTopicPublish(),String.valueOf(new JSONObject(map)),"施封");
                            }