glume-mall是一个B2C模式的电商平台，

package com.glume.glumemall.order.service.impl; import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.glume.common.core.constant.OrderConstant; import com.glume.common.core.exception.servlet.NoStockException; import com.glume.common.core.to.MemberRespTo; import com.glume.common.core.to.mq.OrderTo; import com.glume.common.core.to.mq.SeckillOrderTo; import com.glume.common.core.utils.R; import com.glume.common.core.utils.RedisUtils; import com.glume.common.core.utils.SpringUtils; import com.glume.common.core.utils.StringUtils; import com.glume.glumemall.order.entity.OrderItemEntity; import com.glume.common.core.enums.OrderStatusEnum; import com.glume.glumemall.order.entity.PaymentInfoEntity; import com.glume.glumemall.order.feign.CartFeignService; import com.glume.glumemall.order.feign.MemberFeignService; import com.glume.glumemall.order.feign.ProductFeignService; import com.glume.glumemall.order.feign.WareFeignService; import com.glume.glumemall.order.interceptor.LoginUserInterceptor; import com.glume.glumemall.order.service.OrderItemService; import com.glume.glumemall.order.service.PaymentInfoService; import com.glume.glumemall.order.to.OrderCreateTo; import com.glume.glumemall.order.vo.*; import org.springframework.amqp.AmqpException; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; 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.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.glume.common.mybatis.PageUtils; import com.glume.common.mybatis.Query; import com.glume.glumemall.order.dao.OrderDao; import com.glume.glumemall.order.entity.OrderEntity; import com.glume.glumemall.order.service.OrderService; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.annotation.Resource; @Service("orderService") public class OrderServiceImpl extends ServiceImpl<OrderDao, OrderEntity> implements OrderService { private ThreadLocal<OrderSubmitVo> confirmVoThreadLocal = new ThreadLocal<>(); @Resource MemberFeignService memberFeignService; @Resource CartFeignService cartFeignService; @Resource WareFeignService wareFeignService; @Resource ProductFeignService productFeignService; @Autowired PaymentInfoService paymentInfoService; @Autowired ThreadPoolExecutor executor; @Autowired OrderItemService orderItemService; @Autowired RabbitTemplate rabbitTemplate; @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 OrderEntity getOrderByOrderSn(String orderSn) { OrderEntity orderEntity = baseMapper.selectOne(new QueryWrapper<OrderEntity>().eq("order_sn",orderSn)); return orderEntity; } /** * 当前用户所有订单信息 */ @Override public PageUtils queryPageWithItem(Map<String, Object> params) { MemberRespTo memberRespTo = LoginUserInterceptor.toThreadLocal.get(); IPage<OrderEntity> orderEntityIPage = baseMapper.selectPage( new Query<OrderEntity>().getPage(params), new QueryWrapper<OrderEntity>() .eq("member_id", memberRespTo.getId()).orderByDesc("id")); List<OrderEntity> entityList = orderEntityIPage.getRecords().stream().map(orderEntity -> { List<OrderItemEntity> orderItemEntityList = orderItemService.list(new QueryWrapper<OrderItemEntity>().eq("order_sn", orderEntity.getOrderSn())); orderEntity.setOrderItemEntities(orderItemEntityList); return orderEntity; }).collect(Collectors.toList()); orderEntityIPage.setRecords(entityList); return new PageUtils(orderEntityIPage); } /** * 处理支付宝的支付结果 */ @Override public String handlerPayResult(PayAsyncVo payAsyncVo) { PaymentInfoEntity paymentInfoEntity = new PaymentInfoEntity(); paymentInfoEntity.setAlipayTradeNo(payAsyncVo.getTrade_no()); paymentInfoEntity.setOrderSn(payAsyncVo.getOut_trade_no()); paymentInfoEntity.setPaymentStatus(payAsyncVo.getTrade_status()); paymentInfoEntity.setCallbackTime(payAsyncVo.getNotify_time()); // 保存交易流水 paymentInfoService.save(paymentInfoEntity); // 修改订单状态 if (payAsyncVo.getTrade_status().equals("TRADE_SUCCESS") || payAsyncVo.getTrade_status().equals("TRADE_FINISHED")) { String orderSn = payAsyncVo.getOut_trade_no(); baseMapper.updateOrderStatus(orderSn,OrderStatusEnum.PAYED.getCode()); } return "success"; } @Override public void closeOrder(OrderEntity orderEntity) { OrderEntity entity = baseMapper.selectById(orderEntity.getId()); // 当订单状态为待付款时，才能进行关闭订单 if (entity.getStatus() == OrderStatusEnum.CREATE_NEW.getCode()) { OrderEntity newOrderData = new OrderEntity(); newOrderData.setId(entity.getId()); newOrderData.setStatus(OrderStatusEnum.CANCLED.getCode()); baseMapper.updateById(newOrderData); OrderTo orderTo = new OrderTo(); BeanUtils.copyProperties(entity,orderTo); try { // TODO 保证消息一定能发送出去，每一个消息都可以做好日志记录（给数据库保存每一条记录） rabbitTemplate.convertAndSend("order-event-exchange","order.release.other.#",orderTo); } catch (AmqpException e) { // TODO 将没发送成功的消息进行重试发送 e.printStackTrace(); } } } @Override public PayVo getOrderPay(String orderSn) { PayVo payVo = new PayVo(); OrderEntity orderByOrderSn = this.getOrderByOrderSn(orderSn); payVo.setOut_trade_no(orderByOrderSn.getOrderSn()); // 保留小数点两位，并且向上取值 BigDecimal money = orderByOrderSn.getPayAmount().setScale(2, BigDecimal.ROUND_UP); payVo.setTotal_amount(money.toString()); List<OrderItemEntity> orderItemEntities = orderItemService.list(new QueryWrapper<OrderItemEntity>().eq("order_sn", orderSn)); payVo.setSubject(orderItemEntities.get(0).getSkuName()); payVo.setBody(orderItemEntities.get(0).getSkuAttrsVals()); return payVo; } /** * 订单确认页需要返回的数据 * @return */ @Override public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException { // TODO 订单确认页需要返回的数据待完成 OrderConfirmVo orderConfirmVo = new OrderConfirmVo(); MemberRespTo memberRespTo = LoginUserInterceptor.toThreadLocal.get(); /** 异步多线程：远程调用解决请求头丢失问题 */ ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); // 远程查询会员收货地址 CompletableFuture<Void> feignMemberAddress = CompletableFuture.runAsync(() -> { RequestContextHolder.setRequestAttributes(r