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

患者就诊旅程数据模板

Oracle Health (Cerner)

← 返回改进指南

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

患者就诊旅程数据模板

此综合模板列出了有效分析和优化患者就诊旅程所需的核心数据，涵盖应收集的关键属性、应跟踪的主要活动，以及实用的数据提取指导。使用此资源准备事件日志，顺利开展流程挖掘。

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

刚接触事件日志？了解如何创建流程挖掘事件日志.

下载模板

患者旅程属性

以下是建议纳入事件日志的数据字段，用于全面分析系统中的患者旅程。

5 必需 8 建议 6 可选

	名称	说明
	事件时间戳 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	特定患者就诊或护理阶段的唯一标识符。
说明该属性是患者就医 journey的核心病例标识符，用于汇总单个护理期间发生的所有临床事件、医嘱和行政操作，例如住院或急诊就诊。在流程挖掘中，此ID对于将分散的活动关联为统一的流程视图至关重要。从技术上看，它对应Cerner Millennium数据库ENCOUNTER表中的`ENCNTR_ID`，是关联患者人口统计信息、医嘱和临床事件的主键。为什么重要这是从入院到出院重建端到端患者就医 journey所需的基础键。获取位置表：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
	出院状态 DischargeDisposition	患者出院时的去向或状态。
说明表示患者在就诊事件结束后去往何处，例如“回家”“专业护理机构”或“死亡”。该属性对于“出院计划”分析和识别不理想结果至关重要。位于`ENCOUNTER`表的`DISCH_DISPOSITION_CD`字段。为什么重要关键结果指标，用于定义患者就诊旅程的“结束状态”。获取位置表：ENCOUNTER，列：DISCH_DISPOSITION_CD（通过CODE_VALUE解析）示例出院回家转入康复机构未经医嘱离院死亡
	医嘱项目 OrderMnemonic	所下达具体医嘱的名称，例如检验或药物。
说明描述医嘱事件的内容，例如“全血细胞计数”“阿司匹林81mg”。该属性为“下达诊断医嘱”和“执行给药”等活动提供必要背景。通常位于`ORDERS`表的`ORDER_MNEMONIC`字段中，可视为流程中流转的“产品”。为什么重要对诊断和治疗路径进行细粒度分析所必需。获取位置表：ORDERS，列：ORDER_MNEMONIC 示例胸部X光检查基础代谢面板对乙酰氨基酚脑部MRI
	患者ID PersonId	用于标识患者在多次就诊中的唯一标识符。
说明患者ID（或Person ID）不同于Case 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中，根据表的不同（医嘱表或临床事件表），通常对应`PERFORMED_PRSNL_ID`或`UPDT_ID`。将其映射为通用的“用户”属性，有助于开展职责分离分析。为什么重要支持资源分析，并识别潜在的培训需求或工作负载不均衡问题。获取位置表：CLINICAL_EVENT，列：PERFORMED_PRSNL_ID 示例 Smith医生Jones注册护士系统管理员
	科室 NurseUnit	事件发生所在的具体病房、单元或科室。
说明标识事件发生时负责患者的实际地点或组织单元，例如“ICU”“普通外科”“急诊科”。该属性可用于“跨病区转运效率”仪表板，跟踪患者在不同单元之间的转移。在Cerner中，通常对应就诊表或跟踪表中的`LOC_NURSE_UNIT_CD`。为什么重要对于分析特定科室中的瓶颈和展示患者流转路径至关重要。获取位置表：ENCOUNTER或CLINICAL_EVENT，列：LOC_NURSE_UNIT_CD 示例急诊科心脏科病房ICU放射科
	付款方类型 FinancialClass	患者的主要保险覆盖类型或财务分类。
说明根据付款方来源对患者进行分类，例如Medicare、商业保险或自费。该属性用于分析不同保险类型下的流程或住院时长是否存在差异。源自`ENCOUNTER`表中的`FINANCIAL_CLASS_CD`。为什么重要帮助识别因付款方类型不同而产生的医疗服务或行政处理差异。获取位置表：ENCOUNTER，列：FINANCIAL_CLASS_CD（通过CODE_VALUE解析）示例 MedicareBlue Cross自费Medicaid
	入院渠道 AdmissionSource	患者入院的来源。
说明描述患者如何进入医院系统，例如“医生转诊”“急诊室”或“其他医院转入”。该属性有助于分析医院流程的“入口”，对应`ENCOUNTER`表中的`ADMIT_SRC_CD`。为什么重要根据患者进入医院的渠道，为“初始评估等待时间”提供背景信息。获取位置表：ENCOUNTER，列：ADMIT_SRC_CD 示例急诊室医生转诊从医院转入
	分诊优先级 TriageAcuity	分诊评估期间分配的紧急程度。
说明表示患者病情严重程度的数值或分类值，例如1级（立即处理）至5级（非紧急）。这是分析等待时间的重要细分属性，因为优先级越高的患者，等待时间应越短。通常在分诊事件期间，通过临床表单或特定观察代码记录。为什么重要对于验证流程是否根据临床紧急程度正确安排患者优先级至关重要。获取位置请参阅Oracle Health（Cerner）文档示例 12345
	医嘱编号 OrderId	特定医嘱（检验、药物或会诊）的唯一标识符。
说明系统为医嘱生成的ID。虽然不是Case ID，但它是重要的辅助键，可将“下达诊断医嘱”事件与“验证诊断结果”事件关联起来。如果患者同时存在多个医嘱，没有该字段就难以计算特定检测的准确周转时间。为什么重要对于准确关联成对活动（医嘱→结果）至关重要。获取位置表：ORDERS，列：ORDER_ID 示例 88291028829103
	用药状态 MedAdminStatus	药物医嘱的状态，例如已给药、拒绝或未给药。
说明表示给药任务的结果。对于“用药合规”仪表板，必须区分实际已给药的药物，以及已安排但漏给或被拒绝的药物。该字段可能位于`CLINICAL_EVENT`表或专用的用药记录（MAR）表中。为什么重要识别治疗方案中的合规缺口。获取位置请参阅Oracle Health（Cerner）文档示例已给药拒绝暂缓
	结果状态 ResultStatus	诊断结果的状态，例如已授权（已验证）、已更正或初步结果。
说明表示诊断检测结果所处的生命周期阶段。该属性用于“诊断结果交付时间”分析，以确定结果何时正式可用于临床决策。通常位于包含特定状态代码的`CLINICAL_EVENT`表中。为什么重要区分初步结果和最终结果，这会影响后续活动何时可以开始。获取位置表：CLINICAL_EVENT，列：RESULT_STATUS_CD 示例授权（已验证）错误已修改

必需建议可选

患者旅程活动

以下是建议记录在事件日志中的关键流程步骤和里程碑，用于准确发现流程并识别瓶颈。

8 建议 6 可选

	活动	说明
	出院医嘱已签署	医生下达患者出院医嘱的事件，标志着出院计划计时开始。
为什么重要 “出院计划周期时间”的起点。该事件与实际出院之间的间隔反映运营延迟。获取位置 ORDERS表，其中目录类型表示Discharge。采集出院医嘱状态为ORDERED时记录事件类型 explicit
	分诊评估完成	表示急诊或入院场景中初始护理评估或分诊表单的完成。通常对应系统中记录的特定表单或临床事件。
为什么重要对于计算“初始评估等待时间”KPI以及识别入口环节的瓶颈至关重要。获取位置 CLINICAL_EVENT表，筛选与分诊或初始评估表单相关的事件代码。采集临床文档或表单签署、验证时记录事件类型 explicit
	已发生科室转运	表示患者从一个地点（例如急诊室）实际移动到另一个地点（例如ICU），通过地点历史进行跟踪。
为什么重要支持“跨病区转运效率”分析，并帮助可视化患者在医院内的流转。获取位置 ENCNTR_LOC_HIST（就诊地点历史）表，记录LOC_NURSE_UNIT_CD的变更。采集比较变更前后的状态字段事件类型 inferred
	患者已出院	结束患者住院过程的最终行政事件。该时间戳用于计算总住院时间。
为什么重要流程的主要结束事件，是计算LOS和再入院率的基础。获取位置 ENCOUNTER表，具体为DISCH_DT_TM（出院日期/时间）。采集就诊状态变更为DISCHARGED时记录事件类型 explicit
	患者已登记	标志着患者就诊阶段的开始，即患者到达并录入系统时。在Cerner Millennium中，该事件会在创建就诊记录或设置登记时间戳时记录。
为什么重要用于确定住院时间（LOS）计算和初始等待时间分析的起始时间。获取位置 ENCOUNTER表，具体为REG_DT_TM（登记日期/时间）列。采集交易创建新的ENCOUNTER行时记录事件类型 explicit
	诊断已记录	正式诊断被添加到患者就诊记录时发生。它不同于检查结果，代表临床人员对病情的确认。
为什么重要对于“诊断确认”里程碑以及分析确诊所需时间至关重要。获取位置 DIAGNOSIS表，使用与ENCOUNTER_ID关联的DIAGNOSIS_DT_TM。采集在PowerChart中添加或更新诊断时记录事件类型 explicit
	诊断检查已开立	临床人员为实验室检查或影像学检查录入医嘱时发生。该时间戳用于启动诊断周转时间计算。
为什么重要 “诊断结果交付时间”KPI的起点，有助于识别开立与执行之间的延迟。获取位置 ORDERS表，使用ORIG_ORDER_DT_TM，并筛选目录类型为Laboratory或Radiology的记录。采集医嘱状态设置为ORDERED时记录事件类型 explicit
	诊断结果已验证	实验室或影像学结果最终确定并提供给临床人员的时刻，标志着诊断周转时间区间结束。
为什么重要完成“诊断结果交付时间”周期，并触发后续治疗决策。获取位置 CLINICAL_EVENT表（实验室检查）或ORDERS状态变更为COMPLETED。采集结果状态变更为AUTH（Authenticated）时记录事件类型 explicit
	会诊已完成	标志着专科会诊完成，通常以已签署的会诊记录或文档为依据。
为什么重要识别何时获得专科意见，这在复杂护理路径中可能成为瓶颈。获取位置 CLINICAL_EVENT表，筛选归类为Consultations的文档类型。采集会诊记录签署时记录事件类型 explicit
	后续预约已安排	为患者预订与同一就诊阶段或护理计划关联的未来预约时发生。
为什么重要支持“后续预约及时性”仪表板，用于衡量护理连续性效率。获取位置 SCH_APPT（预约排程）表，与PERSON_ID关联。采集在排程模块中创建预约时记录事件类型 explicit
	已执行用药	记录根据用药管理记录（MAR）为患者实际执行用药的情况。
为什么重要支持“用药执行合规”仪表板，用于验证药物是否按时给药。获取位置 CLINICAL_EVENT表，筛选用药执行事件（Task Status = Complete）。采集扫描条形码或手动录入MAR时记录事件类型 explicit
	护理计划已激活	表示在Cerner中启动PowerPlan或护理路径，说明已选择标准化治疗协议。
为什么重要对于“治疗协议偏差分析”至关重要，可将实际护理与计划路径进行对比。获取位置 ACT_PW_CAT（Action Pathway Catalog）或DCP_FORMS_REF，将路径与就诊记录关联。采集启动PowerPlan时记录事件类型 explicit
	操作已完成	表示手术或重大操作实际进行的时间戳，通常记录在围手术期文档中。
为什么重要是临床路径和资源利用分析的关键里程碑。获取位置 SURGICAL_CASE表（病例开始/结束时间）或用于床旁操作的CLINICAL_EVENT。采集通过SurgiNet或操作文档记录事件类型 explicit
	检查已安排	表示手术病例或重大操作已安排在特定时间进行，有助于了解资源配置和术前等待时间。
为什么重要突出手术室或操作室利用率中的排程效率和潜在瓶颈。获取位置 SURGICAL_CASE表或与就诊记录关联的SCH_APPT表。采集排程交易提交时记录事件类型 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 Sets（例如Encounter Types、Order Catalogs、Event Codes）定义常量，避免将会因域而异的数字code_value标识符直接写入脚本。您可能需要在CODE_VALUE表中查找所在组织的Triage、Discharge和Consult表单对应的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特有格式返回，例如Julian日期或非ISO时间戳，请使用Excel或脚本将其转换为YYYY-MM-DD HH:MM:SS格式后再上传。
验证：在PowerChart中抽查已知患者的Encounter ID（FIN），确认时间戳与提取结果一致。
上传至ProcessMind：将CSV文件导入ProcessMind，并将EncounterId映射为Case ID，将ClinicalEventTag映射为Activity，将EventEndDateTime映射为Timestamp。

配置

日期范围：建议执行窗口为3至6个月。由于CLINICAL_EVENT表数据量较大，日期范围过长可能导致超时。
Code Sets（CDF）：查询依赖code_value筛选条件。您必须将[REPLACE_WITH_TRIAGE_EVENT_CD]等占位符替换为所在域中的实际代码，这些代码可在CODE_VALUE表中找到。
权限：执行脚本的用户需要拥有d（Database）访问权限，以访问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资源的日期范围迭代，以确定患者就诊事件范围。
获取Encounter（患者就诊事件）：查询Encounter资源。该对象作为中心枢纽（案例标识符）。从Encounter资源中提取period.start，生成Patient Registered活动；提取period.end，生成Patient Discharged活动；并遍历location历史记录，生成Department Transfer Occurred活动。
提取临床订单：按Encounter ID查询ServiceRequest资源。使用intent=order筛选，以捕获Diagnostic Order Placed和Procedure Scheduled（如果归类为手术订单）。将authoredOn映射为事件时间戳。
提取诊断和问题：查询与Encounter关联的Condition资源。使用recordedDate或onsetDateTime创建Diagnosis Documented活动。条件允许时，筛选encounter-diagnosis类别。
提取操作：查询Procedure资源。使用performedDateTime生成Procedure Performed活动，以区分已完成的手术和已安排的手术。
提取用药记录：查询MedicationAdministration资源。它不同于MedicationRequest，因为记录的是实际给药。使用effectiveDateTime生成Medication Administered活动。
提取实验室数据和结果：查询Observation或DiagnosticReport资源。使用issued或effectiveDateTime生成Diagnostic Result Verified活动。查找status=final。同时，使用特定的Observation代码，例如用于分诊紧急程度的LOINC代码，识别Triage Assessment Completed活动。
提取文档和照护计划：查询DocumentReference，使用文档类型代码生成Consultation Completed活动；查询CarePlan，生成Care Plan Activated活动。
识别出院活动：要推导Discharge Order Signed，通常需要检查包含特定出院医嘱代码的ServiceRequest，或解析Encounter.statusHistory，查找最终出院前的状态。
数据转换和导出：将JSON响应展平为表格格式。创建所需列（EncounterId、ClinicalEventTag、EventEndDateTime等）。将时间戳转换为ISO 8601格式，并将最终数据集导出为可上传至ProcessMind的CSV文件。

配置

FHIR基础URL：您所在Oracle Health/Cerner实例的具体端点，例如https://fhir-myrecord.cerner.com/r4/...。
身份验证作用域：确保应用已启用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速率限制（Throttling）。
代码筛选：在脚本映射部分配置特定的LOINC或SNOMED代码，以准确区分Triage与General Observations。

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")

准备开始了吗？

使用此模板准备数据，开始发现患者就诊旅程中的有价值洞察。优化患者结果的旅程，就从这里开始。

返回改进指南下载模板

立即优化患者就诊旅程，快速改善结果

快速识别瓶颈，将患者就诊旅程周期时间缩短30%。

开始免费试用

无需信用卡，几分钟即可开始。

患者就诊旅程数据模板

患者就诊旅程数据模板

患者旅程属性

患者旅程活动

提取指南

通过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

准备开始了吗？

立即优化患者就诊旅程，快速改善结果

我们重视您的隐私