Subversion Repositories SmartDukaan

'''

Created on 29-Mar-2010

@author: ashish

'''

from shop2020.thriftpy.model.v1.order.ttypes import Transaction as T_Transaction,\

    LineItem as T_LineItem, Order as T_Order, Alert as T_Alert, OrderStatus

from shop2020.utils.Utils import to_java_date

from shop2020.model.v1.order.impl.DataService import Alerts

from shop2020.utils.OrderStatus import get_t_status

def to_t_transaction(transaction):

    t_transaction = T_Transaction()

    t_transaction.id = transaction.id

    t_transaction.createdOn = to_java_date(transaction.createdOn)

    t_transaction.transactionStatus = transaction.status

    t_transaction.statusDescription = transaction.status_message

    t_transaction.customer_id = transaction.customer_id

    t_transaction.shoppingCartid = transaction.shopping_cart_id

    t_transaction.orders = []

    #populate orders

    for order in transaction.orders:

        t_order = to_t_order(order)

        t_transaction.orders.append(t_order)

    return t_transaction

def to_t_order(order):

    t_order = T_Order()

    t_order.id = order.id

    t_order.warehouse_id = order.warehouse_id

    t_order.logistics_provider_id = order.logistics_provider_id

    t_order.airwaybill_no = order.airwaybill_no

    t_order.tracking_id = order.tracking_id

    t_order.expected_delivery_time = to_java_date(order.expected_delivery_time)

    t_order.customer_id = order.customer_id

    t_order.customer_name = order.customer_name

    t_order.customer_mobilenumber = order.customer_mobilenumber

    t_order.customer_pincode = order.customer_pincode

    t_order.customer_address = order.customer_address

    t_order.customer_city = order.customer_city

    t_order.customer_state = order.customer_state

    t_order.customer_email = order.customer_email    

    t_order.status = order.status 

    t_order.statusDescription = order.statusDescription

    t_order.total_amount = order.total_amount

    t_order.total_weight = order.total_weight

    t_order.created_timestamp = to_java_date(order.created_timestamp)

    t_order.invoice_number = order.invoice_number

    t_order.billed_by = order.billed_by

    t_order.accepted_timestamp = order.accepted_timestamp

    t_order.billing_timestamp = order.billing_timestamp

    t_order.shipping_timestamp = order.shipping_timestamp

    t_order.delivery_timestamp = order.delivery_timestamp

    t_order.jacket_number = order.jacket_number

    t_order.lineitems = []

    for lineitem in order.lineitems:

        t_lineitem = to_t_lineitem(lineitem)

        t_order.lineitems.append(t_lineitem)

    return t_order

def to_t_lineitem(lineitem):

    t_lineitem = T_LineItem()

    t_lineitem.id = lineitem.id

    t_lineitem.item_id = lineitem.item_id

    t_lineitem.unit_weight = lineitem.unit_weight

    t_lineitem.unit_price = lineitem.unit_price

    t_lineitem.total_price = lineitem.total_price

    t_lineitem.total_weight = lineitem.total_weight 

    t_lineitem.quantity = lineitem.quantity

    t_lineitem.color = lineitem.color

    t_lineitem.model_number = lineitem.model_number

    t_lineitem.model_name = lineitem.model_name 

    t_lineitem.extra_info = lineitem.extra_info

    t_lineitem.brand = lineitem.brand

    return t_lineitem

def to_t_alert(alert):

    t_alert = T_Alert()

    t_alert.id = alert.id

    t_alert.comment = alert.comment

    try:

        t_alert.time_set = to_java_date(alert.time_set)

    except:

        pass

    try:

        t_alert.time_unset = to_java_date(alert.time_unset)

    except:

        pass

    t_alert.order_id = alert.order_id

    t_alert.type = alert.type

    return t_alert

"""

def to_t_transaction(transaction):

    t_transaction = T_Transaction()

    t_transaction.id = transaction.id

    t_transaction.warehouse_id = transaction.warehouse_id

    t_transaction.createdOn = to_java_date(transaction.createdOn)

    t_transaction.transactionStatus = OrderStatus.get_t_status(transaction.status)

    t_transaction.statusDescription = transaction.status_message

    t_transaction.expectedDeliveryTime = to_java_date(transaction.expected_delivery_time)

    t_transaction.customer_id = transaction.customer_id

    t_transaction.shoppingCartid = transaction.shopping_cart_id

    t_transaction.orderInfo = to_t_order_info(transaction.lineitems)

    t_transaction.shipmentInfo = to_t_shipment_info(transaction.shipments)

    t_transaction.billingInfo = to_t_billing_info(transaction.lineitems)

    t_transaction.paymentInfo = to_t_payment_info(transaction.payments)

    #populate order info

    return t_transaction

def to_t_payment_info(payments):

    t_payment_info = PaymentInfo()

    if payments:

        payment_map = {}

        for payment in payments:

            t_payment_info.id = payment.id

            t_payment = Payment()

            t_payment.merchant_tx_id = payment.merchant_tx_id

            t_payment.bank_tx_id = payment.bank_tx_id

            t_payment.mode = payment.mode

            t_payment.amount = payment.amount

            t_payment.status = payment.status

            t_payment.description = payment.status_message

            t_payment.submissionTimestamp = to_java_date(payment.start_time)

            t_payment.completionTimestamp = to_java_date(payment.finish_time)

            payment_map[t_payment.submissionTimestamp] = t_payment

        t_payment_info.payments = payment_map

    return t_payment_info

def to_t_billing_info(lineitems):

    t_billing_info = BillingInfo()

    if lineitems:

        billed_items = []

        billings = []

        for item in lineitems:

            #each item has a billing

            t_billing_info.id = item.transaction.id 

            billing = item.billing

            if billing:

                if billed_items.count(billing.id) == 0:

                    billed_items.append(billing.id)

                    billings.append(to_t_billing(billing))

        t_billing_info.billings = billings

    return t_billing_info

def to_t_order_info(lineitems):

    t_order_info = T_OrderInfo()

    if lineitems:

        line_item_list = []

        for lineitem in lineitems:

            t_order_info.id = lineitem.transaction.id

            line_item_list.append(to_t_lineitem(lineitem))

        t_order_info.lineitems = line_item_list

    return t_order_info

def to_t_shipment_info(shipments):

    shipment_info = ShipmentInfo()

    if shipments:

        shipment_list = []

        for shipment in shipments:

            shipment_info.id = shipment.transaction.id

            shipment_list.append(to_t_shipment(shipment))

        shipment_info.shipments = shipment_list

    return shipment_info

def to_t_billing(billing):

    t_billing = T_Billing()

    t_billing.id = billing.id

    t_billing.billNumber = billing.bill_number

    t_billing.generatedBy = billing.generated_by

    try:

        t_billing.generatedTimestamp = to_java_date(billing.created_on)

    except:

        print "date not found"

    t_billing.lineItem = []

    if billing.line_item:

        for item in billing.line_item:

            t_billing.lineItem.append(to_t_lineitem(item))

    return t_billing

def to_t_lineitem(lineitem):

    t_line_item = T_LineItem()

    try:

        t_line_item.id = lineitem.id

    except:

        t_line_item.id = 0

    if lineitem.item_info:

        t_line_item.item = to_t_item_info(lineitem.item_info)

    t_line_item.addedOn = to_java_date(lineitem.added_on)

    t_line_item.additionalInfo = {}

    if lineitem.additional_info:

        for k,v in lineitem.additional_info.iteritems():

            t_line_item.additionalInfo[k] = v

    return t_line_item

def to_t_item_info(item_info):

    t_item = Item()

    t_item.id = item_info.line_item.item_id

    t_item.price = item_info.price

    t_item.weight = item_info.weight

    return t_item

def to_t_shipment(shipment):

    t_shipment = T_Shipment()

    t_shipment.id = shipment.id

    t_shipment.address = shipment.address

    t_shipment.airwayBillNo = shipment.airway_bill_no

    try:

        t_shipment.deliveryTimestamp = to_java_date(shipment.delivery_time)

    except:

        print "no delivery timestamp"

    t_shipment.insurance = shipment.insurance_value

    t_shipment.provider = shipment.provider

    t_shipment.value = shipment.declared_value

    try:

        t_shipment.shipmentTimestamp = to_java_date(shipment.shipment_time)

    except:

        print "no shipment timestamp"

    t_shipment.status = get_t_status(shipment.status)

    t_shipment.weight = shipment.weight

    t_shipment.trackingId = shipment.tracking_id

    t_shipment.lineItems = []

    if shipment.lineitems:

        for line_item in shipment.lineitems:

            t_shipment.lineItems.append(to_t_lineitem(line_item))

    return t_shipment

def to_t_alert(alert):

    t_alert = T_Alert()

    t_alert.id = alert.id

    t_alert.comment = alert.comment

    try:

        t_alert.time_set = to_java_date(alert.time_set)

    except:

        pass

    try:

        t_alert.time_unset = to_java_date(alert.time_unset)

    except:

        pass

    t_alert.transaction_id = alert.transaction_id

    t_alert.type = alert.type

    return t_alert

def to_t_extra_item_info(extra_item_info, transaction_id):

    extra_order_info = T_ExtraOrderInfo()

    if not extra_item_info:

        extra_order_info.id = 2

        extra_order_info.model_name = "N 72"

        extra_order_info.sku_id = 34

        extra_order_info.transaction_id = transaction_id

        extra_order_info.vendor_info = "Nokia"

        extra_order_info.colour = "Black"

        return extra_order_info

    extra_order_info.id = extra_item_info.id

    extra_order_info.model_name = extra_item_info.model

    extra_order_info.vendor_info = extra_item_info.vendor

    extra_order_info.transaction_id = extra_item_info.transaction_id

    extra_order_info.sku_id = extra_item_info.sku_id

    return extra_order_info

"""