From 2a593ddac16e06f1ff55edca22ea568f07b068ba Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 02 四月 2021 19:15:18 +0800
Subject: [PATCH] 3.9.0bug修改

---
 src/main/java/com/yeshi/buwan/service/imp/juhe/MogoTVServiceImpl.java |   19 ++++++++++++-------
 1 files changed, 12 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/yeshi/buwan/service/imp/juhe/MogoTVServiceImpl.java b/src/main/java/com/yeshi/buwan/service/imp/juhe/MogoTVServiceImpl.java
index eec5e5a..832ed59 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/juhe/MogoTVServiceImpl.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/juhe/MogoTVServiceImpl.java
@@ -36,7 +36,7 @@
     private InternetSearchVideoService internetSearchVideoService;
 
     @Override
-    public void save(MogoTVClipInfo detail) {
+    public void save(MogoTVClipInfo detail) throws Exception {
         if (detail.getUpdateTime() == null)
             detail.setUpdateTime(new Date());
         mogoTVClipInfoDao.save(detail);
@@ -69,10 +69,10 @@
     }
 
     @Override
-    public List<MogoTVVideo> getVideoList(String clipId, int page, int pageSize) {
+    public List<MogoTVVideo> getVideoList(String clipId, int page, int pageSize, boolean asc) {
         Query query = new Query();
-        query.addCriteria(Criteria.where("clipId").is(clipId));
-        query.with(new Sort(new Sort.Order(Sort.Direction.ASC, "t1")));
+        query.addCriteria(Criteria.where("clip_id").is(clipId));
+        query.with(new Sort(new Sort.Order(asc ? Sort.Direction.ASC : Sort.Direction.DESC, "t1")));
         query.skip((page - 1) * pageSize);
         query.limit(pageSize);
         List<MogoTVVideo> videoList = mogoTVVideoDao.findList(query);
@@ -81,7 +81,9 @@
 
     @Override
     public MogoTVVideo getVideoDetail(String id) {
-        return mogoTVVideoDao.get(id);
+        Query query = new Query();
+        query.addCriteria(Criteria.where("_id").is(id));
+        return mogoTVVideoDao.findOne(query);
     }
 
 
@@ -110,7 +112,7 @@
             return null;
         MogoTVClipInfo clipInfo = mogoTVClipInfoDao.get(map.getClipId());
 
-        return MogoTVUtil.convertToDetail(getVideoList(map.getClipId(), page, pageSize), clipInfo);
+        return MogoTVUtil.convertToDetail(getVideoList(map.getClipId(), page, pageSize, "缁艰壓".equalsIgnoreCase(clipInfo.getFstlvlType()) ? false : true), clipInfo);
     }
 
     @Override
@@ -121,8 +123,11 @@
 
     @Override
     public void addToInternetSearch(MogoTVClipInfo clipDetail) throws Exception {
+        save(clipDetail);
         InternetSearchVideo video = InternetSearchVideoFactory.create(clipDetail);
-        internetSearchVideoService.save(video);
+        if (internetSearchVideoService.save(video) == null) {
+            return;
+        }
         MogoTVSearchVideoMap map = new MogoTVSearchVideoMap();
         map.setClipId(clipDetail.getClipId());
         map.setVideoId(video.getId());

--
Gitblit v1.8.0