| | |
| | | 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.MemberRidesQuery; |
| | | 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.*; |
| | | import com.doumee.service.business.GoodsorderService; |
| | | import com.doumee.service.business.MemberRidesService; |
| | | import com.doumee.service.business.PricingRuleService; |
| | | import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse; |
| | | import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest; |
| | |
| | | import java.net.InetAddress; |
| | | import java.net.UnknownHostException; |
| | | |
| | | import java.sql.Ref; |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | |
| | | return goodsorderMapper.selectList(wrapper); |
| | | } |
| | | @Override |
| | | public List<GoodsorderExportVO> findExportNotBikPage(Goodsorder model){ |
| | | List<GoodsorderExportVO> list = new ArrayList<>(); |
| | | public PageData<GoodsorderExportVO> findAccountDetailPage(PageWrap<Goodsorder> pageWrap) { |
| | | IPage<Goodsorder> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | pageWrap.getModel().setPayStatus(Constants.ONE); //只查询支付成功的 |
| | | MPJLambdaWrapper<Goodsorder> queryWrapper = initQueryParamByModel(pageWrap.getModel()); |
| | | return PageData.from(goodsorderJoinMapper.selectJoinPage(page, GoodsorderExportVO.class,queryWrapper)); |
| | | } |
| | | @Override |
| | | public List<GoodsorderExportVO> findExportAccountDetailPage(Goodsorder model){ |
| | | // List<GoodsorderExportVO> list = new ArrayList<>(); |
| | | model.setPayStatus(Constants.ONE); //只查询支付成功的 |
| | | MPJLambdaWrapper<Goodsorder> queryWrapper = initQueryParamByModel(model); |
| | | List<Goodsorder> goodsorderList = goodsorderJoinMapper.selectJoinList(Goodsorder.class,queryWrapper); |
| | | if(goodsorderList!=null){ |
| | | List<GoodsorderExportVO> goodsorderList = goodsorderJoinMapper.selectJoinList(GoodsorderExportVO.class,queryWrapper); |
| | | /* if(goodsorderList!=null){ |
| | | for(Goodsorder order : goodsorderList){ |
| | | GoodsorderExportVO vo = new GoodsorderExportVO(); |
| | | vo.setId(order.getId()); |
| | | vo.setCode(order.getCode()); |
| | | vo.setOpenid(order.getMemberOpenid()); |
| | | vo.setPayDate(order.getPayDate()); |
| | | vo.setCloseDate(order.getCloseDate()); |
| | | vo.setCloseDate(order.getCloseDate()); |
| | | vo.setCloseMoney(Constants.formatDecimalNum(order.getCloseMoney()).divide(new BigDecimal(100), 2, BigDecimal.ROUND_UP)); |
| | | vo.setMoney(Constants.translateMoney(order.getMoney())); |
| | | vo.setCloseMoney(Constants.translateMoney(order.getCloseMoney())); |
| | | vo.setRefundDate(order.getRefundDate()); |
| | | vo.setRefundMoney(Constants.formatDecimalNum(order.getRefundMoney()).divide(new BigDecimal(100), 2, BigDecimal.ROUND_UP)); |
| | | vo.setRefundMoney(Constants.translateMoney(order.getRefundMoney())); |
| | | list.add(vo); |
| | | } |
| | | } |
| | | return list; |
| | | }*/ |
| | | return goodsorderList; |
| | | } |
| | | private MPJLambdaWrapper<Goodsorder> initQueryParamByModel(Goodsorder model) { |
| | | MPJLambdaWrapper<Goodsorder> queryWrapper = new MPJLambdaWrapper<>(); |
| | | Utils.MP.blankToNull(model); |
| | | |
| | | queryWrapper.selectAll(Goodsorder.class); |
| | | queryWrapper.selectAs(Member::getOpenid, Goodsorder::getMemberOpenid); |
| | | queryWrapper.leftJoin(Member.class, Member::getId ,Goodsorder::getMemberId); |
| | | queryWrapper.select("select max(r.done_date) from refund r where t1.obj_id=t.id and r.status=2 ) as refund_date"); |
| | | queryWrapper.select("select sum(r.money) from refund r where t1.obj_id=t.id and r.status=2) as refund_money"); |
| | | queryWrapper.select("(select max(r.done_date) from refund r where r.obj_id=t.id and r.status=2 ) as refund_date"); |
| | | queryWrapper.select("(select sum(r.money) from refund r where r.obj_id=t.id and r.status=2) as refund_money"); |
| | | //时间段筛选 |
| | | queryWrapper.ge(model.getStartDate()!=null, Goodsorder::getPayDate, model.getStartDate()); |
| | | queryWrapper.le(model.getEndDate()!=null, Goodsorder::getPayDate, model.getEndDate()); |
| | | queryWrapper.eq(model.getPayStatus() !=null,Goodsorder::getPayStatus,model.getPayStatus()); |
| | | queryWrapper.eq(model.getCode() !=null,Goodsorder::getCode,model.getCode()); |
| | | queryWrapper.like(model.getCode() !=null,Goodsorder::getCode,model.getCode()); |
| | | queryWrapper.like(model.getId() !=null,Goodsorder::getId,model.getId()); |
| | | queryWrapper.eq(model.getStatus() !=null,Goodsorder::getStatus,model.getStatus()); |
| | | queryWrapper.eq(model.getOnlineOrderid() !=null,Goodsorder::getOnlineOrderid,model.getOnlineOrderid()); |
| | | queryWrapper.like(model.getOnlineOrderid() !=null,Goodsorder::getOnlineOrderid,model.getOnlineOrderid()); |
| | | queryWrapper.like(model.getMemberOpenid() !=null,Member::getOpenid,model.getMemberOpenid()); |
| | | queryWrapper.eq(Goodsorder::getIsdeleted,Constants.ZERO); |
| | | queryWrapper.orderByDesc(Goodsorder::getPayDate); |
| | |
| | | MPJLambdaWrapper<Goodsorder> queryWrapper = initQueryParamByModel(pageWrap.getModel()); |
| | | return PageData.from(goodsorderJoinMapper.selectJoinPage(page, Goodsorder.class,queryWrapper)); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public long count(Goodsorder goodsorder) { |
| | |
| | | .eq("status",Constants.ZERO) |
| | | .orderByDesc("create_date") |
| | | )); |
| | | 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()){ |
| | | homeResponse.setIsStopServe(Constants.ONE); |
| | | } |
| | | } |
| | | //查询是否存在 已支付的 押金订单 |
| | | Integer status = this.goodsorderMapper.selectCount(new QueryWrapper<Goodsorder>() |
| | | .eq("member_id",memberId) |
| | |
| | | |
| | | List<PayOrderDTO> payOrderDTOList = new ArrayList<>(); |
| | | Goodsorder goodsorder = goodsorderMapper.selectById(id); |
| | | if(goodsorder == null){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY ); |
| | | } |
| | | QueryWrapper<Refund> refundQuery = new QueryWrapper<>(); |
| | | refundQuery.lambda() |
| | | .eq(Refund::getObjId,id); |
| | | .eq(Refund::getObjId,id) |
| | | .orderByAsc(Refund::getDoneDate); |
| | | //查询所有有退款记录 |
| | | List<Refund> refunds = refundMapper.selectList(refundQuery); |
| | | |
| | | PayOrderDTO payOrderDTO = new PayOrderDTO(); |
| | | payOrderDTO.setId(goodsorder.getId()); |
| | | payOrderDTO.setOrderCode(goodsorder.getCode()); |
| | | payOrderDTO.setPayWay(goodsorder.getPayWay()); |
| | | payOrderDTO.setMoney(goodsorder.getMoney()); |
| | | payOrderDTO.setMoney(Constants.translateMoney(goodsorder.getMoney())); |
| | | payOrderDTO.setPayDate(goodsorder.getPayDate()); |
| | | payOrderDTO.setOnlineorderId(goodsorder.getOnlineOrderid()); |
| | | payOrderDTOList.add(0,payOrderDTO); |
| | | if (!CollectionUtils.isEmpty(refunds)){ |
| | | refunds.forEach(s->{ |
| | | PayOrderDTO refundOrderDTO = new PayOrderDTO(); |
| | | refundOrderDTO.setOrderCode(s.getCode()); |
| | | refundOrderDTO.setId(s.getId()); |
| | | refundOrderDTO.setPayWay(s.getPayWay()); |
| | | refundOrderDTO.setRefundType(s.getType()); |
| | | refundOrderDTO.setMoney(s.getMoney()); |
| | | refundOrderDTO.setMoney(Constants.translateMoney(s.getMoney())); |
| | | refundOrderDTO.setPayDate(s.getDoneDate()); |
| | | payOrderDTOList.add(refundOrderDTO); |
| | | }); |
| | | } |
| | | MPJLambdaWrapper<MemberRides> wrapper = new MPJLambdaWrapper<>(); |
| | | wrapper.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId) |
| | | .eq(BaseParam::getType, Constants.THREE); |
| | | List<MemberRides> memberRides = memberRidesJoinMapper.selectJoinList(MemberRides.class, wrapper); |
| | | MemberRidesQuery query = new MemberRidesQuery(); |
| | | query.setGoodsorderId(goodsorder.getId()); |
| | | List<BikeLogDTO> memberRides = MemberRidesServiceImpl.findBikeLogList(memberRidesJoinMapper,query); |
| | | GoodsorderDetailDTO goodsorderDetailDTO = new GoodsorderDetailDTO(); |
| | | goodsorderDetailDTO.setPayOrderDTOList(payOrderDTOList); |
| | | goodsorderDetailDTO.setMemberRidesList(memberRides); |
| | | goodsorderDetailDTO.setPayOrderDTOList(payOrderDTOList);//交易明细 |
| | | goodsorderDetailDTO.setMemberRidesList(memberRides);//骑行记录 |
| | | goodsorderDetailDTO.setModel(goodsorder);//订单对象 |
| | | return goodsorderDetailDTO; |
| | | } |
| | | |
| | |
| | | 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(),"当前时间暂未营业服务,请注意查看营业时间"); |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"营业时间为06:00 ~ 23:59,请在营业时间内使用本系统"); |
| | | } |
| | | } |
| | | |
| | |
| | | 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(),"当前小程序停止服务,请注意查看公告"); |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.STOP_SERVE_TIPS).getCode()); |
| | | } |
| | | } |
| | | } |
| | |
| | | Integer durationSum = memberRides.stream().filter(s -> s.getDuration() > 0).mapToInt(s -> s.getDuration()).sum(); |
| | | if (durationSum > pricingRule.getMemberRides().getBaseTime()){ |
| | | BigDecimal basePrice = pricingRule.getMemberRides().getBasePrice(); |
| | | //TODO 取证 |
| | | 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.setBikeType(pricingRule.getBikeType()); |
| | | ridesDetailResponse.setDuration(durationSum); |
| | | ridesDetailResponse.setMemberRidesResponseList(collect); |
| | | Refund refund = new Refund(); |
| | | |
| | | 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); |
| | | //若消费金额 大于 订单押金,则不进行退款业务 |
| | | if(goodsorder.getMoney().compareTo(ridesDetailResponse.getAmount())>Constants.ZERO){ |
| | | 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 = wxMiniUtilService.wxRefund(refundDTO); |
| | | } |
| | | |
| | | //存储 消费 交易流水 |
| | | |
| | | Transactions transactions = new Transactions(); |
| | | transactions.setMemberId(refundDTO.getMemberId()); |
| | | transactions.setMemberId(goodsorder.getMemberId()); |
| | | transactions.setCreateDate(new Date()); |
| | | transactions.setIsdeleted(Constants.ZERO); |
| | | transactions.setOrderId(refundDTO.getOrderId()); |
| | | transactions.setMoney(ridesDetailResponse.getAmount()); |
| | | transactions.setOrderId(orderId); |
| | | transactions.setMoney(goodsorder.getMoney().compareTo(ridesDetailResponse.getAmount())<=Constants.ZERO?goodsorder.getMoney():ridesDetailResponse.getAmount()); |
| | | transactions.setType(Constants.transactionsType.consumption); |
| | | transactions.setDoneDate(new Date()); |
| | | transactions.setTitle("消费结算"); |
| | | transactions.setContent("结算实际消费"); |
| | | transactions.setBalance(BigDecimal.ZERO); |
| | | transactions.setObjId(refund.getId()); |
| | | transactions.setObjId(orderId); |
| | | transactions.setObjType(Constants.ONE); |
| | | transactionsMapper.insert(transactions); |
| | | |
| | |
| | | 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.setCloseId(!Objects.isNull(refund)?refund.getId():null); |
| | | update.setCloseDate(!Objects.isNull(refund)?refund.getDoneDate():null); |
| | | update.setCloseInfo(!Objects.isNull(refund)?refund.getInfo():null); |
| | | update.setCloseType(Constants.ONE); |
| | | goodsorderMapper.updateById(update); |
| | | } |