| Line 662... |
Line 662... |
| 662 |
mc.delete(userId)
|
662 |
mc.delete(userId)
|
| 663 |
return {1:'Cache cleared.'}
|
663 |
return {1:'Cache cleared.'}
|
| 664 |
except:
|
664 |
except:
|
| 665 |
return {0:'Unable to clear cache.'}
|
665 |
return {0:'Unable to clear cache.'}
|
| 666 |
|
666 |
|
| 667 |
def updateCollection(data):
|
667 |
def updateCollection(data, multi):
|
| 668 |
print data
|
668 |
print data
|
| - |
|
669 |
if multi!=1:
|
| 669 |
try:
|
670 |
try:
|
| 670 |
collection = get_mongo_connection().Catalog[data['class']]
|
671 |
collection = get_mongo_connection().Catalog[data['class']]
|
| 671 |
class_name = data.pop('class')
|
672 |
class_name = data.pop('class')
|
| 672 |
if class_name == "SkuSchemeDetails":
|
673 |
if class_name == "SkuSchemeDetails":
|
| 673 |
data['addedOn'] = to_java_date(datetime.now())
|
674 |
data['addedOn'] = to_java_date(datetime.now())
|
| 674 |
_id = data.pop('oid')
|
675 |
_id = data.pop('oid')
|
| 675 |
result = collection.update({'_id':ObjectId(_id)},{"$set":data},upsert=False, multi = False)
|
676 |
result = collection.update({'_id':ObjectId(_id)},{"$set":data},upsert=False, multi = False)
|
| 676 |
record = list(collection.find({'_id':ObjectId(_id)}))
|
677 |
record = list(collection.find({'_id':ObjectId(_id)}))
|
| 677 |
if class_name !="CategoryDiscount":
|
678 |
if class_name !="CategoryDiscount":
|
| 678 |
get_mongo_connection().Catalog.MasterData.update({'_id':record[0]['sku']},{"$set":{'updatedOn':to_java_date(datetime.now())}})
|
679 |
get_mongo_connection().Catalog.MasterData.update({'_id':record[0]['sku']},{"$set":{'updatedOn':to_java_date(datetime.now())}})
|
| 679 |
else:
|
680 |
else:
|
| 680 |
get_mongo_connection().Catalog.MasterData.update({'brand':re.compile(record[0]['brand'], re.IGNORECASE),'category_id':record[0]['category_id']}, \
|
681 |
get_mongo_connection().Catalog.MasterData.update({'brand':re.compile(record[0]['brand'], re.IGNORECASE),'category_id':record[0]['category_id']}, \
|
| 681 |
{"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
|
682 |
{"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
|
| 682 |
return {1:"Data updated successfully"}
|
683 |
return {1:"Data updated successfully"}
|
| 683 |
except Exception as e:
|
684 |
except Exception as e:
|
| 684 |
print e
|
685 |
print e
|
| 685 |
return {0:"Data not updated."}
|
686 |
return {0:"Data not updated."}
|
| - |
|
687 |
else:
|
| - |
|
688 |
try:
|
| - |
|
689 |
collection = get_mongo_connection().Catalog[data['class']]
|
| - |
|
690 |
class_name = data.pop('class')
|
| - |
|
691 |
_id = data.pop('oid')
|
| - |
|
692 |
record = list(collection.find({'_id':ObjectId(_id)}))
|
| - |
|
693 |
skuIds = __getBundledSkusfromSku(record[0]['sku'])
|
| - |
|
694 |
for sku in skuIds:
|
| - |
|
695 |
if class_name == "SkuSchemeDetails":
|
| - |
|
696 |
data['addedOn'] = to_java_date(datetime.now())
|
| - |
|
697 |
data['sku'] = sku
|
| - |
|
698 |
data.pop('_id',None)
|
| - |
|
699 |
collection.update({'sku':data['sku']},{"$set":data},upsert=True,multi=False)
|
| - |
|
700 |
get_mongo_connection().Catalog.MasterData.update({'skuBundleId':sku.get('skuBundleId')},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
|
| - |
|
701 |
return {1:"Data added successfully"}
|
| - |
|
702 |
except Exception as e:
|
| - |
|
703 |
print e
|
| - |
|
704 |
return {0:"Data not updated."}
|
| - |
|
705 |
|
| 686 |
|
706 |
|
| 687 |
def addNegativeDeals(data, multi):
|
707 |
def addNegativeDeals(data, multi):
|
| 688 |
if multi !=1:
|
708 |
if multi !=1:
|
| 689 |
collection = get_mongo_connection().Catalog.NegativeDeals
|
709 |
collection = get_mongo_connection().Catalog.NegativeDeals
|
| 690 |
cursor = collection.find({"sku":data['sku']})
|
710 |
cursor = collection.find({"sku":data['sku']})
|