delivery statistics

migrations/015_metada.sql

@@ -20,3 +20,14 @@ CREATE TRIGGER complete_producing_orders_after_update
 AFTER UPDATE ON epoch_table
 FOR EACH ROW
 EXECUTE FUNCTION run_daily_order_complete_check();
+
+
+CREATE type delivery_line AS ENUM ('DL1', 'DL2', 'DL3', 'DL4');
+
+CREATE TABLE IF NOT EXISTS delivery_statistics(
+  id BIGINT GENERATED ALWAYS AS IDENTITY,
+  line delivery_line NOT NULL,
+  piece piece_kind NOT NULL,
+  quantity int NOT NULL,
+  associated_order_id uuid REFERENCES orders(id) NOT NULL
+);

src/db_api/mod.rs

@@ -5,6 +5,7 @@ mod orders;
 mod pieces;
 mod recipes;
 mod shipments;
+mod statistics;
 mod suppliers;
 mod transformations;
 
@@ -15,6 +16,7 @@ pub use orders::*;
 pub use pieces::*;
 pub use recipes::*;
 pub use shipments::*;
+pub use statistics::*;
 pub use suppliers::*;
 pub use transformations::*;
 

src/db_api/statistics.rs

@@ -0,0 +1,42 @@
+use serde::{Deserialize, Serialize};
+use sqlx::PgConnection;
+use uuid::Uuid;
+
+use super::FinalPiece;
+
+#[derive(Debug, Clone, Copy, Serialize, Deserialize, sqlx::Type)]
+#[sqlx(type_name = "delivery_line")]
+pub enum DeliveryLines {
+    DL1,
+    DL2,
+    DL3,
+    DL4,
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct DeliveryStatistics {
+    line: DeliveryLines,
+    piece: FinalPiece,
+    quantity: i32,
+    associated_order_id: Uuid,
+}
+
+impl DeliveryStatistics {
+    pub async fn insert(&self, con: &mut PgConnection) -> sqlx::Result<()> {
+        sqlx::query!(
+            r#"
+            INSERT INTO delivery_statistics
+                (line, piece, quantity, associated_order_id)
+            VALUES ($1, $2, $3, $4)
+            "#,
+            self.line as DeliveryLines,
+            self.piece as FinalPiece,
+            self.quantity,
+            self.associated_order_id
+        )
+        .execute(con)
+        .await?;
+
+        Ok(())
+    }
+}

src/db_api/transformations.rs

@@ -1,5 +1,4 @@
 use serde::Serialize;
-use sqlx::Acquire;
 use sqlx::PgConnection;
 use sqlx::PgPool;
 use uuid::Uuid;

src/routes/mod.rs

@@ -13,8 +13,8 @@ use sqlx::{postgres::types::PgMoney, PgPool};
 use uuid::Uuid;
 
 use crate::db_api::{
-    self, Item, Order, OrderStatus, RawMaterial, Shipment, Transformation,
-    TransformationDetails,
+    self, DeliveryStatistics, Item, Order, OrderStatus, RawMaterial, Shipment,
+    Transformation, TransformationDetails,
 };
 
 fn internal_server_error(e: impl Debug + Display) -> HttpResponse {
@@ -440,6 +440,22 @@ pub async fn post_delivery_confirmation(
     }
 }
 
+#[post("/deliveries/statistics")]
+pub async fn post_delivery_statistics(
+    form: Form<DeliveryStatistics>,
+    pool: Data<PgPool>,
+) -> impl Responder {
+    let mut con = match pool.acquire().await {
+        Ok(con) => con,
+        Err(e) => return internal_server_error(e),
+    };
+
+    match form.insert(&mut con).await {
+        Ok(_) => HttpResponse::Created().finish(),
+        Err(e) => internal_server_error(e),
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use super::{check_health, DayForm};

src/startup.rs

@@ -112,6 +112,7 @@ impl App {
                     .service(routes::post_material_arrival)
                     .service(routes::get_deliveries)
                     .service(routes::post_delivery_confirmation)
+                    .service(routes::post_delivery_statistics)
                     .app_data(Data::new(self.pool.clone()))
             })
             .bind(addr.clone())