| Line 374... |
Line 374... |
| 374 |
time.sleep(1)
|
374 |
time.sleep(1)
|
| 375 |
req = urllib2.Request(url,headers=headers)
|
375 |
req = urllib2.Request(url,headers=headers)
|
| 376 |
response = urllib2.urlopen(req)
|
376 |
response = urllib2.urlopen(req)
|
| 377 |
json_input = response.read()
|
377 |
json_input = response.read()
|
| 378 |
vendorInfo = json.loads(json_input)
|
378 |
vendorInfo = json.loads(json_input)
|
| 379 |
print vendorInfo
|
- |
|
| 380 |
rank ,otherInventory ,ourInventory, ourOfferPrice, ourSp, iterator, secondLowestSellerSp, secondLowestSellerInventory, \
|
379 |
rank ,otherInventory ,ourInventory, ourOfferPrice, ourSp, iterator, secondLowestSellerSp, secondLowestSellerInventory, \
|
| 381 |
lowestOfferPrice, secondLowestSellerOfferPrice = (0,)*10
|
380 |
lowestOfferPrice, secondLowestSellerOfferPrice = (0,)*10
|
| 382 |
lowestSellerName , lowestSellerCode, secondLowestSellerName, secondLowestSellerCode=('',)*4
|
381 |
lowestSellerName , lowestSellerCode, secondLowestSellerName, secondLowestSellerCode=('',)*4
|
| 383 |
for vendor in vendorInfo:
|
382 |
for vendor in vendorInfo:
|
| 384 |
if iterator == 0:
|
383 |
if iterator == 0:
|
| Line 417... |
Line 416... |
| 417 |
|
416 |
|
| 418 |
|
417 |
|
| 419 |
def populateStuff(runType,time):
|
418 |
def populateStuff(runType,time):
|
| 420 |
itemInfo = []
|
419 |
itemInfo = []
|
| 421 |
if runType=='FAVOURITE':
|
420 |
if runType=='FAVOURITE':
|
| 422 |
items = session.query(SnapdealItem).join((MarketplaceItems,SnapdealItem.item_id==MarketplaceItems.itemId)).filter(MarketplaceItems.itemId==17209).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).\
|
421 |
items = session.query(SnapdealItem).join((MarketplaceItems,SnapdealItem.item_id==MarketplaceItems.itemId)).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).\
|
| 423 |
filter(or_(MarketplaceItems.autoFavourite==True, MarketplaceItems.manualFavourite==True)).all()
|
422 |
filter(or_(MarketplaceItems.autoFavourite==True, MarketplaceItems.manualFavourite==True)).all()
|
| 424 |
else:
|
423 |
else:
|
| 425 |
items = session.query(SnapdealItem).all()
|
424 |
items = session.query(SnapdealItem).all()
|
| 426 |
#spm = SourcePercentageMaster.get_by(source=OrderSource.SNAPDEAL)
|
425 |
#spm = SourcePercentageMaster.get_by(source=OrderSource.SNAPDEAL)
|
| 427 |
|
426 |
|
| Line 456... |
Line 455... |
| 456 |
catalog_client = CatalogClient().get_client()
|
455 |
catalog_client = CatalogClient().get_client()
|
| 457 |
inventory_client = InventoryClient().get_client()
|
456 |
inventory_client = InventoryClient().get_client()
|
| 458 |
|
457 |
|
| 459 |
for val in itemInfo:
|
458 |
for val in itemInfo:
|
| 460 |
spm = val.sourcePercentage
|
459 |
spm = val.sourcePercentage
|
| - |
|
460 |
try:
|
| 461 |
snapdealDetails = fetchDetails(val.supc)
|
461 |
snapdealDetails = fetchDetails(val.supc)
|
| 462 |
sys.exit(1)
|
462 |
except:
|
| - |
|
463 |
exceptionItems.append(val)
|
| - |
|
464 |
continue
|
| 463 |
mpItem = MarketplaceItems.get_by(itemId=val.item_id,source=OrderSource.SNAPDEAL)
|
465 |
mpItem = MarketplaceItems.get_by(itemId=val.item_id,source=OrderSource.SNAPDEAL)
|
| 464 |
warehouse = inventory_client.getWarehouse(val.warehouseId)
|
466 |
warehouse = inventory_client.getWarehouse(val.warehouseId)
|
| 465 |
|
467 |
|
| 466 |
itemSaleList = []
|
468 |
itemSaleList = []
|
| 467 |
oosForAllSources = inventory_client.getOosStatusesForXDaysForItem(val.item_id, 0, 3)
|
469 |
oosForAllSources = inventory_client.getOosStatusesForXDaysForItem(val.item_id, 0, 3)
|