商城订单失效退还红包

admin

2020-01-18 26f41e1a5c34a3e36c9e73c237e3643e707924ce

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/BanLiShopOrderMessageListener.java

@@ -39,9 +39,9 @@


   @Override

   public Action consume(Message message, ConsumeContext context) {

		
      LogHelper.mqInfo("consumer:BanLiShopOrderMessageListener",message.getMsgID(), message.getTopic(), message.getTag(),

            new String(message.getBody()));



      LogHelper.mqInfo("consumer:BanLiShopOrderMessageListener", message.getMsgID(), message.getTopic(),

            message.getTag(), new String(message.getBody()));

      String tag = message.getTag();



      if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

@@ -49,9 +49,16 @@
            BanLiShopOrderMQMsg banLiShopOrderMQMsg = new Gson().fromJson(new String(message.getBody()),

                  BanLiShopOrderMQMsg.class);

            if (banLiShopOrderMQMsg != null)

               // 使订单失效

               banLiShopOrderService.invalidOrderByOrderId(banLiShopOrderMQMsg.getOrderId(), "订单失效-长期未付款");

            return Action.CommitMessage;

               try {

                  banLiShopOrderPayService.invalidOrderByOrderId(banLiShopOrderMQMsg.getOrderId(), "订单失效-长期未付款");

                  return Action.CommitMessage;

               } catch (BanLiShopOrderException e) {

                  e.printStackTrace();

                  return Action.CommitMessage;

               } catch (Exception e) {

                  return Action.ReconsumeLater;

               }



         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.banLiShopOrderPaid.name()))// 商城订单付款成功

         {

            BanLiShopOrderMQMsg msg = new Gson().fromJson(new String(message.getBody()), BanLiShopOrderMQMsg.class);

@@ -71,7 +78,7 @@
            }

            return Action.CommitMessage;

         }

			


      }

      return Action.CommitMessage;

   }