| Line 895... |
Line 895... |
| 895 |
val['skuBundleId'] = ""
|
895 |
val['skuBundleId'] = ""
|
| 896 |
data.append(val)
|
896 |
data.append(val)
|
| 897 |
return data
|
897 |
return data
|
| 898 |
|
898 |
|
| 899 |
def addNewItem(data):
|
899 |
def addNewItem(data):
|
| - |
|
900 |
try:
|
| 900 |
data['updatedOn'] = to_java_date(datetime.now())
|
901 |
data['updatedOn'] = to_java_date(datetime.now())
|
| 901 |
data['addedOn'] = to_java_date(datetime.now())
|
902 |
data['addedOn'] = to_java_date(datetime.now())
|
| 902 |
data['priceUpdatedOn'] = to_java_date(datetime.now())
|
903 |
data['priceUpdatedOn'] = to_java_date(datetime.now())
|
| 903 |
max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
|
904 |
max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
|
| 904 |
max_bundle = list(get_mongo_connection().Catalog.MasterData.find().sort([('skuBundleId',pymongo.DESCENDING)]).limit(1))
|
905 |
max_bundle = list(get_mongo_connection().Catalog.MasterData.find().sort([('skuBundleId',pymongo.DESCENDING)]).limit(1))
|
| 905 |
data['_id'] = max_id[0]['_id'] + 1
|
906 |
data['_id'] = max_id[0]['_id'] + 1
|
| 906 |
data['skuBundleId'] = max_bundle[0]['skuBundleId'] + 1
|
907 |
data['skuBundleId'] = max_bundle[0]['skuBundleId'] + 1
|
| - |
|
908 |
data['identifier'] = str(data['identifier'])
|
| - |
|
909 |
data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
|
| 907 |
get_mongo_connection().Catalog.MasterData.insert(data)
|
910 |
get_mongo_connection().Catalog.MasterData.insert(data)
|
| 908 |
return {1:'Data added successfully'}
|
911 |
return {1:'Data added successfully'}
|
| - |
|
912 |
except Exception as e:
|
| - |
|
913 |
print e
|
| - |
|
914 |
return {0:'Unable to add data.'}
|
| 909 |
|
915 |
|
| 910 |
def addItemToExistingBundle(data):
|
916 |
def addItemToExistingBundle(data):
|
| 911 |
try:
|
917 |
try:
|
| 912 |
data['updatedOn'] = to_java_date(datetime.now())
|
918 |
data['updatedOn'] = to_java_date(datetime.now())
|
| 913 |
data['addedOn'] = to_java_date(datetime.now())
|
919 |
data['addedOn'] = to_java_date(datetime.now())
|
| 914 |
data['priceUpdatedOn'] = to_java_date(datetime.now())
|
920 |
data['priceUpdatedOn'] = to_java_date(datetime.now())
|
| 915 |
max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
|
921 |
max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
|
| 916 |
data['_id'] = max_id[0]['_id'] + 1
|
922 |
data['_id'] = max_id[0]['_id'] + 1
|
| - |
|
923 |
data['identifier'] = str(data['identifier'])
|
| - |
|
924 |
data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
|
| 917 |
get_mongo_connection().Catalog.MasterData.insert(data)
|
925 |
get_mongo_connection().Catalog.MasterData.insert(data)
|
| 918 |
return {1:'Data added successfully.'}
|
926 |
return {1:'Data added successfully.'}
|
| - |
|
927 |
except Exception as e:
|
| 919 |
except:
|
928 |
print e
|
| 920 |
return {0:'Unable to add data.'}
|
929 |
return {0:'Unable to add data.'}
|
| 921 |
|
930 |
|
| 922 |
def updateMaster(data, multi):
|
931 |
def updateMaster(data, multi):
|
| 923 |
if multi != 1:
|
932 |
if multi != 1:
|
| 924 |
_id = data.pop('_id')
|
933 |
_id = data.pop('_id')
|
| 925 |
skuBundleId = data.pop('skuBundleId')
|
934 |
skuBundleId = data.pop('skuBundleId')
|
| 926 |
data['updatedOn'] = to_java_date(datetime.now())
|
935 |
data['updatedOn'] = to_java_date(datetime.now())
|
| 927 |
get_mongo_connection().MasterData.Catalog.update({'_id':_id},{"$set":data})
|
936 |
get_mongo_connection().MasterData.Catalog.update({'_id':_id},{"$set":data},upsert=False)
|
| 928 |
else:
|
937 |
else:
|
| - |
|
938 |
_id = data.pop('_id')
|
| 929 |
skuBundleId = data.pop('skuBundleId')
|
939 |
skuBundleId = data.pop('skuBundleId')
|
| - |
|
940 |
get_mongo_connection().MasterData.Catalog.update({'_id':_id},{"$set":data},upsert=False)
|
| 930 |
similarItems = get_mongo_connection().MasterData.find({'skuBundleId':skuBundleId})
|
941 |
similarItems = get_mongo_connection().MasterData.find({'skuBundleId':skuBundleId})
|
| 931 |
for item in similarItems:
|
942 |
for item in similarItems:
|
| - |
|
943 |
if item['_id'] == data['_id']:
|
| - |
|
944 |
continue
|
| 932 |
item['updatedOn'] = to_java_date(datetime.now())
|
945 |
item['updatedOn'] = to_java_date(datetime.now())
|
| 933 |
item['thumbnail'] = data['thumbnail']
|
946 |
item['thumbnail'] = data['thumbnail']
|
| 934 |
item['category'] = data['category']
|
947 |
item['category'] = data['category']
|
| 935 |
item['category_id'] = data['category_id']
|
948 |
item['category_id'] = data['category_id']
|
| 936 |
item['tagline'] = data['tagline']
|
949 |
item['tagline'] = data['tagline']
|
| 937 |
item['is_shortage'] = data['is_shortage']
|
950 |
item['is_shortage'] = data['is_shortage']
|
| 938 |
item['mrp'] = data['mrp']
|
951 |
item['mrp'] = data['mrp']
|
| 939 |
get_mongo_connection().MasterData.Catalog.update({'_id':item['_id']},{"$set":item})
|
952 |
get_mongo_connection().MasterData.Catalog.update({'_id':item['_id']},{"$set":item},upsert=False)
|
| 940 |
|
953 |
|
| 941 |
|
954 |
|
| 942 |
|
955 |
|
| 943 |
|
956 |
|
| 944 |
|
957 |
|