From a8e38a794fa221d25b4b5d1d47f131419add63e4 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 12 十月 2023 18:16:24 +0800
Subject: [PATCH] aa
---
server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java | 135 +++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 129 insertions(+), 6 deletions(-)
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 acefe3f..b342df0 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
@@ -13,9 +13,7 @@
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
-import com.doumee.dao.business.ActionLogMapper;
-import com.doumee.dao.business.LocksMapper;
-import com.doumee.dao.business.MemberRidesMapper;
+import com.doumee.dao.business.*;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.dao.business.web.request.MemberRidesQuery;
@@ -49,6 +47,12 @@
@Autowired
private MemberRidesMapper memberRidesMapper;
@Autowired
+ private HolidaysMapper holidaysMapper;
+ @Autowired
+ private PricingParamMapper pricingParamMapper;
+ @Autowired
+ private PricingDetailMapper pricingDetailMapper;
+ @Autowired
private ActionLogMapper actionLogMapper;
@Autowired
@@ -59,6 +63,10 @@
@Autowired
private LocksMapper locksMapper;
+ @Autowired
+ private SitesMapper sitesMapper;
+ @Autowired
+ private BikesMapper bikesMapper;
@Autowired
private GoodsorderService goodsorderService;
@@ -111,7 +119,7 @@
@Override
public MemberRides findOne(MemberRides memberRides) {
QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(memberRides);
- return memberRidesMapper.selectOne(wrapper);
+ return memberRidesMapper.selectOne(wrapper.last(" limit 1"));
}
@Override
@@ -366,8 +374,8 @@
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀛樺湪楠戣涓溅杈嗭紝鏃犳硶鎵爜");
};
Locks locks = locksMapper.selectOne(new QueryWrapper<Locks>().eq("code",code).eq("isdeleted", Constants.ZERO).last("limit 1"));
- Boolean flag = deviceService.openLock(locks);
- if(!flag){
+ MqttLog flag = deviceService.openLock(locks);
+ if(flag.getResult() == 0){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"寮�閿佸け璐�");
}
//瀛樺偍楠戣璁板綍
@@ -397,4 +405,119 @@
return memberRidesDetailResponse;
}
+
+ /**
+ * 閿佸ご淇℃伅涓婃姤
+ * @param locks
+ * @return
+ */
+ @Override
+ public int mqttLockInfoEvent(Locks locks){
+ //鍒ゆ柇妫�鏌ュ鐞嗙珯鐐归攣澶翠俊鎭�
+ Locks model = dealLockAndSite(locks);
+ //杞﹁締璁板綍
+ Bikes bikes = dealBikesByParam(model);
+
+ //鐘舵�侊紝0闂悎, 1鎵撳紑锛�2杩愯涓�, 3寮傚父
+ if(model.getStatus() == Constants.LockStatus.open){
+ //濡傛灉鏄紑閿佷笟鍔★紝鍒ゆ柇鏄惁鏈夊紑閿佷腑鐨勪俊鎭�
+ MemberRides memberRides = new MemberRides();
+ memberRides.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING.getKey());
+ memberRides.setRentLockId(model.getId());
+ memberRides.setIsdeleted(Constants.ZERO);
+ memberRides = findOne(memberRides);
+ if(memberRides == null){
+ return 0;
+ }
+
+ //锛堟洿鏂拌姹傚紑閿佷腑鐨勯攣澶村叧鑱旂殑楠戣璁板綍锛�
+ memberRidesMapper.updateById( memberRides);
+ }
+ return 0;
+ }
+
+ private Bikes dealBikesByParam(Locks model) {
+ QueryWrapper<Bikes> wrapper = new QueryWrapper<>();
+ wrapper.lambda().eq(Bikes::getLockId, model.getId());
+ wrapper.lambda().eq(Bikes::getSiteId, model.getSiteId());
+ Bikes bikes = bikesMapper.selectOne(wrapper.last("last 1"));
+ if(bikes != null ) {
+ if ( StringUtils.equals(model.getBikeCode(), bikes.getCode())){
+ //濡傛灉缁戝畾杞﹁締淇℃伅鍙戠敓缂栧彿锛屾洿鎹㈢粦瀹氬叧绯�
+ UpdateWrapper<Bikes> updateWrapper = new UpdateWrapper<>();
+ updateWrapper.lambda().set(Bikes::getId, bikes.getId());
+ updateWrapper.lambda().set(Bikes::getCode,model.getBikeCode());
+ updateWrapper.lambda().set(Bikes::getParamId,getBileTypeByCode(model.getBikeCode()));
+ //鏇存柊鑷绔欑偣閿佸ご缁戝畾鑷杞︿俊鎭�
+ bikesMapper.updateById(bikes);
+ }
+ }else{
+ bikes = new Bikes();
+ bikes.setId(Constants.getUUID());
+ bikes.setIsdeleted(Constants.ZERO);
+ bikes.setCreateDate(new Date());
+ bikes.setSiteId(model.getSiteId());
+ bikes.setLockId(model.getId());
+ bikes.setCode(model.getBikeCode());
+ bikes.setParamId(getBileTypeByCode(model.getBikeCode()));
+ bikesMapper.insert(bikes);
+ }
+ return bikes;
+
+ }
+
+ //TODO-----JP------------鏍规嵁杞﹁締code鍒嗘瀽杞﹁締绫诲瀷锛屽緟纭鏂规-------------------
+ private String getBileTypeByCode(String bikeCode) {
+ return null;
+ }
+
+ private Locks dealLockAndSite(Locks locks) {
+ Locks model = locksMapper.selectById(locks.getId());
+ Date date =new Date();
+ //妫�鏌ョ珯鐐逛俊鎭紝涓嶅瓨鍦ㄥ垯鏂板
+ Sites sites = sitesMapper.selectById(locks.getSiteId());
+ if(sites == null){
+ sites = new Sites();
+ sites.setIsdeleted(Constants.ZERO);
+ sites.setCode(locks.getSiteId());
+ sites.setId(locks.getSiteId());
+ sites.setCreateDate(date);
+ sites.setStatus(Constants.ZERO);
+ sites.setLockNum(1);
+ //鏂板閿佸ご
+ sitesMapper.insert(sites);
+ }
+
+ if(model == null){
+ //濡傛灉閿佸ご涓嶅瓨鍦紝鍒ゆ柇瀛樺偍
+ model = new Locks();
+ model.setId(locks.getId());
+ model.setSiteId(locks.getSiteId());
+ model.setIsdeleted(Constants.ZERO);
+ model.setCode(locks.getCode());
+ model.setSiteId(locks.getSiteId());
+ model.setBikeCode(locks.getBikeCode());
+ model.setCreateDate(date);
+ model.setStatus(locks.getStatus());
+ locksMapper.insert(model);
+ }else{
+ model.setSiteId(locks.getSiteId());
+ model.setIsdeleted(Constants.ZERO);
+ model.setCode(locks.getCode());
+ model.setId(locks.getSiteId());
+ model.setEditDate(date);
+ model.setBikeCode(locks.getBikeCode());
+ model.setStatus(locks.getStatus());
+ locksMapper.update(null, new QueryWrapper<>(model));
+
+ }
+ model.setSites(sites);
+ return model;
+ }
+
+ @Override
+ public int mqttCloseBikeEvent(MemberRides bikes){
+ return 0;
+
+ }
}
--
Gitblit v1.9.3