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

import lombok.extern.slf4j.Slf4j;
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.FlowProgramProperties;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.entity.NcProgramApproved;
import org.springblade.mdm.program.service.NcNodeAutoCreateService;
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;

/**
 * 普通派工完成数据处理器，功能：插入审批表数据，DispatchFinishListener调用
 */
@Slf4j
@Component("normalDispatchFinishDataHandler")
public class NormalFinishDataHandler implements FinishDataHandler{
	@Autowired
	private NcProgramApprovedService approvedService;
	@Autowired
	private ApproveRecordService approveRecordService;
	@Autowired
	private FlowProgramFileService flowProgramFileService;
	@Autowired
	private NcNodeService ncNodeService;
	@Autowired
	private NcNodeAutoCreateService ncNodeAutoCreateService;
	/**
	 * DispatchFinishListener中调用
	 * @param props 执行对象
	 */
	public void handleData(FlowProgramProperties props) {
		// 执行业务逻辑
		String instId = props.getProcessInstanceId();

		String programPkgName = NcNodeService.genProgramName(props.getDrawingNo(),props.getProcessNo());
		//NcNode packageNode =createProgramNodes(props);
		NcNode packageNode;// = ncNodeAutoCreateService.createNodeTreeWithProgram(props);
		if(FlowContants.Y.equals(props.getHasCuredProgram())){
			//有固化
			packageNode = ncNodeService.getById(props.getCuredNodeId());

			if(FlowContants.N.equals(props.getCureProgramUseable())) {
				//程序不可用
				//原来的固化节点锁定
				packageNode.lock();
				ncNodeService.updateById(packageNode);

				Integer newVersion = packageNode.genNewVersionNumber();
				packageNode = ncNodeAutoCreateService.createNodeTreeWithProgram(props);
				packageNode.setVersionNumber(newVersion);
				ncNodeService.updateById(packageNode);
			}

		}else{
			packageNode = ncNodeAutoCreateService.createNodeTreeWithProgram(props);
		}

		addApproveTable(packageNode,props);
		updateApproveRecordNodeId(instId, packageNode.getId());
		log.info("普通流程已完成in DispatchFinishListener");
	}


	/**
	 * 保存审批完成的记录
	 * @param packageNode
	 * @param props
	 */
	void addApproveTable(NcNode packageNode,FlowProgramProperties props){
		NcProgramApproved approved = new NcProgramApproved();

		approved.setProgramName(packageNode.getName());
		approved.setNcNodeId(packageNode.getId());//程序包节点id
		approved.setTitle(props.getTitle());
		approved.setProgrammerId(props.getProgrammerId());
		approvedService.save(approved);

	}


	void updateApproveRecordNodeId(String processInstanceId,Long nodeId){
		//更新审批记录的ncNodeId
		approveRecordService.lambdaUpdate()
			.eq(ApproveRecord::getProcessInstanceId, processInstanceId)
			.set(ApproveRecord::getNcNodeId,nodeId).update();
	}
}