| | |
| | | import com.ruoyi.common.core.enums.RequestTypeEnum; |
| | | import com.ruoyi.common.core.enums.ReturnRequestStatusEnum; |
| | | import com.ruoyi.common.core.exception.ServiceException; |
| | | import com.ruoyi.common.core.utils.DateUtils; |
| | | import com.ruoyi.common.core.utils.StringUtils; |
| | | import com.ruoyi.common.core.utils.page.BeanUtils; |
| | | import com.ruoyi.common.core.utils.page.PageDTO; |
| | |
| | | import com.ruoyi.order.util.OrderUtil; |
| | | import com.ruoyi.order.util.SinataUtil; |
| | | import com.ruoyi.system.api.constants.DelayTaskEnum; |
| | | import com.ruoyi.system.api.domain.*; |
| | | import com.ruoyi.system.api.domain.AuctionSalesroom; |
| | | import com.ruoyi.system.api.domain.CouponMember; |
| | | import com.ruoyi.system.api.domain.CustomConfig; |
| | | import com.ruoyi.system.api.domain.DelayTask; |
| | | import com.ruoyi.system.api.domain.GoodsGroupPurchase; |
| | | import com.ruoyi.system.api.domain.GoodsSeckill; |
| | | import com.ruoyi.system.api.domain.GoodsSku; |
| | | import com.ruoyi.system.api.domain.Member; |
| | | import com.ruoyi.system.api.domain.MemberAddress; |
| | | import com.ruoyi.system.api.domain.Order; |
| | | import com.ruoyi.system.api.domain.OrderAuctionBond; |
| | | import com.ruoyi.system.api.domain.dto.CouponMemberDTO; |
| | | import com.ruoyi.system.api.domain.dto.GoodsStockUpdDTO; |
| | | import com.ruoyi.system.api.domain.dto.HomeGoodsSkuDTO; |
| | |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.time.LocalDateTime; |
| | | import java.util.*; |
| | | import java.util.Collection; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.function.Function; |
| | | import java.util.regex.Matcher; |
| | |
| | | order.setOrderNo(OrderUtil.getOrderNoForPrefix("TG")); |
| | | order.setIsOrder(2); |
| | | }if (OrderDTO.getOrderFrom().getCode()==4){ |
| | | order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS); |
| | | order.setOrderFrom(OrderFromEnum.AUCTION_ORDERS); |
| | | order.setOrderNo(OrderUtil.getOrderNoForPrefix("PM")); |
| | | order.setIsOrder(1); |
| | | } |
| | |
| | | |
| | | if (memberOrderDTO.getOrderFrom()==1){ |
| | | GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (goodsSku.getListingStatus().getCode()==1){ |
| | | throw new ServiceException("该商品已经下架"); |
| | | } |
| | | if (goodsSku.getStock()<memberOrderDTO.getGoodsQuantity()){ |
| | | throw new ServiceException("对不起,购买数大于库存"); |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | }else{ |
| | | GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); |
| | |
| | | } |
| | | if (memberOrderDTO.getOrderFrom()==2){ |
| | | GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (data.getListingStatus().getCode()==1){ |
| | | throw new ServiceException("该商品已经下架"); |
| | | } |
| | | |
| | | String goodsLock = "goods_lock_" + CacheConstants.SECKILL_GOODS + data.getId(); |
| | | RLock redissonLock = redissonClient.getLock(goodsLock); |
| | | Integer surpNum = 0; |
| | |
| | | |
| | | GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (data.getLimitNumber()<num1) { |
| | | throw new ServiceException("对不起,大于商品购买数"); |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | } |
| | | |
| | | order.setOrderFrom(OrderFromEnum.SNAP_ORDERS); |
| | |
| | | pice=data.getSeckillPrice(); |
| | | |
| | | if (data.getSeckillStock()<1){ |
| | | throw new ServiceException("对不起,购买数大于库存"); |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | }else{ |
| | | GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO.setGoodsSkuId(data.getId()); |
| | |
| | | if (memberOrderDTO.getOrderFrom()==3){ |
| | | order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS); |
| | | GoodsGroupPurchase data = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (data.getListingStatus().getCode()==1){ |
| | | throw new ServiceException("该商品已经下架"); |
| | | } |
| | | Integer m=data.getCurrentNumber()+1; |
| | | if (m>data.getGroupSize()){ |
| | | throw new ServiceException("对不起,大成团人数"); |
| | |
| | | if (order.getOrderFrom().getCode()==1){ |
| | | GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | |
| | | GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); |
| | | goodsStockUpdDTO.setAuctionStock(goodsSku.getStock()+order.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, |
| | | SecurityConstants.INNER); |
| | | |
| | | if (goodsSku.getStock()+order.getGoodsQuantity()<memberOrderDTO.getGoodsQuantity()){ |
| | | throw new ServiceException("对不起,购买数大于库存"); |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | } |
| | | |
| | | GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); |
| | | goodsStockUpdDTO.setAuctionStock(goodsSku.getStock()+order.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, |
| | | SecurityConstants.INNER); |
| | | |
| | | Integer m= goodsSku.getStock()+order.getGoodsQuantity(); |
| | | goodsStockUpdDTO.setAuctionStock(m-memberOrderDTO.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, |
| | |
| | | if (data.getLimitNumber()<num1){ |
| | | throw new ServiceException("对不起,大于商品购买数"); |
| | | }else{ |
| | | |
| | | |
| | | if (data.getSeckillStock()+order.getGoodsQuantity()<memberOrderDTO.getGoodsQuantity()){ |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | } |
| | | |
| | | GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); |
| | | goodsStockUpdDTO.setGoodsSkuId(data.getId()); |
| | | goodsStockUpdDTO.setAuctionStock(data.getSeckillStock()+order.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER); |
| | | |
| | | if (data.getSeckillStock()+order.getGoodsQuantity()<memberOrderDTO.getGoodsQuantity()){ |
| | | throw new ServiceException("对不起,购买数大于库存"); |
| | | } |
| | | |
| | | Integer m=data.getSeckillStock()+order.getGoodsQuantity(); |
| | | GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); |
| | |
| | | throw new ServiceException("对不起,大于商品购买数"); |
| | | }else{ |
| | | if (data.getLimitNumber()<memberOrderDTO.getGoodsQuantity()){ |
| | | throw new ServiceException("对不起,购买数大于库存"); |
| | | throw new ServiceException("该商品已售罄,暂无库存"); |
| | | }else{ |
| | | memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); |
| | | memberOrderVO.setPrice(data.getGroupPurchasePrice()); |
| | |
| | | |
| | | @Override |
| | | public PageDTO<MemberOrderListVO> MemberrderList(MemberOrderListDTO memberOrderListDTO) { |
| | | |
| | | Page<Order> page = new Page<>(memberOrderListDTO.getPageCurr(), memberOrderListDTO.getPageSize()); |
| | | LambdaQueryWrapper<Order> wrapper= Wrappers.lambdaQuery(); |
| | | wrapper.eq(Order::getMemberId,memberOrderListDTO.getMemberId()); |
| | |
| | | } |
| | | if(memberOrderListDTO.getOrderStatus()!=null){ |
| | | wrapper.eq(Order::getOrderStatus,memberOrderListDTO.getOrderStatus().getCode()-1); |
| | | } |
| | | |
| | | if(memberOrderListDTO.getIsRequest()!=null){ |
| | | wrapper.eq(Order::getIsRequest,memberOrderListDTO.getIsRequest()); |
| | | } |
| | | wrapper.eq(Order::getIsOrder,1); |
| | | wrapper.eq(Order::getDelFlag,0); |
| | |
| | | OrderReturnRequest orderReturnRequest = orderReturnRequestService.getOne( |
| | | Wrappers.lambdaQuery(OrderReturnRequest.class) |
| | | .eq(OrderReturnRequest::getOrderId, |
| | | orderVO.getId()).last("limit 1")); |
| | | orderVO.getId()).eq(OrderReturnRequest::getDelFlag, |
| | | 0).last("limit 1")); |
| | | if (StringUtils.isNotNull(orderReturnRequest)&&orderReturnRequest!=null) { |
| | | orderVO.setStatus(orderReturnRequest.getStatus()); |
| | | orderVO.setRequestId(orderReturnRequest.getId()); |
| | |
| | | |
| | | @Override |
| | | public MemberOrderNumVO MemberOrderNum(MemberOrderListDTO memberOrderListDTO) { |
| | | LambdaQueryWrapper<Order> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(Order::getMemberId,memberOrderListDTO.getMemberId()); |
| | | wrapper1.eq(Order::getOrderStatus,1); |
| | | wrapper1.eq(Order::getIsOrder,1); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | wrapper1.orderByDesc(Order::getCancelTime); |
| | | List<Order> page2 = this.list(wrapper1); |
| | | for (Order MemberOrderList:page2) { |
| | | if (MemberOrderList.getOrderStatus().getCode() == 1) { |
| | | if (MemberOrderList.getOrderFrom().getCode() == 1 || MemberOrderList.getOrderFrom().getCode() == 2 || MemberOrderList.getOrderFrom().getCode() == 3) { |
| | | LocalDateTime localDateTime = MemberOrderList.getOrderTime().plusMinutes(30); |
| | | if (LocalDateTime.now().isAfter(localDateTime)) { |
| | | // dateTime1 在 dateTime2 之后 |
| | | MemberOrderList.setOrderStatus(OrderStatusEnum.CANCELED); |
| | | Order order = this.getById(MemberOrderList.getId()); |
| | | order.setOrderStatus(OrderStatusEnum.CANCELED); |
| | | this.updateById(order); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | MemberOrderNumVO vo=new MemberOrderNumVO(); |
| | | |
| | | LambdaQueryWrapper<Order> paylogEntityWrapper = Wrappers.lambdaQuery(); |
| | |
| | | List<Order> list2 = this.list(paylogEntityWrapper2); |
| | | vo.setDshorderNo(list2.size()); |
| | | |
| | | |
| | | |
| | | LambdaQueryWrapper<Order> paylogEntityWrapper3 = Wrappers.lambdaQuery(); |
| | | paylogEntityWrapper3.eq(Order::getMemberId, memberOrderListDTO.getMemberId()); |
| | | paylogEntityWrapper3.eq(Order::getIsRequest,2); |
| | | List<Order> list3 = this.list(paylogEntityWrapper3); |
| | | vo.setShorderNo(list3.size()); |
| | | return vo; |
| | | } |
| | | |