From 98d0a71132915ab20f6d4ade6164a21aa16001ba Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期三, 13 十二月 2023 17:33:36 +0800
Subject: [PATCH] 飞机

---
 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java |   10 ++++++----
 ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java             |    4 ----
 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java         |    4 ++--
 3 files changed, 8 insertions(+), 10 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
index cb1de71..5f39186 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -78,7 +78,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.info(String.format("   ---->鏀跺埌瀹氫綅鏁版嵁:%s",JSON.toJSONString(gpsMap)));
+//            log.info(String.format("   ---->鏀跺埌瀹氫綅鏁版嵁:%s",JSON.toJSONString(gpsMap)));
             String carId = (String)gpsMap.get("carId");
 
             ((ArdSyCarDayServiceImpl)SpringUtils.getBean("ardSyCarDayServiceImpl")).insertArdSyCarDay(carId);//鏂板杞﹁締涓婃姤鏃堕棿
@@ -95,7 +95,7 @@
                     String carModel = (String) result.get("carModel");//鑾峰彇杞﹁締妯″瀷
                     Integer drct = (Integer) gpsMap.get("drct");//鑾峰彇杞﹁締妯″瀷
                     Integer speed = (Integer) gpsMap.get("speed");
-                    log.info("carId:"+carId+"lng:"+lng+"lat:"+lat);
+//                    log.info("carId:"+carId+"lng:"+lng+"lat:"+lat);
                     //瀹氫箟2缁寸┖闂�
                     Point2D.Double point = new Point2D.Double(Double.parseDouble(lng), Double.parseDouble(lat));
                     List<Point2D.Double> pts = new ArrayList<Point2D.Double>();
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java
index dca46eb..2eab8d3 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarLockServiceImpl.java
@@ -69,8 +69,8 @@
         ArdSyCarRtu ardSyCarRtu = new ArdSyCarRtu();
         ardSyCarRtu.setId(String.valueOf(UUID.randomUUID()));
         ardSyCarRtu.setCarId(addRtuParam.getCarId());
-        ardSyCarRtu.setTopicPublish("/p"+addRtuParam.getCarId()+"/");
-        ardSyCarRtu.setTopicSubscribe("/p"+addRtuParam.getCarId()+"/set/");
+        ardSyCarRtu.setTopicPublish("/p"+addRtuParam.getCarId()+"/set/");
+        ardSyCarRtu.setTopicSubscribe("/p"+addRtuParam.getCarId()+"/");
         ardSyCarRtu.setInstallType(addRtuParam.getInstallType());
         ardSyCarRtu.setUnloadType(addRtuParam.getUnloadType());
         int num = rtuMapper.insert(ardSyCarRtu);
@@ -324,8 +324,10 @@
         ArdSyCarRtu ardSyCarRtu = rtuMapper.selectOne(queryWrapper);
         ArdSyCarLock ardSyCarLock = lockMapper.selectById(lockTypeParam.getLockId());
         Integer relay = ardSyCarLock.getRelayInfo();
-        if(relay.equals("1")){
-            return AjaxResult.error(0,"璇ラ攣澶勪簬瑙e皝鐘舵��,杩滅▼鏃犳硶鎿嶆帶,璇峰厛鎵ц鏂藉皝鎿嶄綔!");
+        if(relay!=null){
+            if(relay.equals("1")){
+                return AjaxResult.error(0,"璇ラ攣澶勪簬瑙e皝鐘舵��,杩滅▼鏃犳硶鎿嶆帶,璇峰厛鎵ц鏂藉皝鎿嶄綔!");
+            }
         }
         String key = "";
         String currents = ardSyCarLock.getCurrents();
diff --git a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java
index 16452c5..2c0d40c 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/EmqClient.java
@@ -27,9 +27,6 @@
             this.mqttClient = new MqttClient(mqttUrl,clientId,mempersitence);//璁剧疆杩炴帴broker鐨刪ost鍙奵lientId
             this.messageCallback = new MessageCallback();
         } catch (MqttException e) {
-            System.out.println("鍒濆鍖栧鎴风mqttClient瀵硅薄澶辫触");
-            System.out.println("brokerUrl:"+mqttUrl);
-            System.out.println("clientId:"+clientId);
             e.getMessage();
         }
     }
@@ -42,7 +39,6 @@
         options.setUserName("admin");
         options.setPassword("xzx12345".toCharArray());
         options.setCleanSession(true);//璁剧疆涓轰复鏃朵細璇�
-
         mqttClient.setCallback(messageCallback);//璁剧疆鍥炶皟
 
         try {

--
Gitblit v1.9.3