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