| Line 783... |
Line 783... |
| 783 |
raise InventoryServiceException(111, "Missing pricing information for Vendor: " + vendor.name + " and Item: " + str(item_id))
|
783 |
raise InventoryServiceException(111, "Missing pricing information for Vendor: " + vendor.name + " and Item: " + str(item_id))
|
| 784 |
|
784 |
|
| 785 |
def get_all_item_pricing(item_id):
|
785 |
def get_all_item_pricing(item_id):
|
| 786 |
item_pricing = VendorItemPricing.query.filter_by(item_id=item_id).all()
|
786 |
item_pricing = VendorItemPricing.query.filter_by(item_id=item_id).all()
|
| 787 |
return item_pricing
|
787 |
return item_pricing
|
| - |
|
788 |
def get_all_vendor_item_pricing(item_id, vendor_id):
|
| - |
|
789 |
query = VendorItemPricing.query
|
| - |
|
790 |
if item_id:
|
| - |
|
791 |
query = query.filter_by(item_id = item_id)
|
| - |
|
792 |
if item_id:
|
| - |
|
793 |
query = query.filter_by(vendor_id = vendor_id)
|
| - |
|
794 |
item_pricing = query.all()
|
| - |
|
795 |
return item_pricing
|
| 788 |
|
796 |
|
| 789 |
def get_item_mappings(item_id):
|
797 |
def get_item_mappings(item_id):
|
| 790 |
item_mappings = VendorItemMapping.query.filter_by(item_id=item_id).all()
|
798 |
item_mappings = VendorItemMapping.query.filter_by(item_id=item_id).all()
|
| 791 |
return item_mappings
|
799 |
return item_mappings
|
| 792 |
|
800 |
|
| 793 |
def add_vendor_pricing(vendorItemPricing):
|
801 |
def add_vendor_pricing(vendorItemPricing):
|
| Line 1179... |
Line 1187... |
| 1179 |
def get_oos_statuses_for_x_days_for_item(itemId, sourceId, days):
|
1187 |
def get_oos_statuses_for_x_days_for_item(itemId, sourceId, days):
|
| 1180 |
timestamp = datetime.datetime.now()
|
1188 |
timestamp = datetime.datetime.now()
|
| 1181 |
timestamp = timestamp - datetime.timedelta(days = days)
|
1189 |
timestamp = timestamp - datetime.timedelta(days = days)
|
| 1182 |
return OOSStatus.query.filter_by(item_id = itemId).filter_by(sourceId = sourceId).filter(OOSStatus.date > timestamp).all()
|
1190 |
return OOSStatus.query.filter_by(item_id = itemId).filter_by(sourceId = sourceId).filter(OOSStatus.date > timestamp).all()
|
| 1183 |
|
1191 |
|
| - |
|
1192 |
def get_oos_statuses_for_x_days(sourceId, days):
|
| - |
|
1193 |
timestamp = datetime.datetime.now()
|
| - |
|
1194 |
timestamp = timestamp - datetime.timedelta(days = days)
|
| - |
|
1195 |
if sourceId == -1:
|
| - |
|
1196 |
return OOSStatus.query.filter(OOSStatus.date > timestamp).all()
|
| - |
|
1197 |
else:
|
| - |
|
1198 |
return OOSStatus.query.filter_by(sourceId = sourceId).filter(OOSStatus.date > timestamp).all()
|
| - |
|
1199 |
|
| 1184 |
def get_non_zero_item_stock_purchase_params():
|
1200 |
def get_non_zero_item_stock_purchase_params():
|
| 1185 |
return ItemStockPurchaseParams.query.filter(or_("numOfDaysStock!=0","minStockLevel!=0"))
|
1201 |
return ItemStockPurchaseParams.query.filter(or_("numOfDaysStock!=0","minStockLevel!=0"))
|
| 1186 |
|
1202 |
|
| 1187 |
def get_last_n_day_sale_for_item(itemId, numberOfDays):
|
1203 |
def get_last_n_day_sale_for_item(itemId, numberOfDays):
|
| 1188 |
lastNdaySale = ""
|
1204 |
lastNdaySale = ""
|