|
| 1 | +# Copyright 2025 Tecnativa - Carlos Dauden |
| 2 | +# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl). |
| 3 | +from datetime import timedelta |
| 4 | + |
| 5 | +from odoo import api, fields, models |
| 6 | + |
| 7 | + |
| 8 | +class ProductProduct(models.Model): |
| 9 | + _inherit = "product.product" |
| 10 | + |
| 11 | + catalog_origin_data = fields.Selection( |
| 12 | + selection=[("sale_order", "Last sales")], |
| 13 | + store=False, |
| 14 | + search="_search_catalog_origin_data", |
| 15 | + ) |
| 16 | + |
| 17 | + @api.model |
| 18 | + def search_fetch(self, domain, field_names, offset=0, limit=None, order=None): |
| 19 | + catalog_orig_data_bool_list = [ |
| 20 | + "catalog_origin_data" in subdomain for subdomain in domain |
| 21 | + ] |
| 22 | + if any(catalog_orig_data_bool_list): |
| 23 | + # Get value of catalog_origin_data from domain to know which method throw. |
| 24 | + # Then browse the ids to respect the order. |
| 25 | + product_ids = getattr( |
| 26 | + self, |
| 27 | + f"_get_product_picker_data_{domain[catalog_orig_data_bool_list.index(True)][2]}", |
| 28 | + )() |
| 29 | + return self.browse(product_ids) |
| 30 | + return super().search_fetch( |
| 31 | + domain, field_names, offset=offset, limit=limit, order=order |
| 32 | + ) |
| 33 | + |
| 34 | + @api.model |
| 35 | + def _search_catalog_origin_data(self, operator, value): |
| 36 | + # Hack to be able to filter by catalog_origin_data |
| 37 | + return [] |
| 38 | + |
| 39 | + @api.model |
| 40 | + def _product_picker_data_sale_order_domain(self): |
| 41 | + """Domain to find recent SO lines.""" |
| 42 | + months = 6 |
| 43 | + start = fields.Datetime.now() - timedelta(days=months * 30) |
| 44 | + start = fields.Datetime.to_string(start) |
| 45 | + catalog_partner_id = self.env.context.get("product_catalog_partner_id", False) |
| 46 | + catalog_order_id = self.env.context.get("product_catalog_order_id", False) |
| 47 | + # Search with sudo for get sale order from other commercials users |
| 48 | + other_sales = ( |
| 49 | + self.env["sale.order"] |
| 50 | + # .sudo() |
| 51 | + ._search( |
| 52 | + [ |
| 53 | + ("id", "!=", catalog_order_id), |
| 54 | + ("company_id", "=", self.env.company.id), |
| 55 | + ("partner_shipping_id", "=", catalog_partner_id), |
| 56 | + ("date_order", ">=", start), |
| 57 | + ] |
| 58 | + ) |
| 59 | + ) |
| 60 | + domain = [ |
| 61 | + ("order_id", "in", other_sales), |
| 62 | + ("qty_delivered", "!=", 0.0), |
| 63 | + ] |
| 64 | + return domain |
| 65 | + |
| 66 | + @api.model |
| 67 | + def _get_product_picker_data_sale_order(self): |
| 68 | + # Specific limit to allow show all products sold in recent orders |
| 69 | + limit = int( |
| 70 | + self.env["ir.config_parameter"] |
| 71 | + .sudo() |
| 72 | + .get_param("sale_order_product_picker.product_picker_last_order_limit", "0") |
| 73 | + ) |
| 74 | + sol_groups = self.env["sale.order.line"]._read_group( |
| 75 | + self._product_picker_data_sale_order_domain(), |
| 76 | + groupby=["product_id"], |
| 77 | + aggregates=["__count", "qty_delivered:sum"], |
| 78 | + limit=limit, |
| 79 | + order="__count desc, qty_delivered:sum desc", |
| 80 | + ) |
| 81 | + return [g[0].id for g in sol_groups] |
0 commit comments