addons/stock/product.py

   1 # -*- coding: utf-8 -*-
   2 ##############################################################################
   3 #
   4 #    OpenERP, Open Source Management Solution
   5 #    Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
   6 #
   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.
  11 #
  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.
  16 #
  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/>.
  19 #
  20 ##############################################################################
  21
  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
  27 class product_product(osv.osv):
  28     _inherit = "product.product"
  29
  30     def _stock_move_count(self, cr, uid, ids, field_name, arg, context=None):
  31         res = dict([(id, {'reception_count': 0, 'delivery_count': 0}) for id in ids])
  32         move_pool=self.pool.get('stock.move')
  33         moves = move_pool.read_group(cr, uid, [
  34             ('product_id', 'in', ids),
  35             ('location_id.usage', '!=', 'internal'),
  36             ('location_dest_id.usage', '=', 'internal'),
  37             ('state','in',('confirmed','assigned','pending'))
  38         ], ['product_id'], ['product_id'])
  39         for move in moves:
  40             product_id = move['product_id'][0]
  41             res[product_id]['reception_count'] = move['product_id_count']
  42         moves = move_pool.read_group(cr, uid, [
  43             ('product_id', 'in', ids),
  44             ('location_id.usage', '=', 'internal'),
  45             ('location_dest_id.usage', '!=', 'internal'),
  46             ('state','in',('confirmed','assigned','pending'))
  47         ], ['product_id'], ['product_id'])
  48         for move in moves:
  49             product_id = move['product_id'][0]
  50             res[product_id]['delivery_count'] = move['product_id_count']
  51         return res
  52
  53     def view_header_get(self, cr, user, view_id, view_type, context=None):
  54         if context is None:
  55             context = {}
  56         res = super(product_product, self).view_header_get(cr, user, view_id, view_type, context)
  57         if res: return res
  58         if (context.get('active_id', False)) and (context.get('active_model') == 'stock.location'):
  59             return _('Products: ')+self.pool.get('stock.location').browse(cr, user, context['active_id'], context).name
  60         return res
  61
  62     def _get_domain_locations(self, cr, uid, ids, context=None):
  63         '''
  64         Parses the context and returns a list of location_ids based on it.
  65         It will return all stock locations when no parameters are given
  66         Possible parameters are shop, warehouse, location, force_company, compute_child
  67         '''
  68         context = context or {}
  69
  70         location_obj = self.pool.get('stock.location')
  71         warehouse_obj = self.pool.get('stock.warehouse')
  72
  73         location_ids = []
  74         if context.get('location', False):
  75             if type(context['location']) == type(1):
  76                 location_ids = [context['location']]
  77             elif type(context['location']) in (type(''), type(u'')):
  78                 domain = [('complete_name','ilike',context['location'])]
  79                 if context.get('force_company', False):
  80                     domain += [('company_id', '=', context['force_company'])]
  81                 location_ids = location_obj.search(cr, uid, domain, context=context)
  82             else:
  83                 location_ids = context['location']
  84         else:
  85             if context.get('warehouse', False):
  86                 wids = [context['warehouse']]
  87             else:
  88                 wids = warehouse_obj.search(cr, uid, [], context=context)
  89
  90             for w in warehouse_obj.browse(cr, uid, wids, context=context):
  91                 location_ids.append(w.lot_stock_id.id)
  92
  93         operator = context.get('compute_child',True) and 'child_of' or 'in'
  94         domain = context.get('force_company', False) and ['&', ('company_id', '=', context['force_company'])] or []
  95         domain += [('product_id', 'in', ids)]
  96         return (
  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)]
 100         )
 101
 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)
 105         domain = []
 106         if from_date:
 107             domain.append(('date', '>=', from_date))
 108         if to_date:
 109             domain.append(('date', '<=', to_date))
 110         return domain
 111
 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 []
 115
 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'))] + domain_products
 119         domain_move_out += self._get_domain_dates(cr, uid, ids, context=context) + [('state', 'not in', ('done', 'cancel'))] + 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']))
 128             moves_in = []
 129             moves_out = []
 130         else:
 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)
 133
 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))
 136
 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))
 139
 140         res = {}
 141         for id in ids:
 142             res[id] = {
 143                 'qty_available': quants.get(id, 0.0),
 144                 'incoming_qty': moves_in.get(id, 0.0),
 145                 'outgoing_qty': moves_out.get(id, 0.0),
 146                 'virtual_available': quants.get(id, 0.0) + moves_in.get(id, 0.0) - moves_out.get(id, 0.0),
 147             }
 148
 149         return res
 150
 151     def _search_product_quantity(self, cr, uid, obj, name, domain, context):
 152         res = []
 153         for field, operator, value in domain:
 154             #to prevent sql injections
 155             assert field in ('qty_available', 'virtual_available', 'incoming_qty', 'outgoing_qty'), 'Invalid domain left operand'
 156             assert operator in ('<', '>', '=', '<=', '>='), 'Invalid domain operator'
 157             assert isinstance(value, (float, int)), 'Invalid domain right operand'
 158
 159             if operator == '=':
 160                 operator = '=='
 161
 162             product_ids = self.search(cr, uid, [], context=context)
 163             ids = []
 164             if product_ids:
 165                 #TODO: use a query instead of this browse record which is probably making the too much requests, but don't forget
 166                 #the context that can be set with a location, an owner...
 167                 for element in self.browse(cr, uid, product_ids, context=context):
 168                     if eval(str(element[field]) + operator + str(value)):
 169                         ids.append(element.id)
 170             res.append(('id', 'in', ids))
 171         return res
 172
 173     _columns = {
 174         'reception_count': fields.function(_stock_move_count, string="Reception", type='integer', multi='pickings'),
 175         'delivery_count': fields.function(_stock_move_count, string="Delivery", type='integer', multi='pickings'),
 176         'qty_available': fields.function(_product_available, multi='qty_available',
 177             type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
 178             string='Quantity On Hand',
 179             fnct_search=_search_product_quantity,
 180             help="Current quantity of products.\n"
 181                  "In a context with a single Stock Location, this includes "
 182                  "goods stored at this Location, or any of its children.\n"
 183                  "In a context with a single Warehouse, this includes "
 184                  "goods stored in the Stock Location of this Warehouse, or any "
 185                  "of its children.\n"
 186                  "stored in the Stock Location of the Warehouse of this Shop, "
 187                  "or any of its children.\n"
 188                  "Otherwise, this includes goods stored in any Stock Location "
 189                  "with 'internal' type."),
 190         'virtual_available': fields.function(_product_available, multi='qty_available',
 191             type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
 192             string='Forecast Quantity',
 193             fnct_search=_search_product_quantity,
 194             help="Forecast quantity (computed as Quantity On Hand "
 195                  "- Outgoing + Incoming)\n"
 196                  "In a context with a single Stock Location, this includes "
 197                  "goods stored in this location, or any of its children.\n"
 198                  "In a context with a single Warehouse, this includes "
 199                  "goods stored in the Stock Location of this Warehouse, or any "
 200                  "of its children.\n"
 201                  "Otherwise, this includes goods stored in any Stock Location "
 202                  "with 'internal' type."),
 203         'incoming_qty': fields.function(_product_available, multi='qty_available',
 204             type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
 205             string='Incoming',
 206             fnct_search=_search_product_quantity,
 207             help="Quantity of products that are planned to arrive.\n"
 208                  "In a context with a single Stock Location, this includes "
 209                  "goods arriving to this Location, or any of its children.\n"
 210                  "In a context with a single Warehouse, this includes "
 211                  "goods arriving to the Stock Location of this Warehouse, or "
 212                  "any of its children.\n"
 213                  "Otherwise, this includes goods arriving to any Stock "
 214                  "Location with 'internal' type."),
 215         'outgoing_qty': fields.function(_product_available, multi='qty_available',
 216             type='float', digits_compute=dp.get_precision('Product Unit of Measure'),
 217             string='Outgoing',
 218             fnct_search=_search_product_quantity,
 219             help="Quantity of products that are planned to leave.\n"
 220                  "In a context with a single Stock Location, this includes "
 221                  "goods leaving this Location, or any of its children.\n"
 222                  "In a context with a single Warehouse, this includes "
 223                  "goods leaving the Stock Location of this Warehouse, or "
 224                  "any of its children.\n"
 225                  "Otherwise, this includes goods leaving any Stock "
 226                  "Location with 'internal' type."),
 227         '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"),
 228         '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"),
 229         'track_all': fields.boolean('Full Lots Traceability', help="Forces to specify a Serial Number on each and every operation related to this product"),
 230         'location_id': fields.dummy(string='Location', relation='stock.location', type='many2one'),
 231         'warehouse_id': fields.dummy(string='Warehouse', relation='stock.warehouse', type='many2one'),
 232         'orderpoint_ids': fields.one2many('stock.warehouse.orderpoint', 'product_id', 'Minimum Stock Rules'),
 233         'route_ids': fields.many2many('stock.location.route', 'stock_route_product', 'product_id', 'route_id', 'Routes', domain="[('product_selectable', '=', True)]",
 234                                     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,..."),
 235     }
 236
 237     def fields_view_get(self, cr, uid, view_id=None, view_type='form', context=None, toolbar=False, submenu=False):
 238         res = super(product_product,self).fields_view_get(cr, uid, view_id, view_type, context, toolbar=toolbar, submenu=submenu)
 239         if context is None:
 240             context = {}
 241         if ('location' in context) and context['location']:
 242             location_info = self.pool.get('stock.location').browse(cr, uid, context['location'])
 243             fields=res.get('fields',{})
 244             if fields:
 245                 if location_info.usage == 'supplier':
 246                     if fields.get('virtual_available'):
 247                         res['fields']['virtual_available']['string'] = _('Future Receptions')
 248                     if fields.get('qty_available'):
 249                         res['fields']['qty_available']['string'] = _('Received Qty')
 250
 251                 if location_info.usage == 'internal':
 252                     if fields.get('virtual_available'):
 253                         res['fields']['virtual_available']['string'] = _('Future Stock')
 254
 255                 if location_info.usage == 'customer':
 256                     if fields.get('virtual_available'):
 257                         res['fields']['virtual_available']['string'] = _('Future Deliveries')
 258                     if fields.get('qty_available'):
 259                         res['fields']['qty_available']['string'] = _('Delivered Qty')
 260
 261                 if location_info.usage == 'inventory':
 262                     if fields.get('virtual_available'):
 263                         res['fields']['virtual_available']['string'] = _('Future P&L')
 264                     if fields.get('qty_available'):
 265                         res['fields']['qty_available']['string'] = _('P&L Qty')
 266
 267                 if location_info.usage == 'procurement':
 268                     if fields.get('virtual_available'):
 269                         res['fields']['virtual_available']['string'] = _('Future Qty')
 270                     if fields.get('qty_available'):
 271                         res['fields']['qty_available']['string'] = _('Unplanned Qty')
 272
 273                 if location_info.usage == 'production':
 274                     if fields.get('virtual_available'):
 275                         res['fields']['virtual_available']['string'] = _('Future Productions')
 276                     if fields.get('qty_available'):
 277                         res['fields']['qty_available']['string'] = _('Produced Qty')
 278         return res
 279
 280     def action_view_routes(self, cr, uid, ids, context=None):
 281         route_obj = self.pool.get("stock.location.route")
 282         act_obj = self.pool.get('ir.actions.act_window')
 283         mod_obj = self.pool.get('ir.model.data')
 284         product_route_ids = set()
 285         for product in self.browse(cr, uid, ids, context=context):
 286             product_route_ids |= set([r.id for r in product.route_ids])
 287             product_route_ids |= set([r.id for r in product.categ_id.total_route_ids])
 288         route_ids = route_obj.search(cr, uid, ['|', ('id', 'in', list(product_route_ids)), ('warehouse_selectable', '=', True)], context=context)
 289         result = mod_obj.get_object_reference(cr, uid, 'stock', 'action_routes_form')
 290         id = result and result[1] or False
 291         result = act_obj.read(cr, uid, [id], context=context)[0]
 292         result['domain'] = "[('id','in',[" + ','.join(map(str, route_ids)) + "])]"
 293         return result
 294
 295 class product_template(osv.osv):
 296     _name = 'product.template'
 297     _inherit = 'product.template'
 298     _columns = {
 299         '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."),
 300         'property_stock_procurement': fields.property(
 301             type='many2one',
 302             relation='stock.location',
 303             string="Procurement Location",
 304             domain=[('usage','like','procurement')],
 305             help="This stock location will be used, instead of the default one, as the source location for stock moves generated by procurements."),
 306         'property_stock_production': fields.property(
 307             type='many2one',
 308             relation='stock.location',
 309             string="Production Location",
 310             domain=[('usage','like','production')],
 311             help="This stock location will be used, instead of the default one, as the source location for stock moves generated by manufacturing orders."),
 312         'property_stock_inventory': fields.property(
 313             type='many2one',
 314             relation='stock.location',
 315             string="Inventory Location",
 316             domain=[('usage','like','inventory')],
 317             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."),
 318         '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."),
 319         'loc_rack': fields.char('Rack', size=16),
 320         'loc_row': fields.char('Row', size=16),
 321         'loc_case': fields.char('Case', size=16),
 322     }
 323
 324     _defaults = {
 325         'sale_delay': 7,
 326     }
 327
 328
 329 class product_removal_strategy(osv.osv):
 330     _name = 'product.removal'
 331     _description = 'Removal Strategy'
 332     _order = 'sequence'
 333     _columns = {
 334         'product_categ_id': fields.many2one('product.category', 'Category', required=True),
 335         'sequence': fields.integer('Sequence'),
 336         'method': fields.selection([('fifo', 'FIFO'), ('lifo', 'LIFO')], "Method", required = True),
 337         'location_id': fields.many2one('stock.location', 'Locations', required=True),
 338     }
 339
 340
 341 class product_putaway_strategy(osv.osv):
 342     _name = 'product.putaway'
 343     _description = 'Put Away Strategy'
 344     _columns = {
 345         'product_categ_id':fields.many2one('product.category', 'Product Category', required=True),
 346         'location_id': fields.many2one('stock.location','Parent Location', help="Parent Destination Location from which a child bin location needs to be chosen", required=True), #domain=[('type', '=', 'parent')],
 347         'method': fields.selection([('fixed', 'Fixed Location')], "Method", required = True),
 348         'location_spec_id': fields.many2one('stock.location','Specific Location', help="When the location is specific, it will be put over there"), #domain=[('type', '=', 'parent')],
 349     }
 350
 351
 352 class product_category(osv.osv):
 353     _inherit = 'product.category'
 354
 355     def calculate_total_routes(self, cr, uid, ids, name, args, context=None):
 356         res = {}
 357         route_obj = self.pool.get("stock.location.route")
 358         for categ in self.browse(cr, uid, ids, context=context):
 359             categ2 = categ
 360             routes = [x.id for x in categ.route_ids]
 361             while categ2.parent_id:
 362                 categ2 = categ2.parent_id
 363                 routes += [x.id for x in categ2.route_ids]
 364             res[categ.id] = routes
 365         return res
 366
 367     _columns = {
 368         'route_ids': fields.many2many('stock.location.route', 'stock_location_route_categ', 'categ_id', 'route_id', 'Routes', domain="[('product_categ_selectable', '=', True)]"),
 369         'removal_strategy_ids': fields.one2many('product.removal', 'product_categ_id', 'Removal Strategies'),
 370         'putaway_strategy_ids': fields.one2many('product.putaway', 'product_categ_id', 'Put Away Strategies'),
 371         'total_route_ids': fields.function(calculate_total_routes, relation='stock.location.route', type='many2many', string='Total routes', readonly=True),
 372     }
 373
 374
 375 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: