From e40a072541e1b31add7ed345e47adf61c49ecf4f Mon Sep 17 00:00:00 2001
From: jiaosong <jiaosong6760@dingtalk.com>
Date: 星期五, 13 十月 2023 09:05:39 +0800
Subject: [PATCH] #获取可退款信息

---
 server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java |  186 ++++++++++++++++++++++++++++------------------
 1 files changed, 113 insertions(+), 73 deletions(-)

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 72449ee..a1b7255 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
@@ -57,6 +57,8 @@
 import java.net.UnknownHostException;
 
 import java.sql.Ref;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -243,19 +245,23 @@
         homeResponse.setLeaseVideoUrl(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.RENT_TIPS_VIDEO).getCode());
         homeResponse.setPricingRules(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PRICING_RULE).getCode());
         homeResponse.setStopServeTips(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_TIPS).getCode());
-        homeResponse.setIsStopServe(Constants.ZERO);
+        homeResponse.setIsStopServe(this.checkTemporaryStop()?1:0);
+        homeResponse.setIsBusiness(this.checkBusiness()?0:1);
+        homeResponse.setUnBusinessTips("钀ヤ笟鏃堕棿涓�"+ systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_STARTTIME).getCode() +" ~ "+systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_ENDTIME).getCode()+"锛岃鍦ㄨ惀涓氭椂闂村唴浣跨敤鏈郴缁�");
         homeResponse.setAdList(adMapper.selectList(new QueryWrapper<Ad>()
                 .eq("isdeleted",Constants.ZERO)
                 .eq("status",Constants.ZERO)
                 .orderByDesc("create_date")
-        ));
-        //鏌ヨ鏄惁瀛樺湪 宸叉敮浠樼殑 鎶奸噾璁㈠崟
-        Integer status = this.goodsorderMapper.selectCount(new QueryWrapper<Goodsorder>()
-                .eq("member_id",memberId)
-                .eq("status",Constants.goodsorderStatus.pay));
-        homeResponse.setDepositStatus(status);
+        ));;
         homeResponse.setRideStatus(-1);
-        if(homeResponse.getDepositStatus()==Constants.goodsorderStatus.pay) {
+        //鏌ヨ鏄惁瀛樺湪 宸叉敮浠樼殑 鎶奸噾璁㈠崟
+        Goodsorder goodsorder = this.goodsorderMapper.selectOne(new QueryWrapper<Goodsorder>()
+                .eq("member_id",memberId)
+                .eq("status",Constants.goodsorderStatus.pay)
+                .last(" limit 1 "));
+        if(!Objects.isNull(goodsorder)&&goodsorder.getStatus().equals(Constants.goodsorderStatus.pay)){
+            homeResponse.setDepositStatus(Constants.goodsorderStatus.pay);
+            homeResponse.setGoodsOrderId(goodsorder.getId());
             //鏌ヨ褰撳墠楠戣鐘舵��
             MemberRides memberRides = memberRidesJoinMapper.selectOne(new QueryWrapper<MemberRides>().eq("member_id", memberId)
                     .orderByDesc(" create_date ")
@@ -273,8 +279,8 @@
                 memberRidesResponse.setBikeCode(memberRides.getBikeCode());
                 memberRidesResponse.setBasePrice(memberRides.getBasePrice());
                 memberRidesResponse.setBaseTime(memberRides.getBaseTime());
-                memberRidesResponse.setUnitTime(memberRidesResponse.getUnitTime());
-                memberRidesResponse.setUnitPrice(memberRidesResponse.getUnitPrice());
+                memberRidesResponse.setUnitTime(memberRides.getUnitTime());
+                memberRidesResponse.setUnitPrice(memberRides.getUnitPrice());
                 homeResponse.setMemberRidesResponse(memberRidesResponse);
             }
         }
@@ -328,12 +334,6 @@
     @Override
     public void forceCloseGoodsorder(String orderId) {
         //鏌ヨ璁㈠崟 淇℃伅
-//        int freeTime = 0;
-//        try {
-//            freeTime = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME, Constants.FREE_RENT_TIME).getCode());
-//        }catch (Exception e){
-//
-//        }
         if(StringUtils.isBlank(orderId)){
             throw new BusinessException(ResponseStatus.BAD_REQUEST );
         }
@@ -351,44 +351,18 @@
         goodsorder.setEditor(user.getId());
         closeGoodsorder(  goodsorder,Constants.REFUND_TYPE.PLAT_FORCE.getKey());
     }
+
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
     @Override
     public void closeGoodsorder( Goodsorder goodsorder ,int type ) {
-
-        MPJLambdaWrapper<MemberRides> wrapper = new MPJLambdaWrapper<>();
-        wrapper.eq(MemberRides::getOrdreId,goodsorder.getId());
-        wrapper.leftJoin(BaseParam.class, BaseParam::getId, MemberRides::getParamId);
-        wrapper.orderByDesc(BaseParam::getSortnum);//鍙栨渶楂樿溅鍨嬩綔涓鸿浠锋柟妗�
-        //鏌ヨ鎵�鏈夐獞琛岃褰�
-        List<MemberRides> memberRides = memberRidesJoinMapper.selectList(wrapper);
+        List<MemberRides> memberRides = getMemberRidesForClose(goodsorder.getId());
         //榛樿缁撶畻涓烘娂閲戦噾棰�
         BigDecimal closeMoney = new BigDecimal(0.00);
         if (!CollectionUtils.isEmpty(memberRides)){
             //楠戣鎬绘椂闀�
-            int durationSum = 0;
-            for(MemberRides rides : memberRides){
-                if ( Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()!=(Constants.formatIntegerNum(rides.getStatus()))){
-                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璁㈠崟鏈夋湭瀹屾垚鐨勯獞琛岋紝鏃犳硶寮哄埗缁撶畻");
-                }
-                durationSum += Constants.formatIntegerNum(rides.getDuration());//绱楠戣锛堣璐癸級鏃堕暱
-            }
-            //鍙栨渶楂樿溅鍨嬭绠楁柟妗堢粨绠楄鍗�
-            MemberRides topRides = memberRides.get(0);
-            if(durationSum > 0){
-                int baseTime =Constants.formatIntegerNum(topRides.getBaseTime());
-                closeMoney = Constants.formatDecimalNum(topRides.getBasePrice());
-                //濡傛灉鏄竴鍙d环鏂瑰紡锛屼环鏍肩洿鎺ヤ负涓�鍙d环baseMoney,濡傛灉涓嶆槸璁$畻姝e父浠锋牸
-                if(baseTime != -1){//涓嶆槸涓�鍙d环
-                    if(durationSum > baseTime && Constants.formatIntegerNum(topRides.getUnitTime())>0){
-                        //濡傛灉瓒呭嚭浜嗚捣姝ヤ环鏍硷紝璁$畻瓒呭嚭浠锋牸
-                        BigDecimal unit = new BigDecimal(durationSum-baseTime).divide(new BigDecimal(topRides.getUnitTime()), 0, BigDecimal.ROUND_UP);
-                        //璁$畻閲戦绱瓒呭嚭閮ㄩ棬浠锋牸锛堣秴鍑烘椂闂村崟浣�*瓒呭嚭鍗曚綅鏃堕棿浠锋牸锛�
-                        closeMoney = closeMoney.add(unit.multiply(Constants.formatDecimalNum(topRides.getUnitPrice())));
-                    }
-                }
-            }
+            closeMoney = getCloseMoneyByRides(memberRides,true).getAmount();
             //瀹為檯缁撶畻浠锋牸锛岃褰曞湪鏈�楂樿溅鍨嬭褰曚笂
-            topRides.setActualPrice(closeMoney);
+            memberRides.get(0).setActualPrice(closeMoney);
             for(MemberRides model :memberRides){
                 MemberRides up = new MemberRides();
                 up.setId(model.getId());
@@ -451,6 +425,50 @@
         //淇敼璁㈠崟淇℃伅
         goodsorderMapper.updateById(update);
     }
+
+    private RidesDetailResponse    getCloseMoneyByRides(List<MemberRides> memberRides,boolean isClose) {
+        RidesDetailResponse ridesDetailResponse = new RidesDetailResponse();
+        BigDecimal closeMoney = new BigDecimal(0.00);
+        int durationSum = 0;
+        //鍙栨渶楂樿溅鍨嬭绠楁柟妗堢粨绠楄鍗�
+        for(MemberRides rides : memberRides){
+            if ( isClose && Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()!=(Constants.formatIntegerNum(rides.getStatus()))){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璁㈠崟鏈夋湭瀹屾垚鐨勯獞琛岋紝鏃犳硶寮哄埗缁撶畻");
+            }
+            durationSum += Constants.formatIntegerNum(rides.getDuration());//绱楠戣锛堣璐癸級鏃堕暱
+        }
+        MemberRides topRides =memberRides.get(0);
+        if(durationSum > 0 && topRides != null){
+            int baseTime =Constants.formatIntegerNum(topRides.getBaseTime());
+            closeMoney = Constants.formatDecimalNum(topRides.getBasePrice());
+            //濡傛灉鏄竴鍙d环鏂瑰紡锛屼环鏍肩洿鎺ヤ负涓�鍙d环baseMoney,濡傛灉涓嶆槸璁$畻姝e父浠锋牸
+            if(baseTime != -1){//涓嶆槸涓�鍙d环
+                if(durationSum > baseTime && Constants.formatIntegerNum(topRides.getUnitTime())>0){
+                    //濡傛灉瓒呭嚭浜嗚捣姝ヤ环鏍硷紝璁$畻瓒呭嚭浠锋牸
+                    BigDecimal unit = new BigDecimal(durationSum-baseTime).divide(new BigDecimal(topRides.getUnitTime()), 0, BigDecimal.ROUND_UP);
+                    //璁$畻閲戦绱瓒呭嚭閮ㄩ棬浠锋牸锛堣秴鍑烘椂闂村崟浣�*瓒呭嚭鍗曚綅鏃堕棿浠锋牸锛�
+                    closeMoney = closeMoney.add(unit.multiply(Constants.formatDecimalNum(topRides.getUnitPrice())));
+                }
+            }
+        }
+        ridesDetailResponse.setDuration(durationSum);
+        ridesDetailResponse.setAmount(closeMoney);
+        ridesDetailResponse.setBikeType(topRides.getParamName());
+        return ridesDetailResponse;
+    }
+
+    private List<MemberRides> getMemberRidesForClose(String id) {
+
+        MPJLambdaWrapper<MemberRides> wrapper = new MPJLambdaWrapper<>();
+        wrapper.eq(MemberRides::getOrdreId,id);
+        wrapper.selectAll(MemberRides.class).selectAs(BaseParam::getName, MemberRides::getParamName);
+        wrapper.leftJoin(BaseParam.class, BaseParam::getId, MemberRides::getParamId);
+        wrapper.orderByDesc(BaseParam::getSortnum);//鍙栨渶楂樿溅鍨嬩綔涓鸿浠锋柟妗�
+        //鏌ヨ鎵�鏈夐獞琛岃褰�
+        List<MemberRides> memberRides = memberRidesJoinMapper.selectList(wrapper);
+        return memberRides;
+    }
+
     @Override
     public void backGoodsorder(String orderId, BigDecimal money,String reason) {
         LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
@@ -481,8 +499,10 @@
     @Override
     public GoodsorderCanBanlanceDTO getGoodsorderCanBanlanceDTO(String orderId) {
 
-
         Goodsorder goodsorder = goodsorderMapper.selectById(orderId);
+        if(goodsorder ==null){
+            throw  new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
         QueryWrapper<Refund> wrapper = new QueryWrapper<>();
         wrapper.lambda()
                 .eq(Refund::getObjId,orderId)
@@ -558,38 +578,50 @@
     }
     @Override
     public RidesDetailResponse getRidesDetailResponse(String id) {
-        QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
-        wrapper.lambda()
-                .eq(MemberRides::getOrdreId,id);
-        List<MemberRides> memberRides = memberRidesJoinMapper.selectList(wrapper);
+        Goodsorder goodsorder = goodsorderMapper.selectById(id);
+        if(goodsorder ==null){
+            throw  new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        List<MemberRides> memberRides = getMemberRidesForClose(id);
         if (!CollectionUtils.isEmpty(memberRides)){
-            PricingRuleDTO pricingRule = pricingRuleService.getPricingRule(memberRides);
-            RidesDetailResponse ridesDetailResponse = new RidesDetailResponse();
+            //棰勮缁撶畻浠锋牸鍜岃绠楁椂闀�
+            int freeTime = 0;
+            try {
+                freeTime = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME, Constants.FREE_RENT_TIME).getCode());
+            }catch (Exception e){
+            }
+            int finalFreeTime = freeTime;
             List<MemberRidesResponse> collect = memberRides.stream().map(s -> {
                 MemberRidesResponse memberRidesResponse = new MemberRidesResponse();
+                Date endTime =memberRidesResponse.getRideEndTime();
+                if ( Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()!=(Constants.formatIntegerNum(s.getStatus()))){
+                 //濡傛灉鏄獞琛屼腑
+                    endTime = new Date();
+                }
+                int rideTime =DateUtil.betweenMin(s.getRentDate(), endTime);
                 memberRidesResponse.setRideStartTime(s.getRentDate());
-                memberRidesResponse.setRideEndTime(s.getBackDate());
-                memberRidesResponse.setRideTime(DateUtil.betweenMin(memberRidesResponse.getRideStartTime(), memberRidesResponse.getRideEndTime()));
+                memberRidesResponse.setRideEndTime(endTime);
+                memberRidesResponse.setRideTime(rideTime);
                 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.setUnitPrice(s.getUnitPrice());
                 memberRidesResponse.setUnitTime(s.getUnitTime());
+                if ( Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()!=(Constants.formatIntegerNum(s.getStatus()))){
+                    //濡傛灉鏄獞琛屼腑
+                    s.setDuration(rideTime> finalFreeTime ?(rideTime- finalFreeTime):0);
+                }
+                s.setRideTime(rideTime);
                 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())));
-                ridesDetailResponse.setAmount(basePrice.add(multiply));
-            }else {
-                ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
+            //绱鍜岄绠楃粨绠楅噾棰�
+            RidesDetailResponse ridesDetailResponse =    getCloseMoneyByRides(memberRides,false);;
+            if(Constants.formatIntegerNum(goodsorder.getStatus())!= Constants.goodsorderStatus.pay){
+                //濡傛灉闈炲凡鏀粯浣嗘湭缁撶畻锛屼娇鐢ㄨ鍗曢噾棰�
+                ridesDetailResponse.setAmount(goodsorder.getCloseMoney());
             }
-            ridesDetailResponse.setBikeType(pricingRule.getBikeType());
-            ridesDetailResponse.setDuration(durationSum);
             ridesDetailResponse.setMemberRidesResponseList(collect);
             return ridesDetailResponse;
         }
@@ -611,9 +643,13 @@
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"宸叉敮浠樿繃瀹氶噾锛屾棤娉曢噸澶嶈鎿嶄綔");
         }
         //鏄惁澶勪簬灏忕▼搴忓仠姝㈡湇鍔℃椂闂村唴
-        this.checkTemporaryStop();
+        if(this.checkTemporaryStop()){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_TIPS).getCode());
+        };
         //鏄惁澶勪簬钀ヤ笟鏃堕棿
-        this.checkBusiness();
+        if(this.checkBusiness()){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"钀ヤ笟鏃堕棿涓�"+ systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_STARTTIME).getCode() +" ~ "+systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.BUSINESS_ENDTIME).getCode()+"锛岃鍦ㄨ惀涓氭椂闂村唴浣跨敤鏈郴缁�");
+        };
         Goodsorder goodsorder = new Goodsorder();
         goodsorder.setId(Constants.getUUID());
         goodsorder.setCreateDate(new Date());
@@ -649,21 +685,24 @@
      * 楠岃瘉钀ヤ笟鏃堕棿
      */
     @Override
-    public void checkBusiness(){
+    public Boolean 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");
+        LocalTime currentTime = LocalTime.now();
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("HH:mm");
+        String nowTime = currentTime.format(formatter);
         if(Integer.valueOf(nowTime.replace(":",""))<= Integer.valueOf(businessStartTime.replace(":",""))
                 ||Integer.valueOf(nowTime.replace(":","")) > Integer.valueOf(businessEndTime.replace(":",""))){
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"钀ヤ笟鏃堕棿涓�06:00 ~ 23:59锛岃鍦ㄨ惀涓氭椂闂村唴浣跨敤鏈郴缁�");
+            return true;
         }
+        return false;
     }
 
     /**
      * 涓存椂鍋滄鏈嶅姟 鏈氦鎶奸噾鐨勭敤鎴凤紝鏃犳硶鎵溅浣跨敤锛涘凡缁忎氦杩囨娂閲戠殑鐢ㄦ埛鍙互缁х画鎵爜楠戣锛�
      */
     @Override
-    public void checkTemporaryStop(){
+    public Boolean 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();
@@ -671,9 +710,10 @@
             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(),systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_TIPS).getCode());
+                return true;
             }
         }
+        return false;
     }
 
 

--
Gitblit v1.9.3