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

 http://www.bluedart.com/servlet/RoutingServlet?handler=tnt&action=custawbquery&loginid=DEL24119&awb=ref&format=XML&lickey=6265d61bafa6292c5ddfdb1ee335ca80&verno=1.3&scan=1&numbers={variable1} is hard coded
 to track DOA orders and for other orders ConfigClient is called to get bluedart_update_url
 @author: Phani Kumar
 '''
+from datetime import datetime
 from shop2020.clients.CRMClient import CRMClient
 from shop2020.clients.LogisticsClient import LogisticsClient
 from shop2020.clients.TransactionClient import TransactionClient
-from shop2020.clients.UserClient import UserClient
+from shop2020.model.v1.order.script.LogisticUtils import \
-from LogisticUtils import enqueueMailForFDA
+    create_crm_tickets_for_delivey_attempted_orders
-from shop2020.thriftpy.crm.ttypes import *
+from shop2020.thriftpy.crm.ttypes import TicketCategory, TicketPriority, \
+    TicketStatus, Activity, ActivityType, SearchFilter
 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 suds.client import Client
-from xml.etree.ElementTree import parse, XML, fromstring
+from xml.etree.ElementTree import parse, fromstring
-from datetime import datetime
+import StringIO
+import ast
 import csv
-import datetime
+import gzip
+import json
 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
+import zlib
 if __name__ == '__main__' and __package__ is None:
     import os
     sys.path.insert(0, os.getcwd())
     if client is None:
         client = Client(RED_EXPRESS_URL, timeout=70)
     return client
 defaultUndeliveredAsssigneeId = 47
+dtrUndeliveredAsssigneeId = 33
 from_user = 'cnc.center@shop2020.in'
 from_pwd = '5h0p2o2o'
 to = ['cnc.center@shop2020.in', "amit.sirohi@shop2020.in", "sandeep.sachdeva@shop2020.in", "sunil.kumar@shop2020.in", "rajveer.singh@shop2020.in"]
 def get_updates(awb_number):
-    str = getClient().service.ProcessTrackingRequest('<TrackingRequest><Request><UserID>' + username + '</UserID><Password>' + password + '</Password><TrackingID>' + awb_number + '</TrackingID><TrackingLevel>ALL_DETAILS</TrackingLevel></Request></TrackingRequest>')
+    str1 = getClient().service.ProcessTrackingRequest('<TrackingRequest><Request><UserID>' + username + '</UserID><Password>' + password + '</Password><TrackingID>' + awb_number + '</TrackingID><TrackingLevel>ALL_DETAILS</TrackingLevel></Request></TrackingRequest>')
-    print str
-    return str
+    return str1
 def get_updates_for_user(awb_number):
     root =  fromstring(str(get_updates(awb_number)))
     children = root.getchildren()
     results = []
         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), to_py_date(order.promised_delivery_time), to_py_date(order.expected_delivery_time), 'True'  if order.otg else 'False'])
-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
-            searchFilter.ticketCategory = TicketCategory.UNDELIVERED
-            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.assigneeId = defaultUndeliveredAsssigneeId
-                ticket.category = TicketCategory.UNDELIVERED
-                ticket.priority = TicketPriority.HIGH
-                ticket.status = TicketStatus.OPEN
-                ticket.description = description
-                ticket.orderId = order.id
-                ticket.airwayBillNo = order.airwaybill_no
-                activity.creatorId = 1
-                activity.ticketAssigneeId = ticket.assigneeId
-                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)
-                '''
-                Inform user about first delivery attempt
-                '''
-                enqueueMailForFDA(order)
-    except:
-        print "Some issue while creating crm tickets for orders in FIRST_DELIVERY_ATTEMPT_MADE status"
-        traceback.print_exc()
 def auto_close_crm_tickets_created():
     try:
         ticket_created_orders = []
         tickets_map = {}
         crmServiceClient = CRMClient().get_client()
             tickets_map[old_ticket.orderId] = old_ticket
         print ticket_created_orders
         txnClient = TransactionClient().get_client()
         orders = txnClient.getOrderList(ticket_created_orders)
         for order in orders:
-            if order.status not in [OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE]:
+            if order.status not in [OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE, OrderStatus.RTO_IN_TRANSIT]:
                 old_ticket = tickets_map.get(order.id)
                 old_ticket.status = TicketStatus.CLOSED
                 activity = Activity()
                 activity.creatorId = 1
                 activity.ticketAssigneeId = old_ticket.assigneeId

Subversion Repositories SmartDukaan

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