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

 Created on 10-May-2010
 @author: ashish
 '''
 from elixir import *
-from shop2020.model.v1.user.impl.Dataservice import Cart, Line, Address, User, Discount
+from shop2020.model.v1.user.impl.Dataservice import Cart, Line, Address, User, Discount, InsuranceDetails
 from shop2020.thriftpy.model.v1.user.ttypes import CartStatus, LineStatus, ShoppingCartException,\
     PromotionException
 import datetime
 from shop2020.utils.Utils import to_py_date, to_java_date
     current_time = datetime.datetime.now()
     cart.updated_on = current_time
     line = get_line(item_id, cart_id, None,True)
     if line:
         #change the quantity only
+        line.insuranceAmount = (line.insuranceAmount/line.quantity) * quantity
         line.quantity = quantity
         line.updated_on = current_time
     else:
         line = Line()
         line.cart = cart
         line.quantity = quantity
         line.created_on = current_time
         line.updated_on = current_time
         line.actual_price = item.sellingPrice
         line.line_status = LineStatus.LINE_ACTIVE
+        line.insurer = 0
+        line.insuranceAmount = 0
     session.commit()
     return retval
 def delete_item_from_cart(cart_id, item_id):
     if not item_id:
             pc = PromotionClient().get_client()
             isGv = pc.isGiftVoucher(cart.coupon_code)
         except:
             isGv = False
+    insuranceDetails = InsuranceDetails.get_by(addressId = cart.address_id)
     for line in cart_lines:
         if line.line_status == LineStatus.LINE_ACTIVE:
             quantity_remaining_for_order = line.quantity
             for discount in line.discounts:
                 i = 0
                 while i < discount.quantity:
                     t_line_item = create_line_item(line.item_id, line.actual_price if isGv else (line.actual_price - discount.discount))
-                    t_order = create_order(userId, cart.address_id, t_line_item, cart.pickupStoreId, discount.discount if isGv else 0)
+                    t_order = create_order(userId, cart.address_id, t_line_item, cart.pickupStoreId, discount.discount if isGv else 0, line.insurer, (line.insuranceAmount/line.quantity), insuranceDetails)
                     orders.append(t_order)
                     i += 1
                 quantity_remaining_for_order -= discount.quantity
             i = 0
             while i < quantity_remaining_for_order:
                 t_line_item = create_line_item(line.item_id, line.actual_price)
-                t_order = create_order(userId, cart.address_id, t_line_item, cart.pickupStoreId, 0)
+                t_order = create_order(userId, cart.address_id, t_line_item, cart.pickupStoreId, 0, line.insurer, (line.insuranceAmount/line.quantity), insuranceDetails)
                 orders.append(t_order)
                 i += 1
     return orders
-def create_order(userId, address_id, t_line_item, pickupStoreId, gvAmount):
+def create_order(userId, address_id, t_line_item, pickupStoreId, gvAmount, insurer, insuranceAmount, insuranceDetails):
     user = User.get_by(id=userId)
     address = Address.get_by(id=address_id)
     t_order = TOrder()
     t_order.customer_id = user.id
     t_order.customer_address2 = address.line_2
     t_order.customer_city = address.city
     t_order.customer_state = address.state
     t_order.customer_mobilenumber = address.phone
-    t_order.total_amount = t_line_item.total_price
+    t_order.total_amount = t_line_item.total_price + insuranceAmount
     t_order.gvAmount = gvAmount
     t_order.total_weight = t_line_item.total_weight
     t_order.lineitems = [t_line_item]
     t_order.status = OrderStatus.PAYMENT_PENDING
     t_order.statusDescription = "Payment Pending"
     t_order.created_timestamp = to_java_date(datetime.datetime.now())
     t_order.pickupStoreId = pickupStoreId
+    t_order.insuranceAmount = insuranceAmount
+    t_order.insurer = insurer
+    t_order.dob = insuranceDetails.dob
+    t_order.guardianName = insuranceDetails.guardianName
     return t_order
 def create_line_item(item_id, final_price, quantity=1):
     inventory_client = CatalogClient().get_client()
     item = inventory_client.getItem(item_id)
             if item_shipping_info.isRisky and item_shipping_info.quantity < line.quantity:
                 line.quantity = 1
                 retval = "Try adding a smaller quantity of " + item.brand + " " + item.modelNumber + " (" + item.color + ")"
             line.actual_price = item.sellingPrice
-            cart.total_price = cart.total_price + (line.actual_price * line.quantity)
+            cart.total_price = cart.total_price + (line.actual_price * line.quantity) + line.insuranceAmount
             try:
                 item_delivery_estimate = logistics_client.getLogisticsEstimation(item_id, customer_pincode, DeliveryType.PREPAID).deliveryTime
             except LogisticsServiceException:
                 item_delivery_estimate = -1
                 #TODO Use the exception clause to set the retval appropriately
     session.commit()
     if cart.coupon_code is not None:
         try:
             updated_cart = promotion_client.applyCoupon(cart.coupon_code, cart.id)
+            totalPrice = 0
             for t_line in updated_cart.lines:
             #Find the line in the database which corresponds to this line
                 line = Line.query.filter_by(cart = cart).filter_by(item_id = t_line.itemId).one()
             #Update its discounted price.
                 line.discounted_price = t_line.discountedPrice
+            #If discounted price of line is set and this coupon is not a gift voucher that means
+            # we will need to correct the insurance price accordingly.
+                if line.discounted_price and not promotion_client.isGiftVoucher(cart.coupon_code) :
+                    line.insuranceAmount = round((line.insuranceAmount/line.actual_price) * line.discounted_price)
+                    totalPrice = totalPrice + line.actual_price * line.quantity + line.insuranceAmount
+                    cart.total_price = totalPrice
             cart.discounted_price = updated_cart.discountedPrice
             session.commit()
             if updated_cart.message is not None:
                 emival = updated_cart.message
         except PromotionException as ex:
     '''line = Line.query.filter_by(item_id = itemId, created_on > to_py_date(startDate), created_on < to_py_date(endDate)).first()'''
     if line is not None:
         return True
     else:
         return False
+def insure_item(itemId, cartId, toInsure):
+    cart = Cart.get_by(id = cartId)
+    line = None
+    for cartLine in cart.lines:
+        if(cartLine.item_id == itemId):
+            line = cartLine
+            break
+    if not line:
+        print("Error : No line found for cartId : " + cartId + " and itemId : " + itemId)
+        return False
+    try:
+        csc = CatalogClient().get_client()
+        item = csc.getItem(itemId)
+        insuranceAmount = csc.getInsuranceAmount(itemId, item.preferredInsurer, line.quantity)
+        if toInsure:
+            line.insurer = item.preferredInsurer
+            line.insuranceAmount = insuranceAmount
+            cart.total_price = cart.total_price + insuranceAmount
+            if cart.discounted_price:
+                cart.discounted_price = cart.discounted_price + insuranceAmount
+        else:
+            cart.total_price = cart.total_price - insuranceAmount
+            if cart.discounted_price:
+                cart.discounted_price = cart.discounted_price - insuranceAmount
+            line.insurer = 0
+            line.insuranceAmount = 0
+        line.updated_on = datetime.datetime.now()
+        cart.updated_on = datetime.datetime.now()
+        session.commit()
+    except:
+        print("Error : Unable to insure")
+        print("insurerId : " + str(item.preferredInsurer) + " ItemId : " + str(itemId) + " CartId : " + str(cartId))
+        return False
+    return True
+def cancel_insurance(cartId):
+    try:
+        cart = Cart.get_by(id = cartId)
+        for cartLine in cart.lines:
+            cart.total_price = cart.total_price - cartLine.insuranceAmount
+            if cart.discounted_price:
+                cart.discounted_price = cart.discounted_price - cartLine.insuranceAmount
+            cartLine.insurer = 0
+            cartLine.insuranceAmount = 0
+            cartLine.updated_on = datetime.datetime.now()
+        cart.updated_on = datetime.datetime.now()
+        session.commit()
+    except:
+        print("Error : Unable to cancel insurance for cartId :" + str(cartId))
+        return False
+    return True
+def store_insurance_specific_details(addressId, dob, guardianName):
+    try:
+        insuranceDetails = InsuranceDetails.get_by(addressId = addressId);
+        if insuranceDetails is None :
+            insuranceDetails = InsuranceDetails()
+        insuranceDetails.addressId = addressId
+        insuranceDetails.dob = dob
+        insuranceDetails.guardianName = guardianName
+        session.commit()
+    except:
+        print("Error : Unable to store insurance details for addressId : " + str(addressId))
+        return False
+    return True
+def is_insurance_detail_present(addressId):
+    try:
+        insuranceDetails = InsuranceDetails.get_by(addressId = addressId);
+        if insuranceDetails is None :
+            return False
+    except:
+        print("Error : Unable to get insurance details for addressId : " + str(addressId))
+        return False
+    return True
 def close_session():
     if session.is_active:
         print "session is active. closing it."
         session.close()

Subversion Repositories SmartDukaan

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