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