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