291 lines
15 KiB
Python
291 lines
15 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
||
|
|
|
||
|
|
from dateutil.relativedelta import relativedelta
|
||
|
|
|
||
|
|
from odoo import api, fields, models, _
|
||
|
|
from odoo.exceptions import UserError
|
||
|
|
from odoo.tools import float_compare
|
||
|
|
from odoo.tools.misc import get_lang
|
||
|
|
|
||
|
|
|
||
|
|
class SaleOrderLine(models.Model):
|
||
|
|
_inherit = 'sale.order.line'
|
||
|
|
|
||
|
|
purchase_line_ids = fields.One2many('purchase.order.line', 'sale_line_id', string="Generated Purchase Lines", readonly=True, help="Purchase line generated by this Sales item on order confirmation, or when the quantity was increased.")
|
||
|
|
purchase_line_count = fields.Integer("Number of generated purchase items", compute='_compute_purchase_count')
|
||
|
|
|
||
|
|
@api.depends('purchase_line_ids')
|
||
|
|
def _compute_purchase_count(self):
|
||
|
|
database_data = self.env['purchase.order.line'].sudo()._read_group([('sale_line_id', 'in', self.ids)], ['sale_line_id'], ['__count'])
|
||
|
|
mapped_data = {sale_line.id: count for sale_line, count in database_data}
|
||
|
|
for line in self:
|
||
|
|
line.purchase_line_count = mapped_data.get(line.id, 0)
|
||
|
|
|
||
|
|
@api.onchange('product_uom_qty')
|
||
|
|
def _onchange_service_product_uom_qty(self):
|
||
|
|
if self.state == 'sale' and self.product_id.type == 'service' and self.product_id.service_to_purchase:
|
||
|
|
if self.product_uom_qty < self._origin.product_uom_qty:
|
||
|
|
if self.product_uom_qty < self.qty_delivered:
|
||
|
|
return {}
|
||
|
|
warning_mess = {
|
||
|
|
'title': _('Ordered quantity decreased!'),
|
||
|
|
'message': _('You are decreasing the ordered quantity! Do not forget to manually update the purchase order if needed.'),
|
||
|
|
}
|
||
|
|
return {'warning': warning_mess}
|
||
|
|
return {}
|
||
|
|
|
||
|
|
# --------------------------
|
||
|
|
# CRUD
|
||
|
|
# --------------------------
|
||
|
|
|
||
|
|
@api.model_create_multi
|
||
|
|
def create(self, values):
|
||
|
|
lines = super(SaleOrderLine, self).create(values)
|
||
|
|
# Do not generate purchase when expense SO line since the product is already delivered
|
||
|
|
lines.filtered(
|
||
|
|
lambda line: line.state == 'sale' and not line.is_expense
|
||
|
|
)._purchase_service_generation()
|
||
|
|
return lines
|
||
|
|
|
||
|
|
def write(self, values):
|
||
|
|
increased_lines = None
|
||
|
|
decreased_lines = None
|
||
|
|
increased_values = {}
|
||
|
|
decreased_values = {}
|
||
|
|
if 'product_uom_qty' in values:
|
||
|
|
precision = self.env['decimal.precision'].precision_get('Product Unit of Measure')
|
||
|
|
increased_lines = self.sudo().filtered(lambda r: r.product_id.service_to_purchase and r.purchase_line_count and float_compare(r.product_uom_qty, values['product_uom_qty'], precision_digits=precision) == -1)
|
||
|
|
decreased_lines = self.sudo().filtered(lambda r: r.product_id.service_to_purchase and r.purchase_line_count and float_compare(r.product_uom_qty, values['product_uom_qty'], precision_digits=precision) == 1)
|
||
|
|
increased_values = {line.id: line.product_uom_qty for line in increased_lines}
|
||
|
|
decreased_values = {line.id: line.product_uom_qty for line in decreased_lines}
|
||
|
|
|
||
|
|
result = super(SaleOrderLine, self).write(values)
|
||
|
|
|
||
|
|
if increased_lines:
|
||
|
|
increased_lines._purchase_increase_ordered_qty(values['product_uom_qty'], increased_values)
|
||
|
|
if decreased_lines:
|
||
|
|
decreased_lines._purchase_decrease_ordered_qty(values['product_uom_qty'], decreased_values)
|
||
|
|
return result
|
||
|
|
|
||
|
|
# --------------------------
|
||
|
|
# Business Methods
|
||
|
|
# --------------------------
|
||
|
|
|
||
|
|
def _purchase_decrease_ordered_qty(self, new_qty, origin_values):
|
||
|
|
""" Decrease the quantity from SO line will add a next acitivities on the related purchase order
|
||
|
|
:param new_qty: new quantity (lower than the current one on SO line), expressed
|
||
|
|
in UoM of SO line.
|
||
|
|
:param origin_values: map from sale line id to old value for the ordered quantity (dict)
|
||
|
|
"""
|
||
|
|
purchase_to_notify_map = {} # map PO -> set(SOL)
|
||
|
|
last_purchase_lines = self.env['purchase.order.line'].search([('sale_line_id', 'in', self.ids)])
|
||
|
|
for purchase_line in last_purchase_lines:
|
||
|
|
purchase_to_notify_map.setdefault(purchase_line.order_id, self.env['sale.order.line'])
|
||
|
|
purchase_to_notify_map[purchase_line.order_id] |= purchase_line.sale_line_id
|
||
|
|
|
||
|
|
# create next activity
|
||
|
|
for purchase_order, sale_lines in purchase_to_notify_map.items():
|
||
|
|
render_context = {
|
||
|
|
'sale_lines': sale_lines,
|
||
|
|
'sale_orders': sale_lines.mapped('order_id'),
|
||
|
|
'origin_values': origin_values,
|
||
|
|
}
|
||
|
|
purchase_order._activity_schedule_with_view('mail.mail_activity_data_warning',
|
||
|
|
user_id=purchase_order.user_id.id or self.env.uid,
|
||
|
|
views_or_xmlid='sale_purchase.exception_purchase_on_sale_quantity_decreased',
|
||
|
|
render_context=render_context)
|
||
|
|
|
||
|
|
def _purchase_increase_ordered_qty(self, new_qty, origin_values):
|
||
|
|
""" Increase the quantity on the related purchase lines
|
||
|
|
:param new_qty: new quantity (higher than the current one on SO line), expressed
|
||
|
|
in UoM of SO line.
|
||
|
|
:param origin_values: map from sale line id to old value for the ordered quantity (dict)
|
||
|
|
"""
|
||
|
|
for line in self:
|
||
|
|
last_purchase_line = self.env['purchase.order.line'].search([('sale_line_id', '=', line.id)], order='create_date DESC', limit=1)
|
||
|
|
if last_purchase_line.state in ['draft', 'sent', 'to approve']: # update qty for draft PO lines
|
||
|
|
quantity = line.product_uom._compute_quantity(new_qty, last_purchase_line.product_uom)
|
||
|
|
last_purchase_line.write({'product_qty': quantity})
|
||
|
|
elif last_purchase_line.state in ['purchase', 'done', 'cancel']: # create new PO, by forcing the quantity as the difference from SO line
|
||
|
|
quantity = line.product_uom._compute_quantity(new_qty - origin_values.get(line.id, 0.0), last_purchase_line.product_uom)
|
||
|
|
line._purchase_service_create(quantity=quantity)
|
||
|
|
|
||
|
|
def _purchase_get_date_order(self, supplierinfo):
|
||
|
|
""" return the ordered date for the purchase order, computed as : SO commitment date - supplier delay """
|
||
|
|
commitment_date = fields.Datetime.from_string(self.order_id.commitment_date or fields.Datetime.now())
|
||
|
|
return commitment_date - relativedelta(days=int(supplierinfo.delay))
|
||
|
|
|
||
|
|
def _purchase_service_get_company(self):
|
||
|
|
return self.company_id
|
||
|
|
|
||
|
|
def _purchase_service_prepare_order_values(self, supplierinfo):
|
||
|
|
""" Returns the values to create the purchase order from the current SO line.
|
||
|
|
:param supplierinfo: record of product.supplierinfo
|
||
|
|
:rtype: dict
|
||
|
|
"""
|
||
|
|
self.ensure_one()
|
||
|
|
partner_supplier = supplierinfo.partner_id
|
||
|
|
fpos = self.env['account.fiscal.position'].sudo()._get_fiscal_position(partner_supplier)
|
||
|
|
date_order = self._purchase_get_date_order(supplierinfo)
|
||
|
|
return {
|
||
|
|
'partner_id': partner_supplier.id,
|
||
|
|
'partner_ref': partner_supplier.ref,
|
||
|
|
'company_id': self._purchase_service_get_company().id,
|
||
|
|
'currency_id': partner_supplier.property_purchase_currency_id.id or self.env.company.currency_id.id,
|
||
|
|
'dest_address_id': False, # False since only supported in stock
|
||
|
|
'origin': self.order_id.name,
|
||
|
|
'payment_term_id': partner_supplier.property_supplier_payment_term_id.id,
|
||
|
|
'date_order': date_order,
|
||
|
|
'fiscal_position_id': fpos.id,
|
||
|
|
}
|
||
|
|
|
||
|
|
def _purchase_service_get_price_unit_and_taxes(self, supplierinfo, purchase_order):
|
||
|
|
supplier_taxes = self.product_id.supplier_taxes_id.filtered(lambda t: t.company_id == purchase_order.company_id)
|
||
|
|
taxes = purchase_order.fiscal_position_id.map_tax(supplier_taxes)
|
||
|
|
if supplierinfo:
|
||
|
|
price_unit = self.env['account.tax'].sudo()._fix_tax_included_price_company(supplierinfo.price, supplier_taxes, taxes, purchase_order.company_id)
|
||
|
|
if purchase_order.currency_id and supplierinfo.currency_id != purchase_order.currency_id:
|
||
|
|
price_unit = supplierinfo.currency_id._convert(
|
||
|
|
price_unit,
|
||
|
|
purchase_order.currency_id,
|
||
|
|
purchase_order.company_id,
|
||
|
|
fields.Date.context_today(self)
|
||
|
|
)
|
||
|
|
else:
|
||
|
|
price_unit = 0.0
|
||
|
|
return price_unit, taxes
|
||
|
|
|
||
|
|
def _purchase_service_get_product_name(self, supplierinfo, purchase_order, quantity):
|
||
|
|
product_ctx = {
|
||
|
|
'lang': get_lang(self.env, purchase_order.partner_id.lang).code,
|
||
|
|
'company_id': purchase_order.company_id.id,
|
||
|
|
}
|
||
|
|
if supplierinfo:
|
||
|
|
product_ctx.update({'seller_id': supplierinfo.id})
|
||
|
|
else:
|
||
|
|
product_ctx.update({'partner_id': purchase_order.partner_id.id})
|
||
|
|
product = self.product_id.with_context(**product_ctx)
|
||
|
|
name = product.display_name
|
||
|
|
if product.description_purchase:
|
||
|
|
name += '\n' + product.description_purchase
|
||
|
|
return name
|
||
|
|
|
||
|
|
def _purchase_service_prepare_line_values(self, purchase_order, quantity=False):
|
||
|
|
""" Returns the values to create the purchase order line from the current SO line.
|
||
|
|
:param purchase_order: record of purchase.order
|
||
|
|
:rtype: dict
|
||
|
|
:param quantity: the quantity to force on the PO line, expressed in SO line UoM
|
||
|
|
"""
|
||
|
|
self.ensure_one()
|
||
|
|
# compute quantity from SO line UoM
|
||
|
|
product_quantity = self.product_uom_qty
|
||
|
|
if quantity:
|
||
|
|
product_quantity = quantity
|
||
|
|
|
||
|
|
purchase_qty_uom = self.product_uom._compute_quantity(product_quantity, self.product_id.uom_po_id)
|
||
|
|
|
||
|
|
# determine vendor (real supplier, sharing the same partner as the one from the PO, but with more accurate informations like validity, quantity, ...)
|
||
|
|
# Note: one partner can have multiple supplier info for the same product
|
||
|
|
supplierinfo = self.product_id._select_seller(
|
||
|
|
partner_id=purchase_order.partner_id,
|
||
|
|
quantity=purchase_qty_uom,
|
||
|
|
date=purchase_order.date_order and purchase_order.date_order.date(), # and purchase_order.date_order[:10],
|
||
|
|
uom_id=self.product_id.uom_po_id
|
||
|
|
)
|
||
|
|
|
||
|
|
price_unit, taxes = self._purchase_service_get_price_unit_and_taxes(supplierinfo, purchase_order)
|
||
|
|
name = self._purchase_service_get_product_name(supplierinfo, purchase_order, quantity)
|
||
|
|
|
||
|
|
line_description = self.with_context(lang=self.order_id.partner_id.lang)._get_sale_order_line_multiline_description_variants()
|
||
|
|
if line_description:
|
||
|
|
name += line_description
|
||
|
|
|
||
|
|
return {
|
||
|
|
'name': name,
|
||
|
|
'product_qty': purchase_qty_uom,
|
||
|
|
'product_id': self.product_id.id,
|
||
|
|
'product_uom': self.product_id.uom_po_id.id,
|
||
|
|
'price_unit': price_unit,
|
||
|
|
'date_planned': purchase_order.date_order + relativedelta(days=int(supplierinfo.delay)),
|
||
|
|
'taxes_id': [(6, 0, taxes.ids)],
|
||
|
|
'order_id': purchase_order.id,
|
||
|
|
'sale_line_id': self.id,
|
||
|
|
}
|
||
|
|
|
||
|
|
def _purchase_service_match_supplier(self, warning=True):
|
||
|
|
# determine vendor of the order (take the first matching company and product)
|
||
|
|
suppliers = self.product_id._select_seller(partner_id=self._retrieve_purchase_partner(), quantity=self.product_uom_qty, uom_id=self.product_uom)
|
||
|
|
if warning and not suppliers:
|
||
|
|
raise UserError(_("There is no vendor associated to the product %s. Please define a vendor for this product.", self.product_id.display_name))
|
||
|
|
return suppliers[0]
|
||
|
|
|
||
|
|
def _purchase_service_match_purchase_order(self, partner, company=False):
|
||
|
|
return self.env['purchase.order'].search([
|
||
|
|
('partner_id', '=', partner.id),
|
||
|
|
('state', '=', 'draft'),
|
||
|
|
('company_id', '=', (company and company or self.env.company).id),
|
||
|
|
], order='id desc')
|
||
|
|
|
||
|
|
def _create_purchase_order(self, supplierinfo):
|
||
|
|
values = self._purchase_service_prepare_order_values(supplierinfo)
|
||
|
|
return self.env['purchase.order'].with_context(mail_create_nosubscribe=True).create(values)
|
||
|
|
|
||
|
|
def _match_or_create_purchase_order(self, supplierinfo):
|
||
|
|
purchase_order = self._purchase_service_match_purchase_order(supplierinfo.partner_id)[:1]
|
||
|
|
if not purchase_order:
|
||
|
|
purchase_order = self._create_purchase_order(supplierinfo)
|
||
|
|
return purchase_order
|
||
|
|
|
||
|
|
def _retrieve_purchase_partner(self):
|
||
|
|
""" In case we want to explicitely name a partner from whom we want to buy or receive products
|
||
|
|
"""
|
||
|
|
self.ensure_one()
|
||
|
|
return False
|
||
|
|
|
||
|
|
def _purchase_service_create(self, quantity=False):
|
||
|
|
""" On Sales Order confirmation, some lines (services ones) can create a purchase order line and maybe a purchase order.
|
||
|
|
If a line should create a RFQ, it will check for existing PO. If no one is find, the SO line will create one, then adds
|
||
|
|
a new PO line. The created purchase order line will be linked to the SO line.
|
||
|
|
:param quantity: the quantity to force on the PO line, expressed in SO line UoM
|
||
|
|
"""
|
||
|
|
supplier_po_map = {}
|
||
|
|
sale_line_purchase_map = {}
|
||
|
|
|
||
|
|
for line in self:
|
||
|
|
line = line.with_company(line._purchase_service_get_company())
|
||
|
|
supplierinfo = line._purchase_service_match_supplier()
|
||
|
|
partner_supplier = supplierinfo.partner_id
|
||
|
|
|
||
|
|
# determine (or create) PO
|
||
|
|
purchase_order = supplier_po_map.get(partner_supplier.id)
|
||
|
|
if not purchase_order:
|
||
|
|
purchase_order = line._match_or_create_purchase_order(supplierinfo)
|
||
|
|
else: # if not already updated origin in this loop
|
||
|
|
so_name = line.order_id.name
|
||
|
|
origins = (purchase_order.origin or '').split(', ')
|
||
|
|
if so_name not in origins:
|
||
|
|
purchase_order.write({'origin': ', '.join(origins + [so_name])})
|
||
|
|
supplier_po_map[partner_supplier.id] = purchase_order
|
||
|
|
|
||
|
|
# add a PO line to the PO
|
||
|
|
values = line._purchase_service_prepare_line_values(purchase_order, quantity=quantity)
|
||
|
|
purchase_line = line.env['purchase.order.line'].create(values)
|
||
|
|
|
||
|
|
# link the generated purchase to the SO line
|
||
|
|
sale_line_purchase_map.setdefault(line, line.env['purchase.order.line'])
|
||
|
|
sale_line_purchase_map[line] |= purchase_line
|
||
|
|
return sale_line_purchase_map
|
||
|
|
|
||
|
|
def _purchase_service_generation(self):
|
||
|
|
""" Create a Purchase for the first time from the sale line. If the SO line already created a PO, it
|
||
|
|
will not create a second one.
|
||
|
|
"""
|
||
|
|
sale_line_purchase_map = {}
|
||
|
|
for line in self:
|
||
|
|
# Do not regenerate PO line if the SO line has already created one in the past (SO cancel/reconfirmation case)
|
||
|
|
if line.product_id.service_to_purchase and not line.purchase_line_count:
|
||
|
|
result = line._purchase_service_create()
|
||
|
|
sale_line_purchase_map.update(result)
|
||
|
|
return sale_line_purchase_map
|