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.SqlServerDialect;
import com.jfinal.plugin.cron4j.Cron4jPlugin;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.template.Engine;
import com.zskk.service.ServiceFactory;
import com.zskk.control.ViewController;
import com.zskk.model._MappingKit;
import com.zskk.task.DataTask;

public class ZskkConfig extends JFinalConfig {
	
	@Override
	public void afterJFinalStart() {
		super.afterJFinalStart();
		ServiceFactory.init();
	}

	@Override
	public void configConstant(Constants me) {
		// 加载少量必要配置，随后可用PropKit.get(...)获取值
		PropKit.use("config.properties");
		me.setDevMode(PropKit.getBoolean("devMode", false));
	}

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

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

	}

	public static DruidPlugin createZskkDruidPlugin() {

		return new DruidPlugin(PropKit.get("jdbcUrl_zskk"), PropKit.get("user_zskk"),PropKit.get("password_zskk").trim());
	}

	public static DruidPlugin createConnectedDruidPlugin() {

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

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

		// 配置ActiveRecord插件
		ActiveRecordPlugin arpZskk = new ActiveRecordPlugin("zskk", druidPluginZskk);
		arpZskk.setDialect(new MysqlDialect());

		 //所有映射在 MappingKit 中自动化搞定
		_MappingKit.mapping(arpZskk);
		me.add(arpZskk);

		// 配置数据库连接池插件
		DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
		me.add(druidPluginConnected);

		// 配置ActiveRecord插件
		ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
		arpConnected.setDialect(new SqlServerDialect());
		me.add(arpConnected);

		Cron4jPlugin cpData = new Cron4jPlugin();
		cpData.addTask("*/20 * * * *", new DataTask());
		me.add(cpData);

//		Cron4jPlugin cp2 = new Cron4jPlugin();
//		cp2.addTask("*/3 * * * *", new SyncTask2());
//	me.add(cp2);
	}

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

	}

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

	}

}