From f788607ff771a47bc60d6a86e00b3433c40f3d2c Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期五, 24 九月 2021 15:22:03 +0800 Subject: [PATCH] 接入视频直播 --- src/main/java/com/yeshi/buwan/service/imp/search/SearchSpecialServiceImpl.java | 17 +++++++++++++++-- 1 files changed, 15 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/yeshi/buwan/service/imp/search/SearchSpecialServiceImpl.java b/src/main/java/com/yeshi/buwan/service/imp/search/SearchSpecialServiceImpl.java index 4206ef8..ac6e2c6 100644 --- a/src/main/java/com/yeshi/buwan/service/imp/search/SearchSpecialServiceImpl.java +++ b/src/main/java/com/yeshi/buwan/service/imp/search/SearchSpecialServiceImpl.java @@ -4,6 +4,8 @@ import com.yeshi.buwan.domain.special.SearchSpecial; import com.yeshi.buwan.service.inter.search.SearchSpecialService; import com.yeshi.buwan.util.StringUtil; +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; @@ -45,6 +47,17 @@ } @Override + public List<SearchSpecial> listByIds(List<String> ids) { + Query query = new Query(); + Criteria[] ors = new Criteria[ids.size()]; + for (int i = 0; i < ids.size(); i++) { + ors[i] = Criteria.where("_id").is(ids.get(i)); + } + query.addCriteria(new Criteria().orOperator(ors)); + return searchSpecialDao.findList(query); + } + + @Override public long countSpecial(String key, String systemId) { SearchSpecialDao.DaoQuery daoQuery = new SearchSpecialDao.DaoQuery(); daoQuery.regexName = key; @@ -53,7 +66,7 @@ } @Override - public void update(SearchSpecial special) { + public void updateSelective(SearchSpecial special) { if (special.getUpdateTime() == null) { special.setUpdateTime(new Date()); } @@ -66,7 +79,7 @@ throw new Exception("鍙傛暟涓嶅畬鏁�"); } - if (special.getAlbumQuery() == null && special.getInternetQuery() == null && special.getShortQuery() == null) { + if (special.getContainerList() == null || special.getContainerList().size() == 0) { throw new Exception("鎼滅储鏉′欢涓嶈兘閮戒负绌�"); } -- Gitblit v1.8.0