admin
2025-02-20 f537abe9f3646c739beaf15076246a2f71a347e9
src/test/java/com/hxh/spring/test/Iqiyi.java
@@ -1,34 +1,39 @@
package com.hxh.spring.test;
import java.util.List;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.junit.Test;
import org.springframework.orm.hibernate4.HibernateCallback;
import com.yeshi.buwan.dao.VideoInfoDao;
import com.yeshi.buwan.iqiyi.entity.IqiyiUpdateQueue;
import com.yeshi.buwan.iqiyi.util.IqiyiUtil;
import com.yeshi.buwan.videos.iqiyi.IqiYiNewAPI;
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum2;
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiUpdateQueue;
import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil;
import com.yeshi.buwan.videos.iqiyi.vo.IqiyiAlbumListResult;
import com.yeshi.buwan.service.imp.ClearService;
import com.yeshi.buwan.service.imp.juhe.IqiyiQueueService;
import com.yeshi.buwan.util.BeanUtil;
import com.yeshi.buwan.util.StringUtil;
import com.yeshi.buwan.util.TimeUtil;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
public class Iqiyi {
   // 203879301
    // 203879301
   public static void main(String[] args) {
    public static void main(String[] args) {
//      IqiyiQueueService iqiyiQueueService = BeanUtil.getBean(IqiyiQueueService.class);
//      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
//
//      List<IqiyiUpdateQueue> queueList = iqiyiQueueService.listUpdateQueue();
//      for (IqiyiUpdateQueue queue : queueList) {
//      for (IqiyiUpdateQueue mq : queueList) {
//         String aid = null;
//         int count = 0;
//         while (StringUtil.isNullOrEmpty(aid) && count < 3) {
//            if (StringUtil.isNullOrEmpty(queue.getAid())) {
//               aid = IqiyiUtil.getAlbumIdFromPlayUrl(queue.getUrl());
//            if (StringUtil.isNullOrEmpty(mq.getAid())) {
//               aid = IqiyiUtil.getAlbumIdFromPlayUrl(mq.getUrl());
//               count++;
//               try {
//                  Thread.sleep(1000 * 2);
@@ -36,98 +41,128 @@
//                  e.printStackTrace();
//               }
//            } else
//               aid = queue.getAid();
//               aid = mq.getAid();
//         }
//         if (!StringUtil.isNullOrEmpty(aid)) {
//            queue.setAid(aid);
//            iqiyiQueueService.updateUpdateQueue(queue);
//            mq.setAid(aid);
//            iqiyiQueueService.updateUpdateQueue(mq);
//            iqiyiUtil.updateAlbum(aid);
//         }
//      }
      test3();
   }
        test7();
//     System.out.println(IqiyiUtil.getVPicture("http://pic2.iqiyipic.com/image/20200814/1b/26/v_150716720_m_601_m3.jpg"));
    }
   @Test
   public static void test() {
      VideoInfoDao infoDao = BeanUtil.getBean(VideoInfoDao.class);
      infoDao.excute(new HibernateCallback<List<String>>() {
         public List<String> doInHibernate(Session session) throws HibernateException {
            List list = session
                  .createSQLQuery(
                        "SELECT hv.`videoid`,v.`picture` FROM wk_video_homevideo hv LEFT JOIN wk_video_video v ON v.`id`=hv.`videoid`  WHERE  hv.`picture` IS NULL OR hv.`picture` =''")
                  .list();
            for (int i = 0; i < list.size(); i++) {
               session.getTransaction().begin();
               Object[] objs = (Object[]) list.get(i);
               session.createSQLQuery("update wk_video_homevideo hv set hv.picture=? where hv.videoid=?")
                     .setParameter(0, objs[1] + "").setParameter(1, objs[0] + "").executeUpdate();
               session.flush();
               session.getTransaction().commit();
            }
            return null;
         }
      });
   }
    public static void test() {
        VideoInfoDao infoDao = BeanUtil.getBean(VideoInfoDao.class);
        infoDao.excute(new HibernateCallback<List<String>>() {
            public List<String> doInHibernate(Session session) throws HibernateException {
                List list = session
                        .createSQLQuery(
                                "SELECT hv.`videoid`,v.`picture` FROM wk_video_homevideo hv LEFT JOIN wk_video_video v ON v.`id`=hv.`videoid`  WHERE  hv.`picture` IS NULL OR hv.`picture` =''")
                        .list();
                for (int i = 0; i < list.size(); i++) {
                    session.getTransaction().begin();
                    Object[] objs = (Object[]) list.get(i);
                    session.createSQLQuery("update wk_video_homevideo hv set hv.picture=? where hv.videoid=?")
                            .setParameter(0, objs[1] + "").setParameter(1, objs[0] + "").executeUpdate();
                    session.flush();
                    session.getTransaction().commit();
                }
                return null;
            }
        });
    }
   @Test
   public static void test2() {
      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
      iqiyiUtil.addShortVideo("208536001");
   }
    public static void test2() {
        IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
        iqiyiUtil.addShortVideo("208536001");
    }
   @Test
   public static void test3() {
      // Map<String, Object> map = IqiYiAPI.getAlbumList("6", "220327201", 1,
      // 50, -1);
      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
      // iqiyiUtil.updateSourceAlbum("233071001");
      // iqiyiUtil.updateAlbum("101160300");
      iqiyiUtil.updateAlbum("252458001");
   }
    public static void test3() {
        // Map<String, Object> map = IqiYiAPI.getAlbumList("6", "220327201", 1,
        // 50, -1);
        IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
        // iqiyiUtil.updateSourceAlbum("233071001");
        // iqiyiUtil.updateAlbum("101160300");
        iqiyiUtil.updateAlbum("252458001");
    }
   public static void test4() {
      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
      iqiyiUtil.updateIqiyiVIP();
   }
    public static void test4() {
        IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
        iqiyiUtil.updateIqiyiVIP();
    }
   public static void test5() {
      ClearService clearService = BeanUtil.getBean(ClearService.class);
      clearService.clearInvalidIqiyiVideo();
   }
    public static void test5() {
        ClearService clearService = BeanUtil.getBean(ClearService.class);
        clearService.clearInvalidIqiyiVideo();
    }
   public static void test6() {
      IqiyiQueueService iqiyiQueueService = BeanUtil.getBean(IqiyiQueueService.class);
      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
      List<IqiyiUpdateQueue> queueList = iqiyiQueueService.listUpdateQueue();
      for (IqiyiUpdateQueue queue : queueList) {
         String aid = null;
         int count = 0;
         while (StringUtil.isNullOrEmpty(aid) && count < 3) {
            if (StringUtil.isNullOrEmpty(queue.getAid())) {
               aid = IqiyiUtil.getAlbumIdFromPlayUrl(queue.getUrl());
               count++;
               try {
                  Thread.sleep(1000 * 2);
               } catch (InterruptedException e) {
                  e.printStackTrace();
               }
            } else
               aid = queue.getAid();
         }
         if (!StringUtil.isNullOrEmpty(aid)) {
            queue.setAid(aid);
            iqiyiQueueService.updateUpdateQueue(queue);
            iqiyiUtil.updateAlbum(aid);
         }
      }
    public static void test6() {
        IqiyiQueueService iqiyiQueueService = BeanUtil.getBean(IqiyiQueueService.class);
        IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
        List<IqiyiUpdateQueue> queueList = iqiyiQueueService.listUpdateQueue();
        for (IqiyiUpdateQueue queue : queueList) {
            String aid = null;
            int count = 0;
            while (StringUtil.isNullOrEmpty(aid) && count < 3) {
                if (StringUtil.isNullOrEmpty(queue.getAid())) {
                    aid = IqiYiNewAPI.getAidByUrl(queue.getUrl());
                    count++;
                    try {
                        Thread.sleep(1000 * 2);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else
                    aid = queue.getAid();
            }
            if (!StringUtil.isNullOrEmpty(aid)) {
                queue.setAid(aid);
                iqiyiQueueService.updateUpdateQueue(queue);
                iqiyiUtil.updateAlbum(aid);
            }
        }
   }
    }
   public static void test7() {
      String aid = IqiyiUtil.getAlbumIdFromPlayUrl("http://www.iqiyi.com/v_19rr1i5o2k.html");
      IqiyiUtil iqiyiUtil = BeanUtil.getBean(IqiyiUtil.class);
      iqiyiUtil.updateAlbum(aid);
      System.out.println(aid);
   }
    public static void test7() {
        System.out.println(IqiyiUtil.getHPicture("http://pic7.iqiyipic.com/image/20201029/c8/70/a_100417138_m_601_m12.jpg"));
    }
    //获取所有专辑
    public static void getAllAlbums() {
        List<IqiyiAlbum2> album2List = new ArrayList<>();
        IqiyiAlbumListResult result = IqiYiNewAPI.getAllAlbumAndVideoList(IqiYiNewAPI.TYPE_ZONGYI + "", null, true, 10);
//        if (result.getAlbum2List() != null)
//            album2List.addAll(result.getAlbum2List());
//        while (result.getMinId() != null) {
//            result = IqiYiNewAPI.getAllAlbumList(IqiYiNewAPI.TYPE_DONGMAN + "", result.getMinId(), true, 10);
//            if (result.getAlbum2List() != null)
//                album2List.addAll(result.getAlbum2List());
//        }
        System.out.println(album2List);
    }
    public static void getAlbumDetail() {
        List<Long> ids = new ArrayList<>();
        ids.add(247738801L);
        IqiYiNewAPI.getAlbumOrVideoDetail(ids);
    }
    //获取更新的专辑
    public static void getUpdateAlbum() {
        Date startTime = new Date(TimeUtil.convertGernalTime("2020-09-01", "yyyy-MM-dd"));
        Date endTime = new Date(TimeUtil.convertGernalTime("2020-09-01 03", "yyyy-MM-dd HH"));
        IqiYiNewAPI.getUpdateAlbumList(IqiYiNewAPI.TYPE_DIANSHIJU + "", startTime, endTime, null, true, 10);
        IqiYiNewAPI.getUpdateVideoList(IqiYiNewAPI.TYPE_DIANSHIJU + "", startTime, endTime, null, true, 10);
    }
}