From 1f43b711ebb1c18b83d86189312e2f1abe8a54d6 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期四, 04 七月 2024 09:00:00 +0800 Subject: [PATCH] 增加支付回调地址 --- ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java | 223 +++++++++++++++++++++++++++++++++++++++---------------- 1 files changed, 156 insertions(+), 67 deletions(-) diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java index 324d2ba..f52612c 100644 --- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java +++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java @@ -17,6 +17,7 @@ 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; @@ -35,16 +36,8 @@ import com.ruoyi.order.service.IPaylogService; import com.ruoyi.order.util.OrderUtil; import com.ruoyi.order.util.SinataUtil; -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.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.constants.DelayTaskEnum; +import com.ruoyi.system.api.domain.*; import com.ruoyi.system.api.domain.dto.CouponMemberDTO; import com.ruoyi.system.api.domain.dto.GoodsStockUpdDTO; import com.ruoyi.system.api.domain.dto.HomeGoodsSkuDTO; @@ -66,11 +59,9 @@ import com.ruoyi.system.api.feignClient.PromotionClient; import com.ruoyi.system.api.feignClient.SysUserClient; import java.math.BigDecimal; +import java.math.RoundingMode; import java.time.LocalDateTime; -import java.util.Collection; -import java.util.List; -import java.util.Map; -import java.util.Set; +import java.util.*; import java.util.concurrent.TimeUnit; import java.util.function.Function; import java.util.regex.Matcher; @@ -78,6 +69,7 @@ import java.util.stream.Collectors; import javax.annotation.Resource; import lombok.Synchronized; +import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.stereotype.Service; @@ -280,8 +272,8 @@ }else{ GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); - goodsStockUpdDTO.setAuctionStock(memberOrderDTO.getGoodsQuantity()*-1); - goodsSkuClient.updGoodsStock(Lists.newArrayList(goodsStockUpdDTO), + goodsStockUpdDTO.setAuctionStock(goodsSku.getStock()-memberOrderDTO.getGoodsQuantity()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, SecurityConstants.INNER); order.setSkuName(goodsSku.getSkuName()); @@ -296,10 +288,10 @@ } if (memberOrderDTO.getOrderFrom()==2){ GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData(); - /* String goodsLock = "goods_lock_" + CacheConstants.SECKILL_GOODS + data.getId(); + String goodsLock = "goods_lock_" + CacheConstants.SECKILL_GOODS + data.getId(); RLock redissonLock = redissonClient.getLock(goodsLock); Integer surpNum = 0; - try { + /* try { redissonLock.lock(30, TimeUnit.SECONDS); surpNum = redisService.getCacheObject(CacheConstants.SECKILL_GOODS + data.getId()); if (surpNum == null || surpNum < memberOrderDTO.getGoodsQuantity()) { @@ -309,9 +301,25 @@ }catch (Exception e){ throw new ServiceException("reids 出错"); }*/ - order.setOrderFrom(OrderFromEnum.SNAP_ORDERS); + + MemberOrderDTO memberOrderDTO1=new MemberOrderDTO(); + memberOrderDTO1.setMemberId(order.getMemberId()); + memberOrderDTO1.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); + Integer num=baseMapper.getSeckillMembers1(memberOrderDTO1); + Integer num1=0; + if (num!=null){ + num1 =num+1; + }else{ + num1=order.getGoodsQuantity(); + } + GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData(); + if (data.getLimitNumber()<num1) { + throw new ServiceException("对不起,大于商品购买数"); + } + + order.setOrderFrom(OrderFromEnum.SNAP_ORDERS); memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); memberOrderVO.setPrice(data.getSeckillPrice()); memberOrderVO.setSjPrice(goodsSku.getPrice()); @@ -320,12 +328,12 @@ memberOrderVO.setYouhiPrice(data.getSeckillPrice()); pice=data.getSeckillPrice(); - if (data.getSeckillStock()<memberOrderDTO.getGoodsQuantity()){ + if (data.getSeckillStock()<1){ throw new ServiceException("对不起,购买数大于库存"); }else{ GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); - goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); - goodsStockUpdDTO.setAuctionStock(data.getSeckillStock()-memberOrderDTO.getGoodsQuantity()); + goodsStockUpdDTO.setGoodsSkuId(data.getId()); + goodsStockUpdDTO.setAuctionStock(data.getSeckillStock()-1); goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER); } @@ -333,7 +341,7 @@ order.setPrice(data.getSeckillPrice()); order.setCoverPic(goodsSku.getCoverPic()); order.setSjPrice(goodsSku.getPrice()); - /*redisService.setCacheObject(CacheConstants.SECKILL_GOODS + data.getId(), surpNum - memberOrderDTO.getGoodsQuantity());*/ + redisService.setCacheObject(CacheConstants.SECKILL_GOODS + data.getId(), surpNum - memberOrderDTO.getGoodsQuantity()); } if (memberOrderDTO.getOrderFrom()==3){ order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS); @@ -361,26 +369,21 @@ CustomConfig memberPointsMoney = sysUserClient.getconfig("MEMBER_POINTS_MONEY").getData(); CustomConfig memberPointsPoints = sysUserClient.getconfig("MEMBER_POINTS_POINTS").getData(); - BigDecimal pic=pice.multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity())); - Double aDouble= Double.valueOf(memberPointsMoney.getConfigValue()) * Double.valueOf(memberPointsPoints.getConfigValue()); - BigDecimal pi=pic.multiply(new BigDecimal(aDouble)); - order.setPoints(pi.intValue()); + BigDecimal pic=pice.multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity())); + BigDecimal divide = pic.divide(new BigDecimal(memberPointsMoney.getConfigValue())); + BigDecimal roundedDown = divide.setScale(0, RoundingMode.DOWN); + BigDecimal aDouble= roundedDown.multiply(new BigDecimal(memberPointsPoints.getConfigValue())); + order.setPoints(aDouble.intValue()); + order.setOrderStatus(OrderStatusEnum.TO_PLAY); - if (memberOrderDTO.getOrderFrom()==3){ - order.setReceiverName(memberOrderDTO.getReceiverName()); - order.setReceiverCity(memberOrderDTO.getReceiverCity()); - order.setReceiverDetailAddress(memberOrderDTO.getReceiverDetailAddress()); - order.setReceiverPhone(memberOrderDTO.getReceiverphone()); - }else{ - MemberAddress data = memberClient.getMemberAddressOne( - memberOrderDTO.getMemberId(), SecurityConstants.INNER).getData(); - if (StringUtils.isNotNull(data)) { - order.setReceiverName(data.getRecipientName()); - order.setReceiverCity(data.getReceiverCity()); - order.setReceiverDetailAddress(data.getDetailedAddress()); - order.setReceiverPhone(data.getRecipientPhone()); - } + MemberAddress data = memberClient.getMemberAddressOne( + memberOrderDTO.getMemberId(), SecurityConstants.INNER).getData(); + if (StringUtils.isNotNull(data)) { + order.setReceiverName(data.getRecipientName()); + order.setReceiverCity(data.getReceiverCity()); + order.setReceiverDetailAddress(data.getDetailedAddress()); + order.setReceiverPhone(data.getRecipientPhone()); } order.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); @@ -402,7 +405,14 @@ memberOrderVO.setReceiverDetailAddress(order.getReceiverDetailAddress()); memberOrderVO.setReceiverphone(order.getReceiverPhone()); Integer delayTime = 30; - redisService.setCacheObject(CacheConstants.ORDER_AUTOMATIC_CANCEL + "-" + order.getId(), order.getId() , delayTime.longValue(), TimeUnit.MINUTES); + redisService.setCacheObject(DelayTaskEnum.ORDER_AUTOMATIC_CANCEL.getCode() + "-" + order.getId(), order.getId() , delayTime.longValue(), TimeUnit.MINUTES); + + DelayTask delayTask = new DelayTask(); + delayTask.setDelFlag(0); + delayTask.setCreateTime(LocalDateTime.now()); + delayTask.setExecuteTime(LocalDateTime.now().plusMinutes(30)); + delayTask.setRedisKey(DelayTaskEnum.ORDER_AUTOMATIC_CANCEL.getCode() + "-" + order.getId()); + sysUserClient.addDelayTask(delayTask, SecurityConstants.INNER); return memberOrderVO; } @@ -420,27 +430,27 @@ order.setReceiverCity(memberOrderDTO.getReceiverCity()); order.setReceiverDetailAddress(memberOrderDTO.getReceiverDetailAddress()); order.setReceiverPhone(memberOrderDTO.getReceiverphone()); + baseMapper.updateById(order); } if (memberOrderDTO.getOrderRemark()!=null){ order.setOrderRemark(memberOrderDTO.getOrderRemark()); }if (memberOrderDTO.getGoodsQuantity()!=null){ if (order.getOrderFrom().getCode()==1){ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); - if (goodsSku.getStock()<memberOrderDTO.getGoodsQuantity()){ - throw new ServiceException("对不起,购买数大于库存"); - }else{ + GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO(); goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId()); - goodsStockUpdDTO.setAuctionStock(order.getGoodsQuantity()*1); - goodsSkuClient.updGoodsStock(Lists.newArrayList(goodsStockUpdDTO), + goodsStockUpdDTO.setAuctionStock(goodsSku.getStock()+order.getGoodsQuantity()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, SecurityConstants.INNER); - GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); - goodsStockUpdDTO1.setGoodsSkuId(goodsSku.getId()); - goodsStockUpdDTO1.setAuctionStock(memberOrderDTO.getGoodsQuantity()*-1); - goodsSkuClient.updGoodsStock(Lists.newArrayList(goodsStockUpdDTO), + if (goodsSku.getStock()+order.getGoodsQuantity()<memberOrderDTO.getGoodsQuantity()){ + throw new ServiceException("对不起,购买数大于库存"); + } + Integer m= goodsSku.getStock()+order.getGoodsQuantity(); + goodsStockUpdDTO.setAuctionStock(m-memberOrderDTO.getGoodsQuantity()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO, SecurityConstants.INNER); - order.setTotalAmount(goodsSku.getPrice().multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity()))); order.setGoodsQuantity(memberOrderDTO.getGoodsQuantity()); memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); @@ -449,7 +459,7 @@ memberOrderVO.setSkuName(goodsSku.getSkuName()); } - } + if (order.getOrderFrom().getCode()==2){ MemberOrderDTO memberOrderDTO1=new MemberOrderDTO(); memberOrderDTO1.setMemberId(order.getMemberId()); @@ -464,22 +474,23 @@ GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData(); - if (data.getLimitNumber()<=num1){ + if (data.getLimitNumber()<num1){ throw new ServiceException("对不起,大于商品购买数"); }else{ - if (data.getSeckillStock()<memberOrderDTO.getGoodsQuantity()){ - throw new ServiceException("对不起,购买数大于库存"); - }else{ - order.setGoodsQuantity(memberOrderDTO.getGoodsQuantity()); 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(); goodsStockUpdDTO1.setGoodsSkuId(data.getId()); - goodsStockUpdDTO1.setAuctionStock(data.getSeckillStock()-memberOrderDTO.getGoodsQuantity()); - goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER); + goodsStockUpdDTO1.setAuctionStock(m-memberOrderDTO.getGoodsQuantity()); + goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO1,SecurityConstants.INNER); order.setTotalAmount(data.getSeckillPrice().multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity()))); order.setGoodsQuantity(memberOrderDTO.getGoodsQuantity()); @@ -488,7 +499,7 @@ order.setCoverPic(goodsSku.getCoverPic()); order.setSjPrice(goodsSku.getPrice()); - } + } memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId()); memberOrderVO.setPrice(goodsSku.getPrice()); @@ -547,10 +558,16 @@ if (pice.doubleValue()>=data.getFullReductionAmount().doubleValue()){ pice=pice.subtract(data.getReductionAmount()); order.setDiscountMoney(data.getReductionAmount()); + }else{ + pice=new BigDecimal(0); + } } if (data.getCouponType().getCode()==2){ pice= order.getTotalAmount(); + if(pice.compareTo(data.getVoucherAmount())<0){ + throw new ServiceException("优惠卷抵扣金额不能大于实际支付金额"); + } pice=pice.subtract(data.getVoucherAmount()); order.setDiscountMoney(data.getVoucherAmount()); } @@ -559,6 +576,13 @@ BigDecimal pice1=new BigDecimal(data.getDiscountRate()); BigDecimal pice2=new BigDecimal(0.1); BigDecimal pice3=pice.multiply(pice1.multiply(pice2)); + if (pice3.compareTo(new BigDecimal(data.getMaxDiscount().doubleValue()))>0){ + pice3=new BigDecimal(data.getMaxDiscount().doubleValue()); + } + if(pice.compareTo(pice3)<0){ + throw new ServiceException("优惠卷抵扣金额不能大于实际支付金额"); + } + BigDecimal pice4= pice.subtract(pice3); if (pice4.doubleValue()>data.getMaxDiscount().doubleValue()){ pice=pice.subtract(data.getMaxDiscount()); @@ -589,9 +613,16 @@ CustomConfig memberPointsMoney = sysUserClient.getconfig("MEMBER_POINTS_MONEY").getData(); CustomConfig memberPointsPoints = sysUserClient.getconfig("MEMBER_POINTS_POINTS").getData(); - Double aDouble= Double.valueOf(memberPointsMoney.getConfigValue()) * Double.valueOf(memberPointsPoints.getConfigValue()); - BigDecimal pi=pice.multiply(new BigDecimal(aDouble)); - order.setPoints(pi.intValue()); + if (pice.intValue()>0){ + BigDecimal divide = pice.divide(new BigDecimal(memberPointsMoney.getConfigValue())); + BigDecimal roundedDown = divide.setScale(0, RoundingMode.DOWN); + BigDecimal aDouble= roundedDown.multiply(new BigDecimal(memberPointsPoints.getConfigValue())); + order.setPoints(aDouble.intValue()); + }else{ + order.setPoints(0); + } + + baseMapper.updateById(order); } @@ -637,6 +668,20 @@ PageDTO<MemberOrderListVO> memberOrderListVOPageDTO = PageDTO.of(page1, MemberOrderListVO.class); List<MemberOrderListVO> list = memberOrderListVOPageDTO.getList(); for (MemberOrderListVO MemberOrderList:list){ + 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.getOrder(MemberOrderList.getId()); + order.setOrderStatus(OrderStatusEnum.CANCELED); + this.updateById(order); + } + + } + + } OrderReturnRequest orderReturnRequest = orderReturnRequestService.getOne( Wrappers.lambdaQuery(OrderReturnRequest.class) .eq(OrderReturnRequest::getOrderId, @@ -715,18 +760,60 @@ order.setOrderStatus(OrderStatusEnum.CANCELED); order.setCancelTime(LocalDateTime.now()); baseMapper.updateById(order); + + 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()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1,SecurityConstants.INNER); + } + + if(order.getOrderNo().contains("MS")){ + GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); + GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); + goodsStockUpdDTO1.setGoodsSkuId(order.getGoodsSkuId()); + goodsStockUpdDTO1.setAuctionStock(data.getSeckillStock()+order.getGoodsQuantity()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1,SecurityConstants.INNER); + } + + } if (order.getOrderStatus().getCode() == 2) { order.setOrderStatus(OrderStatusEnum.CANCELED); order.setCancelTime(LocalDateTime.now()); baseMapper.updateById(order); + 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()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1,SecurityConstants.INNER); + } + + if(order.getOrderNo().contains("MS")){ + GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(order.getGoodsSkuId(), SecurityConstants.INNER).getData(); + GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO(); + goodsStockUpdDTO1.setGoodsSkuId(order.getGoodsSkuId()); + goodsStockUpdDTO1.setAuctionStock(data.getSeckillStock()+order.getGoodsQuantity()); + goodsSkuClient.updGoodsStock1(goodsStockUpdDTO1,SecurityConstants.INNER); + } + + if (order.getCouponId()!=0){ + CouponMemberDTO couponMemberDTO1=new CouponMemberDTO(); + couponMemberDTO1.setId(order.getCouponId()); + couponMemberDTO1.setCouponStatus(0); + promotionClient.updCouponMember(couponMemberDTO1, SecurityConstants.INNER); + } + + updMembeOneDTO MembeOneDTO = new updMembeOneDTO(); MembeOneDTO.setType(2); MembeOneDTO.setMemberId(order.getMemberId()); MembeOneDTO.setMoney(order.getTotalAmount()); MembeOneDTO.setTotalPoints(order.getPoints()); - memberClient.updMembeOne(MembeOneDTO); + memberClient.updMembeOne(MembeOneDTO, SecurityConstants.INNER); if (order.getPaymentMethod() != null && order.getPaymentMethod().getCode() == 1) {//支付宝 @@ -884,9 +971,11 @@ } page = this.lambdaQuery() .in(StringUtils.isNotEmpty(memberIdSet), Order::getMemberId, memberIdSet) - .ne(query.getQueryType().equals(OrderTypeEnum.MALL_ODER), Order::getOrderFrom, + .ne(StringUtils.isNotNull(query.getQueryType()) && query.getQueryType() + .equals(OrderTypeEnum.MALL_ODER), Order::getOrderFrom, OrderFromEnum.AUCTION_ORDERS) - .eq(query.getQueryType().equals(OrderTypeEnum.AUCTION_ORDER), Order::getOrderFrom, + .eq(StringUtils.isNotNull(query.getQueryType()) && query.getQueryType() + .equals(OrderTypeEnum.AUCTION_ORDER), Order::getOrderFrom, OrderFromEnum.AUCTION_ORDERS) .like(StringUtils.isNotBlank(query.getOrderNo()), Order::getOrderNo, query.getOrderNo()) -- Gitblit v1.7.1