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

     import os
     sys.path.insert(0, os.getcwd())
 from shop2020.clients.LogisticsClient import LogisticsClient
 from shop2020.clients.TransactionClient import TransactionClient
+from shop2020.clients.UserClient import UserClient
 from shop2020.config.client.ConfigClient import ConfigClient
+from shop2020.clients.CRMClient import CRMClient
 from shop2020.thriftpy.config.ttypes import ConfigException
 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 shop2020.thriftpy.crm.ttypes import *
+try:
+    config_client = ConfigClient()
+    ARAMEX_URL = config_client.get_property("aramex_update_url")
+except ConfigException as cex:
+    print cex.message
+    traceback.print_exc()
 from_user = 'cnc.center@shop2020.in'
 from_pwd = '5h0p2o2o'
 to = ['cnc.center@shop2020.in', "suraj.sharma@shop2020.in", "sandeep.sachdeva@shop2020.in", "manoj.kumar@shop2020.in"]
 def process_dao_pickup_orders(provider):
     try:
-        doas_tobe_picked_up = fetch_data(provider.id, OrderStatus.DOA_PICKUP_CONFIRMED)
+        doas_tobe_picked_up = fetch_data(provider.id, [OrderStatus.DOA_PICKUP_CONFIRMED])
         doa_pickup_details = read_dao_return_pickup_orders(doas_tobe_picked_up)
-        doas_not_picked_up = update_picked_doas(provider.id, doa_pickup_details)
-        try:
-            if doas_not_picked_up:
+        if doa_pickup_details:
-                print "DOAs not Picked up:"
-                print doas_not_picked_up
-                mismatch_file = "/tmp/DoaPickupMismatch.csv"
+            update_picked_doas(provider.id, doa_pickup_details)
-                print "Some of our DOA orders were not picked up. Printing report to:" + mismatch_file
-                print_dao_return_pickup_mismatch_report(mismatch_file, doas_not_picked_up)
-                pickup_mismatch_part = [get_attachment_part(mismatch_file)]
-                mail(from_user, from_pwd, to,\
-                     "DOA Pickup Mismatch for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     pickup_mismatch_part)
-        except Exception:
-            print "Some issue sending the DOA mismatch report"
-            traceback.print_exc()
     except:
         print "Some issue while processing the orders in DOA_PICKUP_CONFIRMED status"
         traceback.print_exc()
 def process_return_pickup_orders(provider):
     try:
-        returns_tobe_picked_up = fetch_data(provider.id, OrderStatus.RET_PICKUP_CONFIRMED)
+        returns_tobe_picked_up = fetch_data(provider.id, [OrderStatus.RET_PICKUP_CONFIRMED])
         returns_pickup_details = read_dao_return_pickup_orders(returns_tobe_picked_up)
-        returns_not_picked_up = update_picked_returns(provider.id, returns_pickup_details)
-        try:
-            if returns_not_picked_up:
+        if returns_pickup_details:
-                print "Return Orders not Picked up:"
-                print returns_not_picked_up
-                mismatch_file = "/tmp/ReturnsPickupMismatch.csv"
-                print "Some of our Return orders were not picked up. Printing report to:" + mismatch_file
-                print_dao_return_pickup_mismatch_report(mismatch_file, returns_not_picked_up)
+            update_picked_returns(provider.id, returns_pickup_details)
-                pickup_mismatch_part = [get_attachment_part(mismatch_file)]
-                mail(from_user, from_pwd, to,\
-                     "Return orders Pickup Mismatch for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     pickup_mismatch_part)
-        except Exception:
-            print "Some issue sending the Return orders mismatch report"
-            traceback.print_exc()
     except:
         print "Some issue while processing the orders in RET_PICKUP_CONFIRMED status"
         traceback.print_exc()
 def process_pickup_records(provider):
     try:
-        orders_tobe_picked_up = fetch_data(provider.id, OrderStatus.SHIPPED_FROM_WH)
+        orders_tobe_picked_up = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH])
         pickup_details = read_pickup_orders(orders_tobe_picked_up)
-        orders_not_picked_up = update_picked_orders(provider.id, pickup_details)
-        try:
-            if orders_not_picked_up:
-                print "Orders not Picked up:"
-                print orders_not_picked_up
-                mismatch_file = "/tmp/PickupMismatch.csv"
-                print "Some of our orders were not picked up. Printing report to:" + mismatch_file
-                print_pickup_mismatch_report(mismatch_file, orders_not_picked_up)
-                pickup_mismatch_part = [get_attachment_part(mismatch_file)]
-                mail(from_user, from_pwd, to,\
-                     "Order Pickup Mismatch for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     pickup_mismatch_part)
-        except Exception:
+        if pickup_details:
-            print "Some issue sending the pickup mismatch report"
+            update_picked_orders(provider.id, pickup_details)
-            traceback.print_exc()
     except:
         print "Some issue while processing the orders in SHIPPED_FROM_WH status"
         traceback.print_exc()
+def process_local_connection_orders(provider):
+    try:
+        orders_tobe_local_connected = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST])
+        local_connected_orders = read_local_connection_orders(orders_tobe_local_connected)
+        if local_connected_orders:
+            update_local_connected_orders(provider.id, local_connected_orders)
+    except:
+        print "Some issue while processing the orders for local connection status"
+        traceback.print_exc()
+def process_reached_destination_city_orders(provider):
+    try:
+        orders_tobe_reached_destination_city = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.SHIPPED_TO_DESTINATION_CITY])
+        destination_city_reached_orders = read_reached_destination_orders(orders_tobe_reached_destination_city)
+        if destination_city_reached_orders:
+            update_destination_city_reached_orders(provider.id, destination_city_reached_orders)
+    except:
+        print "Some issue while processing the orders for Reached Destination City status"
+        traceback.print_exc()
+def process_first_delivery_attempt_orders(provider):
+    try:
+        orders_tobe_first_delivery_attempted = fetch_data(provider.id, [OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.SHIPPED_TO_DESTINATION_CITY, OrderStatus.REACHED_DESTINATION_CITY])
+        first_atdl_orders = read_first_delivery_attempt_orders(orders_tobe_first_delivery_attempted)
+        if first_atdl_orders:
+            update_first_atdl_orders(provider.id, first_atdl_orders)
+    except:
+        print "Some issue while processing the orders for First delivery attempt status"
+        traceback.print_exc()
 def process_delivery_report(provider):
     try:
-        orders_tobe_delivered = fetch_data(provider.id, OrderStatus.SHIPPED_TO_LOGST)
+        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, delivered_orders_but_wrong_code_mentioned, returned_orders, undelivered_orders = read_delivery_orders(orders_tobe_delivered)
+        delivered_orders, returned_orders, undelivered_orders = read_delivery_orders(orders_tobe_delivered)
         if delivered_orders:
             update_delivered_orders(provider.id, delivered_orders)
         if returned_orders:
             update_returned_orders(provider.id, returned_orders)
-            try:
-                returned_orders_file = "/tmp/ReturnedOrders.csv"
-                print_rto_orders_report(returned_orders_file, returned_orders)
-                returned_orders_report = [get_attachment_part(returned_orders_file)]
-                mail(from_user, from_pwd, to,\
-                     "Returned Orders Report for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     returned_orders_report)
+        if undelivered_orders:
-            except:
-                print "Some issue sending the returned orders report"
-                traceback.print_exc()
-        if delivered_orders_but_wrong_code_mentioned:
-            try:
-                delivered_orders_but_wrong_code_mentioned_file = "/tmp/delivered_orders_but_wrong_code.csv"
-                print_delivered_orders_but_wrong_code_mentioned_report(delivered_orders_but_wrong_code_mentioned_file, delivered_orders_but_wrong_code_mentioned)
-                delivered_orders_but_wrong_code_mentioned_report = [get_attachment_part(delivered_orders_but_wrong_code_mentioned_file)]
-                mail(from_user, from_pwd, to,\
-                     "Delivered Orders but Wrong Code Mentioned Report for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     delivered_orders_but_wrong_code_mentioned_report)
-            except:
-                print "Some issue sending the delivered orders but wrong code mentioned report"
-                traceback.print_exc()
-        try:
-            orders_not_delivered = update_reason_of_undelivered_orders(provider.id, undelivered_orders)
+            update_reason_of_undelivered_orders(provider.id, undelivered_orders)
-            if orders_not_delivered:
-                print "Undelivered Orders:"
-                print orders_not_delivered
-                mismatch_file = "/tmp/UndeliveredOrders.csv"
-                print "Some of our Orders were not delivered. Printing report to:" + mismatch_file
-                print_undelivered_orders_report(mismatch_file, orders_not_delivered)
-                pickup_mismatch_part = [get_attachment_part(mismatch_file)]
-                mail(from_user, from_pwd, to,\
-                     "Orders that are undelivered but picked up or shipped four days ago for " + provider.name,\
-                     "This is a system generated email.Please don't reply to it.",\
-                     pickup_mismatch_part)
-        except Exception:
-            print "Some issue updating and sending the undelivered orders report"
-            traceback.print_exc()
     except:
-        print "Some issue while processing the orders in SHIPPED_TO_LOGST status"
+        print "Some issue while processing the orders for delivery status"
+        traceback.print_exc()
+def generate_reports(provider):
+    get_doas_not_picked_up(provider)
+    get_returns_not_picked_up(provider)
+    get_orders_not_picked_up(provider)
+    get_orders_pending_local_connection(provider)
+    get_returned_orders(provider)
+    get_orders_not_delivered(provider)
+def get_doas_not_picked_up(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        doas_not_picked_up = txnClient.getDoasNotPickedUp(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if doas_not_picked_up:
+            print "DOAs not Picked up:"
+            print doas_not_picked_up
+            mismatch_file = "/tmp/DoaPickupMismatch.csv"
+            print "Some of our DOA orders were not picked up. Printing report to:" + mismatch_file
+            print_dao_return_pickup_mismatch_report(mismatch_file, doas_not_picked_up)
+            pickup_mismatch_part = [get_attachment_part(mismatch_file)]
+            mail(from_user, from_pwd, to,\
+                 "DOA Pickup Mismatch for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 pickup_mismatch_part)
+    except Exception:
+        print "Some issue sending the DOA mismatch report"
+        traceback.print_exc()
+def get_returns_not_picked_up(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        returns_not_picked_up = txnClient.getReturnOrdersNotPickedUp(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if returns_not_picked_up:
+            print "Return Orders not Picked up:"
+            print returns_not_picked_up
+            mismatch_file = "/tmp/ReturnsPickupMismatch.csv"
+            print "Some of our Return orders were not picked up. Printing report to:" + mismatch_file
+            print_dao_return_pickup_mismatch_report(mismatch_file, returns_not_picked_up)
+            pickup_mismatch_part = [get_attachment_part(mismatch_file)]
+            mail(from_user, from_pwd, to,\
+                 "Return orders Pickup Mismatch for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 pickup_mismatch_part)
+    except Exception:
+        print "Some issue sending the Return orders mismatch report"
+        traceback.print_exc()
+def get_orders_not_picked_up(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        orders_not_picked_up = txnClient.getOrdersNotPickedUp(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if orders_not_picked_up:
+            print "Orders not Picked up:"
+            print orders_not_picked_up
+            mismatch_file = "/tmp/PickupMismatch.csv"
+            print "Some of our orders were not picked up. Printing report to:" + mismatch_file
+            print_pickup_mismatch_report(mismatch_file, orders_not_picked_up)
+            pickup_mismatch_part = [get_attachment_part(mismatch_file)]
+            mail(from_user, from_pwd, to,\
+                 "Order Pickup Mismatch for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 pickup_mismatch_part)
+    except Exception:
+        print "Some issue sending the pickup mismatch report"
+        traceback.print_exc()
+def get_orders_pending_local_connection(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        orders_pending_local_connection = txnClient.getOrdersNotLocalConnected(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if orders_pending_local_connection:
+            print "Local Connection Pending Orders:"
+            print orders_pending_local_connection
+            mismatch_file = "/tmp/LocalConnectionPendingOrders.csv"
+            print "Some of our Orders were not Shipped to Destination yet. Printing report to:" + mismatch_file
+            print_undelivered_orders_report(mismatch_file, orders_pending_local_connection)
+            pickup_mismatch_part = [get_attachment_part(mismatch_file)]
+            mail(from_user, from_pwd, to,\
+                 "Orders that are not Shipped to Destination yet for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 pickup_mismatch_part)
+    except Exception:
+        print "Some issue updating and sending the Local Connection orders report"
+        traceback.print_exc()
+def get_returned_orders(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        returned_orders = txnClient.getRTOrders(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if returned_orders:
+            print "Returned Orders:"
+            print returned_orders
+            returned_orders_file = "/tmp/ReturnedOrders.csv"
+            print "Some of our Orders were returned by logistics provider. Printing report to:" + returned_orders_file
+            print_rto_orders_report(returned_orders_file, returned_orders)
+            returned_orders_report = [get_attachment_part(returned_orders_file)]
+            mail(from_user, from_pwd, to,\
+                 "Returned Orders Report for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 returned_orders_report)
+    except:
+        print "Some issue sending the returned orders report"
+        traceback.print_exc()
+def get_orders_not_delivered(provider):
+    txnClient = TransactionClient().get_client()
+    try:
+        orders_not_delivered = txnClient.getNonDeliveredOrdersbyCourier(provider.id)
+    except TransactionServiceException as tex:
+        print tex.message
+    try:
+        if orders_not_delivered:
+            print "Undelivered Orders:"
+            print orders_not_delivered
+            mismatch_file = "/tmp/UndeliveredOrders.csv"
+            print "Some of our Orders were not delivered. Printing report to:" + mismatch_file
+            print_undelivered_orders_report(mismatch_file, orders_not_delivered)
+            pickup_mismatch_part = [get_attachment_part(mismatch_file)]
+            mail(from_user, from_pwd, to,\
+                 "Orders that are undelivered but picked up or shipped four days ago for " + provider.name,\
+                 "This is a system generated email.Please don't reply to it.",\
+                 pickup_mismatch_part)
+    except Exception:
+        print "Some issue updating and sending the undelivered orders report"
         traceback.print_exc()
 def get_provider_by_name(provider_name):
     logistics_client = LogisticsClient().get_client()
     provider = None
             break
     if provider == None:
         sys.exit("Can't continue execution: No such provider")
     return provider
-def fetch_data(provider_id, order_status):
+def fetch_data(provider_id, order_status_list):
     txnClient = TransactionClient().get_client()
     try:
-        doas_tobe_picked_up = txnClient.getOrdersForProviderForStatus(provider_id, order_status)
+        doas_tobe_picked_up = txnClient.getOrdersForProviderForStatus(provider_id, order_status_list)
         return doas_tobe_picked_up
     except TransactionServiceException as tex:
         print tex.message
 def read_dao_return_pickup_orders(orders_tobe_picked_up):
     for order in orders_tobe_picked_up:
         try:
             uri = 'http://www.aramex.com/track_xml.asp?ShipperRef=' + str(order.pickupRequestNo) + '&OrgCntry=In&FromDate=' + to_py_date(order.doa_auth_timestamp).strftime("%m-%d-%Y") +'&ToDate=' + datetime.date.today().strftime("%m-%d-%Y")
             root = parse(urllib2.urlopen(uri)).getroot()
             nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
-            if len(nodes):
-                element = nodes[len(nodes)-1]
+            for element in reversed(nodes):
-                if element.findtext('Status', '') == 'SHOR' and element.findtext('Condition', '') == 'PKUP':
-                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-                    picked_up_orders[order.pickupRequestNo] = str(delivery_date)
+                picked_up_orders[order.pickupRequestNo] = str(delivery_date)
+                break
         except:
             pass
     print "Picked up Orders:"
     print picked_up_orders
     return picked_up_orders
 def read_pickup_orders(orders_tobe_picked_up):
-    try:
-        config_client = ConfigClient()
-        ARAMEX_URL = config_client.get_property("aramex_update_url")
-    except ConfigException as cex:
-        print cex.message
-        traceback.print_exc()
     picked_up_orders = {}
     for order in orders_tobe_picked_up:
         try:
             uri = ARAMEX_URL + order.airwaybill_no
             root = parse(urllib2.urlopen(uri)).getroot()
             nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
-            if len(nodes):
-                element = nodes[len(nodes)-1]
+            for element in reversed(nodes):
-                if element.findtext('Status', '') == 'SHOR' and element.findtext('Condition', '') == 'PKUP':
-                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-                    picked_up_orders[order.airwaybill_no] = str(delivery_date)
+                picked_up_orders[order.airwaybill_no] = str(delivery_date)
+                break
         except:
             pass
     print "Picked up Orders:"
     print picked_up_orders
     return picked_up_orders
-def read_delivery_orders(orders_tobe_delivered):
+def read_local_connection_orders(orders_tobe_local_connected):
+    local_connected_orders = {}
+    for order in orders_tobe_local_connected:
-    try:
+        try:
+            uri = ARAMEX_URL + order.airwaybill_no
+            root = parse(urllib2.urlopen(uri)).getroot()
+            nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
-        config_client = ConfigClient()
+            for element in reversed(nodes):
+                # For local delivery source city and destination city will be same
+                if root.findtext('HAWBDetails/HAWBOriginEntity', '') == root.findtext('HAWBDetails/HAWBDestEntity', '') and element.findtext('Status', '') == 'SHMF' and element.findtext('Condition', '') == 'MNOB':
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-        ARAMEX_URL = config_client.get_property("aramex_update_url")
+                    local_connected_orders[order.airwaybill_no] = str(delivery_date)
+                    break
+                # For outside delivery source city and destination city will be different, so checking for last scan at source city branch.
-    except ConfigException as cex:
+                elif root.findtext('HAWBDetails/HAWBOriginEntity', '') != root.findtext('HAWBDetails/HAWBDestEntity', '') and element.findtext('BranchID', '') == getOriginCityBranchID(root.findtext('HAWBDetails/HAWBOriginEntity', '')) and element.findtext('Status', '') == 'SHMF' and element.findtext('Condition', '') == 'MNOB':
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    local_connected_orders[order.airwaybill_no] = str(delivery_date)
-        print cex.message
+                    break
-        traceback.print_exc()
+        except:
+            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 = {}
+    for order in orders_tobe_reached_destination_city:
+        try:
+            uri = ARAMEX_URL + order.airwaybill_no
+            root = parse(urllib2.urlopen(uri)).getroot()
+            nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
+            for element in reversed(nodes):
+                if root.findtext('HAWBDetails/HAWBOriginEntity', '') == root.findtext('HAWBDetails/HAWBDestEntity', '') and element.findtext('UpdateEntity', '') == root.findtext('HAWBDetails/HAWBDestEntity', ''):
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    destination_city_reached_orders[order.airwaybill_no] = str(delivery_date)
+                    break
+                elif root.findtext('HAWBDetails/HAWBOriginEntity', '') != root.findtext('HAWBDetails/HAWBDestEntity', '') and element.findtext('UpdateEntity', '') == root.findtext('HAWBDetails/HAWBDestEntity', '') and element.findtext('Status', '') == 'SHIB' and element.findtext('Condition', '') == 'SHSC':
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    destination_city_reached_orders[order.airwaybill_no] = str(delivery_date)
+                    break
+        except:
+            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 = {}
+    for order in orders_tobe_first_delivery_attempted:
+        try:
+            uri = ARAMEX_URL + order.airwaybill_no
+            root = parse(urllib2.urlopen(uri)).getroot()
+            nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
+            for element in reversed(nodes):
+                if element.findtext('Status', '') == 'SHUD' and (element.findtext('Condition', '') == 'ATDL' or element.findtext('Condition', '') == 'CSCN'):
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    reason_for_nondelivery = element.findtext('CustomerDescription', '')
+                    first_atdl_orders[order.airwaybill_no] = str(delivery_date) + "|" + reason_for_nondelivery
+                    break
+        except:
+            pass
+    print "FIRST DELIVERY ATTEMPT MADE Orders"
+    print first_atdl_orders
+    return first_atdl_orders
+def read_delivery_orders(orders_tobe_delivered):
     delivered_orders = {}
-    delivered_orders_but_wrong_code_mentioned = {}
     returned_orders = {}
     undelivered_orders = {}
     for order in orders_tobe_delivered:
         try:
             uri = ARAMEX_URL + order.airwaybill_no
             root = parse(urllib2.urlopen(uri)).getroot()
             nodes = root.findall('HAWBDetails/HAWBHistory/HAWBUpdate')
-            if len(nodes):
-                i = len(nodes)-1
+            node_number = len(nodes)-1
-                while i>=0:
-                    element = nodes[i]
+            for element in reversed(nodes):
-                    if element.findtext('Status', '') == 'SHDL' and (element.findtext('Condition', '') == 'DLVD' or element.findtext('Condition', '') == 'DPTT' or element.findtext('Condition', '') == 'DLPT' or element.findtext('Condition', '') == 'LTRB'):
+                if element.findtext('Status', '') == 'SHDL' and (element.findtext('Condition', '') == 'DLVD' or element.findtext('Condition', '') == 'DPTT' or element.findtext('Condition', '') == 'DLPT' or element.findtext('Condition', '') == 'LTRB'):
-                        delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-                        receiver = root.findtext('HAWBDetails/DeliveredTo', '')
+                    receiver = root.findtext('HAWBDetails/DeliveredTo', '')
-                        delivered_orders[order.airwaybill_no] = str(delivery_date) + "|" +  receiver
+                    delivered_orders[order.airwaybill_no] = str(delivery_date) + "|" +  receiver
-                        if element.findtext('Condition', '') != 'DLVD':
-                            delivered_orders_but_wrong_code_mentioned[order.airwaybill_no] = element.findtext('Condition', '')
-                        break
+                    break
-                    elif element.findtext('Condition', '') == 'RTRN' and (element.findtext('Status', '') == 'SHRH' or element.findtext('Status', '') == 'SHUP'):
+                elif element.findtext('Condition', '') == 'RTRN' and (element.findtext('Status', '') == 'SHRH' or element.findtext('Status', '') == 'SHUP'):
-                        delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
+                    delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-                        if i < len(nodes)-1:
+                    if node_number < len(nodes)-1:
-                            reason_for_return = nodes[i+1].findtext('CustomerDescription', '')
+                        reason_for_return = nodes[node_number+1].findtext('CustomerDescription', '')
-                        else:
+                    else:
-                            reason_for_return = element.findtext('CustomerDescription', '')
+                        reason_for_return = element.findtext('CustomerDescription', '')
-                        returned_orders[order.airwaybill_no] = str(delivery_date) + "|" + reason_for_return
+                    returned_orders[order.airwaybill_no] = str(delivery_date) + "|" + reason_for_return
-                        break
+                    break
-                    elif i == 0:
+                elif node_number == 0:
-                        reason = root.findtext('HAWBDetails/CurrentStatus', '')
+                    reason = root.findtext('HAWBDetails/CurrentStatus', '')
-                        undelivered_orders[order.airwaybill_no] = reason
+                    undelivered_orders[order.airwaybill_no] = reason
-                        break
+                    break
-                    i = i-1
+                node_number = node_number - 1
         except:
             pass
     print "Delivered Orders:"
     print delivered_orders
-    print "Delivered Orders but wrong code mentioned:"
-    print delivered_orders_but_wrong_code_mentioned
     print "Returned Orders:"
     print returned_orders
     print "Undelivered Orders"
     print undelivered_orders
-    return delivered_orders, delivered_orders_but_wrong_code_mentioned, returned_orders, undelivered_orders
+    return delivered_orders, returned_orders, undelivered_orders
 def update_picked_orders(provider_id, pickup_details):
     txnClient = TransactionClient().get_client()
     try:
-        orders_not_picked_up = txnClient.markOrdersAsPickedUp(provider_id, pickup_details)
+        txnClient.markOrdersAsPickedUp(provider_id, pickup_details)
-        return orders_not_picked_up
     except TransactionServiceException as tex:
         print tex.message
 def update_picked_doas(provider_id, doa_pickup_details):
     txnClient = TransactionClient().get_client()
     try:
-        doas_not_picked_up = txnClient.markDoasAsPickedUp(provider_id, doa_pickup_details)
+        txnClient.markDoasAsPickedUp(provider_id, doa_pickup_details)
-        return doas_not_picked_up
     except TransactionServiceException as tex:
         print tex.message
 def update_picked_returns(provider_id, returns_pickup_details):
     txnClient = TransactionClient().get_client()
     try:
-        returns_not_picked_up = txnClient.markReturnOrdersAsPickedUp(provider_id, returns_pickup_details)
+        txnClient.markReturnOrdersAsPickedUp(provider_id, returns_pickup_details)
-        return returns_not_picked_up
     except TransactionServiceException as tex:
         print tex.message
 def update_delivered_orders(provider_id, delivered_orders):
     txnClient = TransactionClient().get_client()
         print tex.message
 def update_returned_orders(provider_id, returned_orders):
     txnClient = TransactionClient().get_client()
     try:
-        txnClient.markOrdersAsFailed(provider_id, returned_orders)
+        txnClient.markAsRTOrders(provider_id, returned_orders)
     except TransactionServiceException as tex:
         print tex.message
 def update_reason_of_undelivered_orders(provider_id, undelivered_orders):
     txnClient = TransactionClient().get_client()
     try:
-        orders_not_delivered = txnClient.updateNonDeliveryReason(provider_id, undelivered_orders)
+        txnClient.updateNonDeliveryReason(provider_id, undelivered_orders)
+    except TransactionServiceException as tex:
+        print tex.message
+def update_local_connected_orders(provider_id, local_connected_orders):
+    txnClient = TransactionClient().get_client()
+    try:
+        txnClient.markOrdersAsLocalConnected(provider_id, local_connected_orders)
+    except TransactionServiceException as tex:
+        print tex.message
+def update_destination_city_reached_orders(provider_id, destination_city_reached_orders):
+    txnClient = TransactionClient().get_client()
+    try:
+        txnClient.markOrdersAsDestinationCityReached(provider_id, destination_city_reached_orders)
+    except TransactionServiceException as tex:
-        return orders_not_delivered
+        print tex.message
+def update_first_atdl_orders(provider_id, first_atdl_orders):
+    txnClient = TransactionClient().get_client()
+    try:
+        txnClient.markOrdersAsFirstDeliveryAttempted(provider_id, first_atdl_orders)
     except TransactionServiceException as tex:
         print tex.message
 def print_pickup_mismatch_report(filename, orders):
     writer = csv.writer(open(filename, "wb"), delimiter=',', quoting=csv.QUOTE_NONE)
     writer = csv.writer(open(filename, "wb"), delimiter=',', quoting=csv.QUOTE_NONE)
     writer.writerow(['Order Id', 'Pickup Request No', 'Authorization timestamp'])
     for order in orders:
         writer.writerow([order.id, order.pickupRequestNo, to_py_date(order.doa_auth_timestamp)])
-def print_rto_orders_report(filename, returned_orders):
+def print_rto_orders_report(filename, orders):
     writer = csv.writer(open(filename, "wb"), delimiter=',', quoting=csv.QUOTE_NONE)
-    writer.writerow(['AWB No', 'Return date', 'Reason'])
+    writer.writerow(['Order Id', 'AWB No', 'Return date', 'Reason'])
-    for awb, date_reason in returned_orders.iteritems():
+    for order in orders:
-        date, reason = date_reason.split('|')
+        statusDescription = ''
-        if reason is not None:
+        if order.statusDescription is not None:
-            reason = reason.replace(","," ")
+            statusDescription = order.statusDescription.replace(","," ")
-        writer.writerow([awb, date, reason])
-def print_delivered_orders_but_wrong_code_mentioned_report(filename, delivered_orders_but_wrong_code_mentioned):
+        writer.writerow([order.id, order.airwaybill_no, to_py_date(order.delivery_timestamp), statusDescription])
-    writer = csv.writer(open(filename, "wb"), delimiter=',', quoting=csv.QUOTE_NONE)
-    writer.writerow(['AWB No', 'Code Used'])
-    for awb, code_used in delivered_orders_but_wrong_code_mentioned.iteritems():
-        writer.writerow([awb, code_used])
 def print_undelivered_orders_report(filename, orders):
     writer = csv.writer(open(filename, "wb"), delimiter=',', quoting=csv.QUOTE_NONE)
     writer.writerow(['Order Id', 'AWB No', 'Status', 'Status Description', 'Shipping timestamp', 'Pickup timestamp'])
     for order in orders:
         statusDescription = ''
         if order.statusDescription is not None:
             statusDescription = order.statusDescription.replace(","," ")
         writer.writerow([order.id, order.airwaybill_no, order.status, statusDescription, to_py_date(order.shipping_timestamp), to_py_date(order.pickup_timestamp)])
+def create_crm_tickets_for_delivey_attempted_orders(provider):
+    try:
+        tickets_tobe_created = fetch_data(provider.id, [OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE])
+        userClient = UserClient().get_client()
+        crmServiceClient = CRMClient().get_client()
+        for order in tickets_tobe_created:
+            ticket_created = False
+            searchFilter = SearchFilter()
+            user = userClient.getUserByEmail(order.customer_email)
+            if user is None or user.userId == -1:
+                searchFilter.customerEmailId = order.customer_email
+                searchFilter.customerMobileNumber = order.customer_mobilenumber
+            else:
+                searchFilter.customerId = user.userId
+            tickets = crmServiceClient.getTickets(searchFilter)
+            print tickets
+            for old_ticket in tickets:
+                if old_ticket.orderId == order.id:
+                    ticket_created = True
+                    break
+            if not ticket_created:
+                print "creating ticket for orderId:"+str(order.id)
+                ticket = Ticket()
+                activity = Activity()
+                description = order.statusDescription + "\n\nOrder not delivered by courier due to problems at customer end."
+                ticket.creatorId = 1
+                ticket.category = TicketCategory.DELIVERY_PROBLEM
+                ticket.priority = TicketPriority.HIGH
+                ticket.status = TicketStatus.OPEN
+                ticket.description = description
+                ticket.orderId = order.id
+                ticket.airwayBillNo = order.airwaybill_no
+                activity.creatorId = 1
+                activity.type = ActivityType.OTHER
+                activity.description = description
+                activity.ticketCategory = ticket.category
+                activity.ticketDescription = ticket.description
+                activity.ticketPriority = ticket.priority
+                activity.ticketStatus = ticket.status
+                if user is None or user.userId == -1:
+                    ticket.customerEmailId = order.customer_email
+                    ticket.customerMobileNumber = order.customer_mobilenumber
+                    ticket.customerName = order.customer_name
+                    activity.customerEmailId = order.customer_email
+                    activity.customerMobileNumber = order.customer_mobilenumber
+                    activity.customerName = order.customer_name
+                else:
+                    ticket.customerId = user.userId
+                    activity.customerId = user.userId
+                crmServiceClient.insertTicket(ticket, activity)
+    except:
+        print "Some issue while creating crm tickets for orders in FIRST_DELIVERY_ATTEMPT_MADE status"
+        traceback.print_exc()
 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 = "%m/%d/%Y %I:%M:%S %p"
     if time_string == '':
         return None
     mytime = time.strptime(time_string, time_format)
     return datetime.datetime(*mytime[:6])
+def getOriginCityBranchID(originCity):
+    branchId_OriginCitymap = {'DEL':'7933'}
+    if originCity is None or originCity == '':
+        return ''
+    else:
+        return branchId_OriginCitymap.get(originCity)
 def main():
     parser = optparse.OptionParser()
     parser.add_option("-p", "--pickup", dest="pickup_report",
                    action="store_true",
                    help="Run the pickup reconciliation")
     parser.add_option("-d", "--delivery", dest="delivery_report",
                    action="store_true",
                    help="Run the delivery reconciliation")
+    parser.add_option("-r", "--reports", dest="gen_reports",
+                   action="store_true",
+                   help="Generate logistic reconciliation reports")
     parser.add_option("-a", "--all", dest="all_reports",
                    action="store_true",
                    help="Run all reconciliations")
     parser.add_option("-P", "--provider", dest="provider",
                    default="Aramex", type="string",
                    help="The PROVIDER this report is for",
                    metavar="PROVIDER")
-    parser.set_defaults(pickup_report=False, delivery_report=False, all_reports=False)
+    parser.set_defaults(pickup_report=False, delivery_report=False, gen_reports=False, all_reports=False)
     (options, args) = parser.parse_args()
     if len(args) != 0:
         parser.error("You've supplied extra arguments. Are you sure you want to run this program?")
     if options.all_reports:
     if options.pickup_report:
         process_pickup_records(provider)
         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_delivery_report(provider)
+        create_crm_tickets_for_delivey_attempted_orders(provider)
+    if options.gen_reports:
+        generate_reports(provider)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/script/AramexLogisticsReconciliation.py – Rev 4815 → 4910