package org.springblade.mdm.flow.service.execute;

import org.apache.commons.lang3.StringUtils;
import org.flowable.engine.TaskService;
import org.flowable.task.api.Task;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.tool.support.Kv;
import org.springblade.core.tool.utils.StringUtil;
import org.springblade.mdm.flow.constants.FlowContants;
import org.springblade.mdm.flow.service.ApproveRecordService;
import org.springblade.mdm.flow.service.FlowProgramFileService;
import org.springblade.mdm.flow.vo.BatchDispatchVO;
import org.springblade.mdm.program.service.NcNodeAutoCreateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Map;

/**
 * 试切流程完成任务的实现
 */
@Service
public class BatchDispatchService  {

	@Autowired
	private ApproveRecordService approveRecordService;
	@Autowired
	private TaskService taskService;
	@Transactional
	public void batchCompleteTask(BatchDispatchVO batchDispatchVO) {
		//String[] taskIds, String[] processInstanceIds, String comment, String assignee
		if(StringUtils.isBlank(batchDispatchVO.getAssignee())){
			throw new ServiceException("缺少处理人参数");
		}
		checkBatchParameter(batchDispatchVO);

		Map<String, Object> variables = Kv.create();
		variables.put("assignee", batchDispatchVO.getAssignee());
		variables.put("approve", FlowContants.Y);//默认就是通过
		String taskId;
		String processInstanceId;
		String comment = batchDispatchVO.getComment();
		String[] taskIds = batchDispatchVO.getTaskIds();
		for(int i=0;i<taskIds.length;i++){
			taskId = taskIds[i];
			processInstanceId = batchDispatchVO.getProcessInstanceIds()[i];

			Task task = taskService.createTaskQuery()
				.taskId(taskId)
				.singleResult();
			taskService.complete(taskId, variables);

			if (StringUtil.isNoneBlank(processInstanceId, comment)) {
				taskService.addComment(taskId, processInstanceId, comment);
			}

			approveRecordService.saveApproveRecords(task,FlowContants.Y,comment);
		}
	}

	/**
	 * 自动批量派工
	 * @param batchDispatchVO 批量处理参数
	 */
	public void batchAutoCompleteTask(BatchDispatchVO batchDispatchVO) {
		//TODO 带实现
		checkBatchParameter(batchDispatchVO);
	}

	/**
	 * 验证批量处理参数
	 * @param batchDispatchVO 批量处理参数对象
	 */
	void checkBatchParameter(BatchDispatchVO batchDispatchVO){
		String[] taskIds = batchDispatchVO.getTaskIds();
		if(taskIds == null || taskIds.length == 0){
			throw new ServiceException("任务id组为空");
		}
		String[] processInstanceIds = batchDispatchVO.getProcessInstanceIds();
		if(processInstanceIds == null || processInstanceIds.length == 0){
			throw new ServiceException("流程实例id组为空");
		}
		if(taskIds.length != processInstanceIds.length){
			throw new ServiceException("任务id与流程实例id数量不一致");
		}
	}
}