Subversion Repositories SmartDukaan

Rev

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

Rev 31115 Rev 35718
Line 796... Line 796...
796 
        ItemAvailabilityCache.query.filter_by(itemId=item_id).delete()
 796 
        ItemAvailabilityCache.query.filter_by(itemId=item_id).delete()
797 
        session.commit()
 797 
        session.commit()
798 
 
 798 
 
799
799
800 
def _task_update_item_availability_cache(item_ids):
 800 
def _task_update_item_availability_cache(item_ids):
- 
 
 801 
    try:
801 
    client = CatalogClient("catalog_service_server_host_master", "catalog_service_server_port").get_client()
 802 
        client = CatalogClient("catalog_service_server_host_master", "catalog_service_server_port").get_client()
802 
    items = client.getItems(item_ids)
 803 
        items = client.getItems(item_ids)
803 
    for item_id in item_ids:
 804 
        for item_id in item_ids:
804 
        item_availability = ItemAvailabilityCache.get_by(itemId=item_id, sourceId=1)
 805 
            item_availability = ItemAvailabilityCache.get_by(itemId=item_id, sourceId=1)
805 
        if not item_availability:
 806 
            if not item_availability:
806 
            try:
 807 
                try:
807 
                __update_item_availability_cache(item_id, 1, items[item_id])
 808 
                    __update_item_availability_cache(item_id, 1, items[item_id])
808 
                __check_risky_item(item_id, 1)
 809 
                    __check_risky_item(item_id, 1)
809 
            except:
 810 
                except:
810 
                print "Could not update cache for "
 811 
                    print "Could not update cache for "
811 
                continue
 812 
                    continue
812 
    return True
813 
        return True
- 
 
 814 
    finally:
- 
 
 815 
        session.remove()
813 
 
 816 
 
814 
 
 817 
 
815 
def __update_item_location(item_id):
 818 
def __update_item_location(item_id):
816 
    ignoredWhs = get_ignored_warehouses(item_id)
 819 
    ignoredWhs = get_ignored_warehouses(item_id)
817
820
Line 1291... Line 1294...
1291 
    items_inventory.extend(available_items_inventory)
 1294 
    items_inventory.extend(available_items_inventory)
1292 
    return items_inventory
 1295 
    return items_inventory
1293 
 
 1296 
 
1294 
 
 1297 
 
1295 
def close_session():
 1298 
def close_session():
1296 
    if session.is_active:
 - 
 
1297 
        print "session is active. closing it."
 - 
 
1298 
        session.close()
 1299 
    session.remove()
1299 
 
 1300 
 
1300 
 
 1301 
 
1301 
def is_alive():
 1302 
def is_alive():
1302 
    try:
 1303 
    try:
1303 
        session.query(Vendor.id).limit(1).one()
 1304 
        session.query(Vendor.id).limit(1).one()