清除HongBaoMapper

admin

2019-03-13 33b4ed2bbf28ec16b66e552680f56a691a4e908d

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

@@ -13,9 +13,9 @@
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;

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

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

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

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

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

@@ -50,6 +50,17 @@
   public static String GOODS_UPDATE = "goods_update_queue";



   static {



      if (Constant.IS_TEST) {

         QUEUENAME_ORDER = "test-" + QUEUENAME_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;

      }



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

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

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

@@ -194,8 +205,7 @@
         }

      return map;

   }

	
	


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

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

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

@@ -209,12 +219,11 @@
         }

      return map;

   }

	


   public void deleteFanLiMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);

   }

	


   public void deleteFanLiMsgNew(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

   }