唯品会链接解析升级

admin

2024-04-26 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c

 fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java

@@ -1,437 +1,451 @@
package com.yeshi.fanli.util;



import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



import org.yeshi.utils.CMQUtil;



import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;

import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.qcloud.cmq.Message;

import com.yeshi.fanli.dto.HongBao;

import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;

import com.yeshi.fanli.entity.bus.user.Extract;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.push.PushQueueRecord;

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



public class CMQManager {

   private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";

   private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";

   private static CMQManager cmqManager;

   private static CMQUtil cmqUtil;

   // TODO 订单处理队列

   public static String QUEUENAME_ORDER = "fanli-orders";



   // 刚刚产生的订单处理队列

   public static String QUEUENAME_NEW_ORDER = "fanli-new-orders";



   // 提现结果处理队列

   public static String EXTRACT_RESULT = "extract-result";

   // TODO IOS推送队列

   public static String PUSH_IOS = "push-ios";



   // TODO 返利队列

   public static String FANLI_ORDER = "fanli-order";



   // TODO 返利队列

   public static String FANLI_ORDER_NEW = "fanli-order-new";



   // TODO 提成订单

   public static String FANLI_TICHENG_ORDER = "fanli-ticheng-order";

   // TODO 维权订单

   public static String ORDER_WEIQUAN = "weiquan-order";



   public static String GOODS_UPDATE = "goods_update_queue";

   // 重要数据更新

   public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";



   static {



      if (Constant.IS_TEST) {

         QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;

         QUEUENAME_NEW_ORDER = "test-" + QUEUENAME_NEW_ORDER;

         EXTRACT_RESULT = "test-" + EXTRACT_RESULT;

         PUSH_IOS = "test-" + PUSH_IOS;

         FANLI_ORDER = "test-" + FANLI_ORDER;

         FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;

         FANLI_TICHENG_ORDER = "test-" + FANLI_TICHENG_ORDER;

         ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;

         IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;

      }



      QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

      QUEUENAME_NEW_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

      EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();

      PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();

      FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

      FANLI_ORDER_NEW += "-" + Constant.systemCommonConfig.getProjectName();

      FANLI_TICHENG_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

      ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();

      IMPORTANT_GOODS_UPDATE += "-" + Constant.systemCommonConfig.getProjectName();



      cmqUtil = CMQUtil.getInstance(secretId, secretKey);

      // 最大消息为1M

      cmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);

      cmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);

      cmqUtil.createQueue(EXTRACT_RESULT);

      cmqUtil.createQueue(PUSH_IOS);

      cmqUtil.createQueue(FANLI_ORDER);

      cmqUtil.createQueue(FANLI_ORDER_NEW);

      cmqUtil.createQueue(FANLI_TICHENG_ORDER);

      cmqUtil.createQueue(ORDER_WEIQUAN);

      cmqUtil.createQueue(GOODS_UPDATE);

      cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

   }



   public static CMQManager getInstance() {

      if (cmqManager == null)

         cmqManager = new CMQManager();

      return cmqManager;

   }



   /**

    * 发送订单消息

    * 
    * @param orderMap

    */

   public void addTaoBaoOrderMsg(String orderId) {

      if (!StringUtil.isNullOrEmpty(orderId)) {

         cmqUtil.sendMsg(QUEUENAME_ORDER, orderId);

      }

   }



   /**

    * 消费淘宝订单消息

    * 
    * @param count

    */

   public List<String> consumeTaoBaoOrderMsg(int count) {

      List<String> resultList = new ArrayList<>();

      List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_ORDER);



      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            resultList.add(result);

            // 删除消息

            cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);

         }

      return resultList;

   }



   /**

    * 删除淘宝订单消息

    * 
    * @param receiptHandle

    */

   public void deleteTaoBaoOrderMsg(String receiptHandle) {

      cmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);

   }



   /**

    * 发送订单消息（刚刚产生的订单）

    * 
    * @param orderMap

    */

   public void addTaoBaoNewOrderMsg(String orderId) {

      if (!StringUtil.isNullOrEmpty(orderId)) {

         cmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);

      }

   }



   /**

    * 消费淘宝订单消息（刚刚产生的订单）

    * 
    * @param count

    */

   public List<String> consumeTaoBaoNewOrderMsg(int count) {

      List<String> resultList = new ArrayList<>();

      List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);



      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            resultList.add(result);

            // 删除消息

            cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);

         }

      return resultList;

   }



   /**

    * 删除淘宝订单消息（刚刚产生的订单）

    * 
    * @param receiptHandle

    */

   public void deleteTaoBaoNewOrderMsg(String receiptHandle) {

      cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);

   }



   /**

    * 添加提现结果消息

    * 
    * @param extract

    * @param response

    */

   public void addExtractResultMsg(Extract extract, AlipayFundTransToaccountTransferResponse response,

         AdminUser adminUser) {

      String content = new Gson().toJson(new AlipayTransferResultInfo(extract, response, adminUser));

      cmqUtil.sendMsg(EXTRACT_RESULT, content);

   }



   /**

    * 消费提现结果消息

    * 
    * @param count

    * @return

    */

   public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, EXTRACT_RESULT);

      Map<String, AlipayTransferResultInfo> map = new HashMap<>();



      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

               AlipayTransferResultInfo alipayTransferResultInfo = new Gson().fromJson(result,

                     AlipayTransferResultInfo.class);

               map.put(msg.receiptHandle, alipayTransferResultInfo);

            }

         }

      return map;

   }



   /**

    * 删除提现结果消息

    * 
    * @param receiptHandle

    */

   public void deleteExtractResultMsg(String receiptHandle) {

      cmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);

   }



   // 订单返利

   public void addFanLiMsg(HongBao hongBao) {

      String content = new Gson().toJson(hongBao);

      cmqUtil.sendMsg(FANLI_ORDER, content);

   }



   // 新版订单返利

   public void addFanLiMsgNew(HongBaoV2 hongBao) {

      String content = new Gson().toJson(hongBao);

      cmqUtil.sendMsg(FANLI_ORDER_NEW, content);

   }



   public Map<String, HongBao> consumeFanLiMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER);

      Map<String, HongBao> map = new HashMap<>();

      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

               HongBao hongBao = new Gson().fromJson(result, HongBao.class);

               map.put(msg.receiptHandle, hongBao);

            }

         }

      return map;

   }



   public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);

      Map<String, HongBaoV2> map = new HashMap<>();

      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

               HongBaoV2 hongBao = new Gson().fromJson(result, HongBaoV2.class);

               map.put(msg.receiptHandle, hongBao);

            }

         }

      return map;

   }



   public void deleteFanLiMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);

   }



   public void deleteFanLiMsgNew(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

   }



   // 提成返利

   public void addFanLiTiChengMsg(Long uid) {

      cmqUtil.sendMsg(FANLI_TICHENG_ORDER, uid + "");

   }



   public Map<String, Long> consumeFanLiTiChengMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, FANLI_TICHENG_ORDER);

      Map<String, Long> map = new HashMap<>();

      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

               map.put(msg.receiptHandle, Long.parseLong(result));

            }

         }

      return map;

   }



   public void deleteFanLiTiChengMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_TICHENG_ORDER, receiptHandle);

   }



   // 维权订单

   public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {

      cmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));

   }



   public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, ORDER_WEIQUAN);

      Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();

      Gson gson = new Gson();

      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

               map.put(msg.receiptHandle, gson.fromJson(result, TaoBaoWeiQuanOrder.class));

            }

         }

      return map;

   }



   public void deleteWeiQuanOrderMsg(String receiptHandle) {

      cmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);

   }



   /**

    * 添加IOS推送消息

    * 
    * @param count

    */

   public void addIOSPushMsg(PushQueueRecord pushQueueRecord) {



      String content = new GsonBuilder().create().toJson(pushQueueRecord);

      cmqUtil.sendMsg(PUSH_IOS, content);

   }



   /**

    * IOS推送

    * 
    * @param count

    */

   public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, PUSH_IOS);

      if (list == null) {

         return null;

      }



      Map<String, PushQueueRecord> map = new HashMap<>();

      for (Message msg : list) {



         String result = msg.msgBody;

         if (!StringUtil.isNullOrEmpty(result)) {

            PushQueueRecord pushQueueRecord = new Gson().fromJson(result, PushQueueRecord.class);

            map.put(msg.receiptHandle, pushQueueRecord);

         }



      }



      return map;

   }



   /**

    * 删除IOSPush消息

    * 
    * @param receiptHandle

    */

   public void deleteIOSPushMsg(String receiptHandle) {

      cmqUtil.deleteMsg(PUSH_IOS, receiptHandle);

   }



   /**

    * 添加需要更新的商品ID

    * 
    * @param count

    */

   public void addNeedUpdateTaoBaoGoodsId(Long goodsId) {

      cmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");

   }



   /**

    * 消费消息需要更新的商品消息

    * 
    * @param count

    */

   public Map<String, Long> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, GOODS_UPDATE);

      if (list == null) {

         return null;

      }



      Map<String, Long> map = new HashMap<>();

      for (Message msg : list) {

         String result = msg.msgBody;

         if (!StringUtil.isNullOrEmpty(result)) {

            map.put(msg.receiptHandle, Long.parseLong(result));

         }



      }



      return map;

   }



   /**

    * 删除IOSPush消息

    * 
    * @param receiptHandle

    */

   public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {

      cmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);

   }



   /**

    * 添加淘宝重要商品更新

    * 
    * @param actionId

    */

   public void addTBImpGoodsUpdate(Long actionId) {

      cmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");

   }



   /**

    * 读取重要商品更新队列

    * 
    * @param count

    * @return

    */

   public Map<String, Long> consumeTBImpGoodsUpdateMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);

      if (list == null) {

         return null;

      }



      Map<String, Long> map = new HashMap<>();

      for (Message msg : list) {

         String result = msg.msgBody;

         if (!StringUtil.isNullOrEmpty(result)) {

            map.put(msg.receiptHandle, Long.parseLong(result));

         }

      }

      return map;

   }



   /**

    * 删除队列消息

    * 
    * @param receiptHandle

    */

   public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {

      cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);

   }



}

package com.yeshi.fanli.util;

import com.alipay.api.response.AlipayFundTransUniTransferResponse;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.qcloud.cmq.Message;
import com.yeshi.fanli.dto.HongBao;
import com.yeshi.fanli.dto.mq.UidDateDTO;
import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;
import com.yeshi.fanli.entity.bus.user.Extract;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.fanli.entity.push.PushQueueRecord;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.util.mq.cmq.TDMQUtil;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class CMQManager {
    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static CMQManager cmqManager;
    private static TDMQUtil tdmqUtil;
    // 订单处理队列
    public static String QUEUENAME_ORDER = "fanli-orders";

    // 刚刚产生的订单处理队列
    public static String QUEUENAME_NEW_ORDER = "fanli-new-orders";

    // 提现结果处理队列
    public static String EXTRACT_RESULT = "extract-result";
    // IOS推送队列
    public static String PUSH_IOS = "push-ios";

    // 返利队列
    public static String FANLI_ORDER = "fanli-order";

    // 返利队列
    public static String FANLI_ORDER_NEW = "fanli-order-new";


    // 分享订单收益
    public static String FANLI_SHARE_ORDER = "fanli-share-order";

    // 维权订单
    public static String ORDER_WEIQUAN = "weiquan-order";

    public static String GOODS_UPDATE = "goods_update_queue";
    // 重要数据更新
    public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";

    //特价会员开通
    public static String TEJIA_VIP = "tejia_vip";


    static {

        QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        QUEUENAME_NEW_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();
        PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_ORDER_NEW += "-" + Constant.systemCommonConfig.getProjectName();
        ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();
        IMPORTANT_GOODS_UPDATE += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_SHARE_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        TEJIA_VIP += "-" + Constant.systemCommonConfig.getProjectName();

        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        tdmqUtil = TDMQUtil.getInstance();
        // 最大消息为1M
        tdmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);
        tdmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);
        tdmqUtil.createQueue(EXTRACT_RESULT);
        tdmqUtil.createQueue(PUSH_IOS);
        tdmqUtil.createQueue(FANLI_ORDER);
        tdmqUtil.createQueue(FANLI_ORDER_NEW);

        tdmqUtil.createQueue(ORDER_WEIQUAN);
        tdmqUtil.createQueue(GOODS_UPDATE);
        tdmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

        tdmqUtil.createQueue(FANLI_SHARE_ORDER);
        tdmqUtil.createQueue(TEJIA_VIP);
    }

    public static CMQManager getInstance() {
        if (cmqManager == null)
            cmqManager = new CMQManager();
        return cmqManager;
    }

    /**
     * 发送订单消息
     *
     * @param orderId
     */
    public void addTaoBaoOrderMsg(String orderId) {
        if (!StringUtil.isNullOrEmpty(orderId)) {
            tdmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
        }
    }

    /**
     * 消费淘宝订单消息
     *
     * @param count
     */
    public List<String> consumeTaoBaoOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                tdmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
            }
        return resultList;
    }

    /**
     * 删除淘宝订单消息
     *
     * @param receiptHandle
     */
    public void deleteTaoBaoOrderMsg(String receiptHandle) {

        tdmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);

    }

    /**
     * 发送订单消息（刚刚产生的订单）
     *
     * @param orderId
     */
    public void addTaoBaoNewOrderMsg(String orderId) {
        if (!StringUtil.isNullOrEmpty(orderId)) {
            tdmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
        }
    }

    /**
     * 消费淘宝订单消息（刚刚产生的订单）
     *
     * @param count
     */
    public List<String> consumeTaoBaoNewOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
            }
        return resultList;
    }


    /**
     * 删除淘宝订单消息（刚刚产生的订单）
     *
     * @param receiptHandle
     */
    public void deleteTaoBaoNewOrderMsg(String receiptHandle) {

        tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);

    }

    /**
     * 添加提现结果消息
     *
     * @param extract
     * @param response
     */
    public void addExtractResultMsg(Extract extract, AlipayFundTransUniTransferResponse response,
                                    AdminUser adminUser) {
        String content = new Gson().toJson(new AlipayTransferResultInfo(extract, response, adminUser));
        tdmqUtil.sendMsg(EXTRACT_RESULT, content);
    }

    /**
     * 消费提现结果消息
     *
     * @param count
     * @return
     */
    public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, EXTRACT_RESULT);
        Map<String, AlipayTransferResultInfo> map = new HashMap<>();

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    AlipayTransferResultInfo alipayTransferResultInfo = new Gson().fromJson(result,
                            AlipayTransferResultInfo.class);
                    map.put(msg.receiptHandle, alipayTransferResultInfo);
                }
            }
        return map;
    }

    /**
     * 删除提现结果消息
     *
     * @param receiptHandle
     */
    public void deleteExtractResultMsg(String receiptHandle) {

        tdmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);

    }

    // 订单返利
    public void addFanLiMsg(HongBao hongBao) {
        String content = new Gson().toJson(hongBao);
        tdmqUtil.sendMsg(FANLI_ORDER, content);
    }

    // 新版订单返利
    public void addFanLiMsgNew(HongBaoV2 hongBao) {
        String content = new Gson().toJson(hongBao);
        tdmqUtil.sendMsg(FANLI_ORDER_NEW, content);
    }

    public Map<String, HongBao> consumeFanLiMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_ORDER);
        Map<String, HongBao> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    HongBao hongBao = new Gson().fromJson(result, HongBao.class);
                    map.put(msg.receiptHandle, hongBao);
                }
            }
        return map;
    }

    public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
        Map<String, HongBaoV2> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    HongBaoV2 hongBao = new Gson().fromJson(result, HongBaoV2.class);
                    map.put(msg.receiptHandle, hongBao);
                }
            }
        return map;
    }

    public void deleteFanLiMsg(String receiptHandle) {

        tdmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);

    }

    public void deleteFanLiMsgNew(String receiptHandle) {

        tdmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

    }


    // 分享订单收益
    public void addFanLiShareMsg(UidDateDTO dto) {
        tdmqUtil.sendMsg(FANLI_SHARE_ORDER, new Gson().toJson(dto));
    }

    public Map<String, UidDateDTO> consumeFanLiShareMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                UidDateDTO dto = new Gson().fromJson(result, UidDateDTO.class);
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, dto);
                }
            }
        return map;
    }

    public void deleteFanLiShareMsg(String receiptHandle) {
        tdmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
    }

    // 维权订单
    public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {
        tdmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
    }

    public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, ORDER_WEIQUAN);
        Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();
        Gson gson = new Gson();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, gson.fromJson(result, TaoBaoWeiQuanOrder.class));
                }
            }
        return map;
    }

    public void deleteWeiQuanOrderMsg(String receiptHandle) {
        tdmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
    }

    /**
     * 添加IOS推送消息
     *
     * @param pushQueueRecord
     */
    public void addIOSPushMsg(PushQueueRecord pushQueueRecord) {

        String content = new GsonBuilder().create().toJson(pushQueueRecord);
        tdmqUtil.sendMsg(PUSH_IOS, content);
    }

    /**
     * IOS推送
     *
     * @param count
     */
    public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, PUSH_IOS);
        if (list == null) {
            return null;
        }

        Map<String, PushQueueRecord> map = new HashMap<>();
        for (Message msg : list) {

            String result = msg.msgBody;
            if (!StringUtil.isNullOrEmpty(result)) {
                PushQueueRecord pushQueueRecord = new Gson().fromJson(result, PushQueueRecord.class);
                map.put(msg.receiptHandle, pushQueueRecord);
            }

        }

        return map;
    }

    /**
     * 删除IOSPush消息
     *
     * @param receiptHandle
     */
    public void deleteIOSPushMsg(String receiptHandle) {
        tdmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
    }

    /**
     * 添加需要更新的商品ID
     *
     * @param goodsId
     */
    public void addNeedUpdateTaoBaoGoodsId(String goodsId) {
        tdmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
    }

    /**
     * 消费消息需要更新的商品消息
     *
     * @param count
     */
    public Map<String, String> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, GOODS_UPDATE);
        if (list == null) {
            return null;
        }

        Map<String, String> map = new HashMap<>();
        for (Message msg : list) {
            String result = msg.msgBody;
            if (!StringUtil.isNullOrEmpty(result)) {
                map.put(msg.receiptHandle, result);
            }

        }

        return map;
    }

    /**
     * 删除IOSPush消息
     *
     * @param receiptHandle
     */
    public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {

        tdmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);

    }

    /**
     * 添加淘宝重要商品更新
     *
     * @param actionId
     */
    public void addTBImpGoodsUpdate(String actionId) {
        tdmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
    }

    /**
     * 读取重要商品更新队列
     *
     * @param count
     * @return
     */
    public Map<String, String> consumeTBImpGoodsUpdateMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
        if (list == null) {
            return null;
        }

        Map<String, String> map = new HashMap<>();
        for (Message msg : list) {
            String result = msg.msgBody;
            if (!StringUtil.isNullOrEmpty(result)) {
                map.put(msg.receiptHandle, result);
            }
        }
        return map;
    }

    /**
     * 删除队列消息
     *
     * @param receiptHandle
     */
    public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {
        tdmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
    }

}