Merge branch 'div' into div-1

yujian

2020-03-24 88c7df1d5089d8e39f356a68eaccc18f308e190c

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

@@ -24,7 +24,7 @@
   private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";

   private static CMQManager cmqManager;

   private static CMQUtil cmqUtil;

   // TODO 订单处理队列

   // 订单处理队列

   public static String QUEUENAME_ORDER = "fanli-orders";



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

@@ -32,21 +32,27 @@


   // 提现结果处理队列

   public static String EXTRACT_RESULT = "extract-result";

   // TODO IOS推送队列

   //  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 FANLI_ORDER_TEAM_REWARD="fanli-order-team-reward";

	
   //  维权订单

   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 {



@@ -58,7 +64,11 @@
         FANLI_ORDER = "test-" + FANLI_ORDER;

         FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;

         FANLI_TICHENG_ORDER = "test-" + FANLI_TICHENG_ORDER;

			
         FANLI_ORDER_TEAM_REWARD = "test-" + FANLI_ORDER_TEAM_REWARD;

			
         ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;

         IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;

      }



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

@@ -68,7 +78,10 @@
      FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

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

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

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

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

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



      cmqUtil = CMQUtil.getInstance(secretId, secretKey);

      // 最大消息为1M

@@ -79,8 +92,10 @@
      cmqUtil.createQueue(FANLI_ORDER);

      cmqUtil.createQueue(FANLI_ORDER_NEW);

      cmqUtil.createQueue(FANLI_TICHENG_ORDER);

      cmqUtil.createQueue(FANLI_ORDER_TEAM_REWARD);

      cmqUtil.createQueue(ORDER_WEIQUAN);

      cmqUtil.createQueue(GOODS_UPDATE);

      cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

   }



   public static CMQManager getInstance() {

@@ -280,6 +295,30 @@
      cmqUtil.deleteMsg(FANLI_TICHENG_ORDER, receiptHandle);

   }



	
	
   // 团队奖励

   public void addFanLiOrderTeamRewardMsg(Long uid) {

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

   }



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

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

      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 deleteOrderTeamRewardMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER_TEAM_REWARD, receiptHandle);

   }

	
   // 维权订单

   public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {

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

@@ -389,4 +428,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);

   }



}