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
36 class purchase_order(osv.osv):
38 def _calc_amount(self, cr, uid, ids, prop, unknow_none, unknow_dict):
40 for order in self.browse(cr, uid, ids):
42 for oline in order.order_line:
43 res[order.id] += oline.price_unit * oline.product_qty
46 def _amount_all(self, cr, uid, ids, field_name, arg, context=None):
48 cur_obj=self.pool.get('res.currency')
49 for order in self.browse(cr, uid, ids, context=context):
51 'amount_untaxed': 0.0,
56 cur = order.pricelist_id.currency_id
57 for line in order.order_line:
58 val1 += line.price_subtotal
59 for c in self.pool.get('account.tax').compute_all(cr, uid, line.taxes_id, line.price_unit, line.product_qty, order.partner_address_id.id, line.product_id.id, order.partner_id)['taxes']:
60 val += c.get('amount', 0.0)
61 res[order.id]['amount_tax']=cur_obj.round(cr, uid, cur, val)
62 res[order.id]['amount_untaxed']=cur_obj.round(cr, uid, cur, val1)
63 res[order.id]['amount_total']=res[order.id]['amount_untaxed'] + res[order.id]['amount_tax']
66 def _set_minimum_planned_date(self, cr, uid, ids, name, value, arg, context=None):
67 if not value: return False
68 if type(ids)!=type([]):
70 for po in self.browse(cr, uid, ids, context=context):
72 cr.execute("""update purchase_order_line set
76 (date_planned=%s or date_planned<%s)""", (value,po.id,po.minimum_planned_date,value))
77 cr.execute("""update purchase_order set
78 minimum_planned_date=%s where id=%s""", (value, po.id))
81 def _minimum_planned_date(self, cr, uid, ids, field_name, arg, context=None):
83 purchase_obj=self.browse(cr, uid, ids, context=context)
84 for purchase in purchase_obj:
85 res[purchase.id] = False
86 if purchase.order_line:
87 min_date=purchase.order_line[0].date_planned
88 for line in purchase.order_line:
89 if line.date_planned < min_date:
90 min_date=line.date_planned
91 res[purchase.id]=min_date
95 def _invoiced_rate(self, cursor, user, ids, name, arg, context=None):
97 for purchase in self.browse(cursor, user, ids, context=context):
99 for invoice in purchase.invoice_ids:
100 if invoice.state not in ('draft','cancel'):
101 tot += invoice.amount_untaxed
103 if purchase.amount_untaxed:
104 res[purchase.id] = min(100.0, tot * 100.0 / (purchase.amount_untaxed))
106 res[purchase.id] = 0.0
109 def _shipped_rate(self, cr, uid, ids, name, arg, context=None):
110 if not ids: return {}
115 p.purchase_id,sum(m.product_qty), m.state
119 stock_picking p on (p.id=m.picking_id)
121 p.purchase_id IN %s GROUP BY m.state, p.purchase_id''',(tuple(ids),))
122 for oid,nbr,state in cr.fetchall():
126 res[oid][0] += nbr or 0.0
127 res[oid][1] += nbr or 0.0
129 res[oid][1] += nbr or 0.0
134 res[r] = 100.0 * res[r][0] / res[r][1]
137 def _get_order(self, cr, uid, ids, context=None):
139 for line in self.pool.get('purchase.order.line').browse(cr, uid, ids, context=context):
140 result[line.order_id.id] = True
143 def _invoiced(self, cursor, user, ids, name, arg, context=None):
145 for purchase in self.browse(cursor, user, ids, context=context):
147 if purchase.invoiced_rate == 100.00:
149 res[purchase.id] = invoiced
153 ('draft', 'Request for Quotation'),
155 ('confirmed', 'Waiting Approval'),
156 ('approved', 'Approved'),
157 ('except_picking', 'Shipping Exception'),
158 ('except_invoice', 'Invoice Exception'),
160 ('cancel', 'Cancelled')
164 '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"),
165 'origin': fields.char('Source Document', size=64,
166 help="Reference of the document that generated this purchase order request."
168 'partner_ref': fields.char('Supplier Reference', states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}, size=64),
169 'date_order':fields.date('Date Ordered', required=True, states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)]}, select=True, help="Date on which this document has been created."),
170 'date_approve':fields.date('Date Approved', readonly=1, select=True, help="Date on which purchase order has been approved"),
171 'partner_id':fields.many2one('res.partner', 'Supplier', required=True, states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}, change_default=True),
172 'partner_address_id':fields.many2one('res.partner.address', 'Address', required=True,
173 states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]},domain="[('partner_id', '=', partner_id)]"),
174 'dest_address_id':fields.many2one('res.partner.address', 'Destination Address',
175 states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]},
176 help="Put an address if you want to deliver directly from the supplier to the customer." \
177 "In this case, it will remove the warehouse link and set the customer location."
179 'warehouse_id': fields.many2one('stock.warehouse', 'Warehouse', states={'confirmed':[('readonly',True)], 'approved':[('readonly',True)],'done':[('readonly',True)]}),
180 'location_id': fields.many2one('stock.location', 'Destination', required=True, domain=[('usage','<>','view')]),
181 '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."),
182 'state': fields.selection(STATE_SELECTION, 'State', 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),
183 'order_line': fields.one2many('purchase.order.line', 'order_id', 'Order Lines', states={'approved':[('readonly',True)],'done':[('readonly',True)]}),
184 'validator' : fields.many2one('res.users', 'Validated by', readonly=True),
185 'notes': fields.text('Notes'),
186 'invoice_ids': fields.many2many('account.invoice', 'purchase_invoice_rel', 'purchase_id', 'invoice_id', 'Invoices', help="Invoices generated for a purchase order"),
187 'picking_ids': fields.one2many('stock.picking', 'purchase_id', 'Picking List', readonly=True, help="This is the list of picking list that have been generated for this purchase"),
188 'shipped':fields.boolean('Received', readonly=True, select=True, help="It indicates that a picking has been done"),
189 'shipped_rate': fields.function(_shipped_rate, method=True, string='Received', type='float'),
190 'invoiced': fields.function(_invoiced, method=True, string='Invoiced & Paid', type='boolean', help="It indicates that an invoice has been paid"),
191 'invoiced_rate': fields.function(_invoiced_rate, method=True, string='Invoiced', type='float'),
192 'invoice_method': fields.selection([('manual','Manual'),('order','From Order'),('picking','From Picking')], 'Invoicing Control', required=True,
193 help="From Order: a draft invoice will be pre-generated based on the purchase order. The accountant " \
194 "will just have to validate this invoice for control.\n" \
195 "From Picking: a draft invoice will be pre-generated based on validated receptions.\n" \
196 "Manual: allows you to generate suppliers invoices by chosing in the uninvoiced lines of all manual purchase orders."
198 'minimum_planned_date':fields.function(_minimum_planned_date, fnct_inv=_set_minimum_planned_date, method=True, string='Expected Date', type='date', select=True, help="This is computed as the minimum scheduled date of all purchase order lines' products.",
200 'purchase.order.line': (_get_order, ['date_planned'], 10),
203 'amount_untaxed': fields.function(_amount_all, method=True, digits_compute= dp.get_precision('Purchase Price'), string='Untaxed Amount',
205 'purchase.order.line': (_get_order, None, 10),
206 }, multi="sums", help="The amount without tax"),
207 'amount_tax': fields.function(_amount_all, method=True, digits_compute= dp.get_precision('Purchase Price'), string='Taxes',
209 'purchase.order.line': (_get_order, None, 10),
210 }, multi="sums", help="The tax amount"),
211 'amount_total': fields.function(_amount_all, method=True, digits_compute= dp.get_precision('Purchase Price'), string='Total',
213 'purchase.order.line': (_get_order, None, 10),
214 }, multi="sums",help="The total amount"),
215 'fiscal_position': fields.many2one('account.fiscal.position', 'Fiscal Position'),
216 'product_id': fields.related('order_line','product_id', type='many2one', relation='product.product', string='Product'),
217 'create_uid': fields.many2one('res.users', 'Responsible'),
218 'company_id': fields.many2one('res.company','Company',required=True,select=1),
221 'date_order': lambda *a: time.strftime('%Y-%m-%d'),
223 'name': lambda obj, cr, uid, context: obj.pool.get('ir.sequence').get(cr, uid, 'purchase.order'),
225 'invoice_method': 'order',
227 'partner_address_id': lambda self, cr, uid, context: context.get('partner_id', False) and self.pool.get('res.partner').address_get(cr, uid, [context['partner_id']], ['default'])['default'],
228 '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,
229 'company_id': lambda self,cr,uid,c: self.pool.get('res.company')._company_default_get(cr, uid, 'purchase.order', context=c),
232 ('name_uniq', 'unique(name)', 'Order Reference must be unique !'),
234 _name = "purchase.order"
235 _description = "Purchase Order"
238 def unlink(self, cr, uid, ids, context=None):
239 purchase_orders = self.read(cr, uid, ids, ['state'], context=context)
241 for s in purchase_orders:
242 if s['state'] in ['draft','cancel']:
243 unlink_ids.append(s['id'])
245 raise osv.except_osv(_('Invalid action !'), _('Cannot delete Purchase Order(s) which are in %s State!') % _(dict(purchase_order.STATE_SELECTION).get(s['state'])))
247 # TODO: temporary fix in 5.0, to remove in 5.2 when subflows support
248 # automatically sending subflow.delete upon deletion
249 wf_service = netsvc.LocalService("workflow")
250 for id in unlink_ids:
251 wf_service.trg_validate(uid, 'purchase.order', id, 'purchase_cancel', cr)
253 return super(purchase_order, self).unlink(cr, uid, unlink_ids, context=context)
255 def button_dummy(self, cr, uid, ids, context=None):
258 def onchange_dest_address_id(self, cr, uid, ids, adr_id):
261 values = {'warehouse_id': False}
262 part_id = self.pool.get('res.partner.address').browse(cr, uid, adr_id).partner_id
264 loc_id = part_id.property_stock_customer.id
265 values.update({'location_id': loc_id})
266 return {'value':values}
268 def onchange_warehouse_id(self, cr, uid, ids, warehouse_id):
271 res = self.pool.get('stock.warehouse').read(cr, uid, [warehouse_id], ['lot_input_id'])[0]['lot_input_id'][0]
272 return {'value':{'location_id': res, 'dest_address_id': False}}
274 def onchange_partner_id(self, cr, uid, ids, part):
277 return {'value':{'partner_address_id': False, 'fiscal_position': False}}
278 addr = self.pool.get('res.partner').address_get(cr, uid, [part], ['default'])
279 part = self.pool.get('res.partner').browse(cr, uid, part)
280 pricelist = part.property_product_pricelist_purchase.id
281 fiscal_position = part.property_account_position and part.property_account_position.id or False
282 return {'value':{'partner_address_id': addr['default'], 'pricelist_id': pricelist, 'fiscal_position': fiscal_position}}
284 def wkf_approve_order(self, cr, uid, ids, context=None):
285 self.write(cr, uid, ids, {'state': 'approved', 'date_approve': time.strftime('%Y-%m-%d')})
288 #TODO: implement messages system
289 def wkf_confirm_order(self, cr, uid, ids, context=None):
291 for po in self.browse(cr, uid, ids, context=context):
292 if not po.order_line:
293 raise osv.except_osv(_('Error !'),_('You can not confirm purchase order without Purchase Order Lines.'))
294 for line in po.order_line:
295 if line.state=='draft':
297 message = _("Purchase order '%s' is confirmed.") % (po.name,)
298 self.log(cr, uid, po.id, message)
299 # current_name = self.name_get(cr, uid, ids)[0][1]
300 self.pool.get('purchase.order.line').action_confirm(cr, uid, todo, context)
302 self.write(cr, uid, [id], {'state' : 'confirmed', 'validator' : uid})
305 def wkf_warn_buyer(self, cr, uid, ids):
306 self.write(cr, uid, ids, {'state' : 'wait', 'validator' : uid})
307 request = pooler.get_pool(cr.dbname).get('res.request')
308 for po in self.browse(cr, uid, ids):
310 for oline in po.order_line:
311 manager = oline.product_id.product_manager
312 if manager and not (manager.id in managers):
313 managers.append(manager.id)
314 for manager_id in managers:
315 request.create(cr, uid,{
316 'name' : _("Purchase amount over the limit"),
318 'act_to' : manager_id,
319 'body': _('Somebody has just confirmed a purchase with an amount over the defined limit'),
320 'ref_partner_id': po.partner_id.id,
321 'ref_doc1': 'purchase.order,%d' % (po.id,),
323 def inv_line_create(self, cr, uid, a, ol):
327 'price_unit': ol.price_unit or 0.0,
328 'quantity': ol.product_qty,
329 'product_id': ol.product_id.id or False,
330 'uos_id': ol.product_uom.id or False,
331 'invoice_line_tax_id': [(6, 0, [x.id for x in ol.taxes_id])],
332 'account_analytic_id': ol.account_analytic_id.id or False,
335 def action_cancel_draft(self, cr, uid, ids, *args):
338 self.write(cr, uid, ids, {'state':'draft','shipped':0})
339 wf_service = netsvc.LocalService("workflow")
341 # Deleting the existing instance of workflow for PO
342 wf_service.trg_delete(uid, 'purchase.order', p_id, cr)
343 wf_service.trg_create(uid, 'purchase.order', p_id, cr)
344 for (id,name) in self.name_get(cr, uid, ids):
345 message = _("Purchase order '%s' has been set in draft state.") % name
346 self.log(cr, uid, id, message)
349 def action_invoice_create(self, cr, uid, ids, *args):
351 property_obj = self.pool.get('ir.property')
352 fp_obj = self.pool.get('account.fiscal.position')
353 journal_obj = self.pool.get('account.journal')
354 for o in self.browse(cr, uid, ids):
357 for ol in o.order_line:
360 acc_id = ol.product_id.product_tmpl_id.property_account_expense.id
362 acc_id = ol.product_id.categ_id.property_account_expense_categ.id
364 raise osv.except_osv(_('Error !'), _('There is no expense account defined for this product: "%s" (id:%d)') % (ol.product_id.name, ol.product_id.id,))
366 prop = property_obj.get(cr, uid, 'property_account_expense_categ', 'product.category')
367 acc_id = prop and prop.id or False
368 fpos = o.fiscal_position or False
369 acc_id = fp_obj.map_account(cr, uid, fpos, acc_id)
371 raise osv.except_osv(_('Error !'),
372 _('There is no expense account defined in default Properties for Product Category or Fiscal Position is not defined !'))
373 il.append(self.inv_line_create(cr, uid, acc_id, ol))
375 acc_id = o.partner_id.property_account_payable.id
376 journal_ids = journal_obj.search(cr, uid, [('type', '=','purchase'),('company_id', '=', o.company_id.id)], limit=1)
378 raise osv.except_osv(_('Error !'),
379 _('There is no purchase journal defined for this company: "%s" (id:%d)') % (o.company_id.name, o.company_id.id))
381 'name': o.partner_ref or o.name,
382 'reference': o.partner_ref or o.name,
383 'account_id': acc_id,
384 'type': 'in_invoice',
385 'partner_id': o.partner_id.id,
386 'currency_id': o.pricelist_id.currency_id.id,
387 'address_invoice_id': o.partner_address_id.id,
388 'address_contact_id': o.partner_address_id.id,
389 'journal_id': len(journal_ids) and journal_ids[0] or False,
392 'fiscal_position': o.fiscal_position.id or o.partner_id.property_account_position.id,
393 'payment_term': o.partner_id.property_payment_term and o.partner_id.property_payment_term.id or False,
394 'company_id': o.company_id.id,
396 inv_id = self.pool.get('account.invoice').create(cr, uid, inv, {'type':'in_invoice', 'journal_type': 'purchase'})
397 self.pool.get('account.invoice').button_compute(cr, uid, [inv_id], {'type':'in_invoice'}, set_total=True)
398 self.pool.get('purchase.order.line').write(cr, uid, todo, {'invoiced':True})
399 self.write(cr, uid, [o.id], {'invoice_ids': [(4, inv_id)]})
403 def has_stockable_product(self,cr, uid, ids, *args):
404 for order in self.browse(cr, uid, ids):
405 for order_line in order.order_line:
406 if order_line.product_id and order_line.product_id.product_tmpl_id.type in ('product', 'consu'):
410 def action_cancel(self, cr, uid, ids, context=None):
411 for purchase in self.browse(cr, uid, ids, context=context):
412 for pick in purchase.picking_ids:
413 if pick.state not in ('draft','cancel'):
414 raise osv.except_osv(
415 _('Could not cancel purchase order !'),
416 _('You must first cancel all picking attached to this purchase order.'))
417 for pick in purchase.picking_ids:
418 wf_service = netsvc.LocalService("workflow")
419 wf_service.trg_validate(uid, 'stock.picking', pick.id, 'button_cancel', cr)
420 for inv in purchase.invoice_ids:
421 if inv and inv.state not in ('cancel','draft'):
422 raise osv.except_osv(
423 _('Could not cancel this purchase order !'),
424 _('You must first cancel all invoices attached to this purchase order.'))
426 wf_service = netsvc.LocalService("workflow")
427 wf_service.trg_validate(uid, 'account.invoice', inv.id, 'invoice_cancel', cr)
428 self.write(cr,uid,ids,{'state':'cancel'})
429 for (id,name) in self.name_get(cr, uid, ids):
430 message = _("Purchase order '%s' is cancelled.") % name
431 self.log(cr, uid, id, message)
434 def action_picking_create(self,cr, uid, ids, *args):
436 reception_address_id = False
437 for order in self.browse(cr, uid, ids):
438 if order.dest_address_id:
439 reception_address_id = order.dest_address_id.id
440 elif order.warehouse_id and order.warehouse_id.partner_address_id:
441 reception_address_id = order.warehouse_id.partner_address_id.id
443 if order.company_id.partner_id.address:
444 addresses_default = [address.id for address in order.company_id.partner_id.address if address.type == 'default']
445 addresses_delivery = [address.id for address in order.company_id.partner_id.address if address.type == 'delivery']
446 reception_address_id = (addresses_delivery and addresses_delivery[0]) or (addresses_default and addresses_default[0]) or False
447 loc_id = order.partner_id.property_stock_supplier.id
449 if order.invoice_method=='picking':
450 istate = '2binvoiced'
451 pick_name = self.pool.get('ir.sequence').get(cr, uid, 'stock.picking.in')
452 picking_id = self.pool.get('stock.picking').create(cr, uid, {
454 'origin': order.name+((order.origin and (':'+order.origin)) or ''),
456 'address_id': reception_address_id,
457 'invoice_state': istate,
458 'purchase_id': order.id,
459 'company_id': order.company_id.id,
463 for order_line in order.order_line:
464 if not order_line.product_id:
466 if order_line.product_id.product_tmpl_id.type in ('product', 'consu'):
467 dest = order.location_id.id
468 move = self.pool.get('stock.move').create(cr, uid, {
469 'name': order.name + ': ' +(order_line.name or ''),
470 'product_id': order_line.product_id.id,
471 'product_qty': order_line.product_qty,
472 'product_uos_qty': order_line.product_qty,
473 'product_uom': order_line.product_uom.id,
474 'product_uos': order_line.product_uom.id,
475 'date': order_line.date_planned,
476 'date_expected': order_line.date_planned,
477 'location_id': loc_id,
478 'location_dest_id': dest,
479 'picking_id': picking_id,
480 'move_dest_id': order_line.move_dest_id.id,
482 'purchase_line_id': order_line.id,
483 'company_id': order.company_id.id,
484 'price_unit': order_line.price_unit
486 if order_line.move_dest_id:
487 self.pool.get('stock.move').write(cr, uid, [order_line.move_dest_id.id], {'location_id':order.location_id.id})
488 todo_moves.append(move)
489 self.pool.get('stock.move').action_confirm(cr, uid, todo_moves)
490 self.pool.get('stock.move').force_assign(cr, uid, todo_moves)
491 wf_service = netsvc.LocalService("workflow")
492 wf_service.trg_validate(uid, 'stock.picking', picking_id, 'button_confirm', cr)
495 def copy(self, cr, uid, id, default=None, context=None):
504 'name': self.pool.get('ir.sequence').get(cr, uid, 'purchase.order'),
506 return super(purchase_order, self).copy(cr, uid, id, default, context)
509 def do_merge(self, cr, uid, ids, context=None):
511 To merge similar type of purchase orders.
512 Orders will only be merged if:
513 * Purchase Orders are in draft
514 * Purchase Orders belong to the same partner
515 * Purchase Orders are have same stock location, same pricelist
516 Lines will only be merged if:
517 * Order lines are exactly the same except for the quantity and unit
519 @param self: The object pointer.
520 @param cr: A database cursor
521 @param uid: ID of the user currently logged in
522 @param ids: the ID or list of IDs
523 @param context: A standard dictionary
525 @return: new purchase order id
528 wf_service = netsvc.LocalService("workflow")
529 def make_key(br, fields):
532 field_val = getattr(br, field)
533 if field in ('product_id', 'move_dest_id', 'account_analytic_id'):
536 if isinstance(field_val, browse_record):
537 field_val = field_val.id
538 elif isinstance(field_val, browse_null):
540 elif isinstance(field_val, list):
541 field_val = ((6, 0, tuple([v.id for v in field_val])),)
542 list_key.append((field, field_val))
544 return tuple(list_key)
546 # compute what the new orders should contain
550 for porder in [order for order in self.browse(cr, uid, ids, context=context) if order.state == 'draft']:
551 order_key = make_key(porder, ('partner_id', 'location_id', 'pricelist_id'))
552 new_order = new_orders.setdefault(order_key, ({}, []))
553 new_order[1].append(porder.id)
554 order_infos = new_order[0]
557 'origin': porder.origin,
558 'date_order': time.strftime('%Y-%m-%d'),
559 'partner_id': porder.partner_id.id,
560 'partner_address_id': porder.partner_address_id.id,
561 'dest_address_id': porder.dest_address_id.id,
562 'warehouse_id': porder.warehouse_id.id,
563 'location_id': porder.location_id.id,
564 'pricelist_id': porder.pricelist_id.id,
567 'notes': '%s' % (porder.notes or '',),
568 'fiscal_position': porder.fiscal_position and porder.fiscal_position.id or False,
572 order_infos['notes'] = (order_infos['notes'] or '') + ('\n%s' % (porder.notes,))
574 order_infos['origin'] = (order_infos['origin'] or '') + ' ' + porder.origin
576 for order_line in porder.order_line:
577 line_key = make_key(order_line, ('name', 'date_planned', 'taxes_id', 'price_unit', 'notes', 'product_id', 'move_dest_id', 'account_analytic_id'))
578 o_line = order_infos['order_line'].setdefault(line_key, {})
580 # merge the line with an existing line
581 o_line['product_qty'] += order_line.product_qty * order_line.product_uom.factor / o_line['uom_factor']
583 # append a new "standalone" line
584 for field in ('product_qty', 'product_uom'):
585 field_val = getattr(order_line, field)
586 if isinstance(field_val, browse_record):
587 field_val = field_val.id
588 o_line[field] = field_val
589 o_line['uom_factor'] = order_line.product_uom and order_line.product_uom.factor or 1.0
595 for order_key, (order_data, old_ids) in new_orders.iteritems():
596 # skip merges with only one order
598 allorders += (old_ids or [])
601 # cleanup order line data
602 for key, value in order_data['order_line'].iteritems():
603 del value['uom_factor']
604 value.update(dict(key))
605 order_data['order_line'] = [(0, 0, value) for value in order_data['order_line'].itervalues()]
607 # create the new order
608 neworder_id = self.create(cr, uid, order_data)
609 orders_info.update({neworder_id: old_ids})
610 allorders.append(neworder_id)
612 # make triggers pointing to the old orders point to the new order
613 for old_id in old_ids:
614 wf_service.trg_redirect(uid, 'purchase.order', old_id, neworder_id, cr)
615 wf_service.trg_validate(uid, 'purchase.order', old_id, 'purchase_cancel', cr)
620 class purchase_order_line(osv.osv):
621 def _amount_line(self, cr, uid, ids, prop, arg, context=None):
623 cur_obj=self.pool.get('res.currency')
624 tax_obj = self.pool.get('account.tax')
625 for line in self.browse(cr, uid, ids, context=context):
626 taxes = tax_obj.compute_all(cr, uid, line.taxes_id, line.price_unit, line.product_qty)
627 cur = line.order_id.pricelist_id.currency_id
628 res[line.id] = cur_obj.round(cr, uid, cur, taxes['total'])
632 'name': fields.char('Description', size=256, required=True),
633 'product_qty': fields.float('Quantity', required=True, digits=(16,2)),
634 'date_planned': fields.date('Scheduled Date', required=True, select=True),
635 'taxes_id': fields.many2many('account.tax', 'purchase_order_taxe', 'ord_id', 'tax_id', 'Taxes'),
636 'product_uom': fields.many2one('product.uom', 'Product UOM', required=True),
637 'product_id': fields.many2one('product.product', 'Product', domain=[('purchase_ok','=',True)], change_default=True),
638 'move_ids': fields.one2many('stock.move', 'purchase_line_id', 'Reservation', readonly=True, ondelete='set null'),
639 'move_dest_id': fields.many2one('stock.move', 'Reservation Destination', ondelete='set null'),
640 'price_unit': fields.float('Unit Price', required=True, digits_compute= dp.get_precision('Purchase Price')),
641 'price_subtotal': fields.function(_amount_line, method=True, string='Subtotal', digits_compute= dp.get_precision('Purchase Price')),
642 'notes': fields.text('Notes'),
643 'order_id': fields.many2one('purchase.order', 'Order Reference', select=True, required=True, ondelete='cascade'),
644 'account_analytic_id':fields.many2one('account.analytic.account', 'Analytic Account',),
645 'company_id': fields.related('order_id','company_id',type='many2one',relation='res.company',string='Company', store=True, readonly=True),
646 'state': fields.selection([('draft', 'Draft'), ('confirmed', 'Confirmed'), ('done', 'Done'), ('cancel', 'Cancelled')], 'State', required=True, readonly=True,
647 help=' * The \'Draft\' state is set automatically when purchase order in draft state. \
648 \n* The \'Confirmed\' state is set automatically as confirm when purchase order in confirm state. \
649 \n* The \'Done\' state is set automatically when purchase order is set as done. \
650 \n* The \'Cancelled\' state is set automatically when user cancel purchase order.'),
651 'invoice_lines': fields.many2many('account.invoice.line', 'purchase_order_line_invoice_rel', 'order_line_id', 'invoice_id', 'Invoice Lines', readonly=True),
652 'invoiced': fields.boolean('Invoiced', readonly=True),
653 'partner_id': fields.related('order_id','partner_id',string='Partner',readonly=True,type="many2one", relation="res.partner", store=True),
654 'date_order': fields.related('order_id','date_order',string='Order Date',readonly=True,type="date")
658 'product_qty': lambda *a: 1.0,
659 'state': lambda *args: 'draft',
660 'invoiced': lambda *a: 0,
662 _table = 'purchase_order_line'
663 _name = 'purchase.order.line'
664 _description = 'Purchase Order Line'
666 def copy_data(self, cr, uid, id, default=None, context=None):
669 default.update({'state':'draft', 'move_ids':[],'invoiced':0,'invoice_lines':[]})
670 return super(purchase_order_line, self).copy_data(cr, uid, id, default, context)
672 def product_id_change(self, cr, uid, ids, pricelist, product, qty, uom,
673 partner_id, date_order=False, fiscal_position=False, date_planned=False,
674 name=False, price_unit=False, notes=False):
676 raise osv.except_osv(_('No Pricelist !'), _('You have to select a pricelist or a supplier in the purchase form !\nPlease set one before choosing a product.'))
678 raise osv.except_osv(_('No Partner!'), _('You have to select a partner in the purchase form !\nPlease set one partner before choosing a product.'))
680 return {'value': {'price_unit': price_unit or 0.0, 'name': name or '',
681 'notes': notes or'', 'product_uom' : uom or False}, 'domain':{'product_uom':[]}}
683 prod= self.pool.get('product.product').browse(cr, uid, product)
685 product_uom_pool = self.pool.get('product.uom')
688 lang=self.pool.get('res.partner').read(cr, uid, partner_id, ['lang'])['lang']
689 context={'lang':lang}
690 context['partner_id'] = partner_id
692 prod = self.pool.get('product.product').browse(cr, uid, product, context=context)
693 prod_uom_po = prod.uom_po_id.id
697 date_order = time.strftime('%Y-%m-%d')
701 prod_name = self.pool.get('product.product').name_get(cr, uid, [prod.id], context=context)[0][1]
703 for s in prod.seller_ids:
704 if s.name.id == partner_id:
705 seller_delay = s.delay
707 temp_qty = product_uom_pool._compute_qty(cr, uid, s.product_uom.id, s.min_qty, to_uom_id=prod.uom_id.id)
708 uom = s.product_uom.id #prod_uom_po
709 temp_qty = s.min_qty # supplier _qty assigned to temp
710 if qty < temp_qty: # If the supplier quantity is greater than entered from user, set minimal.
712 res.update({'warning': {'title': _('Warning'), 'message': _('The selected supplier has a minimal quantity set to %s, you cannot purchase less.') % qty}})
713 qty_in_product_uom = product_uom_pool._compute_qty(cr, uid, uom, qty, to_uom_id=prod.uom_id.id)
714 price = self.pool.get('product.pricelist').price_get(cr,uid,[pricelist],
715 product, qty_in_product_uom or 1.0, partner_id, {
721 'title': 'No valid pricelist line found !',
723 "Couldn't find a pricelist line matching this product and quantity.\n"
724 "You have to change either the product, the quantity or the pricelist."
726 res.update({'warning': warning})
727 dt = (datetime.now() + relativedelta(days=int(seller_delay) or 0.0)).strftime('%Y-%m-%d %H:%M:%S')
730 res.update({'value': {'price_unit': price, 'name': prod_name,
731 'taxes_id':map(lambda x: x.id, prod.supplier_taxes_id),
732 'date_planned': date_planned or dt,'notes': notes or prod.description_purchase,
734 'product_uom': uom}})
737 taxes = self.pool.get('account.tax').browse(cr, uid,map(lambda x: x.id, prod.supplier_taxes_id))
738 fpos = fiscal_position and self.pool.get('account.fiscal.position').browse(cr, uid, fiscal_position) or False
739 res['value']['taxes_id'] = self.pool.get('account.fiscal.position').map_tax(cr, uid, fpos, taxes)
741 res2 = self.pool.get('product.uom').read(cr, uid, [uom], ['category_id'])
742 res3 = prod.uom_id.category_id.id
743 domain = {'product_uom':[('category_id','=',res2[0]['category_id'][0])]}
744 if res2[0]['category_id'][0] != res3:
745 raise osv.except_osv(_('Wrong Product UOM !'), _('You have to select a product UOM in the same category than the purchase UOM of the product'))
747 res['domain'] = domain
750 def product_uom_change(self, cr, uid, ids, pricelist, product, qty, uom,
751 partner_id, date_order=False, fiscal_position=False, date_planned=False,
752 name=False, price_unit=False, notes=False):
753 res = self.product_id_change(cr, uid, ids, pricelist, product, qty, uom,
754 partner_id, date_order=date_order, fiscal_position=fiscal_position, date_planned=date_planned,
755 name=name, price_unit=price_unit, notes=notes)
756 if 'product_uom' in res['value']:
757 if uom and (uom != res['value']['product_uom']) and res['value']['product_uom']:
758 seller_uom_name = self.pool.get('product.uom').read(cr, uid, [res['value']['product_uom']], ['name'])[0]['name']
759 res.update({'warning': {'title': _('Warning'), 'message': _('The selected supplier only sells this product by %s') % seller_uom_name }})
760 del res['value']['product_uom']
762 res['value']['price_unit'] = 0.0
765 def action_confirm(self, cr, uid, ids, context=None):
766 self.write(cr, uid, ids, {'state': 'confirmed'}, context=context)
769 purchase_order_line()
771 class procurement_order(osv.osv):
772 _inherit = 'procurement.order'
774 'purchase_id': fields.many2one('purchase.order', 'Purchase Order'),
777 def action_po_assign(self, cr, uid, ids, context=None):
778 """ This is action which call from workflow to assign purchase order to procurements
781 res = self.make_po(cr, uid, ids, context=context)
783 return len(res) and res[0] or 0 #TO CHECK: why workflow is generated error if return not integer value
785 def make_po(self, cr, uid, ids, context=None):
786 """ Make purchase order from procurement
787 @return: New created Purchase Orders procurement wise
792 company = self.pool.get('res.users').browse(cr, uid, uid, context=context).company_id
793 partner_obj = self.pool.get('res.partner')
794 uom_obj = self.pool.get('product.uom')
795 pricelist_obj = self.pool.get('product.pricelist')
796 prod_obj = self.pool.get('product.product')
797 acc_pos_obj = self.pool.get('account.fiscal.position')
798 po_obj = self.pool.get('purchase.order')
799 po_line_obj = self.pool.get('purchase.order.line')
800 for procurement in self.browse(cr, uid, ids, context=context):
801 res_id = procurement.move_id.id
802 partner = procurement.product_id.seller_id # Taken Main Supplier of Product of Procurement.
803 seller_qty = procurement.product_id.seller_qty
804 seller_delay = int(procurement.product_id.seller_delay)
805 partner_id = partner.id
806 address_id = partner_obj.address_get(cr, uid, [partner_id], ['delivery'])['delivery']
807 pricelist_id = partner.property_product_pricelist_purchase.id
808 fiscal_position = partner.property_account_position and partner.property_account_position.id or False
810 uom_id = procurement.product_id.uom_po_id.id
812 qty = uom_obj._compute_qty(cr, uid, procurement.product_uom.id, procurement.product_qty, uom_id)
814 qty = max(qty,seller_qty)
816 price = pricelist_obj.price_get(cr, uid, [pricelist_id], procurement.product_id.id, qty, partner_id, {'uom': uom_id})[pricelist_id]
818 newdate = datetime.strptime(procurement.date_planned, '%Y-%m-%d %H:%M:%S')
819 newdate = (newdate - relativedelta(days=company.po_lead)) - relativedelta(days=seller_delay)
821 res_onchange = po_line_obj.product_id_change(cr, uid, ids, pricelist_id, procurement.product_id.id, qty, uom_id,
822 partner_id, time.strftime('%Y-%m-%d'), fiscal_position=fiscal_position, date_planned=datetime.now() + relativedelta(days=seller_delay or 0.0),
823 name=procurement.name, price_unit=procurement.product_id.list_price, notes=procurement.product_id.description_purchase)
825 #Passing partner_id to context for purchase order line integrity of Line name
826 context.update({'lang': partner.lang, 'partner_id': partner_id})
828 product = prod_obj.browse(cr, uid, procurement.product_id.id, context=context)
831 'name': product.partner_ref,
832 'product_qty': res_onchange['value']['product_qty'],
833 'product_id': procurement.product_id.id,
834 'product_uom': res_onchange['value']['product_uom'],
835 'price_unit': res_onchange['value']['price_unit'],
836 'date_planned': newdate.strftime('%Y-%m-%d %H:%M:%S'),
837 'move_dest_id': res_id,
838 'notes': product.description_purchase,
841 taxes_ids = procurement.product_id.product_tmpl_id.supplier_taxes_id
842 taxes = acc_pos_obj.map_tax(cr, uid, partner.property_account_position, taxes_ids)
844 'taxes_id': [(6,0,taxes)]
846 purchase_id = po_obj.create(cr, uid, {
847 'origin': procurement.origin,
848 'partner_id': partner_id,
849 'partner_address_id': address_id,
850 'location_id': procurement.location_id.id,
851 'pricelist_id': pricelist_id,
852 'order_line': [(0,0,line)],
853 'company_id': procurement.company_id.id,
854 'fiscal_position': partner.property_account_position and partner.property_account_position.id or False
856 res[procurement.id] = purchase_id
857 self.write(cr, uid, [procurement.id], {'state': 'running', 'purchase_id': purchase_id})
862 class stock_invoice_onshipping(osv.osv_memory):
863 _inherit = "stock.invoice.onshipping"
865 def create_invoice(self, cr, uid, ids, context=None):
868 res = super(stock_invoice_onshipping,self).create_invoice(cr, uid, ids, context=context)
869 purchase_obj = self.pool.get('purchase.order')
870 picking_obj = self.pool.get('stock.picking')
872 pick = picking_obj.browse(cr, uid, pick_id, context=context)
874 purchase_obj.write(cr, uid, [pick.purchase_id.id], {
875 'invoice_ids': [(4, res[pick_id])]}, context=context)
878 stock_invoice_onshipping()
880 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: