码迷，mamicode.com
首页 > 编程语言 > 详细

activiti自己定义流程之Spring整合activiti-modeler实例（六）：启动流程

时间：2017-07-24 21:24:39      阅读：237      评论：0      收藏：0      [点我收藏+]

标签：nts   oar   tostring   blank   public   tail   activiti   flush   max   

1.启动流程并分配任务是单个流程的正式開始，因此要使用到runtimeService接口。以及相关的启动流程的方法。我习惯于用流程定义的key启动，由于有多个版本号的流程定义时，用key启动默认会使用最新版本号。同一时候，由于启动中查询了流程部署时xml文件里流程节点的信息。也用到了repositoryService及相关方法。


2.后台业务代码，
  （1）自己定义的申请单实体类（为的目的仅仅为了跑通整个流程。因此仅仅定义了一个实体类。按公司标准开发来说，应该是和前台交互一个command类（事实上也还是实体类，叫法不一样而已），和数据库交互另一个实体类），在这里定义了一个申请单的基本信息：
[java] view plain copy
 技术分享技术分享
  1. package model;  
  2.   
  3.   
  4. public class applyModel {  
  5.     /** 
  6.      * 流程定义id 
  7.      */  
  8.     private String proDefId;  
  9.     /** 
  10.      * 流程定义的key 
  11.      */  
  12.     private String key;  
  13.       
  14.     private String name;  
  15.     /** 
  16.      * 申请人 
  17.      */  
  18.     private String appPerson;  
  19.     /** 
  20.      * 原因 
  21.      */  
  22.     private String cause;  
  23.     /** 
  24.      * 内容 
  25.      */  
  26.     private String content;  
  27.     /** 
  28.      * 处理人。即下一个任务节点的受理人 
  29.      */  
  30.     private String proPerson;  
  31.   
  32.   
  33.     public String getKey() {  
  34.         return key;  
  35.     }  
  36.   
  37.   
  38.     public void setKey(String key) {  
  39.         this.key = key;  
  40.     }  
  41.   
  42.   
  43.     public String getAppPerson() {  
  44.         return appPerson;  
  45.     }  
  46.   
  47.   
  48.     public void setAppPerson(String appPerson) {  
  49.         this.appPerson = appPerson;  
  50.     }  
  51.   
  52.   
  53.     public String getCause() {  
  54.         return cause;  
  55.     }  
  56.   
  57.   
  58.     public void setCause(String cause) {  
  59.         this.cause = cause;  
  60.     }  
  61.   
  62.   
  63.     public String getContent() {  
  64.         return content;  
  65.     }  
  66.   
  67.   
  68.     public void setContent(String content) {  
  69.         this.content = content;  
  70.     }  
  71.   
  72.   
  73.     public String getProPerson() {  
  74.         return proPerson;  
  75.     }  
  76.   
  77.   
  78.     public void setProPerson(String proPerson) {  
  79.         this.proPerson = proPerson;  
  80.     }  
  81.   
  82.   
  83.     public String getName() {  
  84.         return name;  
  85.     }  
  86.   
  87.   
  88.     public void setName(String name) {  
  89.         this.name = name;  
  90.     }  
  91.   
  92.   
  93.     public String getProDefId() {  
  94.         return proDefId;  
  95.     }  
  96.   
  97.   
  98.     public void setProDefId(String proDefId) {  
  99.         this.proDefId = proDefId;  
  100.     }  
  101.   
  102.   
  103.     @Override  
  104.     public String toString() {  
  105.         return "applyModel [proDefId=" + proDefId + ", key=" + key + ", name="  
  106.                 + name + ", appPerson=" + appPerson + ", cause=" + cause  
  107.                 + ", content=" + content + ", proPerson=" + proPerson + "]";  
  108.     }  
  109.   
  110.   
  111. }  


（2）业务逻辑：


A，这种方法获取流程部署时xml文件中的各个节点相关信息。用来辨别当前是哪个节点，下一节点又是什么，共下边的B方法调用。

由于操作部署时的文件，因此使用repositoryService：

[java] view plain copy
 技术分享技术分享
  1. /** 
  2.      * @throws XMLStreamException 
  3.      *             查询流程节点 
  4.      *  
  5.      * @author：tuzongxun 
  6.      * @Title: findFlow 
  7.      * @param @return 
  8.      * @return Iterator<FlowElement> 
  9.      * @date Mar 21, 2016 9:31:42 AM 
  10.      * @throws 
  11.      */  
  12.     public Iterator<FlowElement> findFlow(String processDefId)  
  13.             throws XMLStreamException {  
  14.         List<ProcessDefinition> lists = repositoryService  
  15.                 .createProcessDefinitionQuery()  
  16.                 .processDefinitionId(processDefId)  
  17.                 .orderByProcessDefinitionVersion().desc().list();  
  18.         ProcessDefinition processDefinition = lists.get(0);  
  19.         processDefinition.getCategory();  
  20.         String resourceName = processDefinition.getResourceName();  
  21.         InputStream inputStream = repositoryService.getResourceAsStream(  
  22.                 processDefinition.getDeploymentId(), resourceName);  
  23.         BpmnXMLConverter converter = new BpmnXMLConverter();  
  24.         XMLInputFactory factory = XMLInputFactory.newInstance();  
  25.         XMLStreamReader reader = factory.createXMLStreamReader(inputStream);  
  26.         BpmnModel bpmnModel = converter.convertToBpmnModel(reader);  
  27.         Process process = bpmnModel.getMainProcess();  
  28.         Collection<FlowElement> elements = process.getFlowElements();  
  29.         Iterator<FlowElement> iterator = elements.iterator();  
  30.         return iterator;  
  31.     }  


B.这里调用上一个方法，一起完毕流程的启动及相关信息的设置：

[java] view plain copy
 技术分享技术分享
  1. /** 
  2.      * @throws XMLStreamException 
  3.      *             启动流程 
  4.      *  
  5.      * @author：tuzongxun 
  6.      * @Title: startProcess 
  7.      * @param @return 
  8.      * @return Object 
  9.      * @date Mar 17, 2016 2:06:34 PM 
  10.      * @throws 
  11.      */  
  12.     @RequestMapping(value = "/startProcess.do", method = RequestMethod.POST, produces = "application/json;charset=utf-8")  
  13.     @ResponseBody  
  14.     public Object startProcess(@RequestBody applyModel applyModel,  
  15.             HttpServletRequest req) throws XMLStreamException {  
  16.         Map<String, String> map = new HashMap<String, String>();  
  17.         boolean isLogin = this.isLogin(req);  
  18.         if (isLogin) {  
  19.             if (applyModel != null) {  
  20.                 String processKey = applyModel.getKey();  
  21.                 String processDefId = applyModel.getProDefId();  
  22.                 // //////////////////////////  
  23.                 Iterator<FlowElement> iterator = this.findFlow(processDefId);  
  24.                 Map<String, Object> varables = new HashMap<String, Object>();  
  25.                 int i = 1;  
  26.                 while (iterator.hasNext()) {  
  27.                     FlowElement flowElement = iterator.next();  
  28.                     // 申请人  
  29.                     if (flowElement.getClass().getSimpleName()  
  30.                             .equals("UserTask")  
  31.                             && i == 1) {  
  32.                         UserTask userTask = (UserTask) flowElement;  
  33.                         String assignee = userTask.getAssignee();  
  34.                         int index1 = assignee.indexOf("{");  
  35.                         int index2 = assignee.indexOf("}");  
  36.                         varables.put(assignee.substring(index1 + 1, index2),  
  37.                                 applyModel.getAppPerson());  
  38.                         varables.put("cause", applyModel.getCause());  
  39.                         varables.put("content", applyModel.getContent());  
  40.                         varables.put("taskType", applyModel.getName());  
  41.                         i++;  
  42.                         // 下一个处理人  
  43.                     } else if (flowElement.getClass().getSimpleName()  
  44.                             .equals("UserTask")  
  45.                             && i == 2) {  
  46.                         UserTask userTask = (UserTask) flowElement;  
  47.                         String assignee = userTask.getAssignee();  
  48.                         int index1 = assignee.indexOf("{");  
  49.                         int index2 = assignee.indexOf("}");  
  50.                         varables.put(assignee.substring(index1 + 1, index2),  
  51.                                 applyModel.getProPerson());  
  52.                         break;  
  53.                     }  
  54.                 }  
  55.                 // ///////////////////////////  
  56.                 runtimeService.startProcessInstanceByKey(processKey, varables);  
  57.                 map.put("userName",  
  58.                         (String) req.getSession().getAttribute("userName"));  
  59.                 map.put("isLogin", "yes");  
  60.                 map.put("result", "success");  
  61.             } else {  
  62.                 map.put("result", "fail");  
  63.             }  
  64.         } else {  
  65.             map.put("isLogin", "no");  
  66.         }  
  67.         return map;  
  68.     }  



3.angular js前台代码。：
  （1）app.js中配置路由：
   
[javascript] view plain copy
 技术分享技术分享
  1. $stateProvider    
  2.    .state(‘startProcess‘, {    
  3.    url: "/startProcess",    
  4.    views: {    
  5.       ‘view‘: {    
  6.        templateUrl: ‘activi_views/startProcess.html‘,    
  7.        controller: ‘startProcessCtr‘    
  8.       }    
  9.    }    
  10.   });    


  （2）逻辑相关代码：

     
[javascript] view plain copy
 技术分享技术分享
  1. angular.module(‘activitiApp‘)    
  2. .controller(‘startProcessCtr‘, [‘$rootScope‘,‘$scope‘,‘$http‘,‘$location‘, function($rootScope,$scope,$http,$location){    
  3.   
  4.   
  5.     $http.post("createFlush.do").success(function(result){  
  6.         if(result.isLogin==="yes"){  
  7.             $rootScope.userName=result.userName;  
  8.             $scope.process1={"proDefId":"","key":"","appPerson":"","cause":"","content":"","proPerson":"","name":""};  
  9.             if($rootScope.process==null||$rootScope.process.key==null){  
  10.                 $location.path("/processList");  
  11.             }else{  
  12.                 $scope.process1.proDefId=$rootScope.process.id;  
  13.                  $scope.process1.key=$rootScope.process.key;  
  14.                    $scope.process1.name=$rootScope.process.name;  
  15.             }  
  16.         }else{  
  17.             $location.path("/login");  
  18.         }  
  19.     });  
  20.          
  21.         
  22.         $scope.startProcess=function(process){  
  23.             console.log(process);  
  24.             $http.post("./startProcess.do",process).success(function(deployResult){  
  25.                 $location.path("/taskList");  
  26.             });  
  27.         }  
  28.         
  29.     
  30. }])    


4.相应的填写相关信息的页面：
[html] view plain copy
 技术分享技术分享
  1. <center>    
  2. <div style="margin-top:20px;margin-left:200px;background-color:#9cc;height:500px;width:50%;font-size:22px;position:relative;float:left;">    
  3.     <p style="font-size:28px">新建申请</p>  
  4.     流程定义id:<input type="text" ng-model="process1.proDefId" readonly="readonly" style="background-color:#9dc"/>   
  5.     </br>    
  6.     </br>    
  7.     流程定义key:<input type="text" ng-model="process1.key" readonly="readonly" style="background-color:#9dc"/>   
  8.     </br>    
  9.     </br>    
  10.     申请类型:<input type="text" ng-model="process1.name" readonly="readonly" style="background-color:#9dc"/>   
  11.     </br>    
  12.     </br>    
  13.     申请人:<input type="text" ng-model="process1.appPerson" />   
  14.     </br>    
  15.     </br>    
  16.     申请原因:<input type="text" ng-model="process1.cause"/>    
  17.     </br>    
  18.     </br>    
  19.     申请内容:<input type="text" ng-model="process1.content"/>    
  20.     </br>    
  21.     </br>    
  22.   受理人：<input type="text" ng-model="process1.proPerson"/>    
  23.     </br>    
  24.     </br>    
  25.     <input style="font-size:24px;cursor:pointer" type="button" value="提交申请" ng-click="startProcess(process1);">    
  26.              
  27.     <input style="font-size:24px;cursor:pointer" type="button" value="返回">    
  28. </div>    
  29. </center>    



5.成功启动一个流程实例后，会看到act_ru_execution、act_ru_identitylink、act_ru_task、act_ru_variable以及act_hi_actinst、act_hi_detail、act_hi_indentitylink、act_hi_procinst、act_hi_taskinst、act_hi_varinst表中都有了数据。除开variable和varinst中的数据条数是依据相应的流程变量多少来定的。其它都是添加了一条数据。

activiti自己定义流程之Spring整合activiti-modeler实例（六）：启动流程

标签：nts   oar   tostring   blank   public   tail   activiti   flush   max   

原文地址：http://www.cnblogs.com/wzzkaifa/p/7230967.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！