#pgsql 退款 结算

jiaosong

2023-10-09 b22f741e6918c675fabe5aabc688d2f52858319a

#pgsql 退款 结算

 server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java

@@ -1,5 +1,6 @@
package com.doumee.api.business;

import com.doumee.api.BaseController;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.model.ApiResponse;
@@ -25,7 +26,7 @@
@Api(tags = "订单信息表")
@RestController
@RequestMapping("/business/goodsorder")
public class GoodsorderController {
public class GoodsorderController extends BaseController {


    @Autowired

 server/services/src/main/java/com/doumee/core/constants/Constants.java

@@ -38,6 +38,7 @@
    int all =2;
    int partful = 3;
  }

    public interface goodsorderStatus{
        int waitPay =0;
        int pay =1;
@@ -96,10 +97,6 @@
    public static final String TIPS = "TIPS";






  public static final String FILES_DIR = "FILES_DIR";
  public static final String SCRATCH_REDIRECT_URL = "SCRATCH_REDIRECT_URL";
  public static final Integer ZERO = 0 ;
@@ -129,12 +126,110 @@
      String register="REGISTER";
      String rent="RENT";
  }

        public enum GOODSORDER_STATUS{
            //            0待支付 1已支付 2已取消 3支付失败 4已结算
            UN_PAY("待支付", 0,"待支付"),

            HAVING_PAY("已支付", 1,"已支付"),

            CANCEL("已取消", 2,"已取消"),

            PAY_FAILURE("支付失败", 3,"支付失败"),

            CLOSE("已结算", 4,"已结算"),
            ;
            String name;

            Integer key;

            String info;

            GOODSORDER_STATUS(String name, Integer key, String info) {
                this.name = name;
                this.key = key;
                this.info = info;
            }

            public String getName() {
                return name;
            }

            public void setName(String name) {
                this.name = name;
            }

            public Integer getKey() {
                return key;
            }

            public void setKey(Integer key) {
                this.key = key;
            }

            public String getInfo() {
                return info;
            }

            public void setInfo(String info) {
                this.info = info;
            }
        }

        public enum MEMBER_RIDES_STATUS{
//            0请求开锁中 1骑行中 2已还车  3开锁失败
            LOCKING("请求开锁中", 0,"请求开锁中"),

            RIDES_RUNNING("骑行中", 1,"骑行中"),

            BACK_CYCLING("已还车", 2,"已还车"),

            LOCKING_DEFEAT("开锁失败", 3,"开锁失败")
            ;
            String name;

            Integer key;

            String info;

            MEMBER_RIDES_STATUS(String name, Integer key, String info) {
                this.name = name;
                this.key = key;
                this.info = info;
            }

            public String getName() {
                return name;
            }

            public void setName(String name) {
                this.name = name;
            }

            public Integer getKey() {
                return key;
            }

            public void setKey(Integer key) {
                this.key = key;
            }

            public String getInfo() {
                return info;
            }

            public void setInfo(String info) {
                this.info = info;
            }
        }

  public static BigDecimal formatDecimalNum(BigDecimal num){
   if(num == null){
    return new BigDecimal(0);
   }
   return num;
  }

  public static int compareBigdecimal(BigDecimal num,BigDecimal num2){
   if(num == null){
    num =new BigDecimal(0);
@@ -156,12 +251,14 @@
   }
   return num;
  }

  public static String formatImgPath(String avatar, String imgPath) {
   if(StringUtils.isBlank(avatar)){
    return null;
   }
   return imgPath+avatar;
  }

    public static String getIpAddr(HttpServletRequest request) {
        String ipAddress = request.getHeader("x-forwarded-for");
        if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
@@ -210,6 +307,7 @@
        }
        return encdeStr;
    }

    public static String trimEndSpaceStr(String outPut){
        String newOutPut = "";
        if(StringUtils.isNotBlank(outPut)){

 server/services/src/main/java/com/doumee/core/utils/DateUtil.java

@@ -10,7 +10,6 @@
import java.text.DateFormatSymbols;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.Duration;
import java.util.Date;
import java.util.*;

@@ -3011,11 +3010,11 @@
     * @param end
     * @return
     */
    public static long betweenMin(Date begin, Date end) {
    public static Integer betweenMin(Date begin, Date end) {
        long createTime =begin.getTime();//获取创建时间的时间戳
        long currentTime =Objects.isNull(end)?System.currentTimeMillis():end.getTime();//获取当前时间的时间戳
        long diff=(currentTime-createTime)/1000/60;//获取两个时间相差的分钟
        return diff;
        return (int)diff;
    }



 server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java

@@ -41,7 +41,7 @@
    @ExcelColumn(name="编辑人")
    private String editor;

    @ApiModelProperty(value = "是否已删除 0未删除 1已删除", example = "1")
    @ApiModelProperty(value = "是否已删除 0未删除 1已删除")
    @ExcelColumn(name="是否已删除 0未删除 1已删除")
    @TableLogic
    private Integer isdeleted;
@@ -64,7 +64,7 @@
    @ExcelColumn(name="车辆编码")
    private String bikeCode;

    @ApiModelProperty(value = "当前账户余额", example = "1")
    @ApiModelProperty(value = "当前账户余额")
    @ExcelColumn(name="当前账户余额")
    private BigDecimal balance;

@@ -111,31 +111,31 @@
    @ExcelColumn(name="还车指令编码")
    private String backCommondId;

    @ApiModelProperty(value = "起步价", example = "1")
    @ApiModelProperty(value = "起步价")
    @ExcelColumn(name="起步价")
    private BigDecimal basePrice;

    @ApiModelProperty(value = "起步价时间", example = "1")
    @ApiModelProperty(value = "起步价时间")
    @ExcelColumn(name="起步价时间")
    private Integer baseTime;

    @ApiModelProperty(value = "超出单价", example = "1")
    @ApiModelProperty(value = "超出单价")
    @ExcelColumn(name="超出单价")
    private Integer unitPrice;
    private BigDecimal unitPrice;

    @ApiModelProperty(value = "超出时间单位", example = "1")
    @ApiModelProperty(value = "超出时间单位")
    @ExcelColumn(name="超出时间单位")
    private Integer unitTime;

    @ApiModelProperty(value = "骑行价格", example = "1")
    @ApiModelProperty(value = "骑行价格")
    @ExcelColumn(name="骑行价格")
    private BigDecimal price;

    @ApiModelProperty(value = "骑行实际价格", example = "1")
    @ApiModelProperty(value = "骑行实际价格")
    @ExcelColumn(name="骑行实际价格")
    private BigDecimal actualPrice;

    @ApiModelProperty(value = "骑行计费时长", example = "1")
    @ApiModelProperty(value = "骑行计费时长")
    @ExcelColumn(name="骑行计费时长")
    private Integer duration;

@@ -144,7 +144,7 @@
    //@JsonFormat(pattern = "yyyy-MM-dd")
    private Date closeDate;

    @ApiModelProperty(value = "结算状态 0未结算 1已结束", example = "1")
    @ApiModelProperty(value = "结算状态 0未结算 1已结束")
    @ExcelColumn(name="结算状态 0未结算 1已结束")
    private Integer closeStatus;

@@ -152,7 +152,7 @@
    @ExcelColumn(name="关联订单编码(关联goodsorder）")
    private String ordreId;

    @ApiModelProperty(value = "是否结算计费车型 0否 1是", example = "1")
    @ApiModelProperty(value = "是否结算计费车型 0否 1是")
    @ExcelColumn(name="是否结算计费车型 0否 1是")
    private Integer isStandard;

@@ -164,11 +164,11 @@
    @ExcelColumn(name="是否节假日 0不是 1是")
    private String isHoliday;

    @ApiModelProperty(value = "状态 0请求开锁中 1骑行中 2已还车  3开锁失败", example = "1")
    @ApiModelProperty(value = "状态 0请求开锁中 1骑行中 2已还车  3开锁失败")
    @ExcelColumn(name="状态 0请求开锁中 1骑行中 2已还车  3开锁失败")
    private Integer status;

    @ApiModelProperty(value = "还车类型 0正常还车 1强制还车", example = "1")
    @ApiModelProperty(value = "还车类型 0正常还车 1强制还车")
    @ExcelColumn(name="还车类型 0正常还车 1强制还车")
    private Integer backType;


 server/services/src/main/java/com/doumee/dao/business/model/Refund.java

@@ -59,7 +59,7 @@

    @ApiModelProperty(value = "用户编码（关联member表）", example = "1")
    @ExcelColumn(name="用户编码（关联member表）")
    private BigDecimal memberId;
    private String memberId;

    @ApiModelProperty(value = "交易金额", example = "1")
    @ExcelColumn(name="交易金额")

 server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java

@@ -30,10 +30,10 @@
    private Date rideEndTime;

    @ApiModelProperty(value = "骑行时长")
    private long rideTime;
    private Integer rideTime;

    @ApiModelProperty(value = "计费时长")
    private long duration;
    private Integer duration;

    @ApiModelProperty(value = "车型")
    private String bikeType;

 server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java

@@ -1,6 +1,8 @@
package com.doumee.dao.business.web.response;

import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;
@@ -13,14 +15,19 @@
@ApiModel("交易明细")
public class PayOrderDTO {

    @ApiModelProperty(value = "订单编码")
    private String orderCode;

    private Integer payType;
    @ApiModelProperty(value = "支付方式 0微信 1支付宝")
    private Integer payWay;

    @ApiModelProperty(value = "退款类型 0结算退款 1强制结算退款 2结算后退款")
    private Integer refundType;

    @ApiModelProperty(value = "交易金额")
    private BigDecimal money;

    @ApiModelProperty(value = "支付时间")
    private Date payDate;

}

 server/services/src/main/java/com/doumee/dao/business/web/response/PricingRuleDTO.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
package com.doumee.dao.business.web.response;

import com.doumee.dao.business.model.MemberRides;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;

/**
 *
 * è®¡ä»·è§„则
 * @author T14
 */
@Data
@ApiModel("计价规则")
public class PricingRuleDTO {

    @ApiModelProperty(value = "起步单价")
    private BigDecimal startFare;

    @ApiModelProperty(value = "单价")
    private BigDecimal price;

    @ApiModelProperty(value = "计价方式 1:一口价 2:阶梯定价")
    private Integer type;

    @ApiModelProperty(value = "车辆类型")
    private String paramId;

    @ApiModelProperty(value = "车型名称")
    private String bikeType;

    @ApiModelProperty(value = "计价副本")
    private  MemberRides memberRides;
}

 server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java

@@ -1,5 +1,6 @@
package com.doumee.dao.business.web.response;

import com.doumee.dao.business.model.BaseParam;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
@@ -20,13 +21,13 @@
public class RidesDetailResponse {

    @ApiModelProperty(value = "预计消费金额")
    private long amount;
    private BigDecimal amount;

    @ApiModelProperty(value = "车型")
    private String bikeType;

    @ApiModelProperty(value = "计费时长")
    private long  duration;
    private Integer  duration;

    @ApiModelProperty(value = "骑行记录")
    private List<MemberRidesResponse> memberRidesResponseList;

 server/services/src/main/java/com/doumee/service/business/GoodsorderService.java

@@ -7,6 +7,7 @@
import com.doumee.dao.business.model.Goodsorder;
import com.doumee.dao.business.web.response.HomeResponse;
import com.doumee.dao.business.web.response.GoodsorderDetailDTO;
import com.doumee.dao.business.web.response.RidesDetailResponse;

import java.util.List;

@@ -116,6 +117,7 @@
     */
    Object createGoodsOrderPay(String memberId);


    /**
     * æŠ¼é‡‘支付回调业务
     * @param preOrderId
@@ -137,5 +139,14 @@
     * @param id
     * @return
     */
    Goodsorder closerGoodsorder(String id);
    void closerGoodsorder(String id);



    /**
     * æŠ¼é‡‘支付业务
     * @param id
     * @return
     */
    RidesDetailResponse getRidesDetailResponse(String id);
}

 server/services/src/main/java/com/doumee/service/business/PricingRuleService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.doumee.service.business;

import com.doumee.dao.business.model.MemberRides;
import com.doumee.dao.business.web.response.PricingRuleDTO;

import java.util.List;

/**
 *
 * èŽ·å–计价规则
 * @author T14
 */
public interface PricingRuleService {


    /**
     * èŽ·å–获取计价规则
     * @param goodaorderId
     * @return
     */
    PricingRuleDTO getPricingRule(String goodaorderId);


    PricingRuleDTO getPricingRule(List<MemberRides> memberRidesList);

}

 server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java

@@ -9,6 +9,7 @@
import com.doumee.core.constants.Constants;
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;
@@ -22,19 +23,18 @@
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.web.response.HomeResponse;
import com.doumee.dao.business.web.response.*;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.dao.business.web.response.GoodsorderDetailDTO;
import com.doumee.dao.business.web.response.MemberRidesResponse;
import com.doumee.dao.business.web.response.PayOrderDTO;
import com.doumee.service.business.GoodsorderService;
import com.doumee.service.business.PricingRuleService;
import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
import com.github.binarywang.wxpay.exception.WxPayException;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -51,6 +51,7 @@
import java.util.Date;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

@Service
public class GoodsorderServiceImpl implements GoodsorderService {
@@ -74,14 +75,14 @@
    @Autowired
    private BaseParamMapper baseParamMapper;




    @Autowired
    private RefundMapper refundMapper;

    @Autowired
    private MemberRidesJoinMapper memberRidesJoinMapper;

    @Autowired
    PricingRuleService pricingRuleService;

    @Override
    public String create(Goodsorder goodsorder) {
@@ -237,7 +238,7 @@

        PayOrderDTO payOrderDTO = new PayOrderDTO();
        payOrderDTO.setOrderCode(goodsorder.getCode());
        payOrderDTO.setPayType(goodsorder.getPayWay());
        payOrderDTO.setPayWay(goodsorder.getPayWay());
        payOrderDTO.setMoney(goodsorder.getMoney());
        payOrderDTO.setPayDate(goodsorder.getPayDate());
        payOrderDTOList.add(0,payOrderDTO);
@@ -245,7 +246,8 @@
            refunds.forEach(s->{
                PayOrderDTO refundOrderDTO = new PayOrderDTO();
                refundOrderDTO.setOrderCode(s.getCode());
                refundOrderDTO.setPayType(s.getPayWay());
                refundOrderDTO.setPayWay(s.getPayWay());
                refundOrderDTO.setRefundType(s.getType());
                refundOrderDTO.setMoney(s.getMoney());
                refundOrderDTO.setPayDate(s.getDoneDate());
                payOrderDTOList.add(refundOrderDTO);
@@ -262,15 +264,130 @@
    }

    @Override
    public Goodsorder closerGoodsorder(String id) {
    public void closerGoodsorder(String id) {


        LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        Goodsorder goodsorder = goodsorderMapper.selectById(id);



        return null;
        QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .eq(MemberRides::getOrdreId,id);
        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())));
                ridesDetailResponse.setAmount(basePrice.add(multiply));
            }else {
                ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
            }
            ridesDetailResponse.setBikeType(pricingRule.getBikeType());
            ridesDetailResponse.setDuration(durationSum);
            ridesDetailResponse.setMemberRidesResponseList(collect);


            Refund refund = new Refund();
            refund.setCreateDate(new Date());
            refund.setCreator(principal.getId());
            refund.setEditDate(new Date());
            refund.setEditor(principal.getId());
            refund.setIsdeleted(Constants.ZERO);
            refund.setInfo("系统结算后订单自动完结");
//            refund.setCode();
            refund.setMemberId(goodsorder.getMemberId());
            refund.setMoney(goodsorder.getMoney().subtract(ridesDetailResponse.getAmount()));
//            refund.setStatus();
//            refund.setPreOrderid();
//            refund.setOnlineOrderid();
            refund.setPayWay(goodsorder.getPayWay());
            refund.setDoneDate(new Date());
            refund.setType(Constants.ONE);
            refund.setObjId(goodsorder.getId());
            refund.setReason("确定强制结算吗？结算后订单自动完结");
            refundMapper.insert(refund);
            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.setCloseUserId(principal.getId());
            update.setCloseType(Constants.ONE);
            goodsorderMapper.updateById(update);
        }
    }


    @Override
    public RidesDetailResponse getRidesDetailResponse(String id) {

        QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .eq(MemberRides::getOrdreId,id);
        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())));
                ridesDetailResponse.setAmount(basePrice.add(multiply));
            }else {
                ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
            }
            ridesDetailResponse.setBikeType(pricingRule.getBikeType());
            ridesDetailResponse.setDuration(durationSum);
            ridesDetailResponse.setMemberRidesResponseList(collect);
            return ridesDetailResponse;
        }

        return new RidesDetailResponse();
    }

    @Override
    public Object createGoodsOrderPay(String memberId){

 server/services/src/main/java/com/doumee/service/business/impl/PricingRuleServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,103 @@
package com.doumee.service.business.impl;
import java.math.BigDecimal;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.doumee.core.constants.Constants;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.dao.business.BaseParamMapper;
import com.doumee.dao.business.MemberRidesMapper;
import com.doumee.dao.business.PricingDetailMapper;
import com.doumee.dao.business.PricingParamMapper;
import com.doumee.dao.business.model.BaseParam;
import com.doumee.dao.business.model.MemberRides;
import com.doumee.dao.business.web.response.PricingRuleDTO;
import com.doumee.service.business.PricingRuleService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 *
 * èŽ·å–计价规则
 * @author T14
 */

@Service
public class PricingRuleServiceImpl implements PricingRuleService {


    @Autowired
    PricingParamMapper pricingParamMapper;

    @Autowired
    PricingDetailMapper pricingParamMapper;


    @Autowired
    MemberRidesMapper memberRidesMapper;


    @Autowired
    BaseParamMapper baseParamMapper;


    @Override
    public PricingRuleDTO getPricingRule(String goodaorderId) {
        QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .eq(MemberRides::getOrdreId,goodaorderId);
        List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper);
        if (CollectionUtils.isEmpty(memberRides)){
            return null;
        }
        PricingRuleDTO pricingRule = getPricingRule(memberRides);
        return pricingRule;
    }


    @Override
    public PricingRuleDTO getPricingRule(List<MemberRides> memberRidesList) {
        if (!CollectionUtils.isEmpty(memberRidesList)){
            List<String> collect = memberRidesList.stream()
                    .filter(s -> Objects.nonNull(s.getActualPrice()))
                    .map(s -> s.getParamId())
                    .collect(Collectors.toList());
            QueryWrapper<BaseParam> wrapper = new QueryWrapper<>();
            wrapper.lambda()
                    .eq(BaseParam::getIsdeleted, Constants.ZERO)
                    .eq(BaseParam::getType, Constants.THREE)
                    .in(BaseParam::getId,collect)
                    .orderByDesc(BaseParam::getSortnum)
                    .last("limit 1");
            BaseParam baseParam = baseParamMapper.selectOne(wrapper);

            MemberRides memberRides = memberRidesList.stream()
                    .filter(s -> baseParam.getId().equals(s.getParamId()))
                    .findFirst().orElseThrow(() -> new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "没有车辆类型编码"));
            PricingRuleDTO pricingRuleDTO = new PricingRuleDTO();
            if (memberRides.getBaseTime() < 0){
                //一口价定价
                pricingRuleDTO.setStartFare(memberRides.getBasePrice());
                pricingRuleDTO.setPrice(new BigDecimal("0"));
                pricingRuleDTO.setType(Constants.ONE);
                pricingRuleDTO.setParamId(baseParam.getId());
                pricingRuleDTO.setBikeType(baseParam.getName());
                pricingRuleDTO.setMemberRides(memberRides);
            }else {
                pricingRuleDTO.setStartFare(memberRides.getBasePrice());
                pricingRuleDTO.setPrice(memberRides.getUnitPrice());
                pricingRuleDTO.setType(Constants.TWO);
                pricingRuleDTO.setParamId(baseParam.getId());
                pricingRuleDTO.setBikeType(baseParam.getName());
                pricingRuleDTO.setMemberRides(memberRides);
            }
            return pricingRuleDTO;
        }
        return null;
    }
}