| | |
| | | package com.hxh.spring.test; |
| | | |
| | | import com.yeshi.buwan.dao.HomeNoticeDao; |
| | | import com.yeshi.buwan.domain.HomeNotice; |
| | | import com.yeshi.buwan.domain.SolrVideo; |
| | | import com.yeshi.buwan.domain.VideoInfo; |
| | | import com.yeshi.buwan.dao.video.AlbumVideoMapDao; |
| | | import com.yeshi.buwan.domain.video.AlbumVideoMap; |
| | | import com.yeshi.buwan.dto.search.SolrResultDTO; |
| | | import com.yeshi.buwan.dto.search.SolrVideoSearchFilter; |
| | | import com.yeshi.buwan.iqiyi.util.IqiyiUtil; |
| | | import com.yeshi.buwan.service.imp.VideoInfoService; |
| | | import com.yeshi.buwan.service.manager.SolrAlbumDataManager; |
| | | import org.apache.http.auth.Credentials; |
| | | import org.apache.solr.client.solrj.SolrClient; |
| | | import org.apache.solr.client.solrj.SolrRequest; |
| | | import org.apache.solr.client.solrj.SolrServerException; |
| | | import org.apache.solr.common.util.NamedList; |
| | | import com.yeshi.buwan.service.inter.juhe.AlbumVideoMapService; |
| | | import com.yeshi.buwan.service.manager.SolrAlbumVideoDataManager; |
| | | import com.yeshi.buwan.service.manager.SolrCommonVideoDataManager; |
| | | import org.junit.Test; |
| | | import org.junit.runner.RunWith; |
| | | import org.springframework.data.solr.server.support.HttpSolrClientFactory; |
| | | import org.springframework.data.solr.server.support.HttpSolrClientFactoryBean; |
| | | import org.springframework.data.mongodb.core.query.Criteria; |
| | | import org.springframework.data.mongodb.core.query.Query; |
| | | import org.springframework.test.context.ContextConfiguration; |
| | | import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; |
| | | import org.springframework.test.context.web.WebAppConfiguration; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.io.IOException; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | |
| | |
| | | public class SolrTest { |
| | | |
| | | @Resource |
| | | private SolrAlbumDataManager solrDataManager; |
| | | private SolrAlbumVideoDataManager solrDataManager; |
| | | |
| | | @Resource |
| | | private SolrCommonVideoDataManager solrCommonVideoDataManager; |
| | | |
| | | @Resource |
| | | private VideoInfoService videoInfoService; |
| | | |
| | | @Resource |
| | | private HomeNoticeDao homeNoticeDao; |
| | | @Resource |
| | | private AlbumVideoMapService albumVideoMapService; |
| | | |
| | | @Test |
| | | public void test1() { |
| | |
| | | |
| | | @Test |
| | | public void addSolrAlbum() { |
| | | solrDataManager.syncAlbum("8224447"); |
| | | SolrClient solrClient=new SolrClient() { |
| | | @Override |
| | | public NamedList<Object> request(SolrRequest solrRequest, String s) throws SolrServerException, IOException { |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | | public void close() throws IOException { |
| | | |
| | | } |
| | | }; |
| | | Credentials credentials=new Credentials(); |
| | | HttpSolrClientFactory factory=new HttpSolrClientFactory(); |
| | | |
| | | solrDataManager.syncAllAlbum(); |
| | | System.out.println(); |
| | | } |
| | | |
| | | |
| | | @Test |
| | | public void syncSolrCommonVideo() { |
| | | // solrCommonVideoDataManager.syncAllVideo(); |
| | | } |
| | | |
| | | |
| | | @Resource |
| | | private AlbumVideoMapDao albumVideoMapDao; |
| | | |
| | | @Test |
| | | public void test2() { |
| | | |
| | | for(int i=0;i<100;i++) { |
| | | Query query = new Query(); |
| | | query.addCriteria(Criteria.where("id").type(7)); |
| | | query.limit(100); |
| | | List<AlbumVideoMap> list = albumVideoMapDao.findList(query); |
| | | |
| | | |
| | | for (AlbumVideoMap map : list) { |
| | | AlbumVideoMap newMap = new AlbumVideoMap(); |
| | | newMap.setVideoCount(map.getVideoCount()); |
| | | newMap.setRootVideoType(map.getRootVideoType()); |
| | | newMap.setVideoId(map.getVideoId()); |
| | | newMap.setCreateTime(new Date()); |
| | | newMap.setId(map.getVideoId()); |
| | | albumVideoMapDao.save(newMap); |
| | | albumVideoMapDao.deleteByPrimaryKey(map.getId()); |
| | | } |
| | | try { |
| | | Thread.sleep(1000); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | } |