From 26f41e1a5c34a3e36c9e73c237e3643e707924ce Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 18 一月 2020 11:36:51 +0800
Subject: [PATCH] 商城订单失效退还红包
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java | 21 ++++++++++++++-------
1 files changed, 14 insertions(+), 7 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java
index 5621840..7dd87ee 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java
@@ -39,9 +39,9 @@
@Override
public Action consume(Message message, ConsumeContext context) {
-
- LogHelper.mqInfo("consumer:BanLiShopOrderMessageListener",message.getMsgID(), message.getTopic(), message.getTag(),
- new String(message.getBody()));
+
+ LogHelper.mqInfo("consumer:BanLiShopOrderMessageListener", message.getMsgID(), message.getTopic(),
+ message.getTag(), new String(message.getBody()));
String tag = message.getTag();
if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
@@ -49,9 +49,16 @@
BanLiShopOrderMQMsg banLiShopOrderMQMsg = new Gson().fromJson(new String(message.getBody()),
BanLiShopOrderMQMsg.class);
if (banLiShopOrderMQMsg != null)
- // 浣胯鍗曞け鏁�
- banLiShopOrderService.invalidOrderByOrderId(banLiShopOrderMQMsg.getOrderId(), "璁㈠崟澶辨晥-闀挎湡鏈粯娆�");
- return Action.CommitMessage;
+ try {
+ banLiShopOrderPayService.invalidOrderByOrderId(banLiShopOrderMQMsg.getOrderId(), "璁㈠崟澶辨晥-闀挎湡鏈粯娆�");
+ return Action.CommitMessage;
+ } catch (BanLiShopOrderException e) {
+ e.printStackTrace();
+ return Action.CommitMessage;
+ } catch (Exception e) {
+ return Action.ReconsumeLater;
+ }
+
} else if (tag.equalsIgnoreCase(OrderTopicTagEnum.banLiShopOrderPaid.name()))// 鍟嗗煄璁㈠崟浠樻鎴愬姛
{
BanLiShopOrderMQMsg msg = new Gson().fromJson(new String(message.getBody()), BanLiShopOrderMQMsg.class);
@@ -71,7 +78,7 @@
}
return Action.CommitMessage;
}
-
+
}
return Action.CommitMessage;
}
--
Gitblit v1.8.0