基于SpringBoot和SpringCloud Alibaba的Java高并发区块链保税商品交易系统设计源码

package com.atguigu.gulimall.order.service.impl; import com.alibaba.fastjson.TypeReference; import com.atguigu.common.exception.NoStockException; import com.atguigu.common.to.mq.OrderTo; import com.atguigu.common.to.mq.SeckillOrderTo; import com.atguigu.common.utils.R; import com.atguigu.common.vo.MemberRespVo; //import com.atguigu.gulimall.order.feign.CartFeignService; //import com.atguigu.gulimall.order.feign.MemberFeignService; //import com.atguigu.gulimall.order.interceptor.LoginUserInterceptor; import com.atguigu.gulimall.order.config.AlipayTemplate; import com.atguigu.gulimall.order.constant.OrderConstant; import com.atguigu.gulimall.order.dao.OrderItemDao; import com.atguigu.gulimall.order.entity.OrderItemEntity; import com.atguigu.gulimall.order.entity.PaymentInfoEntity; import com.atguigu.gulimall.order.enume.OrderStatusEnum; import com.atguigu.gulimall.order.feign.CartFeignService; import com.atguigu.gulimall.order.feign.MemberFeignService; import com.atguigu.gulimall.order.feign.ProductFeignService; import com.atguigu.gulimall.order.feign.WmsFeignService; import com.atguigu.gulimall.order.interceptor.LoginUserInterceptor; import com.atguigu.gulimall.order.service.OrderItemService; import com.atguigu.gulimall.order.service.PaymentInfoService; import com.atguigu.gulimall.order.to.OrderCreateTo; import com.atguigu.gulimall.order.vo.*; import com.baomidou.mybatisplus.core.toolkit.IdWorker; 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 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 com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.atguigu.common.utils.PageUtils; import com.atguigu.common.utils.Query; import com.atguigu.gulimall.order.dao.OrderDao; import com.atguigu.gulimall.order.entity.OrderEntity; import com.atguigu.gulimall.order.service.OrderService; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.springframework.web.bind.annotation.RequestAttribute; import org.springframework.web.context.request.RequestAttributes; import org.springframework.web.context.request.RequestContextHolder; @Service("orderService") public class OrderServiceImpl extends ServiceImpl<OrderDao, OrderEntity> implements OrderService { private ThreadLocal<OrderSubmitVo> confirmVoThreadLocal = new ThreadLocal<>(); @Autowired OrderDao orderDao; @Autowired OrderItemDao orderItemDao; @Autowired MemberFeignService memberFeignService; @Autowired CartFeignService cartFeignService; @Autowired ThreadPoolExecutor threadPoolExecutor; @Autowired WmsFeignService wmsFeignService; @Autowired RabbitTemplate rabbitTemplate; @Autowired StringRedisTemplate redisTemplate; @Autowired ProductFeignService productFeignService; @Autowired PaymentInfoService paymentInfoService; @Autowired OrderItemService orderItemService; @Autowired AlipayTemplate alipayTemplate; @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); } @Override public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException { OrderConfirmVo orderConfirmVo = new OrderConfirmVo(); MemberRespVo memberRespVo = LoginUserInterceptor.threadLocal.get(); System.out.println("herer"); //每一个线程都来共享之前的请求数据 //每一个线程都来共享之前的请求数据 //1、远程查询收获列表 //获取之前的请求 RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes(); CompletableFuture<Void> getAddress = CompletableFuture.runAsync(() -> { RequestContextHolder.setRequestAttributes(requestAttributes); List<MemberAddressVo> address = memberFeignService.getAddress(memberRespVo.getId());//会员id orderConfirmVo.setAddressVos(address); System.out.println("微服务地址" + address); }, threadPoolExecutor); //2、远程查询购物车所有选定的购物项 CompletableFuture<Void> getItems = CompletableFuture.runAsync(() -> { RequestContextHolder.setRequestAttributes(requestAttributes); List<OrderItemVo> currentUserCartItems = cartFeignService.getCurrentUserCartItems(); orderConfirmVo.setItems(currentUserCartItems); }, threadPoolExecutor).thenRunAsync(() -> { List<OrderItemVo> items = orderConfirmVo.getItems(); List<Long> collect = items.stream().map(item -> item.getSkuId()).collect(Collectors.toList()); R skusHasStock = wmsFeignService.getSkusHasStock(collect); List<SkuStockVo> data = skusHasStock.getData(new TypeReference<List<SkuStockVo>>() { }); if (data != null) { Map<Long, Boolean> map = data.stream().collect(Collectors.toMap(SkuStockVo::getSkuId, SkuStockVo::getHasStock)); orderConfirmVo.setStocks(map); } }); //在远程调用之前，会调用很多的拦截器 创建一个新的request请求 //http1.1协议 //请求头中也根本没有数据 丢失请求头 // 有很多拦截器可以增强,但是feign中没有拦截器，需要我们自己构造一个拦截器，调用apply //拦截器拦截后，重新调用 // //3、查询用户积分 Integer integration = memberRespVo.getIntegration(); orderConfirmVo.setIntegration(integration); //其他数据自动计算 CompletableFuture.allOf(getAddress, getItems).get(); // 防重令牌 String token = UUID.randomUUID().toString().replace("-", ""); redisTemplate.opsForValue().set(OrderConstant.USER_ORDER_TOKEN_PREFIX + memberRespVo.getId(), token, 30, TimeUnit.MINUTES); orderConfirmVo.setOrderToken(token); return orderConfirmVo; } //下单操作 @Transactional //本地事物，在分布式系统，只能控制自己的回滚，控制不了其他服务的回滚。 //分布式事物：最大愿意：网络问题。 分布式机器， @Override public SubmitOrderResponseVo submitOrder(OrderSubmitVo vo) { SubmitOrderResponseVo responseVo = new SubmitOrderResponseVo(); MemberRespVo memberRespVo = LoginUserInterceptor.threadLocal.get(); responseVo.setCode(0); confirmVoThreadLocal.set(vo); //下单 //1、验证令牌(原子性) //0令牌失败 1令牌正确 删除成功 String script = "if redis.call('get',KEY[1])==ARGV[1] then return redis.call('del',KETS[1] else return 0 "; String orderToken = vo.getOrderToken(); Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class), Arrays.asList(OrderConstant.USER_ORDER_TOKEN_PREFIX + memberRespVo.getId())); //原子验证令牌和删除令牌 if (result == 0L) { //令牌验证失败 responseVo.setCode(1); return responseVo; } else { //令牌验证成功 /