From 0ec22dcf4fd9c4496e6f681e7fab89f56c6e4e8a Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期四, 02 四月 2020 14:45:20 +0800
Subject: [PATCH] vip 消息
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java | 10 +---------
1 files changed, 1 insertions(+), 9 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 bec2144..8e92832 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
@@ -19,7 +19,6 @@
import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
import com.yeshi.fanli.service.inter.order.CommonOrderService;
import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
-import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
@Component
@@ -30,9 +29,6 @@
@Resource
private HongBaoV2SettleTempService hongBaoV2SettleTempService;
-
- @Resource
- private InviteOrderSubsidyService inviteOrderSubsidyService;
@Resource
private CommonOrderService commonOrderService;
@@ -49,11 +45,7 @@
String tag = msg.getTag();
if (msg.getTopic().equalsIgnoreCase(MQTopicName.TOPIC_ORDER.name())) {
-
- if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {
- // TODO 鍔犲叆鎴愬姛鏍囪瘑
- return TransactionStatus.CommitTransaction;
- } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
+ if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
if (hongBaoV2SettleTempService.countByKey(msg.getKey()) > 0)
return TransactionStatus.CommitTransaction;
else
--
Gitblit v1.8.0