1 # -*- coding: utf-8 -*-
2 ##############################################################################
4 # OpenERP, Open Source Management Solution
5 # Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
7 # This program is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU Affero General Public License as
9 # published by the Free Software Foundation, either version 3 of the
10 # License, or (at your option) any later version.
12 # This program is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU Affero General Public License for more details.
17 # You should have received a copy of the GNU Affero General Public License
18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
20 ##############################################################################
23 from datetime import datetime
24 from dateutil.relativedelta import relativedelta
26 from osv import osv, fields
29 from tools.translate import _
30 import decimal_precision as dp
31 from osv.orm import browse_record, browse_null
32 from tools import DEFAULT_SERVER_DATE_FORMAT, DEFAULT_SERVER_DATETIME_FORMAT, DATETIME_FORMATS_MAP
34 class purchase_order(osv.osv):
36 def _amount_all(self, cr, uid, ids, field_name, arg, context=None):
38 cur_obj=self.pool.get('res.currency')
39 for order in self.browse(cr, uid, ids, context=context):
41 'amount_untaxed': 0.0,
46 cur = order.pricelist_id.currency_id
47 for line in order.order_line:
48 val1 += line.price_subtotal
49 for c in self.pool.get('account.tax').compute_all(cr, uid, line.taxes_id, line.price_unit, line.product_qty, line.product_id.id, order.partner_id)['taxes']:
50 val += c.get('amount', 0.0)
51 res[order.id]['amount_tax']=cur_obj.round(cr, uid, cur, val)
52 res[order.id]['amount_untaxed']=cur_obj.round(cr, uid, cur, val1)
53 res[order.id]['amount_total']=res[order.id]['amount_untaxed'] + res[order.id]['amount_tax']
56 def _set_minimum_planned_date(self, cr, uid, ids, name, value, arg, context=None):
57 if not value: return False
58 if type(ids)!=type([]):
60 for po in self.browse(cr, uid, ids, context=context):
62 cr.execute("""update purchase_order_line set
66 (date_planned=%s or date_planned<%s)""", (value,po.id,po.minimum_planned_date,value))
67 cr.execute("""update purchase_order set
68 minimum_planned_date=%s where id=%s""", (value, po.id))
71 def _minimum_planned_date(self, cr, uid, ids, field_name, arg, context=None):
73 purchase_obj=self.browse(cr, uid, ids, context=context)
74 for purchase in purchase_obj:
75 res[purchase.id] = False
76 if purchase.order_line:
77 min_date=purchase.order_line[0].date_planned
78 for line in purchase.order_line:
79 if line.date_planned < min_date:
80 min_date=line.date_planned
81 res[purchase.id]=min_date
85 def _invoiced_rate(self, cursor, user, ids, name, arg, context=None):
87 for purchase in self.browse(cursor, user, ids, context=context):
89 for invoice in purchase.invoice_ids:
90 if invoice.state not in ('draft','cancel'):
91 tot += invoice.amount_untaxed
92 if purchase.amount_untaxed:
93 res[purchase.id] = tot * 100.0 / purchase.amount_untaxed
95 res[purchase.id] = 0.0
98 def _shipped_rate(self, cr, uid, ids, name, arg, context=None):
104 p.purchase_id,sum(m.product_qty), m.state
108 stock_picking p on (p.id=m.picking_id)
110 p.purchase_id IN %s GROUP BY m.state, p.purchase_id''',(tuple(ids),))
111 for oid,nbr,state in cr.fetchall():
115 res[oid][0] += nbr or 0.0
116 res[oid][1] += nbr or 0.0
118 res[oid][1] += nbr or 0.0
123 res[r] = 100.0 * res[r][0] / res[r][1]
126 def _get_order(self, cr, uid, ids, context=None):
128 for line in self.pool.get('purchase.order.line').browse(cr, uid, ids, context=context):
129 result[line.order_id.id] = True
132 def _invoiced(self, cursor, user, ids, name, arg, context=None):
134 for purchase in self.browse(cursor, user, ids, context=context):
136 if purchase.invoiced_rate == 100.00:
138 res[purchase.id] = invoiced
142 ('draft', 'Draft PO'),
143 ('sent', 'RFQ Sent'),
144 ('confirmed', 'Waiting Approval'),
145 ('approved', 'Purchase Order'),
146 ('except_picking', 'Shipping Exception'),
147 ('except_invoice', 'Invoice Exception'),
149 ('cancel', 'Cancelled')
153 'name': fields.char('Order Reference', size=64, required=True, select=True, help="Unique number of the purchase order, computed automatically when the purchase order is created."),
154 'origin': fields.char('Source Document', size=64,
155 help="Reference of the document that generated this purchase order request."
157 'partner_ref': fields.char('Supplier Reference', states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}, size=64),
158 'date_order':fields.date('Order Date', required=True, states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)]}, select=True, help="Date on which this document has been created."),
159 'date_approve':fields.date('Date Approved', readonly=1, select=True, help="Date on which purchase order has been approved"),
160 'partner_id':fields.many2one('res.partner', 'Supplier', required=True, states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}, change_default=True),
161 'dest_address_id':fields.many2one('res.partner', 'Customer Address (Direct Delivery)',
162 states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]},
163 help="Put an address if you want to deliver directly from the supplier to the customer. " \
164 "Otherwise, keep empty to deliver to your own company."
166 'warehouse_id': fields.many2one('stock.warehouse', 'Destination Warehouse', states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}),
167 'location_id': fields.many2one('stock.location', 'Destination', required=True, domain=[('usage','<>','view')]),
168 'pricelist_id':fields.many2one('product.pricelist', 'Pricelist', required=True, states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}, help="The pricelist sets the currency used for this purchase order. It also computes the supplier price for the selected products/quantities."),
169 'currency_id': fields.related('pricelist_id', 'currency_id', type="many2one", relation="res.currency", readonly=True, required=True),
170 'state': fields.selection(STATE_SELECTION, 'Status', readonly=True, help="The state of the purchase order or the quotation request. A quotation is a purchase order in a 'Draft' state. Then the order has to be confirmed by the user, the state switch to 'Confirmed'. Then the supplier must confirm the order to change the state to 'Approved'. When the purchase order is paid and received, the state becomes 'Done'. If a cancel action occurs in the invoice or in the reception of goods, the state becomes in exception.", select=True),
171 'order_line': fields.one2many('purchase.order.line', 'order_id', 'Order Lines', states={'approved':[('readonly',True)],'done':[('readonly',True)]}),
172 'validator' : fields.many2one('res.users', 'Validated by', readonly=True),
173 'notes': fields.text('Terms and Conditions'),
174 'invoice_ids': fields.many2many('account.invoice', 'purchase_invoice_rel', 'purchase_id', 'invoice_id', 'Invoices', help="Invoices generated for a purchase order"),
175 'picking_ids': fields.one2many('stock.picking.in', 'purchase_id', 'Picking List', readonly=True, help="This is the list of incoming shipments that have been generated for this purchase order."),
176 'shipped':fields.boolean('Received', readonly=True, select=True, help="It indicates that a picking has been done"),
177 'shipped_rate': fields.function(_shipped_rate, string='Received', type='float'),
178 'invoiced': fields.function(_invoiced, string='Invoice Received', type='boolean', help="It indicates that an invoice has been paid"),
179 'invoiced_rate': fields.function(_invoiced_rate, string='Invoiced', type='float'),
180 'invoice_method': fields.selection([('manual','Based on Purchase Order lines'),('order','Based on generated draft invoice'),('picking','Based on incoming shipments')], 'Invoicing Control', required=True,
181 help="Based on Purchase Order lines: place individual lines in 'Invoice Control > Based on P.O. lines' from where you can selectively create an invoice.\n" \
182 "Based on generated invoice: create a draft invoice you can validate later.\n" \
183 "Bases on incoming shipments: let you create an invoice when receptions are validated."
185 'minimum_planned_date':fields.function(_minimum_planned_date, fnct_inv=_set_minimum_planned_date, string='Expected Date', type='date', select=True, help="This is computed as the minimum scheduled date of all purchase order lines' products.",
187 'purchase.order.line': (_get_order, ['date_planned'], 10),
190 'amount_untaxed': fields.function(_amount_all, digits_compute= dp.get_precision('Account'), string='Untaxed Amount',
192 'purchase.order.line': (_get_order, None, 10),
193 }, multi="sums", help="The amount without tax"),
194 'amount_tax': fields.function(_amount_all, digits_compute= dp.get_precision('Account'), string='Taxes',
196 'purchase.order.line': (_get_order, None, 10),
197 }, multi="sums", help="The tax amount"),
198 'amount_total': fields.function(_amount_all, digits_compute= dp.get_precision('Account'), string='Total',
200 'purchase.order.line': (_get_order, None, 10),
201 }, multi="sums",help="The total amount"),
202 'fiscal_position': fields.many2one('account.fiscal.position', 'Fiscal Position'),
203 'product_id': fields.related('order_line','product_id', type='many2one', relation='product.product', string='Product'),
204 'create_uid': fields.many2one('res.users', 'Responsible'),
205 'company_id': fields.many2one('res.company','Company',required=True,select=1),
208 'date_order': fields.date.context_today,
210 'name': lambda obj, cr, uid, context: obj.pool.get('ir.sequence').get(cr, uid, 'purchase.order'),
212 'invoice_method': 'order',
214 'pricelist_id': lambda self, cr, uid, context: context.get('partner_id', False) and self.pool.get('res.partner').browse(cr, uid, context['partner_id']).property_product_pricelist_purchase.id,
215 'company_id': lambda self,cr,uid,c: self.pool.get('res.company')._company_default_get(cr, uid, 'purchase.order', context=c),
218 ('name_uniq', 'unique(name, company_id)', 'Order Reference must be unique per Company!'),
220 _name = "purchase.order"
221 _inherit = ['mail.thread', 'ir.needaction_mixin']
222 _description = "Purchase Order"
225 def create(self, cr, uid, vals, context=None):
226 order = super(purchase_order, self).create(cr, uid, vals, context=context)
228 self.create_send_note(cr, uid, [order], context=context)
231 def unlink(self, cr, uid, ids, context=None):
232 purchase_orders = self.read(cr, uid, ids, ['state'], context=context)
234 for s in purchase_orders:
235 if s['state'] in ['draft','cancel']:
236 unlink_ids.append(s['id'])
238 raise osv.except_osv(_('Invalid Action!'), _('In order to delete a purchase order, you must cancel it first.'))
240 # automatically sending subflow.delete upon deletion
241 wf_service = netsvc.LocalService("workflow")
242 for id in unlink_ids:
243 wf_service.trg_validate(uid, 'purchase.order', id, 'purchase_cancel', cr)
245 return super(purchase_order, self).unlink(cr, uid, unlink_ids, context=context)
247 def button_dummy(self, cr, uid, ids, context=None):
250 def onchange_pricelist(self, cr, uid, ids, pricelist_id, context=None):
253 return {'value': {'currency_id': self.pool.get('product.pricelist').browse(cr, uid, pricelist_id, context=context).currency_id.id}}
255 def onchange_dest_address_id(self, cr, uid, ids, address_id):
258 address = self.pool.get('res.partner')
259 values = {'warehouse_id': False}
260 supplier = address.browse(cr, uid, address_id)
262 location_id = supplier.property_stock_customer.id
263 values.update({'location_id': location_id})
264 return {'value':values}
266 def onchange_warehouse_id(self, cr, uid, ids, warehouse_id):
269 warehouse = self.pool.get('stock.warehouse').browse(cr, uid, warehouse_id)
270 return {'value':{'location_id': warehouse.lot_input_id.id, 'dest_address_id': False}}
272 def onchange_partner_id(self, cr, uid, ids, partner_id):
273 partner = self.pool.get('res.partner')
275 return {'value':{'fiscal_position': False}}
276 supplier_address = partner.address_get(cr, uid, [partner_id], ['default'])
277 supplier = partner.browse(cr, uid, partner_id)
278 pricelist = supplier.property_product_pricelist_purchase.id
279 fiscal_position = supplier.property_account_position and supplier.property_account_position.id or False
280 return {'value':{'pricelist_id': pricelist, 'fiscal_position': fiscal_position}}
282 def view_invoice(self, cr, uid, ids, context=None):
284 This function returns an action that display existing invoices of given sale order ids. It can either be a in a list or in a form view, if there is only one invoice to show.
286 mod_obj = self.pool.get('ir.model.data')
287 wizard_obj = self.pool.get('purchase.order.line_invoice')
288 #compute the number of invoices to display
290 for po in self.browse(cr, uid, ids, context=context):
291 if po.invoice_method == 'manual':
292 if not po.invoice_ids:
293 context.update({'active_ids' : [line.id for line in po.order_line]})
294 wizard_obj.makeInvoices(cr, uid, [], context=context)
296 for po in self.browse(cr, uid, ids, context=context):
297 inv_ids+= [invoice.id for invoice in po.invoice_ids]
298 res = mod_obj.get_object_reference(cr, uid, 'account', 'invoice_supplier_form')
299 res_id = res and res[1] or False
302 'name': _('Supplier Invoices'),
306 'res_model': 'account.invoice',
307 'context': "{'type':'in_invoice', 'journal_type': 'purchase'}",
308 'type': 'ir.actions.act_window',
311 'res_id': inv_ids and inv_ids[0] or False,
314 def view_picking(self, cr, uid, ids, context=None):
316 This function returns an action that display existing pîcking orders of given purchase order ids.
318 mod_obj = self.pool.get('ir.model.data')
320 for po in self.browse(cr, uid, ids, context=context):
321 pick_ids += [picking.id for picking in po.picking_ids]
323 action_model, action_id = tuple(mod_obj.get_object_reference(cr, uid, 'stock', 'action_picking_tree4'))
324 action = self.pool.get(action_model).read(cr, uid, action_id, context=context)
325 ctx = eval(action['context'])
327 'search_default_purchase_id': ids[0]
329 if pick_ids and len(pick_ids) == 1:
330 form_view_ids = [view_id for view_id, view in action['views'] if view == 'form']
331 view_id = form_view_ids and form_view_ids[0] or False
336 'res_id': pick_ids[0]
344 def wkf_approve_order(self, cr, uid, ids, context=None):
345 self.write(cr, uid, ids, {'state': 'approved', 'date_approve': fields.date.context_today(self,cr,uid,context=context)})
348 def wkf_send_rfq(self, cr, uid, ids, context=None):
350 This function opens a window to compose an email, with the edi purchase template message loaded by default
352 mod_obj = self.pool.get('ir.model.data')
353 template = mod_obj.get_object_reference(cr, uid, 'purchase', 'email_template_edi_purchase')
354 template_id = template and template[1] or False
355 res = mod_obj.get_object_reference(cr, uid, 'mail', 'email_compose_message_wizard_form')
356 res_id = res and res[1] or False
359 'default_model': 'purchase.order',
360 'default_res_id': ids[0],
361 'default_use_template': True,
362 'default_template_id': template_id,
367 'res_model': 'mail.compose.message',
368 'views': [(res_id, 'form')],
370 'type': 'ir.actions.act_window',
376 #TODO: implement messages system
377 def wkf_confirm_order(self, cr, uid, ids, context=None):
379 for po in self.browse(cr, uid, ids, context=context):
380 if not po.order_line:
381 raise osv.except_osv(_('Error!'),_('You cannot confirm a purchase order without any purchase order line.'))
382 for line in po.order_line:
383 if line.state=='draft':
386 self.pool.get('purchase.order.line').action_confirm(cr, uid, todo, context)
388 self.write(cr, uid, [id], {'state' : 'confirmed', 'validator' : uid})
389 self.confirm_send_note(cr, uid, ids, context)
392 def _prepare_inv_line(self, cr, uid, account_id, order_line, context=None):
393 """Collects require data from purchase order line that is used to create invoice line
394 for that purchase order line
395 :param account_id: Expense account of the product of PO line if any.
396 :param browse_record order_line: Purchase order line browse record
397 :return: Value for fields of invoice lines.
401 'name': order_line.name,
402 'account_id': account_id,
403 'price_unit': order_line.price_unit or 0.0,
404 'quantity': order_line.product_qty,
405 'product_id': order_line.product_id.id or False,
406 'uos_id': order_line.product_uom.id or False,
407 'invoice_line_tax_id': [(6, 0, [x.id for x in order_line.taxes_id])],
408 'account_analytic_id': order_line.account_analytic_id.id or False,
411 def action_cancel_draft(self, cr, uid, ids, context=None):
414 self.write(cr, uid, ids, {'state':'draft','shipped':0})
415 wf_service = netsvc.LocalService("workflow")
417 # Deleting the existing instance of workflow for PO
418 wf_service.trg_delete(uid, 'purchase.order', p_id, cr)
419 wf_service.trg_create(uid, 'purchase.order', p_id, cr)
420 self.draft_send_note(cr, uid, ids, context=context)
423 def action_invoice_create(self, cr, uid, ids, context=None):
424 """Generates invoice for given ids of purchase orders and links that invoice ID to purchase order.
425 :param ids: list of ids of purchase orders.
426 :return: ID of created invoice.
431 journal_obj = self.pool.get('account.journal')
432 inv_obj = self.pool.get('account.invoice')
433 inv_line_obj = self.pool.get('account.invoice.line')
434 fiscal_obj = self.pool.get('account.fiscal.position')
435 property_obj = self.pool.get('ir.property')
437 for order in self.browse(cr, uid, ids, context=context):
438 pay_acc_id = order.partner_id.property_account_payable.id
439 journal_ids = journal_obj.search(cr, uid, [('type', '=','purchase'),('company_id', '=', order.company_id.id)], limit=1)
441 raise osv.except_osv(_('Error!'),
442 _('Define purchase journal for this company: "%s" (id:%d).') % (order.company_id.name, order.company_id.id))
444 # generate invoice line correspond to PO line and link that to created invoice (inv_id) and PO line
446 for po_line in order.order_line:
447 if po_line.product_id:
448 acc_id = po_line.product_id.product_tmpl_id.property_account_expense.id
450 acc_id = po_line.product_id.categ_id.property_account_expense_categ.id
452 raise osv.except_osv(_('Error!'), _('Define expense account for this company: "%s" (id:%d).') % (po_line.product_id.name, po_line.product_id.id,))
454 acc_id = property_obj.get(cr, uid, 'property_account_expense_categ', 'product.category').id
455 fpos = order.fiscal_position or False
456 acc_id = fiscal_obj.map_account(cr, uid, fpos, acc_id)
458 inv_line_data = self._prepare_inv_line(cr, uid, acc_id, po_line, context=context)
459 inv_line_id = inv_line_obj.create(cr, uid, inv_line_data, context=context)
460 inv_lines.append(inv_line_id)
462 po_line.write({'invoiced':True, 'invoice_lines': [(4, inv_line_id)]}, context=context)
464 # get invoice data and create invoice
466 'name': order.partner_ref or order.name,
467 'reference': order.partner_ref or order.name,
468 'account_id': pay_acc_id,
469 'type': 'in_invoice',
470 'partner_id': order.partner_id.id,
471 'currency_id': order.pricelist_id.currency_id.id,
472 'journal_id': len(journal_ids) and journal_ids[0] or False,
473 'invoice_line': [(6, 0, inv_lines)],
474 'origin': order.name,
475 'fiscal_position': order.fiscal_position.id or order.partner_id.property_account_position.id,
476 'payment_term': order.partner_id.property_payment_term and order.partner_id.property_payment_term.id or False,
477 'company_id': order.company_id.id,
479 inv_id = inv_obj.create(cr, uid, inv_data, context=context)
481 # compute the invoice
482 inv_obj.button_compute(cr, uid, [inv_id], context=context, set_total=True)
484 # Link this new invoice to related purchase order
485 order.write({'invoice_ids': [(4, inv_id)]}, context=context)
488 self.invoice_send_note(cr, uid, ids, res, context)
491 def invoice_done(self, cr, uid, ids, context=None):
492 self.write(cr, uid, ids, {'state':'approved'}, context=context)
493 self.invoice_done_send_note(cr, uid, ids, context=context)
496 def has_stockable_product(self, cr, uid, ids, *args):
497 for order in self.browse(cr, uid, ids):
498 for order_line in order.order_line:
499 if order_line.product_id and order_line.product_id.product_tmpl_id.type in ('product', 'consu'):
503 def action_cancel(self, cr, uid, ids, context=None):
504 wf_service = netsvc.LocalService("workflow")
505 for purchase in self.browse(cr, uid, ids, context=context):
506 for pick in purchase.picking_ids:
507 if pick.state not in ('draft','cancel'):
508 raise osv.except_osv(
509 _('Unable to cancel this purchase order.'),
510 _('First cancel all receptions related to this purchase order.'))
511 for pick in purchase.picking_ids:
512 wf_service.trg_validate(uid, 'stock.picking', pick.id, 'button_cancel', cr)
513 for inv in purchase.invoice_ids:
514 if inv and inv.state not in ('cancel','draft'):
515 raise osv.except_osv(
516 _('Unable to cancel this purchase order.'),
517 _('You must first cancel all receptions related to this purchase order.'))
519 wf_service.trg_validate(uid, 'account.invoice', inv.id, 'invoice_cancel', cr)
520 self.write(cr,uid,ids,{'state':'cancel'})
522 for (id, name) in self.name_get(cr, uid, ids):
523 wf_service.trg_validate(uid, 'purchase.order', id, 'purchase_cancel', cr)
524 self.cancel_send_note(cr, uid, ids, context)
527 def _prepare_order_picking(self, cr, uid, order, context=None):
529 'name': self.pool.get('ir.sequence').get(cr, uid, 'stock.picking.in'),
530 'origin': order.name + ((order.origin and (':' + order.origin)) or ''),
531 'date': order.date_order,
532 'partner_id': order.dest_address_id.id or order.partner_id.id,
533 'invoice_state': '2binvoiced' if order.invoice_method == 'picking' else 'none',
535 'partner_id': order.dest_address_id.id or order.partner_id.id,
536 'invoice_state': '2binvoiced' if order.invoice_method == 'picking' else 'none',
537 'purchase_id': order.id,
538 'company_id': order.company_id.id,
542 def _prepare_order_line_move(self, cr, uid, order, order_line, picking_id, context=None):
544 'name': order.name + ': ' + (order_line.name or ''),
545 'product_id': order_line.product_id.id,
546 'product_qty': order_line.product_qty,
547 'product_uos_qty': order_line.product_qty,
548 'product_uom': order_line.product_uom.id,
549 'product_uos': order_line.product_uom.id,
550 'date': order_line.date_planned,
551 'date_expected': order_line.date_planned,
552 'location_id': order.partner_id.property_stock_supplier.id,
553 'location_dest_id': order.location_id.id,
554 'picking_id': picking_id,
555 'partner_id': order.dest_address_id.id or order.partner_id.id,
556 'move_dest_id': order_line.move_dest_id.id,
559 'purchase_line_id': order_line.id,
560 'company_id': order.company_id.id,
561 'price_unit': order_line.price_unit
564 def _create_pickings(self, cr, uid, order, order_lines, picking_id=False, context=None):
565 """Creates pickings and appropriate stock moves for given order lines, then
566 confirms the moves, makes them available, and confirms the picking.
568 If ``picking_id`` is provided, the stock moves will be added to it, otherwise
569 a standard outgoing picking will be created to wrap the stock moves, as returned
570 by :meth:`~._prepare_order_picking`.
572 Modules that wish to customize the procurements or partition the stock moves over
573 multiple stock pickings may override this method and call ``super()`` with
574 different subsets of ``order_lines`` and/or preset ``picking_id`` values.
576 :param browse_record order: purchase order to which the order lines belong
577 :param list(browse_record) order_lines: purchase order line records for which picking
578 and moves should be created.
579 :param int picking_id: optional ID of a stock picking to which the created stock moves
580 will be added. A new picking will be created if omitted.
581 :return: list of IDs of pickings used/created for the given order lines (usually just one)
584 picking_id = self.pool.get('stock.picking').create(cr, uid, self._prepare_order_picking(cr, uid, order, context=context))
586 stock_move = self.pool.get('stock.move')
587 wf_service = netsvc.LocalService("workflow")
588 for order_line in order_lines:
589 if not order_line.product_id:
591 if order_line.product_id.type in ('product', 'consu'):
592 move = stock_move.create(cr, uid, self._prepare_order_line_move(cr, uid, order, order_line, picking_id, context=context))
593 if order_line.move_dest_id:
594 order_line.move_dest_id.write({'location_id': order.location_id.id})
595 todo_moves.append(move)
596 stock_move.action_confirm(cr, uid, todo_moves)
597 stock_move.force_assign(cr, uid, todo_moves)
598 wf_service.trg_validate(uid, 'stock.picking', picking_id, 'button_confirm', cr)
601 def action_picking_create(self, cr, uid, ids, context=None):
603 for order in self.browse(cr, uid, ids):
604 picking_ids.extend(self._create_pickings(cr, uid, order, order.order_line, None, context=context))
606 # Must return one unique picking ID: the one to connect in the subflow of the purchase order.
607 # In case of multiple (split) pickings, we should return the ID of the critical one, i.e. the
608 # one that should trigger the advancement of the purchase workflow.
609 # By default we will consider the first one as most important, but this behavior can be overridden.
611 self.shipment_send_note(cr, uid, ids, picking_ids[0], context=context)
612 return picking_ids[0] if picking_ids else False
614 def picking_done(self, cr, uid, ids, context=None):
615 self.write(cr, uid, ids, {'shipped':1,'state':'approved'}, context=context)
616 self.shipment_done_send_note(cr, uid, ids, context=context)
619 def copy(self, cr, uid, id, default=None, context=None):
628 'name': self.pool.get('ir.sequence').get(cr, uid, 'purchase.order'),
630 return super(purchase_order, self).copy(cr, uid, id, default, context)
632 def do_merge(self, cr, uid, ids, context=None):
634 To merge similar type of purchase orders.
635 Orders will only be merged if:
636 * Purchase Orders are in draft
637 * Purchase Orders belong to the same partner
638 * Purchase Orders are have same stock location, same pricelist
639 Lines will only be merged if:
640 * Order lines are exactly the same except for the quantity and unit
642 @param self: The object pointer.
643 @param cr: A database cursor
644 @param uid: ID of the user currently logged in
645 @param ids: the ID or list of IDs
646 @param context: A standard dictionary
648 @return: new purchase order id
651 #TOFIX: merged order line should be unlink
652 wf_service = netsvc.LocalService("workflow")
653 def make_key(br, fields):
656 field_val = getattr(br, field)
657 if field in ('product_id', 'move_dest_id', 'account_analytic_id'):
660 if isinstance(field_val, browse_record):
661 field_val = field_val.id
662 elif isinstance(field_val, browse_null):
664 elif isinstance(field_val, list):
665 field_val = ((6, 0, tuple([v.id for v in field_val])),)
666 list_key.append((field, field_val))
668 return tuple(list_key)
670 # Compute what the new orders should contain
674 for porder in [order for order in self.browse(cr, uid, ids, context=context) if order.state == 'draft']:
675 order_key = make_key(porder, ('partner_id', 'location_id', 'pricelist_id'))
676 new_order = new_orders.setdefault(order_key, ({}, []))
677 new_order[1].append(porder.id)
678 order_infos = new_order[0]
681 'origin': porder.origin,
682 'date_order': porder.date_order,
683 'partner_id': porder.partner_id.id,
684 'dest_address_id': porder.dest_address_id.id,
685 'warehouse_id': porder.warehouse_id.id,
686 'location_id': porder.location_id.id,
687 'pricelist_id': porder.pricelist_id.id,
690 'notes': '%s' % (porder.notes or '',),
691 'fiscal_position': porder.fiscal_position and porder.fiscal_position.id or False,
694 if porder.date_order < order_infos['date_order']:
695 order_infos['date_order'] = porder.date_order
697 order_infos['notes'] = (order_infos['notes'] or '') + ('\n%s' % (porder.notes,))
699 order_infos['origin'] = (order_infos['origin'] or '') + ' ' + porder.origin
701 for order_line in porder.order_line:
702 line_key = make_key(order_line, ('name', 'date_planned', 'taxes_id', 'price_unit', 'product_id', 'move_dest_id', 'account_analytic_id'))
703 o_line = order_infos['order_line'].setdefault(line_key, {})
705 # merge the line with an existing line
706 o_line['product_qty'] += order_line.product_qty * order_line.product_uom.factor / o_line['uom_factor']
708 # append a new "standalone" line
709 for field in ('product_qty', 'product_uom'):
710 field_val = getattr(order_line, field)
711 if isinstance(field_val, browse_record):
712 field_val = field_val.id
713 o_line[field] = field_val
714 o_line['uom_factor'] = order_line.product_uom and order_line.product_uom.factor or 1.0
720 for order_key, (order_data, old_ids) in new_orders.iteritems():
721 # skip merges with only one order
723 allorders += (old_ids or [])
726 # cleanup order line data
727 for key, value in order_data['order_line'].iteritems():
728 del value['uom_factor']
729 value.update(dict(key))
730 order_data['order_line'] = [(0, 0, value) for value in order_data['order_line'].itervalues()]
732 # create the new order
733 neworder_id = self.create(cr, uid, order_data)
734 orders_info.update({neworder_id: old_ids})
735 allorders.append(neworder_id)
737 # make triggers pointing to the old orders point to the new order
738 for old_id in old_ids:
739 wf_service.trg_redirect(uid, 'purchase.order', old_id, neworder_id, cr)
740 wf_service.trg_validate(uid, 'purchase.order', old_id, 'purchase_cancel', cr)
743 # --------------------------------------
744 # OpenChatter methods and notifications
745 # --------------------------------------
747 def needaction_domain_get(self, cr, uid, ids, context=None):
748 return [('state', '=', 'draft')]
750 def create_send_note(self, cr, uid, ids, context=None):
751 return self.message_post(cr, uid, ids, body=_("Request for quotation <b>created</b>."), context=context)
753 def confirm_send_note(self, cr, uid, ids, context=None):
754 for obj in self.browse(cr, uid, ids, context=context):
755 self.message_post(cr, uid, [obj.id], body=_("Quotation for <em>%s</em> <b>converted</b> to a Purchase Order of %s %s.") % (obj.partner_id.name, obj.amount_total, obj.pricelist_id.currency_id.symbol), context=context)
757 def shipment_send_note(self, cr, uid, ids, picking_id, context=None):
758 for order in self.browse(cr, uid, ids, context=context):
759 for picking in (pck for pck in order.picking_ids if pck.id == picking_id):
760 # convert datetime field to a datetime, using server format, then
761 # convert it to the user TZ and re-render it with %Z to add the timezone
762 picking_datetime = fields.DT.datetime.strptime(picking.min_date, DEFAULT_SERVER_DATETIME_FORMAT)
763 picking_date_str = fields.datetime.context_timestamp(cr, uid, picking_datetime, context=context).strftime(DATETIME_FORMATS_MAP['%+'] + " (%Z)")
764 self.message_post(cr, uid, [order.id], body=_("Shipment <em>%s</em> <b>scheduled</b> for %s.") % (picking.name, picking_date_str), context=context)
766 def invoice_send_note(self, cr, uid, ids, invoice_id, context=None):
767 for order in self.browse(cr, uid, ids, context=context):
768 for invoice in (inv for inv in order.invoice_ids if inv.id == invoice_id):
769 self.message_post(cr, uid, [order.id], body=_("Draft Invoice of %s %s is <b>waiting for validation</b>.") % (invoice.amount_total, invoice.currency_id.symbol), context=context)
771 def shipment_done_send_note(self, cr, uid, ids, context=None):
772 self.message_post(cr, uid, ids, body=_("""Shipment <b>received</b>."""), context=context)
774 def invoice_done_send_note(self, cr, uid, ids, context=None):
775 self.message_post(cr, uid, ids, body=_("Invoice <b>paid</b>."), context=context)
777 def draft_send_note(self, cr, uid, ids, context=None):
778 return self.message_post(cr, uid, ids, body=_("Purchase Order has been set to <b>draft</b>."), context=context)
780 def cancel_send_note(self, cr, uid, ids, context=None):
781 for obj in self.browse(cr, uid, ids, context=context):
782 self.message_post(cr, uid, [obj.id], body=_("Purchase Order for <em>%s</em> <b>cancelled</b>.") % (obj.partner_id.name), context=context)
786 class purchase_order_line(osv.osv):
787 def _amount_line(self, cr, uid, ids, prop, arg, context=None):
789 cur_obj=self.pool.get('res.currency')
790 tax_obj = self.pool.get('account.tax')
791 for line in self.browse(cr, uid, ids, context=context):
792 taxes = tax_obj.compute_all(cr, uid, line.taxes_id, line.price_unit, line.product_qty)
793 cur = line.order_id.pricelist_id.currency_id
794 res[line.id] = cur_obj.round(cr, uid, cur, taxes['total'])
798 'name': fields.text('Description', required=True),
799 'product_qty': fields.float('Quantity', digits_compute=dp.get_precision('Product Unit of Measure'), required=True),
800 'date_planned': fields.date('Scheduled Date', required=True, select=True),
801 'taxes_id': fields.many2many('account.tax', 'purchase_order_taxe', 'ord_id', 'tax_id', 'Taxes'),
802 'product_uom': fields.many2one('product.uom', 'Product Unit of Measure', required=True),
803 'product_id': fields.many2one('product.product', 'Product', domain=[('purchase_ok','=',True)], change_default=True),
804 'move_ids': fields.one2many('stock.move', 'purchase_line_id', 'Reservation', readonly=True, ondelete='set null'),
805 'move_dest_id': fields.many2one('stock.move', 'Reservation Destination', ondelete='set null'),
806 'price_unit': fields.float('Unit Price', required=True, digits_compute= dp.get_precision('Product Price')),
807 'price_subtotal': fields.function(_amount_line, string='Subtotal', digits_compute= dp.get_precision('Account')),
808 'order_id': fields.many2one('purchase.order', 'Order Reference', select=True, required=True, ondelete='cascade'),
809 'account_analytic_id':fields.many2one('account.analytic.account', 'Analytic Account',),
810 'company_id': fields.related('order_id','company_id',type='many2one',relation='res.company',string='Company', store=True, readonly=True),
811 'state': fields.selection([('draft', 'Draft'), ('confirmed', 'Confirmed'), ('done', 'Done'), ('cancel', 'Cancelled')], 'Status', required=True, readonly=True,
812 help=' * The \'Draft\' state is set automatically when purchase order in draft state. \
813 \n* The \'Confirmed\' state is set automatically as confirm when purchase order in confirm state. \
814 \n* The \'Done\' state is set automatically when purchase order is set as done. \
815 \n* The \'Cancelled\' state is set automatically when user cancel purchase order.'),
816 'invoice_lines': fields.many2many('account.invoice.line', 'purchase_order_line_invoice_rel', 'order_line_id', 'invoice_id', 'Invoice Lines', readonly=True),
817 'invoiced': fields.boolean('Invoiced', readonly=True),
818 'partner_id': fields.related('order_id','partner_id',string='Partner',readonly=True,type="many2one", relation="res.partner", store=True),
819 'date_order': fields.related('order_id','date_order',string='Order Date',readonly=True,type="date")
823 'product_qty': lambda *a: 1.0,
824 'state': lambda *args: 'draft',
825 'invoiced': lambda *a: 0,
827 _table = 'purchase_order_line'
828 _name = 'purchase.order.line'
829 _description = 'Purchase Order Line'
831 def copy_data(self, cr, uid, id, default=None, context=None):
834 default.update({'state':'draft', 'move_ids':[],'invoiced':0,'invoice_lines':[]})
835 return super(purchase_order_line, self).copy_data(cr, uid, id, default, context)
837 def onchange_product_uom(self, cr, uid, ids, pricelist_id, product_id, qty, uom_id,
838 partner_id, date_order=False, fiscal_position_id=False, date_planned=False,
839 name=False, price_unit=False, context=None):
841 onchange handler of product_uom.
844 return {'value': {'price_unit': price_unit or 0.0, 'name': name or '', 'product_uom' : uom_id or False}}
845 return self.onchange_product_id(cr, uid, ids, pricelist_id, product_id, qty, uom_id,
846 partner_id, date_order=date_order, fiscal_position_id=fiscal_position_id, date_planned=date_planned,
847 name=name, price_unit=price_unit, context=context)
849 def _get_date_planned(self, cr, uid, supplier_info, date_order_str, context=None):
850 """Return the datetime value to use as Schedule Date (``date_planned``) for
851 PO Lines that correspond to the given product.supplierinfo,
852 when ordered at `date_order_str`.
854 :param browse_record | False supplier_info: product.supplierinfo, used to
855 determine delivery delay (if False, default delay = 0)
856 :param str date_order_str: date of order, as a string in
857 DEFAULT_SERVER_DATE_FORMAT
859 :return: desired Schedule Date for the PO line
861 supplier_delay = int(supplier_info.delay) if supplier_info else 0
862 return datetime.strptime(date_order_str, DEFAULT_SERVER_DATE_FORMAT) + relativedelta(days=supplier_delay)
864 def _check_product_uom_group(self, cr, uid, context=None):
865 group_uom = self.pool.get('ir.model.data').get_object(cr, uid, 'product', 'group_uom')
866 res = [user for user in group_uom.users if user.id == uid]
867 return len(res) and True or False
870 def onchange_product_id(self, cr, uid, ids, pricelist_id, product_id, qty, uom_id,
871 partner_id, date_order=False, fiscal_position_id=False, date_planned=False,
872 name=False, price_unit=False, context=None):
874 onchange handler of product_id.
879 res = {'value': {'price_unit': price_unit or 0.0, 'name': name or '', 'product_uom' : uom_id or False}}
883 product_product = self.pool.get('product.product')
884 product_uom = self.pool.get('product.uom')
885 res_partner = self.pool.get('res.partner')
886 product_supplierinfo = self.pool.get('product.supplierinfo')
887 product_pricelist = self.pool.get('product.pricelist')
888 account_fiscal_position = self.pool.get('account.fiscal.position')
889 account_tax = self.pool.get('account.tax')
891 # - check for the presence of partner_id and pricelist_id
893 raise osv.except_osv(_('No Pricelist !'), _('Select a price list for a supplier in the purchase form to choose a product.'))
895 raise osv.except_osv(_('No Partner!'), _('Select a partner in purchase order to choose a product.'))
897 # - determine name and notes based on product in partner lang.
898 lang = res_partner.browse(cr, uid, partner_id).lang
899 context_partner = {'lang': lang, 'partner_id': partner_id}
900 product = product_product.browse(cr, uid, product_id, context=context_partner)
902 if product.description_purchase:
903 name += '\n' + product.description_purchase
904 res['value'].update({'name': name})
906 # - set a domain on product_uom
907 res['domain'] = {'product_uom': [('category_id','=',product.uom_id.category_id.id)]}
909 # - check that uom and product uom belong to the same category
910 product_uom_po_id = product.uom_po_id.id
912 uom_id = product_uom_po_id
914 if product.uom_id.category_id.id != product_uom.browse(cr, uid, uom_id, context=context).category_id.id:
915 if self._check_product_uom_group(cr, uid, context=context):
916 res['warning'] = {'title': _('Warning!'), 'message': _('Selected Unit of Measure does not belong to the same category as the product Unit of Measure.')}
917 uom_id = product_uom_po_id
919 res['value'].update({'product_uom': uom_id})
921 # - determine product_qty and date_planned based on seller info
923 date_order = fields.date.context_today(self,cr,uid,context=context)
927 for supplier in product.seller_ids:
928 if supplier.name.id == partner_id:
929 supplierinfo = supplier
930 if supplierinfo.product_uom.id != uom_id:
931 res['warning'] = {'title': _('Warning!'), 'message': _('The selected supplier only sells this product by %s') % supplierinfo.product_uom.name }
932 min_qty = product_uom._compute_qty(cr, uid, supplierinfo.product_uom.id, supplierinfo.min_qty, to_uom_id=uom_id)
933 if qty < min_qty: # If the supplier quantity is greater than entered from user, set minimal.
934 res['warning'] = {'title': _('Warning!'), 'message': _('The selected supplier has a minimal quantity set to %s %s, you should not purchase less.') % (supplierinfo.min_qty, supplierinfo.product_uom.name)}
937 dt = self._get_date_planned(cr, uid, supplierinfo, date_order, context=context).strftime(DEFAULT_SERVER_DATETIME_FORMAT)
939 res['value'].update({'date_planned': date_planned or dt, 'product_qty': qty})
941 # - determine price_unit and taxes_id
942 price = product_pricelist.price_get(cr, uid, [pricelist_id],
943 product.id, qty or 1.0, partner_id, {'uom': uom_id, 'date': date_order})[pricelist_id]
945 taxes = account_tax.browse(cr, uid, map(lambda x: x.id, product.supplier_taxes_id))
946 fpos = fiscal_position_id and account_fiscal_position.browse(cr, uid, fiscal_position_id, context=context) or False
947 taxes_ids = account_fiscal_position.map_tax(cr, uid, fpos, taxes)
948 res['value'].update({'price_unit': price, 'taxes_id': taxes_ids})
952 product_id_change = onchange_product_id
953 product_uom_change = onchange_product_uom
955 def action_confirm(self, cr, uid, ids, context=None):
956 self.write(cr, uid, ids, {'state': 'confirmed'}, context=context)
959 purchase_order_line()
961 class procurement_order(osv.osv):
962 _inherit = 'procurement.order'
964 'purchase_id': fields.many2one('purchase.order', 'Purchase Order'),
967 def action_po_assign(self, cr, uid, ids, context=None):
968 """ This is action which call from workflow to assign purchase order to procurements
971 res = self.make_po(cr, uid, ids, context=context)
973 return len(res) and res[0] or 0 #TO CHECK: why workflow is generated error if return not integer value
975 def create_procurement_purchase_order(self, cr, uid, procurement, po_vals, line_vals, context=None):
976 """Create the purchase order from the procurement, using
977 the provided field values, after adding the given purchase
978 order line in the purchase order.
980 :params procurement: the procurement object generating the purchase order
981 :params dict po_vals: field values for the new purchase order (the
982 ``order_line`` field will be overwritten with one
983 single line, as passed in ``line_vals``).
984 :params dict line_vals: field values of the single purchase order line that
985 the purchase order will contain.
986 :return: id of the newly created purchase order
989 po_vals.update({'order_line': [(0,0,line_vals)]})
990 return self.pool.get('purchase.order').create(cr, uid, po_vals, context=context)
992 def _get_purchase_schedule_date(self, cr, uid, procurement, company, context=None):
993 """Return the datetime value to use as Schedule Date (``date_planned``) for the
994 Purchase Order Lines created to satisfy the given procurement.
996 :param browse_record procurement: the procurement for which a PO will be created.
997 :param browse_report company: the company to which the new PO will belong to.
999 :return: the desired Schedule Date for the PO lines
1001 procurement_date_planned = datetime.strptime(procurement.date_planned, DEFAULT_SERVER_DATETIME_FORMAT)
1002 schedule_date = (procurement_date_planned - relativedelta(days=company.po_lead))
1003 return schedule_date
1005 def _get_purchase_order_date(self, cr, uid, procurement, company, schedule_date, context=None):
1006 """Return the datetime value to use as Order Date (``date_order``) for the
1007 Purchase Order created to satisfy the given procurement.
1009 :param browse_record procurement: the procurement for which a PO will be created.
1010 :param browse_report company: the company to which the new PO will belong to.
1011 :param datetime schedule_date: desired Scheduled Date for the Purchase Order lines.
1013 :return: the desired Order Date for the PO
1015 seller_delay = int(procurement.product_id.seller_delay)
1016 return schedule_date - relativedelta(days=seller_delay)
1018 def make_po(self, cr, uid, ids, context=None):
1019 """ Make purchase order from procurement
1020 @return: New created Purchase Orders procurement wise
1025 company = self.pool.get('res.users').browse(cr, uid, uid, context=context).company_id
1026 partner_obj = self.pool.get('res.partner')
1027 uom_obj = self.pool.get('product.uom')
1028 pricelist_obj = self.pool.get('product.pricelist')
1029 prod_obj = self.pool.get('product.product')
1030 acc_pos_obj = self.pool.get('account.fiscal.position')
1031 seq_obj = self.pool.get('ir.sequence')
1032 warehouse_obj = self.pool.get('stock.warehouse')
1033 for procurement in self.browse(cr, uid, ids, context=context):
1034 res_id = procurement.move_id.id
1035 partner = procurement.product_id.seller_id # Taken Main Supplier of Product of Procurement.
1036 seller_qty = procurement.product_id.seller_qty
1037 partner_id = partner.id
1038 address_id = partner_obj.address_get(cr, uid, [partner_id], ['delivery'])['delivery']
1039 pricelist_id = partner.property_product_pricelist_purchase.id
1040 warehouse_id = warehouse_obj.search(cr, uid, [('company_id', '=', procurement.company_id.id or company.id)], context=context)
1041 uom_id = procurement.product_id.uom_po_id.id
1043 qty = uom_obj._compute_qty(cr, uid, procurement.product_uom.id, procurement.product_qty, uom_id)
1045 qty = max(qty,seller_qty)
1047 price = pricelist_obj.price_get(cr, uid, [pricelist_id], procurement.product_id.id, qty, partner_id, {'uom': uom_id})[pricelist_id]
1049 schedule_date = self._get_purchase_schedule_date(cr, uid, procurement, company, context=context)
1050 purchase_date = self._get_purchase_order_date(cr, uid, procurement, company, schedule_date, context=context)
1052 #Passing partner_id to context for purchase order line integrity of Line name
1053 new_context = context.copy()
1054 new_context.update({'lang': partner.lang, 'partner_id': partner_id})
1056 product = prod_obj.browse(cr, uid, procurement.product_id.id, context=new_context)
1057 taxes_ids = procurement.product_id.product_tmpl_id.supplier_taxes_id
1058 taxes = acc_pos_obj.map_tax(cr, uid, partner.property_account_position, taxes_ids)
1060 name = product.partner_ref
1061 if product.description_purchase:
1062 name += '\n'+ product.description_purchase
1066 'product_id': procurement.product_id.id,
1067 'product_uom': uom_id,
1068 'price_unit': price or 0.0,
1069 'date_planned': schedule_date.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
1070 'move_dest_id': res_id,
1071 'taxes_id': [(6,0,taxes)],
1073 name = seq_obj.get(cr, uid, 'purchase.order') or _('PO: %s') % procurement.name
1076 'origin': procurement.origin,
1077 'partner_id': partner_id,
1078 'location_id': procurement.location_id.id,
1079 'warehouse_id': warehouse_id and warehouse_id[0] or False,
1080 'pricelist_id': pricelist_id,
1081 'date_order': purchase_date.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
1082 'company_id': procurement.company_id.id,
1083 'fiscal_position': partner.property_account_position and partner.property_account_position.id or False
1085 res[procurement.id] = self.create_procurement_purchase_order(cr, uid, procurement, po_vals, line_vals, context=new_context)
1086 self.write(cr, uid, [procurement.id], {'state': 'running', 'purchase_id': res[procurement.id]})
1087 self.purchase_order_create_note(cr, uid, ids, context=context)
1090 def purchase_order_create_note(self, cr, uid, ids, context=None):
1091 for procurement in self.browse(cr, uid, ids, context=context):
1092 body = _("Draft Purchase Order created")
1093 self.message_post(cr, uid, [procurement.id], body=body, context=context)
1097 class mail_mail(osv.osv):
1099 _inherit = 'mail.mail'
1101 def _postprocess_sent_message(self, cr, uid, mail, context=None):
1102 if mail.model == 'purchase.order':
1103 wf_service = netsvc.LocalService("workflow")
1104 wf_service.trg_validate(uid, 'purchase.order', mail.res_id, 'send_rfq', cr)
1105 return super(mail_mail, self)._postprocess_sent_message(cr, uid, mail=mail, context=context)
1109 class product_template(osv.osv):
1110 _name = 'product.template'
1111 _inherit = 'product.template'
1113 'purchase_ok': fields.boolean('Can be Purchased', help="Determine if the product is visible in the list of products within a selection from a purchase order line."),
1121 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: