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

 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, XML, fromstring
-from datetime import datetime
 import csv
 import datetime
 import optparse
 import sys
 import time
 import traceback
 import urllib2
 from suds.client import Client
-import json
-import StringIO
-import zlib
-import gzip
-import xmltodict
-import ast
 if __name__ == '__main__' and __package__ is None:
     import os
     sys.path.insert(0, os.getcwd())
 RED_EXPRESS_URL = "http://tracking.getsetred.net/TrackingService.svc?wsdl"
 username = 'C00086721141'
 password = 'SANDEEP.SACHDEVA@SHOP2020.IN'
-tracking_Id_Type = 'REFERENCENO'
-tracking_Level = 'ALL_DETAILS'
-RED_EXPRESS_TRACKING_URL = 'http://webservices.getsetred.net/Services/BulkTracking.svc/'
-headers = {
-               "User-Agent" : "Mozilla/5.0 (X11; Linux i686) AppleWebKit/535.1 (KHTML, like Gecko) Chrome/13.0.782.218 Safari/535.1",
-               "Accept" : "    text/html,application/xhtml+xml,application/xml;q=0.9,/;q=0.8",
-               "Accept-Language" : "en-us,en;q=0.5",
-               "Accept-Encoding" : "gzip, deflate",
-               "Connection" : "keep-alive",
-               "Accept-Charset" : "ISO-8859-1",
-               "Content-type": "application/json; charset=UTF-8"
-               }
 client = None
 def getClient():
     global client
     if client is None:
             timestring = element.findtext('Time', '')
             description = element.findtext('ServiceEvent', '')
             results.append(datestring+"~!~"+timestring+"~!~"+description)
     return results
-def get_track_updates(awb_numbers):
-    req_args = json.dumps({'password':password,
-                           'trackingIdType':'REFERENCENO',
-                           'trackingLevel':'ALL_DETAILS',
-                           'userId':username,
-                           'waybillNo': awb_numbers
-                           })
-    request = urllib2.Request(RED_EXPRESS_TRACKING_URL, req_args, headers)
-    response = urllib2.urlopen(request)
-    encoding = response.info().get("Content-Encoding")
-    if encoding in ('gzip', 'x-gzip', 'deflate'):
-        content = response.read()
-        if encoding == 'deflate':
-            track_data_decoded = StringIO.StringIO(zlib.decompress(content))
-        else:
-            track_data_decoded = gzip.GzipFile('', 'rb', 9, StringIO.StringIO(content))
-    track_data_readable = track_data_decoded.read()
-    conv_dict = xmltodict.parse(track_data_readable)
-    track_data_json= json.dumps(conv_dict)
-    if len(awb_numbers) > 0:
-        track_data_dict = ast.literal_eval(track_data_json)
-    if len(awb_numbers)==1:
-        track_data_list=[]
-        track_data_list.append(track_data_dict['BulkTrackingResponse']['BulkResponse']['TrackingResponse'])
-        track_data_list.append('DUMMY')
-    elif len(awb_numbers)==0:
-        track_data_list=[]
-    else:
-        track_data_list = track_data_dict['BulkTrackingResponse']['BulkResponse']['TrackingResponse']
-    return track_data_list
 def process_dao_pickup_orders(provider):
     try:
         doas_tobe_picked_up = fetch_data(provider.id, [OrderStatus.DOA_PICKUP_CONFIRMED])
         doa_pickup_details = read_dao_return_pickup_orders(doas_tobe_picked_up)
         if doa_pickup_details:
     print picked_up_orders
     return picked_up_orders
 def read_pickup_orders(orders_tobe_picked_up):
     picked_up_orders = {}
-    awb_number_list =[]
     for order in orders_tobe_picked_up:
-        awb_number_list.append(order.airwaybill_no)
-    track_update_list = get_track_updates(awb_number_list)
-    for update in track_update_list:
-        if update == 'DUMMY':
-            continue
-        else:
-            try:
+        try:
-                airwaybill_no = update['ReferenceNo']
-                track_list = update['TrackingList']['TrackingList']
+            root =  fromstring(str(get_updates(order.airwaybill_no)))
-                track_list.reverse()
+            children = root.getchildren()
-                for track_update in track_list:
+            for child in children:
-                    if track_update['TrackingCode'] == 'BKD' :
+                nodes = child.findall('ShipmentInfo/ShipmentEvent')
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
+                for element in reversed(nodes):
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                    datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                    timestring = element.findtext('Time', '')
-                        delivery_date = datestring + timestring
+                    delivery_date = get_py_datetime(datestring, timestring)
-                        picked_up_orders[airwaybill_no] = delivery_date
+                    picked_up_orders[order.airwaybill_no] = str(delivery_date)
-                        break
+                    break
                 break
-            except:
+        except:
-                pass
+            pass
     print "Picked up Orders:"
     print picked_up_orders
     return picked_up_orders
 def read_local_connection_orders(orders_tobe_local_connected):
     local_connected_orders = {}
-    awb_number_list =[]
     for order in orders_tobe_local_connected:
-        awb_number_list.append(order.airwaybill_no)
+        try:
-    track_update_list = get_track_updates(awb_number_list)
+            root =  fromstring(str(get_updates(order.airwaybill_no)))
-    for update in track_update_list:
-        if update == 'DUMMY':
+            children = root.getchildren()
-            continue
+            for child in children:
-        else:
-            try:
-                airwaybill_no = update['ReferenceNo']
-                track_list = update['TrackingList']['TrackingList']
+                nodes = child.findall('ShipmentInfo/ShipmentEvent')
-                track_list.reverse()
+                for element in reversed(nodes):
-                for track_update in track_list:
-                    if track_update['TrackingCode'] == 'PRO' :
+                    if element.findtext('TrackingCode', '') == 'PRO':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                        datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                        timestring = element.findtext('Time', '')
-                        delivery_date = datestring + timestring
+                        delivery_date = get_py_datetime(datestring, timestring)
-                        local_connected_orders[airwaybill_no] = delivery_date
+                        local_connected_orders[order.airwaybill_no] = str(delivery_date)
                         break
                 break
-            except:
+        except:
-                pass
+            pass
     print "Local Connected Orders"
     print local_connected_orders
     return local_connected_orders
 def read_reached_destination_orders(orders_tobe_reached_destination_city):
     destination_city_reached_orders = {}
-    awb_number_list =[]
     for order in orders_tobe_reached_destination_city:
-        awb_number_list.append(order.airwaybill_no)
+        try:
-    track_update_list = get_track_updates(awb_number_list)
+            root =  fromstring(str(get_updates(order.airwaybill_no)))
-    for update in track_update_list:
-        if update == 'DUMMY':
+            children = root.getchildren()
-            continue
+            child_number = 0
-        else:
-            try:
+            for child in children:
-                airwaybill_no = update['ReferenceNo']
+                child_number = child_number + 1
-                track_list = update['TrackingList']['TrackingList']
+                nodes = child.findall('ShipmentInfo/ShipmentEvent')
-                track_list.reverse()
-                for track_update in track_list:
+                for element in nodes:
-                    if track_update['TrackingCode'] == 'RDB' :
+                    if element.findtext('TrackingCode', '') == 'RDB':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                        datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                        timestring = element.findtext('Time', '')
-                        delivery_date = datestring + timestring
+                        delivery_date = get_py_datetime(datestring, timestring)
-                        destination_city_reached_orders[airwaybill_no] = delivery_date
+                        destination_city_reached_orders[order.airwaybill_no] = str(delivery_date)
                         break
-                break
-            except:
+        except:
-                pass
+            pass
     print "Destination City Reached Orders"
     print destination_city_reached_orders
     return destination_city_reached_orders
 def read_first_delivery_attempt_orders(orders_tobe_first_delivery_attempted):
     first_atdl_orders = {}
-    awb_number_list =[]
     for order in orders_tobe_first_delivery_attempted:
-        awb_number_list.append(order.airwaybill_no)
+        try:
-    track_update_list = get_track_updates(awb_number_list)
+            root =  fromstring(str(get_updates(order.airwaybill_no)))
-    for update in track_update_list:
-        if update == 'DUMMY':
+            children = root.getchildren()
-            continue
+            for child in children:
-        else:
-            try:
-                airwaybill_no = update['ReferenceNo']
-                track_list = update['TrackingList']['TrackingList']
+                nodes = child.findall('ShipmentInfo/ShipmentEvent')
-                track_list.reverse()
+                for element in reversed(nodes):
-                for track_update in track_list:
-                    if track_update['TrackingCode'] == 'OFD' :
+                    if element.findtext('TrackingCode', '') == 'OFD':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                        datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                        timestring = element.findtext('Time', '')
-                        delivery_date = datestring + timestring
+                        delivery_date = get_py_datetime(datestring, timestring)
-                        first_atdl_orders[airwaybill_no] = delivery_date
+                        first_atdl_orders[order.airwaybill_no] = str(delivery_date)
                         break
                 break
-            except:
+        except:
-                pass
+            pass
     print "FIRST DELIVERY ATTEMPT MADE Orders"
     print first_atdl_orders
     return first_atdl_orders
 def read_delivery_orders(orders_tobe_delivered):
     delivered_orders = {}
     returned_orders = {}
     undelivered_orders = {}
-    awb_order_map = {}
     for order in orders_tobe_delivered:
-        awb_order_list =[]
-        awb_order_list.append(order.id)
-        awb_order_list.append(order.shipping_timestamp)
-        awb_order_map[order.airwaybill_no]= awb_order_list
-    track_update_list = get_track_updates(awb_order_map.keys())
-    for update in track_update_list:
-        if update == 'DUMMY':
-            continue
-        else:
-            try:
+        try:
-                airwaybill_no = update['ReferenceNo']
-                track_list = update['TrackingList']['TrackingList']
+            root =  fromstring(str(get_updates(order.airwaybill_no)))
-                track_list.reverse()
+            children = root.getchildren()
-                reason_for_return = None
+            child_number = 0
-                for record in track_list:
+            for child in children:
-                    if record['TrackingCode'] == 'UDLD' :
+                child_number = child_number + 1
-                        reason_for_return = record['ServiceEvent'].split(" -")[1]
+                nodes = child.findall('ShipmentInfo/ShipmentEvent')
-                        break
+                if len(nodes):
+                    node_number = len(nodes)-1
-                for track_update in track_list:
+                    for element in nodes:
-                    if track_update['TrackingCode'] == 'DLVD' :
+                        if element.findtext('TrackingCode', '') == 'DLVD':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                            datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                            timestring = element.findtext('Time', '')
-                        del_date = datestring + timestring
+                            delivery_date = get_py_datetime(datestring, timestring)
-                        delivery_date = datetime.strptime(del_date,"%Y-%m-%d %H:%M:%S")
+                            element1 = child.findall('ShipmentInfo/Consignee')[0]
-                        receiver = track_update['ServiceEvent'].split("[ ")[1].split(" ]")[0]
+                            receiver = element1.findtext('Name', '')
-                        if to_py_date(awb_order_map.get(airwaybill_no)[1]) > delivery_date:
+                            if to_py_date(order.shipping_timestamp) > delivery_date:
-                            mail(from_user, from_pwd, to, "Delivery Problem for Red Express", "Order id " + str(awb_order_map.get(airwaybill_no)[0]) + " has shipping date " + str(awb_order_map.get(airwaybill_no)[1]) + " larger than delivery date " + str(delivery_date))
+                                mail(from_user, from_pwd, to, "Delivery Problem for Red Express", "Order id " + str(order.id) + " has shipping date " + str(order.shipping_timestamp) + " larger than delivery date " + str(delivery_date))
-                        else:
+                            else:
-                            delivered_orders[airwaybill_no] = str(delivery_date) + "|" +  receiver
+                                delivered_orders[order.airwaybill_no] = str(delivery_date) + "|" +  receiver
-                        break
+                            break
-                    elif track_update['TrackingCode'] == 'RTO' :
+                        elif element.findtext('TrackingCode', '') == 'RTO':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                            datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                            timestring = element.findtext('Time', '')
-                        del_date = datestring + timestring
+                            delivery_date = get_py_datetime(datestring, timestring)
-                        delivery_date = datetime.strptime(del_date,"%Y-%m-%d %H:%M:%S")
-                        if reason_for_return == None:
+                            if node_number < len(nodes)-1:
-                            returned_orders[airwaybill_no] = str(delivery_date) + "|"  + " Order Booked for Return"
+                                reason_for_return = nodes[node_number+1].findtext('ServiceEvent', '')
-                        else:
+                            else:
+                                reason_for_return = element.findtext('ServiceEvent', '')
-                            returned_orders[airwaybill_no] = str(delivery_date) + "|"  + reason_for_return
+                            returned_orders[order.airwaybill_no] = str(delivery_date) + "|" + reason_for_return
-                        break
+                            break
-                    elif track_update['TrackingCode'] == 'UDLD' :
+                        elif element.findtext('TrackingCode', '') == 'UDLD':
-                        date_obj = datetime.strptime(track_update['ExecutionDate'].split(' ')[0],"%m/%d/%Y")
-                        datestring  = date_obj.strftime("%Y-%m-%d")
+                            datestring = element.findtext('Date', '')
-                        timestring = track_update['ExecutionTime']+':00'
+                            timestring = element.findtext('Time', '')
-                        del_date = datestring + timestring
+                            delivery_date = get_py_datetime(datestring, timestring)
-                        delivery_date = datetime.strptime(del_date,"%Y-%m-%d %H:%M:%S")
-                        if reason_for_return == None:
+                            if node_number < len(nodes)-1:
-                            undelivered_orders[airwaybill_no] = str(delivery_date) + "|" + track_update['ServiceEvent'].split(" -")[1]
+                                reason_for_return = nodes[node_number+1].findtext('ServiceEvent', '')
-                        else:
+                            else:
+                                reason_for_return = element.findtext('ServiceEvent', '')
-                            undelivered_orders[airwaybill_no] = str(delivery_date) + "|" + reason_for_return
+                            undelivered_orders[order.airwaybill_no] = str(delivery_date) + "|" + reason_for_return
-                        break
+                            break
-                break
+                        node_number = node_number - 1
-            except:
+        except:
-                pass
+            pass
     print "Delivered Orders:"
     print delivered_orders
     print "Returned Orders:"

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/script/RedExpressLogisticsReconciliation.py – Rev 8700 → 8702