Subversion Repositories SmartDukaan

Rev

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

Rev 22636 Rev 22714
Line 3492... Line 3492...
3492
    return itemWarrantyMap
3492
    return itemWarrantyMap
3493
 
3493
 
3494
def get_all_fofo_deals(itemIds, tagIds):
3494
def get_all_fofo_deals(itemIds, tagIds):
3495
    returnMap = {}
3495
    returnMap = {}
3496
    
3496
    
3497
    query = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status==status.ACTIVE).filter(Tag_Listing.active==True)
3497
    query = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK])).filter(Tag_Listing.active==True)
3498
    if itemIds:
3498
    if itemIds:
3499
        query = query.filter(Item.id.in_(itemIds))
3499
        query = query.filter(Item.id.in_(itemIds))
3500
    else:
3500
    else:
3501
        return returnMap
3501
        return returnMap
3502
    if tagIds:
3502
    if tagIds:
3503
        query.filter(Tag_Listing.tag_id.in_(tagIds))
3503
        query.filter(Tag_Listing.tag_id.in_(tagIds))
3504
    else:
3504
    else:
3505
        returnMap
3505
        returnMap
-
 
3506
    tagListings = query.all()
3506
    for tagListing in tagListings:
3507
    for tagListing in tagListings:
3507
        if returnMap.has_key(tagListing.item_id):
3508
        if returnMap.has_key(tagListing.item_id):
3508
            if tagListing.selling_price > returnMap.get(tagListing.item_id):
3509
            if tagListing.selling_price > returnMap.get(tagListing.item_id):
3509
                returnMap[tagListing.item_id] = tagListing.selling_price
3510
                returnMap[tagListing.item_id] = tagListing.selling_price
3510
        else:
3511
        else:
Line 3512... Line 3513...
3512
    return returnMap
3513
    return returnMap
3513
             
3514
             
3514
 
3515
 
3515
if __name__=='__main__':
3516
if __name__=='__main__':
3516
    DataService.initialize()
3517
    DataService.initialize()
-
 
3518
    itemIds = [26821]
-
 
3519
    tagIds = [4,7]
3517
    tagListings = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status==status.ACTIVE).filter(Tag_Listing.active==True).filter(Item.id.in_(itemIds)).filter(Tag_Listing.tag_id.in_(tagIds))
3520
    tagListings = session.query(Tag_Listing).join((Item, Item.id==Tag_Listing.item_id)).filter(Item.status.in_([status.ACTIVE, status.PAUSED_BY_RISK])).filter(Tag_Listing.active==True).filter(Item.id.in_(itemIds)).filter(Tag_Listing.tag_id.in_(tagIds))
-
 
3521
    for tagListing in tagListings.all():
-
 
3522
        print tagListing
3518
    #update_bulk_prices_on_production(21053,[])
3523
    #update_bulk_prices_on_production(21053,[])
3519
    #search_terms = ["12206"]
3524
    #search_terms = ["12206"]
3520
    #print search_items(search_terms, 0, 20)
3525
    #print search_items(search_terms, 0, 20)
3521
    #print get_search_result_count(search_terms)
3526
    #print get_search_result_count(search_terms)
3522
    
3527
    
3523
3528