Examples of taskAssignee()

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

128
129
130
131
132
133
134
135
136
137
138
    processInstanceId = processInstance.getId();
   
    // 创建任务查询
    TaskQuery taskQuery = taskService.createTaskQuery();
    // 查找 1200119390 的这个流程实例的当前独占任务
    List<TaskInstance> taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    // 获取一条任务
    TaskInstance taskInstance = taskInstances.get(0);
    //创建通用命令
    ExpandTaskCommand expandTaskCommandGeneral=new ExpandTaskCommand();
    //设置命令为领取任务
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

62
63
64
65
66
67
68
69
70
71
72
    // 验证是否成功启动
    assertNotNull(processInstanceId);

    TaskQuery taskQuery = taskService.createTaskQuery();
    // 查找 1200119390 的这个流程实例的当前独占任务
    List<TaskInstance> taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    TaskInstance taskInstance = taskInstances.get(0);
    //启动子流程，并且令牌停留在UserTask_2节点
    assertEquals("UserTask_2", taskInstance.getNodeId());

    //创建一个处理命令
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

82
83
84
85
86
87
88
89
90
91
92
    //设置任务ID
    expandTaskCommand.setTaskId(taskInstance.getId());
    //执行处理命令
    taskService.expandTaskComplete(expandTaskCommand, null);
   
    taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    taskInstance = taskInstances.get(0);
    //令牌停留在UserTask_3节点
    assertEquals("UserTask_3", taskInstance.getNodeId());
   
    //创建一个处理命令
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

102
103
104
105
106
107
108
109
110
111
112
    //设置任务ID
    expandTaskCommand.setTaskId(taskInstance.getId());
    //执行处理命令
    taskService.expandTaskComplete(expandTaskCommand, null);
   
    taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    taskInstance = taskInstances.get(0);
    //令牌停留在UserTask_4节点
    assertEquals("UserTask_4", taskInstance.getNodeId());
  }
}
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

64
65
66
67
68
69
70
71
72
73
74
    // 验证是否成功启动
    assertNotNull(processInstanceId);

    TaskQuery taskQuery = taskService.createTaskQuery();
    // 查找 1200119390 的这个流程实例的当前独占任务
    List<TaskInstance> taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    // 由于是包容网关，设定的金额为1500，同时满足后面两个线条，会发散成两个任务，任务实例应该有2个
    assertEquals(2, taskInstances.size());

    //定义测试通过标志
    boolean result = false;
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

106
107
108
109
110
111
112
113
        tmp = nodeId;
      }
    }

    // 走完两个任务，任务停留在UserTask_5上
    assertEquals("UserTask_5", taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list().get(0).getNodeId());
  }
}
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

68
69
70
71
72
73
74
75
76
77
78
    // 验证是否成功启动
    assertNotNull(processInstanceId);
   
    TaskQuery taskQuery = taskService.createTaskQuery();
    // 查找 1200119390 的这个流程实例的当前独占任务
    List<TaskInstance> taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    //由于是排他网关，只会走后面线条中的一条，所以任务实例应该只有1个
    assertEquals(1, taskInstances.size());
    //根据设置的金额来判断走哪条路线，上面设置的是700，应该走到UserTask_3节点
    assertEquals("UserTask_3", taskInstances.get(0).getNodeId());
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

61
62
63
64
65
66
67
68
69
70
71
    // 验证是否成功启动
    assertNotNull(processInstanceId);

    TaskQuery taskQuery = taskService.createTaskQuery();
    // 查找 1200119390 的这个流程实例的当前独占任务
    List<TaskInstance> taskInstances = taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list();
    // 由于是并行网关，会发散成两个任务，任务实例应该有2个
    assertEquals(2, taskInstances.size());

    // 循环2个任务
    for (int i = 0; i < taskInstances.size(); i++) {
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

86
87
88
89
90
91
92
93
94
95
96
      if (i == 0) {
        // 第一个任务停靠在UserTask_2上
//        assertEquals("UserTask_2", taskInstances.get(i).getNodeId());
        // 第一个任务执行完，应该只剩下一个任务实例了
        assertEquals(1, taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list().size());
      }
      if (i == 1) {
        // 第二个任务停靠在UserTask_3上
//        assertEquals("UserTask_3", taskInstances.get(i).getNodeId());
        // 第二个任务执行完，会走合并的并行网关，应该还有一个任务实例
View Full Code Here

Examples of com.founder.fix.fixflow.core.task.TaskQuery.taskAssignee()

92
93
94
95
96
97
98
99
100
101
102
      }
      if (i == 1) {
        // 第二个任务停靠在UserTask_3上
//        assertEquals("UserTask_3", taskInstances.get(i).getNodeId());
        // 第二个任务执行完，会走合并的并行网关，应该还有一个任务实例
        assertEquals(1, taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list().size());
      }
    }

    // 走完吧、合并的并行网关，任务停留在UserTask_4上
    assertEquals("UserTask_4", taskQuery.taskAssignee("1200119390").processInstanceId(processInstanceId).taskNotEnd().list().get(0).getNodeId());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.