WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/sources/snapdeal.py

 import pymongo
 import re
 import time
 import traceback
 import urllib
+import urllib2
 USERNAME='profittill2@gmail.com'
 PASSWORD='spice@2020'
 AFFILIATE_URL='http://affiliate.snapdeal.com/login/'
 POST_URL='https://api-p03.hasoffers.com/v3/Affiliate_Report.json'
 ORDER_TRACK_URL='https://m.snapdeal.com/orderSummary'
 CONFIG_URL='http://affiliate.snapdeal.com/publisher/js/config.php'
-NEW_REPORT_URI_TEMPLATE = "http://affiliate.snapdeal.com/affiliate/reports/orders/report/?fromDate=%s&toDate=%s&dump_report=True&request_type=product&status=%s"
+#NEW_REPORT_URI_TEMPLATE = "http://affiliate.snapdeal.com/affiliate/reports/orders/report/?fromDate=%s&toDate=%s&dump_report=True&request_type=product&status=%s"
+AFF_URL_TEMPLATE = "http://affiliate-feeds.snapdeal.com/feed/api/order?startDate=%s&endDate=%s&status=%s"
 #"http://affiliate.snapdeal.com/affiliate/reports/orders/report/?fromDate=2015-04-01&toDate=2015-09-15&dump_report=True&request_type=product&status=cancelled
 #"http://affiliate.snapdeal.com/affiliate/reports/orders/report/?fromDate=07-09-2015&toDate=13-09-2015&dump_report=True&request_type=product&status=cancelled
+AFF_ID = "33550"
+AFF_TOKEN="66d526141b9d39c4b2b4ff76eadc34"
 class Store(MStore):
     '''
     This is to map order statuses of our system to order statuses of snapdeal.
     And our statuses will change accordingly.
     def getName(self):
         return "snapdeal"
     def scrapeAffiliate(self, startDate=None, endDate=None):
-        br = getBrowserObject()
-        br.open(AFFILIATE_URL)
-        br.select_form(nr=0)
-        #br.form['data[User][password]'] = PASSWORD
-        #br.form['data[User][email]'] = USERNAME
-        br.form['email'] =  USERNAME
-        br.form['password'] = PASSWORD
-        br.submit()
-        #after logged in successfully
-        #response = br.open(CONFIG_URL)
-        #find token to fetch api
-        #token =  re.findall('"session_token":"(.*?)"', ungzipResponse(response), re.IGNORECASE)[0]
-        #print token
-        #allOffers = self._getAllOffers(br, token)
-        #fetch api using new report uri
         endDate=date.today() - timedelta(days=1)
         if startDate is None:
             startDate = endDate - timedelta(days=45)
-        endDate = endDate.strftime('%d-%m-%Y')
+        endDate = endDate.strftime('%Y-%m-%d')
-        startDate = startDate.strftime('%d-%m-%Y')
+        startDate = startDate.strftime('%Y-%m-%d')
         statuses=['cancelled', 'approved']
-        directory = "/SnapAff/"
-        curDate = directory + datetime.now().strftime('%Y-%m-%d')
-        if not os.path.exists(directory):
-            os.makedirs(directory)
         for status in statuses:
-            if status == "approved":
+            nextUrl = AFF_URL_TEMPLATE%(startDate, endDate, status)
-                print "app"
+            while nextUrl:
-            reportUrl = NEW_REPORT_URI_TEMPLATE%(startDate, endDate, status)
+                req = urllib2.Request(nextUrl)
-            print reportUrl
+                nextUrl=''
-            filename=curDate + "-" + status
+                req.add_header('Snapdeal-Affiliate-Id', AFF_ID)
-            fileobj = open(filename,"wb")
+                req.add_header('Snapdeal-Token-Id', AFF_TOKEN)
-            fileobj.write(utils.ungzipResponse(br.open(reportUrl)))
+                req.add_header('Accept', 'application/json')
-            fileobj.close()
+                resp = urllib2.urlopen(req)
-            with open(filename, 'rb') as csvfile:
+                ordersDict = json.loads(resp.read())
-                reader = csv.reader(csvfile)
-                self._saveToAffiliate(reader, status)
+                self._saveToAffiliate(ordersDict['productDetails'], status)
     def _setLastSaleDate(self, saleDate):
         self.db.lastSaleDtate.update({'storeId':self.store_id}, {'$set':{'saleDate':saleDate}})
     def _saveToAffiliate(self, offers, status):
         collection = self.db.snapdealOrderAffiliateInfo1
         #mcollection = self.db.merchantOrder
         for offer in offers:
-            count = 0
-            for row in offers:
-                if count==0:
-                    count += 1
-                    continue
-                offer = self.covertToObj(row)
+                offer = self.covertToObj(offer)
                 if offer.orderId:
                     dict1 = todict(offer)
                     dict1["_id"] = dict1["orderId"] + "-" + dict1["productCode"]
                     dict1['status'] = status
                     collection.save(dict1)
                     continue
         finally:
             session.close()
     def covertToObj(self,offer):
-        product,category,order_code,quantity,price,sales,commission_rate,commission_earned,datetime1,affiliate_sub_id1,affiliate_sub_id2 = offer
-        offer1 = AffiliateInfo(affiliate_sub_id1, 3, None, None,            utils.toTimeStamp(datetime.strptime(datetime1, "%m-%d-%Y %H:%M")),
+        offer1 = AffiliateInfo(offer["affiliateSubId1"], 3, None, None, utils.toTimeStamp(datetime.strptime(offer["dateTime"], "%m/%d/%Y %H:%M:%S")),
-if commission_earned=="-" else int(float(commission_earned)), None, None, int(float(sales)))
+                               offer["commissionEarned"], None, None, offer["sale"])
-        offer1.orderId = order_code if order_code  else None
+        offer1.orderId = offer.get('orderCode') if offer.get('orderCode')  else None
-        offer1.productCode = product
+        offer1.productCode = offer["product"]
-        offer1.unitPrice = int(float(price))
+        offer1.unitPrice = offer["price"]
-        offer1.quantity = int(quantity)
+        offer1.quantity = offer["quantity"]
-        offer1.payOut
+        offer1.saleTime = offer["dateTime"]
         return offer1
 def getPostData(token, page = 1, limit= 20, startDate=None, endDate=None):
     endDate=date.today() + timedelta(days=1)
     startDate=endDate - timedelta(days=31)
 def main():
     #print todict([1,2,"3"])
     store = getStore(3)
     #store.parseOrderRawHtml(332221, "3232311", 2, readSSh("/home/amit/snapdeal.html"), "https://m.snapdeal.com/purchaseMobileComplete?code=b92753bd7236bb3efbd6e8a0df46b962&order=9627657388")
-    store.scrapeStoreOrders()
+    store.scrapeAffiliate()
     #https://m.snapdeal.com/purchaseMobileComplete?code=3fbc8a02a1c4d3c4e906f46886de0464&order=5808451506
     #https://m.snapdeal.com/purchaseMobileComplete?code=9f4dfa49ff08a16d04c5e4bf519506fc&order=9611672826
 #    orders = list(session.query(OrdersRaw).filter_by(store_id=3).filter_by(status='ORDER_NOT_CREATED').all())
 #    for o in orders:

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/sources/snapdeal.py – Rev 17462 → 17667