ThisApplication.java 1.3 KB
Newer Older
R
roo00 已提交
1 2 3 4 5
package com.x.query.service.processing;

import org.apache.commons.lang3.BooleanUtils;

import com.x.base.core.project.Context;
Z
zhourui 已提交
6
import com.x.base.core.project.cache.CacheManager;
R
roo00 已提交
7 8 9 10 11 12 13
import com.x.base.core.project.config.Config;
import com.x.query.service.processing.schedule.CrawlCms;
import com.x.query.service.processing.schedule.CrawlWork;
import com.x.query.service.processing.schedule.CrawlWorkCompleted;

public class ThisApplication {

Z
zhourui 已提交
14 15 16 17
	private ThisApplication() {
		// nothing
	}

R
roo00 已提交
18 19 20 21 22 23 24 25
	protected static Context context;

	public static Context context() {
		return context;
	}

	public static void init() {
		try {
Z
zhourui 已提交
26
			CacheManager.init(context.clazz().getSimpleName());
R
roo00 已提交
27
			if (BooleanUtils.isTrue(Config.query().getCrawlWork().getEnable())) {
R
update  
roo00 已提交
28
				context.schedule(CrawlWork.class, Config.query().getCrawlWork().getCron());
R
roo00 已提交
29
			}
NoSubject's avatar
NoSubject 已提交
30
			if (BooleanUtils.isTrue(Config.query().getCrawlWorkCompleted().getEnable())) {
R
update  
roo00 已提交
31
				context.schedule(CrawlWorkCompleted.class, Config.query().getCrawlWorkCompleted().getCron());
R
roo00 已提交
32 33
			}
			if (BooleanUtils.isTrue(Config.query().getCrawlCms().getEnable())) {
R
update  
roo00 已提交
34
				context.schedule(CrawlCms.class, Config.query().getCrawlCms().getCron());
R
roo00 已提交
35 36 37 38 39 40 41 42
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void destroy() {
		try {
Z
zhourui 已提交
43
			CacheManager.shutdown();
R
roo00 已提交
44 45 46 47 48
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}