8d73e917
陈威
初始化提交
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
import com.hotent.assembly.Application;
import com.hotent.lpg.dao.QpBaseInfoDao;
import com.hotent.lpg.manager.QpxxSyncService;
import com.hotent.lpg.model.QpBaseInfo;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = Application.class)
@Transactional
public class SyncQpxxTest {
public static final String URL = "https://qp.cnjifen.cn/a.ashx?d=%s";
@Autowired
private QpxxSyncService qpxxSyncService;
@Autowired
private QpBaseInfoDao qpBaseInfoDao;
@Test
public void syncQpxx() throws Exception {
for (long i = 4101287641L; i < 4999999999L; i++) {
String url = String.format(URL, i);
Thread.sleep(500);
List<QpBaseInfo> qpBaseInfo = qpxxSyncService.getQpBaseInfo(url);
for (QpBaseInfo baseInfo : qpBaseInfo) {
qpBaseInfoDao.insert(baseInfo);
}
}
}
}
|