From 8b25dae4f4481a72a1adbb09a6628f2e001f45b1 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期三, 29 四月 2020 16:25:46 +0800
Subject: [PATCH] 动态自动删除过期
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java
index 8e92832..6b569e1 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java
@@ -50,7 +50,12 @@
return TransactionStatus.CommitTransaction;
else
return TransactionStatus.RollbackTransaction;
- } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
+ } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.teamRewardPreRecieved.name())) {
+ if (hongBaoV2SettleTempService.countByKey(msg.getKey()) > 0)
+ return TransactionStatus.CommitTransaction;
+ else
+ return TransactionStatus.RollbackTransaction;
+ }else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(msg.getBody()),
OrderMoneyRecievedMQMsg.class);
if (dto != null) {
--
Gitblit v1.8.0