| Line 140... |
Line 140... |
| 140 |
t_item_shipping_info = ItemShippingInfo()
|
140 |
t_item_shipping_info = ItemShippingInfo()
|
| 141 |
try:
|
141 |
try:
|
| 142 |
item = get_item(item_id)
|
142 |
item = get_item(item_id)
|
| 143 |
t_item_shipping_info.isRisky = item.risky
|
143 |
t_item_shipping_info.isRisky = item.risky
|
| 144 |
client = InventoryClient().get_client()
|
144 |
client = InventoryClient().get_client()
|
| 145 |
itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId)
|
145 |
itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId, -1)
|
| 146 |
availability = itemInfo[4]
|
146 |
availability = itemInfo[4]
|
| 147 |
if item.risky and item.status == status.ACTIVE:
|
147 |
if item.risky and item.status == status.ACTIVE:
|
| 148 |
if availability <= 0:
|
148 |
if availability <= 0:
|
| 149 |
add_status_change_log(item, status.PAUSED_BY_RISK)
|
149 |
add_status_change_log(item, status.PAUSED_BY_RISK)
|
| 150 |
item.status = status.PAUSED_BY_RISK
|
150 |
item.status = status.PAUSED_BY_RISK
|
| Line 593... |
Line 593... |
| 593 |
|
593 |
|
| 594 |
#Risky item is validated wheter in stock or not
|
594 |
#Risky item is validated wheter in stock or not
|
| 595 |
def check_risky_item(item_id):
|
595 |
def check_risky_item(item_id):
|
| 596 |
item = get_item(item_id)
|
596 |
item = get_item(item_id)
|
| 597 |
client = InventoryClient().get_client()
|
597 |
client = InventoryClient().get_client()
|
| 598 |
itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId)
|
598 |
itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId, -1)
|
| 599 |
availability = itemInfo[4]
|
599 |
availability = itemInfo[4]
|
| 600 |
if availability <= 0:
|
600 |
if availability <= 0:
|
| 601 |
if item.status == status.ACTIVE:
|
601 |
if item.status == status.ACTIVE:
|
| 602 |
change_item_status(item.id, status.PAUSED_BY_RISK)
|
602 |
change_item_status(item.id, status.PAUSED_BY_RISK)
|
| 603 |
__send_mail_for_oos_item(item)
|
603 |
__send_mail_for_oos_item(item)
|
| Line 1153... |
Line 1153... |
| 1153 |
item = product_notification.item
|
1153 |
item = product_notification.item
|
| 1154 |
if itemcountmap.has_key(item.id):
|
1154 |
if itemcountmap.has_key(item.id):
|
| 1155 |
itemcountmap[item.id] = itemcountmap.get(item.id) + 1
|
1155 |
itemcountmap[item.id] = itemcountmap.get(item.id) + 1
|
| 1156 |
else:
|
1156 |
else:
|
| 1157 |
client = InventoryClient().get_client()
|
1157 |
client = InventoryClient().get_client()
|
| 1158 |
availability = client.getItemAvailabilityAtLocation(item.id, sourceId)[4]
|
1158 |
availability = client.getItemAvailabilityAtLocation(item.id, sourceId, -1)[4]
|
| 1159 |
#print "Item status " + str(item.status) + " item.risky " + str(item.risky) + " availability = " + str(availability)
|
1159 |
#print "Item status " + str(item.status) + " item.risky " + str(item.risky) + " availability = " + str(availability)
|
| 1160 |
if item.status == status.ACTIVE and (not item.risky or availability > 0):
|
1160 |
if item.status == status.ACTIVE and (not item.risky or availability > 0):
|
| 1161 |
#print "item status map has new entry " + str(item.id)
|
1161 |
#print "item status map has new entry " + str(item.id)
|
| 1162 |
itemstatusmap[item.id] = True
|
1162 |
itemstatusmap[item.id] = True
|
| 1163 |
else:
|
1163 |
else:
|
| Line 3576... |
Line 3576... |
| 3576 |
|
3576 |
|
| 3577 |
return itemWarrantyMap
|
3577 |
return itemWarrantyMap
|
| 3578 |
|
3578 |
|
| 3579 |
def get_all_fofo_deals(itemIds, tagIds):
|
3579 |
def get_all_fofo_deals(itemIds, tagIds):
|
| 3580 |
returnMap = {}
|
3580 |
returnMap = {}
|
| 3581 |
|
3581 |
print "itemIds", "itemIds"
|
| 3582 |
query = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK, status.PARTIALLY_ACTIVE])).filter(Tag_Listing.active==True)
|
3582 |
query = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK, status.PARTIALLY_ACTIVE])).filter(Tag_Listing.active==True)
|
| 3583 |
if itemIds:
|
3583 |
if itemIds:
|
| 3584 |
query = query.filter(Item.id.in_(itemIds))
|
3584 |
query = query.filter(Item.id.in_(itemIds))
|
| 3585 |
else:
|
3585 |
else:
|
| 3586 |
return returnMap
|
3586 |
return returnMap
|