ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update 修改模板管理代码，删除导入模板时增加监听器代码，改用全局监听器

Browse Source
This commit is contained in:
lijiarao
2023-11-28 15:55:05 +08:00
parent 2338148274
commit 4395c29c9b
3 changed files with 1 additions and 76 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules/src/main/java/com/jero/modules/activiti/config/ActivitiConfig.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class ActivitiConfig implements ProcessEngineConfigurationConfigurer {
@Override
public void configure(SpringProcessEngineConfiguration springProcessEngineConfiguration) {
//全局监听器
//springProcessEngineConfiguration.setEventListeners(Collections.singletonList(new MyGlobalEventListener()));
springProcessEngineConfiguration.setEventListeners(Collections.singletonList(new MyGlobalEventListener()));
//有bug 自定义id
//springProcessEngineConfiguration.setIdGenerator(new MyGen());
}
laws-modules/src/main/java/com/jero/modules/activiti/controller/ModelerController.java
-31
View File
@@ -101,37 +101,6 @@ public class ModelerController {
model.setVersion(version);
repositoryService.saveModel(model);
String modelId = model.getId();
List<ActivitiListener> executionListeners = mainProcess.getExecutionListeners();
ActivitiListener startListener = new ActivitiListener();
startListener.setEvent(BaseExecutionListener.EVENTNAME_START);
startListener.setImplementationType("class");
startListener.setImplementation(StartListener.class.getName());
executionListeners.add(startListener);
ActivitiListener endListener = new ActivitiListener();
endListener.setEvent(BaseExecutionListener.EVENTNAME_END);
endListener.setImplementationType("class");
endListener.setImplementation(EndListener.class.getName());
executionListeners.add(endListener);
mainProcess.setExecutionListeners(executionListeners);
//向所有userTask节点增加创建和完成时任务监听器工作
Collection<FlowElement> flowElements = mainProcess.getFlowElements();
for (FlowElement flowElement : flowElements) {
if (flowElement instanceof UserTask) {
UserTask userTask = (UserTask) flowElement;
List<ActivitiListener> taskListeners = userTask.getTaskListeners();
ActivitiListener createListener = new ActivitiListener();
createListener.setEvent(TaskListener.EVENTNAME_CREATE);
createListener.setImplementationType("class");
createListener.setImplementation(CreateListener.class.getName());
taskListeners.add(createListener);
ActivitiListener completeListener = new ActivitiListener();
completeListener.setEvent(TaskListener.EVENTNAME_COMPLETE);
completeListener.setImplementationType("class");
completeListener.setImplementation(CompleteListener.class.getName());
taskListeners.add(completeListener);
userTask.setTaskListeners(taskListeners);
}
}
ObjectNode objectNode = new BpmnJsonConverter().convertToJson(bpmnModel);
repositoryService.addModelEditorSource(modelId, objectNode.toString().getBytes(StandardCharsets.UTF_8));
//生成节点
laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessModelNodeService.java
-44
View File
@@ -172,37 +172,6 @@ public class ProcessModelNodeService extends ServiceImpl<ProcessModelNodeMapper,
}
public Object testAddTaskListener(AddTaskVO addTaskVO) {
try {
String modelId = addTaskVO.getModelId();
String xmlNodeId = addTaskVO.getXmlNodeId();
String nodeName = addTaskVO.getNodeName();
//查询模型
Model model = repositoryService.getModel(modelId);
byte[] modelEditorSource = repositoryService.getModelEditorSource(modelId);
ObjectNode objectNode = (ObjectNode) new ObjectMapper().readTree(modelEditorSource);
BpmnModel bpmnModel = new BpmnJsonConverter().convertToBpmnModel(objectNode);
Process process = bpmnModel.getMainProcess();
UserTask flowElement1 =(UserTask) process.getFlowElement(xmlNodeId);
List<ActivitiListener> taskListeners = flowElement1.getTaskListeners();
for (ActivitiListener taskListener : taskListeners) {
taskListener.setEvent(TaskListener.EVENTNAME_CREATE);
taskListener.setImplementationType("class");
taskListener.setImplementation("com.jero.modules.activiti.listener.CreateListener");
log.info(taskListener.toString());
}
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
public void deleteTask(AddTaskVO addTaskVO) {
try {
String modelId = addTaskVO.getModelId();
@@ -345,19 +314,6 @@ public class ProcessModelNodeService extends ServiceImpl<ProcessModelNodeMapper,
userTask.setName(name);
userTask.setId(id);
userTask.setAssignee("${"+id.replace("-","")+"}");
//增加监听器
List<ActivitiListener> taskListeners = userTask.getTaskListeners();
ActivitiListener createListener = new ActivitiListener();
createListener.setEvent(TaskListener.EVENTNAME_CREATE);
createListener.setImplementationType("class");
createListener.setImplementation(CreateListener.class.getName());
taskListeners.add(createListener);
ActivitiListener completeListener = new ActivitiListener();
completeListener.setEvent(TaskListener.EVENTNAME_COMPLETE);
completeListener.setImplementationType("class");
completeListener.setImplementation(CompleteListener.class.getName());
taskListeners.add(completeListener);
userTask.setTaskListeners(taskListeners);
return userTask;
}
protected static SequenceFlow createSequenceFlow(String from, String to) {