main #1

Open
philipp wants to merge 71 commits from Ruderverein-Donau-Linz/rowt:main into main
11 changed files with 174 additions and 153 deletions
Showing only changes of commit f7d109f1b2 - Show all commits

View File

@ -1,5 +1,3 @@
use std::collections::HashMap;
use rocket::serde::{Deserialize, Serialize}; use rocket::serde::{Deserialize, Serialize};
use sqlx::{FromRow, SqlitePool}; use sqlx::{FromRow, SqlitePool};
@ -7,6 +5,93 @@ use crate::tera::board::boathouse::FormBoathouseToAdd;
use super::boat::Boat; use super::boat::Boat;
#[derive(Debug, Serialize, Deserialize)]
pub struct BoathousePlace {
boat: Boat,
boathouse_id: i64,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BoathouseRack {
boats: [Option<BoathousePlace>; 12],
}
impl BoathouseRack {
fn new() -> Self {
let boats = [
None, None, None, None, None, None, None, None, None, None, None, None,
];
Self { boats }
}
async fn add(&mut self, db: &SqlitePool, boathouse: Boathouse) {
self.boats[boathouse.level as usize] = Some(BoathousePlace {
boat: Boat::find_by_id(db, boathouse.boat_id as i32)
.await
.unwrap(),
boathouse_id: boathouse.id,
});
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BoathouseSide {
mountain: BoathouseRack,
water: BoathouseRack,
}
impl BoathouseSide {
fn new() -> Self {
Self {
mountain: BoathouseRack::new(),
water: BoathouseRack::new(),
}
}
async fn add(&mut self, db: &SqlitePool, boathouse: Boathouse) {
match boathouse.side.as_str() {
"mountain" => self.mountain.add(db, boathouse).await,
"water" => self.water.add(db, boathouse).await,
_ => panic!("db constraint failed"),
}
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BoathouseAisles {
mountain: BoathouseSide,
middle: BoathouseSide,
water: BoathouseSide,
}
impl BoathouseAisles {
fn new() -> Self {
Self {
mountain: BoathouseSide::new(),
middle: BoathouseSide::new(),
water: BoathouseSide::new(),
}
}
async fn add(&mut self, db: &SqlitePool, boathouse: Boathouse) {
match boathouse.aisle.as_str() {
"water" => self.water.add(db, boathouse).await,
"middle" => self.middle.add(db, boathouse).await,
"mountain" => self.mountain.add(db, boathouse).await,
_ => panic!("db constraint failed"),
};
}
pub async fn from(db: &SqlitePool, boathouses: Vec<Boathouse>) -> Self {
let mut ret = BoathouseAisles::new();
for boathouse in boathouses {
ret.add(db, boathouse).await;
}
ret
}
}
#[derive(FromRow, Debug, Serialize, Deserialize)] #[derive(FromRow, Debug, Serialize, Deserialize)]
pub struct Boathouse { pub struct Boathouse {
pub id: i64, pub id: i64,
@ -17,54 +102,7 @@ pub struct Boathouse {
} }
impl Boathouse { impl Boathouse {
pub async fn get(db: &SqlitePool) -> HashMap<&str, HashMap<&str, [Option<(i64, Boat)>; 12]>> { pub async fn get(db: &SqlitePool) -> BoathouseAisles {
let mut ret: HashMap<&str, HashMap<&str, [Option<(i64, Boat)>; 12]>> = HashMap::new();
let mut mountain = HashMap::new();
mountain.insert(
"mountain",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
mountain.insert(
"water",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
ret.insert("mountain-aisle", mountain);
let mut middle = HashMap::new();
middle.insert(
"mountain",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
middle.insert(
"water",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
ret.insert("middle-aisle", middle);
let mut water = HashMap::new();
water.insert(
"mountain",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
water.insert(
"water",
[
None, None, None, None, None, None, None, None, None, None, None, None,
],
);
ret.insert("water-aisle", water);
let boathouses = sqlx::query_as!( let boathouses = sqlx::query_as!(
Boathouse, Boathouse,
"SELECT id, boat_id, aisle, side, level FROM boathouse" "SELECT id, boat_id, aisle, side, level FROM boathouse"
@ -73,21 +111,7 @@ impl Boathouse {
.await .await
.unwrap(); //TODO: fixme .unwrap(); //TODO: fixme
for boathouse in boathouses { BoathouseAisles::from(db, boathouses).await
let aisle = ret
.get_mut(format!("{}-aisle", boathouse.aisle).as_str())
.unwrap();
let side = aisle.get_mut(boathouse.side.as_str()).unwrap();
side[boathouse.level as usize] = Some((
boathouse.id,
Boat::find_by_id(db, boathouse.boat_id as i32)
.await
.unwrap(),
));
}
ret
} }
pub async fn create(db: &SqlitePool, data: FormBoathouseToAdd) -> Result<(), String> { pub async fn create(db: &SqlitePool, data: FormBoathouseToAdd) -> Result<(), String> {

View File

@ -34,7 +34,6 @@ impl PartialEq for Logbook {
pub(crate) enum Filter { pub(crate) enum Filter {
SingleDayOnly, SingleDayOnly,
MultiDayOnly, MultiDayOnly,
None,
} }
#[derive(FromForm, Debug, Clone)] #[derive(FromForm, Debug, Clone)]
@ -398,9 +397,6 @@ ORDER BY departure DESC
ret.push(LogbookWithBoatAndRowers::from_tx(db, log).await); ret.push(LogbookWithBoatAndRowers::from_tx(db, log).await);
} }
} }
Filter::None => {
ret.push(LogbookWithBoatAndRowers::from_tx(db, log).await);
}
} }
} }
if exclude_last_log { if exclude_last_log {

View File

@ -3,62 +3,62 @@ use serde::Serialize;
#[derive(Serialize, PartialEq, Debug)] #[derive(Serialize, PartialEq, Debug)]
pub(crate) enum Level { pub(crate) enum Level {
NONE, None,
BRONZE, Bronze,
SILVER, Silver,
GOLD, Gold,
DIAMOND, Diamond,
DONE, Done,
} }
impl Level { impl Level {
fn required_km(&self) -> i32 { fn required_km(&self) -> i32 {
match self { match self {
Level::BRONZE => 40000, Level::Bronze => 40000,
Level::SILVER => 80000, Level::Silver => 80000,
Level::GOLD => 100000, Level::Gold => 100000,
Level::DIAMOND => 200000, Level::Diamond => 200000,
Level::DONE => 0, Level::Done => 0,
Level::NONE => 0, Level::None => 0,
} }
} }
fn next_level(km: i32) -> Self { fn next_level(km: i32) -> Self {
if km < Level::BRONZE.required_km() { if km < Level::Bronze.required_km() {
Level::BRONZE Level::Bronze
} else if km < Level::SILVER.required_km() { } else if km < Level::Silver.required_km() {
Level::SILVER Level::Silver
} else if km < Level::GOLD.required_km() { } else if km < Level::Gold.required_km() {
Level::GOLD Level::Gold
} else if km < Level::DIAMOND.required_km() { } else if km < Level::Diamond.required_km() {
Level::DIAMOND Level::Diamond
} else { } else {
Level::DONE Level::Done
} }
} }
pub(crate) fn curr_level(km: i32) -> Self { pub(crate) fn curr_level(km: i32) -> Self {
if km < Level::BRONZE.required_km() { if km < Level::Bronze.required_km() {
Level::NONE Level::None
} else if km < Level::SILVER.required_km() { } else if km < Level::Silver.required_km() {
Level::BRONZE Level::Bronze
} else if km < Level::GOLD.required_km() { } else if km < Level::Gold.required_km() {
Level::SILVER Level::Silver
} else if km < Level::DIAMOND.required_km() { } else if km < Level::Diamond.required_km() {
Level::GOLD Level::Gold
} else { } else {
Level::DIAMOND Level::Diamond
} }
} }
pub(crate) fn desc(&self) -> &str { pub(crate) fn desc(&self) -> &str {
match self { match self {
Level::BRONZE => "Bronze", Level::Bronze => "Bronze",
Level::SILVER => "Silber", Level::Silver => "Silber",
Level::GOLD => "Gold", Level::Gold => "Gold",
Level::DIAMOND => "Diamant", Level::Diamond => "Diamant",
Level::DONE => "", Level::Done => "",
Level::NONE => "-", Level::None => "-",
} }
} }
} }

View File

@ -395,12 +395,10 @@ ASKÖ Ruderverein Donau Linz", self.name),
} }
} else if self.has_role(db, "Ehrenmitglied").await { } else if self.has_role(db, "Ehrenmitglied").await {
fee.add("Ehrenmitglied".into(), 0); fee.add("Ehrenmitglied".into(), 0);
} else if halfprice {
fee.add("Mitgliedsbeitrag (Halbpreis)".into(), REGULAR / 2);
} else { } else {
if halfprice { fee.add("Mitgliedsbeitrag".into(), REGULAR);
fee.add("Mitgliedsbeitrag (Halbpreis)".into(), REGULAR / 2);
} else {
fee.add("Mitgliedsbeitrag".into(), REGULAR);
}
} }
} }
@ -994,39 +992,43 @@ ORDER BY last_access DESC
smtp_pw: &str, smtp_pw: &str,
) { ) {
if self.has_role_tx(db, "scheckbuch").await { if self.has_role_tx(db, "scheckbuch").await {
let amount_trips = Logbook::completed_with_user_tx(db, &self).await.len(); let amount_trips = Logbook::completed_with_user_tx(db, self).await.len();
if amount_trips == 5 { match amount_trips {
if let Some(mail) = &self.mail { 5 => {
let _ = self.send_end_mail_scheckbuch(db, mail, smtp_pw).await; if let Some(mail) = &self.mail {
let _ = self.send_end_mail_scheckbuch(db, mail, smtp_pw).await;
}
Notification::create_for_steering_people_tx(
db,
&format!(
"Liebe Steuerberechtigte, {} hat alle Ausfahrten des Scheckbuchs absolviert. Hoffentlich können wir uns bald über ein neues Mitglied freuen :-)",
self.name
),
"Scheckbuch fertig",
None,None
)
.await;
} }
Notification::create_for_steering_people_tx( a if a > 5 => {
db, let board = Role::find_by_name_tx(db, "Vorstand").await.unwrap();
&format!( Notification::create_for_role_tx(
"Liebe Steuerberechtigte, {} hat alle Ausfahrten des Scheckbuchs absolviert. Hoffentlich können wir uns bald über ein neues Mitglied freuen :-)", db,
self.name &board,
), &format!(
"Scheckbuch fertig", "Lieber Vorstand, {} hat nun bereits die {}. seiner 5 Scheckbuchausfahrten absolviert.",
None,None self.name, amount_trips
) ),
.await; "Scheckbuch überfertig",
} else if amount_trips > 5 { None,None
let board = Role::find_by_name_tx(db, "Vorstand").await.unwrap(); )
Notification::create_for_role_tx( .await;
db, }
&board, _ => {}
&format!(
"Lieber Vorstand, {} hat nun bereits die {}. seiner 5 Scheckbuchausfahrten absolviert.",
self.name, amount_trips
),
"Scheckbuch überfertig",
None,None
)
.await;
} }
} }
// check fahrtenabzeichen fertig // check fahrtenabzeichen fertig
if rowingbadge::Status::completed_with_last_log(db, &self).await { if rowingbadge::Status::completed_with_last_log(db, self).await {
let board = Role::find_by_name_tx(db, "Vorstand").await.unwrap(); let board = Role::find_by_name_tx(db, "Vorstand").await.unwrap();
Notification::create_for_role_tx( Notification::create_for_role_tx(
db, db,

View File

@ -408,7 +408,7 @@ async fn create_scheckbuch(
format!("{} created new scheckbuch: {data:?}", admin.name), format!("{} created new scheckbuch: {data:?}", admin.name),
) )
.await; .await;
Flash::success(Redirect::to("/admin/user/scheckbuch"), &format!("Scheckbuch erfolgreich erstellt. Eine E-Mail in der alles erklärt wird, wurde an {mail} verschickt.")) Flash::success(Redirect::to("/admin/user/scheckbuch"), format!("Scheckbuch erfolgreich erstellt. Eine E-Mail in der alles erklärt wird, wurde an {mail} verschickt."))
} }
#[get("/user/move/schnupperant/<id>/to/scheckbuch")] #[get("/user/move/schnupperant/<id>/to/scheckbuch")]
@ -458,7 +458,7 @@ async fn schnupper_to_scheckbuch(
), ),
) )
.await; .await;
Flash::success(Redirect::to("/admin/schnupper"), &format!("Scheckbuch erfolgreich erstellt. Eine E-Mail in der alles erklärt wird, wurde an {} verschickt.", user.mail.unwrap())) Flash::success(Redirect::to("/admin/schnupper"), format!("Scheckbuch erfolgreich erstellt. Eine E-Mail in der alles erklärt wird, wurde an {} verschickt.", user.mail.unwrap()))
} }
pub fn routes() -> Vec<Route> { pub fn routes() -> Vec<Route> {

View File

@ -18,12 +18,12 @@ async fn index(
context.insert("flash", &msg.into_inner()); context.insert("flash", &msg.into_inner());
} }
let role = Role::find_by_name(&db, "Donau Linz").await.unwrap(); let role = Role::find_by_name(db, "Donau Linz").await.unwrap();
let users = User::all_with_role(&db, &role).await; let users = User::all_with_role(db, &role).await;
let mut people = Vec::new(); let mut people = Vec::new();
let mut rowingbadge_year = None; let mut rowingbadge_year = None;
for user in users { for user in users {
let achievement = Achievements::for_user(&db, &user).await; let achievement = Achievements::for_user(db, &user).await;
if let Some(badge) = &achievement.rowingbadge { if let Some(badge) = &achievement.rowingbadge {
rowingbadge_year = Some(badge.year); rowingbadge_year = Some(badge.year);
} }

View File

@ -148,13 +148,13 @@ async fn fixed<'r>(
#[derive(FromForm)] #[derive(FromForm)]
pub struct FormBoatDamageVerified<'r> { pub struct FormBoatDamageVerified<'r> {
pub desc: &'r str, desc: &'r str,
} }
#[post("/<boatdamage_id>/verified", data = "<data>")] #[post("/<boatdamage_id>/verified", data = "<data>")]
async fn verified<'r>( async fn verified<'r>(
db: &State<SqlitePool>, db: &State<SqlitePool>,
data: Form<FormBoatDamageFixed<'r>>, data: Form<FormBoatDamageVerified<'r>>,
boatdamage_id: i32, boatdamage_id: i32,
techuser: TechUser, techuser: TechUser,
) -> Flash<Redirect> { ) -> Flash<Redirect> {

View File

@ -217,7 +217,7 @@ async fn new_thirty(
eprintln!("Failed to persist file: {:?}", e); eprintln!("Failed to persist file: {:?}", e);
} }
let result = data.result.trim_start_matches(|c| c == '0' || c == ' '); let result = data.result.trim_start_matches(['0', ' ']);
sqlx::query!( sqlx::query!(
"UPDATE user SET dirty_thirty = ? where id = ?", "UPDATE user SET dirty_thirty = ? where id = ?",
@ -318,7 +318,7 @@ async fn new_dozen(
if let Err(e) = data.proof.move_copy_to(file_path).await { if let Err(e) = data.proof.move_copy_to(file_path).await {
eprintln!("Failed to persist file: {:?}", e); eprintln!("Failed to persist file: {:?}", e);
} }
let result = data.result.trim_start_matches(|c| c == '0' || c == ' '); let result = data.result.trim_start_matches(['0', ' ']);
let result = if result.contains(":") || result.contains(".") { let result = if result.contains(":") || result.contains(".") {
format_time(result) format_time(result)
} else { } else {

View File

@ -312,7 +312,7 @@ async fn update(
let data = data.into_inner(); let data = data.into_inner();
let Some(logbook) = Logbook::find_by_id(db, data.id).await else { let Some(logbook) = Logbook::find_by_id(db, data.id).await else {
return Flash::error(Redirect::to("/log"), &format!("Logbucheintrag kann nicht bearbeitet werden, da es einen Logbuch-Eintrag mit ID={} nicht gibt", data.id)); return Flash::error(Redirect::to("/log"), format!("Logbucheintrag kann nicht bearbeitet werden, da es einen Logbuch-Eintrag mit ID={} nicht gibt", data.id));
}; };
match logbook.update(db, data.clone(), &user.user).await { match logbook.update(db, data.clone(), &user.user).await {

View File

@ -19,7 +19,7 @@ async fn cal_registered(
return Err("Invalid".into()); return Err("Invalid".into());
}; };
if &user.user_token != uuid { if user.user_token != uuid {
return Err("Invalid".into()); return Err("Invalid".into());
} }

View File

@ -4,13 +4,12 @@
{% extends "base" %} {% extends "base" %}
{% macro show_place(aisle_name, side_name, level) %} {% macro show_place(aisle_name, side_name, level) %}
<li class="truncate p-2 flex relative w-full"> <li class="truncate p-2 flex relative w-full">
{% set aisle = aisle_name ~ "-aisle" %} {% set place = boathouse[aisle_name][side_name].boats %}
{% set place = boathouse[aisle][side_name] %}
{% if place[level] %} {% if place[level] %}
{{ place[level].1.name }} {{ place[level].boat.name }}
{% if "admin" in loggedin_user.roles %} {% if "admin" in loggedin_user.roles %}
<a class="btn btn-primary absolute end-0" <a class="btn btn-primary absolute end-0"
href="/board/boathouse/{{ place[level].0 }}/delete">X</a> href="/board/boathouse/{{ place[level].boathouse_id }}/delete">X</a>
{% endif %} {% endif %}
{% elif boats | length > 0 %} {% elif boats | length > 0 %}
{% if "admin" in loggedin_user.roles %} {% if "admin" in loggedin_user.roles %}