Subversion Repositories SmartDukaan

Rev

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

Rev 14367 Rev 14431
Line 293... Line 293...
293 
    manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':item[0]['source_id'], 'sku':item[0]['_id']}))
 293 
    manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':item[0]['source_id'], 'sku':item[0]['_id']}))
294 
    if len(manualDeals) > 0:
 294 
    if len(manualDeals) > 0:
295 
        item[0]['dealFlag'] = 1
 295 
        item[0]['dealFlag'] = 1
296 
        item[0]['dealType'] =manualDeals[0]['dealType']
296 
        item[0]['dealType'] =manualDeals[0]['dealType']
297
297
- 
 
 298 
    info = returnLatestPrice(item[0], item[0]['source_id'])
298 
    try:
 299 
    try:
299 
        thread = threading.Thread(target=recomputeDeal, args = (item[0]['skuBundleId'],))
 300 
        thread = threading.Thread(target=recomputeDeal, args = (item[0]['skuBundleId'],))
300 
        thread.daemon = True
 301 
        thread.daemon = True
301 
        thread.start()
302 
        thread.start()
302 
    except:
 303 
    except:
303 
        print "Unable to compute deal for ",item[0]['skuBundleId']
 304 
        print "Unable to compute deal for ",item[0]['skuBundleId']
304 
    return returnLatestPrice(item[0], item[0]['source_id'])
 305 
    return info
305 
 
 306 
 
306 
 
 307 
 
307 
def main():
 308 
def main():
308 
    print getLatestPriceById(22746)
 309 
    print getLatestPriceById(4674)
309 
 
 310 
 
310 
if __name__=='__main__':
 311 
if __name__=='__main__':
311 
    main()
 312 
    main()
312
313