| Line 6... |
Line 6... |
| 6 |
from elixir import *
|
6 |
from elixir import *
|
| 7 |
from shop2020.model.v1.catalog.impl import DataService
|
7 |
from shop2020.model.v1.catalog.impl import DataService
|
| 8 |
from shop2020.model.v1.catalog.impl.DataService import Item, \
|
8 |
from shop2020.model.v1.catalog.impl.DataService import Item, \
|
| 9 |
Warehouse, ItemInventoryHistory, CurrentInventorySnapshot, ItemInfo,\
|
9 |
Warehouse, ItemInventoryHistory, CurrentInventorySnapshot, ItemInfo,\
|
| 10 |
ItemChangeLog, Category, EntityIDGenerator, VendorItemPricing,\
|
10 |
ItemChangeLog, Category, EntityIDGenerator, VendorItemPricing,\
|
| 11 |
VendorItemMapping, Vendor, SimilarItems
|
11 |
VendorItemMapping, Vendor, SimilarItems, ProductNotification
|
| 12 |
from shop2020.thriftpy.model.v1.catalog.ttypes import \
|
12 |
from shop2020.thriftpy.model.v1.catalog.ttypes import \
|
| 13 |
InventoryServiceException, status, ItemShippingInfo
|
13 |
InventoryServiceException, status, ItemShippingInfo
|
| 14 |
from shop2020.model.v1.catalog.impl.Convertors import to_t_item,\
|
14 |
from shop2020.model.v1.catalog.impl.Convertors import to_t_item,\
|
| 15 |
to_t_vendor_item_pricing
|
15 |
to_t_vendor_item_pricing
|
| 16 |
import datetime
|
16 |
import datetime
|
| Line 924... |
Line 924... |
| 924 |
def get_similar_items_catalog_ids(start_index, stop_index, itemId):
|
924 |
def get_similar_items_catalog_ids(start_index, stop_index, itemId):
|
| 925 |
query = SimilarItems.query.filter_by(item_id=itemId).limit(stop_index-start_index)
|
925 |
query = SimilarItems.query.filter_by(item_id=itemId).limit(stop_index-start_index)
|
| 926 |
similar_items = query.all()
|
926 |
similar_items = query.all()
|
| 927 |
return [item.catalog_item_id for item in similar_items]
|
927 |
return [item.catalog_item_id for item in similar_items]
|
| 928 |
|
928 |
|
| - |
|
929 |
def add_product_notification(itemId, email):
|
| - |
|
930 |
try:
|
| - |
|
931 |
product_notification = ProductNotification()
|
| - |
|
932 |
product_notification.email = email
|
| - |
|
933 |
product_notification.item_id = itemId
|
| - |
|
934 |
product_notification.addedOn = datetime.datetime.now()
|
| - |
|
935 |
session.commit()
|
| - |
|
936 |
return True
|
| - |
|
937 |
except:
|
| - |
|
938 |
return False
|
| - |
|
939 |
|
| 929 |
def close_session():
|
940 |
def close_session():
|
| 930 |
if session.is_active:
|
941 |
if session.is_active:
|
| 931 |
print "session is active. closing it."
|
942 |
print "session is active. closing it."
|
| 932 |
session.close()
|
943 |
session.close()
|