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

import lombok.extern.slf4j.Slf4j;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.delegate.DelegateExecution;
import org.springblade.core.tool.utils.Func;
import org.springblade.mdm.flow.constants.FlowContants;
import org.springblade.mdm.flow.entity.ApproveRecord;
import org.springblade.mdm.flow.entity.FlowProgramFile;
import org.springblade.mdm.flow.service.ApproveRecordService;
import org.springblade.mdm.flow.service.FlowProgramFileService;
import org.springblade.mdm.flow.service.ReplaceFlowService;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.entity.NcProgramApproved;
import org.springblade.mdm.program.service.NcNodeService;
import org.springblade.mdm.program.service.NcProgramApprovedService;
import org.springblade.mdm.utils.EntityUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 替换完成执行的事件，功能：插入审批表数据
 */
@Slf4j
@Component("replaceFinishListener")
public class ReplaceFinishListener {
	@Autowired
	private RuntimeService runtimeService;
	@Autowired
	private ApproveRecordService approveRecordService;
	@Autowired
	private FlowProgramFileService flowProgramFileService;
	@Autowired
	private NcProgramApprovedService ncProgramApprovedService;
	@Autowired
	private NcNodeService ncNodeService;
	/**
	 * 在流程结束时自动调用,（配置在审批结束事件的executelistener中了）
	 * @param execution 执行对象
	 */
	public void handle(DelegateExecution execution) {
		// 执行业务逻辑
		String instId = execution.getProcessInstanceId();
		Long nodeId = runtimeService.getVariable(execution.getId(),ReplaceFlowService.NODE_ID,Long.class);
		log.info("事件名称{}，instid={}" , execution.getEventName(),instId);
		List<FlowProgramFile> programFiles =  flowProgramFileService.lambdaQuery().eq(FlowProgramFile::getProcessInstanceId, instId).list();
		NcNode newProgramPackage = replaceProgram(nodeId,instId,programFiles);


		addToApproved(newProgramPackage,Func.toStr(execution.getVariables().get(FlowContants.TITLE)));
		log.info("流程已完成 in replaceFinishListener");
	}

	/**
	 * 增加审批通过记录，供用户导出到工控网
	 * @param newProgramPackage 新的程序包节点
	 * @param title 标题
	 */
	void addToApproved(NcNode newProgramPackage,String title){
		NcProgramApproved approve = new NcProgramApproved();
		approve.setProgramName(newProgramPackage.getName());
		approve.setNcNodeId(newProgramPackage.getId());
		approve.setTitle(title);

		ncProgramApprovedService.save(approve);
	}
	/**
	 * 替换原来程序的文件
	 * @param programFiles 新的文件
	 * @return 新的程序包名节点
	 */
	NcNode replaceProgram(Long nodeId,String processInstanceId, List<FlowProgramFile> programFiles){
		//原节点改为老版本
		NcNode oldPackageNode = ncNodeService.getById(nodeId);
		oldPackageNode.setIsLastEdition(0);
		oldPackageNode.setIsLocked(1);
		ncNodeService.updateById(oldPackageNode);

		//程序包名节点升级版本
		//已确认，要新创建一个package
		NcNode newPackageNode = new NcNode();
		BeanUtils.copyProperties(oldPackageNode,newPackageNode);
		EntityUtil.clearBaseProperties(newPackageNode);
		newPackageNode.setIsLastEdition(1);
		newPackageNode.setVersionNumber(oldPackageNode.genNewVersionNumber());
		newPackageNode.setProcessInstanceId(processInstanceId);
		ncNodeService.save(newPackageNode);


		//老文件，更新成老版本
		List<NcNode> programFileNodes = ncNodeService.getProgramFilesByPackageId(nodeId);
		NcNode fileNodeOne = null;
		if(!programFileNodes.isEmpty()){
			fileNodeOne = programFileNodes.get(0);
		}
		for(NcNode fileNode: programFileNodes){
			fileNode.setIsLastEdition(0);
			ncNodeService.updateById(fileNode);
		}

		for(FlowProgramFile programFile: programFiles){
			NcNode node = new NcNode();
			if(fileNodeOne != null){
				BeanUtils.copyProperties(fileNodeOne, node);
				EntityUtil.clearBaseProperties(node);
			}
			node.setIsLastEdition(1);
			node.setProcessEdition(newPackageNode.getProcessEdition());
			node.setName(programFile.getName());
			node.setParentIds(newPackageNode.getParentIds()+","+newPackageNode.getId());
			node.setParentId(newPackageNode.getId());
			node.setFlowProgramFileId(programFile.getId());
			node.setMachineCode(newPackageNode.getMachineCode());
			node.setProcessName(newPackageNode.getProcessName());
			node.setNodeType(NcNode.TYPE_PROGRAM_FILE);
			node.setVersionNumber(newPackageNode.getVersionNumber());//新版本，应为需要比对
			node.setCraftEdition(newPackageNode.getCraftEdition());
			node.setIsLocked(0);

			ncNodeService.save(node);
		}

		return newPackageNode;
	}

	void updateApproveRecordNodeId(NcNode pkgNode){
		//更新审批记录的ncNodeId
		approveRecordService.lambdaUpdate()
			.eq(ApproveRecord::getProcessInstanceId, pkgNode.getProcessInstanceId())
			.set(ApproveRecord::getNcNodeId,pkgNode.getId()).update();
	}
}