WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/utils/FetchLivePrices.py



from dtr.utils import FlipkartScraper,NewFlipkartScraper
from dtr.storage.MemCache import MemCache
from functools import partial
import threading
from dtr.utils.utils import getCashBack
import traceback
 
mc = MemCache("127.0.0.1")
 
con = None
SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4}

        manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':source_id, 'sku':item['_id']}))
        if len(manualDeals) > 0:
            item['dealFlag'] = 1
            item['dealType'] =manualDeals[0]['dealType']
        info = returnLatestPrice(item, source_id)
        print info
        try:
            cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')
            print "CashBack is ",cashBack
            if not cashBack or cashBack.get('cash_back_status')!=1:
                raise
            else:
                if cashBack['cash_back_type'] in (1,2):
                    info['cash_back_type'] = cashBack['cash_back_type']
                    info['cash_back'] = float(cashBack['cash_back'])
                else:
                    raise
        except Exception as cashBackEx:
            traceback.print_exc()
            print "Error calculating cashback."
            info['cash_back_type'] = 0
            info['cash_back'] = 0
        print "info is ",info
        temp.append(info)
    try:
        thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))
        thread.daemon = True
        thread.start()    

    if len(manualDeals) > 0:
        item[0]['dealFlag'] = 1
        item[0]['dealType'] =manualDeals[0]['dealType'] 
    
    info = returnLatestPrice(item[0], item[0]['source_id'])
    print info
    try:
        cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'], mc, 'localhost')
        print "CashBack is ",cashBack
        if not cashBack or cashBack.get('cash_back_status')!=1:
            raise
        else:
            if cashBack['cash_back_type'] in (1,2):
                info['cash_back_type'] = cashBack['cash_back_type']
                info['cash_back'] = float(cashBack['cash_back'])
            else:
                raise
    except Exception as cashBackEx:
        traceback.print_exc()
        print cashBackEx
        print "Error calculating cashback."
        info['cash_back_type'] = 0
        info['cash_back'] = 0
    try:

    except:
        print "Unable to compute deal for ",item[0]['skuBundleId']
    return info
 
def main():
    print "retuned %s"%(str(getLatestPrice(1132, 3)))
 
if __name__=='__main__':
    main()
    

Rev 14760	Rev 14794
Line 9...	Line 9...
9	`from dtr.utils import FlipkartScraper,NewFlipkartScraper`	9	`from dtr.utils import FlipkartScraper,NewFlipkartScraper`
10	`from dtr.storage.MemCache import MemCache`	10	`from dtr.storage.MemCache import MemCache`
11	`from functools import partial`	11	`from functools import partial`
12	`import threading`	12	`import threading`
13	`from dtr.utils.utils import getCashBack`	13	`from dtr.utils.utils import getCashBack`
-		14	`import traceback`
14		15
15	`mc = MemCache("127.0.0.1")`	16	`mc = MemCache("127.0.0.1")`
16		17
17	`con = None`	18	`con = None`
18	`SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4}`	19	`SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4}`
Line 274...	Line 275...
274	`manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':source_id, 'sku':item['_id']}))`	275	`manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':source_id, 'sku':item['_id']}))`
275	`if len(manualDeals) > 0:`	276	`if len(manualDeals) > 0:`
276	`item['dealFlag'] = 1`	277	`item['dealFlag'] = 1`
277	`item['dealType'] =manualDeals[0]['dealType']`	278	`item['dealType'] =manualDeals[0]['dealType']`
278	`info = returnLatestPrice(item, source_id)`	279	`info = returnLatestPrice(item, source_id)`
-		280	`print info`
279	`try:`	281	`try:`
280	`cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')`	282	`cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')`
-		283	`print "CashBack is ",cashBack`
281	`if not cashBack or cashBack.get('cash_back_status')!=1:`	284	`if not cashBack or cashBack.get('cash_back_status')!=1:`
282	`pass`	285	`raise`
283	`else:`	286	`else:`
284	`if cashBack['cash_back_type'] in (1,2):`	287	`if cashBack['cash_back_type'] in (1,2):`
285	`info['cash_back_type'] = cashBack['cash_back_type']`	288	`info['cash_back_type'] = cashBack['cash_back_type']`
286	`info['cash_back'] = float(cashBack['cash_back'])`	289	`info['cash_back'] = float(cashBack['cash_back'])`
287	`else:`	290	`else:`
288	`raise`	291	`raise`
289	`except Exception as cashBackEx:`	292	`except Exception as cashBackEx:`
290	`print cashBackEx`	293	`traceback.print_exc()`
291	`print "Error calculating cashback."`	294	`print "Error calculating cashback."`
292	`info['cash_back_type'] = 0`	295	`info['cash_back_type'] = 0`
293	`info['cash_back'] = 0`	296	`info['cash_back'] = 0`
-		297	`print "info is ",info`
294	`temp.append(info)`	298	`temp.append(info)`
295	`try:`	299	`try:`
296	`thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))`	300	`thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))`
297	`thread.daemon = True`	301	`thread.daemon = True`
298	`thread.start()`	302	`thread.start()`
Line 308...	Line 312...
308	`if len(manualDeals) > 0:`	312	`if len(manualDeals) > 0:`
309	`item[0]['dealFlag'] = 1`	313	`item[0]['dealFlag'] = 1`
310	`item[0]['dealType'] =manualDeals[0]['dealType']`	314	`item[0]['dealType'] =manualDeals[0]['dealType']`
311		315
312	`info = returnLatestPrice(item[0], item[0]['source_id'])`	316	`info = returnLatestPrice(item[0], item[0]['source_id'])`
-		317	`print info`
313	`try:`	318	`try:`
314	`cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')`	319	`cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'], mc, 'localhost')`
-		320	`print "CashBack is ",cashBack`
315	`if not cashBack or cashBack.get('cash_back_status')!=1:`	321	`if not cashBack or cashBack.get('cash_back_status')!=1:`
316	`pass`	322	`raise`
317	`else:`	323	`else:`
318	`if cashBack['cash_back_type'] in (1,2):`	324	`if cashBack['cash_back_type'] in (1,2):`
319	`info['cash_back_type'] = cashBack['cash_back_type']`	325	`info['cash_back_type'] = cashBack['cash_back_type']`
320	`info['cash_back'] = float(cashBack['cash_back'])`	326	`info['cash_back'] = float(cashBack['cash_back'])`
321	`else:`	327	`else:`
322	`raise`	328	`raise`
323	`except Exception as cashBackEx:`	329	`except Exception as cashBackEx:`
-		330	`traceback.print_exc()`
324	`print cashBackEx`	331	`print cashBackEx`
325	`print "Error calculating cashback."`	332	`print "Error calculating cashback."`
326	`info['cash_back_type'] = 0`	333	`info['cash_back_type'] = 0`
327	`info['cash_back'] = 0`	334	`info['cash_back'] = 0`
328	`try:`	335	`try:`
Line 332...	Line 339...
332	`except:`	339	`except:`
333	`print "Unable to compute deal for ",item[0]['skuBundleId']`	340	`print "Unable to compute deal for ",item[0]['skuBundleId']`
334	`return info`	341	`return info`
335		342
336	`def main():`	343	`def main():`
337	`print "retuned %s"%(str(getLatestPrice(17, 2)))`	344	`print "retuned %s"%(str(getLatestPrice(1132, 3)))`
338		345
339	`if __name__=='__main__':`	346	`if __name__=='__main__':`
340	`main()`	347	`main()`
341		348

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 14760 → 14794