package com.highdatas.mdm.service.act.impl;

import com.highdatas.mdm.entity.TUser;
import com.highdatas.mdm.pojo.NextTaskUserInfo;
import lombok.extern.slf4j.Slf4j;
import org.activiti.engine.*;
import org.activiti.engine.delegate.Expression;
import org.activiti.engine.identity.Group;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.activiti.engine.impl.task.TaskDefinition;
import org.activiti.engine.task.Task;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Service
public class TaskServiceImpl extends BaseServiceImpl implements com.highdatas.mdm.service.act.TaskService{
	@Autowired
	TaskService taskService;
	@Autowired
	RepositoryService repositoryService;
	@Autowired
	HistoryService historyService;
	@Autowired
	RuntimeService runtimeService;
	@Autowired
	IdentityService identityService;
	public boolean checkClaim(String workflowId) {
		Task task = getTask(workflowId);
		if (task == null) {
			return true;
		}
		// 判断任务是否已经被签收
		if (task.getAssignee() == null) {
			return true;
		} else {
			return false;
		}
	}
	public String claimTask(String workflowId) {
		Task task = getTask(workflowId);

        TUser onlineUser = getOnlineUser();
        //resultPool = serviceCaller.getResultPool();
		
		try {
			taskService.claim(task.getId(), onlineUser.getUserId());
			//resultPool.setMessage("Task is claimed");
			return task.getId();
		}
		catch (Exception e) {
			e.printStackTrace();
			return null;
		}
	}

	
	public boolean completeTask(String taskId, boolean pass, String reason, Map<String,Object> other) {
		Map<String, Object> variables = new LinkedHashMap<String, Object>();
		if(other != null){
			Set<String> keySet = other.keySet();
			for (String key : keySet) {
				variables.put(key, other.get(key));
			}
		}
		variables.put("pass", pass);
		variables.put("reason", reason);
		try {
			taskService.setVariables(taskId, variables);
			taskService.complete(taskId,variables);

			return true;
		} 
		catch (Exception e) {
			e.printStackTrace();
			log.debug("can not complete task(" + taskId + "): " + e.getMessage());
			return false;
		}
	}	
	
	public boolean completeTask(String taskId, boolean pass, String reason) {
		return completeTask(taskId,pass,reason,null);
	}	
	
	public List<String> getTodoTask()  {
        TUser onlineUser = getOnlineUser();
        Set<String> result = new HashSet<>();
		//List<Task> list1 = TimeTaskService.createTaskQuery().active().list();
		List<Task> list = taskService.createTaskQuery().taskAssignee(onlineUser.getUserId()).active().list();

		result.addAll(list.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));

		List<Task> toClaimList = taskService.createTaskQuery().taskCandidateUser(onlineUser.getUserId()).active().list();

		result.addAll(toClaimList.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));


		List<Group> groups = identityService.createGroupQuery().groupMember(onlineUser.getUserId()).list();
		if (groups.size() == 0)  {
			return new ArrayList<>(result);
		}
        List<String> groupIds = groups.stream().map(Group::getId).collect(Collectors.toList());
        toClaimList = taskService.createTaskQuery().taskCandidateGroupIn(groupIds).active().list();

		result.addAll(toClaimList.stream().map(task -> task.getProcessInstanceId()).collect(Collectors.toList()));

		return new ArrayList<>(result);
	}
    
    public Task geTask(String processId) {
    	Task task = taskService.createTaskQuery().processInstanceId(processId).singleResult();
    	return task;
	}

	@Override
	public NextTaskUserInfo getNestTaskAssignee(String workflowId) {
		//TODO 需修改
		NextTaskUserInfo nextTaskUserInfo = new NextTaskUserInfo();
		Task nextTask = geTask(workflowId);
		if (nextTask == null) {
			return null;
		}
		String nextTaskAssignee = nextTask.getAssignee();
		if (!StringUtils.isEmpty(nextTaskAssignee)) {
			nextTaskUserInfo.setUserId(nextTaskAssignee);
			nextTaskUserInfo.setRoleId("R001");
			return nextTaskUserInfo;
		}
		String processDefinitionId=nextTask.getProcessDefinitionId(); // 获取流程定义id

		ProcessDefinitionEntity processDefinitionEntity= (ProcessDefinitionEntity) repositoryService.getProcessDefinition(processDefinitionId);

		ActivityImpl activityImpl=processDefinitionEntity.findActivity(nextTask.getTaskDefinitionKey()); // 根据活动id获取活动实例
		TaskDefinition taskDef = (TaskDefinition)activityImpl.getProperties().get("taskDefinition");
		Set<Expression> userCodes = taskDef.getCandidateUserIdExpressions();//候选人
		Set<Expression> roleCodes = taskDef.getCandidateGroupIdExpressions();//候选组
		if (roleCodes.size() != 0) {
			String roleId = roleCodes.stream().map(expression -> expression.getExpressionText()).findFirst().get();
			nextTaskUserInfo.setRoleId(roleId);
		}
		return nextTaskUserInfo;
	}

}