邀请统计

yujian

2019-12-18 89cc8f054c27f70fcfe16f14554a8a12e0c19e23

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java

@@ -49,11 +49,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