From e89de9319d8f771f8e53cb5f876d06465a580c57 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期一, 02 八月 2021 18:23:22 +0800 Subject: [PATCH] kafka日志集成 --- src/test/java/com/hxh/spring/test/SolrTest.java | 17 ++++++++++++----- 1 files changed, 12 insertions(+), 5 deletions(-) diff --git a/src/test/java/com/hxh/spring/test/SolrTest.java b/src/test/java/com/hxh/spring/test/SolrTest.java index 33d3665..24e7f8c 100644 --- a/src/test/java/com/hxh/spring/test/SolrTest.java +++ b/src/test/java/com/hxh/spring/test/SolrTest.java @@ -8,14 +8,12 @@ import com.yeshi.buwan.domain.video.InternetSearchVideo; import com.yeshi.buwan.dto.search.SolrResultDTO; import com.yeshi.buwan.dto.search.SolrVideoSearchFilter; -import com.yeshi.buwan.pptv.PPTVUtil; import com.yeshi.buwan.service.imp.VideoInfoService; import com.yeshi.buwan.service.inter.juhe.AlbumVideoMapService; import com.yeshi.buwan.service.inter.juhe.InternetSearchVideoService; -import com.yeshi.buwan.service.manager.SolrAlbumVideoDataManager; +import com.yeshi.buwan.service.manager.search.SolrAlbumVideoDataManager; import com.yeshi.buwan.service.manager.SolrCommonVideoDataManager; -import com.yeshi.buwan.service.manager.SolrInternetSearchVideoDataManager; -import com.yeshi.buwan.util.Constant; +import com.yeshi.buwan.service.manager.search.SolrInternetSearchVideoDataManager; import com.yeshi.buwan.util.StringUtil; import com.yeshi.buwan.util.factory.VideoInfoFactory; import com.yeshi.buwan.util.video.VideoConstant; @@ -161,10 +159,19 @@ @Test public void addInternet() { - InternetSearchVideo list = internetSearchVideoService.selectByPrimaryKey("59fafccefd20505b0aade6d9ba0e8ed1"); //listAll(1, 10); + InternetSearchVideo list = internetSearchVideoService.selectByPrimaryKey("38ac0127d0cc3433e09964e757ab3505"); //listAll(1, 10); solrInternetSearchVideoDataManager.saveOrUpdate(list); } + @Test + public void deleteInternet() { + String st="161469b4aa35ca7ae1cc5d3ddaa23276,3b57b603b4eef496ce0de50f06ca40c0"; + + + for (String id : st.split(",")) + solrInternetSearchVideoDataManager.deleteById(id); + } + @Resource private AlbumVideoMapDao albumVideoMapDao; -- Gitblit v1.8.0