| Line 5... |
Line 5... |
| 5 |
from dtr.utils import FlipkartScraper,NewFlipkartScraper
|
5 |
from dtr.utils import FlipkartScraper,NewFlipkartScraper
|
| 6 |
from multiprocessing import Pool as ThreadPool
|
6 |
from multiprocessing import Pool as ThreadPool
|
| 7 |
from multiprocessing import cpu_count
|
7 |
from multiprocessing import cpu_count
|
| 8 |
import optparse
|
8 |
import optparse
|
| 9 |
from dtr.storage.MemCache import MemCache
|
9 |
from dtr.storage.MemCache import MemCache
|
| - |
|
10 |
from dtr.utils.utils import getCashBack
|
| 10 |
|
11 |
|
| 11 |
con = None
|
12 |
con = None
|
| 12 |
|
13 |
|
| 13 |
parser = optparse.OptionParser()
|
14 |
parser = optparse.OptionParser()
|
| 14 |
parser.add_option("-m", "--m", dest="mongoHost",
|
15 |
parser.add_option("-m", "--m", dest="mongoHost",
|
| Line 136... |
Line 137... |
| 136 |
bestSellerPoints = 0
|
137 |
bestSellerPoints = 0
|
| 137 |
toUpdate = []
|
138 |
toUpdate = []
|
| 138 |
for similarItem in similarItems:
|
139 |
for similarItem in similarItems:
|
| 139 |
if mc.get("negative_deals") is None:
|
140 |
if mc.get("negative_deals") is None:
|
| 140 |
populateNegativeDeals()
|
141 |
populateNegativeDeals()
|
| - |
|
142 |
try:
|
| - |
|
143 |
cashBack = getCashBack(similarItem['_id'], similarItem['source_id'], similarItem['category_id'], mc, options.mongoHost)
|
| - |
|
144 |
if not cashBack or cashBack.get('cash_back_status')!=1:
|
| - |
|
145 |
pass
|
| - |
|
146 |
else:
|
| - |
|
147 |
if cashBack['cash_back_type'] ==1:
|
| - |
|
148 |
similarItem['available_price'] = similarItem['available_price'] - similarItem['available_price'] * float(cashBack['cash_back'])/100
|
| - |
|
149 |
elif cashBack['cash_back_type'] ==2:
|
| - |
|
150 |
similarItem['available_price'] = similarItem['available_price'] - float(cashBack['cash_back'])
|
| - |
|
151 |
else:
|
| - |
|
152 |
pass
|
| - |
|
153 |
except Exception as cashBackEx:
|
| - |
|
154 |
print cashBackEx
|
| - |
|
155 |
print "Error calculating cashback."
|
| 141 |
if similarItem['in_stock'] == 0 or similarItem['maxprice'] is None or similarItem['maxprice'] < similarItem['available_price'] or similarItem['_id'] in mc.get("negative_deals"):
|
156 |
if similarItem['in_stock'] == 0 or similarItem['maxprice'] is None or similarItem['maxprice'] < similarItem['available_price'] or similarItem['_id'] in mc.get("negative_deals"):
|
| 142 |
get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0 }})
|
157 |
get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0 }})
|
| 143 |
continue
|
158 |
continue
|
| 144 |
if similarItem['available_price'] < bestPrice:
|
159 |
if similarItem['available_price'] < bestPrice:
|
| 145 |
bestOne = similarItem
|
160 |
bestOne = similarItem
|