| Line 3... |
Line 3... |
| 3 |
|
3 |
|
| 4 |
@author: amit
|
4 |
@author: amit
|
| 5 |
'''
|
5 |
'''
|
| 6 |
from datetime import datetime, timedelta
|
6 |
from datetime import datetime, timedelta
|
| 7 |
from dtr.config import PythonPropertyReader
|
7 |
from dtr.config import PythonPropertyReader
|
| 8 |
from dtr.storage.Mongo import getDealRank
|
8 |
from dtr.storage.Mongo import getDealRank,userLookUpForSaholicId
|
| 9 |
from dtr.storage.Mysql import getOrdersAfterDate1, getOrdersAfterDate
|
9 |
from dtr.storage.Mysql import getOrdersAfterDate1, getOrdersAfterDate
|
| 10 |
from pprint import pprint
|
10 |
from pprint import pprint
|
| 11 |
from pymongo.mongo_client import MongoClient
|
11 |
from pymongo.mongo_client import MongoClient
|
| 12 |
import base64
|
12 |
import base64
|
| 13 |
import importlib
|
13 |
import importlib
|
| Line 338... |
Line 338... |
| 338 |
for refund in client.Dtr.refund.find():
|
338 |
for refund in client.Dtr.refund.find():
|
| 339 |
print "%s\t%s\t%s\t%s"%(refund.get("userId") ,refund.get("timestamp") ,refund.get("userAmount"), refund.get("batch"))
|
339 |
print "%s\t%s\t%s\t%s"%(refund.get("userId") ,refund.get("timestamp") ,refund.get("userAmount"), refund.get("batch"))
|
| 340 |
|
340 |
|
| 341 |
|
341 |
|
| 342 |
def refundToWallet(batchId, userAmountMap):
|
342 |
def refundToWallet(batchId, userAmountMap):
|
| 343 |
base64string = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
|
343 |
#base64string = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
|
| 344 |
batchUpdateMap = {}
|
344 |
batchUpdateMap = {}
|
| 345 |
try :
|
345 |
try :
|
| 346 |
saholicUserAmountMap = {}
|
346 |
saholicUserAmountMap = {}
|
| 347 |
for key, value in userAmountMap.iteritems():
|
347 |
for key, value in userAmountMap.iteritems():
|
| 348 |
userLookupRequest = urllib2.Request(USER_LOOKUP_URL %(key), headers=headers)
|
348 |
#userLookupRequest = urllib2.Request(USER_LOOKUP_URL %(key), headers=headers)
|
| 349 |
userLookupRequest.add_header("Authorization", "Basic %s" % base64string)
|
349 |
#userLookupRequest.add_header("Authorization", "Basic %s" % base64string)
|
| 350 |
try:
|
350 |
try:
|
| 351 |
response = urllib2.urlopen(userLookupRequest).read()
|
351 |
#response = urllib2.urlopen(userLookupRequest).read()
|
| 352 |
saholicUserId = json.loads(response)['account_key']
|
352 |
#saholicUserId = json.loads(response)['account_key']
|
| - |
|
353 |
saholicUserId = userLookUpForSaholicId(key)
|
| - |
|
354 |
if saholicUserId is not 'User Not present in profitmandi':
|
| 353 |
saholicUserAmountMap[saholicUserId] = value
|
355 |
saholicUserAmountMap[saholicUserId] = value
|
| - |
|
356 |
else:
|
| - |
|
357 |
raise Exception('User Not present in dtr')
|
| 354 |
except:
|
358 |
except:
|
| 355 |
traceback.print_exc()
|
359 |
traceback.print_exc()
|
| 356 |
tprint("Could not fetch saholic id for user : " + str(key))
|
360 |
tprint("Could not fetch saholic id for user : " + str(key))
|
| 357 |
continue
|
361 |
continue
|
| 358 |
if len(saholicUserAmountMap) > 0:
|
362 |
if len(saholicUserAmountMap) > 0:
|