From b37275dba6b782bf3bb3817c4504f6cdef1bef7c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 18 三月 2021 18:38:51 +0800
Subject: [PATCH] APP首页顶部标签兼容

---
 src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java |   96 ++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 93 insertions(+), 3 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 a4b183c..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,9 +1,14 @@
 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;
 import org.hibernate.Session;
@@ -14,6 +19,9 @@
 import com.yeshi.buwan.dao.ResourceVideoDao;
 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 {
@@ -21,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
@@ -51,6 +63,68 @@
         });
     }
 
+    /**
+     * 鑾峰彇璧勬簮鍒楄〃
+     *
+     * @param videoId
+     * @return
+     */
+    public List<ResourceVideo> getResourceList(String videoId) {
+        List<VideoInfo> videoInfoList = new ArrayList<>();
+        videoInfoList.add(new VideoInfo(videoId));
+        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鏌ヨ
+     *
+     * @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);
     }
@@ -58,13 +132,29 @@
     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));
         }
     }
 
+    @Transactional
+    public void delete(String videoId, String resourceId) {
+        ResourceVideo resourceVideo = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId + "");
+        if (resourceVideo != null) {
+            resourceVideoDao.delete(resourceVideo);
+            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