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);
            }
        }
    }
}