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

 '''
 This class is for only data transfer. Never used outside this module.
 '''
 class _DeliveryEstimateObject:
-    def __init__(self, delivery_time, reliability, provider_id, codAllowed):
+    def __init__(self, delivery_time, reliability, provider_id, codAllowed, otgAvailable):
         self.delivery_time = delivery_time
         self.reliability = reliability
         self.provider_id = provider_id
         self.codAllowed = codAllowed
+        self.otgAvailable = otgAvailable
 def initialize(dbname="logistics", db_hostname="localhost"):
     log_entry("initialize@DataAccessor", "Initializing data service")
     DataService.initialize(dbname, db_hostname)
     print "Starting cache population at: " + str(datetime.datetime.now())
         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
+        provider_pincodes[serviceable_location.dest_pincode] = serviceable_location.dest_code, serviceable_location.exp, serviceable_location.cod, serviceable_location.otgAvailable
 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_providers():
     providers = Provider.query.filter_by(isActive = 1).all()
     return providers
-def get_logistics_estimation(destination_pin, item_selling_price, type=DeliveryType.PREPAID):
+def get_logistics_estimation(destination_pin, item_selling_price):
     logging.info("Getting logistics estimation for pincode:" + destination_pin )
-    provider_id, codAllowed = __get_logistics_provider_for_destination_pincode(type, destination_pin, item_selling_price)
+    provider_id, codAllowed, otgAvailable = __get_logistics_provider_for_destination_pincode(destination_pin, item_selling_price)
     if not provider_id:
         raise LogisticsServiceException(101, "No provider assigned for pincode: " + str(destination_pin))
     try:
         delivery_time = delivery_estimate_cache[destination_pin, provider_id][0]
         reliability = delivery_estimate_cache[destination_pin, provider_id][1]
-        delivery_estimate = _DeliveryEstimateObject(delivery_time, reliability, provider_id, codAllowed)
+        delivery_estimate = _DeliveryEstimateObject(delivery_time, reliability, provider_id, codAllowed, otgAvailable)
         return delivery_estimate
     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, item_selling_price):
+def __get_logistics_provider_for_destination_pincode(destination_pin, item_selling_price):
     if ncr_pincodes.__contains__(destination_pin) and item_selling_price <= 20000:
+        dest_code, exp, iscod, otgAvailable = serviceable_location_cache.get(3).get(destination_pin)
+        otgAvailable = otgAvailable and item_selling_price >= 2000
-        return 3, True
+        return 3, True, otgAvailable
     if serviceable_location_cache.get(3).has_key(destination_pin):
-        dest_code, exp, iscod, station_type = serviceable_location_cache.get(3).get(destination_pin)
+        dest_code, exp, iscod, otgAvailable = serviceable_location_cache.get(3).get(destination_pin)
         iscod = iscod and item_selling_price <= 9600
+        otgAvailable = otgAvailable and item_selling_price >= 2000
-        return 3, iscod
+        return 3, iscod, otgAvailable
     if serviceable_location_cache.get(1).has_key(destination_pin):
-        dest_code, exp, iscod, station_type = serviceable_location_cache.get(1).get(destination_pin)
+        dest_code, exp, iscod, otgAvailable = serviceable_location_cache.get(1).get(destination_pin)
         iscod = iscod and item_selling_price <= 9600
+        otgAvailable = otgAvailable and item_selling_price >= 2000
-        return 1, iscod
+        return 1, iscod, otgAvailable
     else:
         return None, False
 def get_destination_code(providerId, pinCode):
     serviceableLocationDetail = ServiceableLocationDetails.query.filter_by(provider_id = providerId, dest_pincode = pinCode).one()
     return PickupStore.query.filter_by(id = storeId).one()
 def get_pickup_store_by_hotspot_id(hotspotId):
     return PickupStore.query.filter_by(hotspotId = hotspotId).one()
-def add_pincode(provider, pincode, destCode, exp, cod, stationType):
+def add_pincode(provider, pincode, destCode, exp, cod, stationType, otgAvailable):
     provider = Provider().query.filter_by(id = provider).one()
     serviceableLocationDetails = ServiceableLocationDetails()
     serviceableLocationDetails.provider = provider
     serviceableLocationDetails.dest_pincode = pincode
     serviceableLocationDetails.dest_code = destCode
     serviceableLocationDetails.exp = exp
     serviceableLocationDetails.cod = cod
     serviceableLocationDetails.station_type = stationType
+    serviceableLocationDetails.otgAvailable = otgAvailable
     session.commit()
-def update_pincode(providerId, pincode, exp, cod):
+def update_pincode(providerId, pincode, exp, cod, otgAvailable):
     serviceableLocationDetails = ServiceableLocationDetails().get_by(provider_id = providerId, dest_pincode = pincode).one()
     serviceableLocationDetails.exp = exp
     serviceableLocationDetails.cod = cod
+    serviceableLocationDetails.otgAvailable = otgAvailable
     session.commit()

Subversion Repositories SmartDukaan

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