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.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(String[] taskIds, String[] processInstanceIds, String comment,String assignee) {
		if(StringUtils.isBlank(assignee)){
			throw new ServiceException("缺少处理人参数");
		}
		if(taskIds == null || taskIds.length == 0){
			throw new ServiceException("任务id组为空");
		}

		if(processInstanceIds == null || processInstanceIds.length == 0){
			throw new ServiceException("流程实例id组为空");
		}
		if(taskIds.length != processInstanceIds.length){
			throw new ServiceException("任务id与流程实例id数量不一致");
		}

		Map<String, Object> variables = Kv.create();
		variables.put("assignee", assignee);
		variables.put("approve", FlowContants.Y);//默认就是通过
		String taskId;
		String processInstanceId;
		for(int i=0;i<taskIds.length;i++){
			taskId = taskIds[i];
			processInstanceId = processInstanceIds[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 taskIds
	 * @param processInstanceIds
	 * @param comment
	 */
	public void batchAutoCompleteTask(String[] taskIds, String[] processInstanceIds, String comment) {
		//TODO 带实现
	}
}