淘口令格式兼容

admin

2020-09-24 ca1ad791b7b7b04e57db6bd4fb93f0c1066a9f99

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

@@ -2,6 +2,11 @@


import javax.annotation.Resource;



import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.order.body.OrderWeiQuanMQMsg;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

import com.yeshi.fanli.service.inter.order.OrderProcessService;

import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;

import org.springframework.stereotype.Component;



import com.aliyun.openservices.ons.api.Action;

@@ -22,37 +27,15 @@
 * 订单到账消费

 * 

 * @author Administrator

 *

 */

@Component

public class OrderMessageListener implements MessageListener {



   @Resource

   private HongBaoV2SettleTempService hongBaoV2SettleTempService;

    private OrderProcessService orderProcessService;



   @Resource

   private HongBaoV2Service hongBaoV2Service;



   @Resource

   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private Producer producer;



   private int getHongBaoType(int type) {

      switch (type) {

      case HongBaoV2.TYPE_YIJI:

      case HongBaoV2.TYPE_ERJI:

      case HongBaoV2.TYPE_SHARE_YIJI:

      case HongBaoV2.TYPE_SHARE_ERJI:

         return OrderMoneyRecievedMQMsg.TYPE_INVITE;

      case HongBaoV2.TYPE_SHARE_GOODS:

         return OrderMoneyRecievedMQMsg.TYPE_SHARE;

      case HongBaoV2.TYPE_ZIGOU:

         return OrderMoneyRecievedMQMsg.TYPE_ZIGOU;

      }

      return 0;

   }

    private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService;



   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -60,10 +43,11 @@
            new String(message.getBody()));

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

         if (OrderTopicTagEnum.taoBaoOrderWeiQuan.name().equalsIgnoreCase(message.getTag())) {

            String key = message.getKey();

            // 订单维权

            //TODO 维权增加

				
                OrderWeiQuanMQMsg dto = new Gson().fromJson(new String(message.getBody()), OrderWeiQuanMQMsg.class);

                if (dto != null) {

                    TaoBaoWeiQuanOrder taoBaoWeiQuanOrder = taoBaoWeiQuanOrderService.selectByTradeId(dto.getTradeId());

                    orderProcessService.weiQuanOrder(taoBaoWeiQuanOrder);

                }

            return Action.CommitMessage;

         }

      }