From 7becc97c5bfdd827b9a999c26746bb8e8bc3e25c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 13 三月 2021 16:23:36 +0800
Subject: [PATCH] 后台会员/会员订单查询，搜索结果高清标签添加，
---
src/main/java/com/yeshi/buwan/service/imp/VideoManager.java | 1010 +++++++++++++++++++++++++++-------------------------------
1 files changed, 472 insertions(+), 538 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java b/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
index 985d5ba..cfeb1a4 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
@@ -7,6 +7,9 @@
import javax.persistence.ManyToOne;
import javax.persistence.OneToMany;
+import com.yeshi.buwan.domain.video.AlbumVideoMap;
+import com.yeshi.buwan.service.inter.juhe.AlbumVideoMapService;
+import com.yeshi.buwan.util.mq.CMQManager;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
@@ -34,596 +37,527 @@
@Service
public class VideoManager {
- @Resource
- private VideoInfoDao videoInfoDao;
- @Resource
- private VideoTypeDao videoTypeDao;
- @Resource
- private VideoDetailInfoDao videoDetailInfoDao;
+ @Resource
+ private VideoInfoDao videoInfoDao;
+ @Resource
+ private VideoTypeDao videoTypeDao;
+ @Resource
+ private VideoDetailInfoDao videoDetailInfoDao;
- /**
- * 涓婚敭鏌ヨ鏌愪竴涓棰戠殑淇℃伅
- *
- * @param id
- * @return
- */
- public VideoInfo getVideoInfo(String id) {
- VideoInfo info = videoInfoDao.find(VideoInfo.class, id);
- info.setVideoDetailList(getVideoDetail(info.getId()));
- return info;
- }
+ @Resource
+ private ClearService clearService;
- /**
- * 娣诲姞涓�涓棰戜俊鎭�
- *
- * @param info
- * @return
- */
- public VideoInfo addVideoInfo(VideoInfo info) {
- info.setUpdatetime(System.currentTimeMillis() + "");
+ /**
+ * 涓婚敭鏌ヨ鏌愪竴涓棰戠殑淇℃伅
+ *
+ * @param id
+ * @return
+ */
+ public VideoInfo getVideoInfo(String id) {
+ VideoInfo info = videoInfoDao.find(VideoInfo.class, id);
+ info.setVideoDetailList(getVideoDetail(info.getId()));
+ return info;
+ }
- videoInfoDao.save(info);
- List<VideoInfo> list = videoInfoDao.list("from VideoInfo v where v.createtime=? and v.name=?",
- new String[] { info.getCreatetime() + "", info.getName() });
- return list.get(0);
- }
+ /**
+ * 娣诲姞涓�涓棰戜俊鎭�
+ *
+ * @param info
+ * @return
+ */
+ public VideoInfo addVideoInfo(VideoInfo info) {
+ info.setUpdatetime(System.currentTimeMillis() + "");
- String[] sts = { "褰煎緱鍏�", "閾佹墖鍏富", "杩囩尨灞�", "楠勫偛鐨勫皢鍐�", "澶稿彛鐨勯潚铔�", "灏忕尗閽撻奔", "濂芥湅鍙�", "绁炵瑪椹壇", "鏈ㄥご鍏富", "鐚叓鎴掑悆瑗跨摐", "灏忛菠楸�", "鎴戠煡閬�",
- "鑰佸皬闃垮嚒鎻�", "闃跨嫺閫氳瘽鏃ヨ" };
+ videoInfoDao.save(info);
+ List<VideoInfo> list = videoInfoDao.list("from VideoInfo v where v.createtime=? and v.name=?",
+ new String[]{info.getCreatetime() + "", info.getName()});
+ return list.get(0);
+ }
- boolean isContains(String st) {
- for (String s : sts) {
- if (st.contains(s)) {
- return true;
- }
- }
- return false;
- }
+ String[] sts = {"褰煎緱鍏�", "閾佹墖鍏富", "杩囩尨灞�", "楠勫偛鐨勫皢鍐�", "澶稿彛鐨勯潚铔�", "灏忕尗閽撻奔", "濂芥湅鍙�", "绁炵瑪椹壇", "鏈ㄥご鍏富", "鐚叓鎴掑悆瑗跨摐", "灏忛菠楸�", "鎴戠煡閬�",
+ "鑰佸皬闃垮嚒鎻�", "闃跨嫺閫氳瘽鏃ヨ"};
- // 鑾峰彇澶у垎绫�
- public String getRootType(long id) {
- VideoType type = videoTypeDao.find(VideoType.class, id);
- while (type.getParent() != null)
- type = type.getParent();
- return type.getId() + "";
- }
+ boolean isContains(String st) {
+ for (String s : sts) {
+ if (st.contains(s)) {
+ return true;
+ }
+ }
+ return false;
+ }
- // 娣诲姞瑙嗛
- @SuppressWarnings("unchecked")
- public void addVideoInfo(List<VideoInfo> list) {
- for (VideoInfo in : list) {
- final VideoInfo info = in;
- LogUtil.i("瑙嗛鍚嶇О:" + info.getName());
- // if (!info.getName().contains("涓変釜濂剁埜")) continue;
- final String parentId = getRootType(info.getVideoType().getId());
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- List<VideoInfo> vList = session
- .createQuery("from VideoInfo v where v.name=? and v.show=1 and (v.videoType.id="
- + parentId + " or v.videoType.parent.id=" + parentId + ")")
- .setParameter(0, info.getName()).list();
- session.getTransaction().begin();
- if (vList.size() <= 0) {// 涓嶅瓨鍦ㄨ棰�--鍙互娣诲姞杩涘幓
- info.setUpdatetime(System.currentTimeMillis() + "");
- session.persist(info);
- List<VideoInfo> viList = session
- .createQuery("from VideoInfo v where v.name=? and v.createtime=?")
- .setParameter(0, info.getName()).setParameter(1, info.getCreatetime()).list();// 鏌ヨ鍑哄垰鍒氭坊鍔犵殑瑙嗛
- if (viList != null && viList.size() > 0) {
- VideoInfo newVideo = new VideoInfo(viList.get(0).getId());
- LogUtil.i("鏌ュ嚭鐨刅ideoId涓�:" + newVideo.getId());
- for (int i = 0; i < info.getVideoDetailList().size(); i++) {
- VideoDetailInfo detail = info.getVideoDetailList().get(i);
- detail.setVideo(newVideo);
- session.persist(detail);
- session.createSQLQuery(
- "update wk_video_video_detail d set d.videoid=? where d.name=? and d.tag=? and d.createtime=?")
- .setParameter(0, newVideo.getId()).setParameter(1, detail.getName())
- .setParameter(2, detail.getTag()).setParameter(3, detail.getCreatetime())
- .executeUpdate();
- }
- } else {
- LogUtil.i("videoId娌℃湁鏌ュ嚭鏉�");
- }
+ // 鑾峰彇澶у垎绫�
+ public String getRootType(long id) {
+ VideoType type = videoTypeDao.find(VideoType.class, id);
+ while (type.getParent() != null)
+ type = type.getParent();
+ return type.getId() + "";
+ }
- } else {// 瀛樺湪鐨勮棰戯紝娣诲姞杩沀rlList
- // 鑾峰彇videoDetail;
- vList.get(0).setTag(info.getTag());
- session.update(vList.get(0));
- vList.get(0).setNowNumber(info.getNowNumber());
- vList.get(0).setTotalNumber(info.getTotalNumber());
+ // 娣诲姞瑙嗛
+ @SuppressWarnings("unchecked")
+ public void addVideoInfo(List<VideoInfo> list) {
+ for (VideoInfo in : list) {
+ final VideoInfo info = in;
+ LogUtil.i("瑙嗛鍚嶇О:" + info.getName());
+ // if (!info.getName().contains("涓変釜濂剁埜")) continue;
+ final String parentId = getRootType(info.getVideoType().getId());
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ List<VideoInfo> vList = session
+ .createQuery("from VideoInfo v where v.name=? and v.show=1 and (v.videoType.id="
+ + parentId + " or v.videoType.parent.id=" + parentId + ")")
+ .setParameter(0, info.getName()).list();
+ session.getTransaction().begin();
+ if (vList.size() <= 0) {// 涓嶅瓨鍦ㄨ棰�--鍙互娣诲姞杩涘幓
+ info.setUpdatetime(System.currentTimeMillis() + "");
+ session.persist(info);
+ List<VideoInfo> viList = session
+ .createQuery("from VideoInfo v where v.name=? and v.createtime=?")
+ .setParameter(0, info.getName()).setParameter(1, info.getCreatetime()).list();// 鏌ヨ鍑哄垰鍒氭坊鍔犵殑瑙嗛
+ if (viList != null && viList.size() > 0) {
+ VideoInfo newVideo = new VideoInfo(viList.get(0).getId());
+ LogUtil.i("鏌ュ嚭鐨刅ideoId涓�:" + newVideo.getId());
+ for (int i = 0; i < info.getVideoDetailList().size(); i++) {
+ VideoDetailInfo detail = info.getVideoDetailList().get(i);
+ detail.setVideo(newVideo);
+ session.persist(detail);
+ session.createSQLQuery(
+ "update wk_video_video_detail d set d.videoid=? where d.name=? and d.tag=? and d.createtime=?")
+ .setParameter(0, newVideo.getId()).setParameter(1, detail.getName())
+ .setParameter(2, detail.getTag()).setParameter(3, detail.getCreatetime())
+ .executeUpdate();
+ }
+ } else {
+ LogUtil.i("videoId娌℃湁鏌ュ嚭鏉�");
+ }
- List<VideoDetailInfo> detailList = getVideoDetail(session, vList.get(0).getId());// 鑾峰彇鍘熸潵鐨刣etailList
- for (int n = 0; n < info.getVideoDetailList().size(); n++) {
- if (n + 1 > detailList.size()) {// 鍘熸潵涓嶅瓨鍦ㄨ繖涓�闆�
- VideoInfo newVideo = vList.get(0);
- // 淇濆瓨璇︽儏
- VideoDetailInfo detail = info.getVideoDetailList().get(n);
- detail.setVideo(newVideo);
- session.persist(detail);
- session.createSQLQuery(
- "update wk_video_video_detail d set d.videoid=? where d.name=? and d.tag=? and d.createtime=?")
- .setParameter(0, newVideo.getId()).setParameter(1, detail.getName())
- .setParameter(2, detail.getTag()).setParameter(3, detail.getCreatetime())
- .executeUpdate();
+ } else {// 瀛樺湪鐨勮棰戯紝娣诲姞杩沀rlList
+ // 鑾峰彇videoDetail;
+ vList.get(0).setTag(info.getTag());
+ session.update(vList.get(0));
+ vList.get(0).setNowNumber(info.getNowNumber());
+ vList.get(0).setTotalNumber(info.getTotalNumber());
- } else {// 鍘熸潵瀛樺湪杩欎釜detail
- VideoDetailInfo detail = detailList.get(n);// 鑾峰彇鍘熸潵閭ｄ釜url
- List<VideoUrl> urlList = detail.getUrls();
- VideoUrl vurl = null;
+ List<VideoDetailInfo> detailList = getVideoDetail(session, vList.get(0).getId());// 鑾峰彇鍘熸潵鐨刣etailList
+ for (int n = 0; n < info.getVideoDetailList().size(); n++) {
+ if (n + 1 > detailList.size()) {// 鍘熸潵涓嶅瓨鍦ㄨ繖涓�闆�
+ VideoInfo newVideo = vList.get(0);
+ // 淇濆瓨璇︽儏
+ VideoDetailInfo detail = info.getVideoDetailList().get(n);
+ detail.setVideo(newVideo);
+ session.persist(detail);
+ session.createSQLQuery(
+ "update wk_video_video_detail d set d.videoid=? where d.name=? and d.tag=? and d.createtime=?")
+ .setParameter(0, newVideo.getId()).setParameter(1, detail.getName())
+ .setParameter(2, detail.getTag()).setParameter(3, detail.getCreatetime())
+ .executeUpdate();
- for (VideoUrl videoUrl : urlList) {
- if (videoUrl.getResource().getId().equalsIgnoreCase(info.getVideoDetailList()
- .get(n).getUrls().get(0).getResource().getId())) {// 瀛樺湪
- vurl = videoUrl;
- }
- }
+ } else {// 鍘熸潵瀛樺湪杩欎釜detail
+ VideoDetailInfo detail = detailList.get(n);// 鑾峰彇鍘熸潵閭ｄ釜url
+ List<VideoUrl> urlList = detail.getUrls();
+ VideoUrl vurl = null;
- if (vurl == null) {// 涓嶅瓨鍦�--寰�閲岄潰娣诲姞
- VideoUrl vu = null;
- try {
- vu = info.getVideoDetailList().get(n).getUrls().get(0);
- } catch (Exception e) {
- vu = info.getVideoDetailList().get(n).getUrls().get(0);
- }
- vu.setVideoDetail(detail);
- // 鏇存柊url
- session.createSQLQuery(
- "insert into wk_video_video_url (videodetailid,resourceid,vdetailurl,createtime,adminid,beizhu,baseurl) values(?,?,?,?,?,?,?)")
- .setParameter(0, detail.getId())
- .setParameter(1, vu.getResource().getId()).setParameter(2, vu.getUrl())
- .setParameter(3, vu.getCreatetime())
- .setParameter(4, vu.getAdmin().getId()).setParameter(5, vu.getBeizhu())
- .setParameter(6, vu.getBaseUrl()).executeUpdate();
- } else {// 鍘熸潵瀛樺湪璇RL
- VideoUrl newUrl = info.getVideoDetailList().get(n).getUrls().get(0);
- if (!newUrl.getUrl().equals(vurl.getUrl())) {
- vurl.setUrl(newUrl.getUrl());
- session.update(vurl);
- detail.setTag(info.getVideoDetailList().get(n).getTag());
- session.update(detail);
- }
- }
- }
- }
- }
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- LogUtil.i("瑙嗛鍚嶇О:" + info.getName());
- e.printStackTrace();
- session.getTransaction().rollback();
- }
+ for (VideoUrl videoUrl : urlList) {
+ if (videoUrl.getResource().getId().equalsIgnoreCase(info.getVideoDetailList()
+ .get(n).getUrls().get(0).getResource().getId())) {// 瀛樺湪
+ vurl = videoUrl;
+ }
+ }
- return null;
- }
- });
+ if (vurl == null) {// 涓嶅瓨鍦�--寰�閲岄潰娣诲姞
+ VideoUrl vu = null;
+ try {
+ vu = info.getVideoDetailList().get(n).getUrls().get(0);
+ } catch (Exception e) {
+ vu = info.getVideoDetailList().get(n).getUrls().get(0);
+ }
+ vu.setVideoDetail(detail);
+ // 鏇存柊url
+ session.createSQLQuery(
+ "insert into wk_video_video_url (videodetailid,resourceid,vdetailurl,createtime,adminid,beizhu,baseurl) values(?,?,?,?,?,?,?)")
+ .setParameter(0, detail.getId())
+ .setParameter(1, vu.getResource().getId()).setParameter(2, vu.getUrl())
+ .setParameter(3, vu.getCreatetime())
+ .setParameter(4, vu.getAdmin().getId()).setParameter(5, vu.getBeizhu())
+ .setParameter(6, vu.getBaseUrl()).executeUpdate();
+ } else {// 鍘熸潵瀛樺湪璇RL
+ VideoUrl newUrl = info.getVideoDetailList().get(n).getUrls().get(0);
+ if (!newUrl.getUrl().equals(vurl.getUrl())) {
+ vurl.setUrl(newUrl.getUrl());
+ session.update(vurl);
+ detail.setTag(info.getVideoDetailList().get(n).getTag());
+ session.update(detail);
+ }
+ }
+ }
+ }
+ }
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ LogUtil.i("瑙嗛鍚嶇О:" + info.getName());
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
- }
- }
+ return null;
+ }
+ });
- public void updateVideoInfo(VideoInfo info) {
- videoInfoDao.update(info);
- }
+ }
+ }
- public void updateVideoInfo(List<VideoInfo> list) {
- for (VideoInfo vi : list)
- videoInfoDao.update(vi);
- }
+ public void updateVideoInfo(VideoInfo info) {
+ videoInfoDao.update(info);
+ }
- @ManyToOne
- private AdminInfo getAdmin() {
- AdminInfo info = new AdminInfo();
- info.setId("1");
- return info;
- }
+ public void updateVideoInfo(List<VideoInfo> list) {
+ for (VideoInfo vi : list)
+ videoInfoDao.update(vi);
+ }
- /**
- * 娣诲姞瑙嗛璇︽儏
- *
- * @param list
- */
- public void addVideoDetail(final VideoInfo info, final List<VideoDetailInfo> list) {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- for (int i = 0; i < list.size(); i++) {
- VideoInfo video = new VideoInfo(info.getId());
- list.get(i).setVideo(video);
- session.persist(list.get(i));
- }
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ @ManyToOne
+ private AdminInfo getAdmin() {
+ AdminInfo info = new AdminInfo();
+ info.setId("1");
+ return info;
+ }
- }
+ /**
+ * 娣诲姞瑙嗛璇︽儏
+ *
+ * @param list
+ */
+ public void addVideoDetail(final VideoInfo info, final List<VideoDetailInfo> list) {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ for (int i = 0; i < list.size(); i++) {
+ VideoInfo video = new VideoInfo(info.getId());
+ list.get(i).setVideo(video);
+ session.persist(list.get(i));
+ }
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- /**
- * 娣诲姞瑙嗛璇︽儏
- *
- * @param list
- */
- public void addVideoDetail(final List<VideoDetailInfo> list) {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- for (int i = 0; i < list.size(); i++) {
- session.persist(list.get(i));
- }
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ }
- }
+ /**
+ * 娣诲姞瑙嗛璇︽儏
+ *
+ * @param list
+ */
+ public void addVideoDetail(final List<VideoDetailInfo> list) {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ for (int i = 0; i < list.size(); i++) {
+ session.persist(list.get(i));
+ }
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- public VideoDetailInfo addVideoDetail(final VideoDetailInfo detail) {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- session.persist(detail);
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
- }
- });
+ }
- List<VideoDetailInfo> list = getVideoDetail(detail.getVideo().getId());
- if (list != null && list.size() > 0)
- return list.get(0);
- else
- return null;
- }
+ public VideoDetailInfo addVideoDetail(final VideoDetailInfo detail) {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ session.persist(detail);
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+ });
- public List<VideoDetailInfo> getVideoDetail(String videoId) {
- LogUtil.i("璇锋眰寮�濮�:" + System.currentTimeMillis());
- List<VideoDetailInfo> list = videoDetailInfoDao.list("from VideoDetailInfo d where d.video.id=?",
- new String[] { videoId });
- LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
- return list;
- }
+ List<VideoDetailInfo> list = getVideoDetail(detail.getVideo().getId());
+ if (list != null && list.size() > 0)
+ return list.get(0);
+ else
+ return null;
+ }
- public VideoDetailInfo getVideoDetailById(long videoDetailId) {
- return videoDetailInfoDao.find(VideoDetailInfo.class, videoDetailId);
- }
+ public List<VideoDetailInfo> getVideoDetail(String videoId) {
+ LogUtil.i("璇锋眰寮�濮�:" + System.currentTimeMillis());
+ List<VideoDetailInfo> list = videoDetailInfoDao.list("from VideoDetailInfo d where d.video.id=?",
+ new String[]{videoId});
+ LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
+ return list;
+ }
- public List<VideoDetailInfo> getVideoDetailByVideoName(String name) {
- LogUtil.i("璇锋眰寮�濮�:" + System.currentTimeMillis());
+ public VideoDetailInfo getVideoDetailById(long videoDetailId) {
+ return videoDetailInfoDao.find(VideoDetailInfo.class, videoDetailId);
+ }
- List<VideoDetailInfo> list = videoDetailInfoDao.list("from VideoDetailInfo d where d.name=?",
- new String[] { name });
- LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
- return list;
- }
+ public List<VideoDetailInfo> getVideoDetailByVideoName(String name) {
+ LogUtil.i("璇锋眰寮�濮�:" + System.currentTimeMillis());
- public List<VideoDetailInfo> getVideoDetail(Session session, String videoId) {
- @SuppressWarnings("unchecked")
- List<VideoDetailInfo> list = session.createQuery("from VideoDetailInfo d where d.video.id=?")
- .setParameter(0, videoId).list();
- LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
- return list;
- }
+ List<VideoDetailInfo> list = videoDetailInfoDao.list("from VideoDetailInfo d where d.name=?",
+ new String[]{name});
+ LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
+ return list;
+ }
- /**
- * 鏇存柊瑙嗛鐨勮鎯�
- *
- * @param list
- */
- public void updateVideoDetail(final List<VideoDetailInfo> list) {
+ public List<VideoDetailInfo> getVideoDetail(Session session, String videoId) {
+ @SuppressWarnings("unchecked")
+ List<VideoDetailInfo> list = session.createQuery("from VideoDetailInfo d where d.video.id=?")
+ .setParameter(0, videoId).list();
+ LogUtil.i("璇锋眰缁撴潫:" + System.currentTimeMillis());
+ return list;
+ }
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
+ /**
+ * 鏇存柊瑙嗛鐨勮鎯�
+ *
+ * @param list
+ */
+ public void updateVideoDetail(final List<VideoDetailInfo> list) {
- // BaseDao<VideoDetailInfo> dao = new
- // BaseDao<VideoDetailInfo>();
- // /BaseDao<VideoUrl> urlDao = new BaseDao<VideoUrl>();
- // BaseDao<VideoDetailInfo> dao = new
- // BaseDao<VideoDetailInfo>();
- session.getTransaction().begin();
- for (int i = 0; i < list.size(); i++) {
- for (int j = 0; j < list.get(i).getUrls().size(); j++) {
- session.createSQLQuery("update wk_video_video_url set vdetailurl=? where id=?")
- .setParameter(0, list.get(i).getUrls().get(j).getUrl())
- .setParameter(1, list.get(i).getUrls().get(j).getId() + "").executeUpdate();
- }
- }
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
- }
+ // BaseDao<VideoDetailInfo> dao = new
+ // BaseDao<VideoDetailInfo>();
+ // /BaseDao<VideoUrl> urlDao = new BaseDao<VideoUrl>();
+ // BaseDao<VideoDetailInfo> dao = new
+ // BaseDao<VideoDetailInfo>();
+ session.getTransaction().begin();
+ for (int i = 0; i < list.size(); i++) {
+ for (int j = 0; j < list.get(i).getUrls().size(); j++) {
+ session.createSQLQuery("update wk_video_video_url set vdetailurl=? where id=?")
+ .setParameter(0, list.get(i).getUrls().get(j).getUrl())
+ .setParameter(1, list.get(i).getUrls().get(j).getId() + "").executeUpdate();
+ }
+ }
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- public void updateVideoDetail(final VideoDetailInfo detail) {
- if (detail.getUrls() == null || detail.getUrls().size() < 1)
- return;
+ }
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- session.createQuery("delete from VideoUrl vu where vu.videoDetail.id=?")
- .setParameter(0, detail.getId()).executeUpdate();
- for (VideoUrl vu : detail.getUrls())
- session.save(vu);
- session.update(detail);
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ public void updateVideoDetail(final VideoDetailInfo detail) {
+ if (detail.getUrls() == null || detail.getUrls().size() < 1)
+ return;
- }
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ session.createQuery("delete from VideoUrl vu where vu.videoDetail.id=?")
+ .setParameter(0, detail.getId()).executeUpdate();
+ for (VideoUrl vu : detail.getUrls())
+ session.save(vu);
+ session.update(detail);
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- public void deleteVideoDetail(VideoDetailInfo detail) {
- videoDetailInfoDao.delete(detail);
- }
+ }
- /**
- * 鏇存柊瑙嗛鐨勮鎯�
- *
- * @param list
- */
- public void updateVideoDetailByAdmin(final List<VideoDetailInfo> list) {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- for (int i = 0; i < list.size(); i++) {
- try {
- session.persist(list.get(i));
- } catch (Exception e) {
- session.update(list.get(i));
- }
- }
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- LogUtil.i("浜嬬墿鍥炴粴");
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ public void deleteVideoDetail(VideoDetailInfo detail) {
+ videoDetailInfoDao.delete(detail);
+ }
- }
+ /**
+ * 鏇存柊瑙嗛鐨勮鎯�
+ *
+ * @param list
+ */
+ public void updateVideoDetailByAdmin(final List<VideoDetailInfo> list) {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ for (int i = 0; i < list.size(); i++) {
+ try {
+ session.persist(list.get(i));
+ } catch (Exception e) {
+ session.update(list.get(i));
+ }
+ }
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ LogUtil.i("浜嬬墿鍥炴粴");
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- @SuppressWarnings("unchecked")
- public void deleteVideo(final String videoId) {
- try {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- List<HomeVideo> hlist = session.createQuery("from HomeVideo v where v.video.id=?")
- .setParameter(0, videoId).list();
- session.getTransaction().begin();
- JuheVideoUtil.clearData(session, videoId);
- if (hlist != null && hlist.size() > 0) {
- for (HomeVideo hv : hlist) {
- session.delete(hv);
- }
- }
- // 鍒犻櫎鏀惰棌
- session.createSQLQuery("delete from wk_video_collection where videoid=" + videoId)
- .executeUpdate();
+ }
- List<VideoBanQuanVideo> qlist = session
- .createQuery("from VideoBanQuanVideo c where c.info.id=?").setParameter(0, videoId)
- .list();
- if (qlist != null && qlist.size() > 0) {
- for (VideoBanQuanVideo c : qlist)
- session.delete(c);
- }
- List<HomeAd> hdList = session
- .createQuery("from HomeAd ha where ha.linkType=1 and ha.video.id=?")
- .setParameter(0, videoId).list();
+ @Resource
+ private AlbumVideoMapService albumVideoMapService;
- for (HomeAd had : hdList) {
- List<SuperHomeAd> shadL = session
- .createQuery("from SuperHomeAd shad where shad.homeAd.id=?")
- .setParameter(0, had.getId()).list();
- for (SuperHomeAd shad : shadL)
- session.delete(shad);
- session.delete(had);
- }
+ /**
+ * 鍒犻櫎瑙嗛
+ *
+ * @param videoId
+ */
+ public void deleteVideo(final String videoId) {
+ //娓呴櫎sql鏁版嵁琛ㄧ浉鍏充緷璧�
+ clearService.clearDependVideo(videoId);
+ //娓呴櫎MongoDB鐩稿叧渚濊禆
+ albumVideoMapService.deleteByVideoId(videoId);
+ //鏇存柊鎼滅储寮曟搸鏁版嵁
+ CMQManager.getInstance().addSolrMsg(videoId);
+ videoInfoDao.delete(new VideoInfo(videoId));
+ }
- // 涓撻瑙嗛鍒犻櫎
- List<SpecialVideo> svList = session.createQuery("from SpecialVideo ha where ha.video.id=?")
- .setParameter(0, videoId).list();
+ // 鏇存柊瑙嗛鐨勮鐪嬫暟
+ public void updateVideoWatchCount(final String videoId) {
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ try {
+ session.getTransaction().begin();
+ session.createSQLQuery("update wk_video_video set watchcount=(watchcount+1) where id=" + videoId)
+ .executeUpdate();
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- for (SpecialVideo sv : svList) {
- List<SuperSpecial> shadL = session
- .createQuery("from SuperSpecial shad where shad.special.id=?")
- .setParameter(0, sv.getSpecial().getId()).list();
- for (SuperSpecial shad : shadL)
- session.delete(shad);
- session.delete(sv);
- }
+ }
- // 鍚堥泦瑙嗛鍒犻櫎
- List<VideoIntersectionVideo> viList = session
- .createQuery("from VideoIntersectionVideo ha where ha.video.id=?")
- .setParameter(0, videoId).list();
- for (VideoIntersectionVideo sv : viList) {
- session.delete(sv);
- }
+ @OneToMany
+ private List<VideoDetailInfo> getVideoDetailList() {
+ List<VideoDetailInfo> list = new ArrayList<VideoDetailInfo>();
+ VideoDetailInfo info = new VideoDetailInfo();
+ info.setAdmin(getAdmin());
+ info.setBeizhu("娴嬭瘯淇℃伅");
+ info.setCreatetime(System.currentTimeMillis() + "");
+ info.setName("鍔熷か");
+ info.setTag("");
+ List<VideoUrl> urlList = info.getUrls();
+ VideoUrl url = new VideoUrl();
+ url.setAdmin(getAdmin());
+ url.setBeizhu("娴嬭瘯");
+ url.setCreatetime(System.currentTimeMillis() + "");
+ VideoResource resource = new VideoResource();
+ resource.setId("1");
+ url.setResource(resource);
+ url.setUrl("http://123333.mp4");
+ urlList.add(url);
+ info.setUrls(urlList);
+ list.add(info);
+ return list;
+ }
- // 瑙嗛鍒犻櫎
- List<VideoDetailInfo> list = session.createQuery("from VideoDetailInfo v where v.video.id=?")
- .setParameter(0, videoId).list();
- // 鍒犻櫎瑙嗛鐨勮缁嗕俊鎭�
- for (VideoDetailInfo object : list) {
- // 鍒犻櫎閾炬帴淇℃伅
- for (VideoUrl vu : object.getUrls())
- session.delete(vu);
- // 鍒犻櫎璇︽儏
- session.delete(object);
- }
+ @SuppressWarnings("finally")
+ public boolean changeVideoShow(final VideoInfo info) {
+ return (Boolean) videoInfoDao.excute(new HibernateCallback<Boolean>() {
+ public Boolean doInHibernate(Session session) throws HibernateException {
+ int result = 0;
+ try {
+ session.getTransaction().begin();
+ result = session.createSQLQuery("update wk_video_video set `show`=? where `id`=?")
+ .setParameter(0, info.getShow()).setParameter(1, info.getId()).executeUpdate();
+ session.flush();
+ session.getTransaction().commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ if (result > 0)
+ return true;
+ else
+ return false;
+ }
- // 鍒犻櫎瑙嗛婧愪俊鎭�
- session.createSQLQuery("delete from wk_video_video where id=?").setParameter(0, videoId)
- .executeUpdate();
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
- } catch (Exception e) {
- e.printStackTrace();
- }
+ }
+ });
- }
+ }
- // 鏇存柊瑙嗛鐨勮鐪嬫暟
- public void updateVideoWatchCount(final String videoId) {
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- try {
- session.getTransaction().begin();
- session.createSQLQuery("update wk_video_video set watchcount=(watchcount+1) where id=" + videoId)
- .executeUpdate();
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ /**
+ * 鐢熸垚瑙嗛鐨勫悕绉�--鍞竴
+ *
+ * @return
+ */
+ public String getVideoPathName(String type, String oldName) {
+ String src = (long) (Math.random() * 100000000)
+ + StringUtil.Md5(System.currentTimeMillis() + (long) (Math.random() * 100000000) + "");
+ return StringUtil.getBase64(src) + "_" + StringUtil.getBase64(oldName) + "." + type;
+ }
- }
+ @ManyToOne
+ private VideoType getVideoType() {
+ VideoType type = new VideoType();
+ type.setId(1);
+ return type;
+ }
- @OneToMany
- private List<VideoDetailInfo> getVideoDetailList() {
- List<VideoDetailInfo> list = new ArrayList<VideoDetailInfo>();
- VideoDetailInfo info = new VideoDetailInfo();
- info.setAdmin(getAdmin());
- info.setBeizhu("娴嬭瘯淇℃伅");
- info.setCreatetime(System.currentTimeMillis() + "");
- info.setName("鍔熷か");
- info.setTag("");
- List<VideoUrl> urlList = info.getUrls();
- VideoUrl url = new VideoUrl();
- url.setAdmin(getAdmin());
- url.setBeizhu("娴嬭瘯");
- url.setCreatetime(System.currentTimeMillis() + "");
- VideoResource resource = new VideoResource();
- resource.setId("1");
- url.setResource(resource);
- url.setUrl("http://123333.mp4");
- urlList.add(url);
- info.setUrls(urlList);
- list.add(info);
- return list;
- }
+ // 闅愯棌瑙嗛
+ public void setVideoHidden(final String urlKey) {
- @SuppressWarnings("finally")
- public boolean changeVideoShow(final VideoInfo info) {
- return (Boolean) videoInfoDao.excute(new HibernateCallback<Boolean>() {
- public Boolean doInHibernate(Session session) throws HibernateException {
- int result = 0;
- try {
- session.getTransaction().begin();
- result = session.createSQLQuery("update wk_video_video set `show`=? where `id`=?")
- .setParameter(0, info.getShow()).setParameter(1, info.getId()).executeUpdate();
- session.flush();
- session.getTransaction().commit();
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- if (result > 0)
- return true;
- else
- return false;
- }
+ videoInfoDao.excute(new HibernateCallback() {
+ public Object doInHibernate(Session session) throws HibernateException {
+ List<String> listSt = new ArrayList<String>();
+ try {
+ List list = session
+ .createSQLQuery(
+ "select d.videoid from wk_video_video_url u left join wk_video_video_detail d on d.id=u.videodetailid where vdetailurl like ?")
+ .setParameter(0, "%" + urlKey + "%").list();
+ for (int i = 0; i < list.size(); i++) {
+ Object obj = (Object) list.get(i);
+ listSt.add(obj.toString());
+ LogUtil.i(obj.toString());
+ }
+ LogUtil.i(list.size());
+ for (int j = 0; j < listSt.size(); j++) {
+ VideoInfo vi = videoInfoDao.find(VideoInfo.class, listSt.get(j));
+ vi.setShow("0");
+ videoInfoDao.update(vi);
+ }
- }
- });
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+ });
- }
-
- /**
- * 鐢熸垚瑙嗛鐨勫悕绉�--鍞竴
- *
- * @return
- */
- public String getVideoPathName(String type, String oldName) {
- String src = (long) (Math.random() * 100000000)
- + StringUtil.Md5(System.currentTimeMillis() + (long) (Math.random() * 100000000) + "");
- return StringUtil.getBase64(src) + "_" + StringUtil.getBase64(oldName) + "." + type;
- }
-
- @ManyToOne
- private VideoType getVideoType() {
- VideoType type = new VideoType();
- type.setId(1);
- return type;
- }
-
- // 闅愯棌瑙嗛
- public void setVideoHidden(final String urlKey) {
-
- videoInfoDao.excute(new HibernateCallback() {
- public Object doInHibernate(Session session) throws HibernateException {
- List<String> listSt = new ArrayList<String>();
- try {
- List list = session
- .createSQLQuery(
- "select d.videoid from wk_video_video_url u left join wk_video_video_detail d on d.id=u.videodetailid where vdetailurl like ?")
- .setParameter(0, "%" + urlKey + "%").list();
- for (int i = 0; i < list.size(); i++) {
- Object obj = (Object) list.get(i);
- listSt.add(obj.toString());
- LogUtil.i(obj.toString());
- }
- LogUtil.i(list.size());
- for (int j = 0; j < listSt.size(); j++) {
- VideoInfo vi = videoInfoDao.find(VideoInfo.class, listSt.get(j));
- vi.setShow("0");
- videoInfoDao.update(vi);
- }
-
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
- }
- });
-
- }
+ }
}
--
Gitblit v1.8.0