package com.ruoyi.order.service.impl;
|
|
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;
|
|
/**
|
* <p>
|
* 订单表 服务实现类
|
* </p>
|
*
|
* @author mitao
|
* @since 2024-05-16
|
*/
|
@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;
|
}
|
}
|
