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 ##############################################################################
22 from openerp.osv import fields, osv
23 from openerp.tools.translate import _
24 from openerp.tools.safe_eval import safe_eval as eval
25 import openerp.addons.decimal_precision as dp
26 from openerp.tools.float_utils import float_round
28 class product_product(osv.osv):
29 _inherit = "product.product"
31 def _stock_move_count(self, cr, uid, ids, field_name, arg, context=None):
32 res = dict([(id, {'reception_count': 0, 'delivery_count': 0}) for id in ids])
33 move_pool=self.pool.get('stock.move')
34 moves = move_pool.read_group(cr, uid, [
35 ('product_id', 'in', ids),
36 ('location_id.usage', '!=', 'internal'),
37 ('location_dest_id.usage', '=', 'internal'),
38 ('state','in',('confirmed','assigned','pending'))
39 ], ['product_id'], ['product_id'])
41 product_id = move['product_id'][0]
42 res[product_id]['reception_count'] = move['product_id_count']
43 moves = move_pool.read_group(cr, uid, [
44 ('product_id', 'in', ids),
45 ('location_id.usage', '=', 'internal'),
46 ('location_dest_id.usage', '!=', 'internal'),
47 ('state','in',('confirmed','assigned','pending'))
48 ], ['product_id'], ['product_id'])
50 product_id = move['product_id'][0]
51 res[product_id]['delivery_count'] = move['product_id_count']
54 def view_header_get(self, cr, user, view_id, view_type, context=None):
57 res = super(product_product, self).view_header_get(cr, user, view_id, view_type, context)
59 if (context.get('active_id', False)) and (context.get('active_model') == 'stock.location'):
60 return _('Products: ')+self.pool.get('stock.location').browse(cr, user, context['active_id'], context).name
63 def _get_domain_locations(self, cr, uid, ids, context=None):
65 Parses the context and returns a list of location_ids based on it.
66 It will return all stock locations when no parameters are given
67 Possible parameters are shop, warehouse, location, force_company, compute_child
69 context = context or {}
71 location_obj = self.pool.get('stock.location')
72 warehouse_obj = self.pool.get('stock.warehouse')
75 if context.get('location', False):
76 if type(context['location']) == type(1):
77 location_ids = [context['location']]
78 elif type(context['location']) in (type(''), type(u'')):
79 domain = [('complete_name','ilike',context['location'])]
80 if context.get('force_company', False):
81 domain += [('company_id', '=', context['force_company'])]
82 location_ids = location_obj.search(cr, uid, domain, context=context)
84 location_ids = context['location']
86 if context.get('warehouse', False):
87 wids = [context['warehouse']]
89 wids = warehouse_obj.search(cr, uid, [], context=context)
91 for w in warehouse_obj.browse(cr, uid, wids, context=context):
92 location_ids.append(w.view_location_id.id)
94 operator = context.get('compute_child', True) and 'child_of' or 'in'
95 domain = context.get('force_company', False) and ['&', ('company_id', '=', context['force_company'])] or []
97 domain + [('location_id', operator, location_ids)],
98 domain + ['&', ('location_dest_id', operator, location_ids), '!', ('location_id', operator, location_ids)],
99 domain + ['&', ('location_id', operator, location_ids), '!', ('location_dest_id', operator, location_ids)]
102 def _get_domain_dates(self, cr, uid, ids, context):
103 from_date = context.get('from_date', False)
104 to_date = context.get('to_date', False)
107 domain.append(('date', '>=', from_date))
109 domain.append(('date', '<=', to_date))
112 def _product_available(self, cr, uid, ids, field_names=None, arg=False, context=None):
113 context = context or {}
114 field_names = field_names or []
116 domain_products = [('product_id', 'in', ids)]
117 domain_quant, domain_move_in, domain_move_out = self._get_domain_locations(cr, uid, ids, context=context)
118 domain_move_in += self._get_domain_dates(cr, uid, ids, context=context) + [('state', 'not in', ('done', 'cancel', 'draft'))] + domain_products
119 domain_move_out += self._get_domain_dates(cr, uid, ids, context=context) + [('state', 'not in', ('done', 'cancel', 'draft'))] + domain_products
120 domain_quant += domain_products
121 if context.get('lot_id') or context.get('owner_id') or context.get('package_id'):
122 if context.get('lot_id'):
123 domain_quant.append(('lot_id', '=', context['lot_id']))
124 if context.get('owner_id'):
125 domain_quant.append(('owner_id', '=', context['owner_id']))
126 if context.get('package_id'):
127 domain_quant.append(('package_id', '=', context['package_id']))
131 moves_in = self.pool.get('stock.move').read_group(cr, uid, domain_move_in, ['product_id', 'product_qty'], ['product_id'], context=context)
132 moves_out = self.pool.get('stock.move').read_group(cr, uid, domain_move_out, ['product_id', 'product_qty'], ['product_id'], context=context)
134 quants = self.pool.get('stock.quant').read_group(cr, uid, domain_quant, ['product_id', 'qty'], ['product_id'], context=context)
135 quants = dict(map(lambda x: (x['product_id'][0], x['qty']), quants))
137 moves_in = dict(map(lambda x: (x['product_id'][0], x['product_qty']), moves_in))
138 moves_out = dict(map(lambda x: (x['product_id'][0], x['product_qty']), moves_out))
140 for product in self.browse(cr, uid, ids, context=context):
142 qty_available = float_round(quants.get(id, 0.0), precision_rounding=product.uom_id.rounding)
143 incoming_qty = float_round(moves_in.get(id, 0.0), precision_rounding=product.uom_id.rounding)
144 outgoing_qty = float_round(moves_out.get(id, 0.0), precision_rounding=product.uom_id.rounding)
145 virtual_available = float_round(quants.get(id, 0.0) + moves_in.get(id, 0.0) - moves_out.get(id, 0.0), precision_rounding=product.uom_id.rounding)
147 'qty_available': qty_available,
148 'incoming_qty': incoming_qty,
149 'outgoing_qty': outgoing_qty,
150 'virtual_available': virtual_available,
154 def _search_product_quantity(self, cr, uid, obj, name, domain, context):
156 for field, operator, value in domain:
157 #to prevent sql injections
158 assert field in ('qty_available', 'virtual_available', 'incoming_qty', 'outgoing_qty'), 'Invalid domain left operand'
159 assert operator in ('<', '>', '=', '!=', '<=', '>='), 'Invalid domain operator'
160 assert isinstance(value, (float, int)), 'Invalid domain right operand'
165 product_ids = self.search(cr, uid, [], context=context)
168 #TODO: use a query instead of this browse record which is probably making the too much requests, but don't forget
169 #the context that can be set with a location, an owner...
170 for element in self.browse(cr, uid, product_ids, context=context):
171 if eval(str(element[field]) + operator + str(value)):
172 ids.append(element.id)
173 res.append(('id', 'in', ids))
176 def _product_available_text(self, cr, uid, ids, field_names=None, arg=False, context=None):
178 for product in self.browse(cr, uid, ids, context=context):
179 res[product.id] = str(product.qty_available) + _(" On Hand")
183 'reception_count': fields.function(_stock_move_count, string="Receipt", type='integer', multi='pickings'),
184 'delivery_count': fields.function(_stock_move_count, string="Delivery", type='integer', multi='pickings'),
185 'qty_available': fields.function(_product_available, multi='qty_available',
186 type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
187 string='Quantity On Hand',
188 fnct_search=_search_product_quantity,
189 help="Current quantity of products.\n"
190 "In a context with a single Stock Location, this includes "
191 "goods stored at this Location, or any of its children.\n"
192 "In a context with a single Warehouse, this includes "
193 "goods stored in the Stock Location of this Warehouse, or any "
195 "stored in the Stock Location of the Warehouse of this Shop, "
196 "or any of its children.\n"
197 "Otherwise, this includes goods stored in any Stock Location "
198 "with 'internal' type."),
199 'qty_available2': fields.related('qty_available', type="float", relation="product.product", string="On Hand"),
200 'virtual_available': fields.function(_product_available, multi='qty_available',
201 type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
202 string='Forecast Quantity',
203 fnct_search=_search_product_quantity,
204 help="Forecast quantity (computed as Quantity On Hand "
205 "- Outgoing + Incoming)\n"
206 "In a context with a single Stock Location, this includes "
207 "goods stored in this location, or any of its children.\n"
208 "In a context with a single Warehouse, this includes "
209 "goods stored in the Stock Location of this Warehouse, or any "
211 "Otherwise, this includes goods stored in any Stock Location "
212 "with 'internal' type."),
213 'incoming_qty': fields.function(_product_available, multi='qty_available',
214 type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
216 fnct_search=_search_product_quantity,
217 help="Quantity of products that are planned to arrive.\n"
218 "In a context with a single Stock Location, this includes "
219 "goods arriving to this Location, or any of its children.\n"
220 "In a context with a single Warehouse, this includes "
221 "goods arriving to the Stock Location of this Warehouse, or "
222 "any of its children.\n"
223 "Otherwise, this includes goods arriving to any Stock "
224 "Location with 'internal' type."),
225 'outgoing_qty': fields.function(_product_available, multi='qty_available',
226 type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
228 fnct_search=_search_product_quantity,
229 help="Quantity of products that are planned to leave.\n"
230 "In a context with a single Stock Location, this includes "
231 "goods leaving this Location, or any of its children.\n"
232 "In a context with a single Warehouse, this includes "
233 "goods leaving the Stock Location of this Warehouse, or "
234 "any of its children.\n"
235 "Otherwise, this includes goods leaving any Stock "
236 "Location with 'internal' type."),
237 'location_id': fields.dummy(string='Location', relation='stock.location', type='many2one'),
238 'warehouse_id': fields.dummy(string='Warehouse', relation='stock.warehouse', type='many2one'),
239 'orderpoint_ids': fields.one2many('stock.warehouse.orderpoint', 'product_id', 'Minimum Stock Rules'),
242 def fields_view_get(self, cr, uid, view_id=None, view_type='form', context=None, toolbar=False, submenu=False):
243 res = super(product_product,self).fields_view_get(cr, uid, view_id, view_type, context, toolbar=toolbar, submenu=submenu)
246 if ('location' in context) and context['location']:
247 location_info = self.pool.get('stock.location').browse(cr, uid, context['location'])
248 fields=res.get('fields',{})
250 if location_info.usage == 'supplier':
251 if fields.get('virtual_available'):
252 res['fields']['virtual_available']['string'] = _('Future Receipts')
253 if fields.get('qty_available'):
254 res['fields']['qty_available']['string'] = _('Received Qty')
256 if location_info.usage == 'internal':
257 if fields.get('virtual_available'):
258 res['fields']['virtual_available']['string'] = _('Future Stock')
260 if location_info.usage == 'customer':
261 if fields.get('virtual_available'):
262 res['fields']['virtual_available']['string'] = _('Future Deliveries')
263 if fields.get('qty_available'):
264 res['fields']['qty_available']['string'] = _('Delivered Qty')
266 if location_info.usage == 'inventory':
267 if fields.get('virtual_available'):
268 res['fields']['virtual_available']['string'] = _('Future P&L')
269 if fields.get('qty_available'):
270 res['fields']['qty_available']['string'] = _('P&L Qty')
272 if location_info.usage == 'procurement':
273 if fields.get('virtual_available'):
274 res['fields']['virtual_available']['string'] = _('Future Qty')
275 if fields.get('qty_available'):
276 res['fields']['qty_available']['string'] = _('Unplanned Qty')
278 if location_info.usage == 'production':
279 if fields.get('virtual_available'):
280 res['fields']['virtual_available']['string'] = _('Future Productions')
281 if fields.get('qty_available'):
282 res['fields']['qty_available']['string'] = _('Produced Qty')
286 def action_view_routes(self, cr, uid, ids, context=None):
287 template_obj = self.pool.get("product.template")
288 templ_ids = list(set([x.product_tmpl_id.id for x in self.browse(cr, uid, ids, context=context)]))
289 return template_obj.action_view_routes(cr, uid, templ_ids, context=context)
291 class product_template(osv.osv):
292 _name = 'product.template'
293 _inherit = 'product.template'
295 def _product_available(self, cr, uid, ids, name, arg, context=None):
296 res = dict.fromkeys(ids, 0)
297 for product in self.browse(cr, uid, ids, context=context):
299 # "reception_count": sum([p.reception_count for p in product.product_variant_ids]),
300 # "delivery_count": sum([p.delivery_count for p in product.product_variant_ids]),
301 "qty_available": sum([p.qty_available for p in product.product_variant_ids]),
302 "virtual_available": sum([p.virtual_available for p in product.product_variant_ids]),
303 "incoming_qty": sum([p.incoming_qty for p in product.product_variant_ids]),
304 "outgoing_qty": sum([p.outgoing_qty for p in product.product_variant_ids]),
308 def _search_product_quantity(self, cr, uid, obj, name, domain, context):
309 prod = self.pool.get("product.product")
311 for field, operator, value in domain:
312 #to prevent sql injections
313 assert field in ('qty_available', 'virtual_available', 'incoming_qty', 'outgoing_qty'), 'Invalid domain left operand'
314 assert operator in ('<', '>', '=', '!=', '<=', '>='), 'Invalid domain operator'
315 assert isinstance(value, (float, int)), 'Invalid domain right operand'
320 product_ids = prod.search(cr, uid, [], context=context)
323 #TODO: use a query instead of this browse record which is probably making the too much requests, but don't forget
324 #the context that can be set with a location, an owner...
325 for element in prod.browse(cr, uid, product_ids, context=context):
326 if eval(str(element[field]) + operator + str(value)):
327 ids.append(element.id)
328 res.append(('product_variant_ids', 'in', ids))
332 def _product_available_text(self, cr, uid, ids, field_names=None, arg=False, context=None):
334 for product in self.browse(cr, uid, ids, context=context):
335 res[product.id] = str(product.qty_available) + _(" On Hand")
341 'type': fields.selection([('product', 'Stockable Product'), ('consu', 'Consumable'), ('service', 'Service')], 'Product Type', required=True, help="Consumable: Will not imply stock management for this product. \nStockable product: Will imply stock management for this product."),
342 'qty_available2': fields.related('qty_available', type="float", relation="product.template", string="On Hand"),
343 'property_stock_procurement': fields.property(
345 relation='stock.location',
346 string="Procurement Location",
347 domain=[('usage','like','procurement')],
348 help="This stock location will be used, instead of the default one, as the source location for stock moves generated by procurements."),
349 'property_stock_production': fields.property(
351 relation='stock.location',
352 string="Production Location",
353 domain=[('usage','like','production')],
354 help="This stock location will be used, instead of the default one, as the source location for stock moves generated by manufacturing orders."),
355 'property_stock_inventory': fields.property(
357 relation='stock.location',
358 string="Inventory Location",
359 domain=[('usage','like','inventory')],
360 help="This stock location will be used, instead of the default one, as the source location for stock moves generated when you do an inventory."),
361 'sale_delay': fields.float('Customer Lead Time', help="The average delay in days between the confirmation of the customer order and the delivery of the finished products. It's the time you promise to your customers."),
362 'loc_rack': fields.char('Rack', size=16),
363 'loc_row': fields.char('Row', size=16),
364 'loc_case': fields.char('Case', size=16),
365 'track_incoming': fields.boolean('Track Incoming Lots', help="Forces to specify a Serial Number for all moves containing this product and coming from a Supplier Location"),
366 'track_outgoing': fields.boolean('Track Outgoing Lots', help="Forces to specify a Serial Number for all moves containing this product and going to a Customer Location"),
367 'track_all': fields.boolean('Full Lots Traceability', help="Forces to specify a Serial Number on each and every operation related to this product"),
369 # sum of product variant qty
370 # 'reception_count': fields.function(_product_available, multi='qty_available',
371 # fnct_search=_search_product_quantity, type='float', string='Quantity On Hand'),
372 # 'delivery_count': fields.function(_product_available, multi='qty_available',
373 # fnct_search=_search_product_quantity, type='float', string='Quantity On Hand'),
374 'qty_available': fields.function(_product_available, multi='qty_available',
375 fnct_search=_search_product_quantity, type='float', string='Quantity On Hand'),
376 'virtual_available': fields.function(_product_available, multi='qty_available',
377 fnct_search=_search_product_quantity, type='float', string='Quantity Available'),
378 'incoming_qty': fields.function(_product_available, multi='qty_available',
379 fnct_search=_search_product_quantity, type='float', string='Incoming'),
380 'outgoing_qty': fields.function(_product_available, multi='qty_available',
381 fnct_search=_search_product_quantity, type='float', string='Outgoing'),
383 'route_ids': fields.many2many('stock.location.route', 'stock_route_product', 'product_id', 'route_id', 'Routes', domain="[('product_selectable', '=', True)]",
384 help="Depending on the modules installed, this will allow you to define the route of the product: whether it will be bought, manufactured, MTO/MTS,..."),
391 def action_view_routes(self, cr, uid, ids, context=None):
392 route_obj = self.pool.get("stock.location.route")
393 act_obj = self.pool.get('ir.actions.act_window')
394 mod_obj = self.pool.get('ir.model.data')
395 product_route_ids = set()
396 for product in self.browse(cr, uid, ids, context=context):
397 product_route_ids |= set([r.id for r in product.route_ids])
398 product_route_ids |= set([r.id for r in product.categ_id.total_route_ids])
399 route_ids = route_obj.search(cr, uid, ['|', ('id', 'in', list(product_route_ids)), ('warehouse_selectable', '=', True)], context=context)
400 result = mod_obj.xmlid_to_res_id(cr, uid, 'stock.action_routes_form', raise_if_not_found=True)
401 result = act_obj.read(cr, uid, [result], context=context)[0]
402 result['domain'] = "[('id','in',[" + ','.join(map(str, route_ids)) + "])]"
406 def _get_products(self, cr, uid, ids, context=None):
408 for prodtmpl in self.browse(cr, uid, ids, context=None):
409 products += [x.id for x in prodtmpl.product_variant_ids]
412 def _get_act_window_dict(self, cr, uid, name, context=None):
413 mod_obj = self.pool.get('ir.model.data')
414 act_obj = self.pool.get('ir.actions.act_window')
415 result = mod_obj.xmlid_to_res_id(cr, uid, name, raise_if_not_found=True)
416 result = act_obj.read(cr, uid, [result], context=context)[0]
419 def action_open_quants(self, cr, uid, ids, context=None):
420 products = self._get_products(cr, uid, ids, context=context)
421 result = self._get_act_window_dict(cr, uid, 'stock.product_open_quants', context=context)
422 result['domain'] = "[('product_id','in',[" + ','.join(map(str, products)) + "])]"
423 result['context'] = "{'search_default_locationgroup': 1, 'search_default_internal_loc': 1}"
426 def action_view_orderpoints(self, cr, uid, ids, context=None):
427 products = self._get_products(cr, uid, ids, context=context)
428 result = self._get_act_window_dict(cr, uid, 'stock.product_open_orderpoint', context=context)
429 if len(ids) == 1 and len(products) == 1:
430 result['context'] = "{'default_product_id': " + str(products[0]) + ", 'search_default_product_id': " + str(products[0]) + "}"
432 result['domain'] = "[('product_id','in',[" + ','.join(map(str, products)) + "])]"
433 result['context'] = "{}"
437 def action_view_stock_moves(self, cr, uid, ids, context=None):
438 products = self._get_products(cr, uid, ids, context=context)
439 result = self._get_act_window_dict(cr, uid, 'stock.act_product_stock_move_open', context=context)
440 if len(ids) == 1 and len(products) == 1:
441 ctx = "{'tree_view_ref':'stock.view_move_tree', \
442 'default_product_id': %s, 'search_default_product_id': %s}" \
443 % (products[0], products[0])
444 result['context'] = ctx
446 result['domain'] = "[('product_id','in',[" + ','.join(map(str, products)) + "])]"
447 result['context'] = "{'tree_view_ref':'stock.view_move_tree'}"
450 def write(self, cr, uid, ids, vals, context=None):
451 if 'uom_po_id' in vals:
452 product_ids = self.pool.get('product.product').search(cr, uid, [('product_tmpl_id', 'in', ids)], context=context)
453 if self.pool.get('stock.move').search(cr, uid, [('product_id', 'in', product_ids)], context=context, limit=1):
454 raise osv.except_osv(_('Error!'), _("You can not change the unit of measure of a product that has already been used in a stock move. If you need to change the unit of measure, you may deactivate this product.") % ())
455 return super(product_template, self).write(cr, uid, ids, vals, context=context)
458 class product_removal_strategy(osv.osv):
459 _name = 'product.removal'
460 _description = 'Removal Strategy'
463 'name': fields.char('Name', required=True),
464 'method': fields.char("Method", required=True, help="FIFO, LIFO..."),
468 class product_putaway_strategy(osv.osv):
469 _name = 'product.putaway'
470 _description = 'Put Away Strategy'
472 def _get_putaway_options(self, cr, uid, context=None):
473 return [('fixed', 'Fixed Location')]
476 'name': fields.char('Name', required=True),
477 'method': fields.selection(_get_putaway_options, "Method", required=True),
478 'fixed_location_ids': fields.one2many('stock.fixed.putaway.strat', 'putaway_id', 'Fixed Locations Per Product Category', help="When the method is fixed, this location will be used to store the products", copy=True),
485 def putaway_apply(self, cr, uid, putaway_strat, product, context=None):
486 if putaway_strat.method == 'fixed':
487 for strat in putaway_strat.fixed_location_ids:
488 categ = product.categ_id
490 if strat.category_id.id == categ.id:
491 return strat.fixed_location_id.id
492 categ = categ.parent_id
495 class fixed_putaway_strat(osv.osv):
496 _name = 'stock.fixed.putaway.strat'
499 'putaway_id': fields.many2one('product.putaway', 'Put Away Method', required=True),
500 'category_id': fields.many2one('product.category', 'Product Category', required=True),
501 'fixed_location_id': fields.many2one('stock.location', 'Location', required=True),
502 'sequence': fields.integer('Priority', help="Give to the more specialized category, a higher priority to have them in top of the list."),
506 class product_category(osv.osv):
507 _inherit = 'product.category'
509 def calculate_total_routes(self, cr, uid, ids, name, args, context=None):
511 for categ in self.browse(cr, uid, ids, context=context):
513 routes = [x.id for x in categ.route_ids]
514 while categ2.parent_id:
515 categ2 = categ2.parent_id
516 routes += [x.id for x in categ2.route_ids]
517 res[categ.id] = routes
521 'route_ids': fields.many2many('stock.location.route', 'stock_location_route_categ', 'categ_id', 'route_id', 'Routes', domain="[('product_categ_selectable', '=', True)]"),
522 'removal_strategy_id': fields.many2one('product.removal', 'Force Removal Strategy', help="Set a specific removal strategy that will be used regardless of the source location for this product category"),
523 'total_route_ids': fields.function(calculate_total_routes, relation='stock.location.route', type='many2many', string='Total routes', readonly=True),
527 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: