From f537abe9f3646c739beaf15076246a2f71a347e9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 20 二月 2025 16:57:55 +0800
Subject: [PATCH] IOS广告增加区域屏蔽
---
src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java | 1557 ++++++++++++++++++++++++++++++-----------------------------
1 files changed, 781 insertions(+), 776 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java b/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
index 177eeef..e519825 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java
@@ -1,883 +1,888 @@
package com.yeshi.buwan.service.imp.juhe;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.List;
-
-import javax.annotation.Resource;
-
+import com.yeshi.buwan.dao.ResourceVideoDao;
+import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiVideoInfoDao;
+import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
+import com.yeshi.buwan.domain.*;
+import com.yeshi.buwan.domain.push.VideoPushHistory;
+import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
+import com.yeshi.buwan.log.LogHelper;
+import com.yeshi.buwan.service.imp.StatisticsService;
+import com.yeshi.buwan.service.imp.push.PushService;
+import com.yeshi.buwan.util.StringUtil;
+import com.yeshi.buwan.util.TimeUtil;
+import com.yeshi.buwan.util.mq.rabbit.RabbitmqManager;
+import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum;
+import com.yeshi.buwan.videos.iqiyi.entity.IqiyiVideoInfo;
+import com.yeshi.buwan.videos.iqiyi.entity.VideoIqiyi;
+import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil;
+import net.sf.json.JSONArray;
import org.apache.log4j.Logger;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;
-import com.yeshi.buwan.dao.ResourceVideoDao;
-import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiVideoInfoDao;
-import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
-import com.yeshi.buwan.domain.AdminInfo;
-import com.yeshi.buwan.domain.CategoryVideo;
-import com.yeshi.buwan.domain.ResourceVideo;
-import com.yeshi.buwan.domain.VideoDetailInfo;
-import com.yeshi.buwan.domain.VideoInfo;
-import com.yeshi.buwan.domain.VideoResource;
-import com.yeshi.buwan.domain.VideoType;
-import com.yeshi.buwan.domain.push.VideoPushHistory;
-import com.yeshi.buwan.iqiyi.entity.IqiyiAlbum;
-import com.yeshi.buwan.iqiyi.entity.IqiyiVideoInfo;
-import com.yeshi.buwan.iqiyi.entity.VideoIqiyi;
-import com.yeshi.buwan.iqiyi.util.IqiyiUtil;
-import com.yeshi.buwan.log.LogHelper;
-import com.yeshi.buwan.service.imp.StatisticsService;
-import com.yeshi.buwan.service.imp.push.PushService;
-import com.yeshi.buwan.util.StringUtil;
-import com.yeshi.buwan.util.TimeUtil;
-
-import net.sf.json.JSONArray;
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.util.*;
@Service
public class IqiyiService {
- static Logger logger = Logger.getLogger(IqiyiService.class);
- @Resource
- private IqiyiVideoInfoDao iqiyiVideoInfoDao;
- @Resource
- private VideoIqiyiDao videoIqiyiDao;
- @Resource
- private StatisticsService statisticsService;
- @Resource
- private PushService pushService;
+ static Logger logger = Logger.getLogger(IqiyiService.class);
+ @Resource
+ private IqiyiVideoInfoDao iqiyiVideoInfoDao;
+ @Resource
+ private VideoIqiyiDao videoIqiyiDao;
+ @Resource
+ private StatisticsService statisticsService;
+ @Resource
+ private PushService pushService;
- @Resource
- private ResourceVideoDao resourceVideoDao;
+ @Resource
+ private ResourceVideoDao resourceVideoDao;
+ @Resource
+ private RabbitmqManager rabbitmqManager;
- static {
- // PropertyConfigurator.configure(".\\src\\log4j.properties");
- }
- @SuppressWarnings({ "unchecked", "rawtypes" })
- public String saveAlbum(final IqiyiAlbum album) {
- if (album.getCreditList() != null && album.getCreditList().length() > 512)
- album.setCreditList(album.getCreditList().substring(0, 512));
+ static {
+ // PropertyConfigurator.configure(".\\src\\log4j.properties");
+ }
- return videoIqiyiDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- Serializable id = "";
- try {
- List<IqiyiAlbum> list = session.createQuery("from IqiyiAlbum a where a.albumId=?")
- .setParameter(0, album.getAlbumId()).list();
- if (list == null || list.size() == 0) {
- session.getTransaction().begin();
- id = session.save(album);
- session.flush();
- session.getTransaction().commit();
- } else
- id = list.get(0).getId();
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ public String saveAlbum(final IqiyiAlbum album) {
+ if (album.getCreditList() != null && album.getCreditList().length() > 512)
+ album.setCreditList(album.getCreditList().substring(0, 512));
- } catch (Exception e) {
- logger.error(album.getId() + "---" + album.getAlbumName());
- logger.error(e.getMessage());
- e.printStackTrace();
- session.getTransaction().rollback();
- System.out.println(album.getId() + "---" + album.getAlbumName());
- }
- return id.toString();
- }
- }) + "";
+ return videoIqiyiDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ Serializable id = "";
+ try {
+ List<IqiyiAlbum> list = session.createQuery("from IqiyiAlbum a where a.albumId=?")
+ .setParameter(0, album.getAlbumId()).list();
+ if (list == null || list.size() == 0) {
+ session.getTransaction().begin();
+ id = session.save(album);
+ session.flush();
+ session.getTransaction().commit();
+ } else
+ id = list.get(0).getId();
- }
+ } catch (Exception e) {
+ logger.error(album.getId() + "---" + album.getAlbumName());
+ logger.error(e.getMessage());
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ System.out.println(album.getId() + "---" + album.getAlbumName());
+ }
+ return id.toString();
+ }
+ }) + "";
- public IqiyiVideoInfo getLatestVideoInfo(String albumId) {
- List<IqiyiVideoInfo> list = iqiyiVideoInfoDao.list(
- "from IqiyiVideoInfo iv where iv.albumId=? order by iv.playOrder desc", 0, 1, new String[] { albumId });
- return list != null && list.size() > 0 ? list.get(0) : null;
- }
+ }
- @SuppressWarnings("unchecked")
- public static IqiyiVideoInfo getLatestVideoInfo(String albumId, Session session) {
- List<IqiyiVideoInfo> list = session
- .createQuery("from IqiyiVideoInfo iv where iv.albumId=? order by iv.playOrder desc")
- .setParameter(0, albumId).setFirstResult(0).setMaxResults(1).list();
+ public IqiyiVideoInfo getLatestVideoInfo(String albumId) {
+ List<IqiyiVideoInfo> list = iqiyiVideoInfoDao.list(
+ "from IqiyiVideoInfo iv where iv.albumId=? order by iv.playOrder desc", 0, 1, new String[]{albumId});
+ return list != null && list.size() > 0 ? list.get(0) : null;
+ }
- return list != null && list.size() > 0 ? list.get(0) : null;
- }
+ @SuppressWarnings("unchecked")
+ public static IqiyiVideoInfo getLatestVideoInfo(String albumId, Session session) {
+ List<IqiyiVideoInfo> list = session
+ .createQuery("from IqiyiVideoInfo iv where iv.albumId=? order by iv.playOrder desc")
+ .setParameter(0, albumId).setFirstResult(0).setMaxResults(1).list();
- @SuppressWarnings("rawtypes")
- public void saveVideoInfo(final IqiyiVideoInfo vi) {
- videoIqiyiDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- List list = session.createQuery("from IqiyiVideoInfo a where a.tvId=?")
- .setParameter(0, vi.getTvId()).list();
- if (list == null || list.size() == 0) {
- session.getTransaction().begin();
- session.persist(vi);
- session.flush();
- session.getTransaction().commit();
- }
+ return list != null && list.size() > 0 ? list.get(0) : null;
+ }
- } catch (Exception e) {
- logger.error("saveVideoInfo");
- logger.error(e.getMessage());
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
- }
+ @SuppressWarnings("rawtypes")
+ public void saveVideoInfo(final IqiyiVideoInfo vi) {
+ videoIqiyiDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ List list = session.createQuery("from IqiyiVideoInfo a where a.tvId=?")
+ .setParameter(0, vi.getTvId()).list();
+ if (list == null || list.size() == 0) {
+ session.getTransaction().begin();
+ session.persist(vi);
+ session.flush();
+ session.getTransaction().commit();
+ }
- public String saveAlbumVideoInfo(IqiyiAlbum album, List<IqiyiVideoInfo> videoList) {
- String id = saveAlbum(album);
- IqiyiVideoInfo latestVideoIfo = getLatestVideoInfo(album.getAlbumId() + "");
- int startP = 0;
- Comparator<IqiyiVideoInfo> c = new Comparator<IqiyiVideoInfo>() {
+ } catch (Exception e) {
+ logger.error("saveVideoInfo");
+ logger.error(e.getMessage());
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
+ }
- public int compare(IqiyiVideoInfo o1, IqiyiVideoInfo o2) {
- return o1.getPlayOrder() - o2.getPlayOrder();
- }
- };
+ public String saveAlbumVideoInfo(IqiyiAlbum album, List<IqiyiVideoInfo> videoList) {
+ String id = saveAlbum(album);
+ IqiyiVideoInfo latestVideoIfo = getLatestVideoInfo(album.getAlbumId() + "");
+ int startP = 0;
+ Comparator<IqiyiVideoInfo> c = new Comparator<IqiyiVideoInfo>() {
- Collections.sort(videoList, c);
+ public int compare(IqiyiVideoInfo o1, IqiyiVideoInfo o2) {
+ return o1.getPlayOrder() - o2.getPlayOrder();
+ }
+ };
- if (latestVideoIfo != null) {
- for (int i = 0; i < videoList.size(); i++) {
- if (latestVideoIfo.getTvId() == videoList.get(i).getTvId()) {
- startP = i + 1;
- }
- }
- }
- if (videoList.size() > 1) {
- System.out.println("--");
- }
+ Collections.sort(videoList, c);
- if (startP < videoList.size())// 鏈夋洿鏂板唴瀹�
- {
- // startP = startP == 0 ? videoList.size() : startP;
- videoList = videoList.subList(startP, videoList.size());
- for (IqiyiVideoInfo info : videoList)
- saveVideoInfo(info);
- }
- return id;
- }
+ if (latestVideoIfo != null) {
+ for (int i = 0; i < videoList.size(); i++) {
+ if (latestVideoIfo.getTvId() == videoList.get(i).getTvId()) {
+ startP = i + 1;
+ }
+ }
+ }
+ if (videoList.size() > 1) {
+ System.out.println("--");
+ }
- public void deleteByTvId(final String tvId) {
- iqiyiVideoInfoDao.excute(new HibernateCallback<Object>() {
- @Override
- public Object doInHibernate(Session session) throws HibernateException {
- session.getTransaction().begin();
- session.createSQLQuery("delete from `wk_iqiyi_album_tvid` WHERE `tvid`=" + tvId).executeUpdate();
- session.getTransaction().commit();
- session.close();
- return null;
- }
- });
+ if (startP < videoList.size())// 鏈夋洿鏂板唴瀹�
+ {
+ // startP = startP == 0 ? videoList.size() : startP;
+ videoList = videoList.subList(startP, videoList.size());
+ for (IqiyiVideoInfo info : videoList)
+ saveVideoInfo(info);
+ }
+ return id;
+ }
- }
+ public void deleteByTvId(final String tvId) {
+ iqiyiVideoInfoDao.excute(new HibernateCallback<Object>() {
+ @Override
+ public Object doInHibernate(Session session) throws HibernateException {
+ session.getTransaction().begin();
+ session.createSQLQuery("delete from `wk_iqiyi_album_tvid` WHERE `tvid`=" + tvId).executeUpdate();
+ session.getTransaction().commit();
+ session.close();
+ return null;
+ }
+ });
- private static boolean isSameVideoType(int categoryid, long typeid) {
+ }
- switch (categoryid) {
- case 1:
- if (typeid == 151)
- return true;
- break;
- case 2:
- if (typeid == 150)
- return true;
- break;
- case 4:
- if (typeid == 153)
- return true;
- break;
- case 6:
- if (typeid == 152)
- return true;
- break;
- }
+ private static boolean isSameVideoType(int categoryid, long typeid) {
- return false;
+ switch (categoryid) {
+ case 1:
+ if (typeid == 151)
+ return true;
+ break;
+ case 2:
+ if (typeid == 150)
+ return true;
+ break;
+ case 4:
+ if (typeid == 153)
+ return true;
+ break;
+ case 6:
+ if (typeid == 152)
+ return true;
+ break;
+ }
- }
+ return false;
- // 鍒ゆ柇鏄惁涓哄悓涓�瑙嗛
- @SuppressWarnings("unchecked")
- private static VideoInfo isSameVideo(IqiyiAlbum album, Session session) {
- Calendar ca = Calendar.getInstance();
- ca.setTimeInMillis(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"));
- int year = ca.get(Calendar.YEAR);
- List<VideoInfo> list = session.createQuery("from VideoInfo vi where vi.name=?")
- .setParameter(0, album.getSourceId() > 0 ? album.getSource() : album.getAlbumName()).list();
- if (list != null && list.size() > 0)
- for (int i = 0; i < list.size(); i++) {
+ }
- if (Math.abs(Integer.parseInt(list.get(i).getYear()) - year) < 2) {// 骞翠唤鐩稿樊1骞翠互涓嬩笖灞炰簬鍚屼竴涓垎绫绘墠褰掍负涓�璧�
- // 鍒ゆ柇鍒嗙被
- if (album.getCategoryId() == 1 || album.getCategoryId() == 2 || album.getCategoryId() == 4
- || album.getCategoryId() == 6) {// 姝ｇ墖鍒嗙被
- List<CategoryVideo> cvList = session
- .createQuery("from CategoryVideo cv where cv.video.id=" + list.get(i).getId()).list();
- boolean isS = false;
- for (CategoryVideo cv : cvList) {
- if (isSameVideoType(album.getCategoryId(), cv.getVideoType().getId())
- || (cv.getVideoType().getParent() != null && isSameVideoType(album.getCategoryId(),
- cv.getVideoType().getParent().getId()))) {// 绫诲瀷鐩稿悓
- return list.get(i);
- }
+ // 鍒ゆ柇鏄惁涓哄悓涓�瑙嗛
+ @SuppressWarnings("unchecked")
+ private static VideoInfo isSameVideo(IqiyiAlbum album, Session session) {
+ Calendar ca = Calendar.getInstance();
+ ca.setTimeInMillis(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"));
+ int year = ca.get(Calendar.YEAR);
+ List<VideoInfo> list = session.createQuery("from VideoInfo vi where vi.name=?")
+ .setParameter(0, album.getSourceId() > 0 ? album.getSource() : album.getAlbumName()).list();
+ if (list != null && list.size() > 0)
+ for (int i = 0; i < list.size(); i++) {
- }
+ if (Math.abs(Integer.parseInt(list.get(i).getYear()) - year) < 2) {// 骞翠唤鐩稿樊1骞翠互涓嬩笖灞炰簬鍚屼竴涓垎绫绘墠褰掍负涓�璧�
+ // 鍒ゆ柇鍒嗙被
+ if (album.getCategoryId() == 1 || album.getCategoryId() == 2 || album.getCategoryId() == 4
+ || album.getCategoryId() == 6) {// 姝ｇ墖鍒嗙被
+ List<CategoryVideo> cvList = session
+ .createQuery("from CategoryVideo cv where cv.video.id=" + list.get(i).getId()).list();
+ boolean isS = false;
+ for (CategoryVideo cv : cvList) {
+ if (isSameVideoType(album.getCategoryId(), cv.getVideoType().getId())
+ || (cv.getVideoType().getParent() != null && isSameVideoType(album.getCategoryId(),
+ cv.getVideoType().getParent().getId()))) {// 绫诲瀷鐩稿悓
+ return list.get(i);
+ }
- } else // 涓嶅繀姣旇緝鍒嗙被--鍙鍚嶇О鐩稿悓鍒欏垽鏂负鐩稿悓
- { // 鍒ゆ柇涓婁釜鏄惁涓烘鐗囧垎绫�
- List<VideoType> typeList = session
- .createQuery("select cv.videoType from CategoryVideo cv where cv.video.id=?")
- .setParameter(0, list.get(i).getId()).list();
- boolean isZhengpian = false;
- if (typeList != null)
- for (VideoType ltype : typeList) {
- if (ltype.getId() == 150 || ltype.getId() == 151 || ltype.getId() == 152
- || ltype.getId() == 153
- || (ltype.getParent() != null && ltype.getParent().getId() == 150)
- || (ltype.getParent() != null && ltype.getParent().getId() == 151)
- || (ltype.getParent() != null && ltype.getParent().getId() == 152)
- || (ltype.getParent() != null && ltype.getParent().getId() == 153)) {
- isZhengpian = true;
- break;
- }
- }
+ }
- if (!isZhengpian)
- return list.get(i);
- else
- return null;
- }
- }
+ } else // 涓嶅繀姣旇緝鍒嗙被--鍙鍚嶇О鐩稿悓鍒欏垽鏂负鐩稿悓
+ { // 鍒ゆ柇涓婁釜鏄惁涓烘鐗囧垎绫�
+ List<VideoType> typeList = session
+ .createQuery("select cv.videoType from CategoryVideo cv where cv.video.id=?")
+ .setParameter(0, list.get(i).getId()).list();
+ boolean isZhengpian = false;
+ if (typeList != null)
+ for (VideoType ltype : typeList) {
+ if (ltype.getId() == 150 || ltype.getId() == 151 || ltype.getId() == 152
+ || ltype.getId() == 153
+ || (ltype.getParent() != null && ltype.getParent().getId() == 150)
+ || (ltype.getParent() != null && ltype.getParent().getId() == 151)
+ || (ltype.getParent() != null && ltype.getParent().getId() == 152)
+ || (ltype.getParent() != null && ltype.getParent().getId() == 153)) {
+ isZhengpian = true;
+ break;
+ }
+ }
- }
+ if (!isZhengpian)
+ return list.get(i);
+ else
+ return null;
+ }
+ }
- return null;
- }
+ }
- /**
- * 灏嗕笓杈戞彃鍏ヨ棰戣〃
- *
- * @param album
- */
+ return null;
+ }
- @SuppressWarnings("unchecked")
- public String insertAlbumToVideoInfo(final IqiyiAlbum album, final List<IqiyiVideoInfo> videoList,
- final boolean isUpdate) {
- if (JSONArray.fromObject(album.getTvIds()).size() <= 0)// 杩樻病鏈夎棰戜俊鎭�
- return null;
+ /**
+ * 灏嗕笓杈戞彃鍏ヨ棰戣〃
+ *
+ * @param album
+ */
- return videoIqiyiDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- String vid = null;
- VideoInfo updateVideo = null;
- try {
- if (album.getSourceId() <= 0) {
- session.getTransaction().begin();
- List<VideoIqiyi> list = session.createQuery("from VideoIqiyi vi where vi.album.albumId=?")
- .setParameter(0, album.getAlbumId()).setMaxResults(1).list();
+ @SuppressWarnings("unchecked")
+ public String insertAlbumToVideoInfo(final IqiyiAlbum album, final List<IqiyiVideoInfo> videoList,
+ final boolean isUpdate) {
+ if (JSONArray.fromObject(album.getTvIds()).size() <= 0)// 杩樻病鏈夎棰戜俊鎭�
+ return null;
- if (list == null || list.size() == 0) {// 璇ヤ笓杈戞湭鍔犲叆鍒皏ideoinfo
- VideoInfo vi = convertAlbumTOVideoInfo(album, session);
- vi.setVideocount(videoList.size());
- VideoInfo same = isSameVideo(album, session);
- String id = "";
- if (same == null) {
- id = session.save(vi).toString();
- // if(id!=null)
- // session.createSQLQuery(String.format("CALL
- // copyvideotemp(%s)",id)).executeUpdate();
- } else {
- List<IqiyiVideoInfo> ilist = session
- .createQuery(
- "from IqiyiVideoInfo vi where vi.albumId=? order by vi.playOrder desc")
- .setParameter(0, album.getAlbumId() + "").setFirstResult(0).setMaxResults(1)
- .list();
- id = same.getId();
- if (!StringUtil.isNullOrEmpty(ilist.get(0).getUpdateTime())) {
- same.setUpdatetime(TimeUtil.convertGernalTime(ilist.get(0).getUpdateTime(),
- "yyyy-MM-dd HH:mm:ss") + "");
- } else {
- same.setUpdatetime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd") + "");
- }
+ return videoIqiyiDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ String vid = null;
+ VideoInfo updateVideo = null;
+ try {
+ if (album.getSourceId() <= 0) {
+ session.getTransaction().begin();
+ List<VideoIqiyi> list = session.createQuery("from VideoIqiyi vi where vi.album.albumId=?")
+ .setParameter(0, album.getAlbumId()).setMaxResults(1).list();
- String tag = IqiyiUtil.getAlbumTag(album, session);
- LogHelper.iqiyi("鐖卞鑹篢AG:" + tag);
- if (!StringUtil.isNullOrEmpty(tag)) {// tag涓嶄负绌�
- if (album.getCategoryId() == 6 && album.getContentType() == 1)// 缁艰壓
- // 骞朵笖鏄鐗�
- {
- same.setTag(tag);
- } else if (album.getCategoryId() != 6) {
- same.setTag(tag);
- }
- }
+ if (list == null || list.size() == 0) {// 璇ヤ笓杈戞湭鍔犲叆鍒皏ideoinfo
+ VideoInfo vi = convertAlbumTOVideoInfo(album, session);
+ vi.setVideocount(videoList.size());
+ VideoInfo same = isSameVideo(album, session);
+ String id = "";
+ if (same == null) {
+ id = session.save(vi).toString();
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, id, VideoDataChangeMQMsg.ACTION_ADD));
+ // if(id!=null)
+ // session.createSQLQuery(String.format("CALL
+ // copyvideotemp(%s)",id)).executeUpdate();
+ } else {
+ List<IqiyiVideoInfo> ilist = session
+ .createQuery(
+ "from IqiyiVideoInfo vi where vi.albumId=? order by vi.playOrder desc")
+ .setParameter(0, album.getAlbumId() + "").setFirstResult(0).setMaxResults(1)
+ .list();
+ id = same.getId();
+ if (!StringUtil.isNullOrEmpty(ilist.get(0).getUpdateTime())) {
+ same.setUpdatetime(TimeUtil.convertGernalTime(ilist.get(0).getUpdateTime(),
+ "yyyy-MM-dd HH:mm:ss") + "");
+ } else {
+ same.setUpdatetime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd") + "");
+ }
- session.update(same);// 鏇存柊鍘熸潵鐨勮棰�
+ String tag = IqiyiUtil.getAlbumTag(album, session);
+ LogHelper.iqiyi("鐖卞鑹篢AG:" + tag);
+ if (!StringUtil.isNullOrEmpty(tag)) {// tag涓嶄负绌�
+ if (album.getCategoryId() == 6 && album.getContentType() == 1)// 缁艰壓
+ // 骞朵笖鏄鐗�
+ {
+ same.setTag(tag);
+ } else if (album.getCategoryId() != 6) {
+ same.setTag(tag);
+ }
+ }
- Object obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, same.getId()).uniqueResult();
+ session.update(same);// 鏇存柊鍘熸潵鐨勮棰�
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, same.getId(), VideoDataChangeMQMsg.ACTION_UPDATE));
- long c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(new VideoInfo(same.getId()));
- session.persist(rv);
- }
+ Object obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, same.getId()).uniqueResult();
- }
- // 灏嗚棰戜繚瀛樺埌娓犻亾鍒楄〃
- vid = id;
- Object obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, id).uniqueResult();
- long c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(new VideoInfo(id));
- session.persist(rv);
- }
+ long c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(new VideoInfo(same.getId()));
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
- VideoIqiyi vii = new VideoIqiyi();
- vii.setAlbum(new IqiyiAlbum(album.getId()));
- vii.setVideo(new VideoInfo(id));
- session.persist(vii);
- } else// 鏇存柊鏃堕棿涓巘ag
- {
- List<IqiyiVideoInfo> ilist = session
- .createQuery(
- "from IqiyiVideoInfo vi where vi.albumId=? order by vi.playOrder desc")
- .setParameter(0, album.getAlbumId() + "").setFirstResult(0).setMaxResults(1).list();
- if (ilist != null && ilist.size() > 0) {
- // if
- // (!StringUtil.isNullOrEmpty(ilist.get(0).getUpdateTime()))
- // {
- // list.get(0).getVideo()
- // .setUpdatetime(TimeUtil.convertGernalTime(ilist.get(0).getUpdateTime(),
- // "yyyy-MM-dd HH:mm:ss") + "");
- // } else {
- // list.get(0).getVideo().setUpdatetime(
- // TimeUtil.convertGernalTime(ilist.get(0).getTvYear(),
- // "yyyyMMdd") + "");
- // }
- list.get(0).getVideo().setVideocount(videoList.size());
- if (!StringUtil.isNullOrEmpty(ilist.get(0).getVideoImage())) {
- list.get(0).getVideo().setLatestHpicture(
- IqiyiUtil.getHPicture(ilist.get(0).getVideoImage()));
- list.get(0).getVideo().setLatestVpicture(ilist.get(0).getVideoImage());
- }
- }
+ }
+ // 灏嗚棰戜繚瀛樺埌娓犻亾鍒楄〃
+ vid = id;
+ Object obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, id).uniqueResult();
+ long c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(new VideoInfo(id));
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
- if (isUpdate)
- list.get(0).getVideo().setUpdatetime(System.currentTimeMillis() + "");
+ VideoIqiyi vii = new VideoIqiyi();
+ vii.setAlbum(new IqiyiAlbum(album.getId()));
+ vii.setVideo(new VideoInfo(id));
+ session.persist(vii);
+ } else// 鏇存柊鏃堕棿涓巘ag
+ {
+ List<IqiyiVideoInfo> ilist = session
+ .createQuery(
+ "from IqiyiVideoInfo vi where vi.albumId=? order by vi.playOrder desc")
+ .setParameter(0, album.getAlbumId() + "").setFirstResult(0).setMaxResults(1).list();
+ if (ilist != null && ilist.size() > 0) {
+ // if
+ // (!StringUtil.isNullOrEmpty(ilist.get(0).getUpdateTime()))
+ // {
+ // list.get(0).getVideo()
+ // .setUpdatetime(TimeUtil.convertGernalTime(ilist.get(0).getUpdateTime(),
+ // "yyyy-MM-dd HH:mm:ss") + "");
+ // } else {
+ // list.get(0).getVideo().setUpdatetime(
+ // TimeUtil.convertGernalTime(ilist.get(0).getTvYear(),
+ // "yyyyMMdd") + "");
+ // }
+ list.get(0).getVideo().setVideocount(videoList.size());
+ if (!StringUtil.isNullOrEmpty(ilist.get(0).getVideoImage())) {
+ list.get(0).getVideo().setLatestHpicture(
+ IqiyiUtil.getHPicture(ilist.get(0).getVideoImage()));
+ list.get(0).getVideo().setLatestVpicture(ilist.get(0).getVideoImage());
+ }
+ }
- String tag = IqiyiUtil.getAlbumTag(album, session);
- if (!StringUtil.isNullOrEmpty(tag)) {// tag涓嶄负绌�
- if (!tag.equalsIgnoreCase(list.get(0).getVideo().getTag())) {// tag涓嶄竴鏍�
- list.get(0).getVideo().setTag(tag);
- if (ilist != null && ilist.size() > 0) {
- updateVideo = list.get(0).getVideo();
- List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
- detailList.add(convertVideoinfoToDetail(album, ilist.get(0)));
- updateVideo.setVideoDetailList(detailList);
- }
- }
- }
- session.update(list.get(0).getVideo());
- vid = list.get(0).getVideo().getId();
- Object obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
- .uniqueResult();
+ if (isUpdate)
+ list.get(0).getVideo().setUpdatetime(System.currentTimeMillis() + "");
- long c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(new VideoInfo(list.get(0).getVideo().getId()));
- session.persist(rv);
- }
- }
- // 鏇存柊tag
- session.flush();
- session.getTransaction().commit();
- } else {
- // sourceid>0
- Object detailCountObj = session
- .createQuery(
- "select count(*) from IqiyiAlbum a where a.sourceId=" + album.getSourceId())
- .uniqueResult();
- int videoDetailCount = Integer.parseInt(detailCountObj + "");
+ String tag = IqiyiUtil.getAlbumTag(album, session);
+ if (!StringUtil.isNullOrEmpty(tag)) {// tag涓嶄负绌�
+ if (!tag.equalsIgnoreCase(list.get(0).getVideo().getTag())) {// tag涓嶄竴鏍�
+ list.get(0).getVideo().setTag(tag);
+ if (ilist != null && ilist.size() > 0) {
+ updateVideo = list.get(0).getVideo();
+ List<VideoDetailInfo> detailList = new ArrayList<>();
+ detailList.add(convertVideoinfoToDetail(album, ilist.get(0)));
+ updateVideo.setVideoDetailList(detailList);
+ }
+ }
+ }
+ session.update(list.get(0).getVideo());
+ vid = list.get(0).getVideo().getId();
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, vid, VideoDataChangeMQMsg.ACTION_UPDATE));
- List<VideoIqiyi> list = session
- .createQuery(
- "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.createdTime) desc")
- .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1).list();
- session.getTransaction().begin();
- if (list == null || list.size() == 0) {// 涓嶅瓨鍦�
- VideoInfo vi = convertAlbumTOVideoInfo(album, session);
- String videoid = "";
+ Object obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
+ .uniqueResult();
- VideoInfo same = isSameVideo(album, session);
- if (same == null) {
- vi.setVideocount(videoDetailCount);
- videoid = session.save(vi).toString();
- } else
- videoid = same.getId();
+ long c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(new VideoInfo(list.get(0).getVideo().getId()));
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
+ }
+ // 鏇存柊tag
+ session.flush();
+ session.getTransaction().commit();
+ } else {
+ // sourceid>0
+ Object detailCountObj = session
+ .createQuery(
+ "select count(*) from IqiyiAlbum a where a.sourceId=" + album.getSourceId())
+ .uniqueResult();
+ int videoDetailCount = Integer.parseInt(detailCountObj + "");
- vid = videoid;
- VideoIqiyi vii = new VideoIqiyi();
- vii.setAlbum(album);
- vii.setVideo(new VideoInfo(videoid));
- session.persist(vii);
+ List<VideoIqiyi> list = session
+ .createQuery(
+ "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.createdTime) desc")
+ .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1).list();
+ session.getTransaction().begin();
+ if (list == null || list.size() == 0) {// 涓嶅瓨鍦�
+ VideoInfo vi = convertAlbumTOVideoInfo(album, session);
+ String videoid = "";
- Object obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, videoid).uniqueResult();
+ VideoInfo same = isSameVideo(album, session);
+ if (same == null) {
+ vi.setVideocount(videoDetailCount);
+ videoid = session.save(vi).toString();
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_ADD));
+ } else
+ videoid = same.getId();
- long c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(new VideoInfo(videoid));
- session.persist(rv);
- }
+ vid = videoid;
+ VideoIqiyi vii = new VideoIqiyi();
+ vii.setAlbum(album);
+ vii.setVideo(new VideoInfo(videoid));
+ session.persist(vii);
+
+ Object obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, videoid).uniqueResult();
+
+ long c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(new VideoInfo(videoid));
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
+
+ if (same != null)// 鏇存柊鍐呭
+ {
+ list = session
+ .createQuery(
+ "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.tvYear) desc")
+ .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1).list();
+ String tag = IqiyiUtil.getAlbumTag(list.get(0).getAlbum(), session);
+ if (!tag.equalsIgnoreCase(same.getTag())) {
+ same.setTag(tag);
- if (same != null)// 鏇存柊鍐呭
- {
- list = session
- .createQuery(
- "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.tvYear) desc")
- .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1).list();
- String tag = IqiyiUtil.getAlbumTag(list.get(0).getAlbum(), session);
- if (!tag.equalsIgnoreCase(same.getTag())) {
- same.setTag(tag);
+ if (isUpdate) {
+ updateVideo = same;
+ List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
+ detailList.add(convertAlbumToDetail(list.get(0).getAlbum()));
+ updateVideo.setVideoDetailList(detailList);
+ }
+ }
+ same.setUpdatetime(
+ TimeUtil.convertGernalTime(list.get(0).getAlbum().getTvYear(), "yyyyMMdd")
+ + "");
+ session.update(same);
- if (isUpdate) {
- updateVideo = same;
- List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
- detailList.add(convertAlbumToDetail(list.get(0).getAlbum()));
- updateVideo.setVideoDetailList(detailList);
- }
- }
- same.setUpdatetime(
- TimeUtil.convertGernalTime(list.get(0).getAlbum().getTvYear(), "yyyyMMdd")
- + "");
- session.update(same);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_UPDATE));
- obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
- .uniqueResult();
+ obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
+ .uniqueResult();
- c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(same);
- session.persist(rv);
- }
+ c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(same);
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
- }
+ }
- } else {
- Object ob = session
- .createQuery(
- "select count(*) from VideoIqiyi vi where vi.album.sourceId=? and vi.album.albumId=?")
- .setParameter(0, album.getSourceId()).setParameter(1, album.getAlbumId())
- .uniqueResult();
- long count = Long.parseLong(ob.toString());
- if (count <= 0) {// 闇�瑕佸姞鍏ideoIqiyi
- VideoIqiyi vi = new VideoIqiyi();
- vi.setVideo(list.get(0).getVideo());
- vi.setAlbum(album);
- session.persist(vi);
- if (album.getSourceId() > 0) {// 缁艰壓
- // 鏌ヨ鏈�鏂板仛鏇存柊
- list = session
- .createQuery(
- "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.tvYear) desc")
- .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1)
- .list();
- String tag = IqiyiUtil.getAlbumTag(list.get(0).getAlbum(), session);
+ } else {
+ Object ob = session
+ .createQuery(
+ "select count(*) from VideoIqiyi vi where vi.album.sourceId=? and vi.album.albumId=?")
+ .setParameter(0, album.getSourceId()).setParameter(1, album.getAlbumId())
+ .uniqueResult();
+ long count = Long.parseLong(ob.toString());
+ if (count <= 0) {// 闇�瑕佸姞鍏ideoIqiyi
+ VideoIqiyi vi = new VideoIqiyi();
+ vi.setVideo(list.get(0).getVideo());
+ vi.setAlbum(album);
+ session.persist(vi);
+ if (album.getSourceId() > 0) {// 缁艰壓
+ // 鏌ヨ鏈�鏂板仛鏇存柊
+ list = session
+ .createQuery(
+ "from VideoIqiyi vi where vi.album.sourceId=? order by UNIX_TIMESTAMP(vi.album.tvYear) desc")
+ .setParameter(0, album.getSourceId()).setFirstResult(0).setMaxResults(1)
+ .list();
+ String tag = IqiyiUtil.getAlbumTag(list.get(0).getAlbum(), session);
- list.get(0).getVideo().setTag(tag);
- // list.get(0).getVideo().setUpdatetime(
- // TimeUtil.convertGernalTime(list.get(0).getAlbum().getTvYear(),
- // "yyyyMMdd")
- // + "");
- if (isUpdate)
- list.get(0).getVideo().setUpdatetime(System.currentTimeMillis() + "");
+ list.get(0).getVideo().setTag(tag);
+ // list.get(0).getVideo().setUpdatetime(
+ // TimeUtil.convertGernalTime(list.get(0).getAlbum().getTvYear(),
+ // "yyyyMMdd")
+ // + "");
+ if (isUpdate)
+ list.get(0).getVideo().setUpdatetime(System.currentTimeMillis() + "");
- if (!StringUtil.isNullOrEmpty(list.get(0).getAlbum().getPosterPicUrl())) {
- list.get(0).getVideo().setLatestHpicture( IqiyiUtil.getHPicture( list.get(0).getAlbum()
- .getPosterPicUrl()));
- list.get(0).getVideo()
- .setLatestVpicture(list.get(0).getAlbum().getPosterPicUrl());
- }
- list.get(0).getVideo().setVideocount(videoDetailCount);
+ if (!StringUtil.isNullOrEmpty(list.get(0).getAlbum().getPosterPicUrl())) {
+ list.get(0).getVideo().setLatestHpicture(IqiyiUtil.getHPicture(list.get(0).getAlbum()
+ .getPosterPicUrl()));
+ list.get(0).getVideo()
+ .setLatestVpicture(list.get(0).getAlbum().getPosterPicUrl());
+ }
+ list.get(0).getVideo().setVideocount(videoDetailCount);
- session.update(list.get(0).getVideo());
- if (isUpdate) {
- updateVideo = list.get(0).getVideo();
- List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
- detailList.add(convertAlbumToDetail(list.get(0).getAlbum()));
- updateVideo.setVideoDetailList(detailList);
- }
- }
- }
+ session.update(list.get(0).getVideo());
+ if (isUpdate) {
+ updateVideo = list.get(0).getVideo();
+ List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
+ detailList.add(convertAlbumToDetail(list.get(0).getAlbum()));
+ updateVideo.setVideoDetailList(detailList);
+ }
+ }
+ }
- Object obj = session
- .createQuery(
- "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
- .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
- .uniqueResult();
+ Object obj = session
+ .createQuery(
+ "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
+ .setParameter(0, 13 + "").setParameter(1, list.get(0).getVideo().getId())
+ .uniqueResult();
- long c = Long.parseLong(obj + "");
- if (c <= 0) {
- ResourceVideo rv = new ResourceVideo();
- rv.setResource(new VideoResource("13"));
- rv.setVideo(list.get(0).getVideo());
- session.persist(rv);
- }
- vid = list.get(0).getVideo().getId();
- }
- session.flush();
- session.getTransaction().commit();
- }
+ long c = Long.parseLong(obj + "");
+ if (c <= 0) {
+ ResourceVideo rv = new ResourceVideo();
+ rv.setResource(new VideoResource("13"));
+ rv.setVideo(list.get(0).getVideo());
+ session.persist(rv);
+ rabbitmqManager.addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
+ vid = list.get(0).getVideo().getId();
+ }
+ session.flush();
+ session.getTransaction().commit();
+ }
- } catch (Exception e) {
- logger.error("insertAlbumToVideoInfo");
- logger.error(e.getMessage());
- session.getTransaction().rollback();
- e.printStackTrace();
- }
+ } catch (Exception e) {
+ logger.error("insertAlbumToVideoInfo");
+ logger.error(e.getMessage());
+ session.getTransaction().rollback();
+ e.printStackTrace();
+ }
- try {
- if (updateVideo != null && isUpdate) {
- VideoPushHistory vh = new VideoPushHistory();
- vh.setCreatetime(System.currentTimeMillis() + "");
- vh.setDetailId(updateVideo.getVideoDetailList().get(0).getId() + "");
- vh.setType(updateVideo.getVideoDetailList().get(0).getType());
- vh.setResourceId("13");
- vh.setTag(updateVideo.getTag());
- vh.setVideoInfo(updateVideo);
- pushService.addVideoPushHistory(vh);
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
+ try {
+ if (updateVideo != null && isUpdate) {
+ VideoPushHistory vh = new VideoPushHistory();
+ vh.setCreatetime(System.currentTimeMillis() + "");
+ vh.setDetailId(updateVideo.getVideoDetailList().get(0).getId() + "");
+ vh.setType(updateVideo.getVideoDetailList().get(0).getType());
+ vh.setResourceId("13");
+ vh.setTag(updateVideo.getTag());
+ vh.setVideoInfo(updateVideo);
+ pushService.addVideoPushHistory(vh);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
- return vid;
- }
- }) + "";
+ return vid;
+ }
+ }) + "";
- }
+ }
- private static VideoDetailInfo convertAlbumToDetail(IqiyiAlbum ia) {
- VideoDetailInfo vi = new VideoDetailInfo();
- vi.setAdmin(new AdminInfo("1"));
- vi.setId(ia.getAlbumId());
- vi.setIntroduction(ia.getDesc());
- vi.setName(ia.getSource());
- vi.setTag(ia.getTvYear() + " " + (StringUtil.isNullOrEmpty(ia.getFocus()) ? "" : ia.getFocus()));
- vi.setType("album");
- return vi;
- }
+ private static VideoDetailInfo convertAlbumToDetail(IqiyiAlbum ia) {
+ VideoDetailInfo vi = new VideoDetailInfo();
+ vi.setAdmin(new AdminInfo("1"));
+ vi.setId(ia.getAlbumId());
+ vi.setIntroduction(ia.getDesc());
+ vi.setName(ia.getSource());
+ vi.setTag(ia.getTvYear() + " " + (StringUtil.isNullOrEmpty(ia.getFocus()) ? "" : ia.getFocus()));
+ vi.setType("album");
+ return vi;
+ }
- private static VideoDetailInfo convertVideoinfoToDetail(IqiyiAlbum album, IqiyiVideoInfo info) {
- VideoDetailInfo vi = new VideoDetailInfo();
- vi.setAdmin(new AdminInfo("1"));
- vi.setId(info.getTvId());
- vi.setExtraId(info.getTvId() + "");
- vi.setIntroduction("");
- vi.setName("");
- vi.setTag(info.getPlayOrder() + "");
- if (album != null)
- if (album.getCategoryId() == 1)
- vi.setTag(album.getAlbumName());
+ private static VideoDetailInfo convertVideoinfoToDetail(IqiyiAlbum album, IqiyiVideoInfo info) {
+ VideoDetailInfo vi = new VideoDetailInfo();
+ vi.setAdmin(new AdminInfo("1"));
+ vi.setId(info.getTvId());
+ vi.setExtraId(info.getTvId() + "");
+ vi.setIntroduction("");
+ vi.setName("");
+ vi.setTag(info.getPlayOrder() + "");
+ if (album != null)
+ if (album.getCategoryId() == 1)
+ vi.setTag(album.getAlbumName());
- info.getSubTitle();
+ info.getSubTitle();
- vi.setType("tvid");
- return vi;
- }
+ vi.setType("tvid");
+ return vi;
+ }
- @SuppressWarnings("rawtypes")
- public List<List<String>> getSourceAlbumList() {
- List<List<String>> olist = new ArrayList<List<String>>();
+ @SuppressWarnings("rawtypes")
+ public List<List<String>> getSourceAlbumList() {
+ List<List<String>> olist = new ArrayList<List<String>>();
- List list = videoIqiyiDao.sqlList(
- "SELECT a.`sourceId`,a.categoryId FROM wk_iqiyi_album a WHERE a.`sourceId`>0 GROUP BY a.`sourceId` ");
- for (int i = 0; i < list.size(); i++) {
- List<String> ilist = new ArrayList<String>();
- Object[] obj = (Object[]) list.get(i);
- ilist.add(obj[0] + "");
- ilist.add(obj[1] + "");
- olist.add(ilist);
- }
- return olist;
- }
+ List list = videoIqiyiDao.sqlList(
+ "SELECT a.`sourceId`,a.categoryId FROM wk_iqiyi_album a WHERE a.`sourceId`>0 GROUP BY a.`sourceId` ");
+ for (int i = 0; i < list.size(); i++) {
+ List<String> ilist = new ArrayList<String>();
+ Object[] obj = (Object[]) list.get(i);
+ ilist.add(obj[0] + "");
+ ilist.add(obj[1] + "");
+ olist.add(ilist);
+ }
+ return olist;
+ }
- @SuppressWarnings("rawtypes")
- public List<List<String>> getSourceAlbumListBySourceId(String sourceId) {
- List<List<String>> olist = new ArrayList<List<String>>();
+ @SuppressWarnings("rawtypes")
+ public List<List<String>> getSourceAlbumListBySourceId(String sourceId) {
+ List<List<String>> olist = new ArrayList<List<String>>();
- List list = videoIqiyiDao.sqlList("SELECT a.`sourceId`,a.categoryId FROM wk_iqiyi_album a WHERE a.`sourceId`="
- + sourceId + " GROUP BY a.`sourceId` ");
- for (int i = 0; i < list.size(); i++) {
- List<String> ilist = new ArrayList<String>();
- Object[] obj = (Object[]) list.get(i);
- ilist.add(obj[0] + "");
- ilist.add(obj[1] + "");
- olist.add(ilist);
- }
- return olist;
- }
+ List list = videoIqiyiDao.sqlList("SELECT a.`sourceId`,a.categoryId FROM wk_iqiyi_album a WHERE a.`sourceId`="
+ + sourceId + " GROUP BY a.`sourceId` ");
+ for (int i = 0; i < list.size(); i++) {
+ List<String> ilist = new ArrayList<String>();
+ Object[] obj = (Object[]) list.get(i);
+ ilist.add(obj[0] + "");
+ ilist.add(obj[1] + "");
+ olist.add(ilist);
+ }
+ return olist;
+ }
- @SuppressWarnings("unchecked")
- public List<VideoDetailInfo> getVideoDetailList(final String videoid,int page,int pageSize) {
- return (List<VideoDetailInfo>) videoIqiyiDao.excute(new HibernateCallback<List<VideoDetailInfo>>() {
- public List<VideoDetailInfo> doInHibernate(Session session) throws HibernateException {
- try {
- List<IqiyiAlbum> list = session
- .createQuery(
- "select a.album from VideoIqiyi a where a.video.id=? order by UNIX_TIMESTAMP(a.album.tvYear) desc")
- .setFirstResult((page-1)*pageSize).setMaxResults(pageSize)
- .setParameter(0, videoid).list();
- if (list == null || list.size() == 0) {
- return null;
- }
+ @SuppressWarnings("unchecked")
+ public List<VideoDetailInfo> getVideoDetailList(final String videoid, int page, int pageSize) {
+ return (List<VideoDetailInfo>) videoIqiyiDao.excute(new HibernateCallback<List<VideoDetailInfo>>() {
+ public List<VideoDetailInfo> doInHibernate(Session session) throws HibernateException {
+ try {
+ List<IqiyiAlbum> list = session
+ .createQuery(
+ "select a.album from VideoIqiyi a where a.video.id=? order by UNIX_TIMESTAMP(a.album.tvYear) desc")
+ .setFirstResult((page - 1) * pageSize).setMaxResults(pageSize)
+ .setParameter(0, videoid).list();
+ if (list == null || list.size() == 0) {
+ return null;
+ }
- List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
+ List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
- if (list.size() > 1) {
- for (IqiyiAlbum ia : list)
- // 缁艰壓鍙姞姝ｇ墖
- if (ia.getCategoryId() == 6) {
- if (ia.getContentType() == 1)
- detailList.add(convertAlbumToDetail(ia));
- } else
- detailList.add(convertAlbumToDetail(ia));
- } else {
- List<IqiyiVideoInfo> ivlist = session
- .createQuery("from IqiyiVideoInfo a where a.albumId=? order by a.playOrder")
- .setFirstResult((page-1)*pageSize).setMaxResults(pageSize)
- .setParameter(0, list.get(0).getAlbumId() + "").list();
+ if (list.size() > 1) {
+ for (IqiyiAlbum ia : list)
+ // 缁艰壓鍙姞姝ｇ墖
+ if (ia.getCategoryId() == 6) {
+ if (ia.getContentType() == 1)
+ detailList.add(convertAlbumToDetail(ia));
+ } else
+ detailList.add(convertAlbumToDetail(ia));
+ } else {
+ List<IqiyiVideoInfo> ivlist = session
+ .createQuery("from IqiyiVideoInfo a where a.albumId=? order by a.playOrder")
+ .setFirstResult((page - 1) * pageSize).setMaxResults(pageSize)
+ .setParameter(0, list.get(0).getAlbumId() + "").list();
- for (IqiyiVideoInfo ia : ivlist)
- detailList.add(convertVideoinfoToDetail(list.get(0), ia));
- }
- return detailList;
+ for (IqiyiVideoInfo ia : ivlist)
+ detailList.add(convertVideoinfoToDetail(list.get(0), ia));
+ }
+ return detailList;
- } catch (Exception e) {
- e.printStackTrace();
- logger.error("getVideoDetailList");
- logger.error(e.getMessage());
- }
- return new ArrayList<VideoDetailInfo>();
- }
- });
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("getVideoDetailList");
+ logger.error(e.getMessage());
+ }
+ return new ArrayList<VideoDetailInfo>();
+ }
+ });
- }
+ }
- // 鑾峰彇鏈�鏂颁竴闆嗙殑璇︽儏
- @SuppressWarnings("unchecked")
- public VideoDetailInfo getLatestVideoDetail(final String videoid) {
- return (VideoDetailInfo) videoIqiyiDao.excute(new HibernateCallback<VideoDetailInfo>() {
- public VideoDetailInfo doInHibernate(Session session) throws HibernateException {
- try {
- List<IqiyiAlbum> list = session
- .createQuery(
- "select a.album from VideoIqiyi a where a.video.id=? order by UNIX_TIMESTAMP(a.album.tvYear) desc")
- .setFirstResult(0).setMaxResults(2).setParameter(0, videoid).list();
- if (list == null || list.size() == 0) {
- return null;
- }
+ // 鑾峰彇鏈�鏂颁竴闆嗙殑璇︽儏
+ @SuppressWarnings("unchecked")
+ public VideoDetailInfo getLatestVideoDetail(final String videoid) {
+ return (VideoDetailInfo) videoIqiyiDao.excute(new HibernateCallback<VideoDetailInfo>() {
+ public VideoDetailInfo doInHibernate(Session session) throws HibernateException {
+ try {
+ List<IqiyiAlbum> list = session
+ .createQuery(
+ "select a.album from VideoIqiyi a where a.video.id=? order by UNIX_TIMESTAMP(a.album.tvYear) desc")
+ .setFirstResult(0).setMaxResults(2).setParameter(0, videoid).list();
+ if (list == null || list.size() == 0) {
+ return null;
+ }
- List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
+ List<VideoDetailInfo> detailList = new ArrayList<VideoDetailInfo>();
- if (list.size() > 1) {
- for (IqiyiAlbum ia : list)
- detailList.add(convertAlbumToDetail(ia));
+ if (list.size() > 1) {
+ for (IqiyiAlbum ia : list)
+ detailList.add(convertAlbumToDetail(ia));
- } else {
- List<IqiyiVideoInfo> ivlist = session
- .createQuery("from IqiyiVideoInfo a where a.albumId=? order by a.playOrder desc")
- .setParameter(0, list.get(0).getAlbumId() + "").list();
+ } else {
+ List<IqiyiVideoInfo> ivlist = session
+ .createQuery("from IqiyiVideoInfo a where a.albumId=? order by a.playOrder desc")
+ .setParameter(0, list.get(0).getAlbumId() + "").list();
- for (IqiyiVideoInfo ia : ivlist)
- detailList.add(convertVideoinfoToDetail(list.get(0), ia));
- }
- return detailList.get(0);
+ for (IqiyiVideoInfo ia : ivlist)
+ detailList.add(convertVideoinfoToDetail(list.get(0), ia));
+ }
+ return detailList.get(0);
- } catch (Exception e) {
- e.printStackTrace();
- logger.error("getVideoDetailList");
- logger.error(e.getMessage());
- }
- return null;
- }
- });
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("getVideoDetailList");
+ logger.error(e.getMessage());
+ }
+ return null;
+ }
+ });
- }
+ }
- public String getAlbumTag(IqiyiAlbum album) {
- String tag = "";
- if (album.getCategoryId() == 1) {
- if (album.getSourceId() > 0)
- tag = "鏇存柊鑷�" + TimeUtil.getGernalTime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"),
- "yyyy-MM-dd");
- else
- tag = "璇勫垎锛�" + album.getScore();
- } else if (album.getCategoryId() == 2) {
- IqiyiVideoInfo video = getLatestVideoInfo(album.getAlbumId() + "");
- tag = "鏇存柊鑷�" + video.getPlayOrder() + "闆�";
- if (video.getPlayOrder() == album.getSets()) {
- tag = album.getSets() + "闆嗗叏";
- }
- } else if (album.getCategoryId() == 6) {
- tag = "鏇存柊鑷�"
- + TimeUtil.getGernalTime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"), "yyyy-MM-dd")
- + "鏈�";
- } else if (album.getCategoryId() == 4) {
- IqiyiVideoInfo video = getLatestVideoInfo(album.getAlbumId() + "");
- tag = "鏇存柊鑷�" + video.getPlayOrder() + "闆�";
- if (video.getPlayOrder() == album.getSets()) {
- tag = album.getSets() + "闆嗗叏";
- }
- }
- return tag;
- }
+ public String getAlbumTag(IqiyiAlbum album) {
+ String tag = "";
+ if (album.getCategoryId() == 1) {
+ if (album.getSourceId() > 0)
+ tag = "鏇存柊鑷�" + TimeUtil.getGernalTime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"),
+ "yyyy-MM-dd");
+ else
+ tag = "璇勫垎锛�" + album.getScore();
+ } else if (album.getCategoryId() == 2) {
+ IqiyiVideoInfo video = getLatestVideoInfo(album.getAlbumId() + "");
+ tag = "鏇存柊鑷�" + video.getPlayOrder() + "闆�";
+ if (video.getPlayOrder() == album.getSets()) {
+ tag = album.getSets() + "闆嗗叏";
+ }
+ } else if (album.getCategoryId() == 6) {
+ tag = "鏇存柊鑷�"
+ + TimeUtil.getGernalTime(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"), "yyyy-MM-dd")
+ + "鏈�";
+ } else if (album.getCategoryId() == 4) {
+ IqiyiVideoInfo video = getLatestVideoInfo(album.getAlbumId() + "");
+ tag = "鏇存柊鑷�" + video.getPlayOrder() + "闆�";
+ if (video.getPlayOrder() == album.getSets()) {
+ tag = album.getSets() + "闆嗗叏";
+ }
+ }
+ return tag;
+ }
- @SuppressWarnings({ "deprecation", "unchecked" })
- public VideoInfo convertAlbumTOVideoInfo(IqiyiAlbum album, Session session) {
- Calendar ca = Calendar.getInstance();
- if ("0".equalsIgnoreCase(album.getTvYear())) {
- album.setTvYear("20160101");
- }
- ca.setTimeInMillis(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"));
- int day = ca.get(Calendar.DAY_OF_MONTH);
- int month = ca.get(Calendar.MONTH) + 1;
- int year = ca.get(Calendar.YEAR);
+ @SuppressWarnings({"deprecation", "unchecked"})
+ public VideoInfo convertAlbumTOVideoInfo(IqiyiAlbum album, Session session) {
+ Calendar ca = Calendar.getInstance();
+ if ("0".equalsIgnoreCase(album.getTvYear())) {
+ album.setTvYear("20160101");
+ }
+ ca.setTimeInMillis(TimeUtil.convertGernalTime(album.getTvYear(), "yyyyMMdd"));
+ int day = ca.get(Calendar.DAY_OF_MONTH);
+ int month = ca.get(Calendar.MONTH) + 1;
+ int year = ca.get(Calendar.YEAR);
- VideoInfo video = new VideoInfo();
- video.setVideoType(new VideoType(IqiyiUtil.getType(album.getContentType())));
- video.setArea(album.getArea());
- video.setBaseurl(album.getHtml5Url());
- video.setCanSave(false);
- video.setCommentCount(0);
- video.setCreatetime(System.currentTimeMillis());
- video.setDay(day + "");
- video.setDirector(album.getDirector());
- video.setDuration(album.getTimeLength() + "");
- video.setFinish("1");
- video.setIntroduction(album.getDesc());
- video.setMainActor(album.getActor());
- video.setMonth(month + "");
- if (album.getSourceId() == 0)
- video.setName(album.getAlbumName());
- else
- video.setName(album.getSource());
- video.setNowNumber("1");
- video.setOrderby("0" + "");
- video.setPicture(album.getPicUrl());
+ VideoInfo video = new VideoInfo();
+ video.setVideoType(new VideoType(IqiyiUtil.getType(album.getContentType())));
+ video.setArea(album.getArea());
+ video.setBaseurl(album.getHtml5Url());
+ video.setCanSave(false);
+ video.setCommentCount(0);
+ video.setCreatetime(System.currentTimeMillis());
+ video.setDay(day + "");
+ video.setDirector(album.getDirector());
+ video.setDuration(album.getTimeLength() + "");
+ video.setFinish("1");
+ video.setIntroduction(album.getDesc());
+ video.setMainActor(album.getActor());
+ video.setMonth(month + "");
+ if (album.getSourceId() == 0)
+ video.setName(album.getAlbumName());
+ else
+ video.setName(album.getSource());
+ video.setNowNumber("1");
+ video.setOrderby("0" + "");
+ video.setPicture(album.getPicUrl());
- // info.setPlayPicture(info.getPicture().replace(".jpg",
- // "_480_270.jpg"));
+ // info.setPlayPicture(info.getPicture().replace(".jpg",
+ // "_480_270.jpg"));
- video.setVpicture(IqiyiUtil.getVPicture(album.getPicUrl()));
- video.setHpicture( IqiyiUtil.getHPicture( album.getPicUrl()));
+ video.setVpicture(IqiyiUtil.getVPicture(album.getPicUrl()));
+ video.setHpicture(IqiyiUtil.getHPicture(album.getPicUrl()));
- video.setScore(album.getScore());
- video.setShare("0");
- video.setShow("1");
- if (session != null)
- video.setTag(IqiyiUtil.getAlbumTag(album, session));
- else
- video.setTag(getAlbumTag(album));
- video.setThirdType("1");
- video.setTotalNumber("0");
- List<IqiyiVideoInfo> infolist = session
- .createQuery("from IqiyiVideoInfo vi where vi.albumId=? order by UNIX_TIMESTAMP(vi.updateTime) desc")
- .setFirstResult(0).setMaxResults(1).setParameter(0, album.getAlbumId() + "").list();
- if (infolist != null && infolist.size() > 0) {
- if (infolist.get(0).getTvYear().length() > 5)
- video.setUpdatetime(TimeUtil.convertGernalTime(infolist.get(0).getTvYear(), "yyyyMMdd") + "");
- else
- video.setUpdatetime(TimeUtil.convertDateToTemp2(infolist.get(0).getUpdateTime()) + "");
- } else {
- video.setUpdatetime(TimeUtil.convertDateToTemp2(album.getCreatedTime()) + "");
- }
- video.setWatchCount(0 + "");
- video.setYear(year + "");
- video.setAdmin(new AdminInfo("1"));
- video.setContentType(album.getContentType());
- video.setCommentCount(0);
- if (infolist.size() > 0) {
- video.setLatestHpicture(infolist.get(0).getVideoImage());
- video.setVideocount(infolist.size());
- video.setLatestHpicture(IqiyiUtil.getHPicture( infolist.get(0).getVideoImage()));
- video.setLatestVpicture(IqiyiUtil.getVPicture(infolist.get(0).getVideoImage()));
- }
+ video.setScore(album.getScore());
+ video.setShare("0");
+ video.setShow("1");
+ if (session != null)
+ video.setTag(IqiyiUtil.getAlbumTag(album, session));
+ else
+ video.setTag(getAlbumTag(album));
+ video.setThirdType("1");
+ video.setTotalNumber("0");
+ List<IqiyiVideoInfo> infolist = session
+ .createQuery("from IqiyiVideoInfo vi where vi.albumId=? order by UNIX_TIMESTAMP(vi.updateTime) desc")
+ .setFirstResult(0).setMaxResults(1).setParameter(0, album.getAlbumId() + "").list();
+ if (infolist != null && infolist.size() > 0) {
+ if (infolist.get(0).getTvYear().length() > 5)
+ video.setUpdatetime(TimeUtil.convertGernalTime(infolist.get(0).getTvYear(), "yyyyMMdd") + "");
+ else
+ video.setUpdatetime(TimeUtil.convertDateToTemp2(infolist.get(0).getUpdateTime()) + "");
+ } else {
+ video.setUpdatetime(TimeUtil.convertDateToTemp2(album.getCreatedTime()) + "");
+ }
+ video.setWatchCount(0 + "");
+ video.setYear(year + "");
+ video.setAdmin(new AdminInfo("1"));
+ video.setContentType(album.getContentType());
+ video.setCommentCount(0);
+ if (infolist.size() > 0) {
+ video.setLatestHpicture(infolist.get(0).getVideoImage());
+ video.setVideocount(infolist.size());
+ video.setLatestHpicture(IqiyiUtil.getHPicture(infolist.get(0).getVideoImage()));
+ video.setLatestVpicture(IqiyiUtil.getVPicture(infolist.get(0).getVideoImage()));
+ }
- return video;
- }
+ return video;
+ }
- // 娣诲姞鎾斁缁熻
- public void addPlayStatistic(String detailSystemId, IqiyiVideoInfo video) {
- List list = videoIqiyiDao.sqlList(
- "SELECT i.`videoid` FROM wk_video_iqiyi i WHERE i.`albumid`=(SELECT a.`id` FROM wk_iqiyi_album a WHERE a.`albumId`=?)",
- new Serializable[] { Long.parseLong(video.getAlbumId()) });
- if (list != null && list.size() > 0) {
- statisticsService.addStatistics(detailSystemId, list.get(0) + "");
- }
- }
+ // 娣诲姞鎾斁缁熻
+ public void addPlayStatistic(String detailSystemId, IqiyiVideoInfo video) {
+ List list = videoIqiyiDao.sqlList(
+ "SELECT i.`videoid` FROM wk_video_iqiyi i WHERE i.`albumid`=(SELECT a.`id` FROM wk_iqiyi_album a WHERE a.`albumId`=?)",
+ new Serializable[]{Long.parseLong(video.getAlbumId())});
+ if (list != null && list.size() > 0) {
+ statisticsService.addStatistics(detailSystemId, list.get(0) + "");
+ }
+ }
- /**
- * 鍒犻櫎鎸囧畾鐨刬qiyi婧愯棰�
- */
- public void deleteIqiyiVideoByVideoId(final String videoId) {
- // 鍒犻櫎VideoIqiyi
- List<VideoIqiyi> list = videoIqiyiDao.list("from VideoIqiyi i where i.video.id=" + videoId);
- for (VideoIqiyi iqiyi : list)
- videoIqiyiDao.delete(iqiyi);
- // 鍒犻櫎ResourceVideo
- List<ResourceVideo> resourceVideoList = resourceVideoDao
- .list("from ResourceVideo rv where rv.video.id=" + videoId + " and rv.resource.id=19");
- for (ResourceVideo rv : resourceVideoList)
- resourceVideoDao.delete(rv);
- // 鍒よ鏄惁鍒犻櫎鐩稿叧VideoInfo
- resourceVideoList = resourceVideoDao.list("from ResourceVideo rv where rv.video.id=" + videoId);
- // 闇�瑕侀殣钘忚棰�
- if (resourceVideoList.size() <= 0) {
- videoIqiyiDao.excute(new HibernateCallback() {
- @Override
- public Object doInHibernate(Session session) throws HibernateException {
- session.getTransaction().begin();
- session.createSQLQuery("update wk_video_video v set v.show=0 where v.id=" + videoId)
- .executeUpdate();
- session.flush();
- session.getTransaction().commit();
- return null;
- }
- });
- }
+ /**
+ * 鍒犻櫎鎸囧畾鐨刬qiyi婧愯棰�
+ */
+ public void deleteIqiyiVideoByVideoId(final String videoId) {
+ // 鍒犻櫎VideoIqiyi
+ List<VideoIqiyi> list = videoIqiyiDao.list("from VideoIqiyi i where i.video.id=" + videoId);
+ for (VideoIqiyi iqiyi : list)
+ videoIqiyiDao.delete(iqiyi);
+ // 鍒犻櫎ResourceVideo
+ List<ResourceVideo> resourceVideoList = resourceVideoDao
+ .list("from ResourceVideo rv where rv.video.id=" + videoId + " and rv.resource.id=19");
+ for (ResourceVideo rv : resourceVideoList)
+ resourceVideoDao.delete(rv);
+ // 鍒よ鏄惁鍒犻櫎鐩稿叧VideoInfo
+ resourceVideoList = resourceVideoDao.list("from ResourceVideo rv where rv.video.id=" + videoId);
+ // 闇�瑕侀殣钘忚棰�
+ if (resourceVideoList.size() <= 0) {
+ videoIqiyiDao.excute(new HibernateCallback() {
+ @Override
+ public Object doInHibernate(Session session) throws HibernateException {
+ session.getTransaction().begin();
+ session.createSQLQuery("update wk_video_video v set v.show=0 where v.id=" + videoId)
+ .executeUpdate();
+ session.flush();
+ session.getTransaction().commit();
+ return null;
+ }
+ });
+ }
- }
+ }
}
--
Gitblit v1.8.0