Subversion Repositories SmartDukaan

def get_all_similar_items_catalog_ids(itemId):

    query = SimilarItems.query.filter_by(item_id=itemId)

    similar_items = query.all()

    return_list = []

    for similar_item in similar_items:

        item_query = Item.query.filter_by(catalog_item_id=similar_item.catalog_item_id).limit(1)

        item = item_query.one()

        return_list.append(item)

    return get_thrift_item_list(return_list)

def add_similar_item_catalog_id(itemId, catalog_item_id):

    if not itemId or not catalog_item_id:

        raise InventoryServiceException(101, "Bad itemId or catalogItemId in request")

    items_for_entity = get_items_by_catalog_id(catalog_item_id)

    if not len(items_for_entity):

        raise InventoryServiceException(101, "catalogItemId does not exists in database")

    s_items = SimilarItems.query.filter_by(item_id=itemId, catalog_item_id=catalog_item_id).all()

    if not len(s_items):

        s_item = SimilarItems()

        s_item.item_id=itemId

        s_item.catalog_item_id=catalog_item_id

        session.commit()

        return items_for_entity[0]

    else:

        raise InventoryServiceException(101, "Already exists")

def delete_similar_item_catalog_id(itemId, catalog_item_id):

    if not itemId or not catalog_item_id:

        raise InventoryServiceException(101, "Bad itemId or catalogItemId in request")

    similar_item = SimilarItems.query.filter_by(item_id=itemId, catalog_item_id=catalog_item_id).all()

    if len(similar_item):

        similar_item[0].delete()

    session.commit()

    return True