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
+from shop2020.model.v1.user.impl.Dataservice import Cart, Line, Address, User
 from shop2020.thriftpy.model.v1.user.ttypes import CartStatus, LineStatus, ShoppingCartException
 import datetime
-from shop2020.utils.Utils import to_py_date
+from shop2020.utils.Utils import to_py_date, to_java_date
-from shop2020.thriftpy.model.v1.order.ttypes import Transaction,\
-    TransactionStatus
+from shop2020.thriftpy.model.v1.order.ttypes import Transaction as TTransaction,\
+    TransactionStatus as TTransactionStatus, Order as TOrder, LineItem as TLineItem,\
+    PaymentInfo as TPaymentInfo, OrderStatus
+from shop2020.thriftpy.model.v1.catalog.ttypes import Item as TItem
+from shop2020.thriftpy.logistics.ttypes import LogisticsInfo as TLogisticsInfo
+from shop2020.clients.TransactionClient import TransactionClient
+from shop2020.clients.InventoryClient import InventoryClient
+from shop2020.clients.LogisticsClient import LogisticsClient
+from shop2020.model.v1 import user
 def get_cart(user_id):
     query = Cart.query.filter_by(user_id=user_id)
     query = query.filter_by(cart_status = CartStatus.ACTIVE)
     try:
         raise ShoppingCartException(101, "address id cannot be made null")
     cart = get_cart_by_id(cart_id)
     if not cart:
         raise ShoppingCartException(101, "no cart for this id")
+    address = Address.get_by(id=address_id)
+    if not address:
+        raise ShoppingCartException(101, "No address for this id")
     cart.address_id = address_id
     session.commit()
-def commit_cart(cart_id, transaction_client):
+def commit_cart(cart_id):
     cart = get_cart_by_id(cart_id)
     cart.cart_status = CartStatus.COMMITTED
     cart.committed_on = datetime.datetime.now()
-    session.commit()
     #now we have a cart. Need to create a transaction with it
-    #transaction = transaction_client.create_transaction(cart)
+    txn = TTransaction()
-    return True
+    txn.paymentInfo = TPaymentInfo()
-"""
-    transaction.shoppingCartid = cart_id
+    txn.shoppingCartid = cart_id
-    transaction.customer_id = cart.user_id
+    txn.customer_id = cart.user_id
-    transaction.transactionStatus = TransactionStatus.INIT
+    txn.createdOn = to_java_date(datetime.datetime.now())
-    transaction.statusDescription = "Transaction submitted to warehouse"
+    txn.transactionStatus = TTransactionStatus.INIT
-    transaction.created_on = datetime.datetime.now()
+    txn.statusDescription = "New Order"
-    transaction.warehouse_id = 1;
+    txn.orders = create_orders(cart)
+    transaction_client = TransactionClient().get_client()
+    txn_id = transaction_client.createTransaction(txn)
+    session.commit()
+    new_cart = create_cart(cart.user_id)
+    user = User.get_by(id=cart.user_id)
+    user.active_cart_id = new_cart.id
+    session.commit()
+    return txn_id
+def create_orders(cart):
     cart_lines = cart.lines
-    for line in cart_lines:
-        if line.status == LineStatus.LINE_ACTIVE:
-            #line is active
-            line_item = get_line_item(cartLine.getItemId());
-// create orders equivalent to quantity. Create one order per item.
-for(int i= 0; i<cartLine.getQuantity(); i++){
-    //  set order
-    Order order = getOrder(c.getAddressId(), lineItem);
-    order.addToLineitems(lineItem);
-    orders.add(order);
+    orders = []
-"""
+    for line in cart_lines:
+        if line.line_status == LineStatus.LINE_ACTIVE:
+            i = 0
+            while i< line.quantity:
+                t_line_item = create_line_item(line.item_id)
+                t_order = create_order(cart.user_id, cart.address_id, t_line_item)
+                orders.append(t_order)
+                i += 1
+    return orders
+def create_order(user_id, address_id, t_line_item):
+    user = User.get_by(id=user_id)
+    address = Address.get_by(id=address_id)
+    t_order = TOrder()
+    t_order.customer_id = user.id
+    t_order.customer_name = user.name
+    t_order.customer_email = user.email
+    t_order.customer_pincode = address.pin
+    t_order.customer_address = get_address_string(address)
+    t_order.customer_mobilenumber = address.phone
+    t_order.total_amount = t_line_item.total_price
+    t_order.total_weight = t_line_item.total_weight
+    t_order.lineitems = [t_line_item]
+    t_order.status = OrderStatus.SUBMITTED_FOR_PROCESSING
+    t_order.statusDescription = "Submitted to warehouse"
+    t_order.created_timestamp = to_java_date(datetime.datetime.now())
+    logistics_client = LogisticsClient().get_client()
+    logistics_info = logistics_client.getLogisticsInfo(t_order.customer_pincode, t_line_item.sku_id)
+    t_order.logistics_provider_id = logistics_info.provider_id
+    t_order.airwaybill_no = logistics_info.airway_billno
+    t_order.tracking_id = t_order.airwaybill_no
+    t_order.expected_delivery_time = to_java_date(datetime.datetime.now()) + 60*60*1000*logistics_info.delivery_estimate
+    t_order.warehouse_id = logistics_info.warehouse_id
+    return t_order
+def create_line_item(catalog_item_id):
+    inventory_client = InventoryClient().get_client()
+    catalog_item = inventory_client.getItemByCatalogId(catalog_item_id)
+    t_line_item = TLineItem()
+    t_line_item.model_name = catalog_item.modelName
+    t_line_item.model_number = catalog_item.modelNumber
+    t_line_item.extra_info = catalog_item.featureDescription
+    t_line_item.brand = catalog_item.manufacturerName
+    t_line_item.sku_id = catalog_item.vendorItemId
+    t_line_item.quantity = 1
+    t_line_item.unit_price = catalog_item.sellingPrice
+    t_line_item.unit_weight = catalog_item.weight
+    t_line_item.total_price = catalog_item.sellingPrice
+    t_line_item.total_weight = catalog_item.weight
+    return t_line_item
+def get_address_string(address):
+    return address.line_1 + "\n" + address.line_2 + "\nLandmark: " + address.landmark + "\n" + address.city + "\n" + address.state + "\n" + address.country
-def validate_cart(cartId, inventory_client):
+def validate_cart(cartId):
+    inventory_client = InventoryClient().get_client()
+    logistics_client = LogisticsClient().get_client()
     retval = True
     # 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)
+    old_estimate = cart.estimate
+    new_estimate = 0
     cart_lines = cart.lines
+    customer_pincode = ""
+    if cart.address_id:
+        address = Address.get_by(id=cart.address_id)
+        customer_pincode = address.pin
     for line in cart_lines:
-        item_id = line.item_id
+        catalog_item_id = line.item_id
-        if not inventory_client.is_active(item_id):
+        if inventory_client.isActive(catalog_item_id):
+            if customer_pincode:
+                #FIXME: Provider ID should be returned by the same call and shouldn't be hard-coded as 1
+                item_delivery_estimate = logistics_client.getLogisticsEstimation(catalog_item_id, customer_pincode, 1).shippingTime
+                if new_estimate < item_delivery_estimate:
+                    new_estimate = item_delivery_estimate
+        else:
             line.delete()
             retval = False
+    if new_estimate != old_estimate:
+        cart.estimate = new_estimate
+        session.commit()
+        retval = False
     return retval
 def merge_cart(fromCartId, toCartId):
     fromCart = Cart.get_by(id=fromCartId)
     toCart = Cart.get_by(id=toCartId)
     old_lines = fromCart.lines
     for line in old_lines:
         flag = True
         for new_line in new_lines:
             if line.item_id == new_line.item_id:
                 flag = False
         if flag:
             toCart.lines.append(line)
     toCart.updatedOn = datetime.datetime.now()
     fromCart.expired_on = datetime.datetime.now()
     fromCart.cart_status = CartStatus.INACTIVE
-    session.commit()
-"""
-    t_line.id = line.id
-    t_line.itemId = line.item_id
-    t_line.quantity = line.quantity
-    t_line.createdOn = to_java_date(line.created_on)
-    t_line.updatedOn = to_java_date(line.updated_on)
-    t_line.lineStatus = line.line_status
-"""
     session.commit()

Subversion Repositories SmartDukaan

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