Activity工作流

论坛 › 期权论坛 › 脚本     
匿名网站用户   2020-12-20 06:05   11   0

工作流模拟程序员面试过程情景如下：
1.开发知识面试或者笔试
2.人事面试

流程图：

流程配置：

Xml代码 收藏代码
  1. <?xmlversion="1.0"encoding="UTF-8"?>
  2. <definitionsxmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:activiti="http://activiti.org/bpmn"xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"typeLanguage="http://www.w3.org/2001/XMLSchema"expressionLanguage="http://www.w3.org/1999/XPath"targetNamespace="http://www.activiti.org/test">
  3. <processid="DeveloperWorkExam"name="DeveloperWorkExam">
  4. <startEventid="startevent1"name="准备面试"></startEvent>
  5. <endEventid="endevent1"name="面试通过"></endEvent>
  6. <receiveTaskid="receivetask1"name="笔试以及面试通过">
  7. <extensionElements>
  8. <activiti:executionListenerevent="start"class="com.easyway.workflow.activiti.exam.DeveloperKnowledgeExamListener"></activiti:executionListener>
  9. </extensionElements>
  10. </receiveTask>
  11. <receiveTaskid="receivetask2"name="人事面试">
  12. <extensionElements>
  13. <activiti:executionListenerevent="start"class="com.easyway.workflow.activiti.exam.HumanResourceExamListener"></activiti:executionListener>
  14. </extensionElements>
  15. </receiveTask>
  16. <sequenceFlowid="flow1"name=""sourceRef="startevent1"targetRef="receivetask1"></sequenceFlow>
  17. <sequenceFlowid="flow2"name=""sourceRef="receivetask1"targetRef="receivetask2"></sequenceFlow>
  18. <sequenceFlowid="flow3"name=""sourceRef="receivetask2"targetRef="endevent1"></sequenceFlow>
  19. <sequenceFlowid="flow4"name=""sourceRef="receivetask1"targetRef="endevent1"></sequenceFlow>
  20. </process>
  21. </definitions>

spring配置application-context-standalone.xml如下：

Xml代码 收藏代码
  1. <?xmlversion="1.0"encoding="UTF-8"?>
  2. <beansxmlns="http://www.springframework.org/schema/beans"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:tx="http://www.springframework.org/schema/tx"
  5. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd
  7. http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-2.5.xsd
  8. http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
  9. <!--创建数据源-->
  10. <beanid="dataSource"class="org.springframework.jdbc.datasource.SimpleDriverDataSource">
  11. <propertyname="driverClass"value="org.h2.Driver"/>
  12. <propertyname="url"value="jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000"/>
  13. <propertyname="username"value="sa"/>
  14. <propertyname="password"value=""/>
  15. </bean>
  17. <!--创建事务管理器-->
  18. <beanid="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  19. <propertyname="dataSource"ref="dataSource"/>
  20. </bean>
  22. <!--创建流程引擎配置对象-->
  23. <beanid="processEngineConfiguration"class="org.activiti.spring.SpringProcessEngineConfiguration">
  24. <propertyname="dataSource"ref="dataSource"/>
  25. <propertyname="transactionManager"ref="transactionManager"/>
  26. <propertyname="databaseSchemaUpdate"value="true"/>
  27. <propertyname="mailServerHost"value="localhost"/>
  28. <propertyname="mailServerPort"value="5025"/>
  29. <propertyname="jpaHandleTransaction"value="true"/>
  30. <propertyname="jpaCloseEntityManager"value="true"/>
  31. <propertyname="jobExecutorActivate"value="false"/>
  32. </bean>
  34. <!--创建流程引擎对象-->
  35. <beanid="processEngine"class="org.activiti.spring.ProcessEngineFactoryBean">
  36. <propertyname="processEngineConfiguration"ref="processEngineConfiguration"/>
  37. </bean>
  38. <beanid="identityService"factory-bean="processEngine"factory-method="getIdentityService"/>
  40. <beanid="formService"factory-bean="processEngine"factory-method="getFormService"/>
  42. <beanid="repositoryService"factory-bean="processEngine"factory-method="getRepositoryService"/>
  43. <beanid="runtimeService"factory-bean="processEngine"factory-method="getRuntimeService"/>
  44. <beanid="taskService"factory-bean="processEngine"factory-method="getTaskService"/>
  45. <beanid="historyService"factory-bean="processEngine"factory-method="getHistoryService"/>
  46. <beanid="managementService"factory-bean="processEngine"factory-method="getManagementService"/>
  48. </beans>

application-context.xml

Xml代码 收藏代码
  1. <?xmlversion="1.0"encoding="UTF-8"?>
  2. <beansxmlns="http://www.springframework.org/schema/beans"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xmlns:tx="http://www.springframework.org/schema/tx"
  5. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd
  7. http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-2.5.xsd
  8. http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
  9. <!--创建数据源-->
  10. <beanid="dataSource"class="org.springframework.jdbc.datasource.SimpleDriverDataSource">
  11. <propertyname="driverClass"value="org.h2.Driver"/>
  12. <propertyname="url"value="jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000"/>
  13. <propertyname="username"value="sa"/>
  14. <propertyname="password"value=""/>
  15. </bean>
  17. <!--创建事务管理器-->
  18. <beanid="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  19. <propertyname="dataSource"ref="dataSource"/>
  20. </bean>
  22. <!--创建流程引擎配置对象-->
  23. <beanid="processEngineConfiguration"class="org.activiti.spring.SpringProcessEngineConfiguration">
  24. <propertyname="dataSource"ref="dataSource"/>
  25. <propertyname="transactionManager"ref="transactionManager"/>
  26. <propertyname="databaseSchemaUpdate"value="true"/>
  27. <propertyname="mailServerHost"value="localhost"/>
  28. <propertyname="mailServerPort"value="5025"/>
  29. <propertyname="jpaHandleTransaction"value="true"/>
  30. <propertyname="jpaCloseEntityManager"value="true"/>
  31. <propertyname="jobExecutorActivate"value="false"/>
  32. <!--使用spring的自动资源加载部署方式部署-->
  33. <propertyname="deploymentResources"value="classpath*:diagrams/*.bpmn20.xml"/>
  35. </bean>
  37. <!--创建流程引擎对象-->
  38. <beanid="processEngine"class="org.activiti.spring.ProcessEngineFactoryBean">
  39. <propertyname="processEngineConfiguration"ref="processEngineConfiguration"/>
  40. </bean>
  41. <beanid="identityService"factory-bean="processEngine"factory-method="getIdentityService"/>
  43. <beanid="formService"factory-bean="processEngine"factory-method="getFormService"/>
  45. <beanid="repositoryService"factory-bean="processEngine"factory-method="getRepositoryService"/>
  46. <beanid="runtimeService"factory-bean="processEngine"factory-method="getRuntimeService"/>
  47. <beanid="taskService"factory-bean="processEngine"factory-method="getTaskService"/>
  48. <beanid="historyService"factory-bean="processEngine"factory-method="getHistoryService"/>
  49. <beanid="managementService"factory-bean="processEngine"factory-method="getManagementService"/>
  51. </beans>

代码实现：

Java代码 收藏代码
  1. /**
  2. packagecom.easyway.workflow.activiti.exam;
  4. importjava.util.Map;
  6. /**
  7. *
  8. *工作流中配置如下：
  9. *<receiveTaskid="receivetask1"name="笔试以及面试通过">
  10. <extensionElements>
  11. <activiti:executionListenerevent="start"class="com.easyway.workflow.activiti.exam.DeveloperKnowledgeExamListener"/>
  12. </extensionElements>
  13. </receiveTask>
  15. *@authorlonggangbai
  16. *
  17. *2011-12-18上午12:38:24
  18. */
  19. publicclassDeveloperKnowledgeExamListenerimplementsJavaDelegate{
  20. privateLoggerlogger=Logger.getLogger(DeveloperKnowledgeExamListener.class.getName());
  21. /*(non-Javadoc)
  22. *@seeorg.activiti.engine.delegate.JavaDelegate#execute(org.activiti.engine.delegate.DelegateExecution)
  23. */
  24. @Override
  25. publicvoidexecute(DelegateExecutionexecute)throwsException{
  26. //TODOAuto-generatedmethodstub
  27. logger.info("开始开发知识面试了....");
  28. Map<String,Object>variables=execute.getVariables();
  29. Set<Entry<String,Object>>infos=variables.entrySet();
  30. for(Entry<String,Object>entry:infos){
  31. logger.info(entry.getKey()+""+entry.getValue());
  32. }
  33. logger.info("开始开发知识面试了....");
  34. execute.setVariable("result","该考生开发知识面试通过了....");
  36. }
  38. }

Java代码 收藏代码
  1. /**
  2. packagecom.easyway.workflow.activiti.exam;
  4. importjava.util.Map;
  6. /**
  7. *
  8. *
  9. *工作流中配置如下：
  10. *
  11. *<receiveTaskid="receivetask2"name="人事面试">
  12. <extensionElements>
  13. <activiti:executionListenerevent="start"class="com.easyway.workflow.activiti.exam.HumanResourceExamListener"/>
  14. </extensionElements>
  15. </receiveTask>
  17. *@authorlonggangbai
  18. *
  19. *2011-12-18上午12:37:01
  20. */
  21. publicclassHumanResourceExamListenerimplementsJavaDelegate{
  22. privateLoggerlogger=Logger.getLogger(HumanResourceExamListener.class.getName());
  24. /*(non-Javadoc)
  25. *@seeorg.activiti.engine.delegate.JavaDelegate#execute(org.activiti.engine.delegate.DelegateExecution)
  26. */
  27. @Override
  28. publicvoidexecute(DelegateExecutionexecute)throwsException{
  29. //TODOAuto-generatedmethodstub
  30. //TODOAuto-generatedmethodstub
  31. logger.info("检查该考试是否通过开发知识考试....");
  32. Map<String,Object>variables=execute.getVariables();
  33. Stringreuslt=variables.get("result").toString();
  34. logger.info("开发知识面试结果"+reuslt);
  35. logger.info("开始人事面试了....");
  36. execute.setVariable("result","该考生开发知识面试通过了....");
  37. logger.info("人事面试完毕....等候通知....");
  38. }
  40. }

Java代码 收藏代码
  1. /**
  2. packagecom.easyway.workflow.activiti.exam;
  4. importjava.util.logging.Logger;
  5. /**
  6. *
  7. *工作流模拟程序员面试过程情景如下：
  8. *1.开发知识面试或者笔试
  9. *2.人事面试
  10. *
  11. *在spring3.0.3和activiti5.6整合时候，建议采用activiti-spring-examples中的jar文件。
  12. *如果么有完整的jar文件，可以参考{activiti_home}/setup/files/dependencies/libs.spring.runtime.txt文件
  13. *。（C:\mash_activiti-5.6\setup\files\dependencies）
  14. *
  15. *之所以要采用封装的原因，spring配置文件和activiti的配置文件分开发布部署。
  16. *
  17. *@authorlonggangbai
  18. *
  19. *2011-12-18上午01:32:17
  20. */
  21. @ContextConfiguration("classpath:application-context-standalone.xml")
  22. publicabstractclassAbstractSpringTestextendsAbstractTransactionalJUnit4SpringContextTests{
  24. @SuppressWarnings("unused")
  25. privatefinalLoggerlog=Logger.getLogger(AbstractSpringTest.class.getName());
  27. @SuppressWarnings("unused")
  28. @Autowired
  29. privateProcessEngineprocessEngine;
  30. @Autowired
  31. protectedRepositoryServicerepositoryService;
  32. @Autowired
  33. protectedRuntimeServiceruntimeService;
  34. @Autowired
  35. protectedTaskServicetaskService;
  36. @Autowired
  37. protectedHistoryServicehistoryService;
  38. @Autowired
  39. protectedManagementServicemanagementService;
  41. protectedStringdeploymentId;
  43. publicAbstractSpringTest(){
  44. super();
  45. }
  47. @Before
  48. publicvoidinitialize()throwsException{
  49. beforeTest();
  50. }
  52. @After
  53. publicvoidclean()throwsException{
  54. afterTest();
  55. }
  57. protectedabstractvoidbeforeTest()throwsException;
  59. protectedabstractvoidafterTest()throwsException;
  60. }

Java代码 收藏代码
  1. /**
  2. packagecom.easyway.workflow.activiti.exam;
  4. importjava.util.HashMap;
  5. /**
  6. *我把Activiti5.6默认工程中有关JPA的部分配置删除了，其实通过这个就可以初始化Activiti引擎实例。
  7. *为了测试方便，将获取服务的实现抽象出来，同时使用Spring自带的与JUnit4集成的工具（
  8. *AbstractTransactionalJUnit4SpringContextTests）。
  9. *
  10. *将classpath:activiti-context.xml在测试的时候进行加载，这样，在测试的子类中，只需要将其他的相
  11. *关Spring配置单独加载即可，业务配置与流程配置分开，便于维护。
  12. *@authorlonggangbai
  13. *
  14. *2011-12-18上午01:37:14
  15. */
  16. @ContextConfiguration("classpath:application-context-standalone.xml")
  17. publicclassActivitiWithSpringStandaloneTestextendsAbstractSpringTest{
  19. @Override
  20. protectedvoidbeforeTest()throwsException{
  21. Deploymentdeployment=repositoryService
  22. .createDeployment()
  23. .addClasspathResource(
  24. "diagrams/SprintActiviti56.bpmn20.xml")
  25. .deploy();
  26. deploymentId=deployment.getId();
  27. }
  29. @Override
  30. protectedvoidafterTest()throwsException{
  31. repositoryService.deleteDeployment(deploymentId,true);
  32. }
  34. @Test
  35. publicvoidtriggerMyProcess(){
  36. //preparedatapacket
  37. Map<String,Object>variables=newHashMap<String,Object>();
  38. variables.put("姓名","程序员");
  39. variables.put("职务","高级软件工程师");
  40. variables.put("语言","Java/C#");
  41. variables.put("操作系统","Window,Linux，unix，Aix");
  42. variables.put("工作地点","苏州高新技术软件园");
  44. //startprocessinstance
  45. ProcessInstancepi=runtimeService.startProcessInstanceByKey("DeveloperWorkExam",variables);
  46. assert(pi!=null);
  48. List<Execution>executions=runtimeService.createExecutionQuery().list();
  49. assert(executions.size()==1);
  51. Executionexecution=runtimeService.createExecutionQuery().singleResult();
  52. runtimeService.setVariable(execution.getId(),"type","receiveTask");
  53. runtimeService.signal(execution.getId());
  55. executions=runtimeService.createExecutionQuery().list();
  56. assert(executions.size()==1);
  58. execution=executions.get(0);
  59. runtimeService.setVariable(execution.getId(),"oper","录用此人....");
  60. runtimeService.signal(execution.getId());
  61. }
  62. }

自动部署测试：

Java代码 收藏代码
  1. /**
  2. packagecom.easyway.workflow.activiti.exam;
  5. importjava.util.HashMap;
  6. /**
  7. *
  8. *Activiti5.6与Spring3.0.3整合也比较简单，其基本思想就是，通过Spring的IOC容器来管理Activiti的流程引擎
  9. *实例以及相关服务，可见，主要是基于Activiti在与Spring整合上努力上，做好配置即可。这里基于前面的
  10. *<receiveTask>的例子来进行.
  11. *
  12. *
  13. *为了测试方便，将获取服务的实现抽象出来，同时使用Spring自带的与JUnit4集成的工具（
  14. *AbstractTransactionalJUnit4SpringContextTests）。我们的实现类为AbstractSpringTest，
  15. *
  16. *
  17. *本文采用activiti和spring整合中自动部署资源的功能配置如下：
  18. *<!--创建流程引擎配置对象-->
  19. <beanid="processEngineConfiguration"class="org.activiti.spring.SpringProcessEngineConfiguration">
  20. <propertyname="dataSource"ref="dataSource"/>
  21. <propertyname="transactionManager"ref="transactionManager"/>
  22. <propertyname="databaseSchemaUpdate"value="true"/>
  23. <propertyname="mailServerHost"value="localhost"/>
  24. <propertyname="mailServerPort"value="5025"/>
  25. <propertyname="jpaHandleTransaction"value="true"/>
  26. <propertyname="jpaCloseEntityManager"value="true"/>
  27. <propertyname="jobExecutorActivate"value="false"/>
  28. <!--使用spring的自动资源加载部署方式部署-->
  29. <propertyname="deploymentResources"value="classpath*:diagrams/*.bpmn20.xml"/>
  31. </bean>
  32. *@authorlonggangbai
  33. *
  34. *2011-12-18上午12:58:31
  35. */
  36. @ContextConfiguration("classpath:application-context.xml")
  37. publicclassActivitiWithSpringTestextendsAbstractTransactionalJUnit4SpringContextTests{
  40. @Autowired
  41. privateRuntimeServiceruntimeService;
  43. @Autowired
  44. privateTaskServicetaskService;
  45. @Autowired
  46. privateManagementServicemanagerService;
  47. @Autowired
  48. privateIdentityServiceidentityService;
  49. @Autowired
  50. privateFormServiceformService;
  54. /**
  55. *测试方法
  56. */
  57. @Test
  58. publicvoidtriggerMyProcess(){
  59. //面试题目和答案
  60. Map<String,Object>variables=newHashMap<String,Object>();
  61. variables.put("姓名","程序员");
  62. variables.put("职务","高级软件工程师");
  63. variables.put("语言","Java/C#");
  64. variables.put("操作系统","Window,Linux，unix，Aix");
  65. variables.put("工作地点","苏州高新技术软件园");
  67. //startprocessinstance
  68. //获取创建一个实例
  69. ProcessInstancepi=runtimeService.startProcessInstanceByKey("DeveloperWorkExam",variables);
  70. assert(pi!=null);
  72. List<Execution>executions=runtimeService.createExecutionQuery().list();
  73. assert(executions.size()==1);
  74. //执行开发技术知识面试业务
  75. Executionexecution=runtimeService.createExecutionQuery().singleResult();
  76. runtimeService.setVariable(execution.getId(),"type","receiveTask");
  77. runtimeService.signal(execution.getId());
  79. executions=runtimeService.createExecutionQuery().list();
  80. assert(executions.size()==1);
  81. //执行人事面试业务
  82. execution=executions.get(0);
  83. runtimeService.setVariable(execution.getId(),"oper","录用此人....");
  84. runtimeService.signal(execution.getId());
  85. }
  86. }
回复
分享到 :
0 人收藏
返回列表
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

16级独孤
匿名网站用户

积分:1136255
帖子:227251
精华:0
+ 关注 私信
期权论坛 期权论坛
期权网络科技版权所有
关于我们
联系我们
加入我们
反馈问题
免责声明
积分充值
统一社会信用代码
积分规则
网站地图
爱文库
下属网站
官方
新浪微博
微信公众号
◆
下载
表情包
App下载
期权论坛 期权论坛

QQ咨询|关于我们|Archiver|手机版|小黑屋|( 辽ICP备15012455号-4 ) Powered by 期权论坛 X3.2 © 2001-2016 期权工具网&期权论坛 Inc.

发布
内容

下载期权论坛手机APP