| Line 1219... |
Line 1219... |
| 1219 |
return inventory
|
1219 |
return inventory
|
| 1220 |
|
1220 |
|
| 1221 |
def get_all_amazon_inventory():
|
1221 |
def get_all_amazon_inventory():
|
| 1222 |
return session.query(AmazonInventorySnapshot).all()
|
1222 |
return session.query(AmazonInventorySnapshot).all()
|
| 1223 |
|
1223 |
|
| 1224 |
def add_or_update_amazon_inventory_for_item(amazoninventorysnapshot):
|
1224 |
def add_or_update_amazon_inventory_for_item(amazoninventorysnapshot,time):
|
| 1225 |
inventory = AmazonInventorySnapshot.get_by(item_id = amazoninventorysnapshot.item_id)
|
1225 |
inventory = AmazonInventorySnapshot.get_by(item_id = amazoninventorysnapshot.item_id)
|
| 1226 |
if inventory is None:
|
1226 |
if inventory is None:
|
| 1227 |
amazon_inventory = AmazonInventorySnapshot()
|
1227 |
amazon_inventory = AmazonInventorySnapshot()
|
| 1228 |
amazon_inventory.item_id = amazoninventorysnapshot.item_id
|
1228 |
amazon_inventory.item_id = amazoninventorysnapshot.item_id
|
| 1229 |
amazon_inventory.availability = amazoninventorysnapshot.availability
|
1229 |
amazon_inventory.availability = amazoninventorysnapshot.availability
|
| 1230 |
amazon_inventory.reserved = amazoninventorysnapshot.reserved
|
1230 |
amazon_inventory.reserved = amazoninventorysnapshot.reserved
|
| - |
|
1231 |
amazon_inventory.is_oos = amazoninventorysnapshot.is_oos
|
| - |
|
1232 |
if time != 0:
|
| - |
|
1233 |
amazon_inventory.lastUpdatedOnAmazon = to_py_date(time)
|
| 1231 |
else:
|
1234 |
else:
|
| 1232 |
inventory.availability = amazoninventorysnapshot.availability
|
1235 |
inventory.availability = amazoninventorysnapshot.availability
|
| 1233 |
inventory.reserved = amazoninventorysnapshot.reserved
|
1236 |
inventory.reserved = amazoninventorysnapshot.reserved
|
| - |
|
1237 |
if not inventory.is_oos and (to_py_date(time) - inventory.lastUpdatedOnAmazon).days == 0:
|
| - |
|
1238 |
pass
|
| - |
|
1239 |
else:
|
| - |
|
1240 |
inventory.is_oos = amazoninventorysnapshot.is_oos
|
| - |
|
1241 |
if time != 0:
|
| - |
|
1242 |
inventory.lastUpdatedOnAmazon = to_py_date(time)
|
| 1234 |
session.commit()
|
1243 |
session.commit()
|
| 1235 |
|
1244 |
|
| 1236 |
def add_update_hold_inventory(itemId, warehouseId, holdQuantity, source):
|
1245 |
def add_update_hold_inventory(itemId, warehouseId, holdQuantity, source):
|
| 1237 |
if holdQuantity <0:
|
1246 |
if holdQuantity <0:
|
| 1238 |
print "Negative holdQuantity : " + str(holdQuantity) + " is not allowed"
|
1247 |
print "Negative holdQuantity : " + str(holdQuantity) + " is not allowed"
|
| Line 1309... |
Line 1318... |
| 1309 |
snapdeal_inventory_item = SnapdealInventorySnapshot()
|
1318 |
snapdeal_inventory_item = SnapdealInventorySnapshot()
|
| 1310 |
snapdeal_inventory_item.item_id = snapdealinventoryitem.item_id
|
1319 |
snapdeal_inventory_item.item_id = snapdealinventoryitem.item_id
|
| 1311 |
snapdeal_inventory_item.availability = snapdealinventoryitem.availability
|
1320 |
snapdeal_inventory_item.availability = snapdealinventoryitem.availability
|
| 1312 |
snapdeal_inventory_item.pendingOrders = snapdealinventoryitem.pendingOrders
|
1321 |
snapdeal_inventory_item.pendingOrders = snapdealinventoryitem.pendingOrders
|
| 1313 |
snapdeal_inventory_item.lastUpdatedOnSnapdeal = to_py_date(snapdealinventoryitem.lastUpdatedOnSnapdeal)
|
1322 |
snapdeal_inventory_item.lastUpdatedOnSnapdeal = to_py_date(snapdealinventoryitem.lastUpdatedOnSnapdeal)
|
| - |
|
1323 |
snapdeal_inventory_item.is_oos = snapdealinventoryitem.is_oos
|
| 1314 |
else:
|
1324 |
else:
|
| 1315 |
snapdeal_inventory_item.availability = snapdealinventoryitem.availability
|
1325 |
snapdeal_inventory_item.availability = snapdealinventoryitem.availability
|
| 1316 |
snapdeal_inventory_item.pendingOrders = snapdealinventoryitem.pendingOrders
|
1326 |
snapdeal_inventory_item.pendingOrders = snapdealinventoryitem.pendingOrders
|
| - |
|
1327 |
if not snapdeal_inventory_item.is_oos and (to_py_date(snapdealinventoryitem.lastUpdatedOnSnapdeal) - snapdeal_inventory_item.lastUpdatedOnSnapdeal).days == 0:
|
| - |
|
1328 |
pass
|
| - |
|
1329 |
else:
|
| - |
|
1330 |
snapdeal_inventory_item.is_oos = snapdealinventoryitem.is_oos
|
| 1317 |
snapdeal_inventory_item.lastUpdatedOnSnapdeal = to_py_date(snapdealinventoryitem.lastUpdatedOnSnapdeal)
|
1331 |
snapdeal_inventory_item.lastUpdatedOnSnapdeal = to_py_date(snapdealinventoryitem.lastUpdatedOnSnapdeal)
|
| 1318 |
session.commit()
|
1332 |
session.commit()
|
| 1319 |
|
1333 |
|
| 1320 |
def get_nlc_for_warehouse(warehouse_id,itemid):
|
1334 |
def get_nlc_for_warehouse(warehouse_id,itemid):
|
| 1321 |
warehouse = Warehouse.get_by(id=warehouse_id)
|
1335 |
warehouse = Warehouse.get_by(id=warehouse_id)
|
| Line 1346... |
Line 1360... |
| 1346 |
if source:
|
1360 |
if source:
|
| 1347 |
heldInventoryQuery = heldInventoryQuery.filter_by(source = source)
|
1361 |
heldInventoryQuery = heldInventoryQuery.filter_by(source = source)
|
| 1348 |
holdInventoryDetails = heldInventoryQuery.all()
|
1362 |
holdInventoryDetails = heldInventoryQuery.all()
|
| 1349 |
return holdInventoryDetails
|
1363 |
return holdInventoryDetails
|
| 1350 |
|
1364 |
|
| 1351 |
def add_or_update_flipkart_inventory_snapshot(flipkartInventorySnapshot):
|
1365 |
def add_or_update_flipkart_inventory_snapshot(flipkartInventorySnapshot,time):
|
| 1352 |
for snapshot in flipkartInventorySnapshot:
|
1366 |
for snapshot in flipkartInventorySnapshot:
|
| 1353 |
flipkart_inventory = FlipkartInventorySnapshot.get_by(item_id = snapshot.item_id)
|
1367 |
flipkart_inventory = FlipkartInventorySnapshot.get_by(item_id = snapshot.item_id)
|
| 1354 |
if flipkart_inventory is None:
|
1368 |
if flipkart_inventory is None:
|
| 1355 |
flipkart_inventory = FlipkartInventorySnapshot()
|
1369 |
flipkart_inventory = FlipkartInventorySnapshot()
|
| 1356 |
flipkart_inventory.item_id = snapshot.item_id
|
1370 |
flipkart_inventory.item_id = snapshot.item_id
|
| 1357 |
flipkart_inventory.availability = snapshot.availability
|
1371 |
flipkart_inventory.availability = snapshot.availability
|
| 1358 |
flipkart_inventory.createdOrders = snapshot.createdOrders
|
1372 |
flipkart_inventory.createdOrders = snapshot.createdOrders
|
| 1359 |
flipkart_inventory.heldOrders = snapshot.heldOrders
|
1373 |
flipkart_inventory.heldOrders = snapshot.heldOrders
|
| - |
|
1374 |
flipkart_inventory.is_oos = snapshot.is_oos
|
| - |
|
1375 |
flipkart_inventory.lastUpdatedOnFlipkart = to_py_date(time)
|
| 1360 |
else:
|
1376 |
else:
|
| 1361 |
flipkart_inventory.availability = snapshot.availability
|
1377 |
flipkart_inventory.availability = snapshot.availability
|
| 1362 |
flipkart_inventory.createdOrders = snapshot.createdOrders
|
1378 |
flipkart_inventory.createdOrders = snapshot.createdOrders
|
| 1363 |
flipkart_inventory.heldOrders = snapshot.heldOrders
|
1379 |
flipkart_inventory.heldOrders = snapshot.heldOrders
|
| - |
|
1380 |
if not flipkart_inventory.is_oos and (to_py_date(time) - flipkart_inventory.lastUpdatedOnFlipkart).days == 0:
|
| - |
|
1381 |
pass
|
| - |
|
1382 |
else:
|
| - |
|
1383 |
flipkart_inventory.is_oos = snapshot.is_oos
|
| - |
|
1384 |
flipkart_inventory.lastUpdatedOnFlipkart = to_py_date(time)
|
| 1364 |
session.commit()
|
1385 |
session.commit()
|
| 1365 |
|
1386 |
|
| 1366 |
def get_flipkart_inventory_snapshot():
|
1387 |
def get_flipkart_inventory_snapshot():
|
| 1367 |
return FlipkartInventorySnapshot.query.all()
|
1388 |
return FlipkartInventorySnapshot.query.all()
|
| 1368 |
|
1389 |
|