From f7b2baec57a19039ca85880bbba4e17fe27f0511 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 10 三月 2021 18:21:13 +0800
Subject: [PATCH] 删除冗余代码，初步优化首页的推荐专题，3.8.7之后在我的里面添加VIP分类
---
src/main/java/com/yeshi/buwan/util/mq/CMQManager.java | 35 ++++++++++++++++++++++++++++++++++-
1 files changed, 34 insertions(+), 1 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 259c9c3..e64cbcb 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -14,11 +14,14 @@
private static CMQManager cmqManager;
private static CMQUtil cmqUtil;
// 鎼滅储寮曟搸
- public static String QUEUENAME_SOLR = "buwan-solr";
+ public static String QUEUENAME_SOLR = "buwan-solr-new";
//瑙嗛鏇存柊-鐖卞鑹�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";
+
+ //瑙嗛鏇存柊-PPTV
+ public static String QUEUENAME_VIDEO_UPDATE_PPTV = "buwan-video-update-pptv";
//鍒犻櫎瑙嗛璧勬簮
public static String QUEUENAME_VIDEO_RESOURCE_DELETE = "buwan-video-resource-delete";
@@ -36,6 +39,7 @@
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_UPDATE_PPTV, 1024 * 1024);
cmqUtil.createQueue(QUEUENAME_VIDEO_RESOURCE_DELETE, 1024 * 1024);
cmqUtil.createQueue(QUEUENAME_UPDATE_VIDEO_EXTRAINFO, 1024 * 1024);
@@ -102,6 +106,7 @@
return list;
}
+
//鍒犻櫎涓撹緫鏇存柊娑堟伅
public void deleteFunTVAlbumUpdateMsg(String handler) {
cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, handler);
@@ -109,6 +114,34 @@
/**
+ * PPTV鍓ч泦鏇存柊
+ */
+
+ //娣诲姞涓撹緫鏇存柊娑堟伅
+ public void addPPTVSeriesUpdateMsg(PPTVMQMsg msg) {
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_PPTV, new Gson().toJson(msg));
+ }
+
+ //娑堣垂涓撹緫鏇存柊娑堟伅
+ public List<PPTVMQMsg> consumePPTVSeriesUpdateMsg(int count) {
+ List<PPTVMQMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_PPTV);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ PPTVMQMsg mm = new Gson().fromJson(msg.msgBody, PPTVMQMsg.class);
+ mm.setHandler(msg.receiptHandle);
+ list.add(mm);
+ }
+ return list;
+ }
+
+ //鍒犻櫎涓撹緫鏇存柊娑堟伅
+ public void deletePPTVSeriesUpdateMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_PPTV, handler);
+ }
+
+
+ /**
* 鎼滅储寮曟搸
* @param id
*/
--
Gitblit v1.8.0