From b52604d53c7568a522f2e0b471a72dbcd4d022fe Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期五, 03 十一月 2023 08:49:48 +0800
Subject: [PATCH] 硬件协议对接
---
server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java | 10 ++++++++--
server/services/src/main/java/com/doumee/service/business/impl/DeviceSubscribeServiceImpl.java | 1 +
server/services/src/main/java/com/doumee/core/constants/Constants.java | 2 +-
3 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/server/services/src/main/java/com/doumee/core/constants/Constants.java b/server/services/src/main/java/com/doumee/core/constants/Constants.java
index d2c5bba..58c5639 100644
--- a/server/services/src/main/java/com/doumee/core/constants/Constants.java
+++ b/server/services/src/main/java/com/doumee/core/constants/Constants.java
@@ -35,7 +35,7 @@
public static final String FORCE_BACK_LOCK = "FORCE_BACK_LOCK";
public static final String FORCE_BACK_SITE = "FORCE_BACK_SITE";
//杞﹁締绫诲瀷鏁版嵁
- public static final String BIKE_TYPE ="1,2,3,4,5,6,7,8" ;
+ public static final String BIKE_TYPE ="0,1,2,3,4,5,6,7,8" ;
public static String REDIS_DEBUG_STR="test_";
public static final String AD = "AD";
public static String REPAIR = "REPAIR";
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 0b483c2..040e773 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
@@ -104,6 +104,7 @@
bikes.setBackLockId( lockid);
bikes.setBackSiteId( siteid);
bikes.setBackCommondId(logId);
+ bikes.setStatus(pjson.getInteger("status"));
result = memberRidesService.mqttCloseBikeEvent(bikes);
logInfo = "mqtt娑堟伅璁㈤槄杩樿溅娑堟伅";
log.info("mqtt娑堟伅璁㈤槄=========杩樿溅==========鎴愬姛");
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
index 6126046..16e2496 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
@@ -584,7 +584,7 @@
//杞﹁締璁板綍
Bikes bikes = dealBikesByParam(model);
//鐘舵�侊紝0闂悎, 1鎵撳紑锛�2杩愯涓�, 3寮傚父
- if(model.getStatus() == Constants.LockStatus.open){
+ if(locks.getStatus() == Constants.LockStatus.open){
//濡傛灉鏄紑閿佷笟鍔★紝鍒ゆ柇鏄惁鏈夊紑閿佷腑鐨勪俊鎭�
MemberRides memberRides = new MemberRides();
memberRides.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING.getKey());
@@ -644,12 +644,15 @@
if(bikes != null ) {
if ( !StringUtils.equals(model.getBikeCode(), bikes.getCode())){
//濡傛灉缁戝畾杞﹁締淇℃伅鍙戠敓缂栧彿锛屾洿鎹㈢粦瀹氬叧绯�
+ String type =getBileTypeByCode(model.getBikeCode());
UpdateWrapper<Bikes> updateWrapper = new UpdateWrapper<>();
updateWrapper.lambda().eq(Bikes::getId, bikes.getId());
updateWrapper.lambda().set(Bikes::getCode,model.getBikeCode());
- updateWrapper.lambda().set(Bikes::getParamId,getBileTypeByCode(model.getBikeCode()));
+ updateWrapper.lambda().set(Bikes::getParamId,type);
//鏇存柊鑷绔欑偣閿佸ご缁戝畾鑷杞︿俊鎭�
bikesMapper.update(null,updateWrapper);
+ bikes.setCode(model.getBikeCode());
+ bikes.setParamId(model.getBikeType());
}
}else{
bikes = new Bikes();
@@ -751,6 +754,8 @@
updateWrapper.lambda().set(Locks::getEditDate, new Date() );
updateWrapper.lambda().set(Locks::getIsdeleted, Constants.ZERO);
locksMapper.update(null,updateWrapper);
+ model.setStatus(locks.getStatus());
+ model.setBikeCode(locks.getBikeCode());
}
model.setSites(sites);
return model;
@@ -769,6 +774,7 @@
locks.setCode(bikes.getBackLockId());
locks.setBikeCode(bikes.getBikeCode());
locks.setInfo(bikes.getBackCommondId());
+ locks.setStatus(bikes.getStatus());
//澶勭悊閿佸ご鏁版嵁
mqttLockInfoEvent(locks);
//鍏嶈垂楠戣鏃堕暱鏌ヨ锛屾暟鎹瓧鍏搁厤缃�
--
Gitblit v1.9.3