package foundation.system;

import foundation.capacity.Actor;
import foundation.capacity.ActorBucket;
import foundation.capacity.Capacity;
import foundation.capacity.CapacityBucket;
import foundation.capacity.role.Role;
import foundation.capacity.role.RoleAgent;
import foundation.capacity.role.RoleBucket;
import foundation.capacity.sight.LineLimit;
import foundation.capacity.sight.Sight;
import foundation.capacity.sight.SightAgent;
import foundation.capacity.sight.SightBucket;
import foundation.capacity.sight.SightLineLimitManager;
import foundation.dao.Filter;
import foundation.dao.LineLimitManager;
import foundation.dao.OrderBy;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.entity.IDictionary;
import foundation.data.object.DataObject;
import foundation.dictionary.Dictionary;
import foundation.dictionary.DictionaryBucket;
import foundation.dictionary.DictionaryItem;
import foundation.geography.City;
import foundation.geography.CityBucket;
import foundation.geography.Province;
import foundation.geography.ProvinceBucket;
import foundation.log.ILogWriter;
import foundation.menu.Menu;
import foundation.menu.MenuTree;
import foundation.page.Button;
import foundation.page.Page;
import foundation.page.PageBucket;
import foundation.page.Tab;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.server.Initializer;
import foundation.state.approve.StepsCreator;
import foundation.token.IUserManager;
import foundation.user.UserManager;
import foundation.util.Util;


public class SystemLoader extends Initializer {

	@Override
	public void startUp() throws Exception {
		//1. 注册系统组件
		registerComponets();
		
		//2. 加载资源
		loadResources();
		
		//3. 加载权限
		loadCapacities();
	}

	private void registerComponets() {
		//1. 注册日志 Handler
		LogHandler handler = new LogHandler();
		ILogWriter.register(handler);
		
		//2. 注册用户管理器
		UserManager userManager = UserManager.getInstance();
		IUserManager.registerManager(userManager);

		//3. 注册数据权限管理器
		SightLineLimitManager sightLineLimitManager = new SightLineLimitManager();
		LineLimitManager.registLimitManager(sightLineLimitManager);	
		
		//4. 注册销售架构审批步骤 Creator
		HierarchyStepsCreator stepsCreator = HierarchyStepsCreator.getInstance();
		StepsCreator.registerSalesHierarchyStepsCreator(stepsCreator);
	}

	private void loadResources() throws Exception {
		LoadMonitor monitor = new LoadMonitor();
		
		boolean success = monitor.lock();
		
		if (!success) {
			return;
		}
		
		try {
			//1. page
			loadPage(monitor);
			
			//2. menu	
			loadMenu(monitor);
			
			//3. dictionary
			loadDictionary(monitor);
			
			//4. geography
			loadGeography(monitor);
			
			//5. active
			monitor.activate();
		}
		finally {
			monitor.release();
		}		
	}

	public void loadCapacities() throws Exception {
		LoadMonitor monitor = new LoadMonitor();
		
		boolean success = monitor.lock();
		
		if (!success) {
			return;
		}
		
		try {
			//1. actor
			loadActor(monitor);
			
			//2. role
			loadRole(monitor);
			
			//3. sight
			loadSight(monitor);
			
			//4. capacity
			loadCapacity(monitor);
			
			//5. actor-capacity
			loadActorCapacity(monitor);
			
			//6. active
			monitor.activate();
		}
		finally {
			monitor.release();
		}
	}
	
	protected void loadPage(LoadMonitor monitor) throws Exception {
		DataObject dataObject; 
		EntitySet entitySet;
		
		//1. register or get bucket
		PageBucket pageBucket = monitor.register(PageBucket.class);
		
		//2. load page
		dataObject = DataObject.getInstance("sys_page");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			Page page = new Page();
			page.load(entity);
			
			pageBucket.loadOne(page.getId(), page);
		}
		
		//3. load tab
		dataObject = DataObject.getInstance("sys_page_tab");
		entitySet = dataObject.getTableEntitySet(new OrderBy("page_id"));
		
		for (Entity entity: entitySet) {
			 String pageId = entity.getString("page_id");
			
			 Tab tab = new Tab();
			 tab.load(entity);
			 
			 Page page = pageBucket.getCachedOne(pageId);
			 page.loadOneTab(tab);
		}
		
		//4. load button
		dataObject = DataObject.getInstance("sys_page_button");
		entitySet = dataObject.getTableEntitySet(new OrderBy("page_id, index_no"));
		for (Entity entity: entitySet) {
			 String pageId = entity.getString("page_id");
			 Button button = new Button();
			 button.load(entity);
			 Page page = pageBucket.getCachedOne(pageId);
			 page.loadOneButton(button);
		}
	}
	
	protected void loadMenu(LoadMonitor monitor) throws Exception {
		//1. register or get bucket
		MenuTree menuTree = monitor.register(MenuTree.class);
		
		//2. load menu
		NamedSQL namedSQL = NamedSQL.getInstance("getMenu");
		EntitySet entitySet = namedSQL.getEntitySet();
		
		for (Entity entity: entitySet) {
			Menu menu = new Menu();
			menu.load(entity);
			menuTree.loadOne(menu.getId(), menu);
		}
		
		menuTree.onAfterLoad();
	}
	
	protected void loadDictionary(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		DictionaryBucket dictionaryBucket = DictionaryBucket.newInstance();
		
		//1. 加载字典
		dataObject = DataObject.getInstance("sys_dictionary");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			Dictionary dictionary = new Dictionary();
			dictionary.load(entity);
			
			dictionaryBucket.loadOne(dictionary);
		}
		
		//2. 加载字典项（保存在 sys_dictionary_detail 中 的字典项）
		dataObject = DataObject.getInstance("sys_dictionary_detail");
		entitySet = dataObject.getTableEntitySet(new OrderBy("parent_id"));
		
		for (Entity entity: entitySet) {
			String parentId = entity.getString("parent_id");
			Dictionary dictionary = dictionaryBucket.getCachedOne(parentId);
			
			if (dictionary == null) {
				continue;
			}
			
			DictionaryItem item = new DictionaryItem();
			item.load(entity);
			
			dictionary.loadOne(item);
		}
		
		//3. 加载字典项（保存在其他表中的字典项）
		for (IDictionary iDictionary: dictionaryBucket) {
			Dictionary dictionary = (Dictionary)iDictionary;
			
			String dataName = dictionary.getDataName();
			
			if (Util.isEmpty(dataName)) {
				continue;
			}
			
			DataObject itemObject = DataObject.getInstance(dataName);
			EntitySet itemSet = itemObject.getTableEntitySet();
			
			for (Entity entity: itemSet) {
				DictionaryItem item = new DictionaryItem();
				item.load(entity, dictionary.getFieldCode(), dictionary.getFieldName());
				
				dictionary.loadOne(item);
			}
		}
		
		dictionaryBucket.activate();
	}

	protected void loadGeography(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		
		//1. register or get bucket
		ProvinceBucket provinceBucket = monitor.register(ProvinceBucket.class);
		CityBucket cityBucket = monitor.register(CityBucket.class);
		
		//1. load dictionary bucket
		dataObject = DataObject.getInstance("md_geo_province");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			Province province = new Province();
			province.load(entity);
			
			provinceBucket.loadOne(province.getId(), province);
		}
		
		//2. load dictionary item
		dataObject = DataObject.getInstance("md_geo_city");
		entitySet = dataObject.getTableEntitySet(new OrderBy("province_id"));
		
		for (Entity entity: entitySet) {
			String parentId = entity.getString("province_id");
			Province province = provinceBucket.getCachedOne(parentId);
			
			if (province == null) {
				continue;
			}
			
			City city = new City();
			city.load(entity);
			
			province.loadOneCity(city);
			cityBucket.loadOne(city.getId(), city);
		}		
	}
	
	private void loadActor(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		ActorBucket actorBucket = monitor.register(ActorBucket.class);
		
		//1. 加载角色 
		dataObject = DataObject.getInstance("sys_right_actor");
		entitySet = dataObject.getTableEntitySet();
		
		Actor actor; 
		for (Entity entity: entitySet) {
			actor = new Actor();
			actor.load(entity);
			actorBucket.loadOne(actor.getId(), actor); 
		}
	}
	
	public static void reloadRole(String roleId, String pageId) throws Exception {
		RoleBucket roleBucket = RoleBucket.getInstance();
		RoleAgent roleAgent = roleBucket.get(roleId);
		
		if (roleAgent == null) {
			return;
		}
		
		if (!Util.isEmpty(pageId)) {
			PageBucket pageBucket = PageBucket.getInstance();
			Page page = pageBucket.get(pageId);
			//0. load page tab
			loadPageTab(page);
			
			//0.1. load page button
			loadPageButton(page);				
		}
		
		//1. 新建一个新的role
		Role result = roleAgent.newTarget();
		
		//2. load role page
		loadRolePages(null, result, PageBucket.getInstance());
		
		//3. 加载 role tabs
		loadRoleTabs(null, result);
		
		//4. 加载 role buttons
		loadRoleButtons(null, result);
		
		//5. 加载 role menus
		loadOneRoleMenus(result, MenuTree.getInstance());
		
		//6. 替换原来在role
		roleAgent.set(result);
		roleAgent.onAfterLoadMenuTree();
	}
	
	public static void reloadSight(String sightId) throws Exception {
		SightBucket sightBucket = SightBucket.getInstance();
		SightAgent sightAgent = sightBucket.get(sightId);
		
		if (sightAgent == null) {
			return;
		}
		
		//1. 新建一个新的 sight
		Sight result = sightAgent.newTarget();
		loadSightLineLimits(null, result);
		
		//2. 替换原来在 sight
		sightAgent.set(result);
	}
	
	protected void loadRole(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		
		//1. register or get bucket
		RoleBucket roleBucket = monitor.register(RoleBucket.class);
		PageBucket pageBucket = monitor.get(PageBucket.class);
		MenuTree menuTree = monitor.get(MenuTree.class);
		
		//2. load role
		dataObject = DataObject.getInstance("sys_right_role");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			RoleAgent role = new RoleAgent();
			role.load(entity);
			roleBucket.loadOne(role.getId(), role);
		}

		//3. load role page
		loadRolePages(roleBucket, null, pageBucket);
		
		//4. load role tabs
		loadRoleTabs(roleBucket, null);
		
		//5. load role buttons
		loadRoleButtons(roleBucket, null);
		
		//6. load role menus
		loadAllRoleMenus(roleBucket, menuTree);
		
		//7. initialize tree
		for (RoleAgent role: roleBucket) {
			role.onAfterLoadMenuTree();
		}
	}
	
	private static void loadPageTab(Page page) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_page_tab");
		String filter = (page == null) ? "1=1" : "page_id=" + Util.quotedStr(page.getId());
		EntitySet entitySet = dataObject.getTableEntitySet(new Filter(filter), new OrderBy("page_id"));
		
		for (Entity entity: entitySet) {
			 Tab tab = new Tab();
			 tab.load(entity);
			 
			 page.loadOneTab(tab);
		}		
	}
	
	private static void loadPageButton(Page page) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_page_button");
		String filter = (page == null) ? "1=1" : "page_id=" + Util.quotedStr(page.getId());
		EntitySet entitySet = dataObject.getTableEntitySet(new Filter(filter), new OrderBy("page_id, index_no"));
		
		for (Entity entity: entitySet) {
			 Button button = new Button();
			 button.load(entity);

			 page.loadOneButton(button);
		}		
	}	
	
	private static void loadRolePages(RoleBucket roleBucket, Role role, PageBucket pageBucket) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_right_role_menu");
		String filter = (role == null) ? "1=1" : "role_id=" + Util.quotedStr(role.getId());
		EntitySet entitySet = dataObject.getTableEntitySet(new Filter(filter), new OrderBy("role_id"));
		
		String roleId, pageId, menuId;
		
		for (Entity entity: entitySet) {
			roleId = entity.getString("role_id");
			pageId = entity.getString("page_id");
			menuId = entity.getString("menu_id");
			
			  if (roleBucket != null) {
				 RoleAgent agent = roleBucket.getCachedOne(roleId);
			 	  if (agent == null) {
			 		  continue;
			 	  }
				 role = agent.get();
			 }
			 
			 if (role == null) {
				 logger.error("role not exists: {}", roleId);
				 continue;
			 }

			 Page page = pageBucket.getCachedOne(pageId);
			 role.loadOnePage(menuId, page);
		}
	}

	private static void loadRoleTabs(RoleBucket roleBucket, Role role) throws Exception {
		NamedSQL namedSQL = NamedSQL.getInstance("getRolePageTab");
		String filter = (role == null) ? "1=1" : "role_id=" + Util.quotedStr(role.getId());
		namedSQL.setFilter(filter);
		EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
		
		String roleId, pageId, tabId, menuId;
		
		for (Entity entity: entitySet) {
			 roleId = entity.getString("role_code");
			 pageId = entity.getString("page_id");
			 tabId = entity.getString("tab_id");
			 menuId = entity.getString("menu_id");
			  
			  if (roleBucket != null) {
				 RoleAgent agent = roleBucket.getCachedOne(roleId);
			 	  if (agent == null) {
			 		  continue;
			 	  }				 
				 role = agent.get();
			 }
			 
			 if (role == null) {
				 logger.error("role not exists: {}", roleId);
				 continue;
			 }
			 
			 role.loadOneTab(menuId, pageId, tabId);
		}
	}
	
	private static void loadRoleButtons(RoleBucket roleBucket, Role role) throws Exception {
		NamedSQL namedSQL = NamedSQL.getInstance("getRolePageButton");
		String filter = (role == null) ? "1=1" : "role_id=" + Util.quotedStr(role.getId());
		namedSQL.setFilter(filter);
		EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
		
		String roleId, pageId, button_id, menuId;
		
		for (Entity entity: entitySet) {
			 roleId = entity.getString("role_code");
			 pageId = entity.getString("page_id");
			 button_id = entity.getString("button_id");
			 menuId = entity.getString("menu_id");
			 
			  if (roleBucket != null) {
				 RoleAgent agent = roleBucket.getCachedOne(roleId);
			 	  if (agent == null) {
			 		  continue;
			 	  }				 
				 role = agent.get();
			 }
			 
			 if (role == null) {
				 logger.error("role not exists: {}", roleId);
				 continue;
			 }
			 
			 role.loadOneButton(menuId, pageId, button_id, entity);
		}		
	}

	private static void loadAllRoleMenus(RoleBucket roleBucket, MenuTree menuTree) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_right_role_menu");
		
		Filter filter = new Filter("is_active", "T");
		EntitySet entitySet = dataObject.getTableEntitySet(filter);

		//1. load menus
		String roleId, menuId; 
		Role role = null;
		
		for (Entity entity: entitySet) {
			roleId = entity.getString("role_id");
			menuId = entity.getString("menu_id");
			
			if (roleBucket != null) {
				RoleAgent agent = roleBucket.get(roleId);
				if (agent != null) {
					role = agent.get();
				}
				else {
					logger.error("load role menu error, role agent not exists: {}", roleId);
					continue;	
				}
			}
			
			Menu menu = menuTree.get(menuId); 
			role.loadOneMenu(menu);
		}
	}
	
	private static void loadOneRoleMenus(Role role, MenuTree menuTree) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_right_role_menu");
		Filter filter = new Filter("is_active", "T").add("role_id", role.getId());
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
        
		for (Entity entity: entitySet) {
			String menuId = entity.getString("menu_id");
			Menu menu = menuTree.get(menuId); 
			
			role.loadOneMenu(menu);
		}
	}
	
	protected void loadSight(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		
		//1. register or get bucket
		SightBucket sightBucket = monitor.register(SightBucket.class);
		
		//2. load free
		dataObject = DataObject.getInstance("sys_right_sight_free_table");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			 String tableName = entity.getString("table_name");
			 sightBucket.loadOneFreeTable(tableName);
		}
		
		//3. load sight
		dataObject = DataObject.getInstance("sys_right_sight");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			 SightAgent sight = new SightAgent();
			 sight.load(entity);
			 sightBucket.loadOne(sight.getId(), sight);
		}
		
		//4. load line limit
		loadSightLineLimits(sightBucket, null);
	}
	
	private static void loadSightLineLimits(SightBucket sightBucket, Sight sight) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_right_sight_line");
		String filter = (sight == null) ? "1=1" : "parent_id = " + Util.quotedStr(sight.getId());
		EntitySet entitySet = dataObject.getTableEntitySet(new Filter(filter), new OrderBy("parent_id"));
		
		for (Entity entity: entitySet) {
			String sightId = entity.getString("parent_id");
			
			if (sightBucket != null) {
				SightAgent agent = sightBucket.getCachedOne(sightId);
				if (agent == null) {
					continue;
				}
				sight = agent.get();
			}
  
			if (sight == null) {
				logger.error("role not exists: {}", sightId);
				continue;
			}
			  
			LineLimit lineLimit = new LineLimit();
			lineLimit.load(entity);
			sight.loadOneLimit(lineLimit);
		}		
	}

	protected void loadCapacity(LoadMonitor monitor) throws Exception {
		DataObject dataObject; EntitySet entitySet;
		
		//1. register or get bucket
		CapacityBucket capacityBucket = monitor.register(CapacityBucket.class);
		SightBucket sightBucket = monitor.get(SightBucket.class);
		RoleBucket roleBucket = monitor.get(RoleBucket.class);
		
		//2. load 
		dataObject = DataObject.getInstance("sys_right_capacity");
		entitySet = dataObject.getTableEntitySet();
		
		for (Entity entity: entitySet) {
			//2.1 capacity
			Capacity capacity = new Capacity();
			capacity.load(entity);
			capacityBucket.loadOne(capacity.getId(), capacity);
			
			//2.2 role
			String roleId = capacity.getRoleId();
			RoleAgent role = roleBucket.get(roleId);
			
			if (role == null) {
				logger.error("load capacity role error, role not exists: {}", roleId);
				continue;
			}
			
			capacity.setRole(role);
			
			//2.3 sight
			String sightId = capacity.getSightId();
			SightAgent sight = sightBucket.get(sightId);
			
			if (sight == null) {
				logger.error("load capacity sight error, sight not exists: {}", sightId);
				continue;
			}
			
			capacity.setSight(sight);
		}
	}
	
	private void loadActorCapacity(LoadMonitor monitor) throws Exception {
		CapacityBucket capacityBucket = monitor.get(CapacityBucket.class);
		ActorBucket actorBucket = monitor.get(ActorBucket.class);
		
		//1. 从数据库加载Capacity
		DataObject dataObject = DataObject.getInstance("sys_right_actor_capacity");
		EntitySet entitySet = dataObject.getTableEntitySet(new OrderBy("actor_id"));
		
		for (Entity entity: entitySet) {
			String actorId = entity.getString("actor_id");
			Actor actor = actorBucket.get(actorId);
			
			if (actor == null) {
				logger.error("load actor capacity error, actor not exists: {}", actorId);
				continue;
			}
			
			String capacityId = entity.getString("capacity_id");
			Capacity capacity = capacityBucket.get(capacityId);
			
			if (capacity == null) {
				logger.error("load actor capacity error, capacity not exists: {}", capacityId);
				continue;
			}

			capacity.setActorId(actorId);
			actor.loadOneCapacity(capacity);
		}
		
		//2. 合并每个角色的Capacity（一个角色可能有多个Capacity）
		for (Actor actor: actorBucket) {
			actor.buildCapacityRuntime();
		}
	}
	
	@Override
	public void shutDown() throws Exception {
		
	}	

}