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

 It processes the following orders:
 . Orders in DOA_PICKUP_CONFIRMED status : get details of orders that
      were in DOA_PICKUP_CONFIRMED status from database and
      calls aramex api to know whether they are picked up by armaex
      and changes the status to DOA_RETURN_IN_TRANSIT if it is done.
+. Orders in RET_PICKUP_CONFIRMED status : get details of orders that
+     were in RET_PICKUP_CONFIRMED status from database and
+     calls aramex api to know whether they are picked up by armaex
+     and changes the status to RET_RETURN_IN_TRANSIT if it is done.
 . Orders in SHIPPED_FROM_WH status: get details of orders that
      were in SHIPPED_FROM_WH status from database and
      calls aramex api to know whether they are picked up by armaex
      and changes the status to SHIPPED_TO_LOGST if it is done.
 . Orders in SHIPPED_TO_LOGST status: get details of orders that
      were in SHIPPED_TO_LOGST status from database and
      calls aramex api to know their status and changes the status accordingly.
-It sends out a Pickup mismatch report, a Doa Pickup mismatch and Returned Orders Report
+It sends out a Pickup mismatch report, Return orders Pickup Mismatch report, Doa Pickup mismatch report,
-report to cnc.center@shop2020.in
+Undelivered orders report and Returned Orders report to cnc.center@shop2020.in
 http://www.aramex.com/track_xml.asp?ShipperRef={variable1}&OrgCntry=In&FromDate={variable2}&ToDate={variable3} is hard coded
 to track DOA orders and for other orders ConfigClient is called to get aramex_update_url
 @author: Phani Kumar
 to = ['cnc.center@shop2020.in', "suraj.sharma@shop2020.in", "sandeep.sachdeva@shop2020.in", "parmod.kumar@shop2020.in"]
 def process_dao_pickup_orders(provider):
     try:
         doas_tobe_picked_up = fetch_data(provider.id, OrderStatus.DOA_PICKUP_CONFIRMED)
-        doa_pickup_details = read_dao_pickup_orders(doas_tobe_picked_up)
+        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:
                 print "DOAs not Picked up:"
                 print doas_not_picked_up
             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_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:
+                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_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()
+    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)
         pickup_details = read_pickup_orders(orders_tobe_picked_up)
         orders_not_picked_up = update_picked_orders(provider.id, pickup_details)
         doas_tobe_picked_up = txnClient.getOrdersForProviderForStatus(provider_id, order_status)
         return doas_tobe_picked_up
     except TransactionServiceException as tex:
         print tex.message
-def read_dao_pickup_orders(doas_tobe_picked_up):
+def read_dao_return_pickup_orders(orders_tobe_picked_up):
     #uri=http://www.aramex.com/track_xml.asp?ShipperRef=61582&OrgCntry=In&FromDate=2-6-2012&ToDate=2-6-2012
-    picked_up_doas = {}
+    picked_up_orders = {}
-    for order in doas_tobe_picked_up:
+    for order in orders_tobe_picked_up:
-        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()
         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]
                 if element.findtext('Status', '') == 'SHOR' and element.findtext('Condition', '') == 'PKUP':
                     delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
-                    picked_up_doas[order.pickupRequestNo] = str(delivery_date)
+                    picked_up_orders[order.pickupRequestNo] = str(delivery_date)
         except:
             pass
-    print "Picked up DOAs:"
+    print "Picked up Orders:"
-    print picked_up_doas
+    print picked_up_orders
-    return picked_up_doas
+    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")
         print cex.message
         traceback.print_exc()
     picked_up_orders = {}
     for order in orders_tobe_picked_up:
-        uri = ARAMEX_URL + order.airwaybill_no
-        root = parse(urllib2.urlopen(uri)).getroot()
         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]
                 if element.findtext('Status', '') == 'SHOR' and element.findtext('Condition', '') == 'PKUP':
                     delivery_date = get_py_datetime(element.findtext('ActionDate', ''))
     delivered_orders = {}
     delivered_orders_but_wrong_code_mentioned = {}
     returned_orders = {}
     undelivered_orders = {}
     for order in orders_tobe_delivered:
-        uri = ARAMEX_URL + order.airwaybill_no
-        root = parse(urllib2.urlopen(uri)).getroot()
         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
                 while i>=0:
                     element = nodes[i]
         doas_not_picked_up = 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)
+        return returns_not_picked_up
+    except TransactionServiceException as tex:
+        print tex.message
 def update_delivered_orders(provider_id, delivered_orders):
     txnClient = TransactionClient().get_client()
     try:
         txnClient.markOrdersAsDelivered(provider_id, delivered_orders)
     except TransactionServiceException as tex:
     mytime = time.strptime(time_string, time_format)
     return datetime.datetime(*mytime[:6])
 def main():
     parser = optparse.OptionParser()
-    parser.add_option("-e", "--doa", dest="doa_report",
-                   action="store_true",
-                   help="Run the DOA pickup reconciliation")
     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 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(doa_report=False, pickup_report=False, delivery_report=False, all_reports=False)
+    parser.set_defaults(pickup_report=False, delivery_report=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:
-        options.doa_report = True
         options.pickup_report = True
         options.delivery_report = True
     provider = get_provider_by_name(options.provider)
-    if options.doa_report:
-        process_dao_pickup_orders(provider)
     if options.pickup_report:
         process_pickup_records(provider)
+        process_dao_pickup_orders(provider)
+        process_return_pickup_orders(provider)
     if options.delivery_report:
         process_delivery_report(provider)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

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