| Line 5... |
Line 5... |
| 5 |
from dtr.utils import PaytmOfferScraper, PaytmScraper
|
5 |
from dtr.utils import PaytmOfferScraper, PaytmScraper
|
| 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 |
from dtr.utils.utils import getCashBack, DEAL_PRIORITY
|
| 11 |
import traceback
|
11 |
import traceback
|
| 12 |
from dtr.CouponMaster import addToPaytmMaster
|
12 |
from dtr.CouponMaster import addToPaytmMaster
|
| 13 |
from dtr.storage import DataService
|
13 |
from dtr.storage import DataService
|
| 14 |
|
14 |
|
| 15 |
con = None
|
15 |
con = None
|
| Line 241... |
Line 241... |
| 241 |
continue
|
241 |
continue
|
| 242 |
if similarItem.get('netPriceAfterCashBack') < bestPrice:
|
242 |
if similarItem.get('netPriceAfterCashBack') < bestPrice:
|
| 243 |
bestOne = similarItem
|
243 |
bestOne = similarItem
|
| 244 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
244 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
| 245 |
bestSellerPoints = similarItem['bestSellerPoints']
|
245 |
bestSellerPoints = similarItem['bestSellerPoints']
|
| 246 |
elif similarItem.get('netPriceAfterCashBack') == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
|
246 |
elif similarItem.get('netPriceAfterCashBack') == bestPrice:
|
| - |
|
247 |
|
| - |
|
248 |
try:
|
| - |
|
249 |
if (DEAL_PRIORITY.index(int(similarItem['source_id'])) > DEAL_PRIORITY.index(int(bestOne['source_id']))):
|
| - |
|
250 |
continue
|
| - |
|
251 |
except:
|
| - |
|
252 |
traceback.print_exc()
|
| - |
|
253 |
|
| 247 |
bestOne = similarItem
|
254 |
bestOne = similarItem
|
| 248 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
255 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
| 249 |
bestSellerPoints = similarItem['bestSellerPoints']
|
256 |
bestSellerPoints = similarItem['bestSellerPoints']
|
| 250 |
else:
|
257 |
else:
|
| 251 |
pass
|
258 |
pass
|
| Line 260... |
Line 267... |
| 260 |
continue
|
267 |
continue
|
| 261 |
if similarItem.get('netPriceAfterCashBack') < prepaidBestPrice:
|
268 |
if similarItem.get('netPriceAfterCashBack') < prepaidBestPrice:
|
| 262 |
prepaidBestOne = similarItem
|
269 |
prepaidBestOne = similarItem
|
| 263 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
270 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
| 264 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
271 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
| 265 |
elif similarItem.get('netPriceAfterCashBack') == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
|
272 |
elif similarItem.get('netPriceAfterCashBack') == prepaidBestPrice:
|
| - |
|
273 |
|
| - |
|
274 |
try:
|
| - |
|
275 |
if (DEAL_PRIORITY.index(int(similarItem['source_id'])) > DEAL_PRIORITY.index(int(bestOne['source_id']))):
|
| - |
|
276 |
continue
|
| - |
|
277 |
except:
|
| - |
|
278 |
traceback.print_exc()
|
| - |
|
279 |
|
| 266 |
prepaidBestOne = similarItem
|
280 |
prepaidBestOne = similarItem
|
| 267 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
281 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
| 268 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
282 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
| 269 |
else:
|
283 |
else:
|
| 270 |
pass
|
284 |
pass
|