data_fusion/DataFusion/src/com/zskk/config/ZskkConfig.java

package com.zskk.config;

import com.alibaba.fastjson.parser.ParserConfig;
import com.jfinal.config.Constants;
import com.jfinal.config.Handlers;
import com.jfinal.config.Interceptors;
import com.jfinal.config.JFinalConfig;
import com.jfinal.config.Plugins;
import com.jfinal.config.Routes;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
import com.jfinal.plugin.activerecord.dialect.OracleDialect;
import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
import com.jfinal.plugin.cron4j.Cron4jPlugin;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.template.Engine;
import com.zskk.control.ViewController;
import com.zskk.service.ServiceFactory;
import com.zskk.task.CFindTask;
import com.zskk.task.CMoveTask;
import com.zskk.task.DataTask;
import com.zskk.task.InfoTask;
import com.zskk.task.ReCMoveTask;
import com.zskk.task.ReviewTask;
import com.zskk.task.UpdateTask;

public class ZskkConfig extends JFinalConfig {

	// 本地开发模式
	private boolean isLocalDev = false;
	/**
	 * 如果生产环境配置文件存在，则优先加载该配置，否则加载开发环境配置文件
	 * 
	 * @param pro 生产环境配置文件
	 * @param dev 开发环境配置文件
	 */
	public void loadProp(String pro, String dev) {
		try {
			PropKit.use(pro);
		} catch (Exception e) {
			PropKit.use(dev);
			isLocalDev = true;
		}
	}

	public void configConstant(Constants me) {
		loadProp("config.properties", "a_little_config.txt");
		me.setDevMode(PropKit.getBoolean("devMode", false));
	}

	@Override
	public void configRoute(Routes me) {
		// TODO Auto-generated method stub
		me.add("/view", ViewController.class);
		me.add("/", ViewController.class,"");
	}

	@Override
	public void configEngine(Engine me) {
		// TODO Auto-generated method stub

	}

	public static DruidPlugin createConnectedDruidPlugin() {

		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),PropKit.get("password_connected").trim());
	}
	
	public static DruidPlugin createLocalDruidPlugin() {

		return new DruidPlugin(PropKit.get("jdbcUrl_local"), PropKit.get("user_local"),PropKit.get("password_local").trim());
	}

	@Override
	public void configPlugin(Plugins me) {
		// 配置数据库连接池插件
		DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
		me.add(druidPluginConnected);
		
		DruidPlugin druidPluginLocal = createLocalDruidPlugin();
		me.add(druidPluginLocal);

		// 配置ActiveRecord插件
		ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
		arpConnected.setDialect(new SqlServerDialect());
		me.add(arpConnected);
		
		ActiveRecordPlugin arpLocal = new ActiveRecordPlugin("local", druidPluginLocal);
		arpLocal.setDialect(new MysqlDialect());
		me.add(arpLocal);
		
		ParserConfig.getGlobalInstance().setAutoTypeSupport(false);
		
		//同步报告
		Cron4jPlugin cpData = new Cron4jPlugin();
		cpData.addTask("*/4 * * * *", new DataTask());
		me.add(cpData);
		
		//将cfind请求检查录入待检查库
		Cron4jPlugin inData = new Cron4jPlugin();
		inData.addTask("*/4 * * * *", new UpdateTask());
		me.add(inData);
		
		//执行cfind请求
		Cron4jPlugin cgData = new Cron4jPlugin();
		cgData.addTask("*/2 * * * *", new CFindTask());
		me.add(cgData);
		
		//comve获取检查影像
		Cron4jPlugin mvData = new Cron4jPlugin();
		mvData.addTask("*/1 * * * *", new CMoveTask());
		me.add(mvData);
		
		//更新患者信息检查影像
		Cron4jPlugin ifData = new Cron4jPlugin();
		ifData.addTask("*/1 * * * *", new InfoTask());
		me.add(ifData);
		
		// comve获取检查影像
		Cron4jPlugin rcData = new Cron4jPlugin();
		rcData.addTask("*/20 * * * *", new ReCMoveTask());
		me.add(rcData);
		
		// 重新匹配审核后的报告
		Cron4jPlugin rrData = new Cron4jPlugin();
		rrData.addTask("*/7 * * * *", new ReviewTask());
		me.add(rrData);
	}

	@Override
	public void configInterceptor(Interceptors me) {
		// TODO Auto-generated method stub

	}

	@Override
	public void configHandler(Handlers me) {
		// TODO Auto-generated method stub

	}
	
	@Override
	public void onStart() {
		// TODO Auto-generated method stub
		super.onStart();
		ServiceFactory.init();
	}
	
//	public static void main(String[] args) {
//		JFinal.start("WebRoot", 10002, "/", 5);
//	}

}