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
|
# -*- coding: utf-8 -*-
# Part of Odoo. See LICENSE file for full copyright and licensing details.
import base64
import json
from ast import literal_eval
from odoo import models, fields, api
from odoo.tools import date_utils
class pos_cache(models.Model):
_name = 'pos.cache'
_description = 'Point of Sale Cache'
cache = fields.Binary(attachment=True)
product_domain = fields.Text(required=True)
product_fields = fields.Text(required=True)
config_id = fields.Many2one('pos.config', ondelete='cascade', required=True)
compute_user_id = fields.Many2one('res.users', 'Cache compute user', required=True)
@api.model
def refresh_all_caches(self):
self.env['pos.cache'].search([]).refresh_cache()
def refresh_cache(self):
for cache in self:
Product = self.env['product.product'].with_user(cache.compute_user_id.id)
products = Product.search(cache.get_product_domain())
prod_ctx = products.with_context(pricelist=cache.config_id.pricelist_id.id,
display_default_code=False, lang=cache.compute_user_id.lang)
res = prod_ctx.read(cache.get_product_fields())
cache.write({
'cache': base64.encodebytes(json.dumps(res, default=date_utils.json_default).encode('utf-8')),
})
@api.model
def get_product_domain(self):
return literal_eval(self.product_domain)
@api.model
def get_product_fields(self):
return literal_eval(self.product_fields)
def cache2json(self):
return json.loads(base64.decodebytes(self.cache).decode('utf-8'))
class pos_config(models.Model):
_inherit = 'pos.config'
@api.depends('cache_ids')
def _get_oldest_cache_time(self):
for cache in self:
pos_cache = self.env['pos.cache']
oldest_cache = pos_cache.search([('config_id', '=', cache.id)], order='write_date', limit=1)
cache.oldest_cache_time = oldest_cache.write_date
cache_ids = fields.One2many('pos.cache', 'config_id')
oldest_cache_time = fields.Datetime(compute='_get_oldest_cache_time', string='Oldest cache time', readonly=True)
limit_products_per_request = fields.Integer(compute='_compute_limit_products_per_request')
def _compute_limit_products_per_request(self):
limit = self.env['ir.config_parameter'].sudo().get_param('pos_cache.limit_products_per_request', 0)
self.update({'limit_products_per_request': int(limit)})
def get_products_from_cache(self, fields, domain):
fields_str = str(fields)
domain_str = str(domain)
pos_cache = self.env['pos.cache']
cache_for_user = pos_cache.search([
('id', 'in', self.cache_ids.ids),
('compute_user_id', '=', self.env.uid),
('product_domain', '=', domain_str),
('product_fields', '=', fields_str),
])
if not cache_for_user:
cache_for_user = pos_cache.create({
'config_id': self.id,
'product_domain': domain_str,
'product_fields': fields_str,
'compute_user_id': self.env.uid
})
cache_for_user.refresh_cache()
return cache_for_user.cache2json()
def delete_cache(self):
# throw away the old caches
self.cache_ids.unlink()
|
