From 4011b8d0b377af33e2bc435f7726329630d706cb Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 02 三月 2021 18:28:52 +0800
Subject: [PATCH] 搜索引擎接口更新
---
src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java | 24 +++++++++++++++++++++---
1 files changed, 21 insertions(+), 3 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 d2c48f3..dfbffad 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
@@ -10,6 +10,7 @@
import com.yeshi.buwan.domain.VideoInfo;
import com.yeshi.buwan.domain.VideoResourceMapExtraInfo;
import com.yeshi.buwan.domain.video.AlbumVideoMap;
+import com.yeshi.buwan.dto.mq.PPTVMQMsg;
import com.yeshi.buwan.pptv.PPTVQuery;
import com.yeshi.buwan.pptv.PPTVUtil;
import com.yeshi.buwan.pptv.entity.PPTVProgram;
@@ -108,7 +109,7 @@
//鍔犲叆鏄犲皠
VideoPPTVMap vi = new VideoPPTVMap();
vi.setInfoId(series.getInfoID());
- vi.setVideoId(Long.parseLong(newVideoInfo.getId()));
+ vi.setVideoId(newVideoInfo.getId());
vi.setCreateTime(new Date());
videoPPTVMapDao.save(vi);
}
@@ -167,6 +168,14 @@
programList.addAll(tempList);
}
}
+ Comparator<PPTVProgram> comparator = new Comparator<PPTVProgram>() {
+ @Override
+ public int compare(PPTVProgram o1, PPTVProgram o2) {
+ return o1.getRank() - o2.getRank();
+ }
+ };
+ Collections.sort(programList, comparator);
+
series.setSeries(programList);
return series;
}
@@ -193,7 +202,7 @@
series.setCreateTime(new Date());
pptvSeriesDao.save(series);
//澶勭悊鏂板/鏀瑰彉鐨勫墽闆嗕俊鎭�
-// CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(series.getInfoID(), PPTVMQMsg.TYPE_ADD_OR_UPDATE));
+ CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(series.getInfoID(), PPTVMQMsg.TYPE_ADD_OR_UPDATE));
}
break;
@@ -214,12 +223,21 @@
for (String id : infoIds) {
//澶勭悊鍒犻櫎鐨勫墽闆嗕俊鎭�
-// CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(id, PPTVMQMsg.TYPE_DELETE));
+ CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(id, PPTVMQMsg.TYPE_DELETE));
}
}
+ @Override
+ public PPTVSeries getSeriesDetailByVideoId(String videoId) {
+ VideoPPTVMap map = videoPPTVMapDao.get(videoId);
+ if (map == null) {
+ return null;
+ }
+ return getSeriesDetail(map.getInfoId());
+ }
+
/**
* 鍒犻櫎鍓ч泦
*
--
Gitblit v1.8.0