订单修改

admin

2019-12-13 a3e7322a0aa6b5b13a84bc76923d0c6b68b13276

 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