Files
tryton/inventory.py
T
2008-10-08 12:19:58 +02:00

271 lines
9.9 KiB
Python

#This file is part of Tryton. The COPYRIGHT file at the top level
#of this repository contains the full copyright notices and license terms.
'Inventory'
from trytond.osv import fields, OSV
from trytond.wizard import Wizard
STATES = {
'readonly': "state != 'open'",
}
class Inventory(OSV):
'Stock Inventory'
_name = 'stock.inventory'
_description = __doc__
_rec_name = 'location'
location = fields.Many2One(
'stock.location', 'Location', required=True,
domain="[('type', '=', 'storage')]", states={
'readonly': "state != 'open' or bool(lines)",
})
date = fields.Date('Date', states=STATES)
lost_found = fields.Many2One(
'stock.location', 'Lost and Found', required=True,
domain="[('type', '=', 'lost_found')]", states=STATES)
lines = fields.One2Many(
'stock.inventory.line', 'inventory', 'Inventory Lines', states=STATES)
moves = fields.Many2Many(
'stock.move', 'inventory_move_rel', 'inventory', 'move',
'Generated moves')
company = fields.Many2One(
'company.company', 'Company', required=True, states={
'readonly': "state != 'open' or bool(lines)",
})
state = fields.Selection(
[('open','Open'),
('done','Done'),
('cancel','Cancel')],
'State', readonly=True, select=1)
def __init__(self):
super(Inventory, self).__init__()
self._order.insert(0, ('date', 'DESC'))
self._rpc_allowed += [
'set_state_cancel',
'set_state_open',
'set_state_done',
]
def default_state(self, cursor, user, context=None):
return 'open'
def default_date(self, cursor, user, context=None):
date_obj = self.pool.get('ir.date')
return date_obj.today(cursor, user, context=context)
def default_company(self, cursor, user, context=None):
if context.get('company'):
return context.get('company')
user_obj = self.pool.get('res.user')
user = user_obj.browse(cursor, user, user, context=context)
return user.company.id
def set_state_cancel(self, cursor, user, ids, context=None):
self.write(cursor, user, ids, {
'state': 'cancel',
}, context=context)
def set_state_open(self, cursor, user, ids, context=None):
self.write(cursor, user, ids, {
'state': 'open',
}, context=context)
def set_state_done(self, cursor, user, ids, context=None):
self.write(cursor, user, ids, {
'state': 'done',
}, context=context)
def _cancel(self, cursor, user, ids, context=None):
move_obj = self.pool.get("stock.move")
inventories = self.browse(cursor, user, ids, context=context)
move_ids = \
[move.id for inventory in inventories for move in inventory.moves]
return move_obj.set_state_cancel(cursor, user, move_ids, context=context)
def _done(self, cursor, user, ids, context=None):
product_obj = self.pool.get('product.product')
move_obj = self.pool.get('stock.move')
date_obj = self.pool.get('ir.date')
inventories = self.browse(cursor, user, ids, context=context)
location_ids = []
inv_by_loc = {}
for inventory in inventories:
if inventory.state != 'open':
continue
moves = []
for line in inventory.lines:
delta_qty = line.expected_quantity - line.quantity
if delta_qty == 0.0:
continue
from_location = inventory.location.id
to_location = inventory.lost_found.id
if delta_qty < 0:
(from_location, to_location, delta_qty) = \
(to_location, from_location, -delta_qty)
move_id = move_obj.create(cursor, user, {
'from_location': from_location,
'to_location': to_location,
'quantity': delta_qty,
'product': line.product.id,
'uom': line.uom.id,
'company': inventory.company.id,
'state': 'done',
}, context=context)
moves.append(move_id)
self.write(cursor, user, ids, {
'date': date_obj.today(cursor, user, context=context),
'moves': [('add', x) for x in moves],
}, context=context)
def write(self, cursor, user, ids, vals, context=None):
if 'state' in vals:
if vals['state'] == 'done':
self._done(cursor, user, ids, context=context)
elif vals['state'] == 'cancel':
self._cancel(cursor, user, ids, context=context)
return super(Inventory, self).write(cursor, user, ids, vals,
context=context)
Inventory()
class InventoryLine(OSV):
'Stock Inventory Line'
_name = 'stock.inventory.line'
_description = __doc__
_rec_name = 'product'
product = fields.Many2One('product.product', 'Product', required=True,
domain=[('type', '=', 'stockable')])
uom = fields.Function('get_uom', type='many2one', relation='product.uom',
string='UOM', on_change_with=['product'])
expected_quantity = fields.Float('Expected Quantity', digits=(12, 6),
readonly=True)
quantity = fields.Float('Quantity', digits=(12, 6))
inventory = fields.Many2One('stock.inventory', 'Inventory')
def __init__(self):
super(InventoryLine, self).__init__()
self._sql_constraints += [
('check_line_qty_pos',
'CHECK(quantity >= 0.0)', 'Move quantity must be positive'),
('inventory_product_uniq', 'UNIQUE(inventory, product)',
'Product must be unique by inventory!'),
]
def on_change_with_uom(self, cursor, user, ids, vals, context=None):
product_obj = self.pool.get('product.product')
uom_obj = self.pool.get('product.uom')
if vals.get('product'):
product = product_obj.browse(cursor, user, vals['product'],
context=context)
return uom_obj.name_get(cursor, user, product.default_uom.id,
context=context)[0]
return False
def get_uom(self, cursor, user, ids, name, arg, context=None):
uom_obj = self.pool.get('product.uom')
res = {}
for line in self.browse(cursor, user, ids, context=context):
res[line.id] = line.product.default_uom.id
uom2name = {}
for uom_id, name in uom_obj.name_get(cursor, user, res.values(),
context=context):
uom2name[uom_id] = (uom_id, name)
for line_id in res:
res[line_id] = uom2name[res[line_id]]
return res
InventoryLine()
class CompleteInventory(Wizard):
'Complete Inventory '
_name = 'stock.inventory.complete'
states = {
'init': {
'result': {
'type': 'action',
'action': '_complete',
'state': 'end',
},
},
}
def _complete(self, cursor, user, data, context=None):
line_obj = self.pool.get('stock.inventory.line')
inventory_obj = self.pool.get('stock.inventory')
product_obj = self.pool.get('product.product')
uom_obj = self.pool.get('product.uom')
inventories = inventory_obj.browse(cursor, user, data['ids'],
context=context)
context = context and context.copy() or {}
for inventory in inventories:
# Compute product quantities
if inventory.date:
context['stock_date_end'] = inventory.date
pbl = product_obj.products_by_location(
cursor, user, [inventory.location.id],
context=context)
else:
pbl = product_obj.products_by_location(
cursor, user, [inventory.location.id], context=context)
# Index some data
product2uom = {}
for product in product_obj.browse(
cursor, user, [line[1] for line in pbl], context=context):
product2uom[product.id] = product.default_uom.id
product_qty = {}
for (location, product), quantity in pbl.iteritems():
product_qty[product] = (quantity, product2uom[product])
# Update existing lines
for line in inventory.lines:
if line.product.id in product_qty:
quantity, uom_id = product_qty[line.product.id]
del product_qty[line.product.id]
# if nothing as changed, continue
if line.quantity == line.expected_quantity == quantity \
and line.uom.id == uom_id:
continue
values = {'expected_quantity': quantity,
'uom': uom_id}
# update also quantity field if not edited
if line.quantity == line.expected_quantity:
values['quantity'] = max(quantity, 0.0)
else:
values = {'expected_quantity': 0.0,}
if line.quantity == line.expected_quantity:
values['quantity'] = 0
line_obj.write(
cursor, user, line.id, values, context=context)
# Create lines if needed
for product in product_qty:
quantity, uom_id = product_qty[product]
values = {
'product': product,
'expected_quantity': quantity,
'quantity': max(quantity, 0.0),
'uom': uom_id,
'inventory': inventory.id,
}
line_obj.create(
cursor, user, values, context=context)
return {}
CompleteInventory()