Subversion Repositories SmartDukaan

Rev

Rev 16111 | Rev 16120 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
15509 manish.sha 1
'''
2
Created on Jan 15, 2015
3
 
4
@author: Manish 
5
'''
6
from bs4 import BeautifulSoup
7
from bson.binary import Binary
8
from datetime import datetime, date, timedelta
9
from dtr import main
15791 manish.sha 10
from dtr.dao import AffiliateInfo, Order, SubOrder, ShopCluesAffiliateInfo
15509 manish.sha 11
from dtr.main import getBrowserObject, ScrapeException, getStore, ParseException, \
12
    Store as MStore, ungzipResponse, tprint
13
from dtr.storage import Mongo
14
from dtr.storage.Mongo import getImgSrc
15
from dtr.utils.utils import fetchResponseUsingProxy
16
from pprint import pprint
17
from pymongo import MongoClient
18
import json
19
import pymongo
20
import re
21
import time
22
import traceback
23
import urllib
15791 manish.sha 24
import urllib2
15509 manish.sha 25
from urlparse import urlparse, parse_qs
15791 manish.sha 26
import xml.etree.ElementTree as ET
27
from dtr.storage import MemCache
16097 manish.sha 28
from dtr.storage.Mongo import getDealRank
15509 manish.sha 29
 
30
USERNAME='profittill2@gmail.com'
31
PASSWORD='spice@2020'
15791 manish.sha 32
AFFLIATE_TRASACTIONS_URL = "https://admin.optimisemedia.com/v2/reports/affiliate/leads/leadsummaryexport.aspx?Contact=796881&Country=26&Agency=95&Merchant=420562&Status=-1&Year=%d&Month=%d&Day=%d&EndYear=%d&EndMonth=%d&EndDay=%d&DateType=0&Sort=CompletionDate&Login=1347562DA5E3EFF6FB1561765C47C782&Format=XML&RestrictURL=0"
15509 manish.sha 33
ORDER_TRACK_URL='http://www.shopclues.com/index.php?dispatch=order_lookup.details'
15791 manish.sha 34
ORDER_TRACK_URL_DB='https://sm.shopclues.com/trackOrder?'
15509 manish.sha 35
BASE_URL= 'http://www.shopclues.com'
36
BASE_MURL= 'http://m.shopclues.com'
37
 
38
class Store(MStore):
39
 
40
    '''
41
    This is to map order statuses of our system to order statuses of snapdeal.
42
    And our statuses will change accordingly.
43
 
44
    '''
45
    OrderStatusMap = {
46
                      MStore.ORDER_PLACED : ['payment successful', 'new order - cod confirmation pending', 'processing', 'quality check','on schedule', 'processing - pickup-initiated', 'processing - ready to dispatch'],
47
                      MStore.ORDER_DELIVERED : ['delivered', 'complete'],
48
                      MStore.ORDER_SHIPPED : ['in transit', 'dispatched','shipped','order handed to courier'],
49
                      MStore.ORDER_CANCELLED : ['payment failed', 'canceled', 'payment declined', 'order on hold - cancellation requested by customer', 'courier returned']
50
                      }
51
    OrderStatusConfirmationMap= {
15791 manish.sha 52
                                 "P" : "Payment Successful",
53
                                 "D" : "Order Declined",
54
                                 "O" : "New Order - COD confirmation Pending"
15509 manish.sha 55
                                 }
56
 
57
    CONF_CB_AMOUNT = MStore.CONF_CB_DISCOUNTED_PRICE
58
 
16111 manish.sha 59
    def __init__(self,store_id):
60
        super(Store, self).__init__(store_id)
61
 
15791 manish.sha 62
    def convertToObj(self,offer):
63
        orderRef = offer['TransactionId']
64
        orderRef = orderRef[0:len(orderRef)-10]
65
        offer1 = ShopCluesAffiliateInfo(offer['UID'], offer['TransactionTime'], offer['TransactionId'], orderRef,  offer['MerchantRef'], offer['Merchant'], offer['PID'], offer['Product'], float(str(offer['SR'])), float(str(offer['TransactionValue'])), offer['UKey'], offer['ClickTime'], offer['Status'])
66
        return offer1
67
 
68
    def _saveToAffiliate(self, offers):
69
        collection = self.db.shopcluesOrderAffiliateInfo
70
        mcollection = self.db.merchantOrder
71
        for offerObj in offers:
72
            offer = self.convertToObj(offerObj)
73
            collection.update({"transactionId":offer.transactionId, "subTagId":offer.subTagId, "payOut":offer.payOut},{"$set":todict(offer)}, upsert=True)
74
            mcollection.update({"subTagId":offer.subTagId, "storeId":self.store_id, "subOrders.missingAff":True}, {"$set":{"subOrders.$.missingAff":False}})
75
 
15940 manish.sha 76
    def scrapeAffiliate(self, startDate=datetime.today() - timedelta(days=10), endDate=datetime.today()):
15791 manish.sha 77
        uri = AFFLIATE_TRASACTIONS_URL%(startDate.year,startDate.month,startDate.day,endDate.year,endDate.month,endDate.day)
78
        root = ET.parse(urllib2.urlopen(uri)).getroot()
79
        if len(root)> 0 and len(root[0])> 0:
80
            offers = []
81
            for child in root[0][0]:
82
                offers.append(child.attrib)
83
            self._saveToAffiliate(offers)
84
 
15509 manish.sha 85
    def _setLastSaleDate(self, saleDate):
86
        self.db.lastSaleDtate.update({'storeId':self.store_id}, {'$set':{'saleDate':saleDate}})
87
 
88
    def getName(self):
89
        return "shopclues"    
90
 
91
    def _getLastSaleDate(self,):
92
        lastDaySaleObj = self.db.lastDaySale.find_one({"storeId":self.store_id})
93
        if lastDaySaleObj is None:
94
            return datetime.min
95
 
96
    def _getStatusFromDetailedStatus(self, detailedStatus):
97
        for key, value in Store.OrderStatusMap.iteritems():
98
            if detailedStatus.lower() in value:
99
                return key
100
        print "Detailed Status need to be mapped", detailedStatus, self.store_id
101
        return None
102
 
15791 manish.sha 103
    def _getSingleSubOrderMap(self, orderId, soup, orderObj):
104
        orderStatus = self.OrderStatusConfirmationMap.get(orderObj['0']['status'])
105
        statusTime= soup.findAll(attrs={'class' : 'sts no_mobile'})[1].contents[2].strip()
15509 manish.sha 106
        productDetailsMap = {}
107
        orderTable = soup.body.find("table", {'class':'table product-list'}).findAll('tr', recursive=False)
15791 manish.sha 108
        firstRow = orderTable.pop(0)
15949 manish.sha 109
        totalColumns = len(firstRow.find_all('th'))
15791 manish.sha 110
        jsonSubOrdersMap = {}
111
        count = 1
112
 
113
        for val in orderObj['0']['items'].values():
114
            newCount = 0
16110 manish.sha 115
            counts = []
15791 manish.sha 116
            for key in jsonSubOrdersMap.keys():
117
                splitKey = key.split('-')
16112 manish.sha 118
                if orderObj['0']['is_parent_order'] == 'N':
119
                    if str(val['order_id']) == splitKey[0]:
120
                        counts.append(int(splitKey[1]))
121
                else:
122
                    if str(val['child']) == splitKey[0]:
123
                        counts.append(int(splitKey[1]))
16110 manish.sha 124
 
125
            if len(counts) >0:
126
                newCount = max(counts)
16108 manish.sha 127
            count = newCount +1
16112 manish.sha 128
            if orderObj['0']['is_parent_order'] == 'N':
129
                jsonSubOrdersMap[str(val['order_id'])+'-'+str(count)] = val
130
            else:
131
                jsonSubOrdersMap[str(val['child'])+'-'+str(count)] = val
15791 manish.sha 132
 
16110 manish.sha 133
 
15941 manish.sha 134
        print jsonSubOrdersMap.items()
135
 
15791 manish.sha 136
        count = 1
15509 manish.sha 137
        for orderTr in orderTable:
15791 manish.sha 138
            productDetailsSubMap = None
139
            productDetailsSubMap = {}
15509 manish.sha 140
            cols = orderTr.find_all('td')
141
            product_details = cols[0].find_all('a')
142
            #print product_details
143
            productUrl = product_details[0].get('href')
144
            productName = product_details[0].contents[0].strip()
145
            quantity = int(cols[1].text.strip())
15980 manish.sha 146
            sellingPrice = long(cols[2].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 147
            discount = 0
148
            subtotal = 0
149
            if totalColumns == 5:
15949 manish.sha 150
                if cols[3].text.strip()!='-' and 'Rs.' in cols[3].text.strip():
15980 manish.sha 151
                    discount = long(cols[3].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 152
                else:
153
                    discount = 0
15980 manish.sha 154
                subtotal = long(cols[4].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 155
            else:
15980 manish.sha 156
                subtotal = long(cols[3].text.strip().replace("Rs.","").replace(',',''))
15509 manish.sha 157
            productDetailsSubMap['productUrl']=BASE_MURL+productUrl
158
            productDetailsSubMap['productName']=productName
15791 manish.sha 159
            productDetailsSubMap['subOrderTrackingUrl']=ORDER_TRACK_URL_DB+'order_id=' +str(orderId)+'&email_id='+ orderObj['0']['email']
15509 manish.sha 160
            productDetailsSubMap['sellingPrice']=sellingPrice
161
            productDetailsSubMap['quantity']=quantity
162
            productDetailsSubMap['discount']=discount
163
            productDetailsSubMap['subtotal']=subtotal
15942 manish.sha 164
            key = str(orderId)+'-'+str(count)
165
            print 'SubOrder Map Key--',key
15791 manish.sha 166
            jsonSubOrderDetails = jsonSubOrdersMap.get(str(orderId)+'-'+str(count))
167
            productCode = jsonSubOrderDetails['product_code']
168
            productImgUrl = jsonSubOrderDetails['images']['image_path'][0]
15509 manish.sha 169
            productDetailsSubMap['productCode']=productCode
170
            productDetailsSubMap['imgUrl']=productImgUrl
171
 
15791 manish.sha 172
            productDetailsSubMap['subOrderStatus']=orderStatus
173
            productDetailsSubMap['subOrderStatusTime']=statusTime
174
            productDetailsMap[str(orderId)+'-'+str(count)]=productDetailsSubMap
175
            count = count +1
15509 manish.sha 176
        return productDetailsMap
177
 
15791 manish.sha 178
    def _getMultiSubOrdersMap(self, orderId, soup, orderObj):
15509 manish.sha 179
        orderTable = soup.body.find("table", {'class':'table product-list'}).findAll('tr', recursive=False)
16105 manish.sha 180
        firstRow = orderTable.pop(0)
15791 manish.sha 181
        #totalColumns = len(firstRow.find_all('td'))
15509 manish.sha 182
        productDetailsMap = {}
15791 manish.sha 183
        '''
184
        jsonSubOrdersMap = {}
185
        for val in orderObj['0']['items'].values():
186
            jsonSubOrdersMap[val['order_id']] = val
187
        '''
188
        existingOrders = []
15509 manish.sha 189
        for orderTr in orderTable:
15791 manish.sha 190
            subOrderDetailsMap = {}
191
 
15509 manish.sha 192
            cols = orderTr.find_all('td')
193
            product_details = cols[0].find_all('a')
194
            #print product_details
195
            subOrderId= product_details[1].contents[0].strip()
15791 manish.sha 196
            if subOrderId in existingOrders:
197
                continue
198
            else:
199
                existingOrders.append(subOrderId)
200
            #productUrl = product_details[0].get('href')
201
            #productName = product_details[0].contents[0].strip()
202
            subOrderTrackingParsingUrl = product_details[1].get('href')
203
            #subOrderTrackingUrl = subOrderTrackingParsingUrl.split('order_lookup.details&')[1]
204
            '''
15509 manish.sha 205
            quantity = int(cols[1].text.strip())
206
            sellingPrice = long(cols[2].text.strip().replace("Rs.",""))
15791 manish.sha 207
            discount = 0
208
            subtotal = 0
209
            if totalColumns == 5:
210
                if cols[3].text.strip()!='-' or 'Rs.' in cols[3].text.strip():
211
                    discount = long(cols[3].text.strip().replace("Rs.",""))
212
                else:
213
                    discount = 0                    
214
                subtotal = long(cols[4].text.strip().replace("Rs.",""))
215
            else:
216
                subtotal = long(cols[3].text.strip().replace("Rs.",""))
15509 manish.sha 217
            productDetailsSubMap['productUrl']=BASE_MURL+productUrl
218
            productDetailsSubMap['productName']=productName
15791 manish.sha 219
            productDetailsSubMap['subOrderTrackingUrl']=ORDER_TRACK_URL_DB+subOrderTrackingUrl
15509 manish.sha 220
            productDetailsSubMap['sellingPrice']=sellingPrice
221
            productDetailsSubMap['quantity']=quantity
222
            productDetailsSubMap['discount']=discount
223
            productDetailsSubMap['subtotal']=subtotal
15791 manish.sha 224
            jsonSubOrderDetails = jsonSubOrdersMap.get(subOrderId)
225
            productCode = jsonSubOrderDetails['product_code']
226
            productImgUrl = jsonSubOrderDetails['images']['image_path'][0]
15509 manish.sha 227
            productDetailsSubMap['productCode']=productCode
228
            productDetailsSubMap['imgUrl']=productImgUrl
15791 manish.sha 229
            '''
15509 manish.sha 230
            br1 = getBrowserObject()
16106 manish.sha 231
            orderTrackingPage = br1.open(BASE_URL+subOrderTrackingParsingUrl)
15509 manish.sha 232
            headers = str(orderTrackingPage.info()).split('\n')
233
            orderTrackingPage= ungzipResponse(orderTrackingPage)
234
            jsonResponse = None
235
            for header in headers:
236
                header = header.split(':')
237
                if header[0] == 'Content-Type' and 'json' in header[1]:
238
                    jsonResponse = json.loads(orderTrackingPage)
239
 
240
            orderTrackingPageSoup = None
241
            if jsonResponse is not None:
242
                orderTrackingPageSoup = BeautifulSoup(str(jsonResponse['text']))
243
            else:
244
                orderTrackingPageSoup = BeautifulSoup(orderTrackingPage)
15791 manish.sha 245
            '''
15509 manish.sha 246
            subOrderStatusList = orderTrackingPageSoup.findAll(attrs={'class' : 'price ord_status'})
247
            subOrderStatus = subOrderStatusList[0].contents[0].strip()
248
            subOrderStatusTime= orderTrackingPageSoup.findAll(attrs={'class' : 'sts no_mobile'})[1].contents[2].strip()
249
            productDetailsSubMap['subOrderStatus'] = subOrderStatus
250
            productDetailsSubMap['subOrderStatusTime'] = subOrderStatusTime
251
            productDetailsSubMap['parentOrderId']=orderId
15791 manish.sha 252
            '''
253
 
254
            subOrderDetailsMap = self._getSingleSubOrderMap(subOrderId, orderTrackingPageSoup, orderObj)
15509 manish.sha 255
 
15791 manish.sha 256
            productDetailsMap = dict(productDetailsMap.items()+subOrderDetailsMap.items())
15509 manish.sha 257
 
258
        return productDetailsMap
259
 
260
    def updateCashbackInSubOrders(self, subOrders):
261
        for subOrder in subOrders:
262
            cashbackStatus = Store.CB_NA
263
            cashbackAmount = 0
264
            percentage = 0
265
            amount = subOrder.amountPaid
266
            if amount > 0:
267
                (cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, amount)
268
                if cashbackAmount > 0:
269
                    cashbackStatus = Store.CB_PENDING
270
            subOrder.cashBackStatus = cashbackStatus
271
            subOrder.cashBackAmount = cashbackAmount
272
            subOrder.cashBackPercentage = percentage
273
        return subOrders
274
 
15947 manish.sha 275
    def _parseOrders(self, orderId, mpOrderId, subTagId, userId, page, orderSuccessUrl, orderObj):
15509 manish.sha 276
        soup = BeautifulSoup(page)
277
        productDetailsMap = {}
278
        paymentFields = soup.findAll(attrs={'class' : 'box_paymentcalculations_row'})
279
        orderDateList = soup.findAll(attrs={'class':'price ord_date'})
15948 manish.sha 280
        placedOn= orderDateList[0].text.strip().replace("\t","").replace("\n","").replace("\r","").replace("  ","")
15509 manish.sha 281
        ordersubtotal=0
282
        ordercluebucks=0
283
        ordershippingcost=0
284
        ordertotal=0
285
 
286
        for val in paymentFields:
287
            for value in val.contents:
288
                if value is not None:
289
                    if 'div' in str(value).strip():
290
                        if 'Subtotal' in value.text.strip():
15981 manish.sha 291
                            ordersubtotal = long(val.contents[3].text.strip().replace("Rs.","").replace(',',''))
15509 manish.sha 292
                            print ordersubtotal
293
                        if 'Shipping Cost' in value.text.strip():
15981 manish.sha 294
                            ordershippingcost = long(val.contents[3].text.strip().replace("Rs.","").replace(',',''))
15509 manish.sha 295
                            print ordershippingcost
296
                        if 'Clue' in value.text.strip():
15981 manish.sha 297
                            ordercluebucks = long(val.contents[3].text.strip().replace("Rs.","").replace(',',''))
15509 manish.sha 298
                            print ordercluebucks
299
                        if 'Total' in value.text.strip():
15791 manish.sha 300
                            ordertotal = val.contents[3].text.strip().replace("Rs.","")
301
                            ordertotal = ordertotal.replace(',','')
15509 manish.sha 302
                            print ordertotal
15791 manish.sha 303
 
304
        if orderObj['0']['is_parent_order'] == 'N':
15947 manish.sha 305
            productDetailsMap = self._getSingleSubOrderMap(mpOrderId, soup, orderObj)
15509 manish.sha 306
        else:
15947 manish.sha 307
            productDetailsMap = self._getMultiSubOrdersMap(mpOrderId, soup, orderObj)
15509 manish.sha 308
 
15791 manish.sha 309
        merchantOrder = Order(orderId, userId, subTagId, self.store_id, orderSuccessUrl)
15509 manish.sha 310
        merchantOrder.placedOn = placedOn
15791 manish.sha 311
        merchantOrder.merchantOrderId = orderObj['0']['order_id']
15509 manish.sha 312
        merchantOrder.paidAmount = ordertotal
313
        totalOrdersAmount = 0
314
        totalDiscount = 0
315
        subOrders= []
316
        for key in productDetailsMap:
317
            subOrderDetail = productDetailsMap.get(key)
318
            totalOrdersAmount = totalOrdersAmount  + (subOrderDetail['sellingPrice'] * subOrderDetail['quantity'])
319
            totalDiscount = totalDiscount + (subOrderDetail['discount'] * subOrderDetail['quantity'])
320
            subOrder = SubOrder(subOrderDetail['productName'], subOrderDetail['productUrl'], placedOn, subOrderDetail['subtotal'])
321
            subOrder.merchantSubOrderId = key
322
            subOrder.detailedStatus = subOrderDetail['subOrderStatus']
323
            subOrder.imgUrl = subOrderDetail['imgUrl']
324
            subOrder.offerDiscount = subOrderDetail['discount'] * subOrderDetail['quantity']
325
            subOrder.unitPrice = subOrderDetail['sellingPrice']
326
            subOrder.productCode = subOrderDetail['productCode']
327
            subOrder.amountPaid = subOrderDetail['subtotal']
328
            subOrder.quantity = subOrderDetail['quantity']
15791 manish.sha 329
            subOrder.tracingkUrl = subOrderDetail['subOrderTrackingUrl']
16097 manish.sha 330
            dealRank = getDealRank(subOrder.productCode, self.store_id, merchantOrder.userId)
331
            subOrder.dealRank = dealRank.get('rank')
332
            subOrder.rankDesc = dealRank.get('description')
15509 manish.sha 333
            subOrders.append(subOrder)
334
        print totalOrdersAmount, totalDiscount
335
        merchantOrder.totalAmount = totalOrdersAmount
336
        merchantOrder.discountApplied = totalDiscount
337
        merchantOrder.deliveryCharges = ordershippingcost
338
        merchantOrder.subOrders = self.updateCashbackInSubOrders(subOrders)
339
 
340
        return merchantOrder
341
 
342
    def parseOrderRawHtml(self, orderId, subTagId, userId, rawHtml, orderSuccessUrl):
343
        resp = {}
344
        try:
15791 manish.sha 345
            rawHtmlSoup = BeautifulSoup(rawHtml)
346
            emailId = None
347
            orderObj = None
348
            merchantOrderId = None
349
            for script in rawHtmlSoup.find_all('script'):
350
                if 'orderConfirmation' in script.text:
351
                    orderObj = json.loads(script.text.strip().split('\n')[0].split('orderConfirmation = ')[1].split(';')[0])
352
                    if merchantOrderId is None:
353
                        merchantOrderId = orderObj['0']['order_id']
354
                        emailId = orderObj['0']['email']
355
 
15509 manish.sha 356
            br = getBrowserObject()
15791 manish.sha 357
            url = ORDER_TRACK_URL +'&order_id=' +str(merchantOrderId)+'&email_id='+ emailId
15509 manish.sha 358
            page = br.open(url)
359
            headers = str(page.info()).split('\n')
360
            page = ungzipResponse(page)
361
            jsonResponse = None
362
            for header in headers:
363
                header = header.split(':')
364
                if header[0] == 'Content-Type' and 'json' in header[1]:
365
                    jsonResponse = json.loads(page)
366
            if jsonResponse is not None:
367
                page = jsonResponse['text']
368
 
15947 manish.sha 369
            merchantOrder = self._parseOrders(orderId, merchantOrderId, subTagId, userId, page, orderSuccessUrl, orderObj)
15509 manish.sha 370
 
15948 manish.sha 371
            merchantOrder.orderTrackingUrl = ORDER_TRACK_URL_DB + 'order_id=' +str(merchantOrderId)+'&email_id='+ emailId
15509 manish.sha 372
 
373
            if self._saveToOrder(todict(merchantOrder)):
374
                resp['result'] = 'ORDER_CREATED'
375
            else:
376
                resp['result'] = 'ORDER_ALREADY_CREATED_IGNORED'
377
 
378
            return resp
379
        except:
380
            print "Error occurred"
381
            traceback.print_exc()
382
            resp['result'] = 'ORDER_NOT_CREATED'
383
 
15791 manish.sha 384
    def parseSingleSubOrder(self, soup, emailId, subOrderId):
385
        orderStatusList = soup.findAll(attrs={'class' : 'price ord_status'})
386
        subOrderStatus = orderStatusList[0].contents[0].strip()
15509 manish.sha 387
        orderDateList = soup.findAll(attrs={'class':'price ord_date'})
15948 manish.sha 388
        placedOn= orderDateList[0].text.strip().replace("\t","").replace("\n","").replace("\r","").replace("  ","")    
15509 manish.sha 389
        orderTable = soup.body.find("table", {'class':'table product-list'}).findAll('tr', recursive=False)
15791 manish.sha 390
        firstRow = orderTable.pop(0)
15949 manish.sha 391
        totalColumns = len(firstRow.find_all('th'))
15791 manish.sha 392
        subOrders =[]
393
        count =1   
15509 manish.sha 394
        for orderTr in orderTable:
395
            cols = orderTr.find_all('td')
396
            product_details = cols[0].find_all('a')
397
            #print product_details
398
            productUrl = product_details[0].get('href')
399
            productName = product_details[0].contents[0].strip()
400
            quantity = int(cols[1].text.strip())
15980 manish.sha 401
            sellingPrice = long(cols[2].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 402
            discount = 0
403
            subtotal = 0
404
            if totalColumns == 5:
15949 manish.sha 405
                if cols[3].text.strip()!='-' and 'Rs.' in cols[3].text.strip():
15980 manish.sha 406
                    discount = long(cols[3].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 407
                else:
408
                    discount = 0
15980 manish.sha 409
                subtotal = long(cols[4].text.strip().replace("Rs.","").replace(',',''))
15791 manish.sha 410
            else:
15980 manish.sha 411
                subtotal = long(cols[3].text.strip().replace("Rs.","").replace(',',''))
15509 manish.sha 412
            br = getBrowserObject()
413
            productPage = br.open(BASE_MURL+productUrl)
414
            productPageHeaders = str(productPage.info()).split('\n')
415
            productPage = ungzipResponse(productPage)
416
            jsonProductResponse = None
417
            for header in productPageHeaders:
418
                header = header.split(':')
419
                if header[0] == 'Content-Type' and 'json' in header[1]:
420
                    jsonProductResponse = json.loads(productPage)
421
            productPageSoup= None
422
            if jsonProductResponse is not None:
423
                productPageSoup = BeautifulSoup(jsonProductResponse['text'])
424
            else:
425
                productPageSoup = BeautifulSoup(productPage)
15791 manish.sha 426
            productCode = productPageSoup.find('input', {'type':'hidden'})['value']
15509 manish.sha 427
            allproductImageTags = productPageSoup.findAll(attrs={'class' : 'pd-image'})
428
            productImgUrl = ''
429
            if allproductImageTags is not None and len(allproductImageTags)>0:
430
                productImgUrl= allproductImageTags[0].get('style').split("background:url('")[1].split("')no-repeat center")[0].strip()
431
 
432
            subOrder = SubOrder(productName, productUrl, placedOn, subtotal)
15791 manish.sha 433
            subOrder.merchantSubOrderId = str(subOrderId)+'-'+str(count)
15509 manish.sha 434
            subOrder.detailedStatus = subOrderStatus
435
            subOrder.imgUrl = productImgUrl
436
            subOrder.offerDiscount = discount*quantity
437
            subOrder.unitPrice = sellingPrice
438
            subOrder.productCode = productCode
439
            subOrder.amountPaid = subtotal
440
            subOrder.quantity = quantity
15791 manish.sha 441
            subOrder.tracingkUrl = ORDER_TRACK_URL_DB +  'order_id=' +subOrderId+'&email_id='+ emailId
15509 manish.sha 442
            subOrders.append(subOrder)
15791 manish.sha 443
            count = count +1
15509 manish.sha 444
 
445
        subOrders = self.updateCashbackInSubOrders(subOrders)
15791 manish.sha 446
        return subOrders
15509 manish.sha 447
 
15791 manish.sha 448
    def parseMultiSubOrders(self, soup, emailId):
15509 manish.sha 449
        orderTable = soup.body.find("table", {'class':'table product-list'}).findAll('tr', recursive=False)
15791 manish.sha 450
        '''
451
        firstRow = orderTable.pop(0)
452
        totalColumns = len(firstRow.find_all('td'))
453
 
15509 manish.sha 454
        orderDateList = soup.findAll(attrs={'class':'price ord_date'})
15791 manish.sha 455
        placedOn= orderDateList[0].text.strip().replace("\t","").replace("\n","").replace("  ","")
456
        '''    
15509 manish.sha 457
        subOrders = []
15791 manish.sha 458
        existingOrders = []
15509 manish.sha 459
        for orderTr in orderTable:
460
            cols = orderTr.find_all('td')
461
            product_details = cols[0].find_all('a')
462
            #print product_details
463
            subOrderId= product_details[1].contents[0].strip()
15791 manish.sha 464
            if subOrderId in existingOrders:
465
                continue
466
            else:
467
                existingOrders.append(subOrderId)
468
            '''
15509 manish.sha 469
            productUrl = product_details[0].get('href')
470
            productName = product_details[0].contents[0].strip()
15791 manish.sha 471
            '''
472
            subOrderTrackingParsingUrl = product_details[1].get('href')
473
            #subOrderTrackingUrl = subOrderTrackingParsingUrl.split('order_lookup.details&')[1]
474
            '''
15509 manish.sha 475
            quantity = int(cols[1].text.strip())
476
            sellingPrice = long(cols[2].text.strip().replace("Rs.",""))
15791 manish.sha 477
            discount = 0
478
            subtotal = 0
479
            if totalColumns == 5:
480
                if cols[3].text.strip()!='-' or 'Rs.' in cols[3].text.strip():
481
                    discount = long(cols[3].text.strip().replace("Rs.",""))
482
                else:
483
                    discount = 0
484
                subtotal = long(cols[4].text.strip().replace("Rs.",""))
485
            else:
486
                subtotal = long(cols[3].text.strip().replace("Rs.",""))
487
 
15509 manish.sha 488
            br = getBrowserObject()
489
            productPage = br.open(BASE_MURL+productUrl)
490
            productPageHeaders = str(productPage.info()).split('\n')
491
            productPage = ungzipResponse(productPage)
492
            jsonProductResponse = None
493
            for header in productPageHeaders:
494
                header = header.split(':')
495
                if header[0] == 'Content-Type' and 'json' in header[1]:
496
                    jsonProductResponse = json.loads(productPage)
497
            productPageSoup= None
498
            if jsonProductResponse is not None:
499
                productPageSoup = BeautifulSoup(jsonProductResponse['text'])
500
            else:
501
                productPageSoup = BeautifulSoup(productPage)
15791 manish.sha 502
            productCode = productPageSoup.find('input', {'type':'hidden'})['value']
15509 manish.sha 503
            allproductImageTags = productPageSoup.findAll(attrs={'class' : 'pd-image'})
504
            productImgUrl = ''
505
            if allproductImageTags is not None and len(allproductImageTags)>0:
506
                productImgUrl= allproductImageTags[0].get('style').split("background:url('")[1].split("')no-repeat center")[0].strip()
507
            productDetailsSubMap['productCode']=productCode
508
            productDetailsSubMap['imgUrl']=productImgUrl
15791 manish.sha 509
            '''
15509 manish.sha 510
            br1 = getBrowserObject()
15791 manish.sha 511
            orderTrackingPage = br1.open(BASE_URL+'&'+subOrderTrackingParsingUrl)
15509 manish.sha 512
            headers = str(orderTrackingPage.info()).split('\n')
513
            orderTrackingPage= ungzipResponse(orderTrackingPage)
514
            jsonResponse = None
515
            for header in headers:
516
                header = header.split(':')
517
                if header[0] == 'Content-Type' and 'json' in header[1]:
518
                    jsonResponse = json.loads(orderTrackingPage)
519
 
520
            orderTrackingPageSoup = None
521
            if jsonResponse is not None:
522
                orderTrackingPageSoup = BeautifulSoup(str(jsonResponse['text']))
523
            else:
524
                orderTrackingPageSoup = BeautifulSoup(orderTrackingPage)
15791 manish.sha 525
            subOrdersDetails = self.parseSingleSubOrder(orderTrackingPageSoup, emailId, subOrderId)
526
            subOrders = list(set(subOrders + subOrdersDetails))
15509 manish.sha 527
 
15791 manish.sha 528
        return subOrders
15509 manish.sha 529
 
530
    def scrapeStoreOrders(self,):
531
        #collectionMap = {'palcedOn':1}
532
        searchMap = {}
533
        collectionMap = {"orderTrackingUrl":1}
534
        orders = self._getActiveOrders(searchMap,collectionMap)
535
        for order in orders:
536
            print "Order", self.store_name, order['orderId'], order['orderTrackingUrl']
15791 manish.sha 537
            url = ORDER_TRACK_URL + order['orderTrackingUrl'].split('trackOrder?')[1]
15509 manish.sha 538
            page = fetchResponseUsingProxy(url)
539
            soup = BeautifulSoup(page)
540
            bulk = self.db.merchantOrder.initialize_ordered_bulk_op()
541
            closed = True
542
            orderStatusList = soup.findAll(attrs={'class' : 'price ord_status'})
543
            if orderStatusList is not None and len(orderStatusList)>0:
544
                subOrderId = soup.findAll(attrs={'class':'price ord_no'})[0].text.strip()
545
                orderStatus = orderStatusList[0].contents[0].strip()
15791 manish.sha 546
                orderTable = soup.body.find("table", {'class':'table product-list'}).findAll('tr', recursive=False)
547
                orderTable.pop(0)
548
                count = 1
549
                while count <= len(orderTable):
550
                    subOrder =  self._isSubOrderActive(order, str(subOrderId)+'-'+str(count))
551
                    count = count +1
552
                    if subOrder is None:
553
                        try:
554
                            subOrders = self.parseSingleSubOrder(soup, order['orderTrackingUrl'].split('email_id=')[1], subOrderId)
555
                            for subOrder in subOrders:
556
                                if subOrder is None:
557
                                    continue
558
                                self.db.merchantOrder.update({"orderId":order['orderId']},{'$push':{"subOrders":{"$each":todict([subOrder])}}})
559
                                print "Added new suborders to Order id - ", order['orderId']
560
                                closed = False
561
                        except:
562
                            pass
563
                        continue
564
                    elif subOrder['closed']:
565
                        continue
15509 manish.sha 566
                    else:
15791 manish.sha 567
                        findMap = {"orderId": order['orderId'], "subOrders.merchantSubOrderId": subOrderId}
568
                        updateMap = {}
569
                        updateMap["subOrders.$.detailedStatus"] = orderStatus
570
                        status = self._getStatusFromDetailedStatus(orderStatus) 
571
                        closedStatus = status in [Store.ORDER_DELIVERED, Store.ORDER_CANCELLED]
572
                        if status is not None:
573
                            updateMap["subOrders.$.status"] = status
574
                        if closedStatus:
575
                            #if status is closed then change the paybackStatus accordingly
576
                            updateMap["subOrders.$.closed"] = True
577
                            if status == Store.ORDER_DELIVERED:
578
                                if subOrder.get("cashBackStatus") == Store.CB_PENDING:
579
                                    updateMap["subOrders.$.cashBackStatus"] = Store.CB_APPROVED
580
                            elif status == Store.ORDER_CANCELLED:
581
                                if subOrder.get("cashBackStatus") == Store.CB_PENDING:
582
                                    updateMap["subOrders.$.cashBackStatus"] = Store.CB_CANCELLED
583
                        else:
584
                            closed = False
585
                        bulk.find(findMap).update({'$set' : updateMap})
15509 manish.sha 586
 
587
            else:
15791 manish.sha 588
                subOrdersList = self.parseMultiSubOrders(soup, order['orderTrackingUrl'].split('email_id=')[1])
15509 manish.sha 589
                for subOrderObj in subOrdersList:
590
                    subOrder =  self._isSubOrderActive(order, subOrderObj.merchantSubOrderId)
591
                    if subOrder is None:
592
                        self.db.merchantOrder.update({"orderId":order['orderId']},{'$push':{"subOrders":{"$each":todict([subOrderObj])}}})
593
                        print "Added new suborders to Order id - ", order['orderId']
594
                        closed = False
595
                        continue
596
                    elif subOrder['closed']:
597
                        continue
598
                    else:
599
                        findMap = {"orderId": order['orderId'], "subOrders.merchantSubOrderId": subOrderId}
600
                        updateMap = {}
601
                        updateMap["subOrders.$.detailedStatus"] = subOrderObj.detailedStatus
602
                        status = self._getStatusFromDetailedStatus(orderStatus) 
603
                        closedStatus = status in [Store.ORDER_DELIVERED, Store.ORDER_CANCELLED]
604
                        if status is not None:
605
                            updateMap["subOrders.$.status"] = status
606
                        if closedStatus:
607
                            #if status is closed then change the paybackStatus accordingly
608
                            updateMap["subOrders.$.closed"] = True
609
                            if status == Store.ORDER_DELIVERED:
610
                                if subOrder.get("cashBackStatus") == Store.CB_PENDING:
611
                                    updateMap["subOrders.$.cashBackStatus"] = Store.CB_APPROVED
612
                            elif status == Store.ORDER_CANCELLED:
613
                                if subOrder.get("cashBackStatus") == Store.CB_PENDING:
614
                                    updateMap["subOrders.$.cashBackStatus"] = Store.CB_CANCELLED
615
                        else:
616
                            closed = False
15510 manish.sha 617
                        bulk.find(findMap).update({'$set' : updateMap})
15509 manish.sha 618
            bulk.find({'orderId': order['orderId']}).update({'$set':{'closed': closed,"parseError":False}})
619
            result = bulk.execute()
620
            tprint(result)      
15791 manish.sha 621
 
622
    '''
623
    def getTrackingUrls(self, userId):
624
        missingOrderUrls = ['https://sm.shopclues.com/myaccount','https://sm.shopclues.com/myorders']
625
        return missingOrderUrls
15509 manish.sha 626
 
15791 manish.sha 627
    def parseMyProfileForEmailId(self, userId, url, rawhtml):
628
        profileSoup = BeautifulSoup(rawhtml)
629
        if profileSoup.find('input', {'name':'user_email'}) is not None:
630
            emailId = profileSoup.find('input', {'name':'user_email'})['value']
631
            if emailId is not None and emailId.strip() !='':
632
                mc = MemCache()
633
                mc.set(str(userId), emailId, 600)
634
                return 'EMAIL_SET_SUCCESS'
635
            else:
636
                return 'EMAIL_NOT_FOUND'
637
        else:
638
            return 'EMAIL_NOT_FOUND'
15509 manish.sha 639
 
15791 manish.sha 640
    def parseMyOrdersForEmailId(self, userId, url, rawhtml):
641
        myOrdersPageSoup = BeautifulSoup(rawhtml)
642
        if myOrdersPageSoup.find('a', {'class':'detail'}) is not None:
643
            emailId = myOrdersPageSoup.find('a', {'class':'detail'})['href'].split('&')[1].split('=')[1]
644
            mc = MemCache()
645
            mc.set(str(userId), emailId, 600)
646
            return 'EMAIL_SET_SUCCESS'
647
        else:
648
            return 'EMAIL_NOT_FOUND'
649
    '''        
650
 
651
 
15509 manish.sha 652
def todict(obj, classkey=None):
653
    if isinstance(obj, dict):
654
        data = {}
655
        for (k, v) in obj.items():
656
            data[k] = todict(v, classkey)
657
        return data
658
    elif hasattr(obj, "_ast"):
659
        return todict(obj._ast())
660
    elif hasattr(obj, "__iter__"):
661
        return [todict(v, classkey) for v in obj]
662
    elif hasattr(obj, "__dict__"):
663
        data = dict([(key, todict(value, classkey)) 
664
            for key, value in obj.__dict__.iteritems() 
665
            if not callable(value) and not key.startswith('_')])
666
        if classkey is not None and hasattr(obj, "__class__"):
667
            data[classkey] = obj.__class__.__name__
668
        return data
669
    else:
15791 manish.sha 670
        return obj    
671
 
15509 manish.sha 672