| Line 1... |
Line 1... |
| 1 |
import pymongo
|
1 |
import pymongo
|
| 2 |
from dtr.utils.utils import to_java_date, getNlcPoints
|
2 |
from dtr.utils.utils import to_java_date, getNlcPoints, DEAL_PRIORITY
|
| 3 |
from datetime import datetime, timedelta
|
3 |
from datetime import datetime, timedelta
|
| 4 |
from operator import itemgetter
|
4 |
from operator import itemgetter
|
| 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
|
| Line 210... |
Line 210... |
| 210 |
continue
|
210 |
continue
|
| 211 |
if similarItem.get('netPriceAfterCashBack') < bestPrice:
|
211 |
if similarItem.get('netPriceAfterCashBack') < bestPrice:
|
| 212 |
bestOne = similarItem
|
212 |
bestOne = similarItem
|
| 213 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
213 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
| 214 |
bestSellerPoints = similarItem['bestSellerPoints']
|
214 |
bestSellerPoints = similarItem['bestSellerPoints']
|
| 215 |
elif similarItem.get('netPriceAfterCashBack') == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
|
215 |
elif similarItem.get('netPriceAfterCashBack') == bestPrice:
|
| - |
|
216 |
|
| - |
|
217 |
try:
|
| - |
|
218 |
if (DEAL_PRIORITY.index(int(similarItem['source_id'])) > DEAL_PRIORITY.index(int(bestOne['source_id']))):
|
| - |
|
219 |
continue
|
| - |
|
220 |
except:
|
| - |
|
221 |
traceback.print_exc()
|
| - |
|
222 |
|
| 216 |
bestOne = similarItem
|
223 |
bestOne = similarItem
|
| 217 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
224 |
bestPrice = similarItem.get('netPriceAfterCashBack')
|
| 218 |
bestSellerPoints = similarItem['bestSellerPoints']
|
225 |
bestSellerPoints = similarItem['bestSellerPoints']
|
| 219 |
else:
|
226 |
else:
|
| 220 |
pass
|
227 |
pass
|
| Line 229... |
Line 236... |
| 229 |
continue
|
236 |
continue
|
| 230 |
if similarItem.get('netPriceAfterCashBack') < prepaidBestPrice:
|
237 |
if similarItem.get('netPriceAfterCashBack') < prepaidBestPrice:
|
| 231 |
prepaidBestOne = similarItem
|
238 |
prepaidBestOne = similarItem
|
| 232 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
239 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
| 233 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
240 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
| 234 |
elif similarItem.get('netPriceAfterCashBack') == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
|
241 |
elif similarItem.get('netPriceAfterCashBack') == prepaidBestPrice:
|
| - |
|
242 |
|
| - |
|
243 |
try:
|
| - |
|
244 |
if (DEAL_PRIORITY.index(int(similarItem['source_id'])) > DEAL_PRIORITY.index(int(bestOne['source_id']))):
|
| - |
|
245 |
continue
|
| - |
|
246 |
except:
|
| - |
|
247 |
traceback.print_exc()
|
| - |
|
248 |
|
| 235 |
prepaidBestOne = similarItem
|
249 |
prepaidBestOne = similarItem
|
| 236 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
250 |
prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
|
| 237 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
251 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
| 238 |
else:
|
252 |
else:
|
| 239 |
pass
|
253 |
pass
|