基于Java的unimall多端商城系统设计源码

package com.iotechn.unimall.app.api.order; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.dobbinsoft.fw.core.exception.AppServiceException; import com.dobbinsoft.fw.core.exception.ServiceException; import com.dobbinsoft.fw.core.util.GeneratorUtil; import com.dobbinsoft.fw.pay.enums.PayChannelType; import com.dobbinsoft.fw.pay.service.pay.MatrixPayService; import com.dobbinsoft.fw.support.component.CacheComponent; import com.dobbinsoft.fw.support.component.LockComponent; import com.dobbinsoft.fw.support.component.MachineComponent; import com.dobbinsoft.fw.support.model.Page; import com.dobbinsoft.fw.support.mq.DelayedMessageQueue; import com.dobbinsoft.fw.support.service.BaseService; import com.iotechn.unimall.biz.client.erp.ErpClient; import com.iotechn.unimall.biz.executor.GlobalExecutor; import com.iotechn.unimall.biz.service.address.AddressBizService; import com.iotechn.unimall.biz.service.cart.CartBizService; import com.iotechn.unimall.biz.service.coupon.CouponBizService; import com.iotechn.unimall.biz.service.freight.FreightTemplateBizService; import com.iotechn.unimall.biz.service.groupshop.GroupShopBizService; import com.iotechn.unimall.biz.service.notify.AdminNotifyBizService; import com.iotechn.unimall.biz.service.order.OrderBizService; import com.iotechn.unimall.biz.service.pay.PayBizService; import com.iotechn.unimall.biz.service.product.ProductBizService; import com.iotechn.unimall.data.constant.CacheConst; import com.iotechn.unimall.data.constant.LockConst; import com.iotechn.unimall.data.domain.AddressDO; import com.iotechn.unimall.data.domain.OrderDO; import com.iotechn.unimall.data.domain.OrderSkuDO; import com.iotechn.unimall.data.domain.SpuDO; import com.iotechn.unimall.data.dto.AdminDTO; import com.iotechn.unimall.data.dto.CouponUserDTO; import com.iotechn.unimall.data.dto.UserDTO; import com.iotechn.unimall.data.dto.freight.ShipTraceDTO; import com.iotechn.unimall.data.dto.order.OrderDTO; import com.iotechn.unimall.data.dto.order.OrderRequestDTO; import com.iotechn.unimall.data.dto.order.OrderRequestSkuDTO; import com.iotechn.unimall.data.dto.product.GroupShopDTO; import com.iotechn.unimall.data.dto.product.GroupShopSkuDTO; import com.iotechn.unimall.data.dto.product.SkuDTO; import com.iotechn.unimall.data.enums.*; import com.iotechn.unimall.data.exception.ExceptionDefinition; import com.iotechn.unimall.data.mapper.OrderMapper; import com.iotechn.unimall.data.mapper.OrderSkuMapper; import com.iotechn.unimall.data.mapper.SkuMapper; import com.iotechn.unimall.data.model.FreightCalcModel; import com.iotechn.unimall.data.model.OrderCalcSkuModel; import com.iotechn.unimall.data.model.SkuStockInfoModel; import com.iotechn.unimall.data.properties.UnimallOrderProperties; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; import org.springframework.util.StringUtils; import java.util.*; import java.util.stream.Collectors; /** * Created by rize on 2019/7/4. */ @Service public class OrderServiceImpl extends BaseService<UserDTO, AdminDTO> implements OrderService { private static final Logger logger = LoggerFactory.getLogger(OrderServiceImpl.class); @Autowired private SkuMapper skuMapper; @Autowired private CouponBizService couponBizService; @Autowired private OrderMapper orderMapper; @Autowired private OrderSkuMapper orderSkuMapper; @Autowired private CartBizService cartBizService; @Autowired private MatrixPayService payService; @Autowired private PayBizService payBizService; @Autowired private LockComponent lockComponent; @Autowired private AddressBizService addressBizService; @Autowired private OrderBizService orderBizService; @Autowired private FreightTemplateBizService freightTemplateBizService; @Autowired private GroupShopBizService groupShopBizService; @Autowired private AdminNotifyBizService adminNotifyBizService; @Autowired private CacheComponent cacheComponent; @Autowired private ProductBizService productBizService; @Autowired private DelayedMessageQueue delayedMessageQueue; @Autowired private MachineComponent machineComponent; @Value("${com.dobbinsoft.fw.env}") private String ENV; @Autowired private UnimallOrderProperties unimallOrderProperties; @Autowired private ErpClient erpClient; @Override @Transactional(rollbackFor = Exception.class) public String takeOrder(OrderRequestDTO orderRequest, String channel, Long userId) throws ServiceException { if (lockComponent.tryLock(LockConst.TAKE_ORDER_LOCK + userId, 20)) { //加上乐观锁，防止用户重复提交订单 List<OrderRequestSkuDTO> skuList = orderRequest.getSkuList(); boolean calcStockFlag = false; try { UserDTO user = sessionUtil.getUser(); //用户会员等级 Integer userLevel = user.getLevel(); if (user.getStatus().intValue() != UserStatusType.ACTIVE.getCode()) { throw new AppServiceException(ExceptionDefinition.ORDER_USER_IS_NOT_ACTIVE); } // 对Sku排序，防止相互拿锁，两边都无法结算的情况。 orderRequest.getSkuList().sort((o1, o2) -> (int) (o1.getSkuId() - o2.getSkuId())); //参数强校验 START if (CollectionUtils.isEmpty(skuList) || orderRequest.getTotalPrice() == null) { throw new AppServiceException(ExceptionDefinition.PARAM_CHECK_FAILED); } if (orderRequest.getTotalPrice() <= 0) { throw new AppServiceException(ExceptionDefinition.ORDER_PRICE_MUST_GT_ZERO); } // 若是卖虚拟物品，不需要收货地址，可以将此行注释掉 if (orderRequest.getAddressId() == null) { throw new AppServiceException(ExceptionDefinition.ORDER_ADDRESS_CANNOT_BE_NULL); } // 收货地址对象 AddressDO addressDO = addressBizService.getAddressById(orderRequest.getAddressId()); // 库存不足列表，用于提示前端 List<SkuStockInfoModel> stockErrorSkuList = new LinkedList<>(); // 商品状态异常列表，用于提示前端 List<Long> statusErrorSkuList = new LinkedList<>(); // 从缓存读取，用于计算的列表。属于SkuDO的部分属性。 List<OrderCalcSkuModel> calcSkuList = new ArrayList<>(); // 将SkuIds 查取出来 List<Long> skuIds = new ArrayList<>(); for (OrderRequestSkuDTO orderRequestSkuDTO : skuList) { Long skuId = orderRequestSkuDTO.getSkuId(); skuIds.add(skuId); OrderCalcSkuModel orderCalcSpuDTO = cacheComponent.getHashObj(CacheConst.PRT_SPU_HASH_BUCKET, "P" + orderRequestSkuDTO.getSpuId(), OrderCalcSkuModel.class); if (orderCalcSpuDTO == null) { // 尝试从DB中读取 SpuDO spuFromDB = productBizService.getProductByIdFromDB(orderRequestSkuDTO.getSpuId()); if (spuFromDB == null || (spuFromDB.getStatus() == SpuStatusType.STOCK