Merge remote-tracking branch 'origin/div' into 2.1.2

admin

2020-05-20 98b1a0affd69bbe63223c21fdd2c404e8bedfccb

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

@@ -13,7 +13,6 @@
import com.qcloud.cmq.Message;

import com.yeshi.fanli.dto.HongBao;

import com.yeshi.fanli.dto.mq.UidDateDTO;

import com.yeshi.fanli.dto.order.dividents.UserDividentsDayDTO;

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

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

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

@@ -43,11 +42,10 @@
   // 返利队列

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



   // 团队收益

   public static String FANLI_TEAM_INCOME_ORDER = "fanli-team-income-order";





   // 分享订单收益

   public static String FANLI_SHARE_ORDER = "fanli-team-income-order";

   public static String FANLI_SHARE_ORDER = "fanli-share-order";



   // 维权订单

   public static String ORDER_WEIQUAN = "weiquan-order";

@@ -55,8 +53,6 @@
   public static String GOODS_UPDATE = "goods_update_queue";

   // 重要数据更新

   public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";

   // 团队分红

   public static String TEAM_DIVIDENTS = "team_dividents";



   static {



@@ -67,10 +63,9 @@
         PUSH_IOS = "test-" + PUSH_IOS;

         FANLI_ORDER = "test-" + FANLI_ORDER;

         FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;

         FANLI_TEAM_INCOME_ORDER = "test-" + FANLI_TEAM_INCOME_ORDER;

		
         ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;

         IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;

         TEAM_DIVIDENTS = "test-" + TEAM_DIVIDENTS;

         FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;

      }



@@ -80,10 +75,8 @@
      PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();

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

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

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

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

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

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

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



      cmqUtil = CMQUtil.getInstance(secretId, secretKey);

@@ -94,11 +87,11 @@
      cmqUtil.createQueue(PUSH_IOS);

      cmqUtil.createQueue(FANLI_ORDER);

      cmqUtil.createQueue(FANLI_ORDER_NEW);

      cmqUtil.createQueue(FANLI_TEAM_INCOME_ORDER);

	
      cmqUtil.createQueue(ORDER_WEIQUAN);

      cmqUtil.createQueue(GOODS_UPDATE);

      cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

      cmqUtil.createQueue(TEAM_DIVIDENTS);



      cmqUtil.createQueue(FANLI_SHARE_ORDER);

   }



@@ -277,28 +270,7 @@
      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

   }



   // 团队收益

   public void addFanLiTeamIncomeMsg(UidDateDTO dto) {

      cmqUtil.sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");

   }



   public Map<String, UidDateDTO> consumeFanLiTeamIncomeMsg(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_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 deleteTeamIncomeMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);

   }

	


   // 分享订单收益

   public void addFanLiShareMsg(UidDateDTO dto) {

@@ -470,29 +442,6 @@
    */

   public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {

      cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);

   }



   // 团队分红

   public void addTeamDividentsMsg(UserDividentsDayDTO dto) {

      cmqUtil.sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));

   }



   public Map<String, UserDividentsDayDTO> consumeTeamDividentsMsg(int count) {

      Gson gson = new Gson();

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

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

      if (list != null)

         for (Message msg : list) {

            String result = msg.msgBody;

            if (!StringUtil.isNullOrEmpty(result)) {

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

            }

         }

      return map;

   }



   public void deleteTeamDividentsMsg(String receiptHandle) {

      cmqUtil.deleteMsg(TEAM_DIVIDENTS, receiptHandle);

   }



}