From 680c2fc9d9f51961789dc3b6e029a82a3b6cfb28 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 17 十月 2023 10:53:13 +0800
Subject: [PATCH] 订阅

---
 server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java |    7 ++++---
 1 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java
index e4cda85..75517d7 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java
@@ -70,7 +70,8 @@
             if(StringUtils.contains(topic, info)){
                 //濡傛灉閿佸ご淇℃伅涓婃姤
                 Locks locks  = JSONObject.parseObject(param, Locks.class);
-                locks.setId(lockid);
+                locks.setSiteId(siteid);
+                locks.setCode(lockid);
                 locks.setInfo(logId);
                 result = memberRidesService.mqttLockInfoEvent(locks);
                 logInfo = "mqtt娑堟伅璁㈤槄閿佸ご淇℃伅";
@@ -81,8 +82,8 @@
                 JSONObject pjson  = JSONObject.parseObject(param);
                 MemberRides bikes = new MemberRides();
                 bikes.setBikeCode(pjson.getString("bikeCode"));
-                bikes.setBackLockId( pjson.getString("lockId"));
-                bikes.setBackSiteId( pjson.getString("siteId"));
+                bikes.setBackLockId( lockid);
+                bikes.setBackSiteId( siteid);
                 bikes.setBackCommondId(logId);
                 result = memberRidesService.mqttCloseBikeEvent(bikes);
                 logInfo = "mqtt娑堟伅璁㈤槄杩樿溅娑堟伅";

--
Gitblit v1.9.3