大淘客线报单

admin

2021-06-26 dc573610f303115be3e826345fafc0981012546f

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

@@ -44,7 +44,6 @@
   public static String FANLI_ORDER_NEW = "fanli-order-new";



   // 分享订单收益
   public static String FANLI_SHARE_ORDER = "fanli-share-order";

@@ -54,6 +53,10 @@
   public static String GOODS_UPDATE = "goods_update_queue";
   // 重要数据更新
   public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";

    //特价会员开通
    public static String TEJIA_VIP = "tejia_vip";


   static {

@@ -67,6 +70,7 @@
      
         ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;
         IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;
            TEJIA_VIP = "test-" + TEJIA_VIP;
         FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;
      }

@@ -79,6 +83,7 @@
      ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();
      IMPORTANT_GOODS_UPDATE += "-" + Constant.systemCommonConfig.getProjectName();
      FANLI_SHARE_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        TEJIA_VIP += "-" + Constant.systemCommonConfig.getProjectName();

      cmqUtil = CMQUtil.getInstance(secretId, secretKey);
      // 最大消息为1M
@@ -94,6 +99,7 @@
      cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);

      cmqUtil.createQueue(FANLI_SHARE_ORDER);
        cmqUtil.createQueue(TEJIA_VIP);
   }

   public static CMQManager getInstance() {
@@ -270,7 +276,6 @@
   public void deleteFanLiMsgNew(String receiptHandle) {
      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
   }

   

   // 分享订单收益