基于activiti的采购审批流程

      package org.java.service.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.activiti.engine.IdentityService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.runtime.ProcessInstanceQuery;
import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.apache.logging.log4j.core.helpers.UUIDUtil;
import org.java.dao.PurOrderMapper;
import org.java.service.PurOrderService;
import org.java.util.ResourcesUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 采购业务实现类
 * 
 * @author Administrator
 * 
 */
@Service
public class PurOrderServiceImpl implements PurOrderService {

	@Autowired
	private RuntimeService runtimeService;

	@Autowired
	private PurOrderMapper purOrderMapper;

	@Autowired
	private TaskService taskService;
	
	@Autowired
	private IdentityService identityService;
	

	/**
	 * 创建采购单 是完成的任务： 1、启动一个流程实例 2、向业务表中 添加一条业务数据（并且在业务表与工作流的表之间建立关联 ）
	 */
	public void createPurOrder(Map<String, Object> m) {

		// 获得要启动的流程定义的 key
		String processDefinitionKey = ResourcesUtil.getValue("diagram/process",
				"definitionProcessKey");

		// 通过uuid,产生一个随机字符串，作为工作流的businessKey(业务字段)，用于与业务表关联。同时，它也是业务表的主键
		String businessKey = UUIDUtil.getTimeBasedUUID().toString();
		
		//设置任务的发起人
		String userId = (String) m.get("userId");
		identityService.setAuthenticatedUserId(userId);

		// 启动流程实列
		ProcessInstance instance = runtimeService.startProcessInstanceByKey(
				processDefinitionKey, businessKey);
		// (#{id},#{name},#{price},#{content},#{createtime},#{status},#{userid},#{processinstanceid},#{endtime})
		/*************************** 向业务表中添加数据 **************************************************/

		// 向map中，存放需要的数据
		m.put("id", businessKey);
		m.put("createtime", new Date());
		m.put("processinstanceid", instance.getProcessInstanceId());

		purOrderMapper.createPurOrder(m);

		System.out.println("创建成功");
	}

	/**
	 * 查询当前用户的任务列表
	 */
	public List<Map<String, Object>> queryTaskList(String userId) {

		// 创建查询接口
		TaskQuery query = taskService.createTaskQuery();

		// 指定查询哪一个业务流程的任务--------------processDefintionKey
		// String processDefinitionKey =
		// ResourcesUtil.getValue("diagram/process","definitionProcessKey");
		// query.processDefinitionKey(processDefinitionKey);
		// 指定查询哪一个用户负责的任务
		query.taskAssignee(userId);

		// 查询-----查询的结果中，只包含工作流的数据，不包含任何业务数据
		List<Task> taskList = query.orderByTaskId().asc().list();

		// 创建集合，用于包含工作流的信息以及对应的业务数据
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();

		// 对所有的task循 环，分别取得每 一个task对应的业务数据
		for (Task t : taskList) {
			// 通过任务task,查询出当前任务对应的流程实例
			ProcessInstance instance = runtimeService
					.createProcessInstanceQuery()
					.processInstanceId(t.getProcessInstanceId()).singleResult();

			// 得到流程实例的businessKey,也就是业务表的主键，通过它查询业务表
			String businessKey = instance.getBusinessKey();

			// 根据businessKey查询业务表
			Map<String, Object> m = purOrderMapper
					.queryPurOrderByBusinessKey(businessKey);

			// 把Task的一些相关信息，封装到map返回
			m.put("taskId", t.getId());// 任务ID
			m.put("taskName", t.getName());// 任务名称
			m.put("processDefintionId", t.getProcessInstanceId());// 流程实例id
			m.put("startTime", t.getCreateTime());// 任务开始时间
			m.put("assignee", t.getAssignee());// 任务负责人
			m.put("defKey", t.getTaskDefinitionKey());// 任务标识，用于标识当前任务，执行到了哪一个阶段

			list.add(m);
		}

		return list;
	}

	/**
	 * 返回所有正在运行的流程实例，包含业务数据
	 */
	public List<Map<String, Object>> showProcessInstance() {

		// 创建流程实例查询接口
		ProcessInstanceQuery query = runtimeService
				.createProcessInstanceQuery();

		// 查询所有正在运行的流程实例
		List<ProcessInstance> instancelist = query.list();

		// 创建集合，用于包含工作流的信息以及对应的业务数据
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();

		for (ProcessInstance instance : instancelist) {
			// 根据业务主键，查询对应的业务数据
			// 得到流程实例的businessKey,也就是业务表的主键，通过它查询业务表
			String businessKey = instance.getBusinessKey();

			// 根据businessKey查询业务表
			Map<String, Object> m = purOrderMapper
					.queryPurOrderByBusinessKey(businessKey);

			// 把流程实例的相关信息，封装到map中
			m.put("processInstanceId", instance.getProcessInstanceId());// 实例ID
			m.put("processDefinitionId", instance.getProcessDefinitionId());// 定义ID
			m.put("activityId", instance.getActivityId());// 活动节点Id,运行到哪一个阶段
			m.put("businessKey", instance.getBusinessKey());// 业务主键

			list.add(m);
		}
		return list;

	}

	/**
	 * 查询采购单 详情，用于审核
	 */
	public Map<String, Object> purOrderAudit(String purOrderId) {
		return purOrderMapper.queryPurOrderById(purOrderId);
	}

	/**
	 * 提交审核意见
	 */
	public void submitAudit(Map<String, Object> m) {

		// 生成审核单的id
		String id = UUIDUtil.getTimeBasedUUID().toString();

		m.put("id", id);// 审核单的id
		m.put("createtime", new Date());

		purOrderMapper.submitAudit(m);

		/*******************************************************************/
		
		String auditType = (String) m.get("auditType");
		String status = (String) m.get("status");
		
		
		Map<String,Object> variables = new HashMap<String, Object>();
//		variables.put(auditType,status);
		if(auditType.equals("firstAudit")){
			variables.put("firstAudit",status);
		}
		if(auditType.equals("secondAudit")){
			variables.put("secondAudit",status);
		}
		if(auditType.equals("thirdAudit")){
			variables.put("thirdAudit",status);
		}
		
		// 获得任务Id
		String taskId = (String) m.get("taskId");

		// 完成任务
		taskService.complete(taskId,variables);

	}

	/**
	 * 提交采购单，同时，设置流程变量
	 */
	public void submitPurOrder(String taskId) {

		// 通过taskId获得对应的业务数据
		TaskQuery query = taskService.createTaskQuery();

		// 查询出指定的任务
		Task task = query.taskId(taskId).singleResult();

		// 获得任务对应的流程实例，通过流程实例，获得业务主键businessKey
		ProcessInstance instance = runtimeService.createProcessInstanceQuery()
				.processInstanceId(task.getProcessInstanceId()).singleResult();
		//获得业务主键
		String businessKey = instance.getBusinessKey();
		
		//根据业务主键，查询业务数据
		Map<String,Object> variables = purOrderMapper.queryPurOrderByBusinessKey(businessKey);
		
		//提交采购单，同时设置流程变量
		taskService.complete(taskId, variables);

		System.out.println("采购单已提交");
	}
	
	/**
	 * 查询可拾取任务列表
	 */
	public List<Map<String, Object>> queryClaimTaskList(String userId) {
		
		TaskQuery query = taskService.createTaskQuery();
		query.taskCandidateUser(userId);//设置候选人
		
		List<Task> taskList = query.list();
		
		// 创建集合，用于包含工作流的信息以及对应的业务数据
		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();

		// 对所有的task循 环，分别取得每 一个task对应的业务数据
		for (Task t : taskList) {
			// 通过任务task,查询出当前任务对应的流程实例
			ProcessInstance instance = runtimeService
					.createProcessInstanceQuery()
					.processInstanceId(t.getProcessInstanceId()).singleResult();

			// 得到流程实例的businessKey,也就是业务表的主键，通过它查询业务表
			String businessKey = instance.getBusinessKey();

			// 根据businessKey