| Line 8... |
Line 8... |
| 8 |
from dtr.storage.MemCache import MemCache
|
8 |
from dtr.storage.MemCache import MemCache
|
| 9 |
from dtr.utils.utils import to_java_date
|
9 |
from dtr.utils.utils import to_java_date
|
| 10 |
from elixir import *
|
10 |
from elixir import *
|
| 11 |
from operator import itemgetter
|
11 |
from operator import itemgetter
|
| 12 |
import pymongo
|
12 |
import pymongo
|
| - |
|
13 |
import re
|
| 13 |
|
14 |
|
| 14 |
con = None
|
15 |
con = None
|
| 15 |
cashBackMap = {}
|
16 |
cashBackMap = {}
|
| 16 |
itemCashBackMap = {}
|
17 |
itemCashBackMap = {}
|
| 17 |
|
18 |
|
| Line 365... |
Line 366... |
| 365 |
for d in sorted_deals[offset:offset+limit]:
|
366 |
for d in sorted_deals[offset:offset+limit]:
|
| 366 |
item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
|
367 |
item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
|
| 367 |
if not dealsMap.has_key(item[0]['identifier']):
|
368 |
if not dealsMap.has_key(item[0]['identifier']):
|
| 368 |
item[0]['dealRank'] = rank
|
369 |
item[0]['dealRank'] = rank
|
| 369 |
item[0]['persPoints'] = d['persPoints']
|
370 |
item[0]['persPoints'] = d['persPoints']
|
| - |
|
371 |
if d['dealType'] == 1 and d['source_id'] ==1:
|
| - |
|
372 |
item[0]['marketPlaceUrl'] = "http://www.amazon.in/dp/%s"%(item[0]['identifier'].strip())
|
| 370 |
try:
|
373 |
try:
|
| 371 |
cashBack = __getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
|
374 |
cashBack = __getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
|
| 372 |
if not cashBack or cashBack.get('cash_back_status')!=1:
|
375 |
if not cashBack or cashBack.get('cash_back_status')!=1:
|
| 373 |
item[0]['cash_back_type'] = 0
|
376 |
item[0]['cash_back_type'] = 0
|
| 374 |
item[0]['cash_back'] = 0
|
377 |
item[0]['cash_back'] = 0
|
| Line 559... |
Line 562... |
| 559 |
|
562 |
|
| 560 |
def updateCollection(data):
|
563 |
def updateCollection(data):
|
| 561 |
print data
|
564 |
print data
|
| 562 |
try:
|
565 |
try:
|
| 563 |
collection = get_mongo_connection().Catalog[data['class']]
|
566 |
collection = get_mongo_connection().Catalog[data['class']]
|
| 564 |
data.pop('class')
|
567 |
class_name = data.pop('class')
|
| - |
|
568 |
if class_name == "SkuSchemeDetails":
|
| - |
|
569 |
data['addedOn'] = to_java_date(datetime.now())
|
| 565 |
_id = data.pop('oid')
|
570 |
_id = data.pop('oid')
|
| 566 |
result = collection.update({'_id':ObjectId(_id)},{"$set":data},upsert=False, multi = False)
|
571 |
result = collection.update({'_id':ObjectId(_id)},{"$set":data},upsert=False, multi = False)
|
| - |
|
572 |
record = collection.find({'_id':ObjectId(_id)})
|
| - |
|
573 |
if class_name !="CategoryDiscount":
|
| - |
|
574 |
get_mongo_connection().Catalog.MasterData.update({'_id':record['sku']},{"$set":{'updatedOn':to_java_date(datetime.now())}})
|
| 567 |
print result
|
575 |
else:
|
| 568 |
#get_mongo_connection().Catalog.MasterData.update({'brand':data['brand'],'category_id':data['category_id']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
|
576 |
get_mongo_connection().Catalog.MasterData.update({'brand':re.compile(record['brand'], re.IGNORECASE),'category_id':record['category_id']}, \
|
| - |
|
577 |
{"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
|
| 569 |
return {1:"Data updated successfully"}
|
578 |
return {1:"Data updated successfully"}
|
| 570 |
except:
|
579 |
except:
|
| 571 |
return {0:"Data not updated."}
|
580 |
return {0:"Data not updated."}
|
| 572 |
|
581 |
|
| 573 |
|
582 |
|