From 13b23e90f40b96d6a67ff79896736fec5b352f5a Mon Sep 17 00:00:00 2001 From: iven Date: Mon, 27 Apr 2026 14:51:40 +0800 Subject: [PATCH] =?UTF-8?q?feat(health):=20=E6=B6=88=E6=81=AF=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E9=9B=86=E6=88=90=20=E2=80=94=20=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=90=AF=E5=8A=A8=20+=20=E9=A2=84=E7=BA=A6?= =?UTF-8?q?=E6=8F=90=E9=86=92=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - erp-server: 启动逾期随访检查(6h)、积分过期(24h)、预约提醒(1h) 定时任务 - appointment_service: 新增 send_reminders 扫描明日确认预约发送事件 - erp-message: 订阅 appointment.reminder 事件，向患者发送提醒消息 --- crates/erp-health/src/module.rs | 22 ++++++++++ .../src/service/appointment_service.rs | 40 +++++++++++++++++++ crates/erp-message/src/module.rs | 36 +++++++++++++++++ crates/erp-server/src/main.rs | 13 +++++- 4 files changed, 109 insertions(+), 2 deletions(-) diff --git a/crates/erp-health/src/module.rs b/crates/erp-health/src/module.rs index aa094c8..f7ea19a 100644 --- a/crates/erp-health/src/module.rs +++ b/crates/erp-health/src/module.rs @@ -62,6 +62,28 @@ impl HealthModule { }) } + /// 启动预约提醒调度（每 1 小时运行一次），扫描明天有预约的患者发送提醒 + pub fn start_appointment_reminder(db: sea_orm::DatabaseConnection, event_bus: erp_core::events::EventBus) -> tokio::task::JoinHandle<()> { + tokio::spawn(async move { + let mut interval = tokio::time::interval(std::time::Duration::from_secs(3600)); + loop { + tokio::select! { + _ = interval.tick() => { + match crate::service::appointment_service::send_reminders(&db, &event_bus).await { + Ok(count) if count > 0 => tracing::info!(count = count, "预约提醒发送完成"), + Ok(_) => {} + Err(e) => tracing::warn!(error = %e, "预约提醒发送失败"), + } + } + _ = tokio::signal::ctrl_c() => { + tracing::info!("预约提醒调度任务收到关闭信号，正在停止"); + break; + } + } + } + }) + } + pub fn public_routes() -> Router where crate::state::HealthState: axum::extract::FromRef, diff --git a/crates/erp-health/src/service/appointment_service.rs b/crates/erp-health/src/service/appointment_service.rs index 0bcbff7..489e9b7 100644 --- a/crates/erp-health/src/service/appointment_service.rs +++ b/crates/erp-health/src/service/appointment_service.rs @@ -547,3 +547,43 @@ pub async fn calendar_view( Ok(result) } + +/// 扫描明天有预约的患者，通过事件总线发送预约提醒 +/// 由定时任务每小时调用一次 +pub async fn send_reminders( + db: &sea_orm::DatabaseConnection, + event_bus: &erp_core::events::EventBus, +) -> crate::error::HealthResult { + use chrono::{Local, NaiveDate}; + use serde_json::json; + + let tomorrow = Local::now().date_naive() + chrono::Duration::days(1); + + // 查找明天所有确认状态的预约 + let apps = appointment::Entity::find() + .filter(appointment::Column::AppointmentDate.eq(tomorrow)) + .filter(appointment::Column::Status.eq("confirmed")) + .filter(appointment::Column::DeletedAt.is_null()) + .all(db) + .await?; + + let count = apps.len(); + for app in apps { + event_bus.publish( + DomainEvent::new( + "appointment.reminder", + app.tenant_id, + json!({ + "appointment_id": app.id, + "patient_id": app.patient_id, + "doctor_id": app.doctor_id, + "appointment_date": app.appointment_date, + "time_slot": format!("{}-{}", app.start_time.format("%H:%M"), app.end_time.format("%H:%M")), + }), + ), + db, + ).await; + } + + Ok(count) +} diff --git a/crates/erp-message/src/module.rs b/crates/erp-message/src/module.rs index 9a2182b..5f3520e 100644 --- a/crates/erp-message/src/module.rs +++ b/crates/erp-message/src/module.rs @@ -352,6 +352,42 @@ async fn handle_workflow_event( .map_err(|e| e.to_string())?; } } + "appointment.reminder" => { + let patient_id = event + .payload + .get("patient_id") + .and_then(|v| v.as_str()) + .and_then(|s| uuid::Uuid::parse_str(s).ok()); + let appointment_date = event + .payload + .get("appointment_date") + .and_then(|v| v.as_str()) + .unwrap_or("明天"); + let time_slot = event + .payload + .get("time_slot") + .and_then(|v| v.as_str()) + .unwrap_or(""); + + if let Some(pid) = patient_id { + if should_skip_for_dnd(event.tenant_id, pid, "normal", db).await { + return Ok(()); + } + let _ = crate::service::message_service::MessageService::send_system( + event.tenant_id, + pid, + "预约提醒".to_string(), + format!("您明天（{}）有一个预约，时间段：{}，请准时就诊。", appointment_date, time_slot), + "normal", + Some("appointment".to_string()), + event.payload.get("appointment_id").and_then(|v| v.as_str()).and_then(|s| uuid::Uuid::parse_str(s).ok()), + db, + event_bus, + ) + .await + .map_err(|e| e.to_string())?; + } + } "health_data.critical_alert" => { let patient_name = event .payload diff --git a/crates/erp-server/src/main.rs b/crates/erp-server/src/main.rs index e612395..aa64510 100644 --- a/crates/erp-server/src/main.rs +++ b/crates/erp-server/src/main.rs @@ -414,8 +414,17 @@ async fn main() -> anyhow::Result<()> { erp_workflow::WorkflowModule::start_timeout_checker(db.clone(), event_bus.clone()); tracing::info!("Timeout checker started"); - // Start follow-up overdue checker (handled by HealthModule::on_startup) - tracing::info!("Follow-up overdue checker delegated to module on_startup"); + // Start follow-up overdue checker (every 6h) + erp_health::HealthModule::start_overdue_checker(db.clone()); + tracing::info!("Follow-up overdue checker started"); + + // Start points expiration checker (every 24h) + erp_health::HealthModule::start_points_expiration_checker(db.clone(), event_bus.clone()); + tracing::info!("Points expiration checker started"); + + // Start appointment reminder scheduler (every 1h) + erp_health::HealthModule::start_appointment_reminder(db.clone(), event_bus.clone()); + tracing::info!("Appointment reminder scheduler started"); let host = config.server.host.clone(); let port = config.server.port;