use axum::Extension;
use axum::extract::{FromRef, Json, Path, Query, State};
use erp_core::error::AppError;
use erp_core::rbac::require_permission;
use erp_core::types::{ApiResponse, PaginatedResponse, TenantContext};

use crate::service::action_inbox_service::{
    self, ActionInboxQuery, ActionItem, NursePatientSummary, TeamOverview, ThreadResponse,
    WorkbenchStats,
};
use crate::state::HealthState;

pub async fn list_action_inbox<S>(
    State(state): State<HealthState>,
    Extension(ctx): Extension<TenantContext>,
    Query(query): Query<ActionInboxQuery>,
) -> Result<Json<ApiResponse<PaginatedResponse<ActionItem>>>, AppError>
where
    HealthState: FromRef<S>,
    S: Clone + Send + Sync + 'static,
{
    require_permission(&ctx, "health.action-inbox.list")?;
    let user_id = if query.assigned_to_me.unwrap_or(false) {
        Some(ctx.user_id)
    } else {
        None
    };
    let result =
        action_inbox_service::list_action_items(&state.db, ctx.tenant_id, user_id, &query).await?;
    Ok(Json(ApiResponse::ok(result)))
}

pub async fn get_action_thread<S>(
    State(state): State<HealthState>,
    Extension(ctx): Extension<TenantContext>,
    Path(source_ref): Path<String>,
) -> Result<Json<ApiResponse<ThreadResponse>>, AppError>
where
    HealthState: FromRef<S>,
    S: Clone + Send + Sync + 'static,
{
    require_permission(&ctx, "health.action-inbox.list")?;
    let result =
        action_inbox_service::get_action_thread(&state.db, ctx.tenant_id, &source_ref).await?;
    match result {
        Some(resp) => Ok(Json(ApiResponse::ok(resp))),
        None => Err(crate::error::HealthError::Validation("行动项未找到".into()).into()),
    }
}

pub async fn get_workbench_stats<S>(
    State(state): State<HealthState>,
    Extension(ctx): Extension<TenantContext>,
    Query(params): Query<WorkbenchStatsQuery>,
) -> Result<Json<ApiResponse<WorkbenchStats>>, AppError>
where
    HealthState: FromRef<S>,
    S: Clone + Send + Sync + 'static,
{
    require_permission(&ctx, "health.action-inbox.list")?;
    let user_id = if params.assigned_to_me.unwrap_or(false) {
        Some(ctx.user_id)
    } else {
        None
    };
    let result =
        action_inbox_service::get_workbench_stats(&state.db, ctx.tenant_id, user_id).await?;
    Ok(Json(ApiResponse::ok(result)))
}

#[derive(Debug, serde::Deserialize)]
pub struct WorkbenchStatsQuery {
    pub assigned_to_me: Option<bool>,
}

pub async fn get_team_overview<S>(
    State(state): State<HealthState>,
    Extension(ctx): Extension<TenantContext>,
) -> Result<Json<ApiResponse<TeamOverview>>, AppError>
where
    HealthState: FromRef<S>,
    S: Clone + Send + Sync + 'static,
{
    require_permission(&ctx, "health.action-inbox.team")?;
    let result = action_inbox_service::get_team_overview(&state.db, ctx.tenant_id).await?;
    Ok(Json(ApiResponse::ok(result)))
}

/// 获取护士班次患者列表 — 今日分配给当前护士的患者
pub async fn get_nurse_patients<S>(
    State(state): State<HealthState>,
    Extension(ctx): Extension<TenantContext>,
) -> Result<Json<ApiResponse<Vec<NursePatientSummary>>>, AppError>
where
    HealthState: FromRef<S>,
    S: Clone + Send + Sync + 'static,
{
    require_permission(&ctx, "health.action-inbox.list")?;
    let result =
        action_inbox_service::get_nurse_patients(&state.db, ctx.tenant_id, ctx.user_id).await?;
    Ok(Json(ApiResponse::ok(result)))
}