iven/hms
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(health): FHIR $everything 子查询添加 tenant_id 过滤

Browse Source
This commit is contained in:
iven
2026-05-05 23:44:25 +08:00
parent 087e23e57b
commit 482871301e
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crates/erp-health/src/fhir/handler.rs
View File

@@ -687,6 +687,7 @@ pub async fn patient_everything(
// 2. Observations（设备读数） // 2. Observations（设备读数）
let readings = crate::entity::device_readings::Entity::find() let readings = crate::entity::device_readings::Entity::find()
.filter(crate::entity::device_readings::Column::PatientId.eq(id)) .filter(crate::entity::device_readings::Column::PatientId.eq(id))
.filter(crate::entity::device_readings::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::device_readings::Column::DeletedAt.is_null()) .filter(crate::entity::device_readings::Column::DeletedAt.is_null())
.limit(200) .limit(200)
.all(&state.db) .all(&state.db)
@@ -700,6 +701,7 @@ pub async fn patient_everything(
// 3. Devices // 3. Devices
let devices = crate::entity::patient_devices::Entity::find() let devices = crate::entity::patient_devices::Entity::find()
.filter(crate::entity::patient_devices::Column::PatientId.eq(id)) .filter(crate::entity::patient_devices::Column::PatientId.eq(id))
.filter(crate::entity::patient_devices::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::patient_devices::Column::DeletedAt.is_null()) .filter(crate::entity::patient_devices::Column::DeletedAt.is_null())
.all(&state.db) .all(&state.db)
.await?; .await?;
@@ -710,6 +712,7 @@ pub async fn patient_everything(
// 4. Encounters（咨询会话） // 4. Encounters（咨询会话）
let consultations = crate::entity::consultation_session::Entity::find() let consultations = crate::entity::consultation_session::Entity::find()
.filter(crate::entity::consultation_session::Column::PatientId.eq(id)) .filter(crate::entity::consultation_session::Column::PatientId.eq(id))
.filter(crate::entity::consultation_session::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::consultation_session::Column::DeletedAt.is_null()) .filter(crate::entity::consultation_session::Column::DeletedAt.is_null())
.all(&state.db) .all(&state.db)
.await?; .await?;
@@ -720,6 +723,7 @@ pub async fn patient_everything(
// 5. Appointments // 5. Appointments
let appointments = crate::entity::appointment::Entity::find() let appointments = crate::entity::appointment::Entity::find()
.filter(crate::entity::appointment::Column::PatientId.eq(id)) .filter(crate::entity::appointment::Column::PatientId.eq(id))
.filter(crate::entity::appointment::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::appointment::Column::DeletedAt.is_null()) .filter(crate::entity::appointment::Column::DeletedAt.is_null())
.all(&state.db) .all(&state.db)
.await?; .await?;
@@ -730,6 +734,7 @@ pub async fn patient_everything(
// 6. Tasks（随访任务） // 6. Tasks（随访任务）
let tasks = crate::entity::follow_up_task::Entity::find() let tasks = crate::entity::follow_up_task::Entity::find()
.filter(crate::entity::follow_up_task::Column::PatientId.eq(id)) .filter(crate::entity::follow_up_task::Column::PatientId.eq(id))
.filter(crate::entity::follow_up_task::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::follow_up_task::Column::DeletedAt.is_null()) .filter(crate::entity::follow_up_task::Column::DeletedAt.is_null())
.limit(50) .limit(50)
.all(&state.db) .all(&state.db)
@@ -741,6 +746,7 @@ pub async fn patient_everything(
// 7. DiagnosticReports（化验报告） // 7. DiagnosticReports（化验报告）
let reports = crate::entity::lab_report::Entity::find() let reports = crate::entity::lab_report::Entity::find()
.filter(crate::entity::lab_report::Column::PatientId.eq(id)) .filter(crate::entity::lab_report::Column::PatientId.eq(id))
.filter(crate::entity::lab_report::Column::TenantId.eq(ctx.tenant_id))
.filter(crate::entity::lab_report::Column::DeletedAt.is_null()) .filter(crate::entity::lab_report::Column::DeletedAt.is_null())
.limit(50) .limit(50)
.all(&state.db) .all(&state.db)