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/PPTVServiceImpl.java | 32 +++++++++++++++++++++++++-------
1 files changed, 25 insertions(+), 7 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 8dfeec4..4354cd5 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
@@ -25,6 +25,8 @@
import com.yeshi.buwan.service.imp.VideoTypeService;
import com.yeshi.buwan.service.inter.juhe.PPTVService;
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.stereotype.Service;
import javax.annotation.Resource;
@@ -68,9 +70,11 @@
VideoInfo newVideoInfo = PPTVUtil.convertToVideoInfo(series);
if (newVideoInfo == null)
return;
-// if (newVideoInfo.getVideoType() != null) {
-// newVideoInfo.setVideoType(videoTypeService.getVideoType(newVideoInfo.getVideoType().getId()));
-// }
+
+ VideoType videoType = videoTypeService.getVideoType(newVideoInfo.getVideoType().getId());
+ if (videoType.getParent() != null)
+ newVideoInfo.setVideoType(videoType.getParent());
+
VideoPPTVMap videoPPTV = videoPPTVMapDao.selectByInfoId(series.getInfoID());
if (videoPPTV != null) {//娓犻亾瑙嗛宸茬粡瀛樺湪
VideoInfo videoInfo = videoInfoService.getVideoInfo(videoPPTV.getVideoId() + "");
@@ -142,7 +146,7 @@
//娣诲姞瑙嗛鏉ユ簮鏄犲皠
resourceVideoService.addVideoResource(newVideoInfo.getId(), PPTVUtil.RESOURCE_ID + "");
//娣诲姞瑙嗛鍒嗙被鏄犲皠
- categoryVideoService.addCategoryVideo(newVideoInfo.getId(), newVideoInfo.getVideoType().getId());
+ categoryVideoService.addCategoryVideo(newVideoInfo.getId(), videoType.getId());
CMQManager.getInstance().addSolrMsg(newVideoInfo.getId());
}
@@ -195,7 +199,11 @@
@Override
public void save(List<PPTVSeries> seriesList) {
for (PPTVSeries series : seriesList) {
- save(series);
+ try {
+ save(series);
+ } catch (Exception e) {
+
+ }
}
}
@@ -217,9 +225,12 @@
CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(series.getInfoID(), PPTVMQMsg.TYPE_ADD_OR_UPDATE));
}
+ System.out.println("addorupdate:" + series.getName());
+
break;
//鍒犻櫎
case "del":
+ System.out.println("delete:" + series.getName());
deleteSeries(series);
infoIds.add(series.getInfoID());
break;
@@ -272,6 +283,13 @@
return videoPPTVMapDao.selectByInfoId(infoId);
}
+ @Override
+ public PPTVSeries selectSeriesBySeriesCode(String cid) {
+ Query query = new Query();
+ query.addCriteria(new Criteria().where("seriesCode").is(cid));
+ return pptvSeriesDao.findOne(query);
+ }
+
/**
* 鍒犻櫎鍓ч泦
*
@@ -281,7 +299,7 @@
PPTVQuery query = new PPTVQuery();
query.seriesCode = series.getSeriesCode();
Set<String> seriesCodeSet = deleteMap(query);
- pptvSeriesDao.delete(series.getInfoID());
+ pptvSeriesDao.deleteByPrimaryKey(series.getInfoID());
}
@@ -320,7 +338,7 @@
PPTVQuery query = new PPTVQuery();
query.programCode = program.getProgramCode();
Set<String> infoIdSet = deleteMap(query);
- pptvProgramDao.delete(program.getProgramCode());
+ pptvProgramDao.deleteByPrimaryKey(program.getProgramCode());
return infoIdSet;
}
--
Gitblit v1.8.0