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

 import pymongo
 import re
 import traceback
 import urllib
-USERNAME='saholic1@gmail.com'
+USERNAME='profittill2@gmail.com'
 PASSWORD='spice@2020'
 AFFILIATE_URL='http://affiliate.snapdeal.com'
 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'
         for offer in allOffers:
             pyOffer = self.covertToObj(offer).__dict__
             allPyOffers.append(pyOffer)
             saleDate = datetime.strptime(pyOffer['saleDate'],"%Y-%m-%d %H:%M:%S")
             if maxSaleDate < saleDate:
-                self._updateOrdersPayBackStatus(pyOffer['subTagId'],pyOffer['saleDate'])
+                self._updateOrdersPayBackStatus({'subTagId':pyOffer['subTagId'], 'saleDate':pyOffer['saleDate']}, {})
                 if newMaxSaleDate < saleDate:
                     newMaxSaleDate = saleDate
         self._setLastSaleDate(newMaxSaleDate)
         self._saveToAffiliate(allPyOffers)
     def _setLastSaleDate(self, saleDate):
         self.db.lastSaleDtate.update({'storeId':self.store_id}, {'$set':{'saleDate':saleDate}})
-    def _updateOrdersPayBackStatus(self, subTagId, saleDate):
-        self.db.merchantOrder.update({"subTagId":subTagId, "placedOn":saleDate, "subOrders.cashbackStatus":MStore.CB_INIT},
-                                              { '$set': { "subOrders.$.cashbackStatus" : MStore.CB_PENDING } })
     def _getLastSaleDate(self,):
         lastDaySaleObj = self.db.lastDaySale.find_one({"storeId":self.store_id})
         if lastDaySaleObj is None:
                     subOrder.amountPaid = amountPaid
                     subOrder.deliveryCharges = deliveryCharges
                     subOrder.offerDiscount = offerDiscount
                     subOrder.unitPrice = unitPrice
                     subOrder.productCode = re.findall(r'\d+$', productUrl)[0]
-                    cashbackAmount = self.getCashbackAmount(subOrder.productCode, amount)
+                    (cashbackAmount, percentage) = self.getCashbackAmount(subOrder.productCode, amount)
                     cashbackStatus = Store.CB_INIT
                     if cashbackAmount <= 0:
                         cashbackStatus = Store.CB_NA
                     subOrder.cashBackStatus = cashbackStatus
                     subOrder.cashBackAmount = cashbackAmount
+                    if percentage > 0:
+                        subOrder.cashBackPercentage = percentage
                     trackAnchor = div.find("a")
                     if trackAnchor is not None:
                         subOrder.tracingkUrl = str(trackAnchor['href'])
             for subOrderElement in subOrders:
                 closed = True
                 divs = subOrderElement.findAll("div", {"class": "blk lrPad subordrs"})
                 if len(divs)<=0:
                     raise ParseException("subOrder", "Could not Parse suborders for Snapdeal")
+                subOrder = None
                 for div in divs:
                     divStr = str(div)
                     divStr = divStr.replace("\n","").replace("\t", "")
                     updateMap = {}
                     for line in divStr.split("<br />"):
                         if "Suborder ID" in line:
                             merchantSubOrderId = re.findall(r'\d+', line)[0]
                             #break if suborder is inactive
                             findMap = {"orderId": order['orderId'], "subOrders.merchantSubOrderId": merchantSubOrderId}
-                            if not self._isSubOrderActive(order, merchantSubOrderId):
+                            subOrder =  self._isSubOrderActive(order, merchantSubOrderId)
+                            if subOrder is None:
                                 break
                         elif "Status" in line:
                             detailedStatus = re.findall('>(.*?)</span>', line, re.IGNORECASE)[0]
                             detailedStatus = re.findall('>(.*?)</span>', line, re.IGNORECASE)[0]
                             updateMap["subOrders.$.detailedStatus"] = detailedStatus
                             status = self._getStatusFromDetailedStatus(detailedStatus)
                             closedStatus = status in [Store.ORDER_DELIVERED, Store.ORDER_CANCELLED]
                             if closedStatus:
                                 #if status is closed then change the paybackStatus accordingly
                                 if closedStatus == Store.ORDER_DELIVERED:
-                                    if order.get("cashBackStatus") == Store.CB_PENDING:
+                                    if subOrder.get("cashBackStatus") == Store.CB_PENDING:
                                         updateMap["subOrders.$.cashBackStatus"] = Store.CB_APPROVED
                                 elif closedStatus == Store.ORDER_CANCELLED:
-                                    if order.get("cashBackStatus") == Store.CB_PENDING:
+                                    if subOrder.get("cashBackStatus") == Store.CB_PENDING:
                                         updateMap["subOrders.$.cashBackStatus"] = Store.CB_CANCELLED
                             else:
                                 closed = False
                         elif "Est. Shipping Date" in line:
                         elif "Tracking No" in line:
                             trackingNumber = line.split(":")[1].strip()
                             updateMap["subOrders.$.trackingNumber"] = trackingNumber
                     bulk.find(findMap).update({'$set' : updateMap})
-                    bulk.find({'orderId': order['orderId']}).update({'$set':{'closed': closed}})
+                bulk.find({'orderId': order['orderId']}).update({'$set':{'closed': closed}})
             result = bulk.execute()
             pprint(result)
-    def _isSubOrderActive(self,order, merchantSubOrderId):
-        subOrders = order.get("subOrders")
-        for subOrder in subOrders:
-            if merchantSubOrderId == subOrder.get("merchantSubOrderId"):
-                return True
-        return False
     def _saveToAffiliate(self, offers):
         collection = self.db.snapdealOrderAffiliateInfo
         try:
             collection.insert(offers,continue_on_error=True)
         except pymongo.errors.DuplicateKeyError as e:

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/sources/snapdeal.py – Rev 13690 → 13721