WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/logistics/service/impl/DataAccessor.py

 from elixir import session
 import datetime, time
 import sys
 from shop2020.utils.caching.SimpleCaching import memoized
+warehouse_allocation_cache = {}
+serviceable_location_cache = {}
+delivery_estimate_cache = {}
 def initialize(dbname="logistics", db_hostname="localhost"):
     log_entry("initialize@DataAccessor", "Initializing data service")
     DataService.initialize(dbname, db_hostname)
+    print "Starting cache population at: " + datetime.datetime.now()
+    __cache_warehouse_allocation_table()
+    __cache_serviceable_location_details_table()
+    __cache_delivery_estimate_table()
+    close_session()
+    print "Done cache population at: " + datetime.datetime.now()
+def __cache_delivery_estimate_table():
+    delivery_estimates = DeliveryEstimate.query.all()
+    for delivery_estimate in delivery_estimates:
+        delivery_estimate_cache[delivery_estimate.destination_pin, delivery_estimate.provider_id, delivery_estimate.warehouse_location]\
+        =delivery_estimate.delivery_time, delivery_estimate.reliability
+def __cache_serviceable_location_details_table():
+    serviceable_locations = ServiceableLocationDetails.query.all()
+    for serviceable_location in serviceable_locations:
+        try:
+            provider_pincodes = serviceable_location_cache[serviceable_location.provider_id]
+        except:
+            provider_pincodes = {}
+            serviceable_location_cache[serviceable_location.provider_id] = provider_pincodes
+        provider_pincodes[serviceable_location.dest_pincode] = serviceable_location.dest_code, serviceable_location.exp, serviceable_location.cod, serviceable_location.station_type
+def __cache_warehouse_allocation_table():
+    warehouse_allocations = WarehouseAllocation.query.all()
+    for warehouse_allocation in warehouse_allocations:
+        warehouse_allocation_cache[warehouse_allocation.pincode]=warehouse_allocation.primary_warehouse_location
 def get_provider(provider_id):
     provider =  Provider.get_by(id=provider_id)
     return provider
 def get_providers():
     providers = Provider.query.all()
     return providers
 def is_cod_allowed(destination_pin):
+    cod = False
     try:
-        sld = ServiceableLocationDetails.get_by(dest_pincode = destination_pin, cod = True)
+        for value in serviceable_location_cache.itervalues():
+            cod ||= value[destination_pin][2]
     except Exception as ex:
         print "Unexpected error:", sys.exc_info()[0]
-    if sld:
-        return True
+    return cod
-    else:
-        return False
 def get_logistics_estimation(destination_pin, item_selling_price, warehouse_location=None, type=DeliveryType.PREPAID):
     if warehouse_location is None:
         try:
-            warehouse_location = WarehouseAllocation.get_by(pincode = destination_pin).primary_warehouse_location
+            warehouse_location = warehouse_allocation_cache[destination_pin]
         except:
             print "Unexpected error:", sys.exc_info()[0]
             raise LogisticsServiceException(101, "No Warehouse locations assigned to this pincode: " + destination_pin)
-    provider = __get_logistics_provider_for_destination_pincode(type, destination_pin)
+    provider_id = __get_logistics_provider_for_destination_pincode(type, destination_pin)
-    if not provider:
+    if not provider_id:
         raise LogisticsServiceException(101, "No provider assigned for pincode: " + str(destination_pin) + \
                                         ", and warehouse location: " + str(warehouse_location))
 #    query_provider = DestinationProviderAllocation.query.filter_by(destination_pin = destination_pin)
 #    query_provider = query_provider.filter_by(warehouse_location = warehouse_location)
 #        print ex
 #        print "Unexpected error:", sys.exc_info()[0]
 #        raise LogisticsServiceException(101, "No provider assigned for pincode: " + str(destination_pin) + \
 #                                        ", and warehouse location: " + str(warehouse_location))
-    query = DeliveryEstimate.query.filter_by(warehouse_location = warehouse_location)
-    query = query.filter_by(destination_pin = destination_pin)
-    query = query.filter_by(provider = provider)
     try:
-        return query.first()
+        return delivery_estimate_cache[destination_pin, provider_id, warehouse_location][0], delivery_estimate_cache[destination_pin, provider_id, warehouse_location][1], provider_id, warehouse_location
     except Exception as ex:
         print ex
         raise LogisticsServiceException(103, "No Logistics partner listed for this destination pincode and the primary warehouse")
 def __get_logistics_provider_for_destination_pincode(type, destination_pin):
+    for provider_id, value in serviceable_location_cache.iteritems():
-    try:
+        try:
-        sld = ServiceableLocationDetails.get_by(dest_pincode = destination_pin)
+            dest_code, exp, cod, station_type = value[destination_pin]
+        except:
-        if type == DeliveryType.PREPAID and sld.exp:
+            print "Unexpected error:", sys.exc_info()[0]
-            provider = sld.provider
+            continue
-        if type == DeliveryType.COD and sld.cod:
+        if type == DeliveryType.PREPAID and exp:
-            provider = sld.provider
+            return provider_id
-    except Exception as ex:
+        if type == DeliveryType.COD and cod:
-        print "Unexpected error:", sys.exc_info()[0]
+            return provider_id
-    return provider
+    return None
 def add_empty_AWBs(numbers, provider_id, type):
     for number in numbers:
         query = Awb.query.filter_by(awb_number = number, provider_id = provider_id)
         try:
     awb = Awb.get_by(awb_number = awb_number, provider_id = provider_id)
     query = AwbUpdate.query.filter_by(awb = awb)
     info = query.all()
     return info
-'''
-Cache the return values of the function for one day
-'''
-@memoized(86400)
 def get_holidays(start_date, end_date):
     query = PublicHolidays.query
     if start_date != -1:
         query = query.filter(PublicHolidays.date >= to_py_date(start_date))
     if end_date != -1:

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/logistics/service/impl/DataAccessor.py – Rev 3192 → 3217