尚品汇-订单拆单、付出宝关闭交易、关闭过期订单整合（五十） ...

目录：
（1）拆单接口
（2）取消订单业务增补关闭付出记载
（3）付出宝关闭交易
（4）查询付出交易记载
 （5）PaymentFeignClient 长途接口
（6）整合关闭过期订单 
（1）拆单接口

堆栈表：不是同一个堆栈 

 

 

 

 在service_order模块
订单实现拆单接口OrderService

1. List<OrderInfo> orderSplit(Long orderId, String wareSkuMap);

复制代码

 拆单接口实现类OrderServiceImpl

1. @Override
2. @Transactional
3. public List<OrderInfo> orderSplit(Long orderId, String wareSkuMap) {
4.     ArrayList<OrderInfo> orderInfoArrayList = new ArrayList<>();
5.     /*
6.     1.  先获取到原始订单 107
7.     2.  将wareSkuMap 转换为我们能操作的对象 [{"wareId":"1","skuIds":["2","10"]},{"wareId":"2","skuIds":["3"]}]
8.         方案一：class Param{
9.                     private String wareId;
10.                     private List<String> skuIds;
11.                 }
12.         方案二：看做一个Map mpa.put("wareId",value); map.put("skuIds",value)
14.     3.  创建一个新的子订单 108 109 。。。
15.     4.  给子订单赋值
16.     5.  保存子订单到数据库
17.     6.  修改原始订单的状态
18.     7.  测试
19.      */
22.    //获取父订单
23.     OrderInfo orderInfoOrigin = getOrderInfoById(orderId);
24.     List<Map> maps = JSON.parseArray(wareSkuMap, Map.class);
25.     if (maps != null) {
26.         for (Map map : maps) {
27.             String wareId = (String) map.get("wareId");
29.             List<String> skuIds = (List<String>) map.get("skuIds");
31.             OrderInfo subOrderInfo = new OrderInfo();
32.             // 属性拷贝
33.             BeanUtils.copyProperties(orderInfoOrigin, subOrderInfo);
34.             // 防止主键冲突
35.             subOrderInfo.setId(null);
36.             //设置付订单id
37.             subOrderInfo.setParentOrderId(orderId);
38.             // 赋值仓库Id
39.             subOrderInfo.setWareId(wareId);
41.             // 计算子订单的金额: 必须有订单明细
42.             // 获取到子订单明细
43.             // 声明一个集合来存储子订单明细
44.             ArrayList<OrderDetail> orderDetails = new ArrayList<>();
46.             //获取父订单商品总明细
47.             List<OrderDetail> orderDetailList = orderInfoOrigin.getOrderDetailList();
48.             // 表示主主订单明细中获取到子订单的明细
49.             if (orderDetailList != null && orderDetailList.size() > 0) {
50.                 for (OrderDetail orderDetail : orderDetailList) {
51.                     // 获取子订单明细的商品Id
52.                     for (String skuId : skuIds) {
54.                         //对比是否是当前仓库的商品，就收集
55.                         if (Long.parseLong(skuId) == orderDetail.getSkuId().longValue()) {
56.                             // 将订单明细添加到集合
57.                             orderDetails.add(orderDetail);
58.                         }
59.                     }
60.                 }
61.             }
62.             subOrderInfo.setOrderDetailList(orderDetails);
63.             // 计算总金额
64.             subOrderInfo.sumTotalAmount();
65.             // 保存子订单 submitOrdser（subOrderInfo）
66.                 saveOrderInfo(subOrderInfo);
67.             // 将子订单添加到集合中！
68.             orderInfoArrayList.add(subOrderInfo);
69.         }
70.     }
71.     // 修改原始订单的状态
72.     updateOrderStatus(orderId, ProcessStatus.SPLIT);
73.     return orderInfoArrayList;
74. }

复制代码

 
 拆单接口控制器:OrderApiController：

1. /**
2. * 拆单业务
3. * @param request
4. * @return
5. */
6. @RequestMapping("orderSplit")
7. public String orderSplit(HttpServletRequest request){
8.     String orderId = request.getParameter("orderId");
9.     String wareSkuMap = request.getParameter("wareSkuMap");
11.     // 拆单：获取到的子订单集合
12.     List<OrderInfo> subOrderInfoList = orderService.orderSplit(Long.parseLong(orderId),wareSkuMap);
13.     // 声明一个存储map的集合
14.     ArrayList<Map> mapArrayList = new ArrayList<>();
15.     // 生成子订单集合
16.     for (OrderInfo orderInfo : subOrderInfoList) {
17.         Map map = orderService.initWareOrder(orderInfo);
18.         // 添加到集合中！
19.         mapArrayList.add(map);
20.     }
21.     return JSON.toJSONString(mapArrayList);
22. }

复制代码

前面已经写了： 

 实现类

 

多了两条子订单 

库存系统表： 
订单任务

 

订单任务详情 

（2）取消订单业务增补关闭付出记载

用户没有点击扫码付出，不会调用付出宝的接口，这个时间订单超时后直接关闭订单就行了，当点击扫码付出后，会调用付出宝接口这个时间就会天生PaymentInfo对象，这个时间超时了，还需要关闭付出记载

此时假如用户扫码了，但是没有付出，订单超时了，这个时间还需要关闭付出宝交易记载

关闭订单流程图：

在处理超时订单里：添加代码

在MqConst中添加常量

1. /**
2. * 关闭交易
3. */
4. public static final String EXCHANGE_DIRECT_PAYMENT_CLOSE = "exchange.direct.payment.close";
5. public static final String ROUTING_PAYMENT_CLOSE = "payment.close";
6. //队列
7. public static final String QUEUE_PAYMENT_CLOSE  = "queue.payment.close";

复制代码

根据业务进行发送1或2,2是有付出记载 

在取消订单实现类中发送消息关闭交易
更改接口

2是有付出记载，才发送消息

1. @Override
2. public void execExpiredOrder(Long orderId) {
3.     // orderInfo
4.     updateOrderStatus(orderId, ProcessStatus.CLOSED);
6.       rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_PAYMENT_CLOSE, MqConst.ROUTING_PAYMENT_CLOSE, orderId);
7. }

复制代码

service-payment模块接收消息

编写消费者

1. package com.atguigu.gmall.payment.receiver;
3. @Component
4. public class PaymentReceiver {
6.     @Autowired
7.     private PaymentService paymentService;
9.     @SneakyThrows
10.     @RabbitListener(bindings = @QueueBinding(
11.             value = @Queue(value = MqConst.QUEUE_PAYMENT_CLOSE,durable = "true"),
12.             exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_PAYMENT_CLOSE),
13.             key = {MqConst.ROUTING_PAYMENT_CLOSE}
14.     ))
15.     public void closePayment(Long orderId , Message message, Channel channel){
16.         if (null != orderId){
17.             // 关闭交易
18.             paymentService.closePayment(orderId);
19.         }
20.         // 手动ack
21.         channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
22.     }
23. }

复制代码

编写关闭交易记载接口与实现类

1. PaymentService

复制代码

1. /**
2. * 关闭过期交易记录
3. * @param orderId
4. */
5. void closePayment(Long orderId);

复制代码

1. @Override
2. public void closePayment(Long orderId) {
3.     // 设置关闭交易记录的条件  118
4.     QueryWrapper<PaymentInfo> paymentInfoQueryWrapper = new QueryWrapper<>();
5.     paymentInfoQueryWrapper.eq("order_id",orderId);
6.     // 如果当前的交易记录不存在，则不更新交易记录
7.     Integer count = paymentInfoMapper.selectCount(paymentInfoQueryWrapper);
8.     if (null == count || count.intValue()==0) return;
9.     // 在关闭支付宝交易之前。还需要关闭paymentInfo
10.     PaymentInfo paymentInfo = new PaymentInfo();
11.     paymentInfo.setPaymentStatus(PaymentStatus.ClOSED.name());
12.     paymentInfoMapper.update(paymentInfo,paymentInfoQueryWrapper);
14. }

复制代码

提交订单超时后会关闭订单 

（3）付出宝关闭交易

1. AlipayService接口

复制代码

1. /***
2. * 关闭交易
3. * @param orderId
4. * @return
5. */
6. Boolean closePay(Long orderId);

复制代码

编写实现类

1. @SneakyThrows
2. @Override
3. public Boolean closePay(Long orderId) {
4.     OrderInfo orderInfo = orderFeignClient.getOrderInfo(orderId);
5.     AlipayTradeCloseRequest request = new AlipayTradeCloseRequest();
6.     HashMap<String, Object> map = new HashMap<>();
7.     // map.put("trade_no",paymentInfo.getTradeNo()); // 从paymentInfo 中获取！
8.         map.put("out_trade_no",orderInfo.getOutTradeNo());
9.     map.put("operator_id","YX01");
10.     request.setBizContent(JSON.toJSONString(map));
12.     AlipayTradeCloseResponse response = alipayClient.execute(request);
13.     if(response.isSuccess()){
14.         System.out.println("调用成功");
15.         return true;
16.     } else {
17.         System.out.println("调用失败");
18.         return false;
19.     }
20. }

复制代码

编写控制器AlipayController :

2. http://localhost:8205/api/payment/alipay/closePay/25
3. // 根据订单Id关闭订单
4. @GetMapping("closePay/{orderId}")
5. @ResponseBody
6. public Boolean closePay(@PathVariable Long orderId){
7.     Boolean aBoolean = alipayService.closePay(orderId);
8.     return aBoolean;
9. }

复制代码

 

（4）查询付出交易记载

编写接口：AlipayService

2. /**
3. * 根据订单查询是否支付成功！
4.   * @param orderId
5. * @return
6. */
7. Boolean checkPayment(Long orderId);

复制代码

编写实现类

1. @SneakyThrows
2. @Override
3. public Boolean checkPayment(Long orderId) {
4.     // 根据订单Id 查询订单信息
5.     OrderInfo orderInfo = orderFeignClient.getOrderInfo(orderId);
6.     AlipayTradeQueryRequest request = new AlipayTradeQueryRequest();
7.     HashMap<String, Object> map = new HashMap<>();
8.     map.put("out_trade_no",orderInfo.getOutTradeNo());
9.     // 根据out_trade_no 查询交易记录
10.     request.setBizContent(JSON.toJSONString(map));
11.     AlipayTradeQueryResponse response = alipayClient.execute(request);
12.     if(response.isSuccess()){
13.         System.out.println("调用成功")；
14.         return true;
15.     } else {
16.         System.out.println("调用失败")
17.         return false;
18.     }
19. }

复制代码

 编写控制器

1. // 查看是否有交易记录
2. @RequestMapping("checkPayment/{orderId}")
3. @ResponseBody
4. public Boolean checkPayment(@PathVariable Long orderId){
5.     // 调用退款接口
6.     boolean flag = alipayService.checkPayment(orderId);
7.     return flag;
8. }

复制代码

没有付出返回false 

付出后返回true 

在AlipayController 添加查询PaymentInfo 数据接口
查询付出记载

1. @GetMapping("getPaymentInfo/{outTradeNo}")
2. @ResponseBody
3. public PaymentInfo getPaymentInfo(@PathVariable String outTradeNo){
4.     PaymentInfo paymentInfo = paymentService.getPaymentInfo(outTradeNo, PaymentType.ALIPAY.name());
5.     if (null!=paymentInfo){
6.         return paymentInfo;
7.     }
8.     return null;
9. }

复制代码

 （5）PaymentFeignClient 长途接口

创建service-payment-client

2. package com.atguigu.gmall.payment.client;
3. @FeignClient(value = "service-payment",fallback = PaymentDegradeFeignClient.class)
4. public interface PaymentFeignClient {
6.     @GetMapping("api/payment/alipay/closePay/{orderId}")
7.     Boolean closePay(@PathVariable Long orderId);
9.     @GetMapping("api/payment/alipay/checkPayment/{orderId}")
10.     Boolean checkPayment(@PathVariable Long orderId);
12.     @GetMapping("api/payment/alipay/getPaymentInfo/{outTradeNo}")
13.     PaymentInfo getPaymentInfo(@PathVariable String outTradeNo);
15. }

复制代码

PaymentDegradeFeignClient实现类 

2. @Component
3. public class PaymentDegradeFeignClient implements PaymentFeignClient {
4.     @Override<dependency>
5.     <groupId>com.atguigu.gmall</groupId>
6.     <artifactId>service-payment-client</artifactId>
7.     <version>1.0</version>
8. </dependency>
10.     public Boolean closePay(Long orderId) {
11.         return null;
12.     }
14.     @Override
15.     public Boolean checkPayment(Long orderId) {
16.         return null;
17.     }
19.     @Override
20.     public PaymentInfo getPaymentInfo(String outTradeNo) {
21.         return null;
22.     }
23.    
24. }

复制代码

（6）整合关闭过期订单 

在订单service-order项目中添加依赖

1. <dependency>
2.     <groupId>com.atguigu.gmall</groupId>
3.     <artifactId>service-payment-client</artifactId>
4.     <version>1.0</version>
5. </dependency>

复制代码

OrderReceiver 整合代码

1. 接口：OrderService

复制代码

1. /**
2. * 更新过期订单
3. * @param orderId
4. * @param flag
5. */
6. void execExpiredOrder(Long orderId,String flag);

复制代码

1. @Override
2. public void execExpiredOrder(Long orderId,String flag) {
3.     // 调用方法 状态
4.     updateOrderStatus(orderId,ProcessStatus.CLOSED);
6.     //2代表支付宝有交易记录就是扫码了没有支付
7.     if ("2".equals(flag)){
8.         // 发送消息队列，关闭支付宝的交易记录。
9.         rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_PAYMENT_CLOSE,MqConst.ROUTING_PAYMENT_CLOSE,orderId);
10.     }
11. }

复制代码

 

1. @Autowired
2. private RabbitService rabbitService;
4. @Autowired
5. private PaymentFeignClient paymentFeignClient;
6. //  监听消息
7. @SneakyThrows
8. @RabbitListener(queues = MqConst.QUEUE_ORDER_CANCEL)
9. public void orderCancel(Long orderId, Message message, Channel channel){
10.     try {
11.         //  判断订单id 是否存在！
12.         if (orderId!=null){
13.             //  根据订单Id 查询订单对象
14.             OrderInfo orderInfo = orderService.getById(orderId);
15.             //  判断
16.             if(orderInfo!=null && "UNPAID".equals(orderInfo.getOrderStatus()) && "UNPAID".equals(orderInfo.getProcessStatus())){
17.                 //  关闭过期订单！ 还需要关闭对应的 paymentInfo ，还有alipay.
18.                 //  orderService.execExpiredOrder(orderId);
19.                 //  查询支付记录信息paymentInfo -远程调用是否存在！
20.                 PaymentInfo paymentInfo = paymentFeignClient.getPaymentInfo(orderInfo.getOutTradeNo());
21.                 //  判断 用户点击了扫码支付
22.                 if(paymentInfo!=null && "UNPAID".equals(paymentInfo.getPaymentStatus())){
24.                     //  查看是否有支付宝交易记录！
25.                     Boolean flag = paymentFeignClient.checkPayment(orderId);
26.                     //  判断
27.                     if (flag){
28.                         //  flag = true , 有支付宝记录
29.                         //  调用关闭接口！ 扫码未支付这样才能关闭成功！
30.                         Boolean result = paymentFeignClient.closePay(orderId);
31.                         //  判断
32.                         if (result){
33.                             //  result = true; 关闭成功！未付款！需要关闭orderInfo， paymentInfo，Alipay
34.                             orderService.execExpiredOrder(orderId,"2");
35.                         }else {
36.                             //  result = false; 表示付款！
37.                             //  说明已经付款了！ 正常付款成功都会走异步通知！
38.                         }
39.                     }else {
40.                         //  没有交易记录，不需要关闭支付！  需要关闭orderInfo， paymentInfo
41.                           //关闭订单，关闭支付记录
42.                         orderService.execExpiredOrder(orderId,"2");
43.                     }
45.                 }else {
46.                     //  只关闭订单orderInfo！
47.                     orderService.execExpiredOrder(orderId,"1");
48.                 }
49.             }
50.         }
51.         
52.     } catch (Exception e) {
53.         //  写入日志...
54.         e.printStackTrace();
55.     }
56.     //  手动确认
57.     channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
58. }

复制代码

不进行付出 

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。