Subversion Repositories SmartDukaan

Rev

Rev 599 | Rev 609 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 599 Rev 602
Line 5... Line 5...
5 
'''
 5 
'''
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, Price, LatestArrivals, BestDeals, BestSellers
 10 
    ItemChangeLog, Price, BestDeals, BestSellers
11 
from shop2020.thriftpy.model.v1.catalog.ttypes import \
 11 
from shop2020.thriftpy.model.v1.catalog.ttypes import \
12 
    InventoryServiceException, status
 12 
    InventoryServiceException, status
13 
from shop2020.thriftpy.model.v1.catalog.ttypes import Item as TItem
 13 
from shop2020.model.v1.catalog.impl.Convertors import to_t_item
14 
 
 - 
 
15 
from shop2020.thriftpy.model.v1.catalog.ttypes import Warehouse as TWarehouse
 - 
 
16 
import datetime
 14 
import datetime
17 
from shop2020.utils.Utils import log_entry, to_py_date, to_java_date
 15 
from shop2020.utils.Utils import log_entry, to_py_date
18 
from sqlalchemy import desc, asc
 16 
from sqlalchemy import desc
19 
 
 17 
 
20 
 
 18 
 
21 
def initialize():
 19 
def initialize():
22 
    DataService.initialize()
 20 
    DataService.initialize()
23
21
Line 437... Line 435...
437 
        t_deals.append(deal.item_id)
 435 
        t_deals.append(deal.item_id)
438 
    return t_deals
436 
    return t_deals
439
437
440 
def get_latest_arrivals(limit):
 438 
def get_latest_arrivals(limit):
441 
    items = Item.query.order_by(desc(Item.startDate)).all()[0:limit]
 439 
    items = Item.query.order_by(desc(Item.startDate)).all()[0:limit]
- 
 
 440 
    ret_items = []
- 
 
 441 
    for item in items:
- 
 
 442 
        if item:
- 
 
 443 
            ret_items.append(to_t_item(item))
442 
    return items
 444 
    return ret_items
- 
 
 445
- 
 
 446 
def get_latest_arrivals_count(limit):
- 
 
 447 
    #FIXME: This method has not been tested. Have to talk to Rajveer to check where is it used.
- 
 
 448 
    return min(Item.query.count(), limit)
443
449
444 
def get_latest_arrivals_catalog_ids(limit):
 450 
def get_latest_arrivals_catalog_ids(limit):
445 
    arrivals = Item.query.order_by(desc(Item.startDate)).all()[0:limit]
 451 
    arrivals = Item.query.order_by(desc(Item.startDate)).all()[0:limit]
446
452
447 
    t_arrivals = []
 453 
    t_arrivals = []