From e50b781374b27479c9027585cec745f4121e9b78 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 01 四月 2021 19:12:41 +0800
Subject: [PATCH] PPTV兼容，热启动开屏控制
---
src/main/java/com/yeshi/buwan/service/imp/juhe/PPTVServiceImpl.java | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 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 75f68e2..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;
@@ -223,12 +225,12 @@
CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(series.getInfoID(), PPTVMQMsg.TYPE_ADD_OR_UPDATE));
}
- System.out.println("addorupdate:"+series.getName());
+ System.out.println("addorupdate:" + series.getName());
break;
//鍒犻櫎
case "del":
- System.out.println("delete:"+series.getName());
+ System.out.println("delete:" + series.getName());
deleteSeries(series);
infoIds.add(series.getInfoID());
break;
@@ -281,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);
+ }
+
/**
* 鍒犻櫎鍓ч泦
*
--
Gitblit v1.8.0