#This file is part of Tryton. The COPYRIGHT file at the top level of this repository contains the full copyright notices and license terms. "Packing" from trytond.osv import fields, OSV from trytond.netsvc import LocalService import datetime from trytond.report import CompanyReport STATES = { 'readonly': "state in ('cancel', 'done')", } class PackingIn(OSV): "Supplier Packing" _name = 'stock.packing.in' _description = __doc__ _rec_name = 'code' effective_date =fields.DateTime('Effective Date', readonly=True) planned_date = fields.DateTime( 'Planned Date', states={'readonly': "state != 'draft'",}) reference = fields.Char( "Reference", size=None, select=1, states={'readonly': "state != 'draft'",}) supplier = fields.Many2One('relationship.party', 'Supplier', states={ 'readonly': "state != 'draft' or bool(incoming_moves)", }, on_change=['supplier'], required=True) contact_address = fields.Many2One('relationship.address', 'Contact Address', states={ 'readonly': "state != 'draft'", }, domain="[('party', '=', supplier)]") warehouse = fields.Many2One('stock.location', "Warehouse", required=True, domain=[('type', '=', 'warehouse')], states={ 'readonly': "state in ('cancel', 'done') or " \ "bool(incoming_moves)", }) incoming_moves = fields.Function('get_incoming_moves', type='one2many', relation='stock.move', string='Incoming Moves', fnct_inv='set_incoming_moves', add_remove="[" \ "('packing_in', '=', False),"\ "('from_location.type', '=', 'supplier'),"\ "('state', '=', 'draft'),"\ "('to_location_warehouse', '=', warehouse),"\ "]", states={ 'readonly': "state in ('received', 'done', 'cancel')", }, context="{'warehouse': warehouse, 'type': 'incoming'}") inventory_moves = fields.Function('get_inventory_moves', type='one2many', relation='stock.move', string='Inventory Moves', fnct_inv='set_inventory_moves', states={ 'readonly': "state in ('draft', 'done', 'cancel')", }, context="{'warehouse': warehouse, 'type':'inventory_in'}") moves = fields.One2Many('stock.move', 'packing_in', 'Moves', readonly=True) code = fields.Char("Code", size=None, select=1, readonly=True) state = fields.Selection([ ('draft', 'Draft'), ('done', 'Done'), ('cancel', 'Cancel'), ('received', 'Received'), ], 'State', readonly=True) def __init__(self): super(PackingIn, self).__init__() self._rpc_allowed += [ 'button_draft', ] self._order[0] = ('id', 'DESC') self._error_messages.update({ 'incoming_move_input_dest': 'Incoming Moves must ' \ 'have input location as destination location!', 'inventory_move_input_source': 'Inventory Moves must ' \ 'have input location as source location!', 'outgoing_move_output_source': 'Outgoing Moves must ' \ 'have output location as source location!', 'inventory_move_output_dest': 'Inventory Moves must ' \ 'have output location as destination location!', }) def default_state(self, cursor, user, context=None): return 'draft' def on_change_supplier(self, cursor, user, ids, values, context=None): if not values.get('supplier'): return {} party_obj = self.pool.get("relationship.party") address_id = party_obj.address_get(cursor, user, values['supplier'], context=context) return {'contact_address': address_id} def get_incoming_moves(self, cursor, user, ids, name, arg, context=None): res = {} for packing in self.browse(cursor, user, ids, context=context): res[packing.id] = [] for move in packing.moves: if move.to_location.id == packing.warehouse.input_location.id: res[packing.id].append(move.id) return res def set_incoming_moves(self, cursor, user, packing_id, name, value, arg, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) for act in value: if act[0] == 'create': if 'to_location' in act[1]: if act[1]['to_location'] != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'incoming_move_input_dest', context=context) elif act[0] == 'write': if 'to_location' in act[2]: if act[2]['to_location'] != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'incoming_move_input_dest', context=context) elif act[0] == 'add': move = move_obj.browse(cursor, user, act[1], context=context) if move.to_location.id != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'incoming_move_input_dest', context=context) elif act[0] == 'set': moves = move_obj.browse(cursor, user, act[1], context=context) for move in moves: if move.to_location.id != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'incoming_move_input_dest', context=context) self.write(cursor, user, packing_id, { 'moves': value, }, context=context) def get_inventory_moves(self, cursor, user, ids, name, arg, context=None): res = {} for packing in self.browse(cursor, user, ids, context=context): res[packing.id] = [] for move in packing.moves: if move.from_location.id == packing.warehouse.input_location.id: res[packing.id].append(move.id) return res def set_inventory_moves(self, cursor, user, packing_id, name, value, arg, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) for act in value: if act[0] == 'create': if 'from_location' in act[1]: if act[1]['from_location'] != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'inventory_move_input_source', context=context) elif act[0] == 'write': if 'from_location' in act[2]: if act[2]['from_location'] != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'inventory_move_input_source', context=context) elif act[0] == 'add': move = move_obj.browse(cursor, user, act[1], context=context) if move.from_location.id != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'inventory_move_input_source', context=context) elif act[0] == 'set': moves = move_obj.browse(cursor, user, act[1], context=context) for move in moves: if move.from_location.id != \ packing.warehouse.input_location.id: self.raise_user_error(cursor, 'inventory_move_input_source', context=context) self.write(cursor, user, packing_id, { 'moves': value, }, context=context) def set_state_done(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_done( cursor, user, [m.id for m in packing.inventory_moves], context) self.write(cursor, user, packing_id,{ 'state': 'done', 'effective_date': datetime.datetime.now(), }, context=context) def set_state_cancel(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_cancel( cursor, user, [m.id for m in packing.incoming_moves] +\ [m.id for m in packing.inventory_moves], context) self.write(cursor, user, packing_id, {'state':'cancel'}, context=context) def set_state_received(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_done(cursor, user, [m.id for m in packing.incoming_moves], context=context) self.write(cursor, user, packing_id, { 'state': 'received' }, context=context) def set_state_draft(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_draft(cursor, user, [m.id for m in packing.incoming_moves], context=context) move_obj.delete(cursor, user, [m.id for m in packing.inventory_moves], context=context) self.write(cursor, user, packing_id, { 'state': 'draft', }, context=context) def create(self, cursor, user, values, context=None): values = values.copy() values['code'] = self.pool.get('ir.sequence').get( cursor, user, 'stock.packing.in') return super(PackingIn, self).create( cursor, user, values, context=context) def _get_inventory_moves(self, cursor, user, incoming_move, context=None): res = {} if incoming_move.quantity <= 0.0: return None res['product'] = incoming_move.product.id res['uom'] = incoming_move.uom.id res['quantity'] = incoming_move.quantity res['from_location'] = incoming_move.to_location.id res['to_location'] = incoming_move.packing_in.warehouse.\ storage_location.id res['state'] = 'draft' res['company'] = incoming_move.company.id return res def create_inventory_moves(self, cursor, user, packing_id, context=None): packing = self.browse(cursor, user, packing_id, context=context) for incoming_move in packing.incoming_moves: vals = self._get_inventory_moves(cursor, user, incoming_move, context=context) if vals: self.write(cursor, user, packing.id, { 'inventory_moves': [('create', vals)] }, context=context) def button_draft(self, cursor, user, ids, context=None): workflow_service = LocalService('workflow') for packing in self.browse(cursor, user, ids, context=context): workflow_service.trg_create(user, self._name, packing.id, cursor) return True PackingIn() class PackingOut(OSV): "Customer Packing" _name = 'stock.packing.out' _description = __doc__ _rec_name = 'code' effective_date =fields.DateTime('Effective Date', readonly=True) planned_date = fields.DateTime('Planned Date', states={ 'readonly': "state != 'draft'", }) customer = fields.Many2One('relationship.party', 'Customer', required=True, states={ 'readonly': "state != 'draft'", }, on_change=['customer']) delivery_address = fields.Many2One('relationship.address', 'Delivery Address', required=True, states={ 'readonly': "state != 'draft'", }, domain="[('party', '=', customer)]") reference = fields.Char("Reference", size=None, select=1, states={ 'readonly': "state != 'draft'", }) warehouse = fields.Many2One('stock.location', "Warehouse", required=True, states={ 'readonly': "state != 'draft'", }, domain="[('type', '=', 'warehouse')]") customer_location = fields.Many2One('stock.location', "Customer Location", required=True, states={ 'readonly': "state != 'draft'", }, domain="[('type', '=', 'customer')]") outgoing_moves = fields.Function('get_outgoing_moves', type='one2many', relation='stock.move', string='Outgoing Moves', fnct_inv='set_outgoing_moves', states={ 'readonly':"state != 'packed'", }, context="{'warehouse': warehouse, 'type':'outgoing',}") inventory_moves = fields.Function('get_inventory_moves', type='one2many', relation='stock.move', string='Inventory Moves', fnct_inv='set_inventory_moves', states={ 'readonly':"state in ('packed', 'done')", }, context="{'warehouse': warehouse, 'type':'inventory_out',}") moves = fields.One2Many('stock.move', 'packing_out', 'Moves', readonly=True) code = fields.Char("Code", size=None, select=1, readonly=True) state = fields.Selection([ ('draft', 'Draft'), ('done', 'Done'), ('cancel', 'Cancel'), ('assigned', 'Assigned'), ('packed', 'Packed'), ('waiting', 'Waiting'), ], 'State', readonly=True) def __init__(self): super(PackingOut, self).__init__() self._rpc_allowed += [ 'button_draft', ] self._order[0] = ('id', 'DESC') def default_state(self, cursor, user, context=None): return 'draft' def on_change_customer(self, cursor, user, ids, values, context=None): if not values.get('customer'): return {} party_obj = self.pool.get("relationship.party") address_id = party_obj.address_get(cursor, user, values['customer'], type='delivery', context=context) party = party_obj.browse(cursor, user, values['customer'], context=context) return { 'delivery_address': address_id, 'customer_location': party.customer_location.id, } def get_outgoing_moves(self, cursor, user, ids, name, arg, context=None): res = {} for packing in self.browse(cursor, user, ids, context=context): res[packing.id] = [] for move in packing.moves: if move.from_location.id == \ packing.warehouse.output_location.id: res[packing.id].append(move.id) return res def set_outgoing_moves(self, cursor, user, packing_id, name, value, arg, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) for act in value: if act[0] == 'create': if 'from_location' in act[1]: if act[1]['from_location'] != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'outgoing_move_output_source', context=context) elif act[0] == 'write': if 'from_location' in act[2]: if act[2]['from_location'] != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'outgoing_move_output_source', context=context) elif act[0] == 'add': move = move_obj.browse(cursor, user, act[1], context=context) if move.from_location.id != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'outgoing_move_output_source', context=context) elif act[0] == 'set': moves = move_obj.browse(cursor, user, act[1], context=context) for move in moves: if move.from_location.id != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'outgoing_move_output_source', context=context) self.write(cursor, user, packing_id, { 'moves': value, }, context=context) def get_inventory_moves(self, cursor, user, ids, name, arg, context=None): res = {} for packing in self.browse(cursor, user, ids, context=context): res[packing.id] = [] for move in packing.moves: if move.to_location.id == \ packing.warehouse.output_location.id: res[packing.id].append(move.id) return res def set_inventory_moves(self, cursor, user, packing_id, name, value, arg, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) for act in value: if act[0] == 'create': if 'to_location' in act[1]: if act[1]['to_location'] != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'inventory_move_output_dest', context=context) elif act[0] == 'write': if 'to_location' in act[2]: if act[2]['to_location'] != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'inventory_move_output_dest', context=context) elif act[0] == 'add': move = move_obj.browse(cursor, user, act[1], context=context) if move.to_location.id != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'inventory_move_output_dest', context=context) elif act[0] == 'set': moves = move_obj.browse(cursor, user, act[1], context=context) for move in moves: if move.to_location.id != \ packing.warehouse.output_location.id: self.raise_user_error(cursor, 'inventory_move_output_dest', context=context) self.write(cursor, user, packing_id, { 'moves': value, }, context=context) def set_state_assigned(self, cursor, user, packing_id, context=None): self.write(cursor, user, packing_id, {'state':'assigned'}, context=context) def set_state_draft(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) self.write( cursor, user, packing_id, {'state':'draft'}, context=context) move_obj.set_state_draft( cursor, user, [m.id for m in packing.inventory_moves + packing.outgoing_moves], context=context) def set_state_done(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_done(cursor, user, [m.id for m in packing.outgoing_moves if m.state == 'draft'], context=context) self.write(cursor, user, packing_id, { 'state':'done', 'effective_date': datetime.datetime.now(), }, context=context) def set_state_packed(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') uom_obj = self.pool.get('product.uom') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_done( cursor, user, [m.id for m in packing.inventory_moves], context=context) self.write(cursor, user, packing_id, {'state':'packed'}, context=context) # Sum all outgoing quantities outgoing_qty = {} for move in packing.outgoing_moves: if move.state == 'cancel': continue quantity = uom_obj.compute_qty( cursor, user, move.uom, move.quantity, move.product.default_uom, context=context) outgoing_qty.setdefault(move.product.id, 0.0) outgoing_qty[move.product.id] += quantity for move in packing.inventory_moves: if move.state == 'cancel': continue qty_default_uom = uom_obj.compute_qty( cursor, user, move.uom, move.quantity, move.product.default_uom, context=context) # Check if the outgoing move doesn't exist already if outgoing_qty.get(move.product.id): # If it exist, decrease the sum if qty_default_uom <= outgoing_qty[move.product.id]: outgoing_qty[move.product.id] -= qty_default_uom continue # Else create the complement else: out_quantity = qty_default_uom - outgoing_qty[move.product.id] out_quantity = uom_obj.compute_qty( cursor, user, move.product.default_uom, out_quantity, move.uom, context=context) outgoing_qty[move.product.id] = 0.0 else: out_quantity = move.quantity unit_price = uom_obj.compute_price( cursor, user, move.product.default_uom, move.product.list_price, move.uom, context=context) move_obj.create(cursor, user, { 'from_location': move.to_location.id, 'to_location': packing.customer_location.id, 'product': move.product.id, 'uom': move.uom.id, 'quantity': out_quantity, 'packing_out': packing.id, 'state': 'draft', 'company': move.company.id, 'currency': move.company.currency.id, 'unit_price': unit_price, }, context=context) #Re-read the packing and remove exceeding quantities packing = self.browse(cursor, user, packing_id, context=context) for move in packing.outgoing_moves: if move.state == 'cancel': continue if outgoing_qty.get(move.product.id, 0.0) > 0.0: exc_qty = uom_obj.compute_qty( cursor, user, move.product.default_uom, outgoing_qty[move.product.id], move.uom, context=context) move_obj.write(cursor, user, move.id,{ 'quantity': max(0.0, move.quantity-exc_qty), }, context=context) removed_qty = uom_obj.compute_qty( cursor, user, move.uom, min(exc_qty, move.quantity), move.product.default_uom, context=context) outgoing_qty[move.product.id] -= removed_qty def set_state_cancel(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') packing = self.browse(cursor, user, packing_id, context=context) move_obj.set_state_cancel( cursor, user,[m.id for m in packing.outgoing_moves] +\ [m.id for m in packing.inventory_moves], context=context) self.write(cursor, user, packing_id, {'state':'cancel'}, context=context) def set_state_waiting(self, cursor, user, packing_id, context=None): move_obj = self.pool.get('stock.move') uom_obj = self.pool.get('product.uom') packing = self.browse(cursor, user, packing_id, context=context) self.write( cursor, user, packing_id, {'state':'waiting'}, context=context) # Sum all inventory quantities inventory_qty = {} for move in packing.inventory_moves: if move.state == 'cancel': continue quantity = uom_obj.compute_qty( cursor, user, move.uom, move.quantity, move.product.default_uom, context=context) inventory_qty.setdefault(move.product.id, 0.0) inventory_qty[move.product.id] += quantity for move in packing.outgoing_moves: if move.state in ('cancel', 'done'): continue qty_default_uom = uom_obj.compute_qty( cursor, user, move.uom, move.quantity, move.product.default_uom, context=context) # Check if the inventory move doesn't exist already if inventory_qty.get(move.product.id): # If it exist, decrease the sum if qty_default_uom <= inventory_qty[move.product.id]: inventory_qty[move.product.id] -= qty_default_uom continue # Else create the complement else: inv_quantity = qty_default_uom - inventory_qty[move.product.id] inv_quantity = uom_obj.compute_qty( cursor, user, move.product.default_uom, inv_quantity, move.uom, context=context) inventory_qty[move.product.id] = 0.0 else: inv_quantity = move.quantity move_obj.create(cursor, user, { 'from_location': move.packing_out.warehouse.storage_location.id, 'to_location': move.from_location.id, 'product': move.product.id, 'uom': move.uom.id, 'quantity': inv_quantity, 'packing_out': packing.id, 'state': 'draft', 'company': move.company.id, }, context=context) def create(self, cursor, user, values, context=None): values['code'] = self.pool.get('ir.sequence').get( cursor, user, 'stock.packing.out') return super(PackingOut, self).create(cursor, user, values, context=context) def pick_product(self, cursor, user, needed_qty, location_quantities, move=None, location_index=None, context=None): """ Pick the product across the location. Naive (fast) implementation. Product is a browse record and location_index is the index of the browse record of all the locations. """ to_pick = [] for location, available_qty in location_quantities.iteritems(): if needed_qty <= available_qty: to_pick.append((location, needed_qty)) return to_pick else: to_pick.append((location, available_qty)) needed_qty -= available_qty # Force assignation for consumables: if move.product.type == "consumable": to_pick.append((move.from_location.id, needed_qty)) return to_pick return None def _location_amount(self, cursor, user, target_uom, qty_uom, uom_index, context=None): """ Take a raw list of quantities and uom and convert it to the target uom. """ uom_obj = self.pool.get('product.uom') res = 0 for uom, qty in qty_uom: res += uom_obj.compute_qty( cursor, user, uom_index[uom], qty, uom_index[target_uom], context=context) return res def assign_try(self, cursor, user, packing_id, context=None): location_obj = self.pool.get('stock.location') move_obj = self.pool.get('stock.move') product_obj = self.pool.get('product.product') uom_obj = self.pool.get('product.uom') if context is None: context = {} cursor.execute('LOCK TABLE stock_move') packing = self.browse(cursor, user, packing_id, context=context) parent_to_locations = {} location_ids = [] inventory_moves = [] location_index = {} # Fetch child_of for each location for move in packing.inventory_moves: if move.state != 'draft': continue inventory_moves.append(move) location_index[move.from_location.id] = move.from_location if move.from_location.id in parent_to_locations: continue child_ids = location_obj.search(cursor, user, [ ('parent', 'child_of', [move.from_location.id]), ], context=context) parent_to_locations[move.from_location.id] = child_ids location_ids.append(move.from_location.id) pbl = product_obj.products_by_location(cursor, user, location_ids=location_ids, product_ids=[move.product.id for move in inventory_moves], context=context) success = True for move in inventory_moves: locations = parent_to_locations[move.from_location.id] location_qties = {} for location in locations: if (location, move.product.id) in pbl: location_qties[location] = uom_obj.compute_qty( cursor, user, move.product.default_uom, pbl[(location, move.product.id)], move.uom, context=context) to_pick = self.pick_product( cursor, user, move.quantity, location_qties, move=move, location_index=location_index, context=context) if to_pick is None: success = False continue first = True for location, qty in to_pick: to_location = packing.warehouse.output_location.id values = { 'from_location': location, 'to_location': to_location, 'product': move.product.id, 'uom': move.uom.id, 'quantity': qty, 'packing_out': packing.id, 'state': 'assigned', 'company': move.company.id, } if first: move_obj.write(cursor, user, move.id, values, context=context) first = False else: move_obj.create(cursor, user, values, context=context) qty_defaut_uom = uom_obj.compute_qty( cursor, user, move.uom, qty, move.product.default_uom, context=context) pbl[(location, move.product.id)] = \ pbl.get((location, move.product.id), 0.0) + qty_defaut_uom pbl[(packing.warehouse.output_location.id, move.product.id)]= \ pbl.get((to_location, move.product.id), 0.0) - qty_defaut_uom return success def assign_force(self, cursor, user, packing_id, context=None): packing = self.browse(cursor, user, packing_id, context=context) move_obj = self.pool.get('stock.move') move_obj.write( cursor, user, [m.id for m in packing.inventory_moves], {'state':'assigned'}) return True def button_draft(self, cursor, user, ids, context=None): workflow_service = LocalService('workflow') for packing in self.browse(cursor, user, ids, context=context): workflow_service.trg_create(user, self._name, packing.id, cursor) PackingOut() class Address(OSV): _name = 'relationship.address' delivery = fields.Boolean('Delivery') Address() class PackingOutReport(CompanyReport): _name = 'stock.packing.out' def parse(self, cursor, user, report, objects, datas, context): if context is None: context = {} context = context.copy() context['product_name'] = lambda product_id, language: \ self.product_name(cursor, user, product_id, language, context) return super(PackingOutReport, self).parse(cursor, user, report, objects, datas, context) def product_name(self, cursor, user, product_id, language, context): product_obj = self.pool.get('product.product') ctx = context.copy() ctx['language'] = language return product_obj.name_get(cursor, user, [product_id], context=ctx)[0][1] PackingOutReport()