/**

      * 2、发布一个流程

      */

     @Test

     public void  testDeployProcess() {

         RepositoryService repositoryService = processEngine.getRepositoryService();

         DeploymentBuilder builder = repositoryService.createDeployment();

         // 加载发布资源

         builder.name("机器自动执行流程测试") // 设置流程显示别名

                 .addClasspathResource("receiveTask.bpmn") // 设置流程规则文件

                 .addClasspathResource("receiveTask.png"); // 设置流程规则的图片

         // 发布流程

         builder.deploy();

     }

 /**

      * 3、启动流程，并自动执行任务

      */

     @Test

     public void testStartProcess() {

         // 获取服务对象的实例

         RuntimeService runtimeService = processEngine.getRuntimeService();

         String processDefinitionKey = "receiveTask";

         // 自动执行与Key相对应的流程的最高版本

         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey);

         String processInstanceId = processInstance.getId();

         logger.info("Id:" + processInstance.getId());

         //获取当前流程下Execution对象

         Execution e1 = runtimeService

                                             .createExecutionQuery()

                                             .processInstanceId(processInstanceId) //每个流程的唯一标识

                                             .activityId("汇总当天销售额")    //每个活动的唯一标识

                                             .singleResult();

         Assert.assertNotNull(e1);

         //自动逻辑的绑定-汇总当天销售额,进行一堆逻辑后，得到金额money

         Double money = 888888.88d;

         //把金额放入变量中

         runtimeService.setVariable(e1.getId(), "销售额", money);

         logger.info("汇总后当天的销售额是: " +  money);

         //推动流程流转

         runtimeService.signal(e1.getId());

         //判断当前流程，是否仪在一个节点ID是“发短信给老板”的活动节点

         Execution e2 = runtimeService

                 .createExecutionQuery()

                 .processInstanceId(processInstanceId) //每个流程的唯一标识

                 .activityId("发短信给老板")    //每个活动的唯一标识

                 .singleResult();

         Assert.assertNotNull(e2);

         Double m = (Double) runtimeService.getVariable(e2.getId(), "销售额");

         logger.info("老板，今天的销售额是：" +m);

         //推动流程流转

         runtimeService.signal(e2.getId());

         //检查结束状态

         ProcessInstance pInstance = runtimeService

                                                         .createProcessInstanceQuery()

                                                         .processInstanceId(processInstanceId)

                                                         .singleResult();

         Assert.assertNull(pInstance);

         logger.info("机器自动任务流程成功执行！");

     }