package foundation.system;

import java.io.File;
import java.io.FileOutputStream;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Set;

import org.apache.commons.io.FileUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.action.ActionProvider;
import foundation.dao.DataPackage;
import foundation.dao.Filter;
import foundation.dao.OrderBy;
import foundation.data.entity.Entity;
import foundation.data.entity.EntityNode;
import foundation.data.entity.EntitySet;
import foundation.data.entity.EntityTree;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.json.JArrayReader;
import foundation.json.JSONBuilder;
import foundation.json.JSONReader;
import foundation.json.JType;
import foundation.monitor.Progressor;
import foundation.org.AccountMeta;
import foundation.org.AccountMeta.Level;
import foundation.org.Org;
import foundation.org.Position;
import foundation.org.PositionMeta;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.server.config.Configer;
import foundation.user.OnlineUser;
import foundation.user.User;
import foundation.util.ID;
import foundation.util.Util;

public class OrgHandler extends ActionProvider {

	protected static Logger logger;
	
	static {
		logger = LogManager.getLogger(OrgHandler.class); 
	}

	@Override
	protected void publishMethod() {
		//1. 
		addMethod("activeAccountFlag");
		
		//2. 创建临时账户
		addMethod("createTempAccount");
		
		//3. 创建标准账户
		addMethod("createStandardAccount");
		
		//4. 获取管理员账户
		addMethod("getAdminAccount");
		
		//5. 冻结公司
		addMethod("freeze");
		
		//6. 解冻公司
		addMethod("unfreeze");
		
		//7. 创建公司默认内容（仓库等）
		addMethod("createDefaultWorks");	
		
		//8. 创建岗位权限冗余表
		addMethod("createPositionSpeedTable");
		
		//9. 根据导入的数据更新销售架构
		addMethod("saveSaleFrameworkByImport");
		
		//10.同步OA员工数据
		addMethod("syncEmployee");
		
		//11.更新销售数据权限
		addMethod("updateRightActorTarget");
		
		//12.角色分配用户
		addMethod("assignEmployee");

	}	
	
	public void activeAccountFlag() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		String orgId = dataPackage.getMasterId();
				
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createTempAccount error: org ({})not exists", orgId);
			return;
		}
		
		org.activeAccountFlag();
	}

	public void createTempAccount() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		Entity entity = dataPackage.getMasterEntity();
		String orgId = entity.getString("account_org_id");
				
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createTempAccount error: org ({})not exists", orgId);
			return;
		}
		
		AccountMeta accountMeta = AccountMeta.getCustomerInstance(Level.Temp, entity);
		User user = org.createAccount(accountMeta);
		
		dataWriter.addValue("user", user);
	}

	public void createStandardAccount() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		Entity entity = dataPackage.getMasterEntity();
		String orgId = entity.getString("org_id");
		
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createStandardAccount error: org ({})not exists", orgId);
			return;
		}
		
		AccountMeta accountMeta = AccountMeta.getCustomerInstance(Level.Standard, entity);
		User user = org.createAccount(accountMeta);
		
		dataWriter.addValue("user", user);
	}

	public void getAdminAccount() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		String orgId = dataPackage.getMasterId();
		
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createTempAccount error: org ({})not exists", orgId);
			return;
		}
		
		User user = org.getAdminUser();		
		dataWriter.addValue("user", user);
	}

	public void freeze() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		String orgId = dataPackage.getMasterId();
		
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createTempAccount error: org ({})not exists", orgId);
			return;
		}
		
		org.freeze();
	}

	public void unfreeze() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		String orgId = dataPackage.getMasterId();
		
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createTempAccount error: org ({})not exists", orgId);
			return;
		}
		
		org.unfreeze();
	}
	
	public void createDefaultWorks() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		Entity entity = dataPackage.getMasterEntity();
		String orgId = entity.getString("org_id");
		String accountId = entity.getString("id");
		String buName = entity.getString("bu_name");
		String buId = entity.getString("bu_id");
		String companyId = entity.getString("company_id");
		
		Org org = Org.getInstance(orgId);
		
		if (org == null) {
			logger.error("createDefaultWorks error: org ({})not exists", orgId);
			return;
		}
		
		org.getCreateAccountDefaultWorks(accountId, buId, companyId, buName);		
	}
	
	public void createPositionSpeedTable() throws Exception {
		String positionTable = "md_position";
		String positionEmployeeTable = "md_position_employee";
		String positionHierarchyTable = "md_position_hierarchy";
		
		if (dataReader != null) {
			String dataName = dataReader.getString("dataname");
			String preFlag = "version_preparatory_";
			
			if (dataName != null && dataName.startsWith(preFlag)) {
				positionTable = preFlag + positionTable;
				positionEmployeeTable = preFlag + positionEmployeeTable;
				positionHierarchyTable = preFlag + positionHierarchyTable;
			}
		}
		//1.
		DataObject hierarchyObject = DataObject.getInstance(positionHierarchyTable);
		EntitySet hierarchySet = hierarchyObject.createTableEntitySet();
		
		//2.
		DataObject positionObject = DataObject.getInstance(positionTable);
		Filter filter = new Filter("category_code", "Sales");
		EntityTree tree = positionObject.getTableEntityTree(filter, new OrderBy("bu_id, parent_id"));
	
		//3. 清空 speed 表，并进行计算
		hierarchyObject.emptyTable();
		
		String positionPath = null;
		createHierarchys(positionObject, tree.getRootSet(), positionPath, hierarchySet);
		
		//4. 批量插入 speed 表
		hierarchyObject.insertEntitySet(hierarchySet);
		
		//5. 刷新  speed 表 employee 字段
		NamedSQL namedSQL = NamedSQL.getInstance("updatePositionSpeedEmployee");
		namedSQL.setParam("positionHierarchyTable", positionHierarchyTable);
		namedSQL.setParam("positionEmployeeTable", positionEmployeeTable);
		namedSQL.execute();
	}
	
	private void createHierarchys(DataObject positionObject, EntitySet entitySet, String parentPath, EntitySet hierarchySet) throws Exception {
		for (Entity entity: entitySet) {
			EntityNode node = (EntityNode)entity;
			String positionPath = parentPath == null ? entity.getString("name") : parentPath + ">>" + entity.getString("name");
			createOneHierarchyLine(positionObject, node, positionPath, hierarchySet);
			
			EntitySet children = node.getChildren();
			
			if (children != null) {
				createHierarchys(positionObject, children, positionPath, hierarchySet);
			}
		}
	}

	private void createOneHierarchyLine(DataObject positionObject, EntityNode node, String positionPath, EntitySet hierarchySet) throws Exception {
		//1.  插入 speed 表
		int level = node.getLevel() + 1;
		String id = node.getString("id");
		
		Entity entity = hierarchySet.append();
		entity.set("position_id", id);
		entity.set("position_path", positionPath);
		entity.set("level" + level, id);
		
		EntityNode parent = node, region = null;
		for (int i = level; i >=1; i--) {
			parent = parent.getParent();
			
			if (parent == null) {
				break;
			}
			
			if ((i - 1) == 2) {
				region = parent;
			}
			
			entity.set("level" + (i - 1), parent.getString("id"));
		}
		
		//2. 
		EntitySaver saver = positionObject.createEntitySaver(id);
		saver.set("level_no", level);
		
		if (region != null) {
			saver.set("region", region.getValue("name"));
		}
		
		saver.update();
	}

	public void saveSaleFrameworkByImport() throws Exception {
		//1. 获取导入批号
		String batchNo = dataReader.getString("batchNo");
		
		if (Util.isEmpty(batchNo)) {
			dataWriter.reportOneError("销售架构批量导入", "缺少批量导入数据参数batchNo");
			return;		
		}
		
		//2. 根据导入数据刷新销售架构、员工、用户、冗余表
		Progressor progressor = new Progressor();
		
		SQLRunner.beginTrans();
		try {
			//1. 保存当前架构到文件
			savePositionToFile(batchNo, progressor);
			
			//2. 添加没有的岗位,  删除不存在的岗位
			updatePositionOnUpload(batchNo, progressor);
			
			//3. 添加没有的员工, 失效离职的员工
			updateEmployeeOnUpload(batchNo, progressor);
			
			//4. 根据岗位刷新岗位员工关系及冗余表
			updatePositionEmployeeOnUpload(batchNo, progressor);
			
			//6.更新岗位数据权限
			updateRightActorTarget();
			
			//7. 根据员工刷新目标医院辖区关系
			refreshHospitalTerritory(batchNo, progressor);
			
			//8. 根据岗位刷新架构上下级冗余表
			createPositionSpeedTable();
			
			SQLRunner.commit();
		} 
		catch(Exception e) {
			 SQLRunner.rollback();
			 dataWriter.reportOneError("销售架构批量导入", "数据保存失败");
			 e.printStackTrace();
		}
		
		progressor.endTask();
	}
	
	public void updateRightActorTarget() throws Exception {
		logger.info("更新岗位数据权限");
		NamedSQL namedSQL; int cnt;
		
		//1. 删除失效岗位的数据权限
		namedSQL = NamedSQL.getInstance("deleteNotExistsRightActorTarget");
		cnt = namedSQL.execute();		
		logger.info("删除不存在的岗位数据权限 ：" + cnt);
		
		//2. 添加没有数据权限的生效岗位
		DataObject dataObject = DataObject.getInstance("sys_right_actor_target");
		namedSQL = NamedSQL.getInstance("getNewRightActorTarget");
		EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
		String duty, actorCode;
		
		cnt = 0;
		for (Entity entity: entitySet) {
			duty = entity.getString("duty");
			PositionMeta positionMeta = new PositionMeta(duty);
			actorCode = positionMeta.getActorCode();
			entity.set("actor_id", actorCode);
			entity.set("id", ID.newValue());
			cnt = cnt + dataObject.insertEntity(entity);
		}
		
		logger.info("添加新的岗位数据权限：" + cnt);		
	}

	private void savePositionToFile(String batchNo, Progressor progressor) throws Exception {
		progressor.newPhase("bak_currentData", "备份当前数据");
		
		//1. 获取当前岗位列表
		DataObject dataObject = DataObject.getInstance("md_position");
		EntitySet entitySet = dataObject.getTableEntitySet();
		
		//2. 创建文件
		String root = Configer.getParam("PathRepository") + "/hierarchy/";
		
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM");
        String datePath = dateFormat.format(new Date());
        File path = new File(root, datePath);
        
        if (!path.exists()) {
        	FileUtils.forceMkdir(path);
        }
        
        File target = new File(path, batchNo + ".json");
		if (target.exists()) {
			target.delete();
		}
		
		target.createNewFile();
		progressor.appendLine("创建备份文件：" + target.toString());
		
		//3. 保存到JSON
		JSONBuilder content = new JSONBuilder();
				
		content.beginArray();
		for (Entity entity: entitySet) {
			content.beginObject();
			entity.writeJSONBody(content);
			content.endObject();
		}
		content.endArray();
		
		progressor.appendLine("写入数据：" + entitySet.size() + "行");
		
		//4. 保存到文件
        FileOutputStream output = new FileOutputStream(target);
        try {
        	output.write(content.getBytes());
        	progressor.appendLine("写入完毕");
        } 
        catch (Exception e) {
            e.printStackTrace();
        }
        finally{
            try {
            	output.close();
            } catch (Exception e) {
            }
        }
        
        progressor.endPhase();
	}

	private void updatePositionOnUpload(String batchNo, Progressor progressor) throws Exception {
		progressor.newPhase("更新岗位");
		NamedSQL namedSQL; int cnt;

		//1. 删除没有的岗位（根据岗位编码）
		namedSQL = NamedSQL.getInstance("deleteNotExistsSalesPosition");
		namedSQL.setParam("batchNo", batchNo);	
		cnt = namedSQL.execute();
		progressor.appendLine("删除原有岗位：" + cnt);
		
		//2. 更新替换存在的岗位（根据岗位编码）
		namedSQL = NamedSQL.getInstance("updatePositionSalesPosition");
		namedSQL.setParam("batchNo", batchNo);
		namedSQL.execute();
		progressor.appendLine("更新原有岗位：" + cnt);
		
		//3. 添加新的岗位（根据岗位编码）
		namedSQL = NamedSQL.getInstance("appendNewSalesPosition");
		namedSQL.setParam("batchNo", batchNo);
		cnt = namedSQL.execute();
		progressor.appendLine("添加新增岗位：" + cnt);
		
		progressor.endPhase();
	}

	private void updateEmployeeOnUpload(String batchNo, Progressor progressor) throws Exception {
		progressor.newPhase("更新员工");
		NamedSQL namedSQL; int cnt;
		OnlineUser user = OnlineUser.getInstance();
		
		//1. 添加没有的员工
		namedSQL = NamedSQL.getInstance("appendNewSalesEmployee");
		namedSQL.setParam("creatorId",user.getCode());
		namedSQL.setParam("creatorName",user.getName());
		namedSQL.setParam("batchNo", batchNo);	
		cnt = namedSQL.execute();		
		progressor.appendLine("添加新员工（销售）：" + cnt);
		
		//2. 刷新员工表 -- 岗位冗余字段
		updateEmployeeOtherInfo(progressor);

		//3. 失效离职的员工
		namedSQL = NamedSQL.getInstance("inactiveNotExistsSalesEmployee");
		namedSQL.setParam("batchNo", batchNo);	
		cnt = namedSQL.execute();
		progressor.appendLine("离职员工（销售）：" + cnt);
		
		progressor.endPhase();
	}
	
	private void updatePositionEmployeeOnUpload(String batchNo, Progressor progressor) throws Exception {
		progressor.newPhase("更新岗位员工关系");
		NamedSQL namedSQL; int cnt;
		
		//1. 删除不存在的岗位-员工关系
		namedSQL = NamedSQL.getInstance("deleteNotExistsPositionEmployee");
		namedSQL.setParam("batchNo", batchNo);
		cnt = namedSQL.execute();		
		progressor.appendLine("删除不存在的岗位-员工关系：" + cnt);
		
		//2. 更新岗位-员工关系
		namedSQL = NamedSQL.getInstance("updatePositionEmployee");
		namedSQL.setParam("batchNo", batchNo);
		cnt = namedSQL.execute();		
		progressor.appendLine("更新岗位-员工关系：" + cnt);
		
		//3.  新增岗位-员工关系
		namedSQL = NamedSQL.getInstance("appendPositionEmployee");
		namedSQL.setParam("batchNo", batchNo);
		cnt = namedSQL.execute();		
		progressor.appendLine("新增岗位-员工关系：" + cnt);		
		
		progressor.endPhase();
	}
	
	private void updateEmployeeUser(Progressor progressor) throws Exception {
		progressor.newPhase("更新用户");
		NamedSQL namedSQL; int cnt;
		
		//1. 删除离职员工的用户
		namedSQL = NamedSQL.getInstance("inValidNotExistsEmployeeUser");
		cnt = namedSQL.execute();		
		progressor.appendLine("更新不存在的用户（员工）为失效：" + cnt);
		
		//2. 删除离职员工的用户
		namedSQL = NamedSQL.getInstance("validExistsEmployeeUser");
		cnt = namedSQL.execute();		
		progressor.appendLine("激活生效的员工：" + cnt);
				
		//3. 添加没有的员工用户（与岗位有关联的员工）
		namedSQL = NamedSQL.getInstance("appendNewEmployeeUser");
		cnt = namedSQL.execute();		
		progressor.appendLine("添加新的用户（员工）：" + cnt);		
		
		//4. 添加员工与公司关系
		namedSQL = NamedSQL.getInstance("appendNewUserOrg");
		cnt = namedSQL.execute();		
		progressor.appendLine("添加新的用户（员工）- 公司关系：" + cnt);		
	}

	private void refreshHospitalTerritory(String batchNo,Progressor progressor) throws Exception {
		progressor.newPhase("更新辖区医院 ");
		NamedSQL namedSQL; int cnt;
		
		namedSQL = NamedSQL.getInstance("refreshHospitalPosition");
		namedSQL.setParam("batchNo", batchNo);
		cnt = namedSQL.execute();
		progressor.appendLine("更新辖区医院 关系 ：" + cnt);
	}
	
	public void createHierarchys(DataObject positionObject, EntitySet entitySet, String parentPath, EntitySet hierarchySet, Set<String> positionIdSet, NamedSQL levelSQL) throws Exception {
		for (Entity entity: entitySet) {
			EntityNode node = (EntityNode)entity;
			String positionPath = parentPath == null ? entity.getString("name") : parentPath + ">>" + entity.getString("name");
			createOneHierarchyLine(positionObject, node, positionPath, hierarchySet, positionIdSet, levelSQL);
			
			EntitySet children = node.getChildren();
			
			if (children != null) {
				createHierarchys(positionObject, children, positionPath, hierarchySet, positionIdSet, levelSQL);
			}
		}
	}

	public void createOneHierarchyLine(DataObject positionObject, EntityNode node, String positionPath, EntitySet hierarchySet, Set<String> positionIdSet, NamedSQL levelSQL) throws Exception {
		//1.  插入 speed 表
		int level = node.getLevel() + 1;
		String id = node.getString("id");
		
		Entity entity = hierarchySet.append();
		entity.set("position_id", id);
		entity.set("position_path", positionPath);
		entity.set("level" + level, id);
		
		EntityNode parent = node;
		for (int i = level; i >=1; i--) {
			parent = parent.getParent();
			
			if (parent == null) {
				break;
			}
			
			entity.set("level" + (i - 1), parent.getString("id"));
		}
		
		//2. 
		if (positionIdSet.contains(id)) {
			return;
		}
		
		levelSQL.setParam("id", id);
		levelSQL.setParam("level_no", level);
		levelSQL.execute();
		
		positionIdSet.add(id);
	}
	
	private void updateEmployeeOtherInfo(Progressor progressor) throws Exception {
		progressor.newPhase("更新用户OA以及NC信息");
		NamedSQL namedSQL; int cnt;
		
		namedSQL = NamedSQL.getInstance("updateEmployeeInfoOA");
		cnt = namedSQL.execute();		
		progressor.appendLine("更新用户OA信息：" + cnt);
		
		namedSQL = NamedSQL.getInstance("updateEmployeeInfoNC");
		cnt = namedSQL.execute();		
		progressor.appendLine("更新用户NC信息：" + cnt);
		
//		namedSQL = NamedSQL.getInstance("UpdateEmployeeInvalid");
//		cnt = namedSQL.execute();		
//		progressor.appendLine("失效不在OA中的员工：" + cnt);
	}
	
	public void syncEmployee() throws Exception{
		Progressor progressor = new Progressor();	
		SQLRunner.beginTrans();
		try {
			
			boolean existMismatching = true;
			
			progressor.newPhase("更新员工");
			NamedSQL namedSQL; int cnt;
			
			//1. 添加没有的员工
			namedSQL = NamedSQL.getInstance("appendNewEmployee");
			cnt = namedSQL.execute();		
			progressor.appendLine("添加新员工：" + cnt);
			
			progressor.endPhase();
			
			//2. 刷新员工表 -- 岗位冗余字段
			updateEmployeeOtherInfo(progressor);
			
			//3.获取未匹配上NC的员工
			namedSQL = NamedSQL.getInstance("queryEmployeeMatchNCError");
			EntitySet entitySet = namedSQL.getEntitySet();
			if(entitySet == null || entitySet.isEmpty()) {
				existMismatching = false;
			}
			dataWriter.addValue("existMismatching",existMismatching);
			dataWriter.addValue("ncError",entitySet);
			
			//4.新增用户
			updateEmployeeUser(progressor);
			
			SQLRunner.commit();
			
			
		} catch(Exception e) {
			 SQLRunner.rollback();
			 dataWriter.reportOneError("result", "同步OA员工数据");
			 e.printStackTrace();
		}
	}

	public void assignEmployee() throws Exception{
		String buId = dataReader.getString("bu_id");
		String companyId = dataReader.getString("company_id");
		String actorId = dataReader.getString("actor_id");
		String actorName = dataReader.getString("actor_name");
		JArrayReader employeeList = dataReader.getReader("employees", JType.Array);
		
		DataObject dataObject = DataObject.getInstance("sys_right_actor_target");

		Filter filter = new Filter("actor_id", actorId);
		
		if (!Util.isEmpty(companyId)) {
			filter.add("company_id", companyId);
		}
		
		if (!Util.isEmpty(buId)) {
			filter.add("bu_id", buId);
		}
		
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
		
		if (entitySet.isEmpty()) {
			entitySet = Position.createPostion(companyId, buId, actorId, actorName);
		}

		dataObject = DataObject.getInstance("md_position_employee");
		EntitySaver saver;
		String employeeId, positionId;
		
		
		for (Entity entity : entitySet) {
			positionId = entity.getString("target_id");
			
			for (JSONReader employee : employeeList) {
				employeeId = employee.getString("id");
				
				Filter existsFilter = new Filter();
				existsFilter.add("bu_id", buId);
				existsFilter.add("company_id", companyId);
				existsFilter.add("position_id", positionId);
				existsFilter.add("employee_id", employeeId);
				
				int count = dataObject.getCount((existsFilter));
				
				if (count > 0) {
					continue;
				}
			
				saver = dataObject.createEntitySaver();
				saver.set("bu_id", buId);
				saver.set("company_id", companyId);
				saver.set("position_id", positionId);
				saver.set("employee_id", employeeId);
				saver.set("remark", employee.getString("name"));
				
				saver.insert();
			}
		}
		
	}

}