From fc7a6634496066fe45dca8ea9832bdd2f7341db4 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 13 十月 2020 10:25:39 +0800
Subject: [PATCH] 百度内容联盟前端分类，首页弹窗广告

---
 src/main/java/com/yeshi/buwan/util/mq/CMQManager.java |   69 ++++++++++++++++++++++++++++++++--
 1 files changed, 65 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
index 8653ea4..7a52f57 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -1,7 +1,9 @@
 package com.yeshi.buwan.util.mq;
 
 import com.qcloud.cmq.Message;
+import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
 import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
+import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -15,6 +17,8 @@
     public static String QUEUENAME_SOLR = "buwan-solr";
     //瑙嗛鏇存柊-鐖卞鑹�2
     public static String QUEUENAME_VIDEO_UPDATE_IQIYI_2 = "buwan-video-update-iqiyi2";
+    //瑙嗛鏇存柊-椋庤2
+    public static String QUEUENAME_VIDEO_UPDATE_FUNTV_2 = "buwan-video-update-funtv2";
 
 
     static {
@@ -22,6 +26,7 @@
         // 鏈�澶ф秷鎭负1M
         cmqUtil.createQueue(QUEUENAME_SOLR, 1024 * 1024);
         cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_IQIYI_2, 1024 * 1024);
+        cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_FUNTV_2, 1024 * 1024);
     }
 
     public static CMQManager getInstance() {
@@ -32,12 +37,12 @@
 
 
     //娣诲姞涓撹緫鏇存柊娑堟伅
-    public void addAlbumUpdateMsg(Long id) {
+    public void addIqiyiAlbumUpdateMsg(Long id) {
         cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, id + "");
     }
 
     //娑堣垂涓撹緫鏇存柊娑堟伅
-    public List<IqiyiAlbum2MQMsg> consumeAlbumUpdateMsg(int count) {
+    public List<IqiyiAlbum2MQMsg> consumeIqiyiAlbumUpdateMsg(int count) {
         List<IqiyiAlbum2MQMsg> list = new ArrayList<>();
         List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_IQIYI_2);
         if (msgList != null)
@@ -51,10 +56,66 @@
     }
 
     //鍒犻櫎涓撹緫鏇存柊娑堟伅
-    public void deleteAlbumUpdateMsg(String handler) {
+    public void deleteIqiyiAlbumUpdateMsg(String handler) {
         cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, handler);
     }
 
-    //鎼滅储寮曟搸
+
+    //娣诲姞涓撹緫鏇存柊娑堟伅
+    public void addFunTVAlbumUpdateMsg(String id) {
+        cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, id );
+    }
+
+    //娑堣垂涓撹緫鏇存柊娑堟伅
+    public List<FunTVAlbum2MQMsg> consumeFunTVAlbumUpdateMsg(int count) {
+        List<FunTVAlbum2MQMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_FUNTV_2);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                FunTVAlbum2MQMsg mm = new FunTVAlbum2MQMsg();
+                mm.setHandler(msg.receiptHandle);
+                mm.setId(msg.msgBody);
+                list.add(mm);
+            }
+        return list;
+    }
+
+    //鍒犻櫎涓撹緫鏇存柊娑堟伅
+    public void deleteFunTVAlbumUpdateMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, handler);
+    }
+
+
+    /**
+     * 鎼滅储寮曟搸
+     * @param id
+     */
+
+    /**
+     * 鎼滅储寮曟搸娑堟伅
+     *
+     * @param id
+     */
+    public void addSolrMsg(String id) {
+        cmqUtil.sendMsg(QUEUENAME_SOLR, id);
+    }
+
+    public List<SolrVideoMQMsg> consumeSolrMsg(int count) {
+        List<SolrVideoMQMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_SOLR);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                SolrVideoMQMsg mm = new SolrVideoMQMsg();
+                mm.setHandler(msg.receiptHandle);
+                mm.setId(msg.msgBody);
+                list.add(mm);
+            }
+        return list;
+    }
+
+
+    public void deleteSolrMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_SOLR, handler);
+    }
 
 }

--
Gitblit v1.8.0