From eb7f3343af839a7c71f16e8ada2b25d5e2201c08 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 19 四月 2021 19:27:52 +0800
Subject: [PATCH] bug修复

---
 src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java |   25 +++++++++++++++++++++----
 1 files changed, 21 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java b/src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java
index e600094..7d48717 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java
@@ -13,12 +13,10 @@
 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.PPTVProgram;
-import com.yeshi.buwan.pptv.entity.PPTVSeries;
-import com.yeshi.buwan.pptv.entity.PPTVSeriesProgramMap;
-import com.yeshi.buwan.pptv.entity.VideoPPTVMap;
+import com.yeshi.buwan.pptv.entity.*;
 import com.yeshi.buwan.service.imp.CategoryVideoService;
 import com.yeshi.buwan.service.imp.ResourceVideoService;
 import com.yeshi.buwan.service.imp.VideoInfoService;
@@ -27,6 +25,7 @@
 import com.yeshi.buwan.util.mq.CMQManager;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -295,6 +294,24 @@
         return pptvSeriesDao.get(infoId);
     }
 
+    @Override
+    public void updateSeriesGoodsInfo(String infoId, PPTVGoodsInfo goodsInfo) {
+        Query query = new Query();
+        query.addCriteria(Criteria.where("_id").is(infoId));
+        Update update = new Update();
+        update.set("goodsInfo", goodsInfo);
+        pptvSeriesDao.update(query, update);
+    }
+
+    @Override
+    public void syncSeries(String cid) {
+        PPTVSeries series = PPTVApiUtil.getDetail(cid);
+        if (series != null) {
+            save(series);
+        }
+
+    }
+
     /**
      * 鍒犻櫎鍓ч泦
      *

--
Gitblit v1.8.0