From b30fb8afd3cd6228bda9b182dc412bb3c8daf69c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 17 十月 2024 16:28:48 +0800
Subject: [PATCH] CMQ转为Rabbitmq
---
src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java | 21 ++++++++++++---------
1 files changed, 12 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java b/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
index f38fcf4..c98b249 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
@@ -8,7 +8,7 @@
import com.yeshi.buwan.domain.VideoResourceMapExtraInfo;
import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
import com.yeshi.buwan.dto.mq.VideoExtraInfoChangeMQMsg;
-import com.yeshi.buwan.util.mq.CMQManager;
+import com.yeshi.buwan.util.mq.rabbit.RabbitmqManager;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
@@ -31,6 +31,9 @@
@Resource
private VideoResourceMapExtraInfoDao videoResourceMapExtraInfoDao;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
@SuppressWarnings("unchecked")
@@ -114,16 +117,16 @@
}
/**
- * @author hxh
+ * @return java.util.List<com.yeshi.buwan.domain.ResourceVideo>
+ * @author hxh
* @description 鏍规嵁ResourceId鏌ヨ
* @date 10:58 2024/8/16
* @param: resourceId
* @param: page
* @param: pageSize
- * @return java.util.List<com.yeshi.buwan.domain.ResourceVideo>
**/
- public List<ResourceVideo> listResourceVideo(Long resourceId,int page, int pageSize){
- return resourceVideoDao.list("from ResourceVideo rv where rv.resource.id=? ", (page-1)*pageSize, pageSize,new Serializable[]{resourceId+""});
+ public List<ResourceVideo> listResourceVideo(Long resourceId, int page, int pageSize) {
+ return resourceVideoDao.list("from ResourceVideo rv where rv.resource.id=? ", (page - 1) * pageSize, pageSize, new Serializable[]{resourceId + ""});
}
@@ -151,8 +154,8 @@
rv.setResource(new VideoResource(resourceId + ""));
rv.setVideo(new VideoInfo(videoId + ""));
resourceVideoDao.save(rv);
- CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_ADD));
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE,videoId, VideoDataChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_ADD));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, videoId, VideoDataChangeMQMsg.ACTION_ADD));
}
}
@@ -161,8 +164,8 @@
ResourceVideo resourceVideo = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId + "");
if (resourceVideo != null) {
resourceVideoDao.delete(resourceVideo);
- CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
- CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE,videoId, VideoDataChangeMQMsg.ACTION_DELETE));
+ rabbitmqManager.addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, videoId, VideoDataChangeMQMsg.ACTION_DELETE));
}
VideoResourceMapExtraInfo extraInfo = new VideoResourceMapExtraInfo(videoId, Long.parseLong(resourceId));
--
Gitblit v1.8.0