Adrian Torres
4b38cc6590
Multi is the default api for methods, it is not necessary to explicitly decorate methods with it, adds clutter and most people use it because they see that the rest of the code uses it. Done with `find . -type f -name '*.py' | xargs sed -i '/@api.multi/d'`
96 lines
3.4 KiB
Python
96 lines
3.4 KiB
Python
# -*- 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
|
|
|
|
|
|
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.encodestring(json.dumps(res).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)
|
|
|
|
@api.model
|
|
def get_cache(self, domain, fields):
|
|
if not self.cache or domain != self.get_product_domain() or fields != self.get_product_fields():
|
|
self.product_domain = str(domain)
|
|
self.product_fields = str(fields)
|
|
self.refresh_cache()
|
|
|
|
return json.loads(base64.decodestring(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
|
|
|
|
# Use a related model to avoid the load of the cache when the pos load his config
|
|
cache_ids = fields.One2many('pos.cache', 'config_id')
|
|
oldest_cache_time = fields.Datetime(compute='_get_oldest_cache_time', string='Oldest cache time', readonly=True)
|
|
|
|
def _get_cache_for_user(self):
|
|
pos_cache = self.env['pos.cache']
|
|
cache_for_user = pos_cache.search([('id', 'in', self.cache_ids.ids), ('compute_user_id', '=', self.env.uid)])
|
|
|
|
if cache_for_user:
|
|
return cache_for_user[0]
|
|
else:
|
|
return None
|
|
|
|
def get_products_from_cache(self, fields, domain):
|
|
cache_for_user = self._get_cache_for_user()
|
|
|
|
if cache_for_user:
|
|
return cache_for_user.get_cache(domain, fields)
|
|
else:
|
|
pos_cache = self.env['pos.cache']
|
|
pos_cache.create({
|
|
'config_id': self.id,
|
|
'product_domain': str(domain),
|
|
'product_fields': str(fields),
|
|
'compute_user_id': self.env.uid
|
|
})
|
|
new_cache = self._get_cache_for_user()
|
|
return new_cache.get_cache(domain, fields)
|
|
|
|
def delete_cache(self):
|
|
# throw away the old caches
|
|
self.cache_ids.unlink()
|