package org.springblade.mdm.flow.excution.cure;

import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.flowable.engine.delegate.DelegateExecution;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.SpringUtil;
import org.springblade.mdm.flow.excution.dispatch.FinishDataHandler;
import org.springblade.mdm.flow.excution.events.CureFinishedEvent;
import org.springblade.mdm.flow.service.FlowCommonService;
import org.springblade.mdm.flow.service.FlowProgramProperties;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.service.NcNodeHisService;
import org.springblade.mdm.program.service.NcNodeService;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;
import java.util.Date;

@Slf4j
@Component("cureFinishOperateTask")
@AllArgsConstructor
public class CureFinishOperateTask {
	private final NcNodeService nodeService;
	private final NcNodeHisService nodeHisService;
	private final FlowCommonService flowCommonService;
	private final NormalCureFinishDataHandler normalCureFinishDataHandler;
	private final DeviationCureFinishDataHandler deviationCureFinishDataHandler;

	/**
	 * 固化审批通过处理任务，
	 *
	 * @param execution 流程execution
	 */
	@Transactional
	public void execute(DelegateExecution execution) throws IOException {
		log.info("执行固化程序任务服务,流程实例id={}", execution.getProcessInstanceId());
		Date time = DateUtil.now();
		//固化程序检查有效期，
		NcNode node = dealWithNode(execution.getProcessInstanceId());

		nodeHisService.mergeNodeToHisGeTime(time);

		publishEvent(node.getProgramNo());

	}

	void publishEvent(String programNo) {
		//TaskDispatch dispatch = taskDispatchService.getByProgramNo(programNo);
		CureFinishedEvent event = new  CureFinishedEvent("curefinish",programNo);
		SpringUtil.publishEvent(event);
	}

	/**
	 * 处理node状态。
	 *
	 * @param processInstanceId 流程实例id
	 */
	NcNode dealWithNode(String processInstanceId) throws IOException {
		//程序包节点和下属程序节点(包括历史节点非最新版本的)从试切挪到固化下面
		//程序包节点 设置未已固化
		NcNode pkgNode = nodeService.lambdaQuery().eq(NcNode::getProcessInstanceId,  processInstanceId).one();
		FlowProgramProperties flowProps = flowCommonService.getProgramProperties(processInstanceId);
		getDataHandler(pkgNode).handleData(flowProps);

		return pkgNode;
	}

	/**
	 * 获取数据处理其
	 * @param pkgNode
	 * @return
	 */
	FinishDataHandler getDataHandler(NcNode pkgNode) {
		if (pkgNode.isDeviationProgram()) {
			return deviationCureFinishDataHandler;
		}else{
			return normalCureFinishDataHandler;

		}
	}
}