yujian
2020-05-21 ccc87b5ac3d6271f95bb8bd89d2f38d765365702
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalTransactionChecker.java
@@ -50,7 +50,12 @@
               return TransactionStatus.CommitTransaction;
            else
               return TransactionStatus.RollbackTransaction;
         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.teamRewardPreRecieved.name())) {
            if (hongBaoV2SettleTempService.countByKey(msg.getKey()) > 0)
               return TransactionStatus.CommitTransaction;
            else
               return TransactionStatus.RollbackTransaction;
         }else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
            OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(msg.getBody()),
                  OrderMoneyRecievedMQMsg.class);
            if (dto != null) {