From 89e370bfdda29ac8a8f7080a18dc09a6ddc75c09 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 26 十月 2020 18:42:16 +0800
Subject: [PATCH] 风行爱奇艺视频更新
---
src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java | 24 +++++++++++++++++++-----
1 files changed, 19 insertions(+), 5 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 ed991a9..0f265a9 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
@@ -4,6 +4,7 @@
import java.util.List;
import com.yeshi.buwan.domain.VideoResource;
+import com.yeshi.buwan.dto.mq.VideoExtraInfoChangeMQMsg;
import com.yeshi.buwan.util.mq.CMQManager;
import org.hibernate.HibernateException;
import org.hibernate.Query;
@@ -16,6 +17,8 @@
import com.yeshi.buwan.domain.ResourceVideo;
import com.yeshi.buwan.domain.VideoInfo;
import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
@Service
public class ResourceVideoService {
@@ -65,6 +68,19 @@
return getResourceList(videoInfoList);
}
+
+ /**
+ * 鏍规嵁瑙嗛ID涓嶳esourceId鏌ヨ
+ *
+ * @param videoId
+ * @param sourceId
+ * @return
+ */
+
+ public long countByVideoIdAndResourceId(String videoId, long sourceId) {
+ return resourceVideoDao.countByVideoIdAndResourceId(videoId, sourceId + "");
+ }
+
public void save(ResourceVideo resourceVideo) {
resourceVideoDao.save(resourceVideo);
}
@@ -72,16 +88,13 @@
public void addVideoResource(String videoId, String resourceId) {
ResourceVideo rv = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId);
if (rv == null) {
+ System.out.println(videoId + ":" + resourceId);
rv = new ResourceVideo();
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));
}
- }
-
-
- public void delete(ResourceVideo rv) {
- resourceVideoDao.delete(rv);
}
@Transactional
@@ -90,6 +103,7 @@
if (resourceVideo != null)
resourceVideoDao.delete(resourceVideo);
CMQManager.getInstance().addVideoResourceDeleteMsg(videoId);
+ CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
}
--
Gitblit v1.8.0