Subversion Repositories SmartDukaan

Rev

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

Rev 12949 Rev 12963
Line 147... Line 147...
147 
        print "[ERROR] Unexpected error:", sys.exc_info()[0]
 147 
        print "[ERROR] Unexpected error:", sys.exc_info()[0]
148 
    return t_item_shipping_info
 148 
    return t_item_shipping_info
149 
 
 149 
 
150 
def get_items_status(item_ids):
 150 
def get_items_status(item_ids):
151 
    itemsStatus = dict()
 151 
    itemsStatus = dict()
152 
    for item_id in item_ids:
 152 
#    for item_id in item_ids:
153 
        try:
 153 
#        try:
154 
            item = get_item(item_id)
 154 
#            item = get_item(item_id)
155 
            if item is None:
 155 
#            if item is None:
156 
                continue
 156 
#                continue
157 
            client = InventoryClient().get_client()
 157 
#            client = InventoryClient().get_client()
158 
            itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId)
 158 
#            itemInfo = client.getItemAvailabilityAtLocation(item.id, sourceId)
159 
            warehouse_id = itemInfo[0]
 159 
#            warehouse_id = itemInfo[0]
160 
            if item.risky and item.status == status.ACTIVE:
 160 
#            if item.risky and item.status == status.ACTIVE:
161 
                availability = client.getItemAvailibilityAtWarehouse(warehouse_id, item_id)
 161 
#                availability = client.getItemAvailibilityAtWarehouse(warehouse_id, item_id)
162 
                if availability <= 0:
 162 
#                if availability <= 0:
163 
                    item.status = status.PAUSED_BY_RISK
 163 
#                    item.status = status.PAUSED_BY_RISK
164 
            itemsStatus[item_id] = (item.status == status.ACTIVE)
 164 
#            itemsStatus[item_id] = (item.status == status.ACTIVE)
165 
        except InventoryServiceException:
 165 
#        except InventoryServiceException:
166 
            print "[ERROR] Unexpected error:", sys.exc_info()[0]
 166 
#            print "[ERROR] Unexpected error:", sys.exc_info()[0]
167 
    return itemsStatus
 167 
    return itemsStatus
168 
 
 168 
 
169 
def get_item_status_description(itemId):
 169 
def get_item_status_description(itemId):
170 
    item = get_item(itemId)
 170 
    item = get_item(itemId)
171 
    return item.status_description
 171 
    return item.status_description
Line 562... Line 562...
562 
    elif item.status == status.IN_PROCESS:
 562 
    elif item.status == status.IN_PROCESS:
563 
        item.status_description = "This item is in process"
 563 
        item.status_description = "This item is in process"
564 
    elif item.status == status.CONTENT_COMPLETE:
 564 
    elif item.status == status.CONTENT_COMPLETE:
565 
        item.status_description = "This item is in process"
 565 
        item.status_description = "This item is in process"
566 
    session.commit()
 566 
    session.commit()
567
567 
 
- 
 
 568 
#Risky item is validated wheter in stock or not
568 
def check_risky_item(item_id):
 569 
def check_risky_item(item_id):
569 
    item = get_item(item_id)
 570 
    item = get_item(item_id)
570 
    if not item.risky:
 571 
    if not item.risky:
571 
        return
 572 
        return
572 
    client = InventoryClient().get_client()
 573 
    client = InventoryClient().get_client()
Line 991... Line 992...
991 
        query = query.filter(Item.brand == brand)
 992 
        query = query.filter(Item.brand == brand)
992 
    items = query.all()
 993 
    items = query.all()
993 
    return items
 994 
    return items
994 
 
 995 
 
995 
def get_risky_items():
 996 
def get_risky_items():
996 
    items = Item.query.filter_by(risky=True).all()
 997 
    items = Item.query.filter(Item.risky==True).filter(or_(Item.status==status.ACTIVE, Item.status==status.PAUSED_BY_RISK)).all()
997 
    return items
 998 
    return items
998 
 
 999 
 
999 
def get_similar_items_catalog_ids(start_index, stop_index, itemId):
 1000 
def get_similar_items_catalog_ids(start_index, stop_index, itemId):
1000 
    query = SimilarItems.query.filter_by(item_id=itemId).limit(stop_index-start_index)
 1001 
    query = SimilarItems.query.filter_by(item_id=itemId).limit(stop_index-start_index)
1001 
    similar_items = query.all()
 1002 
    similar_items = query.all()