重庆市建设岗培中心网站,一个域名做多个网站,餐饮网站建设的目的,河北建设工程造价信息网站#x1f4e2; 大家好#xff0c;我是 【战神刘玉栋】#xff0c;有10多年的研发经验#xff0c;致力于前后端技术栈的知识沉淀和传播。 #x1f497; #x1f33b; CSDN入驻不久#xff0c;希望大家多多支持#xff0c;后续会继续提升文章质量#xff0c;绝不滥竽充数… 大家好我是 【战神刘玉栋】有10多年的研发经验致力于前后端技术栈的知识沉淀和传播。 CSDN入驻不久希望大家多多支持后续会继续提升文章质量绝不滥竽充数欢迎多多交流。 文章目录 写在前面的话背景技术发明目的具体方案消息中心的搭建构建时限质控核心服务实现时限质控辅助板块展示一些实际案例流程图时限质控任务生成流程图时限质控任务关闭时限质控系统总结 方案特征总结陈词 写在前面的话
本篇文章分享一下博主所在公司的时限质控系统的解决方案。 主要是基于Kafka Quartz实现由于涉及公司隐私内容主要以方案介绍为主有需要探讨的可以留言。 好让我们开始。 背景技术
1、医院质控信息系统要求医护人员在日常工作中需按时完成相应的病历书写任务同时必须遵循时效性上的要求该任务的完成情况通常也会被加入绩效考核评估结果。针对上述工作要求从而衍生的功能模块也称为时限质控模块。时限质控主要是对针对入科、取消入科、转科、取消转科、出院、取消出院、病情变化、完成病历书写等业务场景根据对应的病历类型是否完成书写任务以及是否满足时效性要求进行提醒、统计和评分。通过时限质控提醒医护人员可以更直观的接收到病历的书写的时限并在时限内完成病历医务部则可以通过有无超时书写病历来进行质控评分。 2、传统的时限质控系统通常采用“程序定时器轮询”或“数据库触发器”实现两者在实现时限质控功能的同时也都存在若干缺陷。 2.1、程序定时器轮询方式通过定时服务不断轮询关键业务数据表当查询到符合要求的数据则触发时限质控该方式无论从配置和实现上看都不灵活同时耗费服务资源效率较低。 2.2、数据库触发器方式主要通过监听程序执行的DML语句以做出相应操作但触发执行的逻辑功能比较单一只适合于简单的场景无法运行复杂程序。 发明目的
本方案的发明目的是基于Kafka Quartz 实现低耦合、易扩展、高及时性和高灵活性的时限质控方案。通过预先针对时限质控规则进行规则维护、事件管理、质控类别维护等利用相应的触发机制生成或关闭相应任务最终实现时限质控要求。 本方案摒弃了传统的程序定时器轮询或数据库触发器实现方式带来的缺陷将时限质控涉及的临床业务节点定义成一个个事件事件交由具体业务代码在完成相应操作的同时触发消息中心而时限质控的生成任务和关闭任务的服务仅需要被消息中心对应事件主题订阅即可实现。 各业务系统和时限质控系统只需要专注于自身业务逻辑模块之间的通讯统一交由消息中心完成最终达到模块解耦的目的。引入消息中心和事件驱动机制后时限质控的流程是这样的入院模块只需要关注自身逻辑完成入院逻辑后调用消息中心消息中心负责触发时限质控的生成任务服务生成相应文书的书写任务并分发给指定用户。当用户完成相应病历文书的书写工作时病历书写模块在完成自身逻辑后也会触发消息中心消息中心也会负责订阅时限质控的关闭任务服务针对用户的任务按实际时限进行处理。 可以看出整个过程中时限质控系统和各个业务系统都是充分解耦的同时事件主题的发布/订阅模式可以不仅仅局限于时限质控板块也适用于其他更多的业务需求。 具体方案
消息中心的搭建
采用 Kafka Zookeeper 集群作为核心中间件时限质控涉及的相关临床业务事件作为 Topic院内的HIS和EMR系统作为消息生产者时限质控服务作为消费者整体采用Kafka的发布订阅模式。 1、事件模块准备步骤 分析医院信息系统中涉及与时限质控相关的临床业务将这些临床业务定义为一个个事件事件包含事件编号、事件名称、病历文书类型、以及其他关键业务属性等。当信息系统中的临床业务触发后可以通过消息中心快速通知或触发其他系统执行相应操作这个过程是联动并且解耦的。 2、生产者模块实现步骤 创建生产者模块服务该服务提供对外开放接口。当消息中心被调用后执行生产者校验功能包含利用XSD进行消息入参格式校验、依据消息唯一编号进行消息查重校验、以及验证事件的有效性等。校验通过后利用生产者单例去完成消息发送具体就是以指定的事件编号作为Topic投递消息到Kafka。 3、消费者模块实现步骤 创建时限质控的消费者组服务该服务会不断从集群上拉取消息当拉取到订阅消息后将启动新的工作线程进行相应的逻辑处理具体逻辑是调用时限质控核心服务生成或关闭相应任务。
构建时限质控核心服务
时限质控核心服务主要负责时限质控相关任务的生成和关闭该服务订阅了消息中心相应主题当相应业务主题被触发时消费者将调用时限质控核心服务。 时限质控核心服务包含生成任务服务、关闭任务服务、和任务中心三大板块。 1、生成任务服务的实现步骤 1解析消息入参进行合法性校验提取关键信息例如事件主题、患者信息、医生信息等存储至临时变量 2根据事件主题读取相关时限质控规则配置信息根据规则构建相应任务主表任务属性包含但不限于“单次/连续配置”、“超时配置”、“关闭配置”、“提醒配置”、“触发配置”等等 3读取上述规则配置中的接收人配置使用入参传递的患者和医生信息动态替换得出相应接收人列表 4利用 Quartz 产生生成时限质控任务的相应定时器当定时器符合触发要求时将调用任务中心进行后续操作 2、关闭任务服务的实现步骤 1解析消息入参进行合法性校验提取关键信息例如事件主题、患者信息、病历类型等存储至临时变量 2根据事件主题读取相关时限质控规则配置信息根据病历类型和患者信息判断任务是否达到完成标准 3若符合标准则对任务进行关闭操作并根据完成的时间和情况对任务状态进行更新 4利用 Quartz 产生关闭时限质控任务的相应定时器当定时器符合触发要求时将调用任务中心进行后续操作 3、任务中心的实现步骤 1任务中心是最终控制时限质控任务生成和关闭的枢纽质控核心服务中的生成任务和关闭任务服务仅触发相应定时器符合要求时触发任务中心任务中心也负责与前端的交互。 2当任务生成服务的定时器达到触发要求任务中心将根据预置的任务生成配置模板和相应业务入参信息生成相应的任务构建时限质控任务细表数据并使用 WebSocket 等技术推送至前端至此任务生成完毕。 3当任务关闭服务的定时器达到触发要求任务中心将根据患者信息预置的任务关闭配置模板查找符合要求的待关闭任务列表更新时限质控任务细表数据使用 WebSocket 等技术推送至前端对已产生的任务进行关闭操作至此任务关闭完成。
实现时限质控辅助板块
1、实时推送 时限质控任务的生成和关闭都要和用户前端进行实时交互当任务产生的时候需要告知用户前台界面并实时展示出来当任务关闭的时候也需要告知用户前台界面将相应任务进行删除处理。 这种效果可以采用诸如 WebSocket 等的长连接推送模式在浏览器和服务器完成一个握手的动作在建立连接之后服务器可以主动传送数据给客户端客户端也可以随时向服务器发送数据。 使用 WebSocket 等推送模式要考虑其高可用性建立完善的功能机制包含但不限于如下心跳机制、断网自动重连、消息补发机制、离线消息处理、历史消息查询、消息的压缩机制等。 2、任务看板 在医护人员登入之后的前台主界面需要一个专门的组件用于时限质控信息展示该组件可以是一个独立的使用iframe嵌套的html界面。 该组件可以用于展示该用户未完成的时限任务例如如XX患者首次病程需在入院后8小时内完成超时x小时/x小时候超时用户点击该任务即可跳转到该病人的病历书写界面进行病历的创建。 当任务关闭的时候前台界面收到推送消息也可以在该组件针对该任务做出响应例如添加删除线效果。 3、质控统计 时限质控的数据表将会收集到所有产生的用户任务的处理情况需要针对此类数据做出统计分析功能才可以利用时限质控带来的效果例如用于作为输出报表或作为绩效扣分的依据。 质控系统的时限质控统计界面应该包含但不限于如下功能按不同维度查询各类数据、导出各类报表、生成统计图表针对质控情况进行评分质控任务的闭环信息查看以及对后续情况进行预测分析。 统计页面的关键信息包含但不限于时限任务的基本规则属性、参与人员、开始时间、完成的时间、超时完成/超时未完成的时间、任务完成状态等方便质控员清晰地看出病历的整体书写情况。 4、评分判定 时限质控的最终目的是为了规范医疗人员的日常行为引导其满足及时性要求因此通过需要与绩效评分挂钩。 在质控的方案管理界面通过将评分规则与时限质控规则进行绑定在时限质控统计界面对医生超时完成/超时未完成的时限规则进行快速评分。 5、数据修正与定时补推 借助消息中心事件驱动机制实现的实现的时限质控效果在达到解耦灵活的同时我们也需要充分考虑由于消息中间件稳定性引发的数据丢失以及对应的处理方案。 针对时限质控的数据丢失可以考虑增加数据修正功能。在质控的数据修正界面记录了触发失败的时限规则可以对其进行一个重试操作还可以对时限任务进行关闭操作保障了当有配置错误或程序问题导致的任务提醒或关闭异常进行一个手动的修复。 与此同时也可以考虑增加定时补推机制利用定时服务定时去判断是否存在应该生成但是没生成的例如通过日志捕捉业务方触发了相关埋点这种情况给予生成判断应该关闭但是没关闭的例如已经书写了病历但任务没被关闭针对这种情况直接将任务给予关闭。 6、统一定时规则配置 提供统一的质控任务定时规则配置界面不依赖于业务方针对单次指定时间、连续固定时间、连续不规则频率等定时任务产生规则进行统一的配置。针对任务关闭也支持设置业务根据组合Key、互斥关闭等高级功能。
展示一些实际案例
案例1关于“首次病程记录在入院8小时内完成”的时限质控流程 1护士为患者办理“入院登记”该业务的后端接口将在完成相应入院逻辑后触发消息中心的“入院”事件 2由于该“入院”事件订阅了“时限质控 - 生成服务”当该事件对应主题有消息产生时消息中心消费者将拉取相应消息帮触发该时限质控服务 3该“时限质控 - 生成服务”会产生相应的病历文书的时限质控书写任务其中包含“首次病程记录在入院8小时内完成”同时利用消息入参信息查询到该患者的主管医生通过 WebSocket 等实时推送机制将产生的时限质控任务详情推送给指定医生前端系统进而在该医生的工作桌面上将接收到这一推送消息在任务看板等展示组件中生成“首次病程记录在入院8小时内完成”任务 4当该主管医生完成了该患者的首次病程记录的书写在点击“确认完成”按钮的同时将在完成相应书写任务完成的逻辑后还将触发消息中心的“完成病历书写”事件 5由于该“完成病历书写”事件订阅了“时限质控 - 关闭服务”同样的在该事件对应主题有消息产生时消息中心消费者将拉取相应消息帮触发该时限质控服务 6该“时限质控 - 关闭服务”将从消息入参里提取该份病历的患者基本信息、病历类型等元素进而判断是否关闭已产生的病历书写任务若符合关闭要求则根据完成时间针对已产生任务做出时效性评价同时通过 WebSocket 等推送机制将关闭任务的信息推送至指定医生的前端系统做出相应处理例如自动关闭该任务。
流程图时限质控任务生成 流程图时限质控任务关闭 时限质控系统总结
一种基于事件驱动的时限质控系统包括如下步骤 1、业务系统异步触发消息中心的指定事件埋点 2、消费者服务从消息中心拉取消息触发时限质控服务 3、时限质控服务根据事件类型和规则配置判定任务操作是生成还是关闭以此生成对应的定时器 4、定时器满足触发条件后调用任务中心服务生成或关闭对应的任务并推送至用户前台进行相应展示 方案特征
1、基于Kafka Quartz 实现时限质控方案 本方案采用事件驱动架构借助事件消息的通讯作为基础构建完善的时限质控系统。摒弃了传统的程序定时器或数据库触发器实现方式带来的缺陷将时限质控涉及的临床业务节点定义成一个个事件事件交由具体业务代码在完成相应操作的同时触发消息中心时限质控的生成任务和关闭任务的服务仅需要被消息中心对应事件主题订阅即可实现真正做到了低耦合、高内聚的模块化设计。 同时利用 Quartz 作业调度框架实现定时任务生成与关闭的效果。简化了定时任务的管理和调度允许开发人员定义各种不同类型的任务并在指定的时间点或间隔触发它们的执行。Quartz 提供了可靠的任务调度机制确保任务按照预定的计划运行并具备容错和持久化的能力即使在应用程序重启后也能保持任务的状态。 2、时限质控任务的易扩展 由于底层基于事件驱动架构实现若需要增加其他相同或不同业务场景下的时限质控规则无需修改任何时限质控服务代码业务系统至多仅需要触发相应的消息中心事件埋点订阅对应的时限质控服务针对任务的基本属性进行配置即可实现。完全做到灵活便捷的扩展让时限质控服务与业务系统解耦。 总结陈词
上文介绍了博主所在公司的《基于 Kafka Quartz 实现时限质控方案》方案。 后续会逐步分享企业实际开发中的实战经验有需要交流的可以联系博主。
