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
|
use sqlx::sqlite::SqlitePool;
use std::collections::HashMap;
use crate::db;
use crate::mail;
use crate::model::config::Config;
use crate::payer;
pub async fn send(
config: &Config,
pool: &SqlitePool,
env: &minijinja::Environment<'_>,
) -> bool {
match get_weekly_report(pool, env).await {
Ok(report) => {
let users = db::users::list(pool).await;
mail::send(
config,
users
.into_iter()
.map(|u| mail::Recipient {
name: u.name,
address: u.email,
})
.collect(),
"Rapport hebdomadaire".to_string(),
report,
)
.await
}
Err(err) => {
log::error!(
"Error preparing weekly report from template: {:?}",
err
);
false
}
}
}
async fn get_weekly_report(
pool: &SqlitePool,
env: &minijinja::Environment<'_>,
) -> Result<String, minijinja::Error> {
let users = db::users::list(pool).await;
let incomes_from = db::incomes::defined_for_all(pool).await;
let user_incomes = match incomes_from {
Some(from) => db::incomes::cumulative(pool, from).await,
None => HashMap::new(),
};
let user_payments = db::payments::repartition(pool).await;
let exceeding_payers =
payer::exceeding(&users, &user_incomes, &user_payments);
let last_week_payments = db::payments::last_week(pool).await;
let last_week_incomes = db::incomes::last_week(pool).await;
let template = env.get_template("report/report.j2")?;
template.render(minijinja::context!(
name => "John",
exceeding_payers => exceeding_payers,
payments => last_week_payments,
incomes => last_week_incomes
))
}
|
