Flowable源码地址：https://github.com/flowable/flowable-engine

包路径：org.flowable.engine.test.api.event

DatabaseEventLoggerTest 数据库事件日志测试类

public class DatabaseEventLoggerTest extends PluggableFlowableTestCase {protected EventLogger databaseEventLogger;protected ObjectMapper objectMapper = new ObjectMapper();@BeforeEachprotected void setUp() throws Exception {// 数据库事件日志设置databaseEventLogger = new EventLogger(processEngineConfiguration.getClock(), processEngineConfiguration.getObjectMapper());runtimeService.addEventListener(databaseEventLogger);}@AfterEachprotected void tearDown() throws Exception {// 数据库事件日志移除runtimeService.removeEventListener(databaseEventLogger);}...// 测试没有租户的数据库事件@Testpublic void testDatabaseEventsNoTenant() throws IOException {String deploymentId = repositoryService.createDeployment().addClasspathResource("org/flowable/engine/test/api/event/DatabaseEventLoggerProcess.bpmn20.xml").deploy().getId();// 运行进程以收集数据ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("DatabaseEventLoggerProcess", CollectionUtil.singletonMap("testVar", "helloWorld"));// 验证事件日志条目List<EventLogEntry> eventLogEntries = managementService.getEventLogEntries(null, null);String processDefinitionId = processInstance.getProcessDefinitionId();Iterator<EventLogEntry> iterator = eventLogEntries.iterator();while (iterator.hasNext()) {EventLogEntry entry = iterator.next();if (entry.getProcessDefinitionId() != null && !entry.getProcessDefinitionId().equals(processDefinitionId)) {iterator.remove();}}assertThat(eventLogEntries).hasSize(15);for (int i = 0; i < eventLogEntries.size(); i++) {EventLogEntry entry = eventLogEntries.get(i);if (i == 0) {assertThat(FlowableEngineEventType.VARIABLE_CREATED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 流程实例开始if (i == 1) {assertThat(entry.getType()).isEqualTo("PROCESSINSTANCE_START");Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 活动开始if (i == 2 || i == 5 || i == 9 || i == 12) {assertThat(FlowableEngineEventType.ACTIVITY_STARTED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 离开开始if (i == 3) {assertThat(FlowableEngineEventType.ACTIVITY_COMPLETED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 顺序流if (i == 4 || i == 7 || i == 8) {assertThat(FlowableEngineEventType.SEQUENCEFLOW_TAKEN.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 离开并行网关if (i == 6) {assertThat(FlowableEngineEventType.ACTIVITY_COMPLETED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}// 任务if (i == 11 || i == 14) {assertThat(FlowableEngineEventType.TASK_CREATED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}if (i == 10 || i == 13) {assertThat(FlowableEngineEventType.TASK_ASSIGNED.name()).isEqualTo(entry.getType());Map<String, Object> data = objectMapper.readValue(entry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).doesNotContainKey(Fields.TENANT_ID);}}repositoryService.deleteDeployment(deploymentId, true);// 清除for (EventLogEntry eventLogEntry : managementService.getEventLogEntries(null, null)) {managementService.deleteEventLogEntry(eventLogEntry.getLogNumber());}}// 测试独立的任务事件@Testpublic void testStandaloneTaskEvents() throws JsonParseException, JsonMappingException, IOException {org.flowable.task.api.Task task = taskService.newTask();task.setAssignee("kermit");task.setTenantId("myTenant");taskService.saveTask(task);List<EventLogEntry> events = managementService.getEventLogEntries(null, null);assertThat(events).hasSize(2);assertThat(events.get(0).getType()).isEqualTo("TASK_ASSIGNED");assertThat(events.get(1).getType()).isEqualTo("TASK_CREATED");for (EventLogEntry eventLogEntry : events) {Map<String, Object> data = objectMapper.readValue(eventLogEntry.getData(), new TypeReference<HashMap<String, Object>>() {});assertThat(data).containsEntry(Fields.TENANT_ID, "myTenant");}// 清除taskService.deleteTask(task.getId(), true);for (EventLogEntry eventLogEntry : managementService.getEventLogEntries(null, null)) {managementService.deleteEventLogEntry(eventLogEntry.getLogNumber());}}
}