聚合视频资源包调整，接入韩迷

admin

2021-08-27 8fee151ffae0c3818694b7318583814bf92663e2

 src/main/java/com/yeshi/buwan/job/video/FunTV2VideoUpdate.java

@@ -2,14 +2,11 @@

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.yeshi.buwan.funtv.FunTVNewApi;
import com.yeshi.buwan.funtv.entity.FunTVAlbum2;
import com.yeshi.buwan.funtv.entity.FunTVShortVideo2;
import com.yeshi.buwan.funtv.entity.FunTVVideo2;
import com.yeshi.buwan.iqiyi.IqiYiNewAPI;
import com.yeshi.buwan.iqiyi.util.IqiyiUtil2;
import com.yeshi.buwan.videos.funtv.FunTVNewApi;
import com.yeshi.buwan.videos.funtv.entity.FunTVAlbum2;
import com.yeshi.buwan.videos.funtv.entity.FunTVShortVideo2;
import com.yeshi.buwan.videos.funtv.entity.FunTVVideo2;
import com.yeshi.buwan.service.inter.juhe.FunTV2Service;
import com.yeshi.buwan.service.inter.juhe.Iqiyi2Service;
import com.yeshi.buwan.util.StringUtil;
import com.yeshi.buwan.util.mq.CMQManager;
import com.yeshi.buwan.vo.video.funtv.Funtv2ResultVO;
@@ -67,18 +64,18 @@
     * @return
     * @throws Exception
     */
    @XxlJob("video-update-funtv2-updateAlbumById")
    public ReturnT<String> updateAlbumById(String param) throws Exception {
        FunTVAlbum2 album2 = FunTVNewApi.getAlbumsDetail(param);
        if (album2 != null) {
            funTV2Service.saveAlbum(album2);
            if (album2.getEpisodes() != null)
                for (FunTVVideo2 video2 : album2.getEpisodes())
                    funTV2Service.saveVideo(video2);
            CMQManager.getInstance().addFunTVAlbumUpdateMsg(album2.getId());
        }
        return ReturnT.SUCCESS;
    }
//    @XxlJob("video-update-funtv2-updateAlbumById")
//    public ReturnT<String> updateAlbumById(String param) throws Exception {
//        FunTVAlbum2 album2 = FunTVNewApi.getAlbumsDetail(param);
//        if (album2 != null) {
//            funTV2Service.saveAlbum(album2);
//            if (album2.getEpisodes() != null)
//                for (FunTVVideo2 video2 : album2.getEpisodes())
//                    funTV2Service.saveVideo(video2);
//            CMQManager.getInstance().addFunTVAlbumUpdateMsg(album2.getId());
//        }
//        return ReturnT.SUCCESS;
//    }

    /**
     * 获取最近的短视频
@@ -87,25 +84,25 @@
     */
    public List<FunTVShortVideo2> getLatestShortVideo(int d) {
        List<FunTVShortVideo2> shortVideo2List = new ArrayList<>();
        int pageSize = 100;
        long now = System.currentTimeMillis();
        int page = 1;
        int totalPage = -1;
        while (true) {
            Funtv2ResultVO result = FunTVNewApi.getVideos(page, pageSize, now - 1000 * 60 * 60L * 24 * d, now - 1000 * 60 * 60L * 24 * (d - 1), null, null);
            if (result != null) {
                for (Serializable a : result.getList()) {
                    FunTVShortVideo2 video2 = (FunTVShortVideo2) a;
                    shortVideo2List.add(video2);
                }
            }
            int count = result.getCount();
            if (totalPage < 0)
                totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
            if (page > totalPage)
                break;
            page++;
        }
//        int pageSize = 100;
//        long now = System.currentTimeMillis();
//        int page = 1;
//        int totalPage = -1;
//        while (true) {
//            Funtv2ResultVO result = FunTVNewApi.getVideos(page, pageSize, now - 1000 * 60 * 60L * 24 * d, now - 1000 * 60 * 60L * 24 * (d - 1), null, null);
//            if (result != null) {
//                for (Serializable a : result.getList()) {
//                    FunTVShortVideo2 video2 = (FunTVShortVideo2) a;
//                    shortVideo2List.add(video2);
//                }
//            }
//            int count = result.getCount();
//            if (totalPage < 0)
//                totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
//            if (page > totalPage)
//                break;
//            page++;
//        }
        return shortVideo2List;
    }

@@ -122,7 +119,7 @@
        int page = 1;
        int totalPage = -1;
        while (true) {
            Funtv2ResultVO result = FunTVNewApi.getAlbums(page, pageSize, now - 1000 * 60 * 60L * 24 * d, now - 1000 * 60 * 60L * 24 * (d - 1), null, null);
            Funtv2ResultVO result = FunTVNewApi.getAlbums(page, pageSize, now - 1000 * 60 * 60L * 24 * d, now - 1000 * 60 * 60L * 24 * (d - 1), null);
            if (result != null) {
                for (Serializable a : result.getList()) {
                    FunTVAlbum2 video2 = (FunTVAlbum2) a;