eip_manage/Hos-Resource-Mini/src/main/java/com.yihu.ehr/service/thread/CrawlerThread.java

package com.yihu.ehr.service.thread;

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

public class CrawlerThread implements Runnable {

    DBHelper db = new DBHelper(Thread.currentThread().getName(), DBConfig.get("defaultUri"));

    @Override
    public void run() {
        while (ThreadManage.crawlerIsRunning) {
            try {
                LogUtil.info("采集线程开始");
                CrawlerManager.getInstance().dataCrawlerFrequency();
                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 {
        if (ThreadConfig.CRAWLER_THREAD_SLEEP_TIME == 0) {
            Object obj = db.scalar("select param_value from system_param where param_key='INTERVAL'");
            if(obj!=null) {
                ThreadConfig.CRAWLER_THREAD_SLEEP_TIME = Integer.parseInt(obj.toString());
            }
        }
        LogUtil.info("开始睡眠,睡眠时间:" + 1000 * ThreadConfig.CRAWLER_THREAD_SLEEP_TIME);
        Thread.sleep(1000 * ThreadConfig.CRAWLER_THREAD_SLEEP_TIME);
    }
}