wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 调整一些模型定义

Browse Source
This commit is contained in:
wangli 2023-09-25 20:48:41 +08:00
parent d67f2a3083
commit a4ee10adf7
2 changed files with 20 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
workflow-engine-common/src/main/java/cn/axzo/workflow/common/model/response/mq/ProcessTaskDTO.java
View File

@ -40,12 +40,12 @@ public class ProcessTaskDTO implements Serializable {
private String processInstanceId;
/**
* 流程定义中节点 key, 可用于业务识别唯一的审批节点
* 流程定义中当前任务节点 Key
*/
private String currentElementKey;
/**
* 流程定义中节点名称
* 流程定义中当前节点名称
*/
private String currentElementName;
@ -60,12 +60,12 @@ public class ProcessTaskDTO implements Serializable {
private Map<String, Object> variables;
/**
* 流程实例创建时间
* 流程任务创建时间
*/
private Date startTime;
/**
* 流程实例所属租户
* 流程任务所属租户
*/
private String tenantId;

22
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/RocketMqBpmProcessEventListener.java
View File

@ -37,7 +37,10 @@ public class RocketMqBpmProcessEventListener implements BpmProcessEventListener
@Override
public void onCreated(FlowableEngineEntityEvent event) {
log.info("RocketMQ onCreated: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event));
if (log.isDebugEnabled()) {
log.debug("RocketMQ onCreated: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) event.getEntity()).getDeploymentId()).singleResult();
ProcessInstanceDTO dto = new ProcessInstanceDTO()
@ -97,8 +100,10 @@ public class RocketMqBpmProcessEventListener implements BpmProcessEventListener
@Override
public void onCancelled(FlowableCancelledEvent event) {
log.info("RocketMQ onCancelled: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
if (log.isDebugEnabled()) {
log.info("RocketMQ onCancelled: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
}
Deployment deployment =
repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getDeploymentId())
.singleResult();
@ -133,13 +138,18 @@ public class RocketMqBpmProcessEventListener implements BpmProcessEventListener
*/
@Override
public void onRejected(FlowableCancelledEvent event) {
log.info("RocketMQ onRejected: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event));
if (log.isDebugEnabled()) {
log.info("RocketMQ onRejected: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
}
}
@Override
public void onCompleted(FlowableEngineEntityEvent event) {
log.info("RocketMQ onCompleted: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
if (log.isDebugEnabled()) {
log.info("RocketMQ onCompleted: ClassName: {}, event: {}", event.getClass().getName(),
JSON.toJSONString(event));
}
}
@Override