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-12-08 10:08:52 +08:00
parent 842552a4f0
commit ee8156be52
3 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-common/src/main/java/cn/axzo/workflow/common/model/request/bpmn/BpmnJsonNodeProperty.java
View File

@ -119,9 +119,9 @@ public class BpmnJsonNodeProperty {
private List<BpmnConditionGroup> groups; private List<BpmnConditionGroup> groups;
/** /**
* 条件节点专属属性: 条件组之间的计算模型,目前仅支持 and * 条件节点专属属性: 条件组之间的计算模型,目前仅支持 or
*/ */
@ApiModelProperty(value = "条件组之间的计算模型,目前仅支持 and") @ApiModelProperty(value = "条件组之间的计算模型,目前仅支持 or")
private String groupsType = "or"; private String groupsType = "or";
//************* 条件节点End **************// //************* 条件节点End **************//

2
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java
View File

@ -134,7 +134,7 @@ public class EngineProcessInstanceEventListener extends AbstractFlowableEngineEv
assigner, noticeConfig.orElse(null), assigner, noticeConfig.orElse(null),
processInstance.getProcessInstanceId(), processInstance.getTenantId(), null); processInstance.getProcessInstanceId(), processInstance.getTenantId(), null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("发送站内信: {}", com.alibaba.fastjson.JSON.toJSONString(event)); log.debug("发送站内信: {}", com.alibaba.fastjson.JSON.toJSONString(messagePushEvent));
} }
eventDispatcher.dispatchEvent(messagePushEvent, processEngineConfiguration.getEngineCfgKey()); eventDispatcher.dispatchEvent(messagePushEvent, processEngineConfiguration.getEngineCfgKey());
} }

9
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/MessagePushProcessEventListener.java
View File

@ -3,6 +3,7 @@ package cn.axzo.workflow.server.controller.listener.process;
import cn.axzo.workflow.common.model.request.bpmn.BpmnNoticeConf; import cn.axzo.workflow.common.model.request.bpmn.BpmnNoticeConf;
import cn.axzo.workflow.core.common.utils.BpmnMetaParserHelper; import cn.axzo.workflow.core.common.utils.BpmnMetaParserHelper;
import cn.axzo.workflow.core.engine.event.MessagePushEventBuilder; import cn.axzo.workflow.core.engine.event.MessagePushEventBuilder;
import cn.axzo.workflow.core.engine.event.MessagePushEventImpl;
import cn.axzo.workflow.core.engine.event.MessagePushEventType; import cn.axzo.workflow.core.engine.event.MessagePushEventType;
import cn.axzo.workflow.core.listener.BpmnProcessEventListener; import cn.axzo.workflow.core.listener.BpmnProcessEventListener;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
@ -50,11 +51,13 @@ public class MessagePushProcessEventListener implements BpmnProcessEventListener
Optional<BpmnNoticeConf> optNoticeConfig = Optional<BpmnNoticeConf> optNoticeConfig =
BpmnMetaParserHelper.getNoticeConfig(ProcessDefinitionUtil.getProcess(event.getProcessDefinitionId())); BpmnMetaParserHelper.getNoticeConfig(ProcessDefinitionUtil.getProcess(event.getProcessDefinitionId()));
optNoticeConfig.ifPresent(noticeConfig -> { optNoticeConfig.ifPresent(noticeConfig -> {
MessagePushEventBuilder.createEvent(MessagePushEventType.PENDING_COMPLETE, null, noticeConfig, event.getProcessInstanceId(), null, null); MessagePushEventImpl messagePushEvent =
MessagePushEventBuilder.createEvent(MessagePushEventType.PENDING_COMPLETE, null, noticeConfig,
event.getProcessInstanceId(), null, null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("发送完成待办的消息: {}", JSON.toJSONString(event)); log.debug("发送完成待办的消息: {}", JSON.toJSONString(messagePushEvent));
} }
eventDispatcher.dispatchEvent(event, processEngineConfiguration.getEngineCfgKey()); eventDispatcher.dispatchEvent(messagePushEvent, processEngineConfiguration.getEngineCfgKey());
}); });
} }