From dd73bcda87b47bc4c60da7a2a48211672d3bb447 Mon Sep 17 00:00:00 2001
From: chenqi <chen.qi@jin-group.cn>
Date: Sat, 20 Jun 2026 21:29:16 +0800
Subject: [PATCH] =?UTF-8?q?feat(dataflow):=20=E6=96=B0=E5=A2=9EChain9=20?=
 =?UTF-8?q?=E6=A3=80=E6=9F=A5=E2=86=92=E6=8A=A5=E5=91=8A=E2=86=92=E5=8C=BB?=
 =?UTF-8?q?=E5=98=B1=E8=81=94=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/ExamReportPublishedEvent.java       | 27 +++++++++++++++
 .../handler/ExamReportFeedbackHandler.java    | 33 +++++++++++++++++++
 2 files changed, 60 insertions(+)
 create mode 100644 healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/event/ExamReportPublishedEvent.java
 create mode 100644 healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/handler/ExamReportFeedbackHandler.java

diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/event/ExamReportPublishedEvent.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/event/ExamReportPublishedEvent.java
new file mode 100644
index 000000000..ea9373702
--- /dev/null
+++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/event/ExamReportPublishedEvent.java
@@ -0,0 +1,27 @@
+package com.healthlink.his.web.dataflow.event;
+
+import lombok.Getter;
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * Chain 9: 检查→报告→医嘱联动 — 检查报告发布事件
+ */
+@Getter
+public class ExamReportPublishedEvent extends ApplicationEvent {
+
+    private final Long encounterId;
+    private final Long patientId;
+    private final Long reportId;
+    private final String examType;
+    private final String findingSummary;
+
+    public ExamReportPublishedEvent(Object source, Long encounterId, Long patientId,
+                                     Long reportId, String examType, String findingSummary) {
+        super(source);
+        this.encounterId = encounterId;
+        this.patientId = patientId;
+        this.reportId = reportId;
+        this.examType = examType;
+        this.findingSummary = findingSummary;
+    }
+}
diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/handler/ExamReportFeedbackHandler.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/handler/ExamReportFeedbackHandler.java
new file mode 100644
index 000000000..cf81fbc5e
--- /dev/null
+++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/handler/ExamReportFeedbackHandler.java
@@ -0,0 +1,33 @@
+package com.healthlink.his.web.dataflow.handler;
+
+import com.healthlink.his.web.dataflow.event.ExamReportPublishedEvent;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+/**
+ * Chain 9: 检查→报告→医嘱联动 — 检查报告发布后反馈处理
+ */
+@Slf4j
+@Component
+public class ExamReportFeedbackHandler {
+
+    @Async
+    @EventListener
+    public void onExamReportPublished(ExamReportPublishedEvent event) {
+        log.info("Chain9 ExamFeedback: encounterId={}, examType={}, reportId={}",
+                event.getEncounterId(), event.getExamType(), event.getReportId());
+        try {
+            // 1. 将检查结果关联到医嘱
+            // TODO: 更新医嘱执行状态
+
+            // 2. 推送通知给开单医生
+            // TODO: WebSocket推送
+
+            log.info("Chain9 ExamFeedback: feedback recorded for reportId={}", event.getReportId());
+        } catch (Exception e) {
+            log.error("Chain9 ExamFeedback failed: reportId={}", event.getReportId(), e);
+        }
+    }
+}