package com.hxh.spring.test; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStreamReader; import com.yeshi.buwan.domain.AcFunTemporary; import com.yeshi.buwan.job.JuHeVideoUpdateJob; import com.yeshi.buwan.service.imp.AcFunTemporaryService; import com.yeshi.buwan.util.BeanUtil; import com.yeshi.buwan.util.StringUtil; import com.yeshi.buwan.util.video.AcfunApiUtil; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.test.context.web.WebAppConfiguration; import javax.annotation.Resource; @RunWith(SpringJUnit4ClassRunner.class) //使用junit4进行测试 @ContextConfiguration(locations = {"classpath:spring.xml"}) @WebAppConfiguration public class AcfunTest { @Resource private JuHeVideoUpdateJob juHeVideoUpdateJob; @org.junit.Test public void test1() { } @org.junit.Test public void test2() { AcFunTemporaryService acFunTemporaryService = BeanUtil.getBean(AcFunTemporaryService.class); InputStreamReader isr = null; try { isr = new InputStreamReader( new FileInputStream(new File("C:/Users/Administrator/Desktop/动态分类/myprint.log")), "UTF-8"); BufferedReader br = new BufferedReader(isr); String lineTxt = null; while ((lineTxt = br.readLine()) != null) { if (!StringUtil.isNullOrEmpty(lineTxt)) { StringBuffer buffer = new StringBuffer(lineTxt); int p = buffer.indexOf("[INFO]"); AcFunTemporary act = new AcFunTemporary(); act.setJson(buffer.substring(p + 6).trim()); act.setIsConsume(false); act.setErrorCount(0); acFunTemporaryService.save(act); } } br.close(); } catch (Exception e) { e.printStackTrace(); } } @Test public void getVideoList() { AcfunApiUtil.videoList(""); } }