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

feat - 调整发送 DocChange 事件的实现

Browse Source
This commit is contained in:
wangli 2025-10-10 10:59:19 +08:00
parent bc3e061700
commit 2e7d420ab3
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/doc/DocChangeListener.java
View File

@ -6,8 +6,6 @@ import cn.axzo.workflow.common.enums.DocChangeEventEnum;
import cn.axzo.workflow.common.model.response.mq.DocChangeDTO; import cn.axzo.workflow.common.model.response.mq.DocChangeDTO;
import cn.axzo.workflow.core.conf.CustomEventManager; import cn.axzo.workflow.core.conf.CustomEventManager;
import cn.axzo.workflow.core.engine.event.DocChangeEvent; import cn.axzo.workflow.core.engine.event.DocChangeEvent;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.event.TransactionPhase; import org.springframework.transaction.event.TransactionPhase;
@ -49,12 +47,13 @@ public class DocChangeListener {
.eventCode(DocChangeEventEnum.DOC_CHANGE.getEventCode()) .eventCode(DocChangeEventEnum.DOC_CHANGE.getEventCode())
.targetId(event.getKey()) .targetId(event.getKey())
.targetType(event.getKey()) .targetType(event.getKey())
.data(JSON.toJSONString(DocChangeDTO.builder() .data(DocChangeDTO.builder()
.key(event.getKey()) .key(event.getKey())
.workspaceId(event.getWorkspaceId()) .workspaceId(event.getWorkspaceId())
.newSettings(event.getNewSettings()) .newSettings(event.getNewSettings())
.oldSettings(event.getOldSettings()) .oldSettings(event.getOldSettings())
.build(), SerializerFeature.WriteMapNullValue)) .type(DocChangeEventEnum.DOC_CHANGE)
.build())
.build()); .build());
} }
} }