| 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
|
11 |
VendorItemMapping, Vendor, SimilarItems
|
| 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 918... |
Line 918... |
| 918 |
return items
|
918 |
return items
|
| 919 |
|
919 |
|
| 920 |
def get_risky_items():
|
920 |
def get_risky_items():
|
| 921 |
items = Item.query.filter_by(risky=True).all()
|
921 |
items = Item.query.filter_by(risky=True).all()
|
| 922 |
return items
|
922 |
return items
|
| 923 |
|
923 |
|
| 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 |
similarity_index = Item.get_by(id = itemId).similarityIndex
|
925 |
query = SimilarItems.query.filter_by(item_id=itemId).limit(stop_index-start_index)
|
| 926 |
if similarity_index is None:
|
- |
|
| 927 |
return []
|
- |
|
| 928 |
query = Item.query.filter_by(status=status.ACTIVE).filter_by(similarityIndex=similarity_index).filter(Item.id!=itemId).filter(Item.similarityIndex != None).group_by(Item.catalog_item_id)
|
- |
|
| 929 |
similar_items = query.all()[start_index:stop_index]
|
926 |
similar_items = query.all()
|
| 930 |
return [item.catalog_item_id for item in similar_items]
|
927 |
return [item.catalog_item_id for item in similar_items]
|
| 931 |
|
928 |
|
| 932 |
def close_session():
|
929 |
def close_session():
|
| 933 |
if session.is_active:
|
930 |
if session.is_active:
|
| 934 |
print "session is active. closing it."
|
931 |
print "session is active. closing it."
|