From 8075103992e9482fddd4a579d97b9a50c5dcf550 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 24 十月 2020 18:26:43 +0800
Subject: [PATCH] 爱奇艺资源更新优化

---
 src/main/java/com/yeshi/buwan/util/mq/CMQManager.java |   70 +++++++++++++++++++++++++++++++++-
 1 files changed, 67 insertions(+), 3 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 9f9145b..f5e76d0 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -1,6 +1,8 @@
 package com.yeshi.buwan.util.mq;
 
 import com.qcloud.cmq.Message;
+import com.yeshi.buwan.dto.mq.CMQConsumeMsg;
+import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
 import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
 import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
 
@@ -16,6 +18,11 @@
     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";
+
+    //鍒犻櫎瑙嗛璧勬簮
+    public static String QUEUENAME_VIDEO_RESOURCE_DELETE = "buwan-video-resource-delete";
 
 
     static {
@@ -23,6 +30,8 @@
         // 鏈�澶ф秷鎭负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);
+        cmqUtil.createQueue(QUEUENAME_VIDEO_RESOURCE_DELETE, 1024 * 1024);
     }
 
     public static CMQManager getInstance() {
@@ -33,12 +42,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)
@@ -52,8 +61,33 @@
     }
 
     //鍒犻櫎涓撹緫鏇存柊娑堟伅
-    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);
     }
 
 
@@ -89,4 +123,34 @@
         cmqUtil.deleteMsg(QUEUENAME_SOLR, handler);
     }
 
+
+    /**
+     * 鍒犻櫎瑙嗛璧勬簮
+     *
+     * @param videoId
+     */
+
+    public void addVideoResourceDeleteMsg(String videoId) {
+        cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, videoId);
+    }
+
+    public List<CMQConsumeMsg> consumeVideoResourceDeleteMsg(int count) {
+        List<CMQConsumeMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_RESOURCE_DELETE);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                CMQConsumeMsg mm = new CMQConsumeMsg();
+                mm.setHandler(msg.receiptHandle);
+                mm.setData(msg.msgBody);
+                list.add(mm);
+            }
+        return list;
+    }
+
+
+    public void deleteVideoResourceDeleteMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, handler);
+    }
+
+
 }

--
Gitblit v1.8.0