From ee5c8055b1c0dd7c67a9025a76b10bd287c93d9a Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 15 四月 2020 09:52:27 +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