From 1d28c69a351ae108f4116a10f19f615c89a660a2 Mon Sep 17 00:00:00 2001
From: admin <2780501319@qq.com>
Date: 星期四, 01 四月 2021 01:58:43 +0800
Subject: [PATCH] 首页数据修改
---
src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java | 62 ++++++++++++++++++++++++++++---
1 files changed, 56 insertions(+), 6 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 0f265a9..7474fff 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
@@ -1,10 +1,13 @@
package com.yeshi.buwan.service.imp;
-import java.util.ArrayList;
-import java.util.List;
+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.VideoExtraInfoChangeMQMsg;
+import com.yeshi.buwan.iqiyi.entity.VideoIqiyi;
import com.yeshi.buwan.util.mq.CMQManager;
import org.hibernate.HibernateException;
import org.hibernate.Query;
@@ -26,10 +29,14 @@
@Autowired
private ResourceVideoDao resourceVideoDao;
+ @Resource
+ private VideoResourceMapExtraInfoDao videoResourceMapExtraInfoDao;
+
+
@SuppressWarnings("unchecked")
public List<ResourceVideo> getResourceList(final List<VideoInfo> list) {
if (list == null || list.size() == 0) {
- return new ArrayList<ResourceVideo>();
+ return new ArrayList<>();
}
return (List<ResourceVideo>) resourceVideoDao.excute(new HibernateCallback<List<ResourceVideo>>() {
@Override
@@ -68,6 +75,43 @@
return getResourceList(videoInfoList);
}
+ /**
+ * 鑾峰彇榛樿鐨勬簮
+ *
+ * @param videoId
+ * @param avaiableResourceIds
+ * @return
+ */
+ public VideoResource getDefaultVideoResource(String videoId, Set<Long> avaiableResourceIds) {
+ List<ResourceVideo> resourceVideoList = resourceVideoDao.list("FROM ResourceVideo rv where rv.video.id=? order by rv.resource.orderby desc", videoId);
+ //鍒犻櫎鏃犵敤鏉ユ簮
+ for (int i = 0; i < resourceVideoList.size(); i++) {
+ if (!avaiableResourceIds.contains(Long.parseLong(resourceVideoList.get(i).getResource().getId())) || resourceVideoList.get(i).getResource() == null) {
+ resourceVideoList.remove(i--);
+ }
+ }
+ //鎺掑簭
+
+ List<VideoResource> resourceList = new ArrayList<>();
+
+ for (ResourceVideo rv : resourceVideoList) {
+ resourceList.add(rv.getResource());
+ }
+
+ Comparator<VideoResource> cm = new Comparator<VideoResource>() {
+ @Override
+ public int compare(VideoResource o1, VideoResource o2) {
+ return o2.getOrderby() - o1.getOrderby();
+ }
+ };
+
+ Collections.sort(resourceList, cm);
+ if (resourceList.size() > 0)
+ return resourceList.get(0);
+
+ return null;
+ }
+
/**
* 鏍规嵁瑙嗛ID涓嶳esourceId鏌ヨ
@@ -100,10 +144,16 @@
@Transactional
public void delete(String videoId, String resourceId) {
ResourceVideo resourceVideo = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId + "");
- if (resourceVideo != null)
+ if (resourceVideo != null) {
resourceVideoDao.delete(resourceVideo);
- CMQManager.getInstance().addVideoResourceDeleteMsg(videoId);
- CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
+ CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
+ }
+
+ VideoResourceMapExtraInfo extraInfo = new VideoResourceMapExtraInfo(videoId, Long.parseLong(resourceId));
+ extraInfo = videoResourceMapExtraInfoDao.find(VideoResourceMapExtraInfo.class, extraInfo.getId());
+ if (extraInfo != null) {
+ videoResourceMapExtraInfoDao.delete(extraInfo);
+ }
}
--
Gitblit v1.8.0