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

package com.zskk.config;

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.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 OracleDialect());
		me.add(arpConnected);
		
		ActiveRecordPlugin arpLocal = new ActiveRecordPlugin("local", druidPluginLocal);
		arpLocal.setDialect(new MysqlDialect());
		me.add(arpLocal);
		
//		Cron4jPlugin cpData = new Cron4jPlugin();
//		cpData.addTask("*/5 * * * *", new DataTask());
//		me.add(cpData);
		
		Cron4jPlugin inData = new Cron4jPlugin();
		inData.addTask("5 2 * * *", new UpdateTask());
		me.add(inData);
//		
//		Cron4jPlugin cgData = new Cron4jPlugin();
//		cgData.addTask("50 1 * * *", new CFindTask());
//		me.add(cgData);
//		
		Cron4jPlugin mvData = new Cron4jPlugin();
		mvData.addTask("*/1 * * * *", new CMoveTask());
		me.add(mvData);
	}

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

}