From ab35ac8b769b2d9816dffb33a64f2c6f7bd5dd6e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 05 九月 2024 17:05:55 +0800
Subject: [PATCH] 风行网页版爬虫
---
src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java | 20 ++++++++++++++++++--
1 files changed, 18 insertions(+), 2 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 7474fff..f38fcf4 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
@@ -1,13 +1,13 @@
package com.yeshi.buwan.service.imp;
+import java.io.Serializable;
import java.util.*;
import com.yeshi.buwan.dao.VideoResourceMapExtraInfoDao;
-import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
import com.yeshi.buwan.domain.VideoResource;
import com.yeshi.buwan.domain.VideoResourceMapExtraInfo;
+import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
import com.yeshi.buwan.dto.mq.VideoExtraInfoChangeMQMsg;
-import com.yeshi.buwan.iqiyi.entity.VideoIqiyi;
import com.yeshi.buwan.util.mq.CMQManager;
import org.hibernate.HibernateException;
import org.hibernate.Query;
@@ -69,6 +69,7 @@
* @param videoId
* @return
*/
+ @Transactional
public List<ResourceVideo> getResourceList(String videoId) {
List<VideoInfo> videoInfoList = new ArrayList<>();
videoInfoList.add(new VideoInfo(videoId));
@@ -112,6 +113,19 @@
return null;
}
+ /**
+ * @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+""});
+ }
+
/**
* 鏍规嵁瑙嗛ID涓嶳esourceId鏌ヨ
@@ -138,6 +152,7 @@
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));
}
}
@@ -147,6 +162,7 @@
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));
}
VideoResourceMapExtraInfo extraInfo = new VideoResourceMapExtraInfo(videoId, Long.parseLong(resourceId));
--
Gitblit v1.8.0