| Line 13... |
Line 13... |
| 13 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
13 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
| 14 |
ItemInventoryHistory, CurrentInventorySnapshot, VendorItemPricing, \
|
14 |
ItemInventoryHistory, CurrentInventorySnapshot, VendorItemPricing, \
|
| 15 |
VendorItemMapping, Vendor, MissedInventoryUpdate, BadInventorySnapshot, \
|
15 |
VendorItemMapping, Vendor, MissedInventoryUpdate, BadInventorySnapshot, \
|
| 16 |
VendorItemProcurementDelay, VendorHolidays, ItemAvailabilityCache, \
|
16 |
VendorItemProcurementDelay, VendorHolidays, ItemAvailabilityCache, \
|
| 17 |
CurrentReservationSnapshot, IgnoredInventoryUpdateItems, \
|
17 |
CurrentReservationSnapshot, IgnoredInventoryUpdateItems, \
|
| 18 |
ItemStockPurchaseParams, OOSStatus
|
18 |
ItemStockPurchaseParams, OOSStatus, AmazonInventorySnapshot
|
| 19 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
19 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| 20 |
InventoryServiceException, HolidayType, InventoryType, WarehouseType
|
20 |
InventoryServiceException, HolidayType, InventoryType, WarehouseType
|
| 21 |
from shop2020.thriftpy.model.v1.order.ttypes import AlertType
|
21 |
from shop2020.thriftpy.model.v1.order.ttypes import AlertType
|
| 22 |
from shop2020.thriftpy.purchase.ttypes import PurchaseServiceException
|
22 |
from shop2020.thriftpy.purchase.ttypes import PurchaseServiceException
|
| 23 |
from shop2020.utils import EmailAttachmentSender
|
23 |
from shop2020.utils import EmailAttachmentSender
|
| Line 1039... |
Line 1039... |
| 1039 |
timestamp = datetime.datetime.now()
|
1039 |
timestamp = datetime.datetime.now()
|
| 1040 |
timestamp = timestamp - datetime.timedelta(days = 6)
|
1040 |
timestamp = timestamp - datetime.timedelta(days = 6)
|
| 1041 |
return OOSStatus.query.filter_by(item_id = itemId).filter(OOSStatus.date > timestamp).all()
|
1041 |
return OOSStatus.query.filter_by(item_id = itemId).filter(OOSStatus.date > timestamp).all()
|
| 1042 |
|
1042 |
|
| 1043 |
def get_non_zero_item_stock_purchase_params():
|
1043 |
def get_non_zero_item_stock_purchase_params():
|
| 1044 |
return ItemStockPurchaseParams.query.filter(or_("numOfDaysStock!=0","minStockLevel!=0"))
|
- |
|
| 1045 |
|
1044 |
return ItemStockPurchaseParams.query.filter(or_("numOfDaysStock!=0","minStockLevel!=0"))
|
| - |
|
1045 |
|
| - |
|
1046 |
def get_warehouse_name(warehouseId):
|
| - |
|
1047 |
row = Warehouse.get_by(id = warehouseId)
|
| - |
|
1048 |
return row.displayName
|
| - |
|
1049 |
|
| - |
|
1050 |
def get_amazon_inventory_for_item(amazonItemId):
|
| - |
|
1051 |
inventory = AmazonInventorySnapshot.get_by(item_id=amazonItemId)
|
| - |
|
1052 |
return inventory
|
| - |
|
1053 |
|
| - |
|
1054 |
def get_all_amazon_inventory():
|
| - |
|
1055 |
return session.query(AmazonInventorySnapshot).all()
|
| - |
|
1056 |
|
| - |
|
1057 |
def add_or_update_amazon_inventory_for_item(amazoninventorysnapshot):
|
| - |
|
1058 |
inventory = AmazonInventorySnapshot.get_by(item_id = amazoninventorysnapshot.item_id)
|
| - |
|
1059 |
if inventory is None:
|
| - |
|
1060 |
amazon_inventory = AmazonInventorySnapshot()
|
| - |
|
1061 |
amazon_inventory.item_id = amazoninventorysnapshot.item_id
|
| - |
|
1062 |
amazon_inventory.availability = amazoninventorysnapshot.availability
|
| - |
|
1063 |
amazon_inventory.reserved = amazoninventorysnapshot.reserved
|
| - |
|
1064 |
else:
|
| - |
|
1065 |
inventory.availability = amazoninventorysnapshot.availability
|
| - |
|
1066 |
inventory.reserved = amazoninventorysnapshot.reserved
|
| - |
|
1067 |
session.commit()
|
| - |
|
1068 |
|
| - |
|
1069 |
|
| - |
|
1070 |
|
| - |
|
1071 |
|
| - |
|
1072 |
|