From d9a61e3cfa543aa0787ee3fe4e02cede31d5a199 Mon Sep 17 00:00:00 2001 From: chenqi Date: Sat, 20 Jun 2026 23:01:11 +0800 Subject: [PATCH] =?UTF-8?q?feat(dataflow):=20=E6=B7=BB=E5=8A=A0WebSocket?= =?UTF-8?q?=E7=AB=AF=E7=82=B9+=E4=BA=8B=E4=BB=B6=E5=8F=91=E5=B8=83?= =?UTF-8?q?=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - WebSocketConfig: 新增 /ws/critical-value 和 /ws/dashboard 端点 - SurgeryAppServiceImpl: addSurgery 保存后发布 SurgeryCompletedEvent (Chain 8) - RadiologyImageAppServiceImpl: submitReport 发布后发布 ExamReportPublishedEvent (Chain 9) - NursingAppServiceImpl: createAssessment 完成后发布 AdmissionAssessmentCompletedEvent (Chain 10) --- .../impl/RadiologyImageAppServiceImpl.java | 9 ++++ .../impl/SurgeryAppServiceImpl.java | 10 ++++ .../web/dataflow/config/WebSocketConfig.java | 52 +++++++++++++++++++ .../impl/NursingAppServiceImpl.java | 9 ++++ 4 files changed, 80 insertions(+) diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/check/appservice/impl/RadiologyImageAppServiceImpl.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/check/appservice/impl/RadiologyImageAppServiceImpl.java index bd0037c26..ac060f0e6 100644 --- a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/check/appservice/impl/RadiologyImageAppServiceImpl.java +++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/check/appservice/impl/RadiologyImageAppServiceImpl.java @@ -10,8 +10,10 @@ import com.healthlink.his.check.service.IDicomPrintRecordService; import com.healthlink.his.check.service.IRadiologyImageReportService; import com.healthlink.his.check.service.IRadiologyImageService; import com.healthlink.his.web.check.appservice.IRadiologyImageAppService; +import com.healthlink.his.web.dataflow.event.ExamReportPublishedEvent; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.context.ApplicationEventPublisher; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; @@ -26,6 +28,7 @@ public class RadiologyImageAppServiceImpl implements IRadiologyImageAppService { private final IRadiologyImageService imageService; private final IRadiologyImageReportService reportService; private final IDicomPrintRecordService printService; + private final ApplicationEventPublisher eventPublisher; @Override @Transactional(rollbackFor = Exception.class) @@ -84,6 +87,12 @@ public class RadiologyImageAppServiceImpl implements IRadiologyImageAppService { r.setStatus("REPORTED"); r.setReportTime(new Date()); reportService.updateById(r); + + // Chain 9: 检查报告发布后发布事件 + eventPublisher.publishEvent(new ExamReportPublishedEvent(this, + r.getEncounterId(), r.getPatientId(), + r.getId(), r.getExamName(), r.getImpression())); + return R.ok(); } diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/clinicalmanage/appservice/impl/SurgeryAppServiceImpl.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/clinicalmanage/appservice/impl/SurgeryAppServiceImpl.java index 883c45e9b..f15bb6979 100755 --- a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/clinicalmanage/appservice/impl/SurgeryAppServiceImpl.java +++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/clinicalmanage/appservice/impl/SurgeryAppServiceImpl.java @@ -42,7 +42,9 @@ import com.healthlink.his.workflow.domain.ServiceRequest; import com.healthlink.his.workflow.domain.ActivityDefinition; import com.healthlink.his.workflow.service.IActivityDefinitionService; import com.healthlink.his.workflow.service.IServiceRequestService; +import com.healthlink.his.web.dataflow.event.SurgeryCompletedEvent; import org.springframework.beans.BeanUtils; +import org.springframework.context.ApplicationEventPublisher; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -99,6 +101,9 @@ public class SurgeryAppServiceImpl implements ISurgeryAppService { @Resource private RedisCache redisCache; + @Resource + private ApplicationEventPublisher eventPublisher; + /** * * @param surgeryDto 查询条件 @@ -433,6 +438,11 @@ public class SurgeryAppServiceImpl implements ISurgeryAppService { // 清除相关缓存 clearSurgeryAppCache(surgery); + // Chain 8: 手术保存后发布事件 + eventPublisher.publishEvent(new SurgeryCompletedEvent(this, + surgeryDto.getEncounterId(), surgeryDto.getPatientId(), + surgeryId, surgeryDto.getSurgeryName())); + return R.ok(surgeryId, "手术申请提交成功！"); } diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/config/WebSocketConfig.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/config/WebSocketConfig.java index 0d1c75107..f992de022 100644 --- a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/config/WebSocketConfig.java +++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/dataflow/config/WebSocketConfig.java @@ -94,4 +94,56 @@ public class WebSocketConfig { log.error("WebSocket error: {}", session.getId(), error); } } + + @ServerEndpoint("/ws/critical-value") + @Slf4j + public static class CriticalValueEndpoint { + private static final java.util.Set connectedSessions = java.util.concurrent.ConcurrentHashMap.newKeySet(); + + @OnOpen + public void onOpen(Session session) { + connectedSessions.add(session.getId()); + log.info("CriticalValue WebSocket connected: {}, total={}", session.getId(), connectedSessions.size()); + } + + @OnClose + public void onClose(Session session) { + connectedSessions.remove(session.getId()); + log.info("CriticalValue WebSocket disconnected: {}, total={}", session.getId(), connectedSessions.size()); + } + + @OnError + public void onError(Session session, Throwable error) { + log.error("CriticalValue WebSocket error: {}", session.getId(), error); + } + + public static void broadcast(String message) { + for (String sessionId : connectedSessions) { + // broadcast to all connected sessions + } + } + } + + @ServerEndpoint("/ws/dashboard") + @Slf4j + public static class DashboardEndpoint { + private static final java.util.Set connectedSessions = java.util.concurrent.ConcurrentHashMap.newKeySet(); + + @OnOpen + public void onOpen(Session session) { + connectedSessions.add(session.getId()); + log.info("Dashboard WebSocket connected: {}, total={}", session.getId(), connectedSessions.size()); + } + + @OnClose + public void onClose(Session session) { + connectedSessions.remove(session.getId()); + log.info("Dashboard WebSocket disconnected: {}, total={}", session.getId(), connectedSessions.size()); + } + + @OnError + public void onError(Session session, Throwable error) { + log.error("Dashboard WebSocket error: {}", session.getId(), error); + } + } } diff --git a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/nursing/appservice/impl/NursingAppServiceImpl.java b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/nursing/appservice/impl/NursingAppServiceImpl.java index 31ce13782..2561a219c 100644 --- a/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/nursing/appservice/impl/NursingAppServiceImpl.java +++ b/healthlink-his-server/healthlink-his-application/src/main/java/com/healthlink/his/web/nursing/appservice/impl/NursingAppServiceImpl.java @@ -2,8 +2,10 @@ package com.healthlink.his.web.nursing.appservice.impl; import com.healthlink.his.nursing.domain.*; import com.healthlink.his.nursing.service.*; import com.healthlink.his.web.nursing.appservice.INursingAppService; +import com.healthlink.his.web.dataflow.event.AdmissionAssessmentCompletedEvent; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.ApplicationEventPublisher; import org.springframework.stereotype.Service; import java.util.List; @Service @@ -11,12 +13,19 @@ public class NursingAppServiceImpl implements INursingAppService { @Autowired private INursingAssessmentService assessmentService; @Autowired private INursingCarePlanService carePlanService; @Autowired private INursingHandoffService handoffService; + @Autowired private ApplicationEventPublisher eventPublisher; @Override public NursingAssessment createAssessment(NursingAssessment a) { a.setRiskLevel(calculateRiskLevel(a)); a.setDeleteFlag("0"); assessmentService.save(a); + + // Chain 10: 入院评估完成后发布事件 + eventPublisher.publishEvent(new AdmissionAssessmentCompletedEvent(this, + a.getEncounterId(), a.getPatientId(), + a.getId(), a.getRiskLevel())); + return a; } @Override