WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/order/script/EcomExpressLogisticsReconciliation.py

 from shop2020.thriftpy.crm.ttypes import *
 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     OrderStatus
 from shop2020.utils.EmailAttachmentSender import get_attachment_part, mail
 from shop2020.utils.Utils import to_py_date
-from xml.etree.ElementTree import parse
+from xml.etree.ElementTree import parse, fromstring
 import csv
 import datetime
 import json
 import optparse
 import re
 if __name__ == '__main__' and __package__ is None:
     import os
     sys.path.insert(0, os.getcwd())
+REASON_CODES_PICKUP_REGISTERED = ['013']
+REASON_CODES_SHIPMENT_ARRIVED = ['127', '0002']
+REASON_CODES_UNDELIVERED_MAP = { '005':'Reached Destination City', '006':'Out for Delivery', '303': 'Shipment In Transit'}
+REASON_CODES_NDR = ['200', '201', '202', '206', '207', '208', '209', '210', '212', '213', '214', '215', '216',
+                    '217', '221', '222', '223', '224', '225', '226', '227', '228','229', '231', '232', '233',
+                    '331','331','332','333','331','666','888','218', '219', '220', '1225'
+                    ]
+REASON_CODES_DELIVERED=['999', '204']
+REASON_CODES_RTO = ['777', '77', '80', '82', '83']
 finalUpdateUrl = ""
 live = "false"
 try:
     config_client = ConfigClient()
 except:
     live = "true"
 if live=="true":
     UPDATE_URL = "http://plapi.ecomexpress.in/track_me/api/mawbd/?order=&"
-    ECOM_API_USERNAME = "ecomexpress"
+    ECOM_API_USERNAME = "newspice671445"
-    ECOM_API_PASSWORD = "Ke$3c@4oT5m6h%23$"
+    ECOM_API_PASSWORD = "npcs67unsd44debm"
 else:
     UPDATE_URL = "http://staging.ecomexpress.in/track_me/api/mawbd/?order=&"
     ECOM_API_USERNAME = "ecomexpress"
     ECOM_API_PASSWORD = "Ke$3c@4oT5m6h%23$"
 finalUpdateUrl = UPDATE_URL + "username=" + ECOM_API_USERNAME + "&password="+ECOM_API_PASSWORD
 defaultUndeliveredAsssigneeId = 65
 dtrUndeliveredAsssigneeId = 33
 from_user = 'cnc.center@shop2020.in'
 def process_pickup_records(provider):
     try:
         orders_tobe_picked_up = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH])
         pickup_details = read_pickup_orders(orders_tobe_picked_up)
+        print "pickup_details", pickup_details
         if pickup_details:
             update_picked_orders(provider.id, pickup_details)
     except:
         print "Some issue while processing the orders in SHIPPED_FROM_WH status"
         traceback.print_exc()
 def process_delivery_report(provider):
     try:
         orders_tobe_delivered = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.SHIPPED_TO_DESTINATION_CITY, OrderStatus.REACHED_DESTINATION_CITY, OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE])
         delivered_orders, returned_orders, undelivered_orders = read_delivery_orders(orders_tobe_delivered)
+        print "delivey_orders", delivered_orders
         if delivered_orders:
             update_delivered_orders(provider.id, delivered_orders)
+        print "returned_orders", returned_orders
         if returned_orders:
             update_returned_orders(provider.id, returned_orders)
+        print "undelivered_orders", undelivered_orders
         if undelivered_orders:
             update_reason_of_undelivered_orders(provider.id, undelivered_orders)
     except:
         print "Some issue while processing the orders for delivery status"
         traceback.print_exc()
             currentBatch = awbs[doneAwbs:doneAwbs+batchSize]
             print "currentBatch", currentBatch
             url = finalUpdateUrl + "&awb=" + ",".join(currentBatch)
             print url
             response = urllib2.urlopen(url)
-            print response.read()
+            responseString = response.read()
-            return
-            #print "RQUICK AWB response", response
+            print responseString
-            jsonResponse = json.loads(response.read())
+            root = fromstring(responseString)
-            print jsonResponse
+            print root.tag
-            if jsonResponse['status']!=1:
+            awbs = []
-                print "Invalid api status"
+            for awbEle in root:
-            else:
-                for awbObj in jsonResponse['data']:
+                awbNumber = awbEle.findall("field/[@name='awb_number']")[0].text
-                    for awb, awbResponse in awbObj.iteritems():
+                reasonCode = awbEle.findall("field/[@name='reason_code_number']")[0].text
-                        awbDetails = awbResponse['response']
+                deliveryDate = awbEle.findall("field/[@name='delivery_date']")[0].text
-                        awbStatuses[awb] = awbDetails
+                lastUpdateDate = awbEle.findall("field/[@name='last_update_date']")[0].text
-            doneAwbs += batchSize
+                xmlScans = awbEle.findall("field/object/[@model='scan_stages']")
+                awbStatuses[awbNumber] = {'awbNumber': awbNumber, 'reasonCode': reasonCode, 'deliveryDate':deliveryDate, 'lastUpdateDate':lastUpdateDate, 'scans': xmlScans}
+        doneAwbs += batchSize
+        print awbStatuses
         return awbStatuses
 class __AWBStatusObj:
-    def __init__(self, awb, status, statusDate):
+    def __init__(self, awb, statusCode, statusDescription, statusDate):
         self.awb = awb
-        self.status = status
+        self.statusCode = statusCode
+        self.statusDescription = statusDescription
         self.statusDate = statusDate
+def __get_scan_by_code(xmlScans, codes):
+    awbStatusObj = None
+    for xmlScan in xmlScans:
+        reasonCodeNumber = xmlScan.findall("[@name='reason_code_number']")[0].text
+        if reasonCodeNumber in codes:
+            statusDescription = xmlScan.findall("[@name='status']")[0].text
+            statusDate = get_py_datetime(xmlScan.findall("[@name='updated_on']")[0].text)
+            awbStatusObj = __AWBStatusObj(None, reasonCodeNumber, statusDescription, statusDate)
+    return awbStatusObj
 def read_pickup_orders(orders_tobe_picked_up):
     picked_up_orders = {}
     awbs = [order.airwaybill_no for order in orders_tobe_picked_up]
     for awb, awbDetails in get_awb_status(awbs).iteritems():
-        #status = awbDetails['Status']
+        xmlScans = awbDetails['xmlScans']
-        #statusDate = get_pawbDetails['StatusDateTime']
+        awbStatusObj = __get_scan_by_code(xmlScans, ['0011'])
-        print awbDetails
+        if awbStatusObj is None:
-        tracking = awbDetails['Tracking']
+            continue
-        bookedTime = get_py_datetime(tracking[-1]['StatusDateTime'])
+        bookedTime = awbStatusObj.statusDate
         picked_up_orders[awb] = str(bookedTime)
     print "Picked up Orders:"
     print picked_up_orders
     return picked_up_orders
 def read_local_connection_orders(orders_tobe_local_connected):
     undelivered_orders = {}
     awbs = [order.airwaybill_no for order in orders_tobe_delivered]
     for awb, awbDetails in get_awb_status(awbs).iteritems():
-        status = awbDetails['Status']
+        xmlScans = awbDetails['xmlScans']
+        deliveredAwbStatusObj = __get_scan_by_code(xmlScans, REASON_CODES_DELIVERED)
+        if deliveredAwbStatusObj is not None:
-        statusTime = get_py_datetime(awbDetails['StatusDateTime'])
+            bookedTime = get_py_date(awbDetails['deliveryDate'])
+            delivered_orders[awb] = str(bookedTime) + "|" +  "Not Available"
+            continue
-        #statusDate = awbDetails['StatusDateTime']
+        rtoAwbStatusObj = __get_scan_by_code(xmlScans, REASON_CODES_RTO)
-        #tracking = awbDetails['Tracking']
+        if rtoAwbStatusObj is not None:
-        if status.startswith("Delivered"):
+            bookedTime = rtoAwbStatusObj.statusDate
-            delivered_orders[awb] = str(statusTime) + "|" +  "Not Available"
+            delivered_orders[awb] = str(bookedTime) + "|" +  "Not Available"
+            continue
+        undeliveredAwbStatusObj = __get_scan_by_code(xmlScans, REASON_CODES_UNDELIVERED_MAP.keys())
-        if status.startswith('RTO'):
+        if undeliveredAwbStatusObj is not None:
-            returned_orders[awb] = str(statusTime) + "|" + "Not Available"
+            delivered_orders[awb] = REASON_CODES_UNDELIVERED_MAP.get(undeliveredAwbStatusObj.reasonCodeNumber)
-        undelivered_orders[awb] = status
+        #undelivered_orders[awb] = awbDetails.statusDescription
     print "Delivered Orders:"
     print delivered_orders
     print "Returned Orders:"
 def get_py_datetime(time_string):
     # This should be a command line argument.
     # Refer http://docs.python.org/library/time.html#time.strftime to
     # get a complete list of format specifiers available for date time.
-    time_format = "%d-%m-%Y %H:%M:%S"
+    time_format = "%d %b, %Y, %H:%M"
+    if time_string == '':
+        return None
+    return datetime.datetime.strptime(time_string, time_format)
+def get_py_date(time_string):
+    # This should be a command line argument.
+    # Refer http://docs.python.org/library/time.html#time.strftime to
+    # get a complete list of format specifiers available for date time.
+    time_format = "%d-%b-%Y"
     if time_string == '':
         return None
     return datetime.datetime.strptime(time_string, time_format)
 def getOriginCityBranchID(originCity):
         #process_dao_pickup_orders(provider)
         #process_return_pickup_orders(provider)
     if options.delivery_report:
         #process_local_connection_orders(provider)
         #process_reached_destination_city_orders(provider)
-        process_first_delivery_attempt_orders(provider)
+        #process_first_delivery_attempt_orders(provider)
         process_delivery_report(provider)
         #create_crm_tickets_for_delivey_attempted_orders(provider)
         #auto_close_crm_tickets_created()
     if options.gen_reports:
         pass
         #generate_reports(provider)
 if __name__ == '__main__':
-    #main()
+    main()
+    #awbs =["897986473","225839621", "225839622", "225839623", "22583962"]
-    get_awb_status(["102019265","80005448"])
+    #for awb, awbDetails in get_awb_status(awbs).iteritems():
+        #print awb, awbDetails

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/script/EcomExpressLogisticsReconciliation.py – Rev 23236 → 23250