本文分享自华为云社区《FusionInsight MRS RTD 实时决策引擎在医保行业实践》,作者: pippo 。

背景

据国家医保局曝光台发布,湖南省长沙市望城坡春望医院欺诈骗保案,经长沙市公安局联合医保局调查,发现长沙市望城坡春望医院副院长李某某、院长兼法人刘某某等人存在在药品、化验检查、中药封包治疗等方面骗取医保基金共计人民币4253947.38元的事实。经法院审理判决刘某某有期徒刑10年,并处罚金人民币10万元;处李某某有期徒刑3年,缓刑5年,并处罚金人民币7万元。

这个案件不是个例,按发达国家的测算,医保欺诈的损失率在4%-10%左右。我国医保欺诈的实际损失率很可能高于发达国家。2020年追回医保基金223.1亿元,占全年医保支出的1.06%,可看到其应该还有很大的监管空间。医保基金的损失不但给医保基金收支平衡造成了很大压力,也不利于提高参保人的医保待遇水平。

痛点

《国务院办公厅关于推进医疗保障基金监管制度体系改革》中要求全面建立智能监控制度,并建立和完善医保智能监控系统,加强大数据应用。加强对定点医疗机构临床诊疗行为的引导和审核,强化事前、事中监管。

由于编制限制、经费有限,医保部门长期以来一直缺乏专业化的反欺诈工作队伍,缺乏侦查取证的能力。寄此希望通过监管系统提高监管能力,但当前系统受限于技术能力,不能满足地域性差异化特点,比如某省希望能对6岁儿童在不同等级的医院的医疗费用进行监管就无法获得当前系统支持。

由于系统架构设计问题,无法在合理资源配置下支持高并发处理能力,无法对医疗过程中进行监管和预警,导致只能事后处理。

整体架构如下:

当前风控系统将规则采用硬编码写入业务逻辑中,根据客户要对时间范围进行筛选数据,然后提交批量任务到大数据集群。风控业务提交到大数据集群后,对时间范围内的数据进行分布式进行处理,每条数据进行风控规则判断,将异常数据输出到指定目录。

设计

FusionInsight RTD实时决策引擎主要提供多租户多维度的交易伪冒侦测和风险管理功能。主要与数据接入系统、离线计算系统、主机、业务管理系统、坐席客户端系统产生联系以进行伪冒侦测和风险管理。离线计算系统会定期将批次变量导入到实时决策平台。各渠道交易数据经过数据接入系统整合后,进入实时决策平台进行伪冒侦测,侦测结果将产生伪冒告警通知坐席客户端,坐席客户端侦测专员处理告警,通过实时决策平台调研主机接口对风险的人/片/商户等进行管制或解管制。业务管理员通过业务管理系统对变量和规则等进行配置。

整体架构如下:

架构具有以下特点:

  • 提供RESTful API,基于面向服务的架构。
  • 平台所有业务处理组件均为分布式架构,可水平扩展。
  • 基于内存查询,增量计算,管道模型,快速处理事件流。
  • 遵循大数据lambda架构,实时数据(15天以内)快速查询,历史数据(15天以上)批次处理,通过规则汇总计算结果进行实时决策,可支撑海量数据的实时处理。

实时决策引擎的软件组成部分主要包含:

  • 实时决策 Service:提供实时决策平台的业务安装、布署、运行及业务逻辑的编排能力,是整个实时决策平台的核心组件。采用主备模式布署,保证可用性。
  • 实时决策 Executor:负责平台的业务处理。
  • 实时决策DB:提供了快速大吞吐量的访问能力,并通过存储过程为业务提供了业务逻辑在数据库层快速处理的能力,采用集群方式部署。
  • Containers:提供业务处理容器,是实时决策 BLU的承担体,负责运行实时决策的事件处理业务逻辑,从Kafka接收事件消息,处理业务链辑,访问实时决策DB数据库。Container为实时决策 BLU提供了水平扩展、自动部署、资源隔离的能力。
  • Kafka:消息队列,事件入口和消息出口,为实时决策平台接入多种数据源。
  • DBService组件:为实时决策Service组件提供实时决策系统和业务元数据存储,保证这些数据不丢失,并能快速的访问。
  • FusionInsight Manager:作为运维系统,提供高可靠、安全、容错、易用的集群管理能力,支持BLU的安装部署、集群监控、告警、用户管理、权限管理、审计、服务治理、健康检查、问题定位、升级和补丁等。

针对医保风控,通过实时决策Service定义医保风控规则,保存至实时决策DB中。发布实时决策BLU,通过实时决策Executor进行规则处理。医保事件实时加入到消息队列Kafka中,实时决策BLU从Kafka中获取事件,根据事件定义的各种变量通过实时决策DB的存储过程进行分析,最终给出评分。最后将评分结果发送给消息队列供业务系统消费使用。

从医保事件发生到规则处理,结果发送可以达到毫秒级处理时延,从而能够事前拦截医保欺诈。

实现

采用FusionInsight RTD实时决策系统后,可以对医保相关事件进行实时决策,将医保智能监控系统从事后分析转为事前分析。

比如某省希望能对6岁儿童在不同等级的医院的医疗费用进行监管。具体规则如下:

典型医保规则

6岁儿童药品价格审核,根据医院等级、参保人年龄、药品规定价格,识别出超价药品

特殊门诊违规用药审核,针对某些药品,特殊疾病才可以使用

生育保险单据住院天数异常,属于生育保险规定病种且住院天数5天以内

单张单据药品种类异常,西药和中成药种类数大于6(西药+中成药),或者中药饮片数大于25

非基本医疗保险支付疾病,部分疾病不属于医保报销范围,但单据的医保支付金额大于0

根据规则定义输入和输出结果内容。

6岁儿童药品价格审核信息如下:

在FusionInsight RTD中定义表结构和实时变量,同时对药品价格审核逻辑进行实时变量定义。

整体数据流转变为实时处理,实时决策。

效果

环境搭建

通过FusionInsight Manager安装MRS集群,其中部署Kafka、RTD、MOTService、Container服务。

规则创建

  • 通过FusionInsight Manager创建用户

  • 在RTD Service中创建租户

  • 关联用户与租户

  • 建表

  • 创建维度

  • 创建事件源

  • 创建实时变量

实时决策

总结

华为云FusionInsight MRS云原生数据湖为政企客户提供湖仓一体、云原生的数据湖解决方案,构建一个架构可持续演进的离线、实时、逻辑三种数据湖,支撑政企客户全量数据的实时分析、离线分析、交互查询、实时检索、实时决策、多模分析、数据仓库、数据接入和治理等大数据应用场景。

通过引入FusionInsight RTD实时决策系统,实现医保费用事前预防、事中控制、事后审核的全流程管理。从而将医保监管系统建设成既符合医保智能监管平台需求且具备未来信息化标准拓展能力,同时又能满足国家对智能监控的各项要求,最终实现先进的医保智能监管体系。

实例讲解FusionInsight MRS RTD 实时决策引擎在医保行业应用相关推荐

  1. 华为云FusionInsight MRS:助力企业构建“一企一湖,一城一湖”

    摘要:华为云FusionInsight MRS新一代的数据湖,让大数据越用越快.越用越易.越用越稳.越用越省!让数据价值近在眼前! 10月30日,以"携手共赢·数创未来"为主题的第 ...

  2. 决策引擎应用场景的特性

    决策引擎的应用场景的特性通常包括: 复杂的决策问题:决策引擎通常适用于那些复杂的决策问题,比如多维度的决策,以及众多决策因素的评估. 数据密集型:决策引擎通常需要大量的数据来建模和评估不同的决策方案. ...

  3. HIS系统门急诊医保实时结算接口测试

    本文由Markdown语法编辑器编辑完成. 1. 医保实时结算 医保实时结算,关键是"实时"两个字.意思就是说,当医保患者持医保卡到患者指定的医保定点医院,从门诊挂号.看病到取药等 ...

  4. 实时智能决策引擎在蚂蚁金服风险管理中的实践

    摘要:以"数字金融新原力(The New Force of Digital Finance)"为主题,蚂蚁金服ATEC城市峰会于2019年1月4日上海如期举办.金融智能专场分论坛上 ...

  5. 决策引擎的内核及基于Drools开源引擎讲解

    互联网时代,极速放贷.无需面签.10秒可取等词语成了招揽客户的关键词.此外,网购时平台一般都会提供分期付款.在这背后,风控平台每天收到无数笔申请贷款或分期支付的请求,是批准还是拒绝?金融借贷/支付与科 ...

  6. 金融科技大数据产品推荐:恒丰银行实时智能决策引擎

    恒丰银行实时智能决策引擎是恒丰银行业务策略管理解决方案的核心产品,该产品让策略业务人员轻松高效地配置出风控.反欺诈.实时营销等场景下实时.准实时的决策模型/规则 官网 | www.datayuan.c ...

  7. 实时智能决策引擎在蚂蚁金服风险管理中的实践 1

    摘要:以"数字金融新原力(The New Force of Digital Finance)"为主题,蚂蚁金服ATEC城市峰会于2019年1月4日上海如期举办.金融智能专场分论坛上 ...

  8. FusionInsight MRS:你的大数据“管家”

    本文分享自华为云社区<HDC.Cloud2021 一文回顾华为云FusionInsight MRS云原生数据湖亮点>,原文作者:沙漏. 2021年4月26日,HDC.Cloud2021(华 ...

  9. 一文讲清楚FusionInsight MRS CDL如何使用

    摘要:CDL是一种简单.高效的数据实时集成服务,能够从各种OLTP数据库中抓取Data Change事件,然后推送至Kafka中,最后由Sink Connector消费Topic中的数据并导入到大数据 ...

最新文章

  1. [转载] 淘宝旺铺扶植版如何添加背景音乐
  2. POJ 1321 棋盘问题 题解
  3. 《信息学奥赛一本通》 高精度减法。输入两个正整数,求它们的差。
  4. puppet应用原理及安装部署
  5. tar打包时排除一些文件或者目录
  6. centos双系统只有linux,Centos添加Windows/Centos双系统启动
  7. ubuntu20.04自带python版本_替换 ubuntu 自带的python版本
  8. 周末之个人杂想(四)
  9. 产品经理应该先写需求文档还是先画原型?
  10. C++面向对象程序设计课程笔记(第三周)
  11. APP审核关于3.2.1金融资格的审核回复苹果
  12. 原生 遍历_ECMAScript 6 入门教程—异步遍历器
  13. Docker Centos安装Openssh
  14. WORD图片打印预览没有
  15. 转载-MATLAB中将数据写入TXT文本文档中
  16. Ultimaker_Cura-4.8-Win版本软件下载与安装
  17. html的重置按钮reset无反应,reset() 按钮没有反应???
  18. GNSS/INS组合导航(九):三维简化的INS/GPS组合导航系统
  19. office文件图标显示不正常
  20. emd matlab工具箱,Matlab-EMD工具箱

热门文章

  1. linux刻录光盘空间不足,Linux下的光盘刻录技巧
  2. 解决外网与内网或内网之间的通信,NAT穿透
  3. 百度网盘Linux版本能用吗,百度网盘Linux版使用体验效果
  4. html倒计时的原理,JS实现活动精确倒计时 - 轩枫阁
  5. Ubuntu14.04搭建LXR本地服务器阅读Linux内核代码
  6. Android之Wifi使用
  7. !include: could not find: nsProcess.nsh
  8. 原理 + 代码 | Apriori 算法与基于关联规则的购物篮推荐
  9. 处nm是什么意思_“nm”是什么意思啊?
  10. has leaked window com.android.internal.policy.impl.PhoneWindow解决(Dialog.cancel、dismiss、hide区别)