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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
from .. import controller
from odoo import http
from odoo.http import request
class Cart(controller.Controller):
prefix = '/api/v1/'
PREFIX_USER = prefix + 'user/<user_id>/'
@http.route(PREFIX_USER + 'cart', auth='public', methods=['GET', 'OPTIONS'])
@controller.Controller.must_authorized()
def get_cart_by_user_id(self, user_id, **kw):
user_cart = request.env['website.user.cart']
user_id = int(user_id)
limit = int(kw.get('limit', 0))
offset = int(kw.get('offset', 0))
query = [('user_id', '=', user_id), ('source', '=', 'add_to_cart')]
carts = user_cart.search(query, limit=limit, offset=offset, order='create_date desc')
data = {
'product_total': user_cart.search_count(query),
'products': carts.with_context(price_for="web").get_products()
}
return self.response(data)
@http.route(PREFIX_USER + 'cart/count', auth='public', methods=['GET', 'OPTIONS'])
@controller.Controller.must_authorized()
def get_cart_count_by_user_id(self, user_id, **kw):
user_id = int(user_id)
query = [('user_id', '=', user_id), ('source', '=', 'add_to_cart')]
carts = request.env['website.user.cart'].search_count(query)
return self.response(carts)
@http.route(PREFIX_USER + 'cart/create-or-update', auth='public', methods=['POST', 'OPTIONS'], csrf=False)
@controller.Controller.must_authorized(private=True, private_key='user_id')
def create_or_update_cart(self, user_id, **kw):
# Convert input values to appropriate types
user_id = int(user_id)
product_id = int(kw.get('product_id', 0))
qty = int(kw.get('qty', 0))
source = kw.get('source')
is_selected = kw.get('selected', False)
program_line_id = kw.get('program_line_id', False)
program_line_id = False if program_line_id == 'null' or not program_line_id else int(program_line_id)
is_selected = is_selected in ('true', True)
# Check required fields
if not user_id or not product_id or not qty:
return self.response(code=400, description='user_id, product_id and qty is required')
website_user_cart = request.env['website.user.cart']
# Remove previous 'buy' entries for the user
user_query = ('user_id', '=', user_id)
website_user_cart.search([user_query, ('source', '=', 'buy')]).unlink()
# Prepare query to find existing cart entry
query = [user_query, ('source', '=', 'add_to_cart')]
if product_id:
query.append(('product_id', '=', product_id))
elif program_line_id:
query.append(('program_line_id', '=', program_line_id))
cart = website_user_cart.search(query, limit=1)
data_to_update = {
'qty': qty,
'is_selected': is_selected,
'program_line_id': program_line_id,
'product_id': product_id
}
if program_line_id:
data_to_update['product_id'] = False
if source:
data_to_update['source'] = source
result = {}
if cart and source in (None, 'add_to_cart'):
# Update existing cart entry
cart.write(data_to_update)
result['id'] = cart.id
else:
# Create a new cart entry if it doesn't exist
create = website_user_cart.create({
'user_id': user_id,
**data_to_update
})
result['id'] = create.id
return self.response(result)
@http.route(PREFIX_USER + 'cart', auth='public', methods=['DELETE', 'OPTIONS'], csrf=False)
@controller.Controller.must_authorized()
def delete_cart_by_user_id(self, user_id, **kw):
user_id = int(user_id)
query = [('user_id', '=', user_id)]
product_ids = kw.get('product_ids')
if product_ids:
query += [('product_id', 'in', [int(x) for x in product_ids.split(',')])]
cart = request.env['website.user.cart'].search(query).unlink()
return self.response(cart)
@http.route(PREFIX_USER + 'cart/select-all', auth='public', methods=['POST', 'OPTIONS'], csrf=False)
@controller.Controller.must_authorized(private=True, private_key='user_id')
def select_all_cart_by_user_id(self, user_id):
user_id = int(user_id)
website_user_cart = request.env['website.user.cart']
query = [('user_id', '=', user_id)]
website_user_cart.search(query).write({
'is_selected': True
})
return self.response(True)
|
