Subversion Repositories SmartDukaan

import json

import traceback

def add_items_to_cart(cartId, itemQty, couponCode=None):

    try: 

        found_cart = Cart.get_by(id=cartId)

        itemQtyMap = {}

        current_time = datetime.datetime.now()

        for itemqty in itemQty:

            itemQtyMap[itemqty.itemId] = itemqty.qty 

        for line in found_cart.lines:

            if itemQtyMap.has_key(line.item_id):

                line.delete()

        for itemId,qty in itemQtyMap.iteritems():

            line = Line()

            line.cart = found_cart

            line.item_id = itemId

            line.quantity = qty

            line.created_on = current_time

            line.updated_on = current_time

            line.line_status = LineStatus.LINE_ACTIVE

            line.insurer = 0

            line.insuranceAmount = 0

        if couponCode:

            found_cart.coupon_code = couponCode

        else:

            found_cart.coupon_code = None

        session.commit()

        return True

    except:

        traceback.print_exc()

        return False

def valiate_cart_new(cartId, customer_pincode, sourceId):

    inventory_client = CatalogClient().get_client()

    logistics_client = LogisticsClient().get_client()

    promotion_client = PromotionClient().get_client()

    # 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.

    cart = Cart.get_by(id=cartId)

    cart_lines = cart.lines

    current_time = datetime.datetime.now()

    user = User.get_by(active_cart_id = cartId)

    responseMap = {}

    totalQty = 0

    totalAmount = 0 

    shippingCharges=0

    cartMessages=[]

    cartItems = []

    dealItems = []

    responseMap['shippingCharges']= shippingCharges

    responseMap['cartMessages']= cartMessages

    responseMap['cartItems']= cartItems

    responseMap['pincode']= customer_pincode

    privateDealUser = PrivateDealUser.get_by(id=user.id)    

    itemIds = [cartLine.item_id for cartLine in cart.lines]

    if privateDealUser is not None and privateDealUser.isActive:

        deals = inventory_client.getAllActivePrivateDeals(itemIds, 0)

        dealItems = deals.keys()

    cart.total_price = 0

    itemsMap = inventory_client.getItems(itemIds)

    for line in cart_lines:

        cartItem={}

        old_estimate = line.estimate

        item_id = line.item_id

        item = itemsMap.get(item_id)

        cartItem['itemId']=line.item_id

        cartItem['quantity']=0

        cartItem['messages']=[]

        cartItemMessages = cartItem['messages']

        cartItem['color'] = item.color

        cartItem['catalogItemId'] = item.catalogItemId

        item_shipping_info = inventory_client.isActive(item_id) 

        if item_shipping_info.isActive:

            if item_shipping_info.isRisky and item_shipping_info.quantity < line.quantity:

                line.quantity = item_shipping_info.quantity

                cartMessages.append({"type":"failed", "messageText":"Qty for few items have changed"})

                cartItemMessages.append({"type":"failed", "messageText":"Only " + str(item_shipping_info.quantity) + " available"})

            cartItem['maxQuantity'] = min(item_shipping_info.quantity, 20)

            if item_id in dealItems:

                line.actual_price = deals[item_id].dealPrice

                if deals[item_id].dealTextOption==0:

                    line.dealText = ''

                if deals[item_id].dealTextOption==2:

                    line.dealText = deals[item_id].dealText

                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

            else:

                line.actual_price = item.sellingPrice

                cartItem['dealText'] = item.dealText 

                line.dealText = None

                line.freebieId = None

            cartItem['sellingPrice'] = line.actual_price

            cartItem['quantity'] = line.quantity

            cart.total_price = cart.total_price + (line.actual_price * line.quantity)

            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

            except :

                item_delivery_estimate = -1

            if item_delivery_estimate !=-1:

                inv_client = InventoryClient().get_client()

                itemAvailability = None

                try:

                    itemAvailability = inv_client.getItemAvailabilityAtLocation(item_id, 1)

                except:

                    pass

                print 'itemAvailability billling Warehouse ', itemAvailability[2]

                if itemAvailability is not None:

                    billingWarehouse = None

                    try:

                        billingWarehouse = inv_client.getWarehouse(itemAvailability[2])

                    except:

                        pass

                    print 'billingWarehouse Id Location ', billingWarehouse.stateId

                    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)

                            if estimateVal ==-1:

                                item_delivery_estimate =-1

                        except:

                            pass

                        print 'estimateVal Value ', estimateVal

            cartItem['estimate'] = item_delivery_estimate

            if item_delivery_estimate == -1:

                cartItem['quantity'] = 0

                cartMessages.append({"type":"failed", "messageText":"Few items are undeliverable to your pincode"})

                cartItemMessages.append({"type":"failed", "messageText":"Undeliverable"})

            if old_estimate != item_delivery_estimate:

                line.estimate = item_delivery_estimate

                cart.updated_on = current_time

        else:

            cartItem['quantity'] = 0

            cartMessages.append({"type":"failed", "messageText":"Few items are out of Stock"})

            cartItemMessages.append({"type":"failed", "messageText":"Out of Stock"})

            Discount.query.filter(Discount.line==line).delete()

            line.delete()

        totalQty += cartItem['quantity']

        totalAmount += line.actual_price * cartItem['quantity']

        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()

    if cart.coupon_code is not None:

        try:

            updated_cart = promotion_client.applyCoupon(cart.coupon_code, cart.id)

            if updated_cart.message is not None:

                emival = updated_cart.message

        except PromotionException as ex:

            remove_coupon(cart.id)

            #retval = ex.message

    session.commit()

    cart = Cart.get_by(id=cartId)

    cart_lines = cart.lines

    insurerFlag = False

    for line in cart_lines:

        if line.insurer > 0 or line.dataProtectionInsurer > 0:

            line.insurer = 0

            line.insuranceAmount = 0 

            line.dataProtectionInsurer = 0

            line.dataProtectionAmount = 0

            insurerFlag = True

    if insurerFlag:

        cart.updated_on = datetime.datetime.now()

        session.commit()

    session.close()

    responseMap['totalQty']= totalQty

    responseMap['totalAmount']= totalAmount

    if totalAmount < 500:

        shippingCharges = 100

    elif totalAmount < 1000:

        shippingCharges = 50

    responseMap['shippingCharge']

    return json.dumps(responseMap)