From 8a61ae3f8e17dd8480a498d2509cbb1d1375ef69 Mon Sep 17 00:00:00 2001
From: iven <iven_h@qq.com>
Date: Tue, 28 Apr 2026 19:37:43 +0800
Subject: [PATCH] =?UTF-8?q?feat(health):=20device=5Freadings=20=E5=8F=8C?=
 =?UTF-8?q?=E5=86=99=20vital=5Fsigns=20=E2=80=94=20=E8=A1=80=E5=8E=8B/?=
 =?UTF-8?q?=E8=A1=80=E7=B3=96=E8=87=AA=E5=8A=A8=E5=BD=92=E6=A1=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/service/device_reading_service.rs     | 94 ++++++++++++++++++-
 1 file changed, 93 insertions(+), 1 deletion(-)

diff --git a/crates/erp-health/src/service/device_reading_service.rs b/crates/erp-health/src/service/device_reading_service.rs
index 8bfdb40..7261f55 100644
--- a/crates/erp-health/src/service/device_reading_service.rs
+++ b/crates/erp-health/src/service/device_reading_service.rs
@@ -8,7 +8,7 @@ use uuid::Uuid;
 use erp_core::events::DomainEvent;
 use erp_core::types::PaginatedResponse;
 
-use crate::entity::{device_readings, patient, patient_devices, vital_signs_hourly};
+use crate::entity::{device_readings, patient, patient_devices, vital_signs, vital_signs_hourly};
 use crate::error::{HealthError, HealthResult};
 use crate::service::validation::validate_device_type;
 use crate::state::HealthState;
@@ -118,6 +118,13 @@ pub async fn batch_create_readings(
         &parsed_readings,
     ).await?;
 
+    // 4.5 双写 vital_signs（血压/血糖自动归档）
+    if let Err(e) = sync_bp_glucose_to_vital_signs(
+        &state.db, tenant_id, patient_id, &parsed_readings,
+    ).await {
+        tracing::warn!(error = %e, "双写 vital_signs 失败（不影响主流程）");
+    }
+
     // 5. 降采样 upsert
     upsert_hourly_aggregates(
         &state.db, tenant_id, patient_id, &parsed_readings,
@@ -440,3 +447,88 @@ pub async fn query_hourly_readings(
         total_pages: total.div_ceil(limit.max(1)),
     })
 }
+
+/// 将血压/血糖设备数据同步到 vital_signs 表
+async fn sync_bp_glucose_to_vital_signs(
+    db: &DatabaseConnection,
+    tenant_id: Uuid,
+    patient_id: Uuid,
+    readings: &[(&ReadingInput, DateTime<Utc>)],
+) -> HealthResult<()> {
+    let bp_readings: Vec<_> = readings
+        .iter()
+        .filter(|(r, _)| matches!(r.device_type.as_str(), "blood_pressure" | "blood_glucose"))
+        .collect();
+
+    if bp_readings.is_empty() {
+        return Ok(());
+    }
+
+    let today = Utc::now().date_naive();
+
+    let existing = vital_signs::Entity::find()
+        .filter(vital_signs::Column::TenantId.eq(tenant_id))
+        .filter(vital_signs::Column::PatientId.eq(patient_id))
+        .filter(vital_signs::Column::RecordDate.eq(today))
+        .filter(vital_signs::Column::DeletedAt.is_null())
+        .one(db)
+        .await
+        .map_err(|e| HealthError::DbError(e.to_string()))?;
+
+    let mut model = if let Some(rec) = existing {
+        let mut m: vital_signs::ActiveModel = rec.into();
+        m.updated_at = Set(Utc::now());
+        m.version = Set(m.version.unwrap() + 1);
+        m
+    } else {
+        vital_signs::ActiveModel {
+            id: Set(Uuid::now_v7()),
+            tenant_id: Set(tenant_id),
+            patient_id: Set(patient_id),
+            record_date: Set(today),
+            source: Set("device_auto".into()),
+            created_at: Set(Utc::now()),
+            updated_at: Set(Utc::now()),
+            created_by: Set(None),
+            updated_by: Set(None),
+            deleted_at: Set(None),
+            version: Set(1),
+            ..Default::default()
+        }
+    };
+
+    let mut changed = false;
+
+    for (r, _) in &bp_readings {
+        let metric = r.values.get("metric").and_then(|v| v.as_str()).unwrap_or("");
+        let value = r.values.get("value").and_then(|v| v.as_f64()).unwrap_or(0.0);
+
+        match (r.device_type.as_str(), metric) {
+            ("blood_pressure", "systolic") => {
+                model.systolic_bp_morning = Set(Some(value.round() as i32));
+                changed = true;
+            }
+            ("blood_pressure", "diastolic") => {
+                model.diastolic_bp_morning = Set(Some(value.round() as i32));
+                changed = true;
+            }
+            ("blood_glucose", _) => {
+                let dec_val = sea_orm::prelude::Decimal::from_f64_retain(value).unwrap_or_default();
+                model.blood_sugar = Set(Some(dec_val));
+                changed = true;
+            }
+            _ => {}
+        }
+    }
+
+    if changed {
+        let is_update = matches!(model.version, Set(v) if v > 1);
+        if is_update {
+            model.update(db).await.map_err(|e| HealthError::DbError(e.to_string()))?;
+        } else {
+            model.insert(db).await.map_err(|e| HealthError::DbError(e.to_string()))?;
+        }
+    }
+
+    Ok(())
+}