| Line 182... |
Line 182... |
| 182 |
userAmountMap[res['_id']] = res['amount']
|
182 |
userAmountMap[res['_id']] = res['amount']
|
| 183 |
datetimeNow = datetime.now()
|
183 |
datetimeNow = datetime.now()
|
| 184 |
batchId = int(time.mktime(datetimeNow.timetuple()))
|
184 |
batchId = int(time.mktime(datetimeNow.timetuple()))
|
| 185 |
if refundToWallet(batchId, userAmountMap):
|
185 |
if refundToWallet(batchId, userAmountMap):
|
| 186 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_CREDITED, 'subOrders.$.batchId':batchId}}, multi=True)
|
186 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_CREDITED, 'subOrders.$.batchId':batchId}}, multi=True)
|
| 187 |
for key, value in userAmountMap:
|
187 |
for key, value in userAmountMap.iteritems():
|
| 188 |
client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S")})
|
188 |
client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S")})
|
| 189 |
client.Dtr.user.update({"userId":key}, {'$inc': { "credited": value}}, upsert=True)
|
189 |
client.Dtr.user.update({"userId":key}, {'$inc': { "credited": value}}, upsert=True)
|
| 190 |
else:
|
190 |
else:
|
| 191 |
tprint("Error Occurred while running batch. Rolling Back")
|
191 |
tprint("Error Occurred while running batch. Rolling Back")
|
| 192 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_APPROVED}}, multi=True)
|
192 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_APPROVED}}, multi=True)
|