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

 class Store(MStore):
     orderStatusRegexMap = { MStore.ORDER_PLACED : ['ordered from', 'not yet dispatched','dispatching now', 'preparing for dispatch'],
                             MStore.ORDER_SHIPPED : ['dispatched on','dispatched', 'on the way', 'out for delivery', 'Out for delivery'],
                             MStore.ORDER_CANCELLED : ['return complete', 'refunded', 'cancelled'],
-                            MStore.ORDER_DELIVERED : ['delivered']
+                            MStore.ORDER_DELIVERED : ['delivered', 'your package was delivered']
+                           }
     def __init__(self,store_id):
         super(Store, self).__init__(store_id)
                             shipments = orderEle.findAll('div',{'class':re.compile('.*?a-box.*?')}, recursive=False)
                             shipments.pop(0)
                             for shipment in shipments:
                                 shipdiv = shipment.find('div', {'class':'a-box-inner'})
                                 sdivs = shipment.div.div.findAll('div', recursive=False)
-                                orderStatus = sdivs[0].span.text.strip()
+                                orderStatus = sdivs[0].findAll('div')[1].text.strip()
                                 status = self._getStatusFromDetailedStatus(orderStatus)
-                                if status == MStore.ORDER_DELIVERED:
+#                                if status == MStore.ORDER_DELIVERED:
+#                                    try:
+#                                        #getDateString(sdivs[0].span.text.strip().split("Delivered ")[1].strip())
-                                    deliveredOn = sdivs[0].findAll('span')[-1].text.strip()
+#                                        deliveredOn = sdivs[0].findAll('span')[-1].text.strip()
-                                    try:
+#                                        try:
-                                        deliveredOn = deliveredOn.split(":")[1].strip()
+#                                            deliveredOn = deliveredOn.split(":")[1].strip()
-                                    except:
+#                                        except:
-                                        deliveredOn = ""
+#                                            deliveredOn = ""
+#                                    except:
+#                                        pass
                                 deliveryestimatespan = sdivs[0].find('span', {'class':'a-color-success'})
                                 deliveryEstimate = None
                                 if deliveryestimatespan is not None:
                                     deliveryEstimate = deliveryestimatespan.find('span', {'class':'a-text-bold'}).text.strip()
                                 productDivs = shipdiv.find('div', {'class':re.compile('.*?a-spacing-top-medium.*?')}).find('div', {'class':'a-row'}).findAll('div', recursive=False)
                                             findMap = {"orderId": activeOrder['orderId'], "subOrders.merchantSubOrderId": subOrder.get("merchantSubOrderId")}
                                             updateMap = {}
                                             closedStatus = False
                                             updateMap['subOrders.$.imgUrl'] = imgUrl
                                             updateMap['subOrders.$.lastTracked'] = timestamp
-                                            updateMap['subOrders.$.detailedStatus'] = orderStatus
+                                            updateMap['subOrders.$.detailedStatus'] = status
                                             cashbackStatus = subOrder.get("cashBackStatus")
                                             updateMap['subOrders.$.status'] = status
+                                            if status==MStore.ORDER_DELIVERED:
-                                            if status==MStore.ORDER_DELIVERED:
+#                                                if not deliveredOn:
-                                                updateMap['subOrders.$.deliveredOn'] = deliveredOn
+#                                                    updateMap['subOrders.$.deliveredOn'] = deliveredOn
                                                 closedStatus = True
                                                 updateMap['subOrders.$.closed'] = True
                                                 if cashbackStatus == Store.CB_PENDING:
                                                     updateMap['subOrders.$.cashBackStatus'] = Store.CB_APPROVED
                                             if status==MStore.ORDER_CANCELLED:
             session.close()
 def main():
-    getSummaryFile("/AmazonTrack/User8703/")
+    #getSummaryFile("/AmazonTrack/User8703/")
     #process_rejects("/home/amit/Downloads/RejectCashbackTemplate.xlsx")
     #str1 = readSSh("/AmazonTrack/User2466/orderSummary28-06:13:25:08")
     #str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:04")
     #str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:38:01")
     #str1 = readSSh("/AmazonTrack/User2466/orderSummary24-06:17:31:53")
     #store.trackOrdersForUser(4355, "https://www.amazon.in/gp/css/summary/edit.html?orderID=171-4824011-7090713", readSSh("~/4355"))
     #readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
     #store.scrapeAffiliate()
     #parseDetailNotCreated()
     #parseOrderNotCreated()
-    for userId in store.db.merchantOrder.find({"storeId":1, "closed":True, "subOrders.closed":False}).distinct("userId"):
+    for userId in store.db.merchantOrder.find({"storeId":1, "subOrders.closed":False}).distinct("userId"):
-        print userId
+        userId = int(userId)
         directory = "/AmazonTrack/User" + str(userId) + "/"
-        summaryFile=getSummaryFile(directory)
+        summaryFile="orderSummary13-10:14:41:55"
         if summaryFile is None:
             print "No summary for", userId
         else:
             print userId, directory+summaryFile
-            #store.trackOrdersForUser(userId, 'https://www.amazon.in/gp/css/order-history', readSSh(directory + summaryFile))
+            store.trackOrdersForUser(userId, 'https://www.amazon.in/gp/css/order-history', readSSh(directory + summaryFile))
     #store.trackOrdersForUser(8703, 'https://www.amazon.in/gp/css/order-history', readSSh('/home/amit/Downloads/orderSummary06-10_12_15_54'))
 def getSummaryFile(directory):
     date1 = datetime(2015,1,1)
                 if date2 > date1:
                     date1 = date2
                     finalFile=file
     except:
         print "Missing directory"
     return finalFile
 def parseDetailNotCreated():
     try:
         store=getStore(1)
         for order in orders:
             store.trackOrdersForUser(order.id, order.order_url, order.rawhtml)
     finally:
         session.close()
+def getDateStringDelivered(dateString='Monday'):
+    #print datetime.strftime(dateMin,"%d-%b-%y")
+    if dateString.lower()=='today':
+        return date.today()
+    if dateString.lower()=='yesterday':
+        return date.today() - timedelta(days=1)
+    try:
+        return datetime.strptime(dateString, '%d-%b-%y')
+    except:
+        try:
+            #get Closest Date from today
+            curDate = date.today()
+            curTime = datetime(curDate.year, curDate.month, curDate.day)
+            curYear = curDate.year
+            prevYear = curYear - 1
+            dateMax = datetime.strptime(dateString + " " + str(curYear), "%A,%d %b %Y")
+            dateMin = datetime.strptime(dateString + " " + str(prevYear), "%A,%d %b %Y")
+            if dateMax <= curTime:
+                return dateMax
+            else:
+                return dateMin
+        except:
+            days_of_week = ['sunday','monday','tuesday','wednesday',
+                        'thursday','friday','saturday']
+            deltaDays = curDate.isoweekday() - days_of_week.index(dateString.lower())
+            if deltaDays <= 0:
+                deltaDays= deltaDays + 7
+            curDate = curDate - timedelta(days=deltaDays)
+            print datetime.strftime(curDate, '%d-%b-%y')
+            return curDate
 def parseOrderNotCreated():
     try:
         store=getStore(1)
         orders = session.query(OrdersRaw).filter_by(status='ORDER_NOT_CREATED_UNKNOWN').all()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/sources/amazon.py – Rev 17231 → 17251