| | |
| | | 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); |
| | |
| | | // 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); |
| | | } |
| | | |
| | | |
| | | } |