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
|
use crate::models::{AddTransaction, CartItem, Customer, Product, Transaction};
use crate::schema::cart_items::dsl::*;
use crate::schema::customer::dsl::*;
use crate::schema::product::dsl as prod;
use crate::schema::transaction::dsl::*;
use crate::TPool;
use actix_identity::Identity;
use actix_web::{web, HttpResponse, Responder};
use diesel::prelude::*;
use log::{error, info};
pub async fn checkout_cart(
pool: web::Data<TPool>,
pmt_kind: String,
cookie: Identity,
) -> impl Responder {
let conn = pool.get().unwrap();
info!("Checkout cart for user: {:?}", cookie.identity());
if let Some(uname) = cookie.identity() {
let selected_user = customer
.filter(username.eq(&uname))
.limit(1)
.first::<Customer>(&conn)
.expect("Couldn't connect to DB");
let user_cart_items = cart_items
.filter(cart_id.eq(selected_user.id))
.load::<CartItem>(&conn)
.expect("Couldn't connect to DB");
let cart_total = user_cart_items.into_iter().fold(0., |acc, item| {
let item_price = prod::product
.filter(prod::id.eq(item.product_id))
.limit(1)
.first::<Product>(&conn)
.unwrap()
.price;
acc + item.quantity.unwrap_or(1) as f32 * item_price
});
let transaction_entry = AddTransaction {
customer_id: Some(selected_user.id),
amount: cart_total,
payment_type: pmt_kind,
};
diesel::insert_into(transaction)
.values(transaction_entry)
.execute(&conn)
.expect("Coundn't connect to DB");
return HttpResponse::Ok().body("Transaction performed successfully");
} else {
return HttpResponse::Unauthorized().body("Login first");
}
}
pub async fn list_transactions(
pool: web::Data<TPool>,
cookie: Identity,
) -> impl Responder {
let conn = pool.get().unwrap();
if let Some(uname) = cookie.identity() {
let selected_user = customer
.filter(username.eq(&uname))
.limit(1)
.first::<Customer>(&conn)
.expect("Couldn't connect to DB");
let user_transactions = transaction
.filter(customer_id.eq(selected_user.id))
.load::<Transaction>(&conn)
.expect("Couldn't connect to DB");
return HttpResponse::Ok().json(&user_transactions);
} else {
return HttpResponse::Unauthorized()
.body("Need to be logged in to add to cart!");
}
}
|
