gulimall（谷粒商城）是一个综合性的B2C平台，包括前台商城系统以及后台管理系统

package com.xunqi.gulimall.order.service.impl; import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.lly835.bestpay.model.PayResponse; import com.lly835.bestpay.service.BestPayService; import com.xunqi.common.exception.NoStockException; import com.xunqi.common.to.OrderTo; import com.xunqi.common.to.mq.SeckillOrderTo; import com.xunqi.common.utils.PageUtils; import com.xunqi.common.utils.Query; import com.xunqi.common.utils.R; import com.xunqi.common.vo.MemberResponseVo; import com.xunqi.gulimall.order.constant.PayConstant; import com.xunqi.gulimall.order.dao.OrderDao; import com.xunqi.gulimall.order.entity.OrderEntity; import com.xunqi.gulimall.order.entity.OrderItemEntity; import com.xunqi.gulimall.order.entity.PaymentInfoEntity; import com.xunqi.gulimall.order.enume.OrderStatusEnum; import com.xunqi.gulimall.order.feign.CartFeignService; import com.xunqi.gulimall.order.feign.MemberFeignService; import com.xunqi.gulimall.order.feign.ProductFeignService; import com.xunqi.gulimall.order.feign.WmsFeignService; import com.xunqi.gulimall.order.interceptor.LoginUserInterceptor; import com.xunqi.gulimall.order.service.OrderItemService; import com.xunqi.gulimall.order.service.OrderService; import com.xunqi.gulimall.order.service.PaymentInfoService; import com.xunqi.gulimall.order.to.OrderCreateTo; import com.xunqi.gulimall.order.to.SpuInfoVo; import com.xunqi.gulimall.order.vo.*; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.script.DefaultRedisScript; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; import java.math.BigDecimal; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import static com.xunqi.common.constant.CartConstant.CART_PREFIX; import static com.xunqi.gulimall.order.constant.OrderConstant.USER_ORDER_TOKEN_PREFIX; @Slf4j @Service("orderService") public class OrderServiceImpl extends ServiceImpl<OrderDao, OrderEntity> implements OrderService { private ThreadLocal<OrderSubmitVo> confirmVoThreadLocal = new ThreadLocal<>(); @Autowired private MemberFeignService memberFeignService; @Autowired private CartFeignService cartFeignService; @Autowired private WmsFeignService wmsFeignService; @Autowired private ProductFeignService productFeignService; @Autowired private OrderItemService orderItemService; @Autowired private StringRedisTemplate redisTemplate; @Autowired private RabbitTemplate rabbitTemplate; @Autowired private PaymentInfoService paymentInfoService; @Autowired private BestPayService bestPayService; @Autowired private ThreadPoolExecutor threadPoolExecutor; @Override public PageUtils queryPage(Map<String, Object> params) { IPage<OrderEntity> page = this.page( new Query<OrderEntity>().getPage(params), new QueryWrapper<OrderEntity>() ); return new PageUtils(page); } /** * 订单确认页返回需要用的数据 * @return */ @Override public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException { //构建OrderConfirmVo OrderConfirmVo confirmVo = new OrderConfirmVo(); //获取当前用户登录的信息 MemberResponseVo memberResponseVo = LoginUserInterceptor.loginUser.get(); //TODO :获取当前线程请求头信息(解决Feign异步调用丢失请求头问题) RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes(); //开启第一个异步任务 CompletableFuture<Void> addressFuture = CompletableFuture.runAsync(() -> { //每一个线程都来共享之前的请求数据 RequestContextHolder.setRequestAttributes(requestAttributes); //1、远程查询所有的收获地址列表 List<MemberAddressVo> address = memberFeignService.getAddress(memberResponseVo.getId()); confirmVo.setMemberAddressVos(address); }, threadPoolExecutor); //开启第二个异步任务 CompletableFuture<Void> cartInfoFuture = CompletableFuture.runAsync(() -> { //每一个线程都来共享之前的请求数据 RequestContextHolder.setRequestAttributes(requestAttributes); //2、远程查询购物车所有选中的购物项 List<OrderItemVo> currentCartItems = cartFeignService.getCurrentCartItems(); confirmVo.setItems(currentCartItems); //feign在远程调用之前要构造请求，调用很多的拦截器 }, threadPoolExecutor).thenRunAsync(() -> { List<OrderItemVo> items = confirmVo.getItems(); //获取全部商品的id List<Long> skuIds = items.stream() .map((itemVo -> itemVo.getSkuId())) .collect(Collectors.toList()); //远程查询商品库存信息 R skuHasStock = wmsFeignService.getSkuHasStock(skuIds); List<SkuStockVo> skuStockVos = skuHasStock.getData("data", new TypeReference<List<SkuStockVo>>() {}); if (skuStockVos != null && skuStockVos.size() > 0) { //将skuStockVos集合转换为map Map<Long, Boolean> skuHasStockMap = skuStockVos.stream().collect(Collectors.toMap(SkuStockVo::getSkuId, SkuStockVo::getHasStock)); confirmVo.setStocks(skuHasStockMap); } },threadPoolExecutor); //3、查询用户积分 Integer integration = memberResponseVo.getIntegration(); confirmVo.setIntegration(integration); //4、价格数据自动计算 //TODO 5、防重令牌(防止表单重复提交) //为用户设置一个token，三十分钟过期时间（存在redis） String token = UUID.randomUUID().toString().replace("-", ""); redisTemplate.opsForValue().set(USER_ORDER_TOKEN_PREFIX+memberResponseVo.getId(),token,30, TimeUnit.MINUTES); confirmVo.setOrderToken(token); CompletableFuture.allOf(addressFuture,cartInfoFuture).get(); return confirmVo; } /** * 提交订单 * @param vo * @return */ // @Transactional(isolation = Isolation.READ_COMMITTED) 设置事务的隔离级别 // @Transactional(propagation = Propagation.REQUIRED) 设置事务的传播级别 @Transactional(rollbackFor = Exception.class) // @GlobalTransactional(rollbackFor = Exception.class) @Override public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) { confirmVoThreadLocal.set(vo); SubmitOrderResponseVo responseVo = new SubmitOrderResponseVo(); //去创建、下订单、验令牌、验价格、锁定库存... //获取当前用户登录的信息 MemberResponseVo memberResponseVo = LoginUserInterceptor.loginUser.get(); responseVo.setCode(0); //1、验证令牌是否合法【令牌的对比和删除必须保证原子性】 String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return