淘宝相似商品推荐接口优化，根据商品ID搜索商品基本信息优化

admin

2019-11-16 a6f34b99ee20e528b766c8ed5a61bd9c5aa0e7ae

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

@@ -1,8 +1,7 @@
package com.yeshi.fanli.util;



import java.lang.reflect.Type;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;



@@ -11,7 +10,6 @@
import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;

import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.google.gson.reflect.TypeToken;

import com.qcloud.cmq.Message;

import com.yeshi.fanli.dto.HongBao;

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

@@ -19,10 +17,7 @@
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.TaoBaoOrder;

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



import net.sf.json.JSONObject;



public class CMQManager {

   private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";

@@ -31,6 +26,10 @@
   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推送队列

@@ -48,30 +47,37 @@
   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);

@@ -79,6 +85,7 @@
      cmqUtil.createQueue(FANLI_TICHENG_ORDER);

      cmqUtil.createQueue(ORDER_WEIQUAN);

      cmqUtil.createQueue(GOODS_UPDATE);

      cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

   }



   public static CMQManager getInstance() {

@@ -92,11 +99,9 @@
    * 

    * @param orderMap

    */

   public void addTaoBaoOrderMsg(String orderId, List<TaoBaoOrder> orderList) {

      if (!StringUtil.isNullOrEmpty(orderId) && orderList != null && orderList.size() > 0) {

         JSONObject item = new JSONObject();

         item.put(orderId, new GsonBuilder().create().toJson(orderList));

         cmqUtil.sendMsg(QUEUENAME_ORDER, item.toString());

   public void addTaoBaoOrderMsg(String orderId) {

      if (!StringUtil.isNullOrEmpty(orderId)) {

         cmqUtil.sendMsg(QUEUENAME_ORDER, orderId);

      }

   }



@@ -105,27 +110,18 @@
    * 

    * @param count

    */

   @SuppressWarnings("unchecked")

   public Map<String, List<TaoBaoOrder>> consumeTaoBaoOrderMsg(int count) {

   public List<String> consumeTaoBaoOrderMsg(int count) {

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

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

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



      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            JSONObject data = JSONObject.fromObject(result);

            Iterator<String> its = data.keySet().iterator();

            if (its.hasNext()) {

               String orderId = its.next();

               Type type = new TypeToken<List<TaoBaoOrder>>() {

               }.getType();

               List<TaoBaoOrder> orderList = new Gson().fromJson(data.optJSONArray(orderId).toString(), type);

               map.put(orderId, orderList);

            }

            resultList.add(result);

            // 删除消息

            cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);

         }

      return map;

      return resultList;

   }



   /**

@@ -134,7 +130,46 @@
    * @param receiptHandle

    */

   public void deleteTaoBaoOrderMsg(String receiptHandle) {

      cmqUtil.deleteMsg(EXTRACT_RESULT, 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);

   }



   /**

@@ -359,4 +394,44 @@
      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);

   }



}