| | |
| | | package com.ruoyi.order.service.impl; |
| | | |
| | | import cn.hutool.core.date.DatePattern; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | |
| | | import com.google.common.collect.Lists; |
| | | import com.ruoyi.common.core.constant.CacheConstants; |
| | | import com.ruoyi.common.core.constant.SecurityConstants; |
| | | import com.ruoyi.common.core.enums.*; |
| | | import com.ruoyi.common.core.enums.AuctionOrderTypeEnum; |
| | | import com.ruoyi.common.core.enums.AuditStatusEnum; |
| | | import com.ruoyi.common.core.enums.BondStatusEnum; |
| | | import com.ruoyi.common.core.enums.CouponUseEnum; |
| | | import com.ruoyi.common.core.enums.GroupStatusEnum; |
| | | import com.ruoyi.common.core.enums.OrderFromEnum; |
| | | import com.ruoyi.common.core.enums.OrderStatusEnum; |
| | | import com.ruoyi.common.core.enums.OrderTypeEnum; |
| | |
| | | import com.ruoyi.system.api.domain.dto.MgtAfterSaleSettingDTO; |
| | | import com.ruoyi.system.api.domain.dto.OrderDTO; |
| | | import com.ruoyi.system.api.domain.dto.updMembeOneDTO; |
| | | import com.ruoyi.system.api.domain.vo.*; |
| | | import com.ruoyi.system.api.domain.vo.Express100VO; |
| | | import com.ruoyi.system.api.domain.vo.MemberOrderListVO; |
| | | import com.ruoyi.system.api.domain.vo.MemberOrderNumVO; |
| | | import com.ruoyi.system.api.domain.vo.MemberTiOrderVO; |
| | | import com.ruoyi.system.api.domain.vo.OrderVO; |
| | | import com.ruoyi.system.api.feignClient.AuctionClient; |
| | | import com.ruoyi.system.api.feignClient.GoodsSkuClient; |
| | | import com.ruoyi.system.api.feignClient.MemberClient; |
| | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Objects; |
| | | import java.util.Optional; |
| | | import java.util.Set; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.function.Function; |
| | |
| | | order.setOrderFrom(OrderFromEnum.AUCTION_ORDERS); |
| | | order.setOrderNo(OrderUtil.getOrderNoForPrefix("PM")); |
| | | order.setIsOrder(1); |
| | | if (OrderDTO.getAuctionType().equals(AuctionOrderTypeEnum.AUCTION_ITEMS)) { |
| | | order.setAuctionSalesroomId(OrderDTO.getAuctionSalesroomId()); |
| | | } |
| | | } |
| | | order.setOrderTime(OrderDTO.getOrderTime()); |
| | | order.setOrderFrom(OrderDTO.getOrderFrom()); |
| | |
| | | order.setOrderTimeSx(OrderDTO.getOrderTimeSx()); |
| | | this.save(order); |
| | | |
| | | |
| | | |
| | | if (OrderDTO.getOrderFrom().getCode()==4){ |
| | | if (OrderDTO.getAuctionType().getCode()==1){ |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper= Wrappers.lambdaQuery(); |
| | |
| | | if (OrderDTO.getAuctionType().getCode()==2){ |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper= Wrappers.lambdaQuery(); |
| | | wrapper.eq(OrderAuctionBond::getMemberId,OrderDTO.getMemberId()); |
| | | wrapper.eq(OrderAuctionBond::getAuctionGoodsId,OrderDTO.getGoodsSkuId()); |
| | | wrapper.eq(OrderAuctionBond::getBoundStatus,2); |
| | | wrapper.eq(OrderAuctionBond::getAuctionSalesroomId,OrderDTO.getAuctionSalesroomId()); |
| | | wrapper.eq(OrderAuctionBond::getBondType,2); |
| | |
| | | return memberOrderVO; |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | System.err.println(DateUtil.format(LocalDateTime.now(), DatePattern.NORM_DATETIME_PATTERN)); |
| | | } |
| | | @Override |
| | | public MemberTiOrderVO updMemberOrder(MemberOrderDTO memberOrderDTO) { |
| | | Order order = baseMapper.selectById(memberOrderDTO.getId()); |
| | |
| | | CustomConfig memberPointsMoney = sysUserClient.getconfig("MEMBER_POINTS_MONEY").getData(); |
| | | CustomConfig memberPointsPoints = sysUserClient.getconfig("MEMBER_POINTS_POINTS").getData(); |
| | | |
| | | if (pice.intValue()>0){ |
| | | if (pice.doubleValue()>0){ |
| | | BigDecimal divide = pice.divide(new BigDecimal(memberPointsMoney.getConfigValue())); |
| | | BigDecimal roundedDown = divide.setScale(0, RoundingMode.DOWN); |
| | | BigDecimal aDouble= roundedDown.multiply(new BigDecimal(memberPointsPoints.getConfigValue())); |
| | |
| | | } |
| | | wrapper.eq(Order::getIsOrder,1); |
| | | wrapper.eq(Order::getDelFlag,0); |
| | | wrapper.orderByDesc(Order::getCancelTime); |
| | | wrapper.orderByDesc(Order::getCreateTime); |
| | | Page<Order> page1 = this.page(page, wrapper); |
| | | |
| | | PageDTO<MemberOrderListVO> memberOrderListVOPageDTO = PageDTO.of(page1, MemberOrderListVO.class); |
| | |
| | | Wrappers.lambdaQuery(OrderReturnRequest.class) |
| | | .eq(OrderReturnRequest::getOrderId, |
| | | MemberOrderList.getId()).last("limit 1")); |
| | | if (StringUtils.isNotNull(orderReturnRequest)&&orderReturnRequest!=null) { |
| | | if (StringUtils.isNotNull(orderReturnRequest) |
| | | && orderReturnRequest.getStatus() != ReturnRequestStatusEnum.QX) { |
| | | MemberOrderList.setStatus(orderReturnRequest.getStatus()); |
| | | MemberOrderList.setRequestId(orderReturnRequest.getId()); |
| | | MemberOrderList.setIsRequest(2); |
| | |
| | | OrderVO orderVO=new OrderVO(); |
| | | try { |
| | | orderVO = BeanUtils.copyBean(order, OrderVO.class); |
| | | orderVO.setAuctionType(order.getAuctionOrderType()); |
| | | orderVO.setCouponId(order.getCouponId()); |
| | | orderVO.setBound(order.getBound()); |
| | | orderVO.setIsRequest(order.getIsRequest()); |
| | | if (orderVO.getOrderFrom().getCode()==3){ |
| | | GoodsGroupPurchase data = GoodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | orderVO.setGroupTime(data.getGroupTime()); |
| | | orderVO.setSkuId(data.getGoodsSkuId()); |
| | | } |
| | | |
| | | OrderReturnRequest orderReturnRequest = orderReturnRequestService.getOne( |
| | | Wrappers.lambdaQuery(OrderReturnRequest.class) |
| | | .eq(OrderReturnRequest::getOrderId, |
| | | orderVO.getId()).eq(OrderReturnRequest::getDelFlag, |
| | | 0).last("limit 1")); |
| | | if (StringUtils.isNotNull(orderReturnRequest)&&orderReturnRequest!=null) { |
| | | orderVO.setStatus(orderReturnRequest.getStatus()); |
| | | orderVO.setRequestId(orderReturnRequest.getId()); |
| | | orderVO.setIsRequest(2); |
| | | }else{ |
| | | orderVO.setIsRequest(1); |
| | | } |
| | | |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper3= Wrappers.lambdaQuery(); |
| | |
| | | } |
| | | }else { |
| | | orderVO.setIsAuctionBond(1); |
| | | orderVO.setBound(new BigDecimal(0)); |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | |
| | | orderVO.setOrderShuoMin(memberPointsPoints.getConfigValue()); |
| | | CustomConfig ReturnCycle = sysUserClient.getconfig("RETURN_CYCLE").getData(); |
| | | orderVO.setOrderZq(Integer.valueOf(ReturnCycle.getConfigValue())); |
| | | // 查询售后记录 |
| | | Optional<OrderReturnRequest> orderReturnRequestOpt = orderReturnRequestService.lambdaQuery() |
| | | .eq(OrderReturnRequest::getOrderId, order.getId()).oneOpt(); |
| | | if (orderReturnRequestOpt.isPresent()) { |
| | | OrderReturnRequest orderReturnRequest = orderReturnRequestOpt.get(); |
| | | orderVO.setStatus(orderReturnRequest.getStatus()); |
| | | } |
| | | return orderVO; |
| | | } |
| | | |
| | |
| | | goodsGroupPurchaseInfo.setMubre(order.getGroupNo()); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = GoodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo2(order.getGroupNo(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSeckiGoodsGroupPurchaseInfo.setPurchaseNum(order.getGoodsQuantity()); |
| | | GoodsSkuClient.updgoodsGroupPurchaseInfo1(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | } |
| | |
| | | goodsGroupPurchaseInfo.setMubre(order.getGroupNo()); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = GoodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo2(order.getGroupNo(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSeckiGoodsGroupPurchaseInfo.setPurchaseNum(order.getGoodsQuantity()); |
| | | GoodsSkuClient.updgoodsGroupPurchaseInfo1(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | } |
| | |
| | | MembeOneDTO.setTotalPoints(order.getPoints()); |
| | | memberClient.updMembeOne(MembeOneDTO, SecurityConstants.INNER); |
| | | |
| | | MemberPointsDTO memberPointsDTO = new MemberPointsDTO(); |
| | | memberPointsDTO.setMemberId(order.getMemberId()); |
| | | memberPointsDTO.setPointsType(2); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.REDUCE); |
| | | memberPointsDTO.setPoints(order.getPoints()); |
| | | memberClient.addMemberPoints(memberPointsDTO); |
| | | |
| | | if (order.getPaymentMethod() != null && order.getPaymentMethod().getCode() == 2) {//支付宝 |
| | | //获取支付信息 |
| | |
| | | } |
| | | } |
| | | } |
| | | if (order.getOrderFrom().equals(OrderFromEnum.AUCTION_ORDERS)) { |
| | | refundBond(order); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | |
| | | Order byId = this.getById(memberOrderListDTO.getId()); |
| | | |
| | | if(byId.getOrderNo().contains("TG")){ |
| | | GoodsGroupPurchaseInfo goodsGroupPurchaseInfo =new GoodsGroupPurchaseInfo(); |
| | | goodsGroupPurchaseInfo.setGroupPurchaseId(byId.getGoodsSkuId()); |
| | | goodsGroupPurchaseInfo.setMubre(byId.getGroupNo()); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = GoodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo1(goodsGroupPurchaseInfo, SecurityConstants.INNER).getData(); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = GoodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo2(byId.getGroupNo(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSeckiGoodsGroupPurchaseInfo.setPurchaseNum(byId.getGoodsQuantity()); |
| | | GoodsSkuClient.updgoodsGroupPurchaseInfo1(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | } |
| | |
| | | order.setReceiveTime(LocalDateTime.now()); |
| | | baseMapper.updateById(order); |
| | | |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper= Wrappers.lambdaQuery(); |
| | | wrapper.eq(OrderAuctionBond::getOrderId,order.getId()); |
| | | OrderAuctionBond orderAuctionBond = orderAuctionBondMapper.selectOne(wrapper); |
| | | if(orderAuctionBond!=null){ |
| | | if (order.getPaymentMethod() != null && order.getPaymentMethod().getCode() == 1) {//支付宝 |
| | | //获取支付信息 |
| | | LambdaQueryWrapper<Paylog> paylogEntityWrapper = Wrappers.lambdaQuery(); |
| | | paylogEntityWrapper.eq(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo()); |
| | | Paylog paylog = iPaylogService.getOne(paylogEntityWrapper); |
| | | boolean bo = paylogService.refundForAlipay(paylog.getOutTradeNo(), paylog.getTradeNo(), paylog.getPayMoney()); |
| | | if (!bo) { |
| | | System.out.println("支付宝退款失败"); |
| | | } |
| | | } else if (order.getPaymentMethod() != null && order.getPaymentMethod().getCode() == 2) {//微信 |
| | | //获取支付信息 |
| | | LambdaQueryWrapper<Paylog> paylogEntityWrapper = Wrappers.lambdaQuery(); |
| | | paylogEntityWrapper.eq(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo()); |
| | | Paylog paylog = iPaylogService.getOne(paylogEntityWrapper); |
| | | if (order.getAuctionOrderType().getCode()==1){ |
| | | |
| | | String refundMoney = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer refundFee = Integer.parseInt(refundMoney.substring(0, refundMoney.length() - 3)); |
| | | String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | refundFee = 1; |
| | | }else{ |
| | | |
| | | String regEx = "[^0-9]"; |
| | | Pattern p = Pattern.compile(regEx); |
| | | Matcher m = p.matcher(order.getOrderNo()); |
| | | String ma = m.replaceAll("").trim(); |
| | | boolean bo = paylogService.refundForWxpay(4, paylog.getTradeNo(), paylog.getOutTradeNo(), "R" + ma, totalFee, refundFee, "2"); |
| | | if (!bo) { |
| | | System.out.println("微信退款失败"); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | }else{ |
| | | refundBond(order); |
| | | } else { |
| | | order.setOrderStatus(OrderStatusEnum.FINISHED); |
| | | order.setReceiveTime(LocalDateTime.now()); |
| | | baseMapper.updateById(order); |
| | | } |
| | | } |
| | | |
| | | private void refundBond(Order order) { |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper = Wrappers.lambdaQuery(); |
| | | wrapper.eq(order.getAuctionOrderType().equals(AuctionOrderTypeEnum.AUCTION_ITEMS), |
| | | OrderAuctionBond::getAuctionSalesroomId, order.getAuctionSalesroomId()); |
| | | wrapper.eq(order.getAuctionOrderType().equals(AuctionOrderTypeEnum.REGULAR_ITEMS), |
| | | OrderAuctionBond::getAuctionGoodsId, order.getGoodsSkuId()); |
| | | wrapper.eq(OrderAuctionBond::getMemberId, order.getMemberId()); |
| | | wrapper.eq(OrderAuctionBond::getBoundStatus, BondStatusEnum.PAID); |
| | | OrderAuctionBond orderAuctionBond = orderAuctionBondMapper.selectOne(wrapper); |
| | | if (orderAuctionBond != null && orderAuctionBond.getBond() != null) { |
| | | if (order.getPaymentMethod() != null && order.getPaymentMethod().getCode() == 2) {// 支付宝 |
| | | // 获取支付信息 |
| | | LambdaQueryWrapper<Paylog> paylogEntityWrapper = Wrappers.lambdaQuery(); |
| | | paylogEntityWrapper.eq(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo()); |
| | | Paylog paylog = iPaylogService.getOne(paylogEntityWrapper); |
| | | boolean bo = paylogService.refundForAlipay(paylog.getOutTradeNo(), |
| | | paylog.getTradeNo(), paylog.getPayMoney()); |
| | | if (!bo) { |
| | | System.out.println("支付宝退款失败"); |
| | | } else { |
| | | orderAuctionBond.setBoundStatus(BondStatusEnum.REFUNDED); |
| | | } |
| | | } else if (order.getPaymentMethod() != null |
| | | && order.getPaymentMethod().getCode() == 1) {// 微信 |
| | | // 获取支付信息 |
| | | LambdaQueryWrapper<Paylog> paylogEntityWrapper = Wrappers.lambdaQuery(); |
| | | paylogEntityWrapper.eq(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo()); |
| | | Paylog paylog = iPaylogService.getOne(paylogEntityWrapper); |
| | | |
| | | String refundMoney = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer refundFee = Integer.parseInt( |
| | | refundMoney.substring(0, refundMoney.length() - 3)); |
| | | String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | refundFee = 1; |
| | | String refundNo = OrderUtil.getOrderNoForPrefix("R"); |
| | | boolean bo = paylogService.refundForWxpay(4, paylog.getTradeNo(), |
| | | paylog.getOutTradeNo(), refundNo, totalFee, refundFee, "2"); |
| | | if (!bo) { |
| | | System.out.println("微信退款失败"); |
| | | } else { |
| | | orderAuctionBond.setBoundStatus(BondStatusEnum.REFUNDED); |
| | | } |
| | | } |
| | | orderAuctionBondMapper.updateById(orderAuctionBond); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | if(order.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO1.setGoodsSkuId(order.getGoodsSkuId()); |
| | | goodsStockUpdDTO1.setAuctionStock(goodsSku.getStock()+order.getGoodsQuantity()); |
| | | if (goodsSku.getSoldQuantity()-order.getGoodsQuantity()<0){ |
| | | goodsStockUpdDTO1.setSoldQuantity(0); |
| | | }else { |
| | | goodsStockUpdDTO1.setSoldQuantity(goodsSku.getSoldQuantity()-order.getGoodsQuantity()); |
| | | } |
| | | if (Objects.nonNull(goodsSku)) { |
| | | GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO1.setGoodsSkuId(order.getGoodsSkuId()); |
| | | goodsStockUpdDTO1.setAuctionStock( |
| | | goodsSku.getStock() + order.getGoodsQuantity()); |
| | | if (goodsSku.getSoldQuantity() - order.getGoodsQuantity() < 0) { |
| | | goodsStockUpdDTO1.setSoldQuantity(0); |
| | | } else { |
| | | goodsStockUpdDTO1.setSoldQuantity( |
| | | goodsSku.getSoldQuantity() - order.getGoodsQuantity()); |
| | | } |
| | | |
| | | goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1,SecurityConstants.INNER); |
| | | goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1, |
| | | SecurityConstants.INNER); |
| | | } |
| | | } |
| | | |
| | | if(order.getOrderNo().contains("MS")){ |
| | |
| | | wrapper1.eq(Order::getMemberId,homeGoodsSkuDTO1.getMemberId()); |
| | | wrapper1.eq(Order::getOrderFrom,3); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | wrapper1.eq(Order::getOrderStatus,2); |
| | | wrapper1.orderByDesc(Order::getCreateTime); |
| | | Page<Order> page = new Page<>(homeGoodsSkuDTO1.getPageCurr(), homeGoodsSkuDTO1.getPageSize()); |
| | | Page< Order> page1 = this.page(page, wrapper1); |
| | | PageDTO<WdOrderVO> HomeGoodsSeckillVOPageDTO = PageDTO.of(page1, WdOrderVO.class); |
| | |
| | | Order byId1 = this.getById(goodsGroupPurchaseeVO1.getId()); |
| | | |
| | | GoodsGroupPurchase data = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(byId1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | BeanUtils.copyProperties(data,goodsGroupPurchaseeVO1); |
| | | GoodsSku byId = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | goodsGroupPurchaseeVO1.setGoodsSkuName(byId.getSkuName()); |
| | | goodsGroupPurchaseeVO1.setCoverPic(byId.getCoverPic()); |
| | | goodsGroupPurchaseeVO1.setPrice(byId.getPrice()); |
| | | goodsGroupPurchaseeVO1.setYears(String.valueOf(byId.getYears().getYear())); |
| | | goodsGroupPurchaseeVO1.setIsGoodsGroupPurchase(2); |
| | | GoodsGroupPurchaseInfo one1 = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo2(byId1.getGroupNo(), SecurityConstants.INNER).getData(); |
| | | if (one1!=null) { |
| | | goodsGroupPurchaseeVO1.setCurrentNumber(one1.getCurrentNumber()); |
| | | if (one1.getGroupStatus() == 0) { |
| | | if (one1.getGroupSize() - one1.getCurrentNumber() < 5) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.MS_FAILURE); |
| | | } else { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.TO_FORM_A_GROUP); |
| | | if (Objects.nonNull(data)) { |
| | | BeanUtils.copyProperties(data, goodsGroupPurchaseeVO1); |
| | | GoodsSku byId = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), |
| | | SecurityConstants.INNER).getData(); |
| | | goodsGroupPurchaseeVO1.setGoodsSkuName(byId.getSkuName()); |
| | | goodsGroupPurchaseeVO1.setCoverPic(byId.getCoverPic()); |
| | | goodsGroupPurchaseeVO1.setPrice(byId.getPrice()); |
| | | goodsGroupPurchaseeVO1.setYears(String.valueOf(byId.getYears().getYear())); |
| | | goodsGroupPurchaseeVO1.setIsGoodsGroupPurchase(2); |
| | | if (byId1.getGroupNo() != null) { |
| | | GoodsGroupPurchaseInfo one1 = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo2( |
| | | byId1.getGroupNo(), SecurityConstants.INNER).getData(); |
| | | if (one1 != null) { |
| | | goodsGroupPurchaseeVO1.setCurrentNumber(one1.getCurrentNumber()); |
| | | if (one1.getGroupStatus() == 0) { |
| | | if (one1.getGroupSize() - one1.getCurrentNumber() < 5) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.MS_FAILURE); |
| | | } else { |
| | | goodsGroupPurchaseeVO1.setGroupStatus( |
| | | GroupStatusEnum.TO_FORM_A_GROUP); |
| | | } |
| | | } |
| | | } |
| | | if (one1.getGroupStatus() == 1) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.FORMED_INTO_A_GROUP); |
| | | } |
| | | if (goodsGroupPurchaseeVO1.getStartStatus().getCode() == 1) { |
| | | if (one1.getGroupStatus() == 1) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus( |
| | | GroupStatusEnum.FORMED_INTO_A_GROUP); |
| | | } |
| | | if (one1.getGroupStatus() == 2) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.TO_FORM_A_GROUP); |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.GROUP_FAILURE); |
| | | } |
| | | } else { |
| | | if (one1.getGroupStatus() == 2) { |
| | | if (data.getGroupStatus().getCode() == 1) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.TO_FORM_A_GROUP); |
| | | } |
| | | if (data.getGroupStatus().getCode() == 2) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus( |
| | | GroupStatusEnum.FORMED_INTO_A_GROUP); |
| | | } |
| | | if (data.getGroupStatus().getCode() == 3) { |
| | | goodsGroupPurchaseeVO1.setGroupStatus(GroupStatusEnum.GROUP_FAILURE); |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public List<Order> getOrderByCouponIds(Collection<Long> couponIds) { |
| | | return this.lambdaQuery().in(Order::getCouponId, couponIds).list(); |
| | | return this.lambdaQuery().in(Order::getCouponId, couponIds) |
| | | .ne(Order::getOrderStatus, OrderStatusEnum.CANCELED).eq(Order::getIsRequest, 1) |
| | | .list(); |
| | | } |
| | | |
| | | /** |
| | |
| | | query.getSkuName()) |
| | | .eq(StringUtils.isNotNull(query.getOrderStatus()), Order::getOrderStatus, |
| | | query.getOrderStatus()) |
| | | .eq(StringUtils.isNotNull(query.getOrderStatus()) && query.getOrderStatus() |
| | | .equals(OrderStatusEnum.FINISHED), Order::getIsRequest, 1) |
| | | .orderByDesc(Order::getCreateTime) |
| | | .page(new Page<>(query.getPageCurr(), query.getPageSize())); |
| | | if (StringUtils.isEmpty(page.getRecords())) { |
| | |
| | | } |
| | | pageVO = PageDTO.of(page, MgtOrderVO.class); |
| | | List<MgtOrderVO> voList = pageVO.getList(); |
| | | List<Long> orderIdList = voList.stream().filter(order -> order.getIsRequest().equals(2)) |
| | | .map(MgtOrderVO::getId).collect( |
| | | Collectors.toList()); |
| | | if (CollUtils.isNotEmpty(orderIdList)) { |
| | | List<OrderReturnRequest> orderReturnRequestList = orderReturnRequestService.lambdaQuery() |
| | | .in(OrderReturnRequest::getOrderId, orderIdList) |
| | | .eq(OrderReturnRequest::getStatus, ReturnRequestStatusEnum.COMPLETED) |
| | | .eq(OrderReturnRequest::getAuditStatus, AuditStatusEnum.PASSED).list(); |
| | | List<Long> orderReturnRequestPassedIds = orderReturnRequestList.stream() |
| | | .map(OrderReturnRequest::getOrderId) |
| | | .collect(Collectors.toList()); |
| | | for (MgtOrderVO order : voList) { |
| | | if (orderReturnRequestPassedIds.contains(order.getId())) { |
| | | order.setIsRequest(3); |
| | | } |
| | | } |
| | | } |
| | | if (query.getQueryType() == OrderTypeEnum.AUCTION_ORDER) { |
| | | List<MgtOrderVO> list = voList; |
| | | // 封装参数查询拍卖会 |
| | |
| | | salesroomMap = auctionSalesroomList.stream() |
| | | .collect(Collectors.toMap(AuctionSalesroom::getId, |
| | | AuctionSalesroom::getSalesroomName)); |
| | | auctionSalesroomList.stream() |
| | | .map(AuctionSalesroom::getId) |
| | | .collect(Collectors.toSet()); |
| | | } |
| | | // 封装参数查询拍卖订单保证金 |
| | | Set<Long> auctionGoodsIdSet = list.stream() |
| | |
| | | order.setOrderStatus(OrderStatusEnum.FINISHED); |
| | | order.setReceiveTime(LocalDateTime.now()); |
| | | this.updateById(order); |
| | | // 拍卖订单退保证金 |
| | | if (order.getOrderFrom() == OrderFromEnum.AUCTION_ORDERS) { |
| | | refundBond(id); |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | throw new ServiceException("该订单已是售后状态"); |
| | | } |
| | | String orderNo = order.getOrderNo(); |
| | | Paylog paylog = iPaylogService.lambdaQuery().eq(Paylog::getOutTradeNo, orderNo) |
| | | .last("limit 1").one(); |
| | | Optional<Paylog> paylogOpt = iPaylogService.lambdaQuery().eq(Paylog::getOutTradeNo, orderNo) |
| | | .last("limit 1").oneOpt(); |
| | | PaymentMethodEnum paymentMethod = order.getPaymentMethod(); |
| | | |
| | | if (StringUtils.isNotNull(paylog)) { |
| | | if (paylogOpt.isPresent()) { |
| | | Paylog paylog = paylogOpt.get(); |
| | | boolean result = handleRefund(paymentMethod, paylog, orderNo); |
| | | if (result) { |
| | | paylog.setState(3);// 已退款 |
| | | iPaylogService.updateById(paylog); |
| | | } |
| | | OrderReturnRequest orderReturnRequest = new OrderReturnRequest(); |
| | | orderReturnRequest.setOrderId(id); |
| | | orderReturnRequest.setRequestTime(LocalDateTime.now()); |
| | | orderReturnRequest.setRequestType(RequestTypeEnum.REFUND); |
| | | orderReturnRequest.setRequestReason("管理后台退款"); |
| | | orderReturnRequest.setStatus(ReturnRequestStatusEnum.COMPLETED); |
| | | orderReturnRequest.setAuditStatus(AuditStatusEnum.PASSED); |
| | | orderReturnRequest.setAuditTime(LocalDateTime.now()); |
| | | orderReturnRequestService.save(orderReturnRequest); |
| | | } |
| | | order.setIsRequest(2); |
| | | this.updateById(order); |
| | | // 生成售后记录 |
| | | OrderReturnRequest orderReturnRequest = new OrderReturnRequest(); |
| | | orderReturnRequest.setOrderId(id); |
| | | orderReturnRequest.setRequestTime(LocalDateTime.now()); |
| | | orderReturnRequest.setRequestType(RequestTypeEnum.REFUND); |
| | | orderReturnRequest.setRequestReason("管理后台退款"); |
| | | orderReturnRequest.setStatus(ReturnRequestStatusEnum.COMPLETED); |
| | | orderReturnRequest.setAuditStatus(AuditStatusEnum.PASSED); |
| | | orderReturnRequest.setAuditTime(LocalDateTime.now()); |
| | | orderReturnRequestService.save(orderReturnRequest); |
| | | // 扣除订单积分 |
| | | Member member = memberClient.getMembeOne(order.getMemberId(), SecurityConstants.INNER) |
| | | .getData(); |
| | | if (StringUtils.isNotNull(member)) { |
| | | MemberPointsDTO memberPointsDTO = new MemberPointsDTO(); |
| | | memberPointsDTO.setMemberId(order.getMemberId()); |
| | | memberPointsDTO.setPointsType(1); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.INCREASE); |
| | | memberPointsDTO.setPointsType(2); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.REDUCE); |
| | | memberPointsDTO.setPoints(order.getPoints()); |
| | | memberClient.addMemberPoints(memberPointsDTO); |
| | | |
| | |
| | | refundMoney.substring(0, refundMoney.length() - 3)); |
| | | String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100D); |
| | | Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | String regEx = "[^0-9]"; |
| | | Pattern p = Pattern.compile(regEx); |
| | | Matcher m = p.matcher(orderNo); |
| | | String ma = m.replaceAll("").trim(); |
| | | String refundNo = OrderUtil.getOrderNoForPrefix("R"); |
| | | result = paylogService.refundForWxpay(2, paylog.getTradeNo(), |
| | | paylog.getOutTradeNo(), "R" + ma, totalFee, refundFee, "4"); |
| | | paylog.getOutTradeNo(), refundNo, totalFee, refundFee, "4"); |
| | | } else if (paymentMethod == PaymentMethodEnum.ALIPAY) { |
| | | result = paylogService.refundForAlipay(paylog.getOutTradeNo(), paylog.getTradeNo(), |
| | | paylog.getPayMoney()); |
| | |
| | | if (order.getAuctionOrderType() == AuctionOrderTypeEnum.AUCTION_ITEMS) { |
| | | orderAuctionBond = orderAuctionBondMapper.selectOne( |
| | | Wrappers.lambdaQuery(OrderAuctionBond.class) |
| | | .eq(OrderAuctionBond::getOrderId, id) |
| | | .eq(OrderAuctionBond::getAuctionSalesroomId, |
| | | order.getAuctionSalesroomId()) |
| | | .eq(OrderAuctionBond::getMemberId, order.getMemberId()) |
| | | .eq(OrderAuctionBond::getBoundStatus, BondStatusEnum.PAID)); |
| | | } else { |
| | | orderAuctionBond = orderAuctionBondMapper.selectOne( |
| | | Wrappers.lambdaQuery(OrderAuctionBond.class) |
| | | .eq(OrderAuctionBond::getOrderId, id) |
| | | .eq(OrderAuctionBond::getAuctionGoodsId, |
| | | order.getGoodsSkuId()) |
| | | .eq(OrderAuctionBond::getMemberId, order.getMemberId()) |
| | | .eq(OrderAuctionBond::getBoundStatus, BondStatusEnum.PAID)); |
| | | } |
| | | if (StringUtils.isNotNull(orderAuctionBond)) { |
| | | Paylog paylog = iPaylogService.lambdaQuery() |
| | | Optional<Paylog> paylogOpt = iPaylogService.lambdaQuery() |
| | | .in(Paylog::getOutTradeNo, orderAuctionBond.getOrderNo()) |
| | | .one(); |
| | | boolean result = handleRefund(orderAuctionBond.getPaymentMethod(), paylog, |
| | | orderAuctionBond.getOrderNo()); |
| | | if (result) { |
| | | paylog.setState(3);// 已退款 |
| | | orderAuctionBond.setBoundStatus(BondStatusEnum.REFUNDED); |
| | | iPaylogService.updateById(paylog); |
| | | this.updateById(order); |
| | | .oneOpt(); |
| | | if (paylogOpt.isPresent()) { |
| | | Paylog paylog = paylogOpt.get(); |
| | | boolean result = handleRefund(orderAuctionBond.getPaymentMethod(), paylog, |
| | | orderAuctionBond.getOrderNo()); |
| | | if (result) { |
| | | paylog.setState(3);// 已退款 |
| | | orderAuctionBond.setBoundStatus(BondStatusEnum.REFUNDED); |
| | | iPaylogService.updateById(paylog); |
| | | orderAuctionBondMapper.updateById(orderAuctionBond); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | @Override |
| | | public List<Order> updateOrderStatusByMubres2(String formedGroupMubres) { |
| | | return this.lambdaQuery().eq(Order::getGroupNo, formedGroupMubres).list(); |
| | | LambdaQueryWrapper<Order> wrapper = Wrappers.lambdaQuery(); |
| | | wrapper.eq(Order::getGroupNo, formedGroupMubres); |
| | | List<Order> page1 = this.list(wrapper); |
| | | return page1; |
| | | } |
| | | } |