add scheckbook functionality, Fixes #184 (#235)

Reviewed-on: #235

src/model/logbook.rs

@@ -226,6 +226,38 @@ ORDER BY departure DESC
         ret
     }
 
+    pub async fn completed_with_user(
+        db: &SqlitePool,
+        user: &User,
+    ) -> Vec<LogbookWithBoatAndRowers> {
+        let logs = sqlx::query_as(
+               &format!("
+    SELECT id, boat_id, shipmaster, steering_person, shipmaster_only_steering, departure, arrival, destination, distance_in_km, comments, logtype
+    FROM logbook
+    JOIN rower ON logbook.id = rower.logbook_id
+    WHERE arrival is not null AND rower_id = {}
+    ORDER BY departure DESC
+            ",  user.id)
+            )
+            .fetch_all(db)
+            .await
+            .unwrap(); //TODO: fixme
+
+        let mut ret = Vec::new();
+        for log in logs {
+            ret.push(LogbookWithBoatAndRowers {
+                rowers: Rower::for_log(db, &log).await,
+                boat: Boat::find_by_id(db, log.boat_id as i32).await.unwrap(),
+                shipmaster_user: User::find_by_id(db, log.shipmaster as i32).await.unwrap(),
+                steering_user: User::find_by_id(db, log.steering_person as i32)
+                    .await
+                    .unwrap(),
+                logbook: log,
+            });
+        }
+        ret
+    }
+
     pub async fn completed(db: &SqlitePool) -> Vec<LogbookWithBoatAndRowers> {
         let year = chrono::Utc::now().year();
         let logs = sqlx::query_as(

src/model/user.rs

@@ -225,28 +225,6 @@ impl User {
         .count
     }
 
-    pub async fn rowed_km(&self, db: &SqlitePool) -> i32 {
-        sqlx::query!(
-            "SELECT COALESCE(SUM(distance_in_km),0) as rowed_km
-        FROM (
-            SELECT distance_in_km
-            FROM logbook 
-            WHERE shipmaster = ?1
-            UNION  
-            SELECT l.distance_in_km 
-            FROM logbook l
-            INNER JOIN rower r ON r.logbook_id = l.id 
-            WHERE r.rower_id = ?1
-        
-            );",
-            self.id,
-        )
-        .fetch_one(db)
-        .await
-        .unwrap()
-        .rowed_km
-    }
-
     pub async fn has_role(&self, db: &SqlitePool, role: &str) -> bool {
         if sqlx::query!(
             "SELECT * FROM user_role WHERE user_id=? AND role_id = (SELECT id FROM role WHERE name = ?)",
@@ -379,6 +357,22 @@ ORDER BY last_access DESC
         .unwrap()
     }
 
+    pub async fn all_with_role(db: &SqlitePool, role: &Role) -> Vec<Self> {
+        sqlx::query_as!(
+            Self,
+            "
+SELECT id, name, pw, deleted, last_access, dob, weight, sex, member_since_date, birthdate, mail, nickname, notes, phone, address, family_id
+FROM user u
+JOIN user_role ur ON u.id = ur.user_id
+WHERE ur.role_id = ? AND deleted = 0
+ORDER BY name;
+        ", role.id
+        )
+        .fetch_all(db)
+        .await
+        .unwrap()
+    }
+
     pub async fn all_payer_groups(db: &SqlitePool) -> Vec<Self> {
         sqlx::query_as!(
             Self,