好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

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

@@ -8,10 +8,12 @@
import org.yeshi.utils.CMQUtil;



import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;

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;

@@ -32,22 +34,21 @@


   // 提现结果处理队列

   public static String EXTRACT_RESULT = "extract-result";

   //  IOS推送队列

   // 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_TICHENG_ORDER = "fanli-ticheng-order";

	
   //  团队奖励到账

   public static String FANLI_ORDER_TEAM_REWARD="fanli-order-team-reward";

	
   //  维权订单





   // 分享订单收益

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



   // 维权订单

   public static String ORDER_WEIQUAN = "weiquan-order";



   public static String GOODS_UPDATE = "goods_update_queue";

@@ -63,12 +64,10 @@
         PUSH_IOS = "test-" + PUSH_IOS;

         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;

         FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;

      }



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

@@ -77,11 +76,9 @@
      PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();

      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();

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



      cmqUtil = CMQUtil.getInstance(secretId, secretKey);

      // 最大消息为1M

@@ -91,11 +88,12 @@
      cmqUtil.createQueue(PUSH_IOS);

      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);



      cmqUtil.createQueue(FANLI_SHARE_ORDER);

   }



   public static CMQManager getInstance() {

@@ -188,7 +186,7 @@
    * @param extract

    * @param response

    */

   public void addExtractResultMsg(Extract extract, AlipayFundTransToaccountTransferResponse response,

   public void addExtractResultMsg(Extract extract, AlipayFundTransUniTransferResponse response,

         AdminUser adminUser) {

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

      cmqUtil.sendMsg(EXTRACT_RESULT, content);

@@ -273,52 +271,31 @@
      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

   }



   // 提成返利

   public void addFanLiTiChengMsg(Long uid) {

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

	


   // 分享订单收益

   public void addFanLiShareMsg(UidDateDTO dto) {

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

   }



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

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

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

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

      List<Message> list = cmqUtil.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, Long.parseLong(result));

               map.put(msg.receiptHandle, dto);

            }

         }

      return map;

   }



   public void deleteFanLiTiChengMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_TICHENG_ORDER, receiptHandle);

   public void deleteFanLiShareMsg(String receiptHandle) {

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