| Line 2... |
Line 2... |
| 2 |
Created on Jan 15, 2015
|
2 |
Created on Jan 15, 2015
|
| 3 |
|
3 |
|
| 4 |
@author: amit
|
4 |
@author: amit
|
| 5 |
'''
|
5 |
'''
|
| 6 |
from datetime import datetime
|
6 |
from datetime import datetime
|
| 7 |
from dtr.config import PythonPropertyReader
|
7 |
from dtr.config import PythonPropertyReader, PythonPropertyReader
|
| 8 |
import time
|
- |
|
| 9 |
from pprint import pprint
|
8 |
from pprint import pprint
|
| 10 |
from pymongo.mongo_client import MongoClient
|
9 |
from pymongo.mongo_client import MongoClient
|
| - |
|
10 |
import base64
|
| 11 |
import importlib
|
11 |
import importlib
|
| 12 |
import json
|
12 |
import json
|
| 13 |
import math
|
13 |
import math
|
| 14 |
import mechanize
|
14 |
import mechanize
|
| - |
|
15 |
import time
|
| 15 |
import traceback
|
16 |
import traceback
|
| 16 |
import urllib
|
17 |
import urllib
|
| 17 |
import urllib2
|
18 |
import urllib2
|
| 18 |
from dtr.config import PythonPropertyReader
|
- |
|
| 19 |
sourceMap = {1:"amazon", 2:"flipkart", 3:"snapdeal", 4:"spice", 5:"homeshop18"}
|
19 |
sourceMap = {1:"amazon", 2:"flipkart", 3:"snapdeal", 4:"spice", 5:"homeshop18"}
|
| 20 |
headers = {
|
20 |
headers = {
|
| 21 |
'User-agent':'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11',
|
21 |
'User-agent':'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11',
|
| 22 |
'Accept' : 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
|
22 |
'Accept' : 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
|
| 23 |
'Accept-Language' : 'en-US,en;q=0.8',
|
23 |
'Accept-Language' : 'en-US,en;q=0.8',
|
| Line 209... |
Line 209... |
| 209 |
else:
|
209 |
else:
|
| 210 |
tprint("Error Occurred while running batch. Rolling Back")
|
210 |
tprint("Error Occurred while running batch. Rolling Back")
|
| 211 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_APPROVED}}, multi=True)
|
211 |
client.Dtr.merchantOrder.update({'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS},{'$set':{'subOrders.$.cashBackStatus':Store.CB_APPROVED}}, multi=True)
|
| 212 |
|
212 |
|
| 213 |
def refundToWallet(batchId, userAmountMap):
|
213 |
def refundToWallet(batchId, userAmountMap):
|
| - |
|
214 |
|
| - |
|
215 |
base64string = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
|
| 214 |
batchUpdateMap = {}
|
216 |
batchUpdateMap = {}
|
| 215 |
try :
|
217 |
try :
|
| 216 |
saholicUserAmountMap = {}
|
218 |
saholicUserAmountMap = {}
|
| 217 |
for key, value in userAmountMap.iteritems():
|
219 |
for key, value in userAmountMap.iteritems():
|
| 218 |
userLookupRequest = urllib2.Request(USER_LOOKUP_URL %(key), headers=headers)
|
220 |
userLookupRequest = urllib2.Request(USER_LOOKUP_URL %(key), headers=headers)
|
| - |
|
221 |
userLookupRequest.add_header("Authorization", "Basic %s" % base64string)
|
| 219 |
try:
|
222 |
try:
|
| 220 |
response = urllib2.urlopen(userLookupRequest).read()
|
223 |
response = urllib2.urlopen(userLookupRequest).read()
|
| 221 |
saholicUserId = json.loads(response)['account_key']
|
224 |
saholicUserId = json.loads(response)['account_key']
|
| 222 |
saholicUserAmountMap[saholicUserId] = value
|
225 |
saholicUserAmountMap[saholicUserId] = value
|
| 223 |
except:
|
226 |
except:
|