package com.yihu.ehr.service.thread;

import com.yihu.ehr.common.config.ThreadConfig;
import com.yihu.ehr.service.crawler.CrawlerManager;
import com.yihu.ehr.service.standard.StandardManager;
import com.yihu.ehr.util.log.LogUtil;

public class CrawlerSupplyThread implements Runnable {

    @Override
    public void run() {
        while (ThreadManage.crawlerSupplyIsRunning) {
            try {
                LogUtil.info("补采线程开始");
                CrawlerManager.getInstance().dataCrawlerSupply();
                LogUtil.info("补采线程结束");
                sleep();
            } catch (InterruptedException e) {
                LogUtil.error("休眠中断！");
                LogUtil.error(e);
                continue;
            } catch (Exception e) {
                LogUtil.error("补采线程失败，将重启启动线程！");
                LogUtil.error(e);
                try {
                    sleep();
                } catch (Exception e1) {
                    continue;
                }
                continue;
            }
        }
    }


    private void sleep() throws Exception {
        LogUtil.info("开始睡眠,睡眠时间:" + 1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
        Thread.sleep(1000 * ThreadConfig.CRAWLER_SUPPLY_THREAD_SLEEP_TIME);
    }
}