lariv-rs 0.1.0

Compile-time plugin web application framework built on Axum, SeaORM, Maud, and HTMX
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use chrono::Utc;
use sea_orm::{
    ActiveModelTrait, ActiveValue::Set, ColumnTrait, DatabaseConnection, EntityTrait, QueryFilter,
};

use crate::plugins::finance_products::entities::product_preferences::{
    self, Entity as ProductPreferencesEntity,
};

pub fn optional_i64(v: Option<i64>) -> i64 {
    v.unwrap_or(0).max(0)
}

pub async fn load_product_preferences(db: &DatabaseConnection) -> product_preferences::Model {
    if let Ok(Some(p)) = ProductPreferencesEntity::find_by_id(1i64).one(db).await {
        return p;
    }
    let now = Utc::now();
    let am = product_preferences::ActiveModel {
        id: Set(1),
        created_at: Set(Some(now)),
        updated_at: Set(Some(now)),
        ..Default::default()
    };
    am.insert(db).await.unwrap_or(product_preferences::Model {
        id: 1,
        created_at: Some(now),
        updated_at: Some(now),
        inventory_account_id: None,
        cost_of_sales_account_id: None,
    })
}

pub async fn set_product_tax_ids(
    db: &DatabaseConnection,
    product_id: i64,
    tax_ids: &[i64],
) -> Result<(), sea_orm::DbErr> {
    use crate::plugins::finance_products::entities::product_tax::{
        self, Entity as ProductTaxEntity,
    };
    ProductTaxEntity::delete_many()
        .filter(product_tax::Column::ProductId.eq(product_id))
        .exec(db)
        .await?;
    for tax_id in tax_ids {
        let am = product_tax::ActiveModel {
            product_id: Set(product_id),
            tax_id: Set(*tax_id),
        };
        am.insert(db).await?;
    }
    Ok(())
}

pub async fn load_product_tax_ids(db: &DatabaseConnection, product_id: i64) -> Vec<i64> {
    use crate::plugins::finance_products::entities::product_tax::{
        self, Entity as ProductTaxEntity,
    };
    ProductTaxEntity::find()
        .filter(product_tax::Column::ProductId.eq(product_id))
        .all(db)
        .await
        .unwrap_or_default()
        .into_iter()
        .map(|r| r.tax_id)
        .collect()
}

pub async fn load_default_product_tax_ids(db: &DatabaseConnection) -> Vec<i64> {
    use crate::plugins::finance_products::entities::product_preferences_tax::{
        self, Entity as ProductPreferencesTaxEntity,
    };
    ProductPreferencesTaxEntity::find()
        .filter(product_preferences_tax::Column::ProductPreferencesId.eq(1i64))
        .all(db)
        .await
        .unwrap_or_default()
        .into_iter()
        .map(|r| r.tax_id)
        .collect()
}