add blood inventory

Author: cjustinobi

src/handlers/hospitals.rs

@@ -41,6 +41,7 @@ pub struct CreateHospitalRequest {
     pub has_blood_bank: bool,
     pub accepting_donors: bool,
     pub donating_operating_hours: Option<String>,
+    pub blood_inventory: Option<Vec<BloodInventoryUpdate>>,
 }
 
 #[derive(Debug, Deserialize, ToSchema)]
@@ -145,7 +146,7 @@ pub async fn create_hospital(
         accepting_donors: hospital.accepting_donors,
         donating_operating_hours: hospital.donating_operating_hours,
         created_at: hospital.created_at,
-        blood_inventory: vec![], // New hospital has no inventory yet
+        blood_inventory: hospitals::service::get_hospital_inventory(&mut conn, hospital.id)?,
     };
 
     Ok(ApiResponse::success_with_message(
@@ -447,19 +448,44 @@ pub async fn upload_accreditation_doc(
     get,
     path = "/api/hospitals",
     responses(
-        (status = 200, body = ApiResponse<Vec<Hospital>>),
+        (status = 200, body = ApiResponse<Vec<HospitalResponse>>),
         (status = 500)
     ),
     tag = "hospitals"
 )]
 pub async fn get_hospitals(
     State(state): State<AppState>,
-) -> Result<ApiResponse<Vec<Hospital>>, AppError> {
+) -> Result<ApiResponse<Vec<HospitalResponse>>, AppError> {
     let mut conn = state.pool.get()?;
     let hospitals = hospitals::service::get_hospitals(&mut conn)?;
+
+    let mut response = Vec::new();
+    for hospital in hospitals {
+        let inventory = hospitals::service::get_hospital_inventory(&mut conn, hospital.id)?;
+        response.push(HospitalResponse {
+            id: hospital.id,
+            name: hospital.name,
+            hospital_type: hospital.hospital_type,
+            address: hospital.address,
+            city: hospital.city,
+            country: hospital.country,
+            primary_phone: hospital.primary_phone,
+            emergency_phone: hospital.emergency_phone,
+            email: hospital.email,
+            license_number: hospital.license_number,
+            accreditation_doc_url: hospital.accreditation_doc_url,
+            license_status: hospital.license_status,
+            has_blood_bank: hospital.has_blood_bank,
+            accepting_donors: hospital.accepting_donors,
+            donating_operating_hours: hospital.donating_operating_hours,
+            created_at: hospital.created_at,
+            blood_inventory: inventory,
+        });
+    }
+
     Ok(ApiResponse::success_with_message(
         "Hospitals retrieved successfully",
-        hospitals,
+        response,
     ))
 }
 

src/hospitals/service.rs

@@ -52,26 +52,44 @@ pub fn create_hospital(
         validate_phone_length(emergency, 11, 15)?;
     }
 
-    let hospital: Hospital = diesel::insert_into(hospitals)
-        .values((
-            user_id.eq(user.id),
-            name.eq(payload.name),
-            hospital_type.eq(payload.hospital_type),
-            address.eq(payload.address),
-            city.eq(payload.city),
-            country.eq(payload.country),
-            primary_phone.eq(payload.primary_phone),
-            emergency_phone.eq(payload.emergency_phone),
-            email.eq(payload.email),
-            license_number.eq(payload.license_number),
-            accreditation_doc_url.eq(payload.accreditation_doc_url),
-            has_blood_bank.eq(payload.has_blood_bank),
-            accepting_donors.eq(payload.accepting_donors),
-            donating_operating_hours.eq(payload.donating_operating_hours),
-        ))
-        .returning(Hospital::as_select())
-        .get_result(conn)
-        .map_err(AppError::from)?;
+    let hospital: Hospital = conn.transaction::<Hospital, AppError, _>(|conn| {
+        let hospital: Hospital = diesel::insert_into(hospitals)
+            .values((
+                user_id.eq(user.id),
+                name.eq(payload.name),
+                hospital_type.eq(payload.hospital_type),
+                address.eq(payload.address),
+                city.eq(payload.city),
+                country.eq(payload.country),
+                primary_phone.eq(payload.primary_phone),
+                emergency_phone.eq(payload.emergency_phone),
+                email.eq(&payload.email),
+                license_number.eq(payload.license_number),
+                accreditation_doc_url.eq(payload.accreditation_doc_url),
+                has_blood_bank.eq(payload.has_blood_bank),
+                accepting_donors.eq(payload.accepting_donors),
+                donating_operating_hours.eq(payload.donating_operating_hours),
+            ))
+            .returning(Hospital::as_select())
+            .get_result(conn)
+            .map_err(AppError::from)?;
+
+        if let Some(inventory) = payload.blood_inventory {
+            use crate::schema::hospital_blood_inventories::dsl::*;
+            for item in inventory {
+                diesel::insert_into(hospital_blood_inventories)
+                    .values((
+                        hospital_id.eq(hospital.id),
+                        blood_type.eq(item.blood_type),
+                        units_available.eq(item.units_available.unwrap_or(0)),
+                        bank_capacity.eq(item.bank_capacity.unwrap_or(0)),
+                    ))
+                    .execute(conn)?;
+            }
+        }
+
+        Ok(hospital)
+    })?;
 
     if let Some(ref hospital_email) = hospital.email {
         let mail_service = mail_service.clone();