分支自 ard/ruoyi-api
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
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)),"施封");


                            }


                        }