WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/user/impl/CartDataAccessors.py

     except:
         traceback.print_exc()
         return False
+def validate_fofo_cart(cart, user, privateDealUser, customer_pincode):
+    current_time = datetime.datetime.now()
+    totalQty = 0
+    totalAmount = 0
+    cartMessages = []
+    cartItems = []
+    responseMap = {}
+    cartMessageChanged = 0
+    cartMessageOOS = 0
+    codAllowed = False
+    cartMessageUndeliverable = 0
+    itemIds = [cartLine.item_id for cartLine in cart.lines]
+    catalog_client = CatalogClient().get_client()
+    #logistics_client = LogisticsClient().get_client()
+    #promotion_client = PromotionClient().get_client()
+    inv_client = InventoryClient().get_client()
+    fofoDealsMap = catalog_client.getAllFofoDeals(itemIds, [4, 7])
+    fofoDealsAvailability = inv_client.getFofoAvailability(fofoDealsMap.keys())
+    itemsMap = catalog_client.getItems(itemIds)
+    cart_lines = cart.lines
+    cart.total_price = 0
+    for line in cart_lines:
+        itemQuantityChanged=False
+        cartItem={}
+        tempBulkItemList = []
+        old_estimate = line.estimate
+        item_id = line.item_id
+        item = itemsMap.get(item_id)
+        #in case item is missing remove that line
+        #lets silently remvoe fofoDealsMap as fofo customer is not allowed to orders with fofo
+        if item is None or item.itemStatus==0 or not fofoDealsMap.has_key(item.id):
+            Discount.query.filter(Discount.line==line).delete()
+            line.delete()
+            continue
+        cartItem['itemId']=line.item_id
+        cartItem['quantity']=0
+        cartItem['cartItemMessages']=[]
+        cartItemMessages = cartItem['cartItemMessages']
+        cartItem['color'] = item.color
+        cartItem['catalogItemId'] = item.catalogItemId
+        cartItem['packQuantity'] = item.packQuantity
+        cartItem['minBuyQuantity'] = item.minimumBuyQuantity
+        cartItem['quantityStep'] = item.quantityStep
+        cartItem['bulkPricing'] = tempBulkItemList
+        cartItem['maxQuantity'] =0
+        item_shipping_info = catalog_client.isActive(item_id)
+        if not fofoDealsAvailability.has_key(item_id):
+            continue
+        else:
+            availability = fofoDealsAvailability.get(item_id)
+            if availability < line.quantity:
+                line.quantity = availability
+                itemQuantityChanged=True
+            cartItem['maxQuantity'] = min(availability,100)
+            if item.maximumBuyQuantity is not None and item.maximumBuyQuantity >0:
+                cartItem['maxQuantity'] = min(item_shipping_info.quantity, item.maximumBuyQuantity)
+            if availability < cartItem['minBuyQuantity']:
+                cartItem['minBuyQuantity'] = availability
+            if line.quantity < cartItem['minBuyQuantity']:
+                itemQuantityChanged=True
+                line.quantity = cartItem['minBuyQuantity']
+            if line.quantity > cartItem['maxQuantity']:
+                itemQuantityChanged=True
+                line.quantity = cartItem['maxQuantity']
+            cartItem['quantity'] = line.quantity
+            line.actual_price = fofoDealsMap.get(item_id)
+        cartItem['sellingPrice'] = line.actual_price
+        cartItem['bulkPricing'] = []
+        print "item_shipping_info", item_shipping_info
+        if item_shipping_info.isActive:
+            cart.total_price = cart.total_price + (line.actual_price * line.quantity)
+            ##Lets assign hardcoded deliveryestimate for fofo
+            item_delivery_estimate = 2
+            codAllowed = False
+            cartItem['estimate'] = item_delivery_estimate
+            if itemQuantityChanged:
+                cartMessageChanged += 1
+                cartItemMessages.append({"type":"danger", "messageText":"Only " + str(item_shipping_info.quantity) + " available"})
+            if old_estimate != item_delivery_estimate:
+                line.estimate = item_delivery_estimate
+                cart.updated_on = current_time
+            totalAmount += line.actual_price * cartItem['quantity']
+        else:
+            cartItem['quantity'] = 0
+            cartMessageOOS += 1
+            cartItemMessages.append({"type":"danger", "messageText":"Out of Stock"})
+            Discount.query.filter(Discount.line==line).delete()
+            line.delete()
+        totalQty += cartItem['quantity']
+        if cartItemMessages:
+            cartItems.insert(0, cartItem)
+        else:
+            cartItems.append(cartItem)
+    if cart.checked_out_on is not None:
+        if cart.updated_on > cart.checked_out_on:
+            cart.checked_out_on = None
+    session.commit()
+    responseMap['totalQty']= totalQty
+    responseMap['totalAmount']= totalAmount
+    responseMap['cartMessages']= cartMessages
+    responseMap['cartItems']= cartItems
+    responseMap['pincode']= customer_pincode
+    responseMap['shippingCharge'] = 0
+    responseMap['cartMessageChanged'] = cartMessageChanged
+    responseMap['cartMessageOOS'] = cartMessageOOS
+    responseMap['cartMessageUndeliverable'] = cartMessageUndeliverable
+    responseMap['codAllowed'] = codAllowed
+    return json.dumps(responseMap)
 def validate_cart_new(cartId, customer_pincode, sourceId):
     # No need to validate duplicate items since there are only two ways
     # to add items to a cart and both of them check whether the item being
     # added is a duplicate of an already existing item.
     current_time = datetime.datetime.now()
     #if customer_pincode is 000000 pincode should be considered from address or
     #is address is not present treat is as customer input
     user = User.get_by(active_cart_id = cartId)
+    privateDealUser = PrivateDealUser.get_by(id=user.id)
     if customer_pincode == "000000":
         address = Address.get_by(id=cart.address_id)
         if address:
             customer_pincode = address.pin
+    if privateDealUser is not None and privateDealUser.isActive and privateDealUser.isFofo:
+        return validate_fofo_cart(cart, user, privateDealUser, customer_pincode)
     catalog_client = CatalogClient().get_client()
     logistics_client = LogisticsClient().get_client()
     promotion_client = PromotionClient().get_client()
     responseMap = {}
     totalQty = 0
     nonAccessoryQuantity = 0
     totalAmount = 0
     shippingCharges=0
     bulkPricingItems =[]
     itemIds = [cartLine.item_id for cartLine in cart.lines]
-    privateDealUser = PrivateDealUser.get_by(id=user.id)
-    fofoDealsMap = {}
-    if sourceId==53:
-        #get tagId valid
-        #get all fofoDeals corresponding to item
-        #TODO: hardcoded to be removed
-        fofoDealsMap = catalog_client.getAllFofoDeals(itemIds, [53, 4, 7])
     if privateDealUser is not None and privateDealUser.isActive:
-        if not fofoDealsMap:
-            deals = catalog_client.getAllActivePrivateDeals(itemIds, 0)
+        deals = catalog_client.getAllActivePrivateDeals(itemIds, 0)
-            bulkPricingMap = catalog_client.getBulkPricingForItems(itemIds)
+        bulkPricingMap = catalog_client.getBulkPricingForItems(itemIds)
-        else:
-            remainingItemIds = []
-            for remainingItemId in itemIds:
-                if remainingItemId not  in fofoDealsMap.keys():
-                    remainingItemIds.append(remainingItemId)
-            if remainingItemIds:
-                deals = catalog_client.getAllActivePrivateDeals(remainingItemIds, 0)
-                bulkPricingMap = catalog_client.getBulkPricingForItems(remainingItemIds)
         dealItems = deals.keys()
         bulkPricingItems = bulkPricingMap.keys()
     cart.total_price = 0
     itemsMap = catalog_client.getItems(itemIds)
             if deals[item_id].dealFreebieOption==0:
                 line.freebieId = 0
             if deals[item_id].dealFreebieOption==2:
                 line.freebieId =  deals[item_id].dealFreebieItemId
             cartItem['dealText'] = line.dealText
-        elif fofoDealsMap.has_key(item_id):
-            line.actual_price = fofoDealsMap.get(item_id)
         else:
             if not singleUnitPricing and item_id in bulkPricingItems:
                 tempBulkItemList.append({'quantity':1,'price':item.sellingPrice})
             if bulkPrice is None:
                 line.actual_price = item.sellingPrice
                     if billingWarehouse is not None:
                         estimateVal = None
                         if not logistics_client.isAlive() :
                             logistics_client = LogisticsClient().get_client()
                         try:
-                            estimateVal = logistics_client.getFirstDeliveryEstimateForWhLocation(customer_pincode, billingWarehouse.stateId)
+                            estimateVal = logistics_client.getFirstDeliveryEstimateForWhLocation(customer_pincode, billingWarehouse.logisticsLocation)
                             if estimateVal ==-1:
                                 item_delivery_estimate =-1
                         except:
                             traceback.print_exc()
                             pass

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/user/impl/CartDataAccessors.py – Rev 22715 → 22721