From 04f09e52ffd4681bdfd85e51acd3da0d1280c3d3 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 16 四月 2022 16:07:10 +0800
Subject: [PATCH] bug修复
---
src/main/java/com/yeshi/buwan/service/imp/VideoInfoService.java | 48 +++++++++++++++++++++++++++++-------------------
1 files changed, 29 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/VideoInfoService.java b/src/main/java/com/yeshi/buwan/service/imp/VideoInfoService.java
index c57b166..2355cdf 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/VideoInfoService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/VideoInfoService.java
@@ -1,13 +1,11 @@
package com.yeshi.buwan.service.imp;
-import java.io.Serializable;
-import java.util.*;
-
-import javax.annotation.Resource;
-
-import com.yeshi.buwan.util.HibernateSessionFactory;
+import com.yeshi.buwan.dao.CategoryVideoDao;
+import com.yeshi.buwan.dao.VideoInfoDao;
+import com.yeshi.buwan.domain.*;
+import com.yeshi.buwan.domain.entity.PlayUrl;
+import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
import com.yeshi.buwan.util.StringUtil;
-import com.yeshi.buwan.util.TimeUtil;
import com.yeshi.buwan.util.mq.CMQManager;
import com.yeshi.buwan.util.video.VideoConstant;
import org.hibernate.HibernateException;
@@ -19,16 +17,11 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
-import com.yeshi.buwan.dao.CategoryVideoDao;
-import com.yeshi.buwan.dao.VideoInfoDao;
-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.VideoUrl;
-import com.yeshi.buwan.domain.entity.PlayUrl;
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
@Service
public class VideoInfoService {
@@ -52,7 +45,7 @@
return videoInfoDao.find(VideoInfo.class, vid);
}
- @Cacheable(value = "videoCache",key = "'getVideoInfoDetail-'+#vid")
+ @Cacheable(value = "videoCache", key = "'getVideoInfoDetail-'+#vid")
public VideoInfo getVideoInfoCache(String vid) {
return videoInfoDao.find(VideoInfo.class, vid);
}
@@ -84,12 +77,14 @@
}
@Transactional
- public void save(VideoInfo videoInfo) {
+ public void saveWithCategoryAndResource(VideoInfo videoInfo) {
videoInfoDao.save(videoInfo);
+ CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoInfo.getId(), VideoDataChangeMQMsg.ACTION_ADD));
CategoryVideo ca = new CategoryVideo();
ca.setVideo(videoInfo);
ca.setVideoType(videoInfo.getVideoType());
categoryVideoDao.create(ca);
+ CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_CATEGORY, videoInfo.getId(), VideoDataChangeMQMsg.ACTION_ADD));
List<VideoResource> resourceList = videoInfo.getResourceList();
ResourceVideo rs = null;
for (VideoResource videoResource : resourceList) {
@@ -98,6 +93,21 @@
rs.setVideo(videoInfo);
resourceVideoService.save(rs);
}
+ CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, videoInfo.getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ }
+
+
+ @Transactional
+ public Serializable save(VideoInfo videoInfo) {
+ Serializable id = videoInfoDao.save(videoInfo);
+ CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoInfo.getId(), VideoDataChangeMQMsg.ACTION_ADD));
+ return id;
+ }
+
+ @Transactional
+ public void update(VideoInfo videoInfo) {
+ videoInfoDao.update(videoInfo);
+ CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoInfo.getId(), VideoDataChangeMQMsg.ACTION_UPDATE));
}
public List<VideoDetailInfo> getVideoDetailList(String videoid, VideoResource vr, int page, int pageSize) {
--
Gitblit v1.8.0