> 持续流程改进 > 患者旅程 > Oracle Health (Cerner) > 数据模板

您的患者旅程数据模板

Oracle Health (Cerner)

← 返回改进指南

患者旅程属性 (20) 患者旅程活动 (14) 提取指南 (2)

您的患者旅程数据模板

这份全面的模板概述了有效分析和优化患者旅程所需的核心数据。它提供了要收集的关键属性、要跟踪的核心活动以及数据提取的实用指南。利用此资源准备您的事件日志，开启无缝的流程挖掘体验。

建议收集的属性
需要追踪的关键活动
提取指南

不熟悉事件日志？了解如何创建流程挖掘事件日志.

下载模板

患者旅程属性

建议在事件日志中包含这些数据字段，以便对系统内的患者旅程进行全面分析。

5 必填 9 推荐 6 可选

	名称	描述
	事件timestamp EventEndDateTime	活动发生或完成的具体日期和时间。
描述此属性记录事件发生的准确时刻。它用于对活动进行排序，并计算流程步骤之间的周期时间。在 `CLINICAL_EVENT` 表中，这通常对应 `EVENT_END_DT_TM`。这里的准确性对于计算等待时间至关重要，例如“患者登记”与“分诊评估”之间的时间间隔。为何重要对于确定事件顺序及计算前置时间等性能 KPI 至关重要。获取方式表：CLINICAL_EVENT，列：EVENT_END_DT_TM 示例 2023-10-15T08:30:00Z2023-10-15T09:15:45Z2023-10-16T14:20:00Z
	患者诊疗周期 EncounterId	特定患者就诊或诊疗周期的唯一标识符。
描述此属性充当患者旅程的核心 Case Identifier。它将单一诊疗周期（如住院或急诊就诊）内发生的所有临床事件、医嘱和行政操作归组。在流程挖掘中，此 ID 对于将分散的活动关联为统一的流程视图至关重要。从技术上讲，这对应于 Cerner Millennium 数据库中 `ENCOUNTER` 表里的 `ENCNTR_ID`。它是链接患者人口统计信息、医嘱和临床事件的主键。为何重要这是重建从入院到出院端到端患者旅程所需的核心关键。获取方式表：ENCOUNTER，列：ENCNTR_ID 示例 123456789876543211223344
	活动 ClinicalEventTag	所执行的临床或行政事件的名称或描述。
描述此属性捕获患者护理过程中采取的具体行动，例如“已给药”、“采集生命体征”或“患者出院”。它为流程步骤提供了可读的标签。在 Cerner 中，这通常源自 `CLINICAL_EVENT` 表，特别是将 `EVENT_CD` (事件代码) 映射到其显示值或使用 `EVENT_TAG`。统一命名规范对于生成易读的流程图至关重要。为何重要定义流程图中的步骤，使工作流可视化。获取方式表：CLINICAL_EVENT，列：EVENT_TAG 或 EVENT_CD 链接的 CODE_VALUE 示例分诊评估血常规（含分类计数）出院医嘱转运患者
	最后数据更新 LastDataUpdate	记录在仓库中提取或最后修改的时间戳。
描述指示分析中使用的数据的新鲜度。此时间戳帮助用户了解他们查看的是实时数据还是之前加载的快照。这通常是在 ETL（提取、转换、加载）过程中生成的，而不是临床属性。为何重要对于数据治理以及确保基于最新信息进行分析至关重要。获取方式 ETL 系统时间戳示例 2023-11-01T00:00:00Z2023-11-02T12:00:00Z
	源系统 SourceSystem	数据来源系统的名称。
描述识别数据记录的源应用程序。在此背景下，主要为“Oracle Health”或“Cerner Millennium”。这在多系统环境中非常有用，因为数据可能与其他 EMR 或科室系统混合。如果摄取了多个来源的数据，它允许分析师根据数据来源对流程分析进行过滤或细分。为何重要确保数据血缘和可追溯性，特别是在多系统流程挖掘配置中。获取方式硬编码字符串或系统元数据示例 Oracle HealthCerner Millennium
	主要诊断 DiagnosisCode	代表主要治疗原因的 ICD-10 或 SNOMED 代码。
描述分配给诊疗周期的标准临床代码（例如肺炎的 'J18.9'）。这允许按病情对患者进行分组，以分析特定疾病的“治疗方案偏离”情况。可在链接到就诊记录的 `DIAGNOSIS` 表中找到。为何重要支持对特定病种的患者路径进行对等比较。获取方式表：DIAGNOSIS，列：DIAGNOSIS_CODE (通过术语库) 示例 I10E11.9J18.9
	住院时长 LengthOfStay	以天或小时计的患者诊疗总时长。
描述这是一个计算属性，代表入院时间戳与出院时间戳之间的时间差。它是“整体患者住院时长分析”仪表板的主要效率指标。虽然可以在流程挖掘工具内部计算，但将其作为 Case 层级的预计算静态属性导入通常更具性能优势。为何重要医院管理中最重要的单一效率 KPI。获取方式源自 ENCOUNTER 表的 REG_DT_TM 和 DISCH_DT_TM 列示例 4.5 天2小时12 天
	出院状态 DischargeDisposition	患者出院时的目的地或状态。
描述指示患者在诊疗周期结束后的去向（例如“回家”、“专业护理机构”、“离世”）。这对于“出院计划”分析和识别不良结果至关重要。可在 `ENCOUNTER` 表的 `DISCH_DISPOSITION_CD` 字段中找到。为何重要关键结果指标；定义了患者旅程的“终态”。获取方式表：ENCOUNTER，列：DISCH_DISPOSITION_CD (通过 CODE_VALUE 解析) 示例出院回家转至康复机构违背医嘱离院 (DAMA)已到期
	医嘱项目 OrderMnemonic	所下达的具体医嘱名称，如化验检查或药物。
描述描述医嘱事件的内容（例如“全血细胞计数”、“阿司匹林 81mg”）。此属性为“下达诊断医嘱”和“给药”活动提供必要的背景信息。它通常位于 `ORDERS` 表的 `ORDER_MNEMONIC` 列中，充当流程中流转的“产品”。为何重要对诊断和治疗路径进行细粒度分析所必需。获取方式表：ORDERS，列：ORDER_MNEMONIC 示例胸部 X 光基础代谢类检查 (BMP)对乙酰氨基酚 (Acetaminophen)脑部 MRI
	患者 ID PersonId	患者在多次就诊中的唯一标识符。
描述与就诊 ID 不同，患者 ID（或 Person ID）在患者多次就医期间保持不变。此属性对于分析再入院率和了解患者的长期病史至关重要。在 Cerner 中，这是 `PERSON` 表中的 `PERSON_ID`。它将多个 `ENCNTR_ID`（就诊记录）链接在一起。为何重要通过将不同的就诊阶段链接到同一个人，支持“患者再入院率”KPI 统计。获取方式表：PERSON，列：PERSON_ID 示例 P10001P55992P99221
	是否再入院 IsReadmission	标记该诊疗阶段是否发生在上次出院后的 30 天内。
描述用于识别该案例是否为再入院的布尔标记。通过比较同一 `PersonId` 下当前就诊阶段的入院日期与前次就诊阶段的出院日期计算得出。这对于“患者再入院趋势”仪表板至关重要。为何重要直接支撑“患者再入院率”这一关键医疗质量 KPI。获取方式通过比较 ENCOUNTER 记录的 SQL 逻辑得出示例 truefalse
	案例类型 EncounterType	患者就诊类别的划分，如住院、门诊或急诊。
描述对患者诊疗阶段的性质进行分类。这是切分数据的主要维度，因为“急诊”就诊的流程与“择期住院”的流程有显著差异。这源自 `ENCOUNTER` 表中的 `ENCNTR_TYPE_CD`，它引用了代码集中的值（如“住院”、“急诊”）。为何重要支持对不同医疗设置下的路径和接诊量进行对比分析。获取方式表：ENCOUNTER，列：ENCNTR_TYPE_CD (通过 CODE_VALUE 解析) 示例住院紧急门诊日间手术
	用户 PerformingPrsnlId	执行该活动的临床医生标识符或姓名。
描述记录执行流程步骤的人员，例如给药的护士或签署出院令的医生。这有助于进行资源利用分析。在 Cerner 中，根据表的不同（医嘱表 vs 临床事件表），这通常是 `PERFORMED_PRSNL_ID` 或 `UPDT_ID`。将其映射到通用的“用户”属性有助于进行职责分离 (SoD) 分析。为何重要支持资源分析，识别潜在的培训需求或工作量失衡。获取方式表：CLINICAL_EVENT，列：PERFORMED_PRSNL_ID 示例史密斯医生 (Dr. Smith)护士 JonesSysAdmin
	部门 NurseUnit	事件发生的特定病房、单元或科室。
描述识别事件发生时负责患者的物理位置或组织单元（如“ICU”、“普外科”、“急诊科”）。这有助于通过追踪各单元间的移动，在“科室间转运效率”仪表板中进行分析。在 Cerner 中，这通常是就诊表或追踪表中的 `LOC_NURSE_UNIT_CD`。为何重要对于分析特定科室瓶颈以及可视化患者流动地理分布至关重要。获取方式表：ENCOUNTER 或 CLINICAL_EVENT，列：LOC_NURSE_UNIT_CD 示例急诊科心内科病房重症监护室 (ICU)放射科
	付款人类型 FinancialClass	患者的主要保险覆盖或财务分类。
描述根据支付来源（如医保、商业保险、自费）对患者进行分类。此属性用于分析流程或住院时长是否因保险类型而异。源自 `ENCOUNTER` 表中的 `FINANCIAL_CLASS_CD`。为何重要有助于根据支付方类型识别医疗服务或行政处理方面的差异。获取方式表：ENCOUNTER，列：FINANCIAL_CLASS_CD (通过 CODE_VALUE 解析) 示例 Medicare (联邦医保)蓝十字 (Blue Cross)自费Medicaid (医疗补助)
	入院途径 AdmissionSource	患者入院的来源。
描述描述患者进入医院系统的途径，例如“医生转诊”、“急诊室”或“从其他医院转院”。这有助于分析医院流程的“入口端”。它映射到 `ENCOUNTER` 表中的 `ADMIT_SRC_CD`。为何重要根据入口点对“初步评估等待时间”进行上下文分析。获取方式表：ENCOUNTER，列：ADMIT_SRC_CD 示例急诊室医生转诊转院
	分诊优先级 TriageAcuity	分诊评估期间分配的紧急程度。
描述指示患者病情严重程度的数值或分类值（例如，1-急诊即刻到5-非紧急）。这是分析候诊时间的关键细分属性，因为优先级较高的患者应当拥有更短的等待时间。通常在分诊事件期间通过临床表单或特定的观察代码捕获。为何重要对于验证流程是否根据临床紧急程度正确划分患者优先级至关重要。获取方式咨询 Oracle Health (Cerner) 文档示例 12345
	结果状态 ResultStatus	诊断结果的状态（例如：已审核/验证、已修正、初步）。
描述指示诊断检查结果的生命周期阶段。这用于“诊断结果交付时间”分析，以确定结果何时正式可供临床决策使用。通常在 `CLINICAL_EVENT` 中通过特定的状态代码找到。为何重要区分初步报告和最终报告，这会影响下游活动的启动时间。获取方式表：CLINICAL_EVENT，列：RESULT_STATUS_CD 示例已授权（已核实）错误已修改
	给药状态 MedAdminStatus	药物医嘱的状态（例如：已给药、拒绝、未给药）。
描述指示给药任务的结果。对于“给药合规性”仪表板，区分实际给药与已排期但漏服或拒绝给药的情况至关重要。可能在 `CLINICAL_EVENT` 或特定的给药记录 (MAR) 表中找到。为何重要识别诊疗规范中的合规差距。获取方式咨询 Oracle Health (Cerner) 文档示例已给药拒绝暂停
	订单号 OrderId	特定医嘱（化验、给药、会诊）的唯一标识符。
描述系统生成的医嘱 ID。虽然不是 Case ID，但它是关键的辅助键。它将“诊断医嘱已下达”事件与“诊断结果已验证”事件链接起来。如果没有这个 ID，当患者有多个并发医嘱时，很难计算特定检查的准确周转时间。为何重要对于准确链接配对活动（如医嘱 -> 结果）至关重要。获取方式表：ORDERS，列：ORDER_ID 示例 88291028829103

必填推荐可选

患者旅程活动

这些是您事件日志中需要捕获的关键流程步骤和里程碑，以便准确进行流程发现和瓶颈识别。

8 推荐 6 可选

	活动	描述
	出院医嘱已签署	医生下达出院医嘱的事件。这标志着出院计划计时的开始。
为何重要 “出院计划周期时间”的起点。该点与实际出院之间的差距反映了运营延误。获取方式 `ORDERS` 表，其中目录类型指示为出院 (Discharge)。捕获当出院医嘱状态为“已下达 (ORDERED)”时记录事件类型 explicit
	分诊评估已完成	代表急诊或入院背景下初始护理评估或分诊表格的完成。这通常是系统中记录的特定表格或临床事件。
为何重要对于计算“初步评估等待时间”KPI 以及识别“入口端”瓶颈至关重要。获取方式 CLINICAL_EVENT 表，通过与分诊或初步评估表单关联的事件代码进行过滤。捕获在临床文件/表格签署或验证时记录事件类型 explicit
	发生科室转运	记录患者在不同地点（如从急诊室到 ICU）之间的实际物理移动。该活动通过位置历史进行跟踪。
为何重要支持“科室间转运效率”分析，并协助可视化全院的患者流动情况。获取方式 ENCNTR_LOC_HIST (Encounter Location History) 表，捕获 LOC_NURSE_UNIT_CD 的变更。捕获比较状态字段的前后变化事件类型 inferred
	患者出院	结束患者住院的最后行政事件。该时间戳用于计算总住院时长 (LOS)。
为何重要流程的主要结束事件。对于计算住院时长 (LOS) 和再入院率至关重要。获取方式 ENCOUNTER 表，特别是 DISCH_DT_TM（出院日期/时间）。捕获当就诊状态更改为“已出院 (DISCHARGED)”时记录事件类型 explicit
	患者已登记	标记患者到达并录入系统时的诊疗起点。在 Cerner Millennium 中，这在创建就诊记录或设置登记时间戳时捕获。
为何重要为住院时长 (LOS) 计算和初始等待时间分析建立起始时间。获取方式 ENCOUNTER 表，特别是 REG_DT_TM（登记日期/时间）列。捕获在事务创建新的 ENCOUNTER 行时记录事件类型 explicit
	诊断医嘱已下达	当临床医生下达化验或影像检查医嘱时发生。该时间戳是计算诊断周转时间的起点。
为何重要 “诊断结果交付时间”KPI 的起点；有助于识别下达医嘱与执行之间的延误。获取方式 `ORDERS` 表，使用目录类型为化验 (Laboratory) 或影像 (Radiology) 的 `ORIG_ORDER_DT_TM` 字段。捕获当医嘱状态设置为“已下达 (ORDERED)”时记录事件类型 explicit
	诊断已归档	当正式诊断被添加到患者的就诊记录时发生。这不同于化验结果，代表了临床医生对病情的确认。
为何重要对于“诊断确诊”里程碑及分析确诊所需时间至关重要。获取方式 DIAGNOSIS 表，使用与 ENCOUNTER_ID 关联的 DIAGNOSIS_DT_TM。捕获在 PowerChart 中添加或更新诊断时记录事件类型 explicit
	诊断结果已验证	化验或影像结果定稿并提供给临床医生的时刻。这标志着诊断周转时间的结束。
为何重要完成“诊断结果交付时间”周期并触发后续治疗决策。获取方式 CLINICAL_EVENT 表（用于实验检查）或 ORDERS 状态更改为 COMPLETED。捕获当结果状态更改为“已审核 (AUTH)”时记录事件类型 explicit
	会诊完成	标记专家会诊的完成，通常以签署会诊记录或文件为凭据。
为何重要识别何时收到专家意见，这可能是复杂诊疗路径中的瓶颈。获取方式 CLINICAL_EVENT 表，过滤分类为“会诊”的文档类型。捕获在会诊记录签署时记录事件类型 explicit
	已执行手术/处置	指示手术或重大处置实际发生的时间戳。这通常捕获在围手术期记录中。
为何重要临床路径和资源利用分析的关键里程碑。获取方式 `SURGICAL_CASE` 表（手术开始/停止时间）或床旁操作的 `CLINICAL_EVENT`。捕获通过 SurgiNet 或手术记录进行记录事件类型 explicit
	已排期手术/处置	表示已为特定时间预定了外科手术或重大操作。这有助于了解资源配置和术前/操作前等待时间。
为何重要突出显示手术室或操作室利用方面的排期效率及潜在瓶颈。获取方式 `SURGICAL_CASE` 表或链接到就诊的 `SCH_APPT` 表。捕获在提交预约事务时记录事件类型 explicit
	已给药	记录药物给药记录 (MAR) 中记录的对患者的实际给药情况。
为何重要支持“给药合规性”仪表板，验证药物是否按时给予。获取方式 CLINICAL_EVENT 表，过滤给药事件（任务状态 = 完成）。捕获在条形码扫描或手动 MAR 录入时记录事件类型 explicit
	护理计划已激活	代表 Cerner 中 PowerPlan 或护理路径的启动。这标志着已选择标准化的治疗协议。
为何重要对于进行“诊疗规范偏离分析”以对比实际护理与计划路径至关重要。获取方式 ACT_PW_CAT (Action Pathway Catalog) 或 DCP_FORMS_REF，将临床路径与就诊关联。捕获在启动 PowerPlan 时记录事件类型 explicit
	随访预约已安排	当为患者预订了与同一诊疗周期或护理计划相关的后续预约时发生。
为何重要支持“随访预约及时性”仪表板。衡量护理连续性的效率。获取方式 `SCH_APPT` (预约排期) 表，链接至 `PERSON_ID`。捕获在预约模块创建预约时记录事件类型 explicit

推荐可选

提取指南

如何从 Oracle Health (Cerner) 获取数据

步骤

启动 Discern Visual Developer：在您的 Citrix 或本地 Cerner 域访问环境中打开 Discern Visual Developer (DVDev) 应用程序。
创建新脚本：初始化一个新的 Command Language (CCL) 脚本文件（例如 extract_patient_journey.prg）。
定义提示符：在脚本顶部定义 start_date 和 end_date 的用户提示符，以便针对特定时间范围进行动态执行。
设置常量：为特定代码集（如就诊类型、医嘱目录、事件代码）定义常量，避免硬编码随环境变化的数字 code_value 标识符。您可能需要查找所在机构分诊、出院和会诊表单的具体 code_value 或 display_key。
构建查询：将下面提供的 SQL 查询复制到脚本主体中。该查询使用 UNION ALL 将来自多个表（ENCOUNTER、CLINICAL_EVENT、ORDERS、SURG_CASE_TBL 等）的数据合并为单一的扁平化事件日志结构。
编译脚本：使用编译功能（Ctrl+F7 或 Build 菜单）检查语法错误。确保您拥有对相关表的 SELECT 访问权限。
执行与导出：运行脚本 (Go/F9)。在输出目标中选择“Spreadsheet”或“Flat File”。将结果保存为 CSV 文件。
数据转换（可选）：如果返回的日期是 Cerner 特定格式（如儒略日或非 ISO 时间戳），请在上传前使用 Excel 或脚本将其转换为 YYYY-MM-DD HH:MM:SS 格式。
验证：在 PowerChart 中针对已知的患者就诊 ID (FIN) 进行抽样检查，以验证时间戳与提取的数据是否一致。
上传至 ProcessMind：将 CSV 文件导入 ProcessMind，将 EncounterId 列映射为 Case ID，ClinicalEventTag 映射为 Activity，EventEndDateTime 映射为 Timestamp。

配置

日期范围：建议的执行窗口为3-6个月。由于CLINICAL_EVENT表的数据量巨大，日期范围过大可能会导致查询超时。
代码集 (CDF)：该查询依赖于code_value过滤器。您必须将[REPLACE_WITH_TRIAGE_EVENT_CD]等占位符替换为您域中的实际代码（可在CODE_VALUE表中找到）。
权限：执行脚本的用户需要对以下表具有d（数据库）访问权限：ENCOUNTER、CLINICAL_EVENT、ORDERS、SURG_CASE_TBL、ENCNTR_LOC_HIST和SCH_APPOINTMENT。
性能：CLINICAL_EVENT表非常大。请确保EVENT_END_DT_TM上的日期过滤器已建立索引并严格执行。
再入院逻辑：IsReadmission属性作为一个占位符包含在内。复杂的追溯逻辑最好在数据加载到ProcessMind应用程序后进行处理，而不是在提取查询中处理。

a 查询示例 sql

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Patient Registered'
    , EventEndDateTime = FORMAT(E.REG_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = P.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = 'N/A'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1) /* Days */
    , IsReadmission = '0' /* Calculate in Tool */
    , DiagnosisCode = 'N/A'
FROM
    ENCOUNTER E
    , PERSON P
    , PRSNL PR
WHERE
    E.REG_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND E.PERSON_ID = P.PERSON_ID
    AND E.REG_PRSNL_ID = PR.PERSON_ID
    AND E.ACTIVE_IND = 1

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Triage Assessment Completed'
    , EventEndDateTime = FORMAT(CE.EVENT_END_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = CE.EVENT_TAG
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    CLINICAL_EVENT CE
    , ENCOUNTER E
    , PRSNL PR
WHERE
    CE.EVENT_END_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND CE.EVENT_CD IN ([REPLACE_WITH_TRIAGE_EVENT_CD]) /* e.g., Triage Acuity */
    AND CE.VALID_UNTIL_DT_TM > CNVTDATETIME(CURDATE, CURTIME3)
    AND CE.ENCNTR_ID = E.ENCNTR_ID
    AND CE.PERFORMED_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Diagnostic Order Placed'
    , EventEndDateTime = FORMAT(O.ORIG_ORDER_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = O.ORDER_MNEMONIC
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    ORDERS O
    , ENCOUNTER E
    , PRSNL PR
WHERE
    O.ORIG_ORDER_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND O.CATALOG_TYPE_CD IN ([REPLACE_WITH_LAB_RAD_CODES]) /* General Lab, Radiology */
    AND O.ENCNTR_ID = E.ENCNTR_ID
    AND O.ORDER_STATUS_CD != [REPLACE_WITH_CANCELED_CODE]
    AND O.STATUS_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Procedure Scheduled'
    , EventEndDateTime = FORMAT(SCT.UPDT_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = 'Surgical Case'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    SURG_CASE_TBL SCT
    , ENCOUNTER E
    , PRSNL PR
WHERE
    SCT.UPDT_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND SCT.ENCNTR_ID = E.ENCNTR_ID
    AND SCT.UPDT_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Diagnosis Documented'
    , EventEndDateTime = FORMAT(D.DIAG_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = D.DIAGNOSIS_DISPLAY
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = D.DIAGNOSIS_DISPLAY
FROM
    DIAGNOSIS D
    , ENCOUNTER E
    , PRSNL PR
WHERE
    D.DIAG_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND D.ENCNTR_ID = E.ENCNTR_ID
    AND D.ACTIVE_IND = 1
    AND D.DIAG_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Care Plan Activated'
    , EventEndDateTime = FORMAT(PWC.START_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = PWC.DESCRIPTION
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    ACT_PW_COMP PWC
    , ENCOUNTER E
    , PRSNL PR
WHERE
    PWC.START_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND PWC.ENCNTR_ID = E.ENCNTR_ID
    AND PWC.ACTIVE_IND = 1
    AND PWC.START_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Medication Administered'
    , EventEndDateTime = FORMAT(CE.EVENT_END_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = CE.EVENT_TAG
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    CLINICAL_EVENT CE
    , ENCOUNTER E
    , PRSNL PR
WHERE
    CE.EVENT_END_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND CE.EVENT_CLASS_CD = [REPLACE_WITH_MED_ADMIN_CLASS] /* e.g., 232 (MED) */
    AND CE.ENCNTR_ID = E.ENCNTR_ID
    AND CE.VALID_UNTIL_DT_TM > CNVTDATETIME(CURDATE, CURTIME3)
    AND CE.PERFORMED_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Diagnostic Result Verified'
    , EventEndDateTime = FORMAT(CE.VERIFIED_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = CE.EVENT_TAG
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    CLINICAL_EVENT CE
    , ENCOUNTER E
    , PRSNL PR
WHERE
    CE.VERIFIED_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND CE.EVENT_CLASS_CD IN ([REPLACE_WITH_LAB_RAD_CLASS_CODES])
    AND CE.RESULT_STATUS_CD = [REPLACE_WITH_AUTH_STATUS_CD]
    AND CE.ENCNTR_ID = E.ENCNTR_ID
    AND CE.VERIFIED_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Procedure Performed'
    , EventEndDateTime = FORMAT(SCT.SURG_START_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = 'N/A'
    , OrderMnemonic = 'Surgical Case'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    SURG_CASE_TBL SCT
    , ENCOUNTER E
WHERE
    SCT.SURG_START_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND SCT.ENCNTR_ID = E.ENCNTR_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Department Transfer Occurred'
    , EventEndDateTime = FORMAT(ELH.BEG_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(ELH.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = 'Transfer'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    ENCNTR_LOC_HIST ELH
    , ENCOUNTER E
    , PRSNL PR
WHERE
    ELH.BEG_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND ELH.ENCNTR_ID = E.ENCNTR_ID
    AND ELH.UPDT_ID = PR.PERSON_ID
    AND ELH.ACTIVE_IND = 1

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Consultation Completed'
    , EventEndDateTime = FORMAT(CE.EVENT_END_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = CE.EVENT_TAG
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    CLINICAL_EVENT CE
    , ENCOUNTER E
    , PRSNL PR
WHERE
    CE.EVENT_END_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND CE.EVENT_CD IN ([REPLACE_WITH_CONSULT_NOTE_CODES])
    AND CE.ENCNTR_ID = E.ENCNTR_ID
    AND CE.PERFORMED_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Discharge Order Signed'
    , EventEndDateTime = FORMAT(O.ORIG_ORDER_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = O.ORDER_MNEMONIC
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    ORDERS O
    , ENCOUNTER E
    , PRSNL PR
WHERE
    O.ORIG_ORDER_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND O.ORDER_MNEMONIC = '*Discharge*'
    AND O.ENCNTR_ID = E.ENCNTR_ID
    AND O.STATUS_PRSNL_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Patient Discharged'
    , EventEndDateTime = FORMAT(E.DISCH_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = E.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = 'N/A'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    ENCOUNTER E
    , PERSON P
    , PRSNL PR
WHERE
    E.DISCH_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND E.PERSON_ID = P.PERSON_ID
    AND E.ACTIVE_IND = 1
    AND E.UPDT_ID = PR.PERSON_ID

UNION ALL

SELECT
    EncounterId = E.ENCNTR_ID
    , ClinicalEventTag = 'Follow-up Appointment Scheduled'
    , EventEndDateTime = FORMAT(SA.UPDT_DT_TM, 'YYYY-MM-DD HH:MM:SS')
    , SourceSystem = 'Cerner'
    , LastDataUpdate = FORMAT(CNVTDATETIME(CURDATE, CURTIME3), 'YYYY-MM-DD HH:MM:SS')
    , PersonId = SA.PERSON_ID
    , EncounterType = UAR_GET_CODE_DISPLAY(E.ENCNTR_TYPE_CD)
    , NurseUnit = UAR_GET_CODE_DISPLAY(E.LOC_NURSE_UNIT_CD)
    , PerformingPrsnlId = PR.NAME_FULL_FORMATTED
    , OrderMnemonic = 'Follow-up'
    , DischargeDisposition = UAR_GET_CODE_DISPLAY(E.DISCH_DISPOSITION_CD)
    , LengthOfStay = DATETIFF(E.DISCH_DT_TM, E.REG_DT_TM, 1)
    , IsReadmission = '0'
    , DiagnosisCode = 'N/A'
FROM
    SCH_APPOINTMENT SA
    , ENCOUNTER E
    , PRSNL PR
WHERE
    SA.UPDT_DT_TM BETWEEN CNVTDATETIME($start_date) AND CNVTDATETIME($end_date)
    AND SA.ENCNTR_ID = E.ENCNTR_ID
    AND SA.BEG_DT_TM > E.DISCH_DT_TM
    AND SA.SCH_STATE_CD != [REPLACE_WITH_CANCELED_STATE_CD]
    AND SA.UPDT_ID = PR.PERSON_ID

步骤

前提配置：确保已安装 Python 及必要的库（pandas、requests），并拥有 Oracle Health (Cerner) FHIR R4 端点的有效 OAuth2 凭据（client_id、client_secret）。必须启用以下范围的权限：Patient、Encounter、Observation、Condition、Procedure、MedicationAdministration、ServiceRequest 和 DiagnosticReport。
身份验证处理：实现身份验证处理器以从授权服务器获取 Bearer 令牌。Cerner 通常使用 SMART on FHIR 或标准的 OAuth2 客户端凭据流。提供的脚本已包含令牌获取逻辑。
定义范围与时间窗口：确定提取窗口（例如使用 last_updated_gt 或 date 参数）。最佳实践是在 Encounter 资源上按日期范围进行迭代，以定义患者诊疗阶段 (Patient Episodes) 的范围。
获取就诊信息（患者诊疗阶段）：查询 Encounter 资源。该对象是核心枢纽（Case ID）。从 Encounter 资源中提取 period.start 作为患者登记，提取 period.end 作为患者出院，并遍历 location 历史记录以提取发生科室转运事件。
提取临床医嘱：按 Encounter ID 过滤查询 ServiceRequest 资源。通过 intent=order 过滤来捕获下达诊断医嘱和手术/操作预约。将 authoredOn 映射为事件时间戳。
提取诊断与问题：查询与就诊关联的 Condition 资源。使用 recordedDate 或 onsetDateTime 创建诊断归档事件。尽可能过滤 encounter-diagnosis 类别。
提取手术/操作：查询 Procedure 资源。使用 performedDateTime 生成执行手术/操作事件。这可以区分已完成的手术与仅预约的手术。
提取药物信息：查询 MedicationAdministration 资源。这与 MedicationRequest 不同，因为它记录的是实际给药情况。使用 effectiveDateTime 作为给药完成事件的时间戳。
提取实验项目与结果：查询 Observation 或 DiagnosticReport 资源。使用 issued 或 effectiveDateTime 作为诊断结果已验证事件的时间戳。筛选 status=final 的记录。同时，使用特定的 Observation 代码（如分诊病情的 LOINC 代码）来识别分诊评估完成。
提取文档与护理计划：查询 DocumentReference 以获取会诊完成（使用文档类型代码）事件，查询 CarePlan 以获取护理计划已激活事件。
识别出院活动：识别出院医嘱已签署通常需要检查 ServiceRequest 中的特定出院医嘱代码，或解析 Encounter.statusHistory 中最终出院前的状态。
数据转换与导出：将 JSON 响应展平为表格格式。创建所需的列（EncounterId、ClinicalEventTag、EventEndDateTime 等）。将时间戳转换为 ISO 8601 格式，并将最终数据集导出为 CSV 文件，以便上传至 ProcessMind。

配置

FHIR 基础 URL：您 Oracle Health/Cerner 实例的特定端点（例如 https://fhir-myrecord.cerner.com/r4/...）。
身份验证范围 (Scopes)：确保应用程序具有 system/Encounter.read、system/Observation.read、system/Patient.read、system/Procedure.read、system/Condition.read 等权限。
日期过滤：在 Encounter 资源上使用 date=ge[YYYY-MM-DD] 来提取从特定日期开始的诊疗阶段。避免查询全部历史记录。
分页处理：API 以 Bundle 形式返回数据。脚本必须处理分页链接（relation: next）以检索完整的数据集。
并发处理：对于大批量数据提取，可以考虑按 Encounter ID 范围并行化请求，但需遵守 API 速率限制（节流策略）。
代码过滤：在脚本映射部分配置特定的 LOINC 或 SNOMED 代码，以准确区分分诊 (Triage) 与常规观察。

a 查询示例 python

import requests
import pandas as pd
import time
from datetime import datetime, timedelta

class=class="hl-string">"hl-comment"># === CONFIGURATION ===
FHIR_BASE_URL = class="hl-string">"https://fhir-ehr.cerner.com/r4/ec2458f2-1e24-41c8-b71b-0e701af7583d"  class=class="hl-string">"hl-comment"># Placeholder
CLIENT_ID = class="hl-string">"[YOUR_CLIENT_ID]"
CLIENT_SECRET = class="hl-string">"[YOUR_CLIENT_SECRET]"
TOKEN_URL = class="hl-string">"https://authorization.cerner.com/tenants/ec2458f2-1e24-41c8-b71b-0e701af7583d/protocols/oauth2/profiles/smart-v1/token"

class=class="hl-string">"hl-comment"># Standard headers
HEADERS = {
    class="hl-string">"Accept": class="hl-string">"application/fhir+json",
    class="hl-string">"Content-Type": class="hl-string">"application/json"
}

class=class="hl-string">"hl-comment"># === AUTHENTICATION ===
def get_access_token():
    class=class="hl-string">"hl-comment"># Basic OAuth2 Client Credentials implementation
    class=class="hl-string">"hl-comment"># Adjust for specific SMART on FHIR flows if needed
    payload = {
        class="hl-string">"grant_type": class="hl-string">"client_credentials",
        class="hl-string">"client_id": CLIENT_ID,
        class="hl-string">"client_secret": CLIENT_SECRET,
        class="hl-string">"scope": class="hl-string">"system/Encounter.read system/Patient.read system/Observation.read system/Procedure.read system/Condition.read system/MedicationAdministration.read system/ServiceRequest.read"
    }
    try:
        response = requests.post(TOKEN_URL, data=payload, auth=(CLIENT_ID, CLIENT_SECRET))
        response.raise_for_status()
        return response.json()[class="hl-string">"access_token"]
    except Exception as e:
        print(fclass="hl-string">"Auth failed: {e}")
        return None

class=class="hl-string">"hl-comment"># === API HELPER ===
def fetch_resource(url, token):
    resources = []
    headers = HEADERS.copy()
    headers[class="hl-string">"Authorization"] = fclass="hl-string">"Bearer {token}"
    
    while url:
        try:
            resp = requests.get(url, headers=headers)
            if resp.status_code == 429:
                time.sleep(2)
                continue
            resp.raise_for_status()
            data = resp.json()
            
            if class="hl-string">'entry' in data:
                resources.extend([item[class="hl-string">'resource'] for item in data[class="hl-string">'entry']])
            
            class=class="hl-string">"hl-comment"># Handle Pagination
            url = None
            for link in data.get(class="hl-string">'link', []):
                if link[class="hl-string">'relation'] == class="hl-string">'next':
                    url = link[class="hl-string">'url']
                    break
        except Exception as e:
            print(fclass="hl-string">"Error fetching {url}: {e}")
            break
    return resources

class=class="hl-string">"hl-comment"># === MAIN EXTRACTION ===
def extract_patient_journey(start_date, end_date):
    token = get_access_token()
    if not token:
        return

    class=class="hl-string">"hl-comment"># 1. Fetch Encounters (Episodes)
    print(class="hl-string">"Fetching Encounters...")
    enc_url = fclass="hl-string">"{FHIR_BASE_URL}/Encounter?date=ge{start_date}&date=le{end_date}"
    encounters = fetch_resource(enc_url, token)
    
    event_log = []

    print(fclass="hl-string">"Processing {len(encounters)} encounters...")
    
    for enc in encounters:
        enc_id = enc.get(class="hl-string">'id')
        patient_id = enc.get(class="hl-string">'subject', {}).get(class="hl-string">'reference', class="hl-string">'').replace(class="hl-string">'Patient/', class="hl-string">'')
        enc_type = enc.get(class="hl-string">'class', {}).get(class="hl-string">'code', class="hl-string">'Unknown')
        
        class=class="hl-string">"hl-comment"># Helper to append event
        def add_event(tag, timestamp, order_item=None, location=None):
            if timestamp:
                event_log.append({
                    class="hl-string">"EncounterId": enc_id,
                    class="hl-string">"PersonId": patient_id,
                    class="hl-string">"ClinicalEventTag": tag,
                    class="hl-string">"EventEndDateTime": timestamp,
                    class="hl-string">"SourceSystem": class="hl-string">"OracleHealth_Cerner",
                    class="hl-string">"EncounterType": enc_type,
                    class="hl-string">"NurseUnit": location,
                    class="hl-string">"OrderMnemonic": order_item,
                    class="hl-string">"LastDataUpdate": datetime.now().isoformat()
                })

        class=class="hl-string">"hl-comment"># --- Activity 1: Patient Registered ---
        start_time = enc.get(class="hl-string">'period', {}).get(class="hl-string">'start')
        add_event(class="hl-string">"Patient Registered", start_time)

        class=class="hl-string">"hl-comment"># --- Activity 13: Patient Discharged ---
        end_time = enc.get(class="hl-string">'period', {}).get(class="hl-string">'end')
        class=class="hl-string">"hl-comment"># Activity 12: Discharge Order Signed (Inferred from status or specific request)
        class=class="hl-string">"hl-comment"># For simplicity, if end_time exists, we assume discharge order preceded it slightly or check ServiceRequest
        add_event(class="hl-string">"Patient Discharged", end_time)

        class=class="hl-string">"hl-comment"># --- Activity 10: Department Transfer Occurred ---
        locations = enc.get(class="hl-string">'location', [])
        for i, loc in enumerate(locations):
            loc_name = loc.get(class="hl-string">'location', {}).get(class="hl-string">'display', class="hl-string">'Unknown Unit')
            loc_start = loc.get(class="hl-string">'period', {}).get(class="hl-string">'start')
            class=class="hl-string">"hl-comment"># Skip the first location as it's usually registration
            if i > 0 and loc_start:
                add_event(class="hl-string">"Department Transfer Occurred", loc_start, location=loc_name)

        class=class="hl-string">"hl-comment"># === FETCH SUB-RESOURCES ===
        class=class="hl-string">"hl-comment"># Note: In production, consider batch requests or bulk export if available to avoid N+1 queries
        
        class=class="hl-string">"hl-comment"># --- Activity 5: Diagnosis Documented ---
        cond_url = fclass="hl-string">"{FHIR_BASE_URL}/Condition?patient={patient_id}&encounter={enc_id}"
        conditions = fetch_resource(cond_url, token)
        for cond in conditions:
            dx_name = cond.get(class="hl-string">'code', {}).get(class="hl-string">'text', class="hl-string">'Unknown Diagnosis')
            dx_time = cond.get(class="hl-string">'recordedDate') or cond.get(class="hl-string">'onsetDateTime')
            add_event(class="hl-string">"Diagnosis Documented", dx_time, order_item=dx_name)

        class=class="hl-string">"hl-comment"># --- Activity 9: Procedure Performed ---
        proc_url = fclass="hl-string">"{FHIR_BASE_URL}/Procedure?patient={patient_id}&encounter={enc_id}"
        procedures = fetch_resource(proc_url, token)
        for proc in procedures:
            if proc.get(class="hl-string">'status') == class="hl-string">'completed':
                proc_name = proc.get(class="hl-string">'code', {}).get(class="hl-string">'text', class="hl-string">'Unknown Procedure')
                proc_time = proc.get(class="hl-string">'performedDateTime')
                add_event(class="hl-string">"Procedure Performed", proc_time, order_item=proc_name)

        class=class="hl-string">"hl-comment"># --- Activity 7: Medication Administered ---
        med_url = fclass="hl-string">"{FHIR_BASE_URL}/MedicationAdministration?patient={patient_id}&encounter={enc_id}"
        meds = fetch_resource(med_url, token)
        for med in meds:
            if med.get(class="hl-string">'status') == class="hl-string">'completed':
                med_name = med.get(class="hl-string">'medicationCodeableConcept', {}).get(class="hl-string">'text', class="hl-string">'Unknown Med')
                med_time = med.get(class="hl-string">'effectiveDateTime')
                add_event(class="hl-string">"Medication Administered", med_time, order_item=med_name)

        class=class="hl-string">"hl-comment"># --- Activity 2, 8: Observations (Triage & Labs) ---
        obs_url = fclass="hl-string">"{FHIR_BASE_URL}/Observation?patient={patient_id}&encounter={enc_id}"
        observations = fetch_resource(obs_url, token)
        for obs in observations:
            obs_code = obs.get(class="hl-string">'code', {}).get(class="hl-string">'text', class="hl-string">'')
            obs_time = obs.get(class="hl-string">'effectiveDateTime') or obs.get(class="hl-string">'issued')
            categories = [c.get(class="hl-string">'code') for cat in obs.get(class="hl-string">'category', []) for c in cat.get(class="hl-string">'coding', [])]
            
            if class="hl-string">'triage' in str(categories).lower() or class="hl-string">'acuity' in obs_code.lower():
                add_event(class="hl-string">"Triage Assessment Completed", obs_time, order_item=obs_code)
            elif class="hl-string">'laboratory' in str(categories).lower() and obs.get(class="hl-string">'status') == class="hl-string">'final':
                add_event(class="hl-string">"Diagnostic Result Verified", obs_time, order_item=obs_code)

        class=class="hl-string">"hl-comment"># --- Activity 3, 4, 12: Service Requests (Orders) ---
        req_url = fclass="hl-string">"{FHIR_BASE_URL}/ServiceRequest?patient={patient_id}&encounter={enc_id}"
        requests_list = fetch_resource(req_url, token)
        for req in requests_list:
            req_name = req.get(class="hl-string">'code', {}).get(class="hl-string">'text', class="hl-string">'Unknown Order')
            req_time = req.get(class="hl-string">'authoredOn')
            intent = req.get(class="hl-string">'intent')
            
            if intent == class="hl-string">'order':
                class=class="hl-string">"hl-comment"># Simple logic to distinguish Labs vs other orders based on code or category
                add_event(class="hl-string">"Diagnostic Order Placed", req_time, order_item=req_name)
            elif intent == class="hl-string">'plan':
                 add_event(class="hl-string">"Procedure Scheduled", req_time, order_item=req_name)
            
            class=class="hl-string">"hl-comment"># Discharge Order Logic (Placeholder: Check for specific discharge code)
            if class="hl-string">"discharge" in req_name.lower():
                add_event(class="hl-string">"Discharge Order Signed", req_time)

        class=class="hl-string">"hl-comment"># --- Activity 6: Care Plan Activated ---
        cp_url = fclass="hl-string">"{FHIR_BASE_URL}/CarePlan?patient={patient_id}&encounter={enc_id}"
        careplans = fetch_resource(cp_url, token)
        for cp in careplans:
            cp_start = cp.get(class="hl-string">'period', {}).get(class="hl-string">'start')
            add_event(class="hl-string">"Care Plan Activated", cp_start)

        class=class="hl-string">"hl-comment"># --- Activity 11: Consultation Completed ---
        class=class="hl-string">"hl-comment"># Often DocumentReference
        doc_url = fclass="hl-string">"{FHIR_BASE_URL}/DocumentReference?patient={patient_id}&encounter={enc_id}"
        docs = fetch_resource(doc_url, token)
        for doc in docs:
            type_text = doc.get(class="hl-string">'type', {}).get(class="hl-string">'text', class="hl-string">'').lower()
            if class="hl-string">'consult' in type_text or class="hl-string">'note' in type_text:
                doc_date = doc.get(class="hl-string">'date') class=class="hl-string">"hl-comment"># When document was created/signed
                add_event(class="hl-string">"Consultation Completed", doc_date, order_item=type_text)
        
        class=class="hl-string">"hl-comment"># --- Activity 14: Follow-up Appointment Scheduled ---
        class=class="hl-string">"hl-comment"># Check for appointments created strictly after encounter start, linked to patient
        apt_url = fclass="hl-string">"{FHIR_BASE_URL}/Appointment?patient={patient_id}&date=ge{start_time}"
        appointments = fetch_resource(apt_url, token)
        for apt in appointments:
            created_date = apt.get(class="hl-string">'created') class=class="hl-string">"hl-comment"># When the booking happened
            if created_date and start_time and created_date >= start_time:
                 add_event(class="hl-string">"Follow-up Appointment Scheduled", created_date)

    class=class="hl-string">"hl-comment"># === EXPORT ===
    df = pd.DataFrame(event_log)
    class=class="hl-string">"hl-comment"># Basic cleaning
    df.drop_duplicates(inplace=True)
    df.fillna(class="hl-string">'', inplace=True)
    
    output_file = class="hl-string">"cerner_extraction.csv"
    df.to_csv(output_file, index=False)
    print(fclass="hl-string">"Extraction complete. Saved to {output_file}")

class=class="hl-string">"hl-comment"># Run extraction for a specific window
extract_patient_journey(class="hl-string">"2023-01-01", class="hl-string">"2023-01-07")

您的患者旅程数据模板

您的患者旅程数据模板

患者旅程属性

患者旅程活动

提取指南

通过 Discern 进行 Cerner Command Language 数据提取

步骤

配置

a 查询示例 sql

通过 Oracle Health FHIR R4 API 进行 Python 数据提取

步骤

配置

a 查询示例 python

准备好开始了吗？

立即优化患者旅程，快速提升医疗效果

您的患者旅程数据模板

您的患者旅程数据模板

患者旅程属性

患者旅程活动

提取指南

通过 Discern 进行 Cerner Command Language 数据提取

步骤

配置

a 查询示例 sql

通过 Oracle Health FHIR R4 API 进行 Python 数据提取

步骤

配置

a 查询示例 python

我们重视您的隐私

准备好开始了吗？

立即优化患者旅程，快速提升医疗效果