From 77eaafed3ddf06929a7ed04f50197fac982f2c46 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 10 十月 2023 16:48:12 +0800
Subject: [PATCH] Merge branch 'dev' of http://139.186.142.91:10010/r/productDev/parkBike into dev
---
server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java | 1
server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java | 71 +++++++++++
server/web/src/main/java/com/doumee/api/web/BusinessApi.java | 32 +++++
server/services/src/main/java/com/doumee/service/business/GoodsorderService.java | 15 ++
server/services/src/main/java/com/doumee/service/business/MemberRidesService.java | 15 ++
server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java | 143 +++++++++++++++++++++--
server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesDetailResponse.java | 25 ++++
server/services/src/main/java/com/doumee/dao/business/web/request/RefundDTO.java | 4
8 files changed, 288 insertions(+), 18 deletions(-)
diff --git a/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java b/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java
index 295eb7e..c8cbce4 100644
--- a/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java
+++ b/server/services/src/main/java/com/doumee/core/wx/WxMiniUtilService.java
@@ -61,6 +61,7 @@
refund.setType(refundDTO.getType());
refund.setObjId(refundDTO.getOrderId());
refund.setReason(refundDTO.getReason());
+ refund.setCanBalance(refundDTO.getCanBalance());
refundMapper.insert(refund);
//瀛樺偍浜ゆ槗娴佹按琛�
Transactions transactions = new Transactions();
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/request/RefundDTO.java b/server/services/src/main/java/com/doumee/dao/business/web/request/RefundDTO.java
index 9f14775..97260fd 100644
--- a/server/services/src/main/java/com/doumee/dao/business/web/request/RefundDTO.java
+++ b/server/services/src/main/java/com/doumee/dao/business/web/request/RefundDTO.java
@@ -24,6 +24,10 @@
@ApiModelProperty(value = "璁㈠崟鎬婚噾棰濓紙鍒嗭級")
private BigDecimal totalAmount;
+
+ @ApiModelProperty(value = "鍙��閲戦锛堝垎锛�")
+ private BigDecimal canBalance;
+
@ApiModelProperty(value = "鐢ㄦ埛涓婚敭")
private String memberId;
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesDetailResponse.java b/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesDetailResponse.java
new file mode 100644
index 0000000..78b7566
--- /dev/null
+++ b/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesDetailResponse.java
@@ -0,0 +1,25 @@
+package com.doumee.dao.business.web.response;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * Created by IntelliJ IDEA.
+ *
+ * @Author : Rk
+ * @create 2023/10/10 11:39
+ */
+@Data
+@ApiModel("楠戣璁板綍鐘舵�佷俊鎭繑鍥炵被")
+public class MemberRidesDetailResponse {
+
+
+ @ApiModelProperty(value = "楠戣璁板綍涓婚敭")
+ private String id;
+
+ @ApiModelProperty(value = "楠戣璁板綍鐘舵�� 0璇锋眰寮�閿佷腑 1楠戣涓� 2宸茶繕杞� 3寮�閿佸け璐�")
+ private Integer status;
+
+
+}
diff --git a/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java b/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
index 4568275..5dc8652 100644
--- a/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
+++ b/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
@@ -1,6 +1,7 @@
package com.doumee.service.business;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.business.model.Bikes;
@@ -153,5 +154,19 @@
GoodsorderTotalDataVO getTotalData(Goodsorder pageWrap);
+ /**
+ * 楠岃瘉鏄惁涓鸿惀涓氭椂闂�
+ */
+ void checkBusiness();
+
+ /**
+ * 楠岃瘉鏄惁澶勪簬鍋滄杩愯惀鏃堕棿
+ */
+ void checkTemporaryStop();
+
+ Goodsorder findOneByWrapper(QueryWrapper<Goodsorder> wrapper);
+
List<GoodsorderExportVO> findExportNotBikPage(Goodsorder model);
+
+ void goodsOrderSettlement(String orderId);
}
diff --git a/server/services/src/main/java/com/doumee/service/business/MemberRidesService.java b/server/services/src/main/java/com/doumee/service/business/MemberRidesService.java
index 6e19a55..985fd51 100644
--- a/server/services/src/main/java/com/doumee/service/business/MemberRidesService.java
+++ b/server/services/src/main/java/com/doumee/service/business/MemberRidesService.java
@@ -6,6 +6,7 @@
import com.doumee.dao.business.web.request.MemberRidesQuery;
import com.doumee.dao.business.web.response.BikeLogDTO;
import com.doumee.dao.business.web.response.MemberRidesDTO;
+import com.doumee.dao.business.web.response.MemberRidesDetailResponse;
import java.util.List;
@@ -115,6 +116,20 @@
*/
String getOnlineBike(String memberId);
+ /**
+ * 鎵爜瑙i攣
+ * @param code
+ * @param memberId
+ * @return
+ */
+ MemberRidesDetailResponse openLock(String code, String memberId);
+
+ /**
+ * 鍒锋柊瑙i攣鎯呭喌
+ * @param id
+ * @return
+ */
+ MemberRidesDetailResponse refreshLock(String id);
void updateDuration(MemberRides memberRides);
void forceBack(MemberRides memberRides);
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
index 9af2579..28599f9 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
@@ -16,6 +16,7 @@
import com.doumee.core.utils.ID;
import com.doumee.core.utils.Utils;
import com.doumee.core.wx.WxMiniConfig;
+import com.doumee.core.wx.WxMiniUtilService;
import com.doumee.dao.business.*;
import com.doumee.dao.business.MemberRidesMapper;
import com.doumee.dao.business.join.GoodsorderJoinMapper;
@@ -25,6 +26,7 @@
import com.doumee.dao.business.model.MemberRides;
import com.doumee.dao.business.vo.GoodsorderExportVO;
import com.doumee.dao.business.vo.GoodsorderTotalDataVO;
+import com.doumee.dao.business.web.request.RefundDTO;
import com.doumee.dao.business.web.response.*;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
import com.doumee.dao.business.model.*;
@@ -40,6 +42,7 @@
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@@ -88,6 +91,9 @@
@Autowired
private TransactionsMapper transactionsMapper;
+
+ @Autowired
+ private WxMiniUtilService wxMiniUtilService;
@Autowired
PricingRuleService pricingRuleService;
@@ -140,6 +146,11 @@
@Override
public Goodsorder findOne(Goodsorder goodsorder) {
QueryWrapper<Goodsorder> wrapper = new QueryWrapper<>(goodsorder);
+ return goodsorderMapper.selectOne(wrapper);
+ }
+
+ @Override
+ public Goodsorder findOneByWrapper(QueryWrapper<Goodsorder> wrapper) {
return goodsorderMapper.selectOne(wrapper);
}
@@ -492,24 +503,9 @@
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"宸叉敮浠樿繃瀹氶噾锛屾棤娉曢噸澶嶈鎿嶄綔");
}
//鏄惁澶勪簬灏忕▼搴忓仠姝㈡湇鍔℃椂闂村唴
- if(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.IS_STOP_SERVE).getCode().equals(Constants.ONE)){
- String stopServeStartTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_STARTTIME).getCode();
- String stopServeEndTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_ENDTIME).getCode();
- //鏌ヨ褰撳墠鏃堕棿鏄惁鍦ㄥ仠姝腑
- long s = DateUtil.StringToDate(stopServeStartTime).getTime();
- long e = DateUtil.StringToDate(stopServeEndTime).getTime();
- if(e>System.currentTimeMillis()&&s<=System.currentTimeMillis()){
- throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠灏忕▼搴忓仠姝㈡湇鍔★紝璇锋敞鎰忔煡鐪嬪叕鍛�");
- }
- }
+ this.checkTemporaryStop();
//鏄惁澶勪簬钀ヤ笟鏃堕棿
- String businessStartTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_STARTTIME).getCode();
- String businessEndTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_ENDTIME).getCode();
- String nowTime = DateUtil.getDate(new Date(),"HH:mm");
- if(Integer.valueOf(nowTime.replace(":",""))<= Integer.valueOf(businessStartTime.replace(":",""))
- ||Integer.valueOf(nowTime.replace(":","")) > Integer.valueOf(businessEndTime.replace(":",""))){
- throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠鏃堕棿鏆傛湭钀ヤ笟鏈嶅姟锛岃娉ㄦ剰鏌ョ湅钀ヤ笟鏃堕棿");
- }
+ this.checkBusiness();
Goodsorder goodsorder = new Goodsorder();
goodsorder.setId(Constants.getUUID());
goodsorder.setCreateDate(new Date());
@@ -541,6 +537,119 @@
}
}
+ /**
+ * 楠岃瘉钀ヤ笟鏃堕棿
+ */
+ @Override
+ public void checkBusiness(){
+ String businessStartTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_STARTTIME).getCode();
+ String businessEndTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_ENDTIME).getCode();
+ String nowTime = DateUtil.getDate(new Date(),"HH:mm");
+ if(Integer.valueOf(nowTime.replace(":",""))<= Integer.valueOf(businessStartTime.replace(":",""))
+ ||Integer.valueOf(nowTime.replace(":","")) > Integer.valueOf(businessEndTime.replace(":",""))){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠鏃堕棿鏆傛湭钀ヤ笟鏈嶅姟锛岃娉ㄦ剰鏌ョ湅钀ヤ笟鏃堕棿");
+ }
+ }
+
+ /**
+ * 涓存椂鍋滄鏈嶅姟 鏈氦鎶奸噾鐨勭敤鎴凤紝鏃犳硶鎵溅浣跨敤锛涘凡缁忎氦杩囨娂閲戠殑鐢ㄦ埛鍙互缁х画鎵爜楠戣锛�
+ */
+ @Override
+ public void checkTemporaryStop(){
+ if(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.IS_STOP_SERVE).getCode().equals(Constants.ONE)){
+ String stopServeStartTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_STARTTIME).getCode();
+ String stopServeEndTime = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_ENDTIME).getCode();
+ //鏌ヨ褰撳墠鏃堕棿鏄惁鍦ㄥ仠姝腑
+ long s = DateUtil.StringToDate(stopServeStartTime).getTime();
+ long e = DateUtil.StringToDate(stopServeEndTime).getTime();
+ if(e>System.currentTimeMillis()&&s<=System.currentTimeMillis()){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠灏忕▼搴忓仠姝㈡湇鍔★紝璇锋敞鎰忔煡鐪嬪叕鍛�");
+ }
+ }
+ }
+
+
+
+ @Override
+ @Transactional(rollbackFor = {Exception.class,BusinessException.class})
+ public void goodsOrderSettlement(String orderId) {
+ Goodsorder goodsorder = goodsorderMapper.selectById(orderId);
+ QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
+ wrapper.lambda().eq(MemberRides::getOrdreId,orderId);
+ List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper);
+ if (!CollectionUtils.isEmpty(memberRides)){
+ boolean exitUnBack = memberRides.stream().anyMatch(s -> !Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey().equals(s.getStatus()));
+ if (exitUnBack){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璁㈠崟鏈夋湭瀹屾垚鐨勯獞琛岋紝鏃犳硶寮哄埗缁撶畻");
+ }
+ PricingRuleDTO pricingRule = pricingRuleService.getPricingRule(memberRides);
+ RidesDetailResponse ridesDetailResponse = new RidesDetailResponse();
+ List<MemberRidesResponse> collect = memberRides.stream().map(s -> {
+ MemberRidesResponse memberRidesResponse = new MemberRidesResponse();
+ memberRidesResponse.setRideStartTime(s.getRentDate());
+ memberRidesResponse.setRideEndTime(s.getBackDate());
+ memberRidesResponse.setRideTime(DateUtil.betweenMin(memberRidesResponse.getRideStartTime(), memberRidesResponse.getRideEndTime()));
+ memberRidesResponse.setDuration(s.getDuration());
+ memberRidesResponse.setBikeType(s.getParamName());
+ memberRidesResponse.setBikeCode(s.getBikeCode());
+ memberRidesResponse.setBasePrice(s.getBasePrice());
+ memberRidesResponse.setBaseTime(s.getBaseTime());
+ memberRidesResponse.setUnitPrice(s.getUnitTime());
+ memberRidesResponse.setUnitTime(s.getUnitTime());
+ return memberRidesResponse;
+ }).collect(Collectors.toList());
+
+ Integer durationSum = memberRides.stream().filter(s -> s.getDuration() > 0).mapToInt(s -> s.getDuration()).sum();
+ if (durationSum > pricingRule.getMemberRides().getBaseTime()){
+ BigDecimal basePrice = pricingRule.getMemberRides().getBasePrice();
+ BigDecimal multiply = pricingRule.getMemberRides().getUnitPrice().multiply(new BigDecimal((durationSum - pricingRule.getMemberRides().getBaseTime())).divide(new BigDecimal(pricingRule.getMemberRides().getUnitTime())).setScale(0,BigDecimal.ROUND_CEILING));
+ ridesDetailResponse.setAmount(basePrice.add(multiply));
+ }else {
+ ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
+ }
+ ridesDetailResponse.setBikeType(pricingRule.getBikeType());
+ ridesDetailResponse.setDuration(durationSum);
+ ridesDetailResponse.setMemberRidesResponseList(collect);
+
+ RefundDTO refundDTO = new RefundDTO();
+ refundDTO.setOrderId(orderId);
+ refundDTO.setCanBalance(goodsorder.getMoney());
+ refundDTO.setRefundAmount(goodsorder.getMoney().subtract(ridesDetailResponse.getAmount()));
+ refundDTO.setTotalAmount(goodsorder.getMoney());
+ refundDTO.setMemberId(goodsorder.getMemberId());
+ refundDTO.setReason("鐢ㄦ埛涓诲姩閫�娆�");
+ refundDTO.setType(Constants.REFUND_TYPE.NORMAL.getKey());
+ Refund refund = wxMiniUtilService.wxRefund(refundDTO);
+ //瀛樺偍 娑堣垂 浜ゆ槗娴佹按
+
+ Transactions transactions = new Transactions();
+ transactions.setMemberId(refundDTO.getMemberId());
+ transactions.setCreateDate(new Date());
+ transactions.setIsdeleted(Constants.ZERO);
+ transactions.setOrderId(refundDTO.getOrderId());
+ transactions.setMoney(ridesDetailResponse.getAmount());
+ transactions.setType(Constants.transactionsType.consumption);
+ transactions.setDoneDate(new Date());
+ transactions.setTitle("娑堣垂缁撶畻");
+ transactions.setContent("缁撶畻瀹為檯娑堣垂");
+ transactions.setBalance(BigDecimal.ZERO);
+ transactions.setObjId(refund.getId());
+ transactions.setObjType(Constants.ONE);
+ transactionsMapper.insert(transactions);
+
+ Goodsorder update = new Goodsorder();
+ update.setId(goodsorder.getId());
+ update.setStatus(Constants.GOODSORDER_STATUS.CLOSE.getKey());
+ update.setCloseMoney(goodsorder.getMoney().subtract(ridesDetailResponse.getAmount()));
+ update.setCloseId(refund.getId());
+ update.setCloseDate(refund.getDoneDate());
+ update.setCloseInfo(refund.getInfo());
+ update.setCloseType(Constants.ONE);
+ goodsorderMapper.updateById(update);
+ }
+ }
+
+
@Override
public String payNotify(String preOrderId,String paymentNo){
Goodsorder goodsorder = this.goodsorderMapper.selectById(preOrderId);
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 2d9fb70..4d3dffc 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
@@ -4,19 +4,30 @@
import com.doumee.core.constants.Constants;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
+import com.doumee.dao.business.GoodsorderMapper;
+import com.doumee.dao.business.LocksMapper;
import com.doumee.dao.business.ActionLogMapper;
import com.doumee.dao.business.MemberRidesMapper;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
import com.doumee.dao.business.model.*;
+import com.doumee.dao.business.model.BaseParam;
+import com.doumee.dao.business.model.Goodsorder;
+import com.doumee.dao.business.model.Member;
+import com.doumee.dao.business.model.MemberRides;
+import com.doumee.dao.business.model.*;
import com.doumee.dao.business.web.request.MemberRidesQuery;
import com.doumee.dao.business.web.response.BikeLogDTO;
import com.doumee.dao.business.web.response.MemberRidesDTO;
+import com.doumee.dao.business.web.response.MemberRidesDetailResponse;
import com.doumee.service.business.DeviceService;
+import com.doumee.service.business.GoodsorderService;
import com.doumee.service.business.MemberRidesService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -25,6 +36,8 @@
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
+import org.checkerframework.checker.units.qual.C;
+import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -48,12 +61,17 @@
@Autowired
private ActionLogMapper actionLogMapper;
-
@Autowired
private MemberRidesJoinMapper memberRidesJoinMapper;
@Autowired
private DeviceService deviceService;
+
+ @Autowired
+ private LocksMapper locksMapper;
+
+ @Autowired
+ private GoodsorderService goodsorderService;
@Override
public String create(MemberRides memberRides) {
@@ -326,7 +344,58 @@
}
+ @Override
+ public MemberRidesDetailResponse openLock(String code,String memberId){
+ //鍒ゆ柇褰撳墠鏄惁宸叉敮浠樻娂閲�
+ Goodsorder goodsorder = goodsorderService.findOneByWrapper(new QueryWrapper<Goodsorder>()
+ .eq("isdeleted",Constants.ZERO)
+ .eq("status",Constants.goodsorderStatus.pay)
+ .eq("member_id",memberId)
+ .orderByDesc("create_date")
+ .last("limit 1"));
+ if(Objects.isNull(goodsorder)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈敮浠樻娂閲戯紝鏃犳硶杩涜璇ユ搷浣滐紒");
+ }
+ //鍒ゆ柇褰撳墠鎶奸噾璁㈠崟鏄惁涓轰粖鏃ユ娂閲�
+ if(!DateUtil.DateToStr(goodsorder.getPayDate(),"yyyy-MM-dd").equals(DateUtil.getDate(new Date(),"yyyy-MM-dd"))){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炰粖鏃ユ娂閲戣鍗曪紝璇风粨绠楀悗閲嶆柊鏀粯锛�");
+ }
+ //鍒ゆ柇鏄惁澶勪簬钀ヤ笟鏃堕棿
+ goodsorderService.checkBusiness();
+ //鏌ヨ鏄惁澶勪簬楠戣涓�
+ if(memberRidesMapper.selectCount(new QueryWrapper<MemberRides>().eq("member_id",memberId).in("status",0,1))>Constants.ZERO){
+ 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){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"寮�閿佸け璐�");
+ }
+ //瀛樺偍楠戣璁板綍
+ MemberRides memberRides = new MemberRides();
+ memberRides.setIsdeleted(Constants.ZERO);
+ memberRides.setMemberId(memberId);
+ memberRides.setCreateDate(new Date());
+ memberRides.setRentSiteId(locks.getSiteId());
+ memberRides.setRentLockId(locks.getId());
+ memberRides.setStatus(Constants.MEMBER_RIDES_STATUS.LOCKING.getKey());
+ memberRidesMapper.insert(memberRides);
+ MemberRidesDetailResponse memberRidesDetailResponse = new MemberRidesDetailResponse();
+ BeanUtils.copyProperties(memberRides,memberRidesDetailResponse);
+ return memberRidesDetailResponse;
+ }
+ @Override
+ public MemberRidesDetailResponse refreshLock(String id){
+ MemberRides memberRides = memberRidesMapper.selectById(id);
+ if(Objects.isNull(memberRides)){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ MemberRidesDetailResponse memberRidesDetailResponse = new MemberRidesDetailResponse();
+ BeanUtils.copyProperties(memberRides,memberRidesDetailResponse);
+ return memberRidesDetailResponse;
+
+ }
}
diff --git a/server/web/src/main/java/com/doumee/api/web/BusinessApi.java b/server/web/src/main/java/com/doumee/api/web/BusinessApi.java
index 9ca214a..0b481b2 100644
--- a/server/web/src/main/java/com/doumee/api/web/BusinessApi.java
+++ b/server/web/src/main/java/com/doumee/api/web/BusinessApi.java
@@ -11,6 +11,7 @@
import com.doumee.dao.business.model.RentSite;
import com.doumee.dao.business.model.Transactions;
import com.doumee.dao.business.web.request.RepairRequest;
+import com.doumee.dao.business.web.response.MemberRidesDetailResponse;
import com.doumee.dao.business.web.response.RidesDetailResponse;
import com.doumee.service.business.*;
import io.swagger.annotations.Api;
@@ -141,9 +142,40 @@
}
+ @LoginRequired
+ @ApiOperation(value = "鎵爜瑙i攣", notes = "灏忕▼搴忕")
+ @GetMapping("/openLock")
+ @ApiImplicitParams({
+ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "鐢ㄦ埛token鍊�", required = true),
+ @ApiImplicitParam(paramType = "query", dataType = "String", name = "code", value = "閿佸ご鐮�", required = true)
+ })
+ public ApiResponse<MemberRidesDetailResponse> openLock(@RequestParam String code) {
+ return ApiResponse.success("鎿嶄綔鎴愬姛",memberRidesService.openLock(code,getMemberId()));
+ }
+ @LoginRequired
+ @ApiOperation(value = "鍒锋柊瑙i攣鎯呭喌", notes = "灏忕▼搴忕")
+ @GetMapping("/refreshLock")
+ @ApiImplicitParams({
+ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "鐢ㄦ埛token鍊�", required = true),
+ @ApiImplicitParam(paramType = "query", dataType = "String", name = "id", value = "楠戣璁板綍涓婚敭", required = true)
+ })
+ public ApiResponse<MemberRidesDetailResponse> refreshLock(@RequestParam String id) {
+ return ApiResponse.success("鎿嶄綔鎴愬姛",memberRidesService.refreshLock(id));
+ }
+ @LoginRequired
+ @ApiOperation(value = "璁㈠崟缁撶畻", notes = "灏忕▼搴忕")
+ @GetMapping("/goodsOrderSettlement")
+ @ApiImplicitParams({
+ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "鐢ㄦ埛token鍊�", required = true),
+ @ApiImplicitParam(paramType = "query", dataType = "String", name = "orderId", value = "璁㈠崟涓婚敭", required = true)
+ })
+ public ApiResponse goodsOrderSettlement(@RequestParam String orderId) {
+ goodsorderService.goodsOrderSettlement(orderId);
+ return ApiResponse.success("鎿嶄綔鎴愬姛");
+ }
}
--
Gitblit v1.9.3