| Line 391... |
Line 391... |
| 391 |
time = datetime.datetime.now()
|
391 |
time = datetime.datetime.now()
|
| 392 |
warehouse.lastCheckedOn = time
|
392 |
warehouse.lastCheckedOn = time
|
| 393 |
warehouse.vendorString = timestamp
|
393 |
warehouse.vendorString = timestamp
|
| 394 |
vendor = warehouse.vendor
|
394 |
vendor = warehouse.vendor
|
| 395 |
session.commit()
|
395 |
session.commit()
|
| - |
|
396 |
items = []
|
| 396 |
for item_key, quantity in availability.iteritems():
|
397 |
for item_key, quantity in availability.iteritems():
|
| 397 |
try:
|
398 |
try:
|
| 398 |
vendor_item_mapping = VendorItemMapping.query.filter_by(vendor=vendor, item_key=item_key).one();
|
399 |
vendor_item_mapping = VendorItemMapping.query.filter_by(vendor=vendor, item_key=item_key).one();
|
| 399 |
item = vendor_item_mapping.item
|
400 |
item = vendor_item_mapping.item
|
| - |
|
401 |
items.append(item)
|
| 400 |
except:
|
402 |
except:
|
| 401 |
print 'Skipping update for ' + item_key + ' quantity ' + str(quantity) + ' warehouse id: ' + str(warehouse_id)
|
403 |
print 'Skipping update for ' + item_key + ' quantity ' + str(quantity) + ' warehouse id: ' + str(warehouse_id)
|
| 402 |
__send_mail_for_missing_key(item_key, quantity, warehouse_id)
|
404 |
__send_mail_for_missing_key(item_key, quantity, warehouse_id)
|
| 403 |
continue
|
405 |
continue
|
| 404 |
try:
|
406 |
try:
|
| Line 422... |
Line 424... |
| 422 |
__send_alert_for_negative_availability(item, current_inventory_snapshot.availability, warehouse)
|
424 |
__send_alert_for_negative_availability(item, current_inventory_snapshot.availability, warehouse)
|
| 423 |
except:
|
425 |
except:
|
| 424 |
raise InventoryServiceException(108, "Some unforeseen error while updating inventory")
|
426 |
raise InventoryServiceException(108, "Some unforeseen error while updating inventory")
|
| 425 |
session.commit()
|
427 |
session.commit()
|
| 426 |
#**Update item availability cache**#
|
428 |
#**Update item availability cache**#
|
| - |
|
429 |
for item in items:
|
| 427 |
__update_item_availability_cache(item.id)
|
430 |
__update_item_availability_cache(item.id)
|
| 428 |
check_risky_item(item)
|
431 |
check_risky_item(item)
|
| 429 |
|
432 |
|
| 430 |
def __send_alert_for_negative_reserved(item, reserved, warehouse):
|
433 |
def __send_alert_for_negative_reserved(item, reserved, warehouse):
|
| 431 |
itemName = " ".join([str(item.id), str(item.brand), str(item.model_name), str(item.model_number), str(item.color)])
|
434 |
itemName = " ".join([str(item.id), str(item.brand), str(item.model_name), str(item.model_number), str(item.color)])
|
| 432 |
EmailAttachmentSender.mail('cnc.center@shop2020.in', '5h0p2o2o', 'mandeep.dhir@shop2020.in', 'Negative reserved: ' + str(reserved) + ' for Item Id: ' + itemName + ' warehouse id: ' + str(warehouse.id), None)
|
435 |
EmailAttachmentSender.mail('cnc.center@shop2020.in', '5h0p2o2o', 'mandeep.dhir@shop2020.in', 'Negative reserved: ' + str(reserved) + ' for Item Id: ' + itemName + ' warehouse id: ' + str(warehouse.id), None)
|
| 433 |
|
436 |
|