From a6508a543e3727eb527db5feec9ac7155e88f599 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期一, 03 六月 2024 21:17:54 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java | 385 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 382 insertions(+), 3 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 e425d49..831b8a1 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
@@ -1,9 +1,33 @@
package com.ruoyi.order.service.impl;
-import com.ruoyi.order.domain.pojo.Order;
-import com.ruoyi.order.mapper.OrderMapper;
-import com.ruoyi.order.service.IOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.common.collect.Lists;
+import com.ruoyi.common.core.constant.SecurityConstants;
+import com.ruoyi.common.core.enums.OrderFromEnum;
+import com.ruoyi.common.core.enums.OrderStatusEnum;
+import com.ruoyi.common.core.enums.PaymentMethodEnum;
+import com.ruoyi.common.core.exception.ServiceException;
+import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.order.domain.OrderMall;
+import com.ruoyi.order.mapper.OrderMapper;
+import com.ruoyi.order.service.IOrderMallService;
+import com.ruoyi.order.service.IOrderService;
+import com.ruoyi.order.util.OrderUtil;
+import com.ruoyi.system.api.domain.*;
+import com.ruoyi.system.api.domain.dto.*;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+import javax.annotation.Resource;
+
+import com.ruoyi.system.api.domain.vo.MemberTiOrderVO;
+import com.ruoyi.system.api.domain.vo.OrderVO;
+import com.ruoyi.system.api.feignClient.GoodsSkuClient;
+import com.ruoyi.system.api.feignClient.MemberClient;
+import com.ruoyi.system.api.feignClient.PromotionClient;
import org.springframework.stereotype.Service;
/**
@@ -17,4 +41,359 @@
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
+
+
+ @Resource
+ private IOrderMallService orderMallService;
+
+ @Resource
+ private GoodsSkuClient goodsSkuClient;
+
+ @Resource
+ private MemberClient memberClient;
+
+ @Resource
+ private PromotionClient promotionClient;
+
+
+ @Override
+ public void saveOrderOne(OrderDTO OrderDTO) {
+ Order order=new Order();
+ if (OrderDTO.getOrderFrom().getCode()==1){
+ order.setOrderFrom(OrderFromEnum.COMMODITY_ORDER);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("SP"));
+ }
+ if (OrderDTO.getOrderFrom().getCode()==2){
+ order.setOrderFrom(OrderFromEnum.SNAP_ORDERS);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("MS"));
+ }
+ if (OrderDTO.getOrderFrom().getCode()==3){
+ order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("TG"));
+ }if (OrderDTO.getOrderFrom().getCode()==4){
+ order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("PM"));
+ }
+ order.setOrderTime(OrderDTO.getOrderTime());
+ order.setOrderFrom(OrderDTO.getOrderFrom());
+ order.setAuctionType(OrderDTO.getAuctionType());
+ order.setMemberId(OrderDTO.getMemberId());
+ order.setTotalAmount(OrderDTO.getTotalAmount());
+ order.setOrderStatus(OrderStatusEnum.TO_PLAY);
+ order.setGoodsQuantity(OrderDTO.getGoodsQuantity());
+ order.setReceiverName(OrderDTO.getReceiverName());
+ order.setReceiverphone(OrderDTO.getReceiverphone());
+ order.setReceiverCity(OrderDTO.getReceiverCity());
+ order.setReceiverDetailAddress(OrderDTO.getReceiverDetailAddress());
+ order.setBound(OrderDTO.getBound());
+ this.save(order);
+ }
+
+ /**
+ * 获取某个商品的已购会员数
+ *
+ * @param id 秒杀商品id
+ * @return 已购会员数
+ */
+ @Override
+ public Integer getSeckillMembers(Long id) {
+ return baseMapper.getSeckillMembers(id);
+ }
+
+ /**
+ * 获取团购商品已购数量
+ *
+ * @param id 团购商品id
+ * @return 团购商品已购数量
+ */
+ @Override
+ public Integer getGroupPurchasesGoodsNum(Long id) {
+ Set<Long> orderIdSet = orderMallService.lambdaQuery().eq(OrderMall::getActivityId, id)
+ .list()
+ .stream().map(OrderMall::getOrderId).collect(
+ Collectors.toSet());
+ List<Order> list = this.lambdaQuery().in(Order::getId, orderIdSet)
+ .in(Order::getOrderStatus, OrderStatusEnum.TO_BE_SHIPPED,
+ OrderStatusEnum.GOODS_TO_BE_RECEIVED, OrderStatusEnum.FINISHED).list();
+ return list.stream().map(Order::getGoodsQuantity).reduce(0, Integer::sum);
+ }
+
+ /**
+ * 根据团购商品id获取团购商品订单
+ *
+ * @param id 团购商品id
+ * @return 订单列表
+ */
+ @Override
+ public List<Order> getOrderByGroupPurchaseId(Long id) {
+ return baseMapper.getOrderByGroupPurchaseId(id);
+ }
+
+ @Override
+ public Order getOrderByGroupPurchaseMemberId(HomeGoodsSkuDTO homeGoodsSkuDTO) {
+ return baseMapper.getOrderByGroupPurchaseMemberId(homeGoodsSkuDTO);
+ }
+
+ @Override
+ public List<OrderVO> getOrderByGroupPurchaseMemberList(HomeGoodsSkuDTO homeGoodsSkuDTO) {
+ return baseMapper.getOrderByGroupPurchaseMemberList(homeGoodsSkuDTO);
+ }
+
+ @Override
+ public MemberTiOrderVO saveMemberOrder(MemberOrderDTO memberOrderDTO) {
+
+ MemberTiOrderVO memberOrderVO=new MemberTiOrderVO();
+ BigDecimal pice=new BigDecimal(0);
+
+ Order order=new Order();
+ if (memberOrderDTO.getOrderFrom()==1){
+ order.setOrderFrom(OrderFromEnum.COMMODITY_ORDER);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("SP"));
+ }
+ if (memberOrderDTO.getOrderFrom()==2){
+ order.setOrderFrom(OrderFromEnum.SNAP_ORDERS);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("MS"));
+ }
+ if (memberOrderDTO.getOrderFrom()==3){
+ order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS);
+ order.setOrderNo(OrderUtil.getOrderNoForPrefix("TG"));
+ }
+ if (memberOrderDTO.getPaymentMethod()==1){
+ order.setPaymentMethod(PaymentMethodEnum.WECHAT);
+ }if (memberOrderDTO.getPaymentMethod()==2){
+ order.setPaymentMethod(PaymentMethodEnum.ALIPAY);
+ }
+
+ if (memberOrderDTO.getOrderFrom()==1){
+ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ if (goodsSku.getStock()<memberOrderDTO.getGoodsQuantity()){
+ throw new ServiceException("对不起，购买数大于库存");
+ }else{
+ GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO();
+ goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId());
+ goodsStockUpdDTO.setAuctionStock(memberOrderDTO.getGoodsQuantity()*-1);
+ goodsSkuClient.updGoodsStock(Lists.newArrayList(goodsStockUpdDTO),
+ SecurityConstants.INNER);
+ }
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setPrice(goodsSku.getPrice());
+ memberOrderVO.setCoverPic(goodsSku.getCoverPic());
+ memberOrderVO.setSkuName(goodsSku.getSkuName());
+ pice=goodsSku.getPrice();
+ }
+ if (memberOrderDTO.getOrderFrom()==2){
+ order.setOrderFrom(OrderFromEnum.SNAP_ORDERS);
+ GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setPrice(goodsSku.getPrice());
+ memberOrderVO.setCoverPic(goodsSku.getCoverPic());
+ memberOrderVO.setSkuName(goodsSku.getSkuName());
+ memberOrderVO.setYouhiPrice(data.getSeckillPrice());
+ pice=data.getSeckillPrice();
+
+ if (data.getSeckillStock()<memberOrderDTO.getGoodsQuantity()){
+ throw new ServiceException("对不起，购买数大于库存");
+ }else{
+ GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO();
+ goodsStockUpdDTO.setGoodsSkuId(goodsSku.getId());
+ goodsStockUpdDTO.setAuctionStock(data.getSeckillStock()-memberOrderDTO.getGoodsQuantity());
+ goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER);
+ }
+
+
+ }
+ if (memberOrderDTO.getOrderFrom()==3){
+ order.setOrderFrom(OrderFromEnum.GROUP_PURCHASE_ORDERS);
+ GoodsGroupPurchase data = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(data.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setPrice(goodsSku.getPrice());
+ memberOrderVO.setCoverPic(goodsSku.getCoverPic());
+ memberOrderVO.setSkuName(goodsSku.getSkuName());
+ memberOrderVO.setYouhiPrice(data.getGroupPurchasePrice());
+ pice=data.getGroupPurchasePrice();
+ }
+ order.setMemberId(memberOrderDTO.getMemberId());
+ order.setGoodsQuantity(memberOrderDTO.getGoodsQuantity());
+ order.setOrderTime(LocalDateTime.now());
+ order.setGoodsQuantity(memberOrderDTO.getGoodsQuantity());
+ order.setTotalAmount(pice.multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity())));
+ 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());
+ }
+ }
+
+
+ baseMapper.insert(order);
+ OrderMall orderMall=new OrderMall();
+ orderMall.setOrderId(order.getId());
+ if (memberOrderDTO.getOrderFrom()==1){
+ orderMall.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ }
+ if (memberOrderDTO.getOrderFrom()==2){
+ orderMall.setActivityId(memberOrderDTO.getGoodsSkuId());
+ }
+ if (memberOrderDTO.getOrderFrom()==3){
+ orderMall.setActivityId(memberOrderDTO.getGoodsSkuId());
+ }
+ orderMallService.save(orderMall);
+ memberOrderVO.setId(order.getId());
+ memberOrderVO.setOrderStatus(OrderStatusEnum.TO_PLAY);
+ memberOrderVO.setOrderNo(order.getOrderNo());
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setOrderTime(order.getOrderTime());
+ memberOrderVO.setOrderFrom(order.getOrderFrom());
+ memberOrderVO.setMemberId(memberOrderDTO.getMemberId());
+ memberOrderVO.setPaymentMethod(order.getPaymentMethod());
+ memberOrderVO.setTotalAmount(order.getTotalAmount());
+ memberOrderVO.setOrderStatus(order.getOrderStatus());
+ memberOrderVO.setGoodsQuantity(order.getGoodsQuantity());
+ memberOrderVO.setReceiverName(order.getReceiverName());
+ memberOrderVO.setReceiverCity(order.getReceiverCity());
+ memberOrderVO.setReceiverDetailAddress(order.getReceiverDetailAddress());
+ memberOrderVO.setReceiverphone(order.getReceiverphone());
+
+ return memberOrderVO;
+ }
+
+ @Override
+ public MemberTiOrderVO updMemberOrder(MemberOrderDTO memberOrderDTO) {
+ Order order = baseMapper.selectById(memberOrderDTO.getId());
+ MemberTiOrderVO memberOrderVO=new MemberTiOrderVO();
+ if (memberOrderDTO.getReceiverDetailAddress()!=null){
+ order.setReceiverName(memberOrderDTO.getReceiverName());
+ order.setReceiverCity(memberOrderDTO.getReceiverCity());
+ order.setReceiverDetailAddress(memberOrderDTO.getReceiverDetailAddress());
+ order.setReceiverphone(memberOrderDTO.getReceiverphone());
+ }
+ if (memberOrderDTO.getOrderRemark()!=null){
+ order.setOrderRemark(memberOrderDTO.getOrderRemark());
+ }if (memberOrderDTO.getGoodsQuantity()!=null){
+ if (order.getOrderFrom().getCode()==1){
+ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(memberOrderDTO.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),
+ SecurityConstants.INNER);
+
+ GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO();
+ goodsStockUpdDTO1.setGoodsSkuId(goodsSku.getId());
+ goodsStockUpdDTO1.setAuctionStock(memberOrderDTO.getGoodsQuantity()*-1);
+ goodsSkuClient.updGoodsStock(Lists.newArrayList(goodsStockUpdDTO),
+ SecurityConstants.INNER);
+
+ order.setTotalAmount(goodsSku.getPrice().multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity())));
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setPrice(goodsSku.getPrice());
+ memberOrderVO.setCoverPic(goodsSku.getCoverPic());
+ memberOrderVO.setSkuName(goodsSku.getSkuName());
+ }
+
+ }
+ if (order.getOrderFrom().getCode()==2){
+ MemberOrderDTO memberOrderDTO1=new MemberOrderDTO();
+ memberOrderDTO1.setMemberId(memberOrderDTO.getMemberId());
+ memberOrderDTO1.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ Integer num=baseMapper.getSeckillMembers1(memberOrderDTO1);
+ GoodsSeckill data = goodsSkuClient.getGoodsSeckillOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ GoodsSku goodsSku = goodsSkuClient.getGoodsSkuOne(memberOrderDTO.getGoodsSkuId(), SecurityConstants.INNER).getData();
+ if (data.getLimitNumber()<=num){
+ throw new ServiceException("对不起，大于商品购买数");
+ }else{
+ if (data.getSeckillStock()<memberOrderDTO.getGoodsQuantity()){
+ throw new ServiceException("对不起，购买数大于库存");
+ }else{
+ GoodsStockUpdDTO goodsStockUpdDTO = new GoodsStockUpdDTO();
+ goodsStockUpdDTO.setGoodsSkuId(data.getId());
+ goodsStockUpdDTO.setAuctionStock(data.getSeckillStock()+order.getGoodsQuantity());
+ goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER);
+
+ GoodsStockUpdDTO goodsStockUpdDTO1 = new GoodsStockUpdDTO();
+ goodsStockUpdDTO1.setGoodsSkuId(data.getId());
+ goodsStockUpdDTO1.setAuctionStock(data.getSeckillStock()-memberOrderDTO.getGoodsQuantity());
+ goodsSkuClient.updGoodsSeckill(goodsStockUpdDTO,SecurityConstants.INNER);
+
+ order.setTotalAmount(data.getSeckillPrice().multiply(new BigDecimal(memberOrderDTO.getGoodsQuantity())));
+
+ }
+ }
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setPrice(goodsSku.getPrice());
+ memberOrderVO.setCoverPic(goodsSku.getCoverPic());
+ memberOrderVO.setSkuName(goodsSku.getSkuName());
+ memberOrderVO.setYouhiPrice(data.getSeckillPrice());
+ }
+ }
+
+ if (memberOrderDTO.getCouponId()!=null){
+ CouponMemberDTO couponMemberDTO=new CouponMemberDTO();
+ couponMemberDTO.setId(memberOrderDTO.getCouponId());
+ CouponMember data = promotionClient.getCouponMember(couponMemberDTO, SecurityConstants.INNER).getData();
+ BigDecimal pice=new BigDecimal(0);
+ if (data.getCouponType().getCode()==1){
+ pice= order.getTotalAmount();
+ if (pice.doubleValue()>=data.getFullReductionAmount().doubleValue()){
+ pice.subtract(data.getReductionAmount());
+ }
+ }
+ if (data.getCouponType().getCode()==2){
+ pice= order.getTotalAmount();
+ pice.subtract(data.getVoucherAmount());
+
+ }
+ if (data.getCouponType().getCode()==3){
+ pice= order.getTotalAmount();
+ BigDecimal pice1=new BigDecimal(data.getDiscountRate());
+ BigDecimal pice2=new BigDecimal(0.1);
+ BigDecimal pice3=pice.multiply(pice1.multiply(pice2));
+ BigDecimal pice4= pice.subtract(pice3);
+ if (pice4.doubleValue()>data.getMaxDiscount().doubleValue()){
+ pice=pice.subtract(data.getMaxDiscount());
+ }else{
+ pice=pice3;
+ }
+
+ }
+ order.setTotalAmount(pice);
+ }
+
+ baseMapper.updateById(order);
+
+ memberOrderVO.setId(order.getId());
+ memberOrderVO.setOrderStatus(OrderStatusEnum.TO_PLAY);
+ memberOrderVO.setOrderNo(order.getOrderNo());
+ memberOrderVO.setGoodsSkuId(memberOrderDTO.getGoodsSkuId());
+ memberOrderVO.setOrderTime(order.getOrderTime());
+ memberOrderVO.setOrderFrom(order.getOrderFrom());
+ memberOrderVO.setMemberId(memberOrderDTO.getMemberId());
+ memberOrderVO.setPaymentMethod(order.getPaymentMethod());
+ memberOrderVO.setTotalAmount(order.getTotalAmount());
+ memberOrderVO.setOrderStatus(order.getOrderStatus());
+ memberOrderVO.setGoodsQuantity(order.getGoodsQuantity());
+ memberOrderVO.setReceiverName(order.getReceiverName());
+ memberOrderVO.setReceiverCity(order.getReceiverCity());
+ memberOrderVO.setReceiverDetailAddress(order.getReceiverDetailAddress());
+ memberOrderVO.setReceiverphone(order.getReceiverphone());
+ memberOrderVO.setYouhiPrice(order.getDiscountMoney());
+
+ return memberOrderVO;
+ }
}
--
Gitblit v1.7.1