> 持续流程改进 > 患者就医旅程 > 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	用于标识特定患者就诊或诊疗事件的唯一标识符。
说明此属性是患者诊疗过程的核心案例标识符，用于汇总同一诊疗期间（如住院或急诊就诊）发生的所有临床事件、医嘱和行政操作。在流程挖掘中，此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”。在多系统环境中，数据可能与其他电子病历系统或科室系统的数据合并，此属性有助于识别数据来源。如果接入了多个数据源，分析人员可以据此筛选或细分流程分析。重要性确保数据沿袭可追溯，尤其适用于多系统流程挖掘场景。获取途径硬编码字符串或系统元数据示例 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）不同于案例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放射科
	入院渠道 AdmissionSource	患者入院的来源。
说明描述患者如何进入医院系统，例如“医生转诊”“急诊室”或“从其他医院转入”。此属性有助于分析医院流程的入口，对应`ENCOUNTER`表中的`ADMIT_SRC_CD`。重要性根据入院渠道，为“初步评估等待时间”提供背景信息。获取途径表：ENCOUNTER，列：ADMIT_SRC_CD 示例急诊室医生转诊从其他医院转入
	分诊优先级 TriageAcuity	分诊评估时确定的紧急程度。
说明表示患者病情严重程度的数值或类别（例如1级为立即处理，5级为非紧急）。这是分析等待时间的重要细分属性，因为优先级较高的患者等待时间应更短。通常在分诊时记录于临床表单或特定观察代码中。重要性对于验证流程是否根据临床紧急程度正确安排患者优先级至关重要。获取途径请查阅Oracle Health（Cerner）文档示例 12345
	医嘱编号 OrderId	特定医嘱（化验、药物、会诊）的唯一标识符。
说明系统为医嘱生成的ID。它虽不是案例ID，却是重要的辅助键，可关联“已开具诊断检查医嘱”和“已验证诊断结果”事件。如果患者同时有多项医嘱，就难以据此准确计算特定检查的周转时间。重要性对于准确关联成对活动（医嘱→结果）至关重要。获取途径表：ORDERS，列：ORDER_ID 示例 88291028829103
	支付方类型 FinancialClass	患者的主要保险保障或财务分类。
说明根据患者的支付来源进行分类（例如Medicare、商业保险、自费）。此属性用于分析不同保险类型是否会影响流程或住院时长。此属性取自`ENCOUNTER`表中的`FINANCIAL_CLASS_CD`。重要性有助于发现支付方类型造成的护理服务或行政处理差异。获取途径表：ENCOUNTER，列：FINANCIAL_CLASS_CD（通过CODE_VALUE解析）示例 MedicareBlue Cross自费Medicaid
	用药状态 MedAdminStatus	药物医嘱的状态（例如已给药、已拒绝、未给药）。
说明表示给药任务的结果。对于“用药执行合规性”仪表板，区分实际给药与已安排但漏服或被拒绝的药物至关重要。此属性可能位于`CLINICAL_EVENT`表或专门的用药记录（MAR）表中。重要性用于识别治疗方案执行中的合规差距。获取途径请查阅Oracle Health（Cerner）文档示例已给药已拒绝暂缓给药
	结果状态 ResultStatus	诊断结果的状态（例如已审核（已验证）、已更正、初步结果）。
说明表示诊断检查结果所处的生命周期阶段。在“诊断结果交付时间”分析中，此属性用于确定结果何时正式可供临床决策使用。通常可在`CLINICAL_EVENT`表的特定状态代码中找到。重要性区分初步结果和最终结果，这会影响后续活动何时可以开始。获取途径表：CLINICAL_EVENT，列：RESULT_STATUS_CD 示例已审核（已验证）有误已修改

必填建议填写选填

患者就医历程活动

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

8 建议填写 6 选填

	活动	说明
	出院医嘱已签署	医生下达患者出院医嘱时记录的事件。此时开始计算出院计划周期。
重要性 “出院计划周期时间”的起点。此时与实际出院时间之间的间隔反映了运营延误。获取途径 ORDERS表，目录类型标明为出院。采集出院医嘱状态为ORDERED时记录事件类型 explicit
	分诊评估已完成	表示急诊或入院过程中初次护理评估或分诊表单已完成。通常会在系统中记录为特定表单或临床事件。
重要性这是计算“初次评估等待时间”KPI并识别入口环节瓶颈的关键数据。获取途径 CLINICAL_EVENT表，筛选与分诊或初次评估表单相关的事件代码。采集临床文档或表单签署、核验时记录事件类型 explicit
	已发生科室转运	表示患者已从一个地点（如急诊室）转移到另一个地点（如ICU），通过位置历史记录进行跟踪。
重要性支持“病区间转运效率”分析，并帮助直观呈现患者在医院内的流转情况。获取途径 ENCNTR_LOC_HIST（就诊位置历史）表，记录LOC_NURSE_UNIT_CD的变更。采集比较变更前后的状态字段事件类型 inferred
	已开具诊断检查	临床人员录入实验室检查或影像检查医嘱时发生。此时间戳用于开始计算诊断周转时间。
重要性这是“诊断结果交付时间”KPI的起点，有助于区分开具医嘱和执行检查环节的延误。获取途径 ORDERS表，使用ORIG_ORDER_DT_TM，并筛选目录类型为Laboratory或Radiology的记录。采集医嘱状态设为ORDERED时记录事件类型 explicit
	已记录诊断	正式诊断添加到患者就诊记录时发生。这不同于检查结果，代表临床人员已确认患者的病情。
重要性这是“确诊”里程碑的必要数据，也用于分析明确诊断所需时间。获取途径 DIAGNOSIS表，使用与ENCOUNTER_ID关联的DIAGNOSIS_DT_TM。采集在PowerChart中添加或更新诊断时记录事件类型 explicit
	患者出院	结束患者住院过程的最后一项行政事件。此时间戳用于计算总住院时长。
重要性流程的主要结束事件，是计算住院时长和再入院率的关键。获取途径 ENCOUNTER表中的DISCH_DT_TM（出院日期/时间）。采集就诊状态变为DISCHARGED时记录事件类型 explicit
	患者已登记	标记患者到达并录入系统时患者就诊记录的开始。在Cerner Millennium中，创建就诊记录或设置登记时间戳时会记录此事件。
重要性用于确定住院时间（LOS）的计算起点，并开展初始等待时间分析。获取途径 ENCOUNTER表，具体为REG_DT_TM（登记日期/时间）列。采集创建新的ENCOUNTER行时记录事件类型 explicit
	诊断结果已核验	实验室或影像检查结果最终确认并提供给临床人员的时刻。此时诊断周转时间结束。
重要性完成“诊断结果交付时间”周期，并触发后续治疗决策。获取途径 CLINICAL_EVENT表（实验室检查），或ORDERS状态变更为COMPLETED。采集结果状态变更为AUTH（Authenticated）时记录事件类型 explicit
	会诊已完成	标记专科会诊已完成，通常以已签署的会诊记录或文档为依据。
重要性用于确定何时获得专科意见，这可能是复杂护理路径中的瓶颈。获取途径 CLINICAL_EVENT表，筛选归类为会诊的文档类型。采集会诊记录签署时记录事件类型 explicit
	已安排操作	表示手术或重大操作已安排在特定时间进行，有助于了解资源配置和操作前等待时间。
重要性用于评估手术室或操作室的排期效率，并发现潜在瓶颈。获取途径 SURGICAL_CASE表，或与就诊记录关联的SCH_APPT表。采集排期事务提交时记录事件类型 explicit
	已安排随访预约	为患者预约未来就诊，且预约关联到同一诊疗事件或护理计划时发生。
重要性支持“随访预约及时性”仪表板，用于衡量护理连续性的效率。获取途径 SCH_APPT（预约安排）表，关联PERSON_ID。采集在预约模块中创建预约时记录事件类型 explicit
	已实施操作	记录手术或重大操作实际进行时间的时间戳，通常来自围手术期文档。
重要性这是临床路径和资源利用分析的关键里程碑。获取途径 SURGICAL_CASE表（病例开始/结束时间），或用于床旁操作的CLINICAL_EVENT表。采集通过SurgiNet或操作文档记录事件类型 explicit
	已执行用药	记录根据用药记录（MAR）为患者实际给药的情况。
重要性用于支持“用药合规性”仪表板，核实是否按时给药。获取途径 CLINICAL_EVENT表，筛选用药执行事件（Task Status = Complete）。采集扫描条形码或手动录入MAR时记录事件类型 explicit
	护理计划已激活	表示在Cerner中启动PowerPlan或护理路径，说明已选定标准化治疗方案。
重要性这是开展“治疗方案偏差分析”的关键数据，可用于将实际护理与计划路径进行比较。获取途径 ACT_PW_CAT（Action Pathway Catalog）或DCP_FORMS_REF，用于将路径关联到就诊记录。采集启动PowerPlan时记录事件类型 explicit

建议填写选填

数据提取指南

如何从Oracle Health（Cerner）获取数据

步骤

启动Discern Visual Developer：在Citrix或本地Cerner域访问环境中打开Discern Visual Developer（DVDev）应用程序。
创建新脚本：新建命令语言（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映射为案例ID、ClinicalEventTag映射为活动、EventEndDateTime映射为时间戳。

配置

日期范围：建议提取最近3至6个月的数据。由于CLINICAL_EVENT表数据量较大，日期范围过长可能导致超时。
代码集（CDF）：查询依赖code_value筛选条件。您必须将[REPLACE_WITH_TRIAGE_EVENT_CD]等占位符替换为所在域的实际代码（可在CODE_VALUE表中查找）。
权限：执行脚本的用户需要对ENCOUNTER、CLINICAL_EVENT、ORDERS、SURG_CASE_TBL、ENCNTR_LOC_HIST和SCH_APPOINTMENT等表具有d（Database）访问权限。
性能：CLINICAL_EVENT表数据量很大。请确保EVENT_END_DT_TM上的日期筛选字段已建立索引，并严格应用筛选条件。
再入院逻辑：IsReadmission属性目前是占位字段。复杂的回溯判断建议在数据加载后通过ProcessMind应用处理，而不是放在提取查询中。

查询示例 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、过程、MedicationAdministration、ServiceRequest和DiagnosticReport。
处理身份验证：实现身份验证处理程序，从授权服务器获取Bearer令牌。Cerner通常使用SMART on FHIR或标准OAuth2客户端凭据流程。提供的脚本已处理令牌获取。
确定范围和时间段：确定数据提取时间范围（例如使用last_updated_gt或date参数）。建议按Encounter资源的日期范围迭代，以确定患者就诊记录的范围。
提取就诊记录（患者就诊）：查询Encounter资源。该资源是核心对象，用作案例标识符。从Encounter资源中提取period.start作为患者登记时间，提取period.end作为患者出院时间，并遍历location历史记录以识别发生部门转移。
提取临床医嘱：按Encounter ID筛选ServiceRequest资源。通过intent=order筛选，获取已开具诊断医嘱和已安排操作（若归类为外科医嘱）。将authoredOn映射为事件时间戳。
提取诊断和问题：查询与Encounter关联的Condition资源。使用recordedDate或onsetDateTime创建已记录诊断事件。条件允许时，筛选encounter-diagnosis类别。
提取操作：查询过程资源。使用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/...）。
身份验证范围：确保应用已启用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），以获取完整数据集。
并发：大批量提取时，可考虑按就诊ID范围并行发送请求，但须遵守API速率限制（限流）。
代码筛选：在脚本映射部分配置特定的LOINC或SNOMED代码，以准确区分分诊记录和一般观察记录。

查询示例 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命令语言提取数据

步骤

配置

查询示例 sql

通过Oracle Health FHIR R4 API使用Python提取数据

步骤

配置

查询示例 python

准备好开始了吗？

立即优化患者就医历程，尽快改善治疗效果