团队奖励相关机制建立

admin

2020-03-19 0d91bad397c1a1b41bc77d9cd9f7555ed78f7f1a

 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