diff --git a/src/model/trip.rs b/src/model/trip.rs index 0cdfaad..a8d4e16 100644 --- a/src/model/trip.rs +++ b/src/model/trip.rs @@ -30,10 +30,24 @@ pub struct Trip { pub struct TripWithUserAndType { #[serde(flatten)] pub trip: Trip, - rower: Vec, + pub rower: Vec, trip_type: Option, } +impl TripWithUserAndType { + pub async fn from(db: &SqlitePool, trip: Trip) -> Self { + let mut trip_type = None; + if let Some(trip_type_id) = trip.trip_type_id { + trip_type = TripType::find_by_id(db, trip_type_id).await; + } + Self { + rower: Registration::all_rower(db, trip.trip_details_id.unwrap()).await, + trip, + trip_type, + } + } +} + impl Trip { /// Cox decides to create own trip. pub async fn new_own(db: &SqlitePool, cox: &CoxUser, trip_details: TripDetails) { @@ -154,15 +168,7 @@ WHERE day=? let mut ret = Vec::new(); for trip in trips { - let mut trip_type = None; - if let Some(trip_type_id) = trip.trip_type_id { - trip_type = TripType::find_by_id(db, trip_type_id).await; - } - ret.push(TripWithUserAndType { - rower: Registration::all_rower(db, trip.trip_details_id.unwrap()).await, - trip, - trip_type, - }); + ret.push(TripWithUserAndType::from(db, trip).await); } ret } @@ -199,6 +205,34 @@ WHERE day=? .await .unwrap(); //Okay, as trip_details can only be created with proper DB backing + if max_people == 0 { + let rowers = TripWithUserAndType::from(db, trip.clone()).await.rower; + for user in rowers { + if let Some(user) = User::find_by_name(db, &user.name).await { + let notes = if let Some(notes) = notes { + format!(": {notes}") + } else { + String::from(".") + }; + + Notification::create( + db, + &user, + &format!( + "Die Ausfahrt von {} am {} um {} wurde abgesagt{}", + cox.user.name, trip.day, trip.planned_starting_time, notes + ), + "Absage Ausfahrt", + None, + ) + .await; + } + } + } + + let trip_details = TripDetails::find_by_id(db, trip_details_id).await.unwrap(); + trip_details.check_free_spaces(db).await; + Ok(()) } diff --git a/src/model/tripdetails.rs b/src/model/tripdetails.rs index 6eafa88..109eefe 100644 --- a/src/model/tripdetails.rs +++ b/src/model/tripdetails.rs @@ -4,6 +4,11 @@ use rocket::FromForm; use serde::{Deserialize, Serialize}; use sqlx::{FromRow, SqlitePool}; +use super::{ + notification::Notification, + trip::{Trip, TripWithUserAndType}, +}; + #[derive(FromRow, Debug, Serialize, Deserialize)] pub struct TripDetails { pub id: i64, @@ -64,6 +69,62 @@ WHERE day = ? AND planned_starting_time = ? .await.unwrap() } + /// This function is called when a person registers to a trip or when the cox changes the + /// amount of free places. + pub async fn check_free_spaces(&self, db: &SqlitePool) { + if !self.is_full(db).await { + // We still have space for new people, no need to do anything + return; + } + + if Trip::find_by_trip_details(db, self.id).await.is_none() { + // This trip_details belongs to a planned_event, no need to do anything + return; + }; + + let other_trips_same_time = Self::find_by_startingdatetime( + db, + self.day.clone(), + self.planned_starting_time.clone(), + ) + .await; + + for trip in &other_trips_same_time { + if !trip.is_full(db).await { + // There are trips on the same time, with open places + return; + } + } + + // We just got fully booked and there are no other trips with remaining rower places. Send + // notification to all coxes which are registered as non-cox. + for trip_details in other_trips_same_time { + let Some(trip) = Trip::find_by_trip_details(db, trip_details.id).await else { + // This trip_details belongs to a planned_event, no need to do anything + continue; + }; + let pot_coxes = TripWithUserAndType::from(db, trip.clone()).await; + let pot_coxes = pot_coxes.rower; + for user in pot_coxes { + let cox = User::find_by_id(db, trip.cox_id as i32).await.unwrap(); + let Some(user) = User::find_by_name(db, &user.name).await else { + // User is a guest, no need to bother. + continue; + }; + if !user.has_role(db, "cox").await { + // User is no cox, no need to bother + continue; + } + if user.id == cox.id { + // User already offers a trip, no need to bother + continue; + } + + Notification::create(db, &user, &format!("Du hast dich als Ruderer bei der Ausfahrt von {} am {} um {} angemeldet. Bei allen Ausfahrten zu dieser Zeit sind nun alle Plätze ausgebucht. Damit noch mehr (Nicht-Steuerleute) mitfahren können, wäre es super, wenn du eine eigene Ausfahrt zur selben Zeit ausschreiben könntest.", cox.name, self.day, self.planned_starting_time), "Volle Ausfahrt", None).await; + } + } + } + /// Creates a new entry in `trip_details` and returns its id. pub async fn create(db: &SqlitePool, tripdetails: TripDetailsToAdd<'_>) -> i64 { let query = sqlx::query!( diff --git a/src/model/usertrip.rs b/src/model/usertrip.rs index e2a510c..647f7cd 100644 --- a/src/model/usertrip.rs +++ b/src/model/usertrip.rs @@ -79,6 +79,8 @@ impl UserTrip { None, ) .await; + + trip_details.check_free_spaces(db).await; } Ok(name_newly_registered_person) diff --git a/templates/planned.html.tera b/templates/planned.html.tera index d39f4d2..d5ef0f1 100644 --- a/templates/planned.html.tera +++ b/templates/planned.html.tera @@ -310,7 +310,7 @@

Ausfahrt bearbeiten

- {{ macros::input(label='Anzahl Ruderer', name='max_people', type='number', required=true, value=trip.max_people, min='0') }} + {{ macros::input(label='Anzahl Ruderer', name='max_people', type='number', required=true, value=trip.max_people, min=trip.rower | length) }} {{ macros::input(label='Anmerkungen', name='notes', type='input', value=trip.notes) }} {{ macros::checkbox(label='Immer anzeigen', name='always_show', id=trip.id,checked=trip.always_show) }} {{ macros::checkbox(label='Gesperrt', name='is_locked', id=trip.id,checked=trip.is_locked) }} @@ -326,6 +326,22 @@ Termin löschen
+ {% else %} + {% if trip.max_people == 0 %} + Wenn du deine Absage absagen (:^)) willst, einfach entsprechende Anzahl an Ruderer oben eintragen. + {% else %} +
+

Ausfahrt absagen

+ + {{ macros::input(label='', name='max_people', type='hidden', value=0) }} + {{ macros::input(label='', name='notes', type='hidden', value=trip.notes) }} + {{ macros::input(label='', name='always_show', type='hidden', value=trip.always_show) }} + {{ macros::input(label='', name='is_locked', type='hidden', value=trip.is_locked) }} + {{ macros::input(label='', name='trip_type', type='hidden', value=trip.trip_type_id) }} + + +
+ {% endif %} {% endif %} {% endif %} {# --- END Edit Form --- #}