刷单标识

Administrator

2020-02-25 fb6eb1e6b9df772d243b5ade8b9e3dd08028e935

 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