package org.springblade.mdm.flow.service;

import com.alibaba.excel.util.StringUtils;
import lombok.AllArgsConstructor;
import org.flowable.engine.HistoryService;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.history.HistoricProcessInstance;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.history.HistoricTaskInstance;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func;
import org.springblade.mdm.basesetting.machine.service.MachineService;
import org.springblade.mdm.basesetting.machine.entity.Machine;
import org.springblade.mdm.basesetting.producedivision.entity.ProduceDivision;
import org.springblade.mdm.basesetting.producedivision.service.ProduceDivisionService;
import org.springblade.mdm.commons.service.UserCommonService;
import org.springblade.mdm.flow.constants.FlowContants;
import org.springblade.mdm.flow.constants.FlowVariableContants;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.service.NodeDeptQueryService;
import org.springblade.system.feign.IUserClient;
import org.springblade.system.pojo.entity.User;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.Map;

@AllArgsConstructor
@Service
public class FlowCommonService {
	private final RuntimeService runtimeService;
	private final HistoryService historyService;
	private final ProduceDivisionService produceDivisionService;
	private final NodeDeptQueryService nodeDeptQueryService;
	private final MachineService machineService;
	private final UserCommonService userCommonService;
	/**
	 * 根据流程实例id获取definitionKey
	 * @param processInstanceId
	 * @return
	 */
	public String getDefinitionKey(String processInstanceId){

		ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
			.processInstanceId(processInstanceId)
			.singleResult();
		return processInstance.getProcessDefinitionKey();
	}

	/**
	 * 从流程变量获取发起流程的树形
	 * @param processInstanceId
	 * @return
	 */
	public FlowProgramProperties getProgramProperties(String processInstanceId){
		FlowProgramProperties programProperties = new FlowProgramProperties();
		programProperties.setProcessInstanceId(processInstanceId);

		Map<String, Object> vars = runtimeService.getVariables(processInstanceId);
		this.copyFlowPropertiesFromMap(programProperties, vars);

		ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
			.processInstanceId(processInstanceId)
			.singleResult();
		String processDefinitionKey = processInstance.getProcessDefinitionKey();
		programProperties.setProcessDefinitionKey(processDefinitionKey);
		return programProperties;
	}
	public FlowProgramProperties getProgramPropertiesFromHis(String processInstanceId) {
		HistoricProcessInstance historicInstance = historyService.createHistoricProcessInstanceQuery().includeProcessVariables()
			.processInstanceId(processInstanceId)
			.singleResult();

		FlowProgramProperties programProperties = new FlowProgramProperties();
		programProperties.setProcessInstanceId(processInstanceId);

		Map<String, Object> vars =historicInstance.getProcessVariables();
		this.copyFlowPropertiesFromMap(programProperties,vars);

		programProperties.setProcessDefinitionKey(historicInstance.getProcessDefinitionKey());
		return programProperties;
	}

	/**
	 * 从map中赋值流程便利到vo
	 * @param programProperties vo
	 * @param vars 变量map
	 */
	void copyFlowPropertiesFromMap(FlowProgramProperties programProperties,Map<String, Object> vars){

		programProperties.setTitle(String.valueOf(vars.get(FlowVariableContants.TITLE)));
		programProperties.setIsTempFlow(Func.toStr(vars.get(FlowVariableContants.IS_TEMP_FLOW)));
		programProperties.setDrawingNo(String.valueOf(vars.get(FlowVariableContants.DRAWING_NO)));
		programProperties.setDrawingNoEdition(String.valueOf(vars.get(FlowVariableContants.DRAWING_NO_EDITION)));
		programProperties.setProductModel(String.valueOf(vars.get(FlowVariableContants.PRODUCT_MODEL)));

		programProperties.setProcessNo(String.valueOf(vars.get(FlowVariableContants.PROCESS_NO)));
		programProperties.setProcessEdition(String.valueOf(vars.get(FlowVariableContants.PROCESS_EDITION)));//工序版次
		programProperties.setProcessName(String.valueOf(vars.get(FlowVariableContants.PROCESS_NAME)));
		programProperties.setMachineCode(String.valueOf(vars.get(FlowVariableContants.MACHINE_CODE)));

		programProperties.setMachineMode(String.valueOf(vars.get(FlowVariableContants.MACHINE_MODE)));
		//数据处理名称为版次以前，零件号加工序号：YZL4-1100-01-50 零组件号：YZL4-1100-01 工序号 50

		programProperties.setCraftEdition(String.valueOf(vars.get(FlowVariableContants.CRAFT_EDITION)));
		programProperties.setHasCuredProgram(String.valueOf(vars.get(FlowVariableContants.HAS_CURED_PROGRAM)));
		programProperties.setIsProcessEditionSame(String.valueOf(vars.get(FlowVariableContants.IS_PROCESS_EDITION_SAME)));
		if(vars.containsKey(FlowVariableContants.DEVIATION)) {
			programProperties.setDeviation(String.valueOf(vars.get(FlowVariableContants.DEVIATION)));
		}
		if(vars.containsKey(FlowVariableContants.CURED_NODE_ID)){
			programProperties.setCuredNodeId(Func.toLong(vars.get(FlowVariableContants.CURED_NODE_ID)));
		}
		if(vars.containsKey(FlowContants.NODE_ID)){
			programProperties.setNodeId(Func.toLong(vars.get(FlowContants.NODE_ID)));
		}
		programProperties.setCureProgramUseable(String.valueOf(vars.get(FlowContants.CURE_PROGRAM_USEABLE)));

		programProperties.setTeamLeaderId(Func.toLong(vars.get(FlowVariableContants.TEAM_LEADER)));
		programProperties.setProgrammerId(Func.toLong(vars.get(FlowVariableContants.PROGRAMMER)));
		programProperties.setCheckerId(Func.toLong(vars.get(FlowVariableContants.CHECKER)));
		programProperties.setSeniorId(Func.toLong(vars.get(FlowVariableContants.SENIOR)));

		programProperties.setProgramNo(programProperties.getDrawingNo()+"-"+programProperties.getProcessNo()+"-"+programProperties.getProcessEdition());

		programProperties.setActProgrammerId(Func.toLong(vars.get(FlowVariableContants.ACT_PROGRAMMER)));
		programProperties.setActCheckerId(Func.toLong(vars.get(FlowVariableContants.ACT_CHECKER)));
		programProperties.setActSeniorId(Func.toLong(vars.get(FlowVariableContants.ACT_SENIOR)));
		programProperties.setProgrammerName(Func.toStr(vars.get("programmerName")));
	}
	/**
	 * 流程是否在进行
	 * @param processInstanceId 实例id
	 */
	public boolean isProcessInstanceActive(String processInstanceId) {
		if(processInstanceId == null){
			return false;
		}
		// 先查运行时表
		ProcessInstance instance = runtimeService.createProcessInstanceQuery()
			.processInstanceId(processInstanceId)
			.singleResult();

		if (instance != null) {
			return true;
		}

		// 再查历史表确认是否曾经存在
		HistoricProcessInstance historicInstance = historyService.createHistoricProcessInstanceQuery()
			.processInstanceId(processInstanceId)
			.singleResult();

		return historicInstance != null && historicInstance.getEndTime() == null;
	}

	/**
	 * 上一步处理人
	 * @param processInstanceId 流程实例id
	 * @return assignee
	 */
	/*
    public String previusAssignee(String processInstanceId) {
		// 获取历史任务实例
		List<HistoricTaskInstance> historicTasks = historyService.createHistoricTaskInstanceQuery()
			.processInstanceId(processInstanceId)
			.orderByHistoricTaskInstanceEndTime().asc()
			.list();

		// 获取上一个已完成的任务
		String assignee = "";
		if(!historicTasks.isEmpty()) {
			assignee = historicTasks.get(historicTasks.size() - 1).getAssignee();
		}
		return assignee;
    }*/

	/**
	 * 将默认审批用户放入map中
	 * @param vars 启动流程的变量map
	 * @param drawingNo 零组件号
	 */
	public ProduceDivision putDefaultAssignees(Map<String, Object> vars,String drawingNo,String defaultAssignee){
		ProduceDivision div = produceDivisionService.getByDrawingNoWithQinzhe(drawingNo);
		vars.put(FlowVariableContants.TEAM_LEADER,div.getTeamLeaderId());
		vars.put(FlowVariableContants.PROGRAMMER,div.getProgrammerId());
		vars.put(FlowVariableContants.CHECKER,div.getCheckerId());
		vars.put(FlowVariableContants.SENIOR,div.getSeniorId());
		if(StringUtils.isNotBlank(defaultAssignee)) {
			vars.put(FlowVariableContants.ASSIGNEE, defaultAssignee);//第一个审批用户：组长
		}

		vars.put(FlowContants.PROGRAMMER_NAME, userCommonService.getUserNameById(div.getProgrammerId()));
		return div;
	}

	/**
	 * 根据程序包名节点，填充变量map
	 * @param vars
	 * @param programPackageNode
	 */
	public void putFlowVariablesByNode(Map<String, Object> vars, NcNode programPackageNode){
		//机床编号
		vars.put(FlowVariableContants.MACHINE_CODE,programPackageNode.getMachineCode());
		Machine machine = machineService.getByCode(programPackageNode.getMachineCode());
		//机床型号
		if(machine != null) {
			vars.put(FlowVariableContants.MACHINE_MODE, machine.getName());
		}
		vars.put(FlowVariableContants.PROCESS_NO,programPackageNode.getProcessNo());
		vars.put(FlowVariableContants.PROCESS_NAME,programPackageNode.getProcessName());
		vars.put(FlowVariableContants.PROCESS_EDITION,programPackageNode.getProcessEdition());
		vars.put(FlowVariableContants.CRAFT_EDITION,programPackageNode.getCraftEdition());

		vars.put(FlowVariableContants.DRAWING_NO,programPackageNode.getDrawingNo());
		vars.put(FlowVariableContants.DRAWING_NO_EDITION,programPackageNode.getDrawingNoEdition());

		vars.put(FlowVariableContants.PROGRAM_PACKAGE_NAME,programPackageNode.getName());

		vars.put(FlowVariableContants.PRODUCT_MODEL,programPackageNode.getProductModel());
		vars.put(FlowContants.NODE_ID, programPackageNode.getId());
		vars.put(FlowVariableContants.WORKSHOP,nodeDeptQueryService.getWorkshopNameByMachineCode(programPackageNode.getMachineCode()));

	}
}