admin
2022-04-16 04f09e52ffd4681bdfd85e51acd3da0d1280c3d3
src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java
@@ -2,7 +2,6 @@
import com.yeshi.buwan.dao.VideoInfoDao;
import com.yeshi.buwan.dao.VideoResourceMapExtraInfoDao;
import com.yeshi.buwan.dao.VideoTypeDao;
import com.yeshi.buwan.dao.juhe.pptv.PPTVProgramDao;
import com.yeshi.buwan.dao.juhe.pptv.PPTVSeriesDao;
import com.yeshi.buwan.dao.juhe.pptv.PPTVSeriesProgramMapDao;
@@ -13,17 +12,16 @@
import com.yeshi.buwan.domain.VideoType;
import com.yeshi.buwan.domain.video.AlbumVideoMap;
import com.yeshi.buwan.dto.mq.PPTVMQMsg;
import com.yeshi.buwan.pptv.PPTVApiUtil;
import com.yeshi.buwan.pptv.PPTVQuery;
import com.yeshi.buwan.pptv.PPTVUtil;
import com.yeshi.buwan.pptv.entity.*;
import com.yeshi.buwan.videos.pptv.PPTVApiUtil;
import com.yeshi.buwan.videos.pptv.PPTVQuery;
import com.yeshi.buwan.videos.pptv.PPTVUtil;
import com.yeshi.buwan.videos.pptv.entity.*;
import com.yeshi.buwan.service.imp.CategoryVideoService;
import com.yeshi.buwan.service.imp.ResourceVideoService;
import com.yeshi.buwan.service.imp.VideoInfoService;
import com.yeshi.buwan.service.imp.VideoTypeService;
import com.yeshi.buwan.service.inter.juhe.PPTVService;
import com.yeshi.buwan.util.mq.CMQManager;
import com.yeshi.buwan.util.video.VideoConstant;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
@@ -101,14 +99,14 @@
                    videoInfo.setVpicture(newVideoInfo.getVpicture());
                    videoInfo.setShow(newVideoInfo.getShow());
                    videoInfo.setVideoType(newVideoInfo.getVideoType());
                    videoInfoDao.update(videoInfo);
                    videoInfoService.update(videoInfo);
                }
            } else {//视频不存在
                //判断2个视频实体是否为同一视频
                VideoInfo oldVideo = videoInfoService.getExistSameVideoWithDirector(newVideoInfo);
                if (oldVideo == null) {
                    //添加视频
                    Serializable id = videoInfoDao.save(newVideoInfo);
                    Serializable id = videoInfoService.save(newVideoInfo);
                    newVideoInfo.setId(id + "");
                } else {//为同一视频
                    //更新tag
@@ -120,7 +118,7 @@
                    oldVideo.setVpicture(newVideoInfo.getVpicture());
                    oldVideo.setShow(newVideoInfo.getShow());
                    oldVideo.setVideoType(newVideoInfo.getVideoType());
                    videoInfoDao.update(oldVideo);
                    videoInfoService.update(oldVideo);
                }
                //加入专辑视频映射