创建分享返回结果修改

admin

2020-03-12 19bf27d4ab468cfae8733ccb11850ebc6e5d1a62

 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