activiti自定义流程之Spring整合activiti-modeler5.16实例(七):任务列表展示

简介: <span style="font-family:Arial; font-size:14px; line-height:26px"></span><span style="font-family:Arial; font-size:14px; line-height:26px">注:(1)环境搭建:<a target="_blank" href="http://blog.csdn.net/t
注:(1)环境搭建:activiti自定义流程之Spring整合activiti-modeler5.16实例(一):环境搭建
        (2)创建流程模型:activiti自定义流程之Spring整合activiti-modeler5.16实例(二):创建流程模型 
        (3)流程模型列表展示:activiti自定义流程之Spring整合activiti-modeler5.16实例(三):流程模型列表展示
        (4)部署流程定义:activiti自定义流程之Spring整合activiti-modeler5.16实例(四):部署流程定义

        (5)流程定义列表:activiti自定义流程之Spring整合activiti-modeler5.16实例(五):流程定义列表

        (6)启动流程:activiti自定义流程之Spring整合activiti-modeler5.16实例(六):启动流程



1.通过上一节的操作,可以知道流程启动以后会同时生成一个流程实例和用户任务,这个用户任务保存在act_ru_task和act_hi_task表中,从表明可以看出ru是runtime,hi是history。但是需要注意的是,和操作流程使用的service不同,操作正在发生任务不是使用runtimeService,而是专门的taskService。
2.后台业务代码,
  (1)自定义的任务实体类

package model;
import java.util.Date;
public class TaskModel {
	private String id;
	private String name;
	private String processInstanceId;
	private String assignee;
	private Date createTime;
	private String nextPerson;
	private String cause;
	private String content;
	private String taskType;
	private String processKey;
	private String processDefId;

	public String getTaskType() {
		return taskType;
	}

	public void setTaskType(String taskType) {
		this.taskType = taskType;
	}

	public String getId() {
		return id;
	}

	public void setId(String id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getProcessInstanceId() {
		return processInstanceId;
	}

	public void setProcessInstanceId(String processInstanceId) {
		this.processInstanceId = processInstanceId;
	}

	public String getAssignee() {
		return assignee;
	}

	public void setAssignee(String assignee) {
		this.assignee = assignee;
	}

	public Date getCreateTime() {
		return createTime;
	}

	public void setCreateTime(Date createTime) {
		this.createTime = createTime;
	}

	public String getNextPerson() {
		return nextPerson;
	}

	public void setNextPerson(String nextPerson) {
		this.nextPerson = nextPerson;
	}

	public String getCause() {
		return cause;
	}

	public void setCause(String cause) {
		this.cause = cause;
	}

	public String getContent() {
		return content;
	}

	public void setContent(String content) {
		this.content = content;
	}

	public String getProcessKey() {
		return processKey;
	}

	public void setProcessKey(String processKey) {
		this.processKey = processKey;
	}

	public String getProcessDefId() {
		return processDefId;
	}

	public void setProcessDefId(String processDefId) {
		this.processDefId = processDefId;
	}

	@Override
	public String toString() {
		return "TaskModel [id=" + id + ", name=" + name
				+ ", processInstanceId=" + processInstanceId + ", assignee="
				+ assignee + ", createTime=" + createTime + ", nextPerson="
				+ nextPerson + ", cause=" + cause + ", content=" + content
				+ ", taskType=" + taskType + ", processKey=" + processKey
				+ ", processDefId=" + processDefId + "]";
	}
}



(2)业务逻辑:查询任务使用taskService调用相关的方法来完成,可以根据特定的条件,也可以不加条件查询所有。可以返回task为元素的list,也可以返回单独的task对象,但是需要注意的是,如果要返回单独的task对象,则必须确定返回值是唯一的对象,否则就会抛出异常。下边的例子中,我是根据当前登陆的用户名来查询出对应的所有task:
/**
	 * @throws XMLStreamException
	 *             查询个人任务
	 * 
	 * @author:tuzongxun
	 * @Title: findTask
	 * @param @return
	 * @return Object
	 * @date Mar 17, 2016 2:44:11 PM
	 * @throws
	 */
	@RequestMapping(value = "/findTask.do", method = RequestMethod.POST, produces = "application/json;charset=utf-8")
	@ResponseBody
	public Object findTask(HttpServletRequest req) throws XMLStreamException {
		Map<String, Object> map = new HashMap<String, Object>();
		boolean isLogin = this.isLogin(req);
		if (isLogin) {
			List<TaskModel> taskList = new ArrayList<TaskModel>();
			HttpSession session = req.getSession();
			String assginee = (String) session.getAttribute("userName");
			List<Task> taskList1 = taskService.createTaskQuery()
					.taskAssignee(assginee).list();
			if (taskList1 != null && taskList1.size() > 0) {
				for (Task task : taskList1) {
					TaskModel taskModel = new TaskModel();
					taskModel.setAssignee(task.getAssignee());
					taskModel.setCreateTime(task.getCreateTime());
					taskModel.setId(task.getId());
					taskModel.setName(task.getName());
					taskModel.setProcessInstanceId(task.getProcessInstanceId());
					taskModel.setProcessDefId(task.getProcessDefinitionId());
					// 获取流程变量
					Map<String, Object> variables = runtimeService
							.getVariables(task.getProcessInstanceId());
					Set<String> keysSet = variables.keySet();
					Iterator<String> keySet = keysSet.iterator();
					while (keySet.hasNext()) {
						String key = keySet.next();
						if (key.endsWith("cause")) {
							taskModel.setCause((String) variables.get("cause"));
						} else if (key.endsWith("content")) {
							taskModel.setContent((String) variables
									.get("content"));
						} else if (key.endsWith("taskType")) {
							taskModel.setTaskType((String) variables
									.get("taskType"));
						} else if (!assginee.equals(variables.get(key))) {
							// 想办法查询是否还有下一个任务节点
							Iterator<FlowElement> iterator = this.findFlow(task
									.getProcessDefinitionId());
							while (iterator.hasNext()) {
								FlowElement flowElement = iterator.next();
								String classNames = flowElement.getClass()
										.getSimpleName();
								if (classNames.equals("UserTask")) {
									UserTask userTask = (UserTask) flowElement;
									String assginee11 = userTask.getAssignee();
									String assginee12 = assginee11.substring(
											assginee11.indexOf("{") + 1,
											assginee11.indexOf("}"));
									String assignee13 = (String) variables
											.get(assginee12);
									if (assginee.equals(assignee13)) {
										// 看下下一个节点是什么
										iterator.next();
										FlowElement flowElement2 = iterator
												.next();
										String classNames1 = flowElement2
												.getClass().getSimpleName();
										// 设置下一个任务人
										if (!(classNames1.equals("EndEvent"))) {
											UserTask userTask2 = (UserTask) flowElement2;
											String assginee21 = userTask2
													.getAssignee();
											String assginee22 = assginee21
													.substring(
															assginee21
																	.indexOf("{") + 1,
															assginee21
																	.indexOf("}"));
											String assignee23 = (String) variables
													.get(assginee22);
											taskModel.setNextPerson(ToolUtils
													.isEmpty(assignee23));
										}
									}


								}
							}
							// //////////
						}
					}
					taskList.add(taskModel);
				}
			}
			map.put("isLogin", "yes");
			map.put("userName",
					(String) req.getSession().getAttribute("userName"));
			map.put("result", "success");
			map.put("data", taskList);
		} else {
			map.put("isLogin", "no");
		}
		return map;
	}




3.angular js前台代码(前台只是做简单的展示,不多讲):
  (1)app.js中配置路由:
   
  
 $stateProvider  
   .state('taskList', {  
   url: "/taskList",  
   views: {  
      'view': {  
       templateUrl: 'activi_views/taskList.html',  
       controller: 'taskCtr'  
      }  
   }  
  });  



  (2)逻辑相关代码:

   
  angular.module('activitiApp')  
.controller('taskCtr', ['$rootScope','$scope','$http','$location','$state', function($rootScope,$scope,$http,$location,$state){  
$scope.init=function(){
        $http.post("./findTask.do").success(function(result) {
        	if(result.isLogin==="yes"){
        	console.log(result.data); 
        	$rootScope.userName=result.userName;
    	    $scope.taskList=result.data;
        	}else{
        		$location.path("/login");
        	}
        });
}    
        $scope.completeTaskTo=function(task){
        	console.log(task);
        	$rootScope.task=task;
        	//$location.path("/completeTaskTo");
        	$location.path("/completeTaskTo1");
        }
      
  
}])  



4.对应的填写相关信息的页面:

<div id="logdiv1" ng-init="init();">  
   <p style="font-size:22px;margin-top:10px">当前任务列表</p>
   <center> 
   <table border="1px" style="width:87%;font-size:14px;text-align:center;margin-top:1px;margin-left:2px;position:relative;float:left;" cellSpacing="0px" cellPadding="0px">
      <tr style="background-color:#ccc">
         <td>类型</td>
         <td>ID</td>
         <td>NAME</td>
         <td>ProcessIntanceId</td>
         <td>ProcessDefId</td>
         <td>创建时间</td>
         <td>申请人</td>
         <td>受理人</td>
         <td>申请原因</td>
         <td>申请内容</td>
         <td>操 作</td>
      </tr>
      <tr ng-repeat="task in taskList | orderBy:'id'" >
         <td>{{task.taskType}}</td>
         <td>{{task.id}}</td>
         <td>{{task.name}}</td>
         <td>{{task.processInstanceId}}</td>
         <td>{{task.processDefId}}</td>
         <td>{{task.createTime | date:"yyyy-MM-dd HH:mm:ss"}}</td>
         <td>{{task.assignee}}</td>
         <td>{{task.nextPerson}}</td>
         <td>{{task.cause}}</td>
         <td>{{task.content}}</td>
         <td><a href="script:;" ng-click="completeTaskTo(task)">完成任务</a> 
         </td>
      </tr>
   </table>  
   </center> 
</div>  
 


目录
相关文章
|
人工智能 Java Serverless
【MCP教程系列】搭建基于 Spring AI 的 SSE 模式 MCP 服务并自定义部署至阿里云百炼
本文详细介绍了如何基于Spring AI搭建支持SSE模式的MCP服务,并成功集成至阿里云百炼大模型平台。通过四个步骤实现从零到Agent的构建,包括项目创建、工具开发、服务测试与部署。文章还提供了具体代码示例和操作截图,帮助读者快速上手。最终,将自定义SSE MCP服务集成到百炼平台,完成智能体应用的创建与测试。适合希望了解SSE实时交互及大模型集成的开发者参考。
14651 60
|
7月前
|
监控 安全 Java
使用 @HealthEndpoint 在 Spring Boot 中实现自定义健康检查
Spring Boot 通过 Actuator 模块提供了强大的健康检查功能,帮助开发者快速了解应用程序的运行状态。默认健康检查可检测数据库连接、依赖服务、资源可用性等,但在实际应用中,业务需求和依赖关系各不相同,因此需要实现自定义健康检查来更精确地监控关键组件。本文介绍了如何使用 @HealthEndpoint 注解及实现 HealthIndicator 接口来扩展 Spring Boot 的健康检查功能,从而提升系统的可观测性与稳定性。
539 0
使用 @HealthEndpoint 在 Spring Boot 中实现自定义健康检查
|
IDE Java 应用服务中间件
spring boot 启动流程
Spring Boot 启动流程简介: 在使用 Spring Boot 之前,启动 Java Web 应用需要配置 Web 容器(如 Tomcat),并将应用打包放入容器目录。而使用 Spring Boot,只需运行 main() 方法即可启动 Web 应用。Spring Boot 的核心启动方法是 SpringApplication.run(),它负责初始化和启动应用上下文。 主要步骤包括: 1. **应用启动计时**:使用 StopWatch 记录启动时间。 2. **打印 Banner**:显示 Spring Boot 的 LOGO。 3. **创建上下文实例**:通过反射创建
793 5
|
XML Java 数据格式
使用idea中的Live Templates自定义自动生成Spring所需的XML配置文件格式
本文介绍了在使用Spring框架时,如何通过创建`applicationContext.xml`配置文件来管理对象。首先,在resources目录下新建XML配置文件,并通过IDEA自动生成部分配置。为完善配置,特别是添加AOP支持,可以通过IDEA的Live Templates功能自定义XML模板。具体步骤包括:连续按两次Shift搜索Live Templates,配置模板内容,输入特定前缀(如spring)并按Tab键即可快速生成完整的Spring配置文件。这样可以大大提高开发效率,减少重复工作。
1009 1
使用idea中的Live Templates自定义自动生成Spring所需的XML配置文件格式
|
JSON Java 数据格式
微服务——SpringBoot使用归纳——Spring Boot中的全局异常处理——拦截自定义异常
本文介绍了在实际项目中如何拦截自定义异常。首先,通过定义异常信息枚举类 `BusinessMsgEnum`,统一管理业务异常的代码和消息。接着,创建自定义业务异常类 `BusinessErrorException`,并在其构造方法中传入枚举类以实现异常信息的封装。最后,利用 `GlobalExceptionHandler` 拦截并处理自定义异常,返回标准的 JSON 响应格式。文章还提供了示例代码和测试方法,展示了全局异常处理在 Spring Boot 项目中的应用价值。
587 0
|
9月前
|
Java Spring 容器
SpringBoot自动配置的原理是什么?
Spring Boot自动配置核心在于@EnableAutoConfiguration注解,它通过@Import导入配置选择器,加载META-INF/spring.factories中定义的自动配置类。这些类根据@Conditional系列注解判断是否生效。但Spring Boot 3.0后已弃用spring.factories,改用新格式的.imports文件进行配置。
1293 0
|
10月前
|
人工智能 Java 测试技术
Spring Boot 集成 JUnit 单元测试
本文介绍了在Spring Boot中使用JUnit 5进行单元测试的常用方法与技巧,包括添加依赖、编写测试类、使用@SpringBootTest参数、自动装配测试模块(如JSON、MVC、WebFlux、JDBC等),以及@MockBean和@SpyBean的应用。内容实用,适合Java开发者参考学习。
1095 0
|
6月前
|
JavaScript Java Maven
【SpringBoot(二)】带你认识Yaml配置文件类型、SpringMVC的资源访问路径 和 静态资源配置的原理!
SpringBoot专栏第二章,从本章开始正式进入SpringBoot的WEB阶段开发,本章先带你认识yaml配置文件和资源的路径配置原理,以方便在后面的文章中打下基础
542 4
|
6月前
|
Java 测试技术 数据库连接
【SpringBoot(四)】还不懂文件上传?JUnit使用?本文带你了解SpringBoot的文件上传、异常处理、组件注入等知识!并且带你领悟JUnit单元测试的使用!
Spring专栏第四章,本文带你上手 SpringBoot 的文件上传、异常处理、组件注入等功能 并且为你演示Junit5的基础上手体验
1068 3
|
前端开发 Java 数据库
微服务——SpringBoot使用归纳——Spring Boot集成Thymeleaf模板引擎——Thymeleaf 介绍
本课介绍Spring Boot集成Thymeleaf模板引擎。Thymeleaf是一款现代服务器端Java模板引擎,支持Web和独立环境,可实现自然模板开发,便于团队协作。与传统JSP不同,Thymeleaf模板可以直接在浏览器中打开,方便前端人员查看静态原型。通过在HTML标签中添加扩展属性(如`th:text`),Thymeleaf能够在服务运行时动态替换内容,展示数据库中的数据,同时兼容静态页面展示,为开发带来灵活性和便利性。
505 0