package foundation.state.approve;

import java.util.List;

import foundation.action.ActionContext;
import foundation.action.SingletonActionProvider;
import foundation.dao.DataPackage;
import foundation.dao.DataReader;
import foundation.dao.DataSource;
import foundation.dao.DataWriter;
import foundation.dao.Domain;
import foundation.dao.Filter;
import foundation.dao.OrderBy;
import foundation.dao.Page;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.entity.EntityTree;
import foundation.data.object.DataObject;
import foundation.json.JObjectReader;
import foundation.json.JType;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.state.MachineBucket;
import foundation.state.StateMachine;
import foundation.state.StateMachineLoader;
import foundation.token.IOnlineUser;
import foundation.util.ContentBuilder;
import foundation.util.Util;



public class ApproveCenter extends SingletonActionProvider {
	
	public static String Remark_Approve = "同意";
	public static String Remark_Deny = "不同意";

	private static ApproveCenter instance;

	
	private ApproveCenter() {
		
	}
	
	public static synchronized ApproveCenter getInstance() {
		if (instance == null) {
			instance = new ApproveCenter();
		}
		
		return instance;
	}
	
	@Override
	protected void publishMethod() {
		//1.1 获取审批流图数据
		addMethod("getOneApprove");
		
		//1.2 保存审批流图数据
		addMethod("saveOneApprove");
		
		//1.3 保存审批组
		addMethod("saveBoard");
		
		//1.4 删除审批组
		addMethod("deleteOneboard");

		//1.5 修改审批组人员
		addMethod("saveOneBoardUser");
		
		//1.6 修改审批组人员
		addMethod("deleteOneBoardUser");
		
		//2.1 审批中心--树
		addMethod("getOutline");
		
		//2.2 审批中心—待审列表
		addMethod("getDocumentList");
		
		//2.3 审批中心—已审列表
		addMethod("getDocumentHistory");
		
		//2.4 审批中心——某个单据的当前申请流
		addMethod("getAliveWorkflow");
		
		//2.5 审批中心——某个单据的已审列表
		addMethod("getWorkHistory");
		
		//2.6 审批中心—当前步骤
		addMethod("getWorkSetps");
		
		//2.7 审批中心—审批历史
		addMethod("getWorkHistory");
		
		//2.9 审批中心—单据审批人转移
		addMethod("transferWorkStepApprover");
	}

	public void getOneApprove(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		String approveId = dataReader.getString("id");
		ApproveTemplate approveTemplate = ApproveTemplate.getInstance(approveId);
		
		if (approveTemplate == null) {
			return;
		}
		
		dataWriter.addValue(approveTemplate);
	}
	
	public void saveOneApprove(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();

		ApproveTemplate newTemplate = new ApproveTemplate();
		JObjectReader reader = dataReader.getReader("data", JType.Object);
		newTemplate.load(reader);
		
		ApproveTemplate original = ApproveTemplate.getInstance(newTemplate.getId());
		
		//1. 如果是第一次保存，直接插入到数据库
		if (original == null) {
			newTemplate.insertToDB();
			dataWriter.addValue(newTemplate);
		}
		//2. 如果存在原始模版，合并后保存
		else {
			original.updateToDB(newTemplate);
			dataWriter.addValue(original);
		}
	}
	
	public void saveBoard(ActionContext context) throws Exception {
		DataPackage dataPackage = context.getDataPackage();
		dataPackage.saveOneDataToDB(DataSource.Request);

		String boardId = dataPackage.getMasterId();
		StateMachineLoader.reloadStepBoard(boardId);
	}
	
	public void deleteOneBoard(ActionContext context) throws Exception {
		DataWriter dataWriter = context.getDataWriter();
		DataPackage dataPackage = context.getDataPackage();
		String boardId = dataPackage.getMasterId();
		
		NamedSQL namedSQL = NamedSQL.getInstance("getApproverStepInUsing");
		namedSQL.setParam("boardId", boardId);
		EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
		
		if (entitySet.isEmpty()) {
			dataPackage.deleteOneDataFromDB();
			StateMachineLoader.reloadStepBoard(boardId);
			return;
		}
		ContentBuilder approveStep = new ContentBuilder(",");
		
		for (Entity entity: entitySet) {
			approveStep.append(entity.getString("name"));
		}
		
		dataWriter.reportOneError("checkBoardUsed", "当前审批组正在审批流：【" + approveStep.toString() + "】中使用，不允许删除。");
	}
	
	public void saveOneBoardUser(ActionContext context) throws Exception {
		DataPackage dataPackage = context.getDataPackage();
		dataPackage.saveOneDataToDB(DataSource.Request);
		
		dataPackage.loadOneDataFromDB();
		Entity entity = dataPackage.getMasterEntity();
		StepUser stepUser = new StepUser();
		stepUser.load(entity);
		
		String boardId = entity.getString("board_id");
		StepBoardBucket boardBucket = StepBoardBucket.getInstance();
		StepBoard board = boardBucket.get(boardId);
		board.loadOneUser(stepUser.getId(), stepUser);
		board.reWriterNames();
	}
	
	public void deleteOneBoardUser(ActionContext context) throws Exception {
		DataPackage dataPackage = context.getDataPackage();
		Entity entity = dataPackage.getMasterEntity();
		String boardId = entity.getString("board_id");
		StepBoardBucket boardBucket = StepBoardBucket.getInstance();
		StepBoard board = boardBucket.get(boardId);

		dataPackage.deleteOneDataFromDB();

		board.removeOneUser(entity.getId());
		board.reWriterNames();

	}
	
	public void getOutline(ActionContext context) throws Exception {
		DataWriter dataWriter = context.getDataWriter();
		
		NamedSQL namedSQL = NamedSQL.getInstance("getOutline"); 
		IOnlineUser user = IOnlineUser.getInstance();
		
		if (user.isAdmin()) {
			namedSQL.setParam("user_limit", "1=1");
		}
		else {
			namedSQL.setParam("user_limit", "sys_state_working_user.user_id = " + Util.quotedStr(user.getId()));
		}
		
		namedSQL.setOrderBy(new OrderBy("parent_id"));
		EntityTree entityTree = SQLRunner.getEntityTree(namedSQL);
		dataWriter.addValue("data", entityTree);
	}
	
	public void getDocumentList(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		Domain domain = dataReader.getDomain();
		String dataName = domain.getDataName();
		
    	StateMachine machine = MachineBucket.getMachineByDataName(dataName);
    	if (machine == null) {
			return;
    	}
    	
		DataObject dataObject = DataObject.getInstance(dataName);
		
		//1. 从请求中获取Page和OrderBy
		Page page = new Page(); 
		OrderBy orderBy = new OrderBy();
		dataReader.loadPageOrderByFromJSON(dataObject, page, orderBy);
		
		if (orderBy.isEmpty()) {
			orderBy.add("update_time desc");
		}
		
		//2. 生成过滤条件
		String machineId = machine.getId();
		
		Filter filter = new Filter(); 
		dataReader.loadFilterFromJSON(dataObject, filter);
		dataObject.addDefaultFilter(filter);
		
		IOnlineUser user = IOnlineUser.getInstance();
		String userLimit = " 1 = 1 ";
		
		if (!user.isAdmin()) {
			userLimit = "sys_state_working_user.user_id = " + Util.quotedStr(user.getId());
		}
		
		NamedSQL namedSQL = NamedSQL.getInstance("getDocumentListFilter"); 
		namedSQL.setParam("tableName", dataObject.getTableOrViewName());
		namedSQL.setParam("machine_id", machineId);
		namedSQL.setParam("user_limit", userLimit);

		filter.add(namedSQL.toString());
		
		//3. 计算分页
		int batchCount = dataObject.getCount(filter);
		page.setRecordCount(batchCount);
		dataWriter.addValue("page", page);
		
		//4. 加载数据
        EntitySet entitySet = dataObject.getBrowseEntitySet(filter, orderBy, page);
        dataWriter.addValue("data", entitySet);
	}
	
	public void getDocumentHistory(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		Domain domain = dataReader.getDomain();
		String dataName = domain.getDataName();
		
    	StateMachine machine = MachineBucket.getMachineByDataName(dataName);
    	if (machine == null) {
			return;
    	}
    	
		DataObject dataObject = DataObject.getInstance(dataName);
		
		//1. 从请求中获取Page和OrderBy
		Page page = new Page(); 
		OrderBy orderBy = new OrderBy();
		dataReader.loadPageOrderByFromJSON(dataObject, page, orderBy);
		
		if (orderBy.isEmpty()) {
			orderBy.add("update_time desc");
		}
		
		//2. 生成过滤条件
		String machineId = machine.getId();
		
		Filter filter = new Filter(); 
		dataReader.loadFilterFromJSON(dataObject, filter);
		dataObject.addDefaultFilter(filter);
		
		IOnlineUser user = IOnlineUser.getInstance();
		String userLimit = " 1 = 1 ";
		
		if (!user.isAdmin()) {
			userLimit = "sys_state_working_user.user_id = " + Util.quotedStr(user.getId());
		}
		
		NamedSQL namedSQL = NamedSQL.getInstance("getDocumentHistoryFilter"); 
		namedSQL.setParam("tableName", dataObject.getTableOrViewName());
		namedSQL.setParam("machine_id", machineId);
		namedSQL.setParam("user_limit", userLimit);

		filter.add(namedSQL.toString());
		
		//3. 计算分页
		int batchCount = dataObject.getCount(filter);
		page.setRecordCount(batchCount);
		dataWriter.addValue("page", page);		
		
		//4. 加载数据
        EntitySet entitySet = dataObject.getBrowseEntitySet(filter, orderBy, page);
        dataWriter.addValue("data", entitySet);
	}

	public void getAliveWorkflow(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		Domain domain = dataReader.getDomain();
		String documnetId = domain.getId();
		
		WorkingInstance flowInstance = new WorkingInstance(documnetId);
		flowInstance.loadActive(false, false);
		
		if (flowInstance.isEmpty()) {
			dataWriter.reportOneError("审批流查询", "没有查询到相关流程");
			return;
		}
		
		dataWriter.addValue("data", flowInstance);
	}

	public void getWorkSetps(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		Domain domain = dataReader.getDomain();
		String documnetId = domain.getId();
		
		WorkingInstance workingInstance = new WorkingInstance(documnetId);
		workingInstance.loadActive(true, false);
		
		if (workingInstance.isEmpty()) {
			dataWriter.reportOneError("审批流查询", "没有查询到相关流程");
			return;
		}
		
		List<WorkingStep> steps = workingInstance.getWorkingSteps();
		dataWriter.addValue("data", steps);
	}

	public void getWorkHistory(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		Domain domain = dataReader.getDomain();
		String documnetId = domain.getId();
		
		WorkingInstance flowInstance = new WorkingInstance(documnetId);
		flowInstance.loadActive(false, true);
		
		if (flowInstance.isEmpty()) {
			dataWriter.reportOneError("审批流查询", "没有查询到相关流程");
			return;
		}
		
		EntitySet histories = flowInstance.getHistories();
		dataWriter.addValue("data", histories);
	}

	public void transferWorkStepApprover(ActionContext context) throws Exception {
		// 1. 更新审批人
		String dataName = context.getDataName();
		DataPackage dataPackage = context.getDataPackage();
		dataPackage.loadDataFromRequest();
		dataPackage.loadFilterPageOrderByFromJSON();
		
		try {
			SQLRunner.beginTrans();
			
			Entity entity = dataPackage.getItemEntity(dataName, DataSource.Request);
			Filter filter = dataPackage.getFilter();
			DataObject dataObject = dataPackage.getDataObject(dataName);
			
			dataObject.updateByEntity(entity, filter);
			
			//2. 更新步骤
			NamedSQL namedSQL = NamedSQL.getInstance("getWorkStep");
			namedSQL.setFilter(filter);
			
			EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
			String workingStepId, documnetId;
			
			for (Entity step : entitySet) {
				documnetId = step.getString("doc_id");
				workingStepId = step.getId();
				
				WorkingInstance workingInstance = new WorkingInstance(documnetId);
				workingInstance.resetWorkingStep(workingStepId);
				workingInstance.loadActive(true, false);
			}
			
		}catch (Exception e) {
			SQLRunner.rollback();
			e.printStackTrace();
		}
		
		SQLRunner.commit();
		
		
		
	}
}