package foundation.system;

import java.sql.SQLException;
import java.util.Date;
import java.util.List;
import java.util.Set;

import foundation.action.ActionProvider;
import foundation.dao.Domain;
import foundation.dao.Filter;
import foundation.data.entity.Entity;
import foundation.data.meta.DataMetaCenter;
import foundation.data.object.DataObject;
import foundation.data.object.DataObjectContainer;
import foundation.data.object.EntitySaver;
import foundation.data.object.Sequence;
import foundation.json.JArrayReader;
import foundation.json.JSONReader;
import foundation.json.JType;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.user.OnlineUser;
import foundation.util.ID;
import foundation.util.Util;
import foundation.variant.provider.VariantCenter;

public class SystemHandler extends ActionProvider {

	@Override
	protected void publishMethod() {
		//1. 
		addMethod("getVariantListeners");
		
		//2. 得到下一个变量的值
		addMethod("getOneVariantValue");
		
		//3. 重新加载配置
		addMethod("reload");
		
		//4. 同步字段配置（所有对象）
		addMethod("synchronizFields");
		
		//4. 同步属性配置（所有对象）
		addMethod("synchronizPropertys");
		
		//4. 同步字段+属性配置
		addMethod("synchronizOneObjectMeta");
		
		//4. 同步字段配置
		addMethod("synchronizOneObjectFields");
		
		//4. 同步属性配置
		addMethod("synchronizOneObjectPropertys");
		
		//5. 得到数据源配置
		addMethod("getDataSourceList");
		
		//6. 获取数据对象
		addMethod("getDataObjectList");
		
		//7. 得到指定sequence的当前值
		addMethod("getSequence");
		
		//8. 修改表字符集
		addMethod("alterTablesCharset");
		
		//9. 保存角色菜单
		addMethod("saveRoleMenus");
		
		//10. 保存角色菜单的button、tab
		addMethod("saveBtnAndTab");
		
		//11. 操作数据权限明细配置
		addMethod("operateSightLine");
		
		//12. 计算过期
		addMethod("refreshExpire");
		
		//13. 重新加载角色
		addMethod("reloadRole");
		
		//13. 重新加载角色页面
		addMethod("reloadRolePage");
	}

	public void alterTablesCharset() throws Exception {
	    List<String> tables = SQLRunner.getTableList();
	  
	    NamedSQL namedSQL = NamedSQL.getInstance("alterTableCharset");
	  
	    for (String table: tables) {
	         namedSQL.setTableName(table);
	         namedSQL.execute();
	    }
	}	
	
	public void getVariantListeners() throws Exception {
		VariantCenter variantCenter = VariantCenter.getInstance();
		dataWriter.addValue("variantListeners", variantCenter);
	}

	public void getOneVariantValue() throws Exception {
		OnlineUser user = OnlineUser.getInstance();
		
		String variantName = dataReader.getString(ISystem.VariantName);
		Object value = VariantCenter.getValue(null, variantName, user);
		
		dataWriter.addValue(value);
	}
	
	public void reload() throws Exception {
		
	}
	
	public void synchronizMetas() throws Exception {
		String tablePrefix = dataReader.getString("prefix");
		DataMetaCenter.synchronizMetas(tablePrefix);
	}
	
	public void synchronizFields() throws Exception {
		String tablePrefix = dataReader.getString("prefix");
		DataMetaCenter.synchronizFields(tablePrefix, null, null);
	}
	
	public void synchronizPropertys() throws Exception {
		String tablePrefix = dataReader.getString("prefix");
		DataMetaCenter.synchronizPropertys(tablePrefix, null, null);
	}
	
	public void synchronizOneObjectMeta() throws Exception {
		String dataName = dataReader.getString("dataName");
		Set<String> includeFields = dataReader.getStringSet("includeFields");
		
		if (Util.isEmpty(dataName)) {
			return;
		}
		
		DataObject dataObject = DataObject.getInstance(dataName);
		DataMetaCenter.synchronizOneObjectMeta(dataObject, includeFields, null);
	}
	
	public void synchronizOneObjectFields() throws Exception {
		String dataName = dataReader.getString("dataName");
		Set<String> includeFields = dataReader.getStringSet("includeFields");
		
		if (Util.isEmpty(dataName)) {
			return;
		}
		
		DataObject dataObject = DataObject.getInstance(dataName);
		DataMetaCenter.synchronizOneObjectFields(dataObject, includeFields, null);
	}
	
	public void synchronizOneObjectPropertys() throws Exception {
		String dataName = dataReader.getString("dataName");
		Set<String> includeFields = dataReader.getStringSet("includeFields");
		
		if (Util.isEmpty(dataName)) {
			return;
		}
		
		DataObject dataObject = DataObject.getInstance(dataName);
		DataMetaCenter.synchronizOneObjectPropertys(dataObject, includeFields, null);
	}
	
	public void getDataSourceList() throws Exception {
		
	}
	
	public void getDataObjectList() throws Exception {
		DataObjectContainer objectContainer = DataObjectContainer.getInstance();
		dataWriter.addValue(objectContainer);
	}
	
	public void getSequence() throws Exception {
		String dataName = dataReader.getString("dataName");
		DataObject dataObject = DataObject.getInstance(dataName);
		
		if (dataObject == null) {
			return;
		}
		
		String tableName = dataObject.getTableName();
		Sequence sequence = new Sequence(tableName);
		long result = sequence.current();
		
		dataWriter.addValue("sequence", result);
	}
	
	public void saveRoleMenus() throws Exception{
		//1.获取接口传过来的值
		String dataName = dataReader.getString("dataName");
		String roleId = dataReader.getString("roleId");
		JArrayReader menusList = dataReader.getReader("menus", JType.Array);
		
		//2.创建连接
		DataObject dataObject = null;
		Filter filter = null;
		
		SQLRunner.beginTrans();
		try {
			 //3.删除(角色菜单表)sys_role_page
			 dataObject = DataObject.getInstance(dataName);
			 filter = new Filter();
			 filter.add("role_id", roleId);
			 dataObject.deleteEntitySet(filter);
			
			 //4.将menus列表中的菜单插入
			for (JSONReader menu : menusList) {
				  dataObject = DataObject.getInstance(dataName);
				  
				  EntitySaver saver = dataObject.createEntitySaver();
				  saver.set("id", ID.newValue());
				  saver.set("role_id", roleId);
				  saver.set("page_id", menu.getString("pageId"));
				  saver.set("menu_id", menu.getString("menuId"));
				  saver.set("remark", menu.getString("remark"));
				  saver.set("is_active", "T");
				  saver.insert();
			 }
			 
			 SQLRunner.commit();
		} 
		catch(Exception e) {
			 e.printStackTrace();
			 try {
				 SQLRunner.rollback();
			} catch (SQLException e1) {
				 e1.printStackTrace();
			}
		}
		
		SystemLoader.reloadRole(roleId, null);
	}

	public void saveBtnAndTab() throws Exception{
		//1.获取接口传过来的值
		String roleId = dataReader.getString("roleId");
		String roleCode = dataReader.getString("roleCode");
		String pageId = dataReader.getString("pageId");
		String menuId = dataReader.getString("menuId");

		JArrayReader buttons = dataReader.getReader("buttons", JType.Array);
		List<String> tabs = dataReader.getStringList("tabs");
		
		SQLRunner.beginTrans();
		try {
			 //3.保存角色页面按钮(sys_role_page_button)
			 saveButton(roleId, roleCode, menuId, pageId, buttons);
			 
			 //4.保存角色页面Tab(sys_role_page_tab)
			 saveTab(roleId, roleCode, menuId, pageId, tabs);
			 
			 SQLRunner.commit();
		} 
		catch(Exception e) {
			 e.printStackTrace();
			 try {
				  SQLRunner.rollback();
			} catch (SQLException e1) {
			}
		}
	}	
	
	public void refreshExpire() throws Exception {
		Domain domain = dataReader.getDomain();
		String dataName = domain.getDataName();
		
		if (Util.isEmpty(domain)) {
			return;
		}
		
		
		DataObject dataObject = DataObject.getInstance("sys_expire");
		Entity entity = dataObject.getTableEntity(new Filter("data_name", dataName));
		
		if (entity == null || !entity.getBoolean("is_active", true)) {
			return;
		}
		
		String field_expire_tag = entity.getString("field_expire_tag", "is_expire");
		String field_date_to = entity.getString("field_date_to", "date_to");
				
		NamedSQL namedSQL = NamedSQL.getInstance("refreshExpire");
		namedSQL.setTableName(dataName);
		namedSQL.setParam("expire_tag", field_expire_tag);
		namedSQL.setParam("date_to", field_date_to);
		namedSQL.setParam("now", new Date());
		
		int cnt = namedSQL.execute();
		dataWriter.addValue(cnt);
	}

	public void reloadRole() throws Exception {
		String roleId = dataReader.getString("role_id");
		SystemLoader.reloadRole(roleId, null);
	}

	public void reloadRolePage() throws Exception {
		String roleId = dataReader.getString("role_id");
		String pageId = dataReader.getString("page_id");
		SystemLoader.reloadRole(roleId, pageId);
	}
	
	public void saveTab(String roleId, String roleCode, String menuId, String pageId, List<String> tabs) throws Exception {
		DataObject dataObject = null;
		Filter filter = null;
		Entity entity = null;
		
		if (tabs == null || tabs.isEmpty()) {
			return;
		}		

		dataObject = DataObject.getInstance("sys_right_role_page_tab");
		filter = new Filter();
		filter.add("role_id", roleId);
		filter.add("page_id", pageId);
		filter.add("menu_id", menuId);
		dataObject.deleteEntitySet(filter);
		
		//1.将buttons列表中的菜单插入
		for (String tabId : tabs) {
			 //1.1 保存(角色菜单表)sys_role_page
			 dataObject = DataObject.getInstance("sys_right_role_page_tab");
			 entity = dataObject.createTableEntity(true);
			 entity.set("id", ID.newValue());
			 entity.set("role_id", roleId);
			 entity.set("role_code", roleCode);
			 entity.set("menu_id", menuId);
			 entity.set("page_id", pageId);
			 entity.set("tab_id", tabId);
			 entity.set("is_visible", "T");
			 entity.set("is_active", "T");
			 
			 dataObject.insertEntity(entity);
	   }
	}
	
	public void saveButton(String roleId, String roleCode, String menuId, String pageId, JArrayReader buttons) throws Exception {
		DataObject dataObject = null;
		Filter filter = null;
		Entity entity = null;

		if (buttons == null || buttons.isEmpty()) {
			return;
		}		
		
		dataObject = DataObject.getInstance("sys_right_role_page_button");
		filter = new Filter();
		filter.add("role_id", roleId);
		filter.add("page_id", pageId);
		filter.add("menu_id", menuId);
		dataObject.deleteEntitySet(filter);
		
		//1.将buttons列表中的菜单插入
		for (JSONReader button : buttons) {
			 //1.1 保存(角色菜单表)sys_role_page
			 dataObject = DataObject.getInstance("sys_right_role_page_button");
			 entity = dataObject.createTableEntity(true);
			 entity.set("id", ID.newValue());
			 entity.set("role_id", roleId);
			 entity.set("role_code", roleCode);
			 entity.set("page_id", pageId);
			 entity.set("menu_id", menuId);
			 entity.set("tab_id", button.getString("tab_id"));
			 entity.set("button_id", button.getString("button_id"));
			 entity.set("is_visible", "T");
			 entity.set("is_active", "T");
			  
			 dataObject.insertEntity(entity);		
	   }
	}
}