diff --git a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java
index 5d5d3788..a27af970 100644
--- a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java
+++ b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java
@@ -242,4 +242,26 @@ public class RocketMQEventConfiguration {
             super.onEvent(message, eventConsumer);
         }
     }
+
+    /**
+     * 变洽签业务消费单据日志
+     */
+    @Slf4j
+    @Component
+    @RocketMQMessageListener(topic = "topic_nanopart_${spring.profiles.active}",
+            consumerGroup = "GID_visa_change_log_${spring.application.name}_${spring.profiles.active}",
+            consumeMode = ConsumeMode.ORDERLY,
+            nameServer = "${rocketmq.name-server}"
+    )
+    public static class VisaChangeLogListener extends BaseListener implements RocketMQListener<MessageExt> {
+
+        @Autowired
+        private EventConsumer eventConsumer;
+
+        @Override
+        public void onMessage(MessageExt message) {
+            log.info("VisaChangeLogListener onMessage nanopart, message:{}", JSON.toJSONString(message));
+            super.onEvent(message, eventConsumer);
+        }
+    }
 }
diff --git a/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/process/ProcessInstanceAllEventHandler.java b/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/process/ProcessInstanceAllEventHandler.java
new file mode 100644
index 00000000..ab6ff533
--- /dev/null
+++ b/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/process/ProcessInstanceAllEventHandler.java
@@ -0,0 +1,56 @@
+package cn.axzo.visa.server.mq.listener.workflow.process;
+
+import cn.axzo.framework.rocketmq.Event;
+import cn.axzo.framework.rocketmq.EventConsumer;
+import cn.axzo.workflow.common.model.response.mq.ProcessInstanceDTO;
+import cn.axzo.workflow.starter.handler.ProcessInstanceEventHandler;
+import org.springframework.stereotype.Component;
+
+/**
+ * 工作流广播的实例维度的所有事件类型
+ *
+ * @author wangli
+ * @since 2025-01-17 11:35
+ */
+@Component
+public class ProcessInstanceAllEventHandler implements ProcessInstanceEventHandler {
+    @Override
+    public int getOrder() {
+        return Integer.MIN_VALUE;
+    }
+
+    @Override
+    public boolean accept(ProcessInstanceDTO dto, Event event, EventConsumer.Context context) {
+        return ProcessInstanceEventHandler.super.accept(dto, event, context);
+    }
+
+    @Override
+    public void onCreated(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onCreated(dto);
+    }
+
+    @Override
+    public void onStarted(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onStarted(dto);
+    }
+
+    @Override
+    public void onCompleted(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onCompleted(dto);
+    }
+
+    @Override
+    public void onCancelled(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onCancelled(dto);
+    }
+
+    @Override
+    public void onRejected(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onRejected(dto);
+    }
+
+    @Override
+    public void onAborted(ProcessInstanceDTO dto) {
+        ProcessInstanceEventHandler.super.onAborted(dto);
+    }
+}
diff --git a/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/task/ProcessTaskAllEventHandler.java b/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/task/ProcessTaskAllEventHandler.java
new file mode 100644
index 00000000..9e2f683a
--- /dev/null
+++ b/visa/visa-server/src/main/java/cn/axzo/visa/server/mq/listener/workflow/task/ProcessTaskAllEventHandler.java
@@ -0,0 +1,45 @@
+package cn.axzo.visa.server.mq.listener.workflow.task;
+
+import cn.axzo.framework.rocketmq.Event;
+import cn.axzo.framework.rocketmq.EventConsumer;
+import cn.axzo.workflow.common.model.response.mq.ProcessTaskDTO;
+import cn.axzo.workflow.starter.handler.ProcessTaskEventHandler;
+import io.swagger.models.auth.In;
+
+/**
+ * 工作流广播的任务维度的所有事件类型
+ *
+ * @author wangli
+ * @since 2025-01-17 11:34
+ */
+public class ProcessTaskAllEventHandler implements ProcessTaskEventHandler {
+    @Override
+    public int getOrder() {
+        return Integer.MAX_VALUE;
+    }
+
+    @Override
+    public boolean accept(ProcessTaskDTO dto, Event event, EventConsumer.Context context) {
+        return ProcessTaskEventHandler.super.accept(dto, event, context);
+    }
+
+    @Override
+    public void onAssigned(ProcessTaskDTO dto) {
+        ProcessTaskEventHandler.super.onAssigned(dto);
+    }
+
+    @Override
+    public void onCreated(ProcessTaskDTO dto) {
+        ProcessTaskEventHandler.super.onCreated(dto);
+    }
+
+    @Override
+    public void onCompleted(ProcessTaskDTO dto) {
+        ProcessTaskEventHandler.super.onCompleted(dto);
+    }
+
+    @Override
+    public void onDeleted(ProcessTaskDTO dto) {
+        ProcessTaskEventHandler.super.onDeleted(dto);
+    }
+}