| Line 310... |
Line 310... |
| 310 |
|
310 |
|
| 311 |
def update_inventory_history(warehouse_id, timestamp, availability):
|
311 |
def update_inventory_history(warehouse_id, timestamp, availability):
|
| 312 |
warehouse = get_Warehouse(warehouse_id)
|
312 |
warehouse = get_Warehouse(warehouse_id)
|
| 313 |
if not warehouse:
|
313 |
if not warehouse:
|
| 314 |
raise InventoryServiceException(107, "Warehouse? Where?")
|
314 |
raise InventoryServiceException(107, "Warehouse? Where?")
|
| - |
|
315 |
#FIXME Choose vendor.
|
| 315 |
vendor = warehouse.vendor
|
316 |
#vendor = warehouse.vendor
|
| - |
|
317 |
vendor = get_Vendor(1)
|
| 316 |
time = datetime.datetime.now()
|
318 |
time = datetime.datetime.now()
|
| 317 |
for item_key, quantity in availability.iteritems():
|
319 |
for item_key, quantity in availability.iteritems():
|
| 318 |
try:
|
320 |
try:
|
| 319 |
vendor_item_mapping = VendorItemMapping.query.filter_by(vendor=vendor, item_key=item_key).one();
|
321 |
vendor_item_mapping = VendorItemMapping.query.filter_by(vendor=vendor, item_key=item_key).one();
|
| 320 |
item = vendor_item_mapping.item
|
322 |
item = vendor_item_mapping.item
|
| Line 1267... |
Line 1269... |
| 1267 |
|
1269 |
|
| 1268 |
def get_pending_orders_inventory(vendor_id=1):
|
1270 |
def get_pending_orders_inventory(vendor_id=1):
|
| 1269 |
"""
|
1271 |
"""
|
| 1270 |
Returns a list of inventory stock for items for which there are pending orders.
|
1272 |
Returns a list of inventory stock for items for which there are pending orders.
|
| 1271 |
"""
|
1273 |
"""
|
| - |
|
1274 |
|
| 1272 |
warehouse_ids = [warehouse.id for warehouse in Warehouse.query.filter_by(vendor_id=vendor_id).all()]
|
1275 |
#warehouse_ids = [warehouse.id for warehouse in Warehouse.query.filter_by(vendor_id=vendor_id).all()]
|
| - |
|
1276 |
warehouse_ids = [1,2,3,4,5]
|
| 1273 |
pending_items_inventory = []
|
1277 |
pending_items_inventory = []
|
| 1274 |
if warehouse_ids:
|
1278 |
if warehouse_ids:
|
| 1275 |
pending_items_inventory = session.query(CurrentInventorySnapshot.item_id, func.sum(CurrentInventorySnapshot.availibility), func.sum(CurrentInventorySnapshot.reserved)).filter(CurrentInventorySnapshot.warehouse_id.in_(warehouse_ids)).group_by(CurrentInventorySnapshot.item_id).having(func.sum(CurrentInventorySnapshot.reserved) > 0).all()
|
1279 |
pending_items_inventory = session.query(CurrentInventorySnapshot.item_id, func.sum(CurrentInventorySnapshot.availibility), func.sum(CurrentInventorySnapshot.reserved)).filter(CurrentInventorySnapshot.warehouse_id.in_(warehouse_ids)).group_by(CurrentInventorySnapshot.item_id).having(func.sum(CurrentInventorySnapshot.reserved) > 0).all()
|
| 1276 |
return pending_items_inventory
|
1280 |
return pending_items_inventory
|
| 1277 |
|
1281 |
|