当前位置：首页 > news >正文

DRG/DIP 2.0时代下基于PostgreSQL的成本管理实践与探索（下）

news 来源：原创 2025/5/25 13:22:33

五、数据处理与 ETL 流程编程实现

5.1 数据抽取与转换（ETL）

在 DRG/DIP 2.0 时代的医院成本管理中，数据抽取与转换（ETL）是将医院各个业务系统中的原始数据转化为可供成本管理分析使用的关键环节。这一过程涉及从医院 HIS 系统中抽取患者诊疗数据，并对其进行格式转换、字段映射等处理，以满足后续成本核算和分析的需求。

医院 HIS 系统是医院信息化管理的核心，包含患者诊疗的全方位信息，如患者基本信息、诊疗记录、费用明细等。与 HIS 系统对接时，可采用 API 接口或中间库的方式进行数据抽取。使用 API 接口对接时，需先与 HIS 系统的开发团队沟通，获取详细的接口文档，明确接口的请求方式（如 GET、POST）、请求参数以及返回数据的格式（如 JSON、XML）。以获取患者诊疗信息为例，若 HIS 系统提供的 API 接口为https://his.example.com/api/patient_info，请求方式为 POST，请求参数为患者的住院号inpatient_no，则在 PostgreSQL 中可使用http_request函数（需安装相关扩展，如http_post）来发送请求，示例代码如下：

-- 安装http_post扩展（若未安装）CREATE EXTENSION IF NOT EXISTS http_post;-- 发送POST请求获取患者诊疗信息SELECT http_post('https://his.example.com/api/patient_info',    '{"inpatient_no": "20230101001"}',    'Content-Type: application/json');

上述代码通过http_post函数向 HIS 系统的 API 接口发送 POST 请求，传递患者住院号信息，接口返回的患者诊疗信息可进一步处理和存储到 PostgreSQL 数据库中。

采用中间库方式对接时，HIS 系统将数据定期同步到中间库（如 MySQL 数据库），PostgreSQL 再从中间库中抽取数据。可以使用dblink扩展来实现跨数据库连接和数据抽取。假设中间库为 MySQL，已安装mysql_fdw扩展并配置好连接参数，示例代码如下：

-- 安装mysql_fdw扩展（若未安装）CREATE EXTENSION IF NOT EXISTS mysql_fdw;-- 创建外部服务器CREATE SERVER his_mysql_server    FOREIGN DATA WRAPPER mysql_fdw    OPTIONS (host '192.168.1.100', port '3306', dbname 'his_database');-- 创建用户映射CREATE USER MAPPING FOR current_user    SERVER his_mysql_server    OPTIONS (username 'his_user', password 'his_password');-- 导入中间库中的患者诊疗信息表IMPORT FOREIGN SCHEMA his_schema    LIMIT TO (patient_info)    FROM SERVER his_mysql_server INTO public;

上述代码通过mysql_fdw扩展创建了与 MySQL 中间库的连接，导入了中间库中的患者诊疗信息表到 PostgreSQL 数据库中，以便后续进行数据处理。

从 HIS 系统抽取的数据往往需要进行格式转换和字段映射，以符合成本管理系统的数据模型。数据格式转换方面，日期格式可能在 HIS 系统中以不同的格式存储，如YYYY-MM-DD、MM/DD/YYYY等，而成本管理系统要求统一的日期格式。在 PostgreSQL 中，可使用to_date函数进行日期格式转换，示例代码如下：

-- 将HIS系统中格式为MM/DD/YYYY的日期转换为YYYY-MM-DD格式UPDATE patient_infoSET admission_date = to_date(his_admission_date, 'MM/DD/YYYY')WHERE his_admission_date ~ '^\d{2}/\d{2}/\d{4}$';

字段映射是将 HIS 系统中的字段对应到成本管理系统中的字段。HIS 系统中的患者姓名字段可能为patient_name，而成本管理系统中为name，则可通过UPDATE语句进行字段映射，示例代码如下：

-- 字段映射，将HIS系统中的patient_name映射到成本管理系统中的nameUPDATE patient_infoSET name = his_patient_name;

在实际应用中，可能还需要处理复杂的数据结构，如 HIS 系统中可能将患者的多个诊断信息存储在一个字段中，以逗号分隔，而成本管理系统要求将每个诊断信息存储在单独的字段或数组中。可使用string_to_array函数将逗号分隔的诊断信息拆分为数组，示例代码如下：

-- 将HIS系统中逗号分隔的诊断信息拆分为数组UPDATE patient_infoSET diagnosis_array = string_to_array(his_diagnoses, ',');

通过以上数据抽取与转换的编程实现，能够将医院 HIS 系统中的原始数据转化为符合成本管理系统要求的数据格式和结构，为后续的成本核算、分析和管理提供准确、可靠的数据基础。

5.2 时间窗口处理与增量抽取

在医院成本管理系统中，数据的持续更新和增长是常态。为了减少系统负载，提高数据处理效率，按医保结算周期（如月度）进行增量抽取数据是一种行之有效的方法。这种方法能够避免每次都对全量数据进行处理，仅抽取自上次抽取时间点以来发生变化的数据，从而显著降低数据传输和处理的工作量。

在 PostgreSQL 中，实现时间窗口处理和增量抽取可以借助数据库的时间戳字段和相关的查询语句。假设患者诊疗信息表PatientInfo中有一个UpdateTime字段，记录了每条记录的最后更新时间。要实现每月的增量抽取，可以使用以下步骤和代码示例：

首先，确定时间窗口。以月度为例，获取当前月份的起始时间和结束时间。在 PostgreSQL 中，可以使用date_trunc函数和generate_series函数来生成时间窗口。获取当前月份的起始时间和结束时间的代码如下：

-- 获取当前月份的起始时间SELECT date_trunc('month', current_date) INTO start_date;-- 获取当前月份的结束时间SELECT (date_trunc('month', current_date) + INTERVAL '1 month - 1 day') INTO end_date;

上述代码中，date_trunc('month', current_date)函数将当前日期截断到月份，得到当前月份的起始时间，存储在start_date变量中。(date_trunc('month', current_date) + INTERVAL '1 month - 1 day')则是在当前月份起始时间的基础上加上 1 个月再减去 1 天，得到当前月份的结束时间，存储在end_date变量中。

接下来，根据时间窗口进行增量抽取。使用WHERE子句结合UpdateTime字段来筛选出在时间窗口内更新的记录。从PatientInfo表中抽取当前月份更新的患者诊疗信息的代码如下：

-- 从PatientInfo表中抽取当前月份更新的记录SELECT *FROM PatientInfoWHERE UpdateTime BETWEEN start_date AND end_date;

上述代码通过BETWEEN运算符，筛选出UpdateTime字段在start_date和end_date之间的记录，即当前月份更新的患者诊疗信息。

在实际应用中，还可以结合INSERT INTO...SELECT语句，将增量抽取的数据插入到另一个表中，用于后续的处理和分析。将当前月份更新的患者诊疗信息插入到MonthlyPatientInfo表中的代码如下：

-- 将当前月份更新的记录插入到MonthlyPatientInfo表中INSERT INTO MonthlyPatientInfoSELECT *FROM PatientInfoWHERE UpdateTime BETWEEN start_date AND end_date;

上述代码将从PatientInfo表中筛选出的当前月份更新的记录插入到MonthlyPatientInfo表中，方便对每月的增量数据进行单独处理和分析。

为了确保每次增量抽取的准确性和连续性，可以记录上次抽取的时间点。在每次抽取完成后，更新记录的时间点，以便下次抽取时能够准确获取自上次抽取以来的增量数据。可以使用一个单独的表来记录抽取时间点，假设该表名为ETLTimeStamp，包含TableName（表名）和LastExtractTime（上次抽取时间）字段。更新和获取抽取时间点的代码如下：

-- 更新ETLTimeStamp表中PatientInfo表的上次抽取时间为当前月份的结束时间UPDATE ETLTimeStampSET LastExtractTime = end_dateWHERE TableName = 'PatientInfo';-- 从ETLTimeStamp表中获取PatientInfo表的上次抽取时间SELECT LastExtractTimeFROM ETLTimeStampWHERE TableName = 'PatientInfo';

上述代码中，第一条UPDATE语句将ETLTimeStamp表中PatientInfo表的LastExtractTime更新为当前月份的结束时间，以便下次抽取时能够准确获取自上次抽取以来的增量数据。第二条SELECT语句则是从ETLTimeStamp表中获取PatientInfo

DRG/DIP 2.0时代下基于PostgreSQL的成本管理实践与探索（下）

五、数据处理与 ETL 流程编程实现 5.1 数据抽取与转换（ETL）在 DRG/DIP 2.0 时代的医院成本管理中，数据抽取与转换（ETL）是将医院各个业务系统中的原始数据转化为可供成本管理分析使用的关键环节。这一过程涉及从医院 HIS 系统中抽取患者诊疗数据，并对其进行格式转换、字…...

编程日记 2025/5/25 13:22:33

【设计模式-行为型】状态模式

一、什么是状态模式什么是状态模式呢，这里我举一个例子来说明，在自动挡汽车中，挡位的切换是根据驾驶条件（如车速、油门踏板位置、刹车状态等）自动完成的。这种自动切换挡位的过程可以很好地用状态模式来描述。状态模式…...

编程日记 2025/5/25 12:37:28

想品客老师的第六天：函数

函数基础的部分写在这里函数声明在js里万物皆对象，函数也可以用对象的方式定义 let func new Function("title", "console.log(title)");func(我是参数title); 也可以对函数赋值： let cms function (title) {console.log(tit…...

编程日记 2025/5/25 12:50:22

hedfs和hive数据迁移后校验脚本

先谈论校验方法，本人腾讯云大数据工程师。 1、hdfs的校验这个通常就是distcp校验，hdfs通过distcp迁移到另一个集群，怎么校验你的对不对。有人会说，默认会有校验CRC校验。我们关闭了，为什么关闭？全量迁…...

编程日记 2025/5/24 15:42:24

面向通感一体化的非均匀感知信号设计

文章目录 1 非均匀信号设计的背景分析1.1 基于OFDM波形的感知信号1.2 非均匀信号设计的必要性和可行性1.2 非均匀信号设计的必要性和可行性 3 通感一体化系统中的非均匀信号设计方法3.1 非均匀信号的设计流程（1）均匀感知信号设计（2&#xff0…...

编程日记 2025/5/25 11:35:15

React将props传递给一个组件

React 组件通讯：从单向数据流到跨层级交互的深度实践 ——基于 Props 的通讯机制解析与高阶模式探索一、Props 的本质：不可变数据管道 React 的 props（properties）机制构建了单向数据流的核心范式。每个父组件通过 props 向子…...

编程日记 2025/5/25 11:30:32

头歌实训作业算法设计与分析-贪心算法(第2关：最优装载问题)

任务描述有一批集装箱要装上一艘载重量为C的轮船，共有n个集装箱，其中集装箱i的重量为Wi。最优装载问题要求确定在装载体积不受限制的情况下，将尽可能多的集装箱装上轮船。测试说明输入和输出说明： 第1行为集装箱数目n和载重限…...

编程日记 2025/5/25 12:32:42

HarmonyOS基于ArkTS卡片服务

卡片服务前言 Form Kit（卡片开发框架）提供了一种在桌面、锁屏等系统入口嵌入显示应用信息的开发框架和API，可以将应用内用户关注的重要信息或常用操作抽取到服务卡片（以下简称“卡片”）上，通过将卡片添加…...

编程日记 2025/5/25 6:41:07

Elasticsearch 性能测试工具 Loadgen 之 001——部署及应用详解

在现代软件开发中，性能测试是确保应用程序稳定性和响应速度的关键环节。今天，我们就来深入了解一款国产化功能强大的 Elasticsearch 负载测试工具——INFINI Loadgen。一、INFINI Loadgen 简介 Github地址：https://github.com/infinilabs/l…...

编程日记 2025/5/25 11:31:56

Python算法详解：动态规划

动态规划（Dynamic Programming，简称 DP）是计算机科学中一种高效解决问题的算法思想。它通过将复杂问题分解为更小的子问题，记录中间结果，避免重复计算，从而提升效率。本文将从动态规划的基础思想出发&#…...

编程日记 2025/5/25 13:05:16

python3+TensorFlow 2.x（二）回归模型

目录回归算法 1、线性回归 (Linear Regression) 一元线性回归举例 2、非线性回归 3、回归分类回归算法回归算法用于预测连续的数值输出。回归分析的目标是建立一个模型，以便根据输入特征预测目标变量，在使用 TensorFlow 2.x 实现线性回归模型时&…...

编程日记 2025/5/25 6:41:35

lombok 没生效 java: 找不到符号符号: 方法 setName(java.lang.String)

今天使用lombok 添加了 Data注解 set方法却没起效解决方法 1 给lombok 添加版本号再maven刷新下 <dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.8</version><optional>…...

编程日记 2025/5/25 13:06:51

uiautomator2教程

一、简介 uiautomator2 是一个 Python 库，用于 Android 的 UI 自动化测试，底层基于 Google uiautomator。二、安装 1、安装adb 2、pip install uiautomator2 3、设备安装 atx - agent，python -m uiautomator2 init 4、安装weditor&…...

编程日记 2025/5/20 22:30:36

旅游风景的代码项目

敦煌莫高窟：用代码打开千年艺术的大门 ——一个零基础也能看懂的神奇项目前言：当古老艺术遇上现代代码想象一下，你坐在电脑前，指尖轻轻一点，就能穿越到敦煌莫高窟——看飞天的衣袂飘飘、听千年的驼铃声声。这不是科…...

编程日记 2025/5/25 13:14:39

【后端开发】字节跳动青训营之性能分析工具pprof

性能分析工具pprof 一、测试程序介绍二、pprof工具安装与使用2.1 pprof工具安装2.2 pprof工具使用资料链接： 项目代码链接实验指南pprof使用指南一、测试程序介绍 package mainimport ("log""net/http"_ "net/http/pprof" // 自…...

编程日记 2025/5/25 13:09:39

【测试】-- 认识测试

1. 软件测试定义软件测试就是验证软件产品特性（功能、性能、界面、易用性等）是否满足用户的需求。 2. 测试的岗位软件测试开发工程师（测开） 开发：开发测试效率工具（自动化、性能测试、覆盖率等&#x…...

编程日记 2025/5/25 11:50:47

浏览器hid 和蓝牙bluetooth技术区别

HID与蓝牙技术区别引言在前端开发中，与外部设备的交互越来越重要，尤其是在移动设备和物联网设备日益普及的今天。HID（Human Interface Device）和蓝牙（Bluetooth）是两种常用的技术，用于实现设备…...

编程日记 2025/5/25 11:10:28

PCIE模式配置

对于VU系列FPGA，当DMA/Bridge Subsystem for PCI Express IP配置为Bridge模式时，等同于K7系列中的AXI Memory Mapped To PCI Express IP。...

编程日记 2025/5/25 12:35:46

mysql 学习3 SQL语句--整体概述。SQL通用语法；DDL创建数据库，查看数据库，删除数据库，使用数据库；

SQL通用语法 SQL语句分类 DDL data definition language : 用来创建数据库，创建表，创建表中的字段，创建索引。因此成为数据定义语言 DML data manipulation language 有了数据库和表以及字段后，那么我们就需要给这个表中添加数…...

编程日记 2025/5/22 10:13:24

Swing使用MVC模型架构

什么是MVC模式？ MVC是一组英文的缩写，其全名是Model-View-Controller，也就是“模型-视图-控制器”这三个部分组成。这三个部分任意一个部分发生变化都会引起另外两个发生变化。三者之间的关系示意图如下所示： MVC分为三个部分，所以在MVC模型中将按照此三部分分成三…...

编程日记 2025/5/16 14:55:41

Java定时任务实现方案(二)——ScheduledExecutorService

这篇笔记，我们要来介绍实现Java定时任务的第二个方案，使用ScheduledExecutorService，以及该方案的优点和缺点。 ScheduledExecutorService是Java并发包java.util.concurrent中用于执行定时任务和周期性任务的接口，它拓展了Executo…...

编程日记 2025/5/20 4:40:25

Agent群舞，在亚马逊云科技搭建数字营销多代理(Multi-Agent)（下篇）

在本系列的上篇中，小李哥为大家介绍了如何在亚马逊云科技上给社交数字营销场景创建AI代理的方案，用于社交动态的生成和对文章进行推广曝光。在本篇中小李哥将继续本系列的介绍，为大家介绍如何创建主代理，将多个子代理挂载到主代理…...

编程日记 2025/5/20 20:40:12

Leecode刷题C语言之收集所有金币可获得的最大积分

执行结果:通过执行用时和内存消耗如下： int dfs(int node, int parent, int f, int* coins, int k, int **children, int *childCount, int **memo) {if (memo[node][f] ! -1) {return memo[node][f];}int res0 (coins[node] >> f) - k;int res1 coins[no…...

编程日记 2025/5/24 10:29:14

STM32_SD卡的SDIO通信_基础读写

本篇将使用CubeMXKeil, 创建一个SD卡读写的工程。目录一、SD卡要点速读二、SDIO要点速读三、SD卡座接线原理图四、CubeMX新建工程五、CubeMX 生成 SD卡的SDIO通信部分六、Keil 编辑工程代码七、实验效果实现效果，如下图： 一、SD卡速读…...

编程日记 2025/5/24 2:43:11

新手理解：Android 中 Handler 和 Thread.sleep 的区别及应用场景

新手理解：Android 中 Handler 和 Thread.sleep 的区别及应用场景 Handler 是啥？Handler 的几个核心功能： Thread.sleep 是啥？Thread.sleep 的核心特点： 两者的区别它们的应用场景1. Handler 的应用场景2. Thread.sleep…...

编程日记 2025/5/23 10:36:13

C语言-----扫雷游戏

扫雷游戏的功能说明 ： • 使⽤控制台实现经典的扫雷游戏 • 游戏可以通过菜单实现继续玩或者退出游戏 • 扫雷的棋盘是9*9的格⼦ • 默认随机布置10个雷 • 可以排查雷： ◦ 如果位置不是雷，就显⽰周围有⼏个雷 ◦ 如果位置是雷，就…...

编程日记 2025/5/21 5:58:20

监控与调试：性能优化的利器 — ShardingSphere

在分布式数据库系统中，监控和调试是确保系统高效运行的关键。ShardingSphere 提供了多种监控和调试工具，帮助开发者实时跟踪和优化性能，识别瓶颈，进行故障排查，从而提升系统的稳定性和响应速度。本文将介绍如何使用 Sh…...

编程日记 2025/5/22 23:59:04

Kubernetes相关知识入门详解

一、Pod的滚动升级 1.服务升级的一般思路：停止与该服务相关的所有服务pod，重新拉去更新后的镜像并启动。这种方法存在一个比较现实的问题是逐步升级导致较长时间的服务不可用。 2.Kubernetes滚动升级的思路：通过滚动升级的命令创建新的rc&…...

编程日记 2025/5/21 16:56:44

多层 RNN原理以及实现

数学原理多层 RNN 的核心思想是堆叠多个 RNN 层，每一层的输出作为下一层的输入，从而逐层提取更高层次的抽象特征。 1. 单层 RNN 的数学表示首先，单层 RNN 的计算过程如下。对于一个时间步 t t t，单层 RNN 的隐藏状态 h t h_t…...

编程日记 2025/5/21 23:33:36

Unity阿里云OpenAPI 获取 Token的C#【记录】

获取Token using UnityEngine; using System; using System.Text; using System.Linq; using Newtonsoft.Json.Linq; using System.Security.Cryptography; using UnityEngine.Networking; using System.Collections.Generic; using System.Globalization; using Cysharp.Thr…...

编程日记 2025/5/25 10:13:01

五、数据处理与 ETL 流程编程实现

5.1 数据抽取与转换（ETL）

5.2 时间窗口处理与增量抽取

相关文章：