Subversion Repositories SmartDukaan

def reship_order(order_id):

    """

    If the order is in SALES_RET_RECEIVED or DOA_CERT_INVALID state, it does the following:

        1. Creates a new order for processing in the BILLED state. All billing information is saved.

        2. Marks the current order as one of the final states SALES_RET_RESHIPPED and DOA_INVALID_RESHIPPED depending on what state the order started in.

    If the order is in DOA_CERT_VALID state, it does the following:

        1. Creates a new order for processing in the SUBMITTED_FOR_PROCESSING state.

        2. Creates a return order for the warehouse executive to return the DOA material.

        3. Marks the current order as the final DOA_RESHIPPED state.

    Returns the id of the newly created order.

    Throws an exception if the order with the given id couldn't be found.

    Parameters:

     - orderId

    """

    order = get_order(order_id)

    if order.status == OrderStatus.SALES_RET_RECEIVED:

        new_order = __clone_order(order, True)

        order.status = OrderStatus.SALES_RET_RESHIPPED

        order.statusDescription = "Order Reshipped"

        session.commit()

    elif order.status == OrderStatus.DOA_CERT_INVALID:

        new_order = __clone_order(order, True)

        order.status = OrderStatus.DOA_INVALID_RESHIPPED

        order.statusDescription = "Order Reshipped"

        session.commit()

    elif order.status == OrderStatus.DOA_CERT_VALID:

        new_order = __clone_order(order, False)

        ret_order = __create_return_order(order)

        order.status = OrderStatus.DOA_RESHIPPED

        order.statusDescription = "Order Reshipped"

        session.commit()

    else:

        raise TransactionServiceException(112, "This order can't be reshipped")

    order.new_order_id = new_order.id

    session.commit()

    return new_order.id

def refund_order(order_id):

    """

    If the order is in SALES_RET_RECEIVED, DOA_CERT_VALID or DOA_CERT_INVALID state, it does the following:

        1. Creates a refund request for batch processing.

        2. Creates a return order for the warehouse executive to return the shipped material.

        3. Marks the current order as SALES_RET_REFUNDED, DOA_VALID_REFUNDED or DOA_INVALID_REFUNDED final states.

    If the order is in SUBMITTED_FOR_PROCESSING or INVENTORY_LOW state, it does the following:

        1. Creates a refund request for batch processing.

        2. Marks the current order as the REFUNDED final state.

    Returns True if it is successful.

    Throws an exception if the order with the given id couldn't be found.

    Parameters:

     - orderId

    """

    status_transition = {OrderStatus.SALES_RET_RECEIVED : OrderStatus.SALES_RET_REFUNDED,

                         OrderStatus.DOA_CERT_INVALID : OrderStatus.DOA_INVALID_REFUNDED,

                         OrderStatus.DOA_CERT_VALID : OrderStatus.DOA_VALID_REFUNDED,

                         OrderStatus.SUBMITTED_FOR_PROCESSING : OrderStatus.REFUNDED,

                         OrderStatus.INVENTORY_LOW : OrderStatus.REFUNDED

                         }

    order = get_order(order_id)

    if order.status in [OrderStatus.SALES_RET_RECEIVED, OrderStatus.DOA_CERT_INVALID, OrderStatus.DOA_CERT_VALID] :

        __create_return_order(order)

        __create_refund(order)

        order.status = status_transition[order.status]

        order.statusDescription = "Refunded"

    elif order.status in [OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW]:

        __create_refund(order)

        order.status = status_transition[order.status]

        order.statusDescription = "Refunded"

    else:

        raise TransactionServiceException(114, "This order can't be refunded")

    session.commit()

    return True

def __clone_order(order, should_copy_billing_info):

    current_time = datetime.datetime.now()

    new_order = Order()

    new_order.customer_id = order.customer_id

    new_order.customer_name = order.customer_name

    new_order.customer_city = order.customer_city

    new_order.customer_state = order.customer_state

    new_order.customer_mobilenumber = order.customer_mobilenumber

    new_order.customer_pincode = order.customer_pincode

    new_order.customer_address1 = order.customer_address1

    new_order.customer_address2 = order.customer_address2

    new_order.customer_email = order.customer_email

    new_order.total_amount = order.total_amount

    new_order.total_weight = order.total_weight

    new_order.status = OrderStatus.SUBMITTED_FOR_PROCESSING

    new_order.statusDescription = 'Submitted for Processing'

    new_order.created_timestamp = current_time

    new_order.transaction = order.transaction

    for line_item in order.lineitems:

        litem = LineItem()

        litem.item_id = line_item.item_id

        litem.productGroup = line_item.productGroup

        litem.brand = line_item.brand

        if line_item.model_number:

            litem.model_number = line_item.model_number

        if line_item.model_name:    

            litem.model_name = line_item.model_name

        if line_item.color:

            litem.color = line_item.color

        if line_item.extra_info:

            litem.extra_info = line_item.extra_info

        litem.quantity = line_item.quantity

        litem.unit_price = line_item.unit_price

        litem.unit_weight = line_item.unit_weight

        litem.total_price = line_item.total_price

        litem.total_weight = line_item.total_weight

        litem.transfer_price = line_item.transfer_price

        litem.order = new_order

    logistics_client = LogisticsClient().get_client()

    item_id = new_order.lineitems[0].item_id

    logistics_info = logistics_client.getLogisticsInfo(new_order.customer_pincode, item_id) #TODO: We should be able to pass another flag to suggest ignoring the inventory situation.

    logistics_info.deliveryTime = adjust_delivery_time(current_time, logistics_info.deliveryTime)

    new_order.warehouse_id = logistics_info.warehouseId

    new_order.logistics_provider_id = logistics_info.providerId

    new_order.airwaybill_no = logistics_info.airway_billno

    new_order.tracking_id = new_order.airwaybill_no

    new_order.expected_delivery_time = current_time + datetime.timedelta(days=logistics_info.deliveryTime)

    if should_copy_billing_info:

        new_order.invoice_number = order.invoice_number

        new_order.billed_by = order.billed_by

        new_order.warehouse_id = order.warehouse_id

        new_order.accepted_timestamp = current_time

        new_order.billing_timestamp = current_time    

        new_order.status = OrderStatus.BILLED

        new_order.statusDescription = 'Order Billed'

    else:       

        catalog_client = InventoryClient().get_client()

        catalog_client.reserveItemInWarehouse(item_id, logistics_info.warehouseId, new_order.lineitems[0].quantity)

        item_pricing = catalog_client.getItemPricing(item_id, order.warehouse_id)

        new_order.lineitems[0].transfer_price = item_pricing.transferPrice

    return new_order

def __create_return_order(order):

    ret_order = ReturnOrder()

    ret_order.order_id = order.id

    ret_order.jacket_number = order.jacket_number

    ret_order.invoice_number = order.invoice_number

    line_item = order.lineitems[0]

    ret_order.item_id = line_item.item_id

    ret_order.productGroup = line_item.productGroup

    ret_order.brand = line_item.brand

    ret_order.model_number = line_item.model_number

    ret_order.model_name = line_item.model_name

    ret_order.color = line_item.color

    ret_order.total_price = line_item.total_price

    ret_order.transfer_price = line_item.transfer_price

    ret_order.created_timestamp = datetime.datetime.now()

    return ret_order

def __create_refund(order):

    pass