| Line 212... |
Line 212... |
| 212 |
updateMap['subOrders.$.missingAff'] = True
|
212 |
updateMap['subOrders.$.missingAff'] = True
|
| 213 |
self.db.merchantOrder.update(searchMap, { '$set': updateMap }, multi=True)
|
213 |
self.db.merchantOrder.update(searchMap, { '$set': updateMap }, multi=True)
|
| 214 |
|
214 |
|
| 215 |
def _getActiveOrders(self, searchMap={}, collectionMap={}):
|
215 |
def _getActiveOrders(self, searchMap={}, collectionMap={}):
|
| 216 |
collection = self.db.merchantOrder
|
216 |
collection = self.db.merchantOrder
|
| 217 |
searchMap = dict(searchMap.items()+ {"closed": False, "storeId" : self.store_id}.items())
|
217 |
searchMap = dict(searchMap.items()+ {"subOrders.closed": False, "storeId" : self.store_id}.items())
|
| 218 |
collectionMap = dict(collectionMap.items() + {"orderSuccessUrl":1, "orderId":1,"subOrders":1, "placedOn":1}.items())
|
218 |
collectionMap = dict(collectionMap.items() + {"orderSuccessUrl":1, "orderId":1,"subOrders":1, "placedOn":1}.items())
|
| 219 |
stores = collection.find(searchMap, collectionMap)
|
219 |
stores = collection.find(searchMap, collectionMap)
|
| 220 |
return [store for store in stores]
|
220 |
return [store for store in stores]
|
| 221 |
|
221 |
|
| 222 |
def _getMissingOrders(self,searchMap={}):
|
222 |
def _getMissingOrders(self,searchMap={}):
|
| Line 291... |
Line 291... |
| 291 |
if refundToWallet(batchId, userAmountMap):
|
291 |
if refundToWallet(batchId, userAmountMap):
|
| 292 |
bulk = client.Dtr.merchantOrder.initialize_ordered_bulk_op()
|
292 |
bulk = client.Dtr.merchantOrder.initialize_ordered_bulk_op()
|
| 293 |
for searchMap in searchMapList:
|
293 |
for searchMap in searchMapList:
|
| 294 |
bulk.find(searchMap).update({'$set' : {'subOrders.$.cashBackStatus':Store.CB_CREDITED, "subOrders.$.batchId":batchId}})
|
294 |
bulk.find(searchMap).update({'$set' : {'subOrders.$.cashBackStatus':Store.CB_CREDITED, "subOrders.$.batchId":batchId}})
|
| 295 |
print bulk.execute()
|
295 |
print bulk.execute()
|
| - |
|
296 |
sum=0
|
| - |
|
297 |
creditedSubOrders=0
|
| - |
|
298 |
message = []
|
| 296 |
for key, value in userAmountMap.iteritems():
|
299 |
for key, value in userAmountMap.iteritems():
|
| - |
|
300 |
sum += value
|
| - |
|
301 |
creditedSubOrders += 1
|
| 297 |
client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S"), "type":utils.CREDIT_TYPE_ORDER})
|
302 |
client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S"), "type":utils.CREDIT_TYPE_ORDER})
|
| 298 |
client.Dtr.user.update({"userId":key}, {"$inc": { "credited": value, utils.CREDIT_TYPE_ORDER:value}}, upsert=True)
|
303 |
client.Dtr.user.update({"userId":key}, {"$inc": { "credited": value, utils.CREDIT_TYPE_ORDER:value}}, upsert=True)
|
| - |
|
304 |
message.append("<b>Batch Id - %d</b><br><b>Total Amount Credited - %d</b><br><b>Total SubOrders Credited- %d</b>"%(batchId,sum, creditedSubOrders))
|
| - |
|
305 |
utils.sendmail(['amit.gupta@shop2020.in', 'rajneesh.arora@saholic.com'], "".join(message), 'Cashback for Order Credited Successfully')
|
| 299 |
tprint("PayBack Settled")
|
306 |
tprint("PayBack Settled")
|
| 300 |
else:
|
307 |
else:
|
| 301 |
tprint("Error Occurred while running batch. Rolling Back")
|
308 |
tprint("Error Occurred while running batch. Rolling Back")
|
| 302 |
bulk = client.Dtr.merchantOrder.initialize_ordered_bulk_op()
|
309 |
bulk = client.Dtr.merchantOrder.initialize_ordered_bulk_op()
|
| 303 |
for searchMap in searchMapList:
|
310 |
for searchMap in searchMapList:
|