Subversion Repositories SmartDukaan

        #Now BILLED orders can also be refunded directly with low inventory cancellations 

        if order.status in [OrderStatus.BILLED, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.SHIPPED_FROM_WH]:

            __create_refund(order, order.wallet_amount, reason)

def process_failed_payment(new_status, transaction_id, description, sourceId, pickUp):

    logging.info("########change transaction status called" + str(transaction_id))

    transaction = get_transaction(transaction_id)

    transaction.status = new_status

    transaction.status_message = description

    order = transaction.orders[0]

    expectedDelayMap = {}

    billingWarehouseIdMap = {}

    billingWarehouseTxnMap = {}

    if new_status == TransactionStatus.FAILED:

        for order in transaction.orders:

            order.status = OrderStatus.PAYMENT_FAILED

            order.statusDescription = "Payment Failed"

    elif new_status == TransactionStatus.AUTHORIZED or new_status == TransactionStatus.FLAGGED:                  

        user_client = UserClient().get_client()

        catalog_client = CatalogClient().get_client()

        pdu = user_client.getPrivateDealUser(transaction.orders[0].customer_id)

        print "pdu.isFofo----", pdu.isFofo

        fofoWarehousesMap = {} 

        if pdu.isFofo:

            fofoDealMap = catalog_client.getAllFofoDeals([order.lineitems[0].item_id], [4,7])

            if fofoDealMap:

                itemIds = []

                for order in transaction.orders:

                    itemIds.append(order.lineitems[0].item_id)

                inventory_client = InventoryClient().get_client()

                print "calling getFofoFulFillmentWarehouseMap" 

                fofoWarehousesMap = inventory_client.getFofoFulFillmentWarehouseMap(itemIds)

                print "called getFofoFulFillmentWarehouseMap" 

        expectedDelayMap = {}

        billingWarehouseIdMap = {}

        billingWarehouseTxnMap = {}

        subOrderAmountsMap = {}       

        for order in transaction.orders:

            if new_status == TransactionStatus.AUTHORIZED:

                order.status = OrderStatus.SUBMITTED_FOR_PROCESSING

                order.statusDescription = "Submitted to warehouse"

            elif new_status == TransactionStatus.FLAGGED:

                order.status = OrderStatus.PAYMENT_FLAGGED

                order.statusDescription = "Payment flagged by gateway"

            order.cod = False

            #Order type cant be changed during authorization

            #if orderType is not None:

            #    order.orderType = orderType

            #After we got payment success, we will set logistics info also 

            logistics_client = LogisticsClient().get_client()

            #FIXME line item is only one now. If multiple will come, need to fix.

            item_id = order.lineitems[0].item_id

            if pickUp == PickUpType.RUNNER or pickUp == PickUpType.SELF:

                current_time = datetime.datetime.now()

                if pdu.isFofo:

                    stateMaster = fetchStateMaster()

                    stateId = -1

                    for k, v in stateMaster.iteritems():

                        if v.stateName == order.customer_state:

                            stateId = k

                            break

                    logistics_info = logistics_client.getLogisticsInfo(order.customer_pincode, item_id, DeliveryType.PREPAID, pickUp, stateId)

                else:

                    logistics_info = logistics_client.getLogisticsInfo(order.customer_pincode, item_id, DeliveryType.PREPAID, pickUp, -1)

                order.logistics_provider_id = logistics_info.providerId

                order.warehouse_id = logistics_info.warehouseId

                order.fulfilmentWarehouseId = logistics_info.fulfilmentWarehouseId

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

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

                logistics_info.deliveryDelay = adjust_delivery_time(current_time, (logistics_info.shippingTime+logistics_info.deliveryDelay))

                order.courier_delivery_time = (current_time + datetime.timedelta(days=logistics_info.deliveryDelay)).replace(hour=PREPAID_SHIPPING_CUTOFF_TIME, minute=0, second=0)

                order.expected_shipping_time = (current_time + datetime.timedelta(days=logistics_info.shippingTime)).replace(hour=PREPAID_SHIPPING_CUTOFF_TIME, minute=0, second=0)

                order.promised_shipping_time = order.expected_shipping_time

                order.expected_delivery_time = (current_time + datetime.timedelta(days=logistics_info.deliveryTime)).replace(hour=PREPAID_SHIPPING_CUTOFF_TIME, minute=0, second=0)

                order.promised_delivery_time = order.expected_delivery_time

                order.otg = False

                inventory_client = InventoryClient().get_client()

                if order.productCondition != ProductCondition.BAD:

                    inventory_client.reserveItemInWarehouse(item_id, order.fulfilmentWarehouseId, sourceId, order.id, to_java_date(order.created_timestamp), to_java_date(order.promised_shipping_time), order.lineitems[0].quantity)

            elif order.source == OrderSource.WEBSITE:

                try:

                    #Get the id and location of actual warehouse that'll be used to fulfil this order.

                    inventory_client = InventoryClient().get_client()

                    fulfilmentWhId, expected_delay, billingWarehouseId, sellingPrice, totalAvailability, weight = inventory_client.getItemAvailabilityAtLocation(item_id, 1, -1)

                except Exception as ex:

                    raise TransactionServiceException(103, "Unable to fetch inventory information about this item.")

                expectedDelayMap[item_id] = expected_delay

                if billingWarehouseIdMap.has_key(billingWarehouseId):

                    ordersList = billingWarehouseIdMap.get(billingWarehouseId)

                    ordersList.append(order)

                    billingWarehouseIdMap[billingWarehouseId] = ordersList

                else:

                    ordersList = []

                    ordersList.append(order)

                    billingWarehouseIdMap[billingWarehouseId] = ordersList

                if billingWarehouseTxnMap.has_key(billingWarehouseId):

                    transactionAmount , transactionWeight = billingWarehouseTxnMap.get(billingWarehouseId)

                    transactionAmount = transactionAmount+order.total_amount

                    transactionWeight = transactionWeight+order.total_weight

                    billingWarehouseTxnMap[billingWarehouseId] = transactionAmount , transactionWeight

                else:

                    billingWarehouseTxnMap[billingWarehouseId] = order.total_amount , order.total_weight

                subOrderAmountsMap[long(order.lineitems[0].unit_price)] = order

                order.fulfilmentWarehouseId = fulfilmentWhId

                order.warehouse_id = billingWarehouseId

                if order.productCondition != ProductCondition.BAD:

                    inventory_client.reserveItemInWarehouse(item_id, order.fulfilmentWarehouseId, sourceId, order.id, to_java_date(order.created_timestamp), to_java_date(order.promised_shipping_time), order.lineitems[0].quantity)

            try:

                item_pricing = inventory_client.getItemPricing(item_id, -1)

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

                order.lineitems[0].nlc = item_pricing.nlc

            except:

                print "Not able to get transfer price. Skipping"

    elif new_status == TransactionStatus.COD_IN_PROCESS:

        expectedDelayMap = {}

        billingWarehouseIdMap = {}

        billingWarehouseTxnMap = {}

        subOrderAmountsMap = {}

        for order in transaction.orders:

            order.status = OrderStatus.COD_VERIFICATION_PENDING

            order.statusDescription = "Verification Pending"

            order.cod = True

            #OrderType cant be changed

            #order.orderType = orderType

            #After we got payment success, we will set logistics info also 

            logistics_client = LogisticsClient().get_client()

            #FIXME line item is only one now. If multiple will come, need to fix.

            item_id = order.lineitems[0].item_id

            try:

                #Get the id and location of actual warehouse that'll be used to fulfil this order.

                inventory_client = InventoryClient().get_client()

                fulfilmentWhId, expected_delay, billingWarehouseId, sellingPrice, totalAvailability, weight = inventory_client.getItemAvailabilityAtLocation(item_id, 1, -1)

            except Exception as ex:

                raise TransactionServiceException(103, "Unable to fetch inventory information about this item.")

            expectedDelayMap[item_id] = expected_delay

            if billingWarehouseIdMap.has_key(billingWarehouseId):

                ordersList = billingWarehouseIdMap.get(billingWarehouseId)

                ordersList.append(order)

                billingWarehouseIdMap[billingWarehouseId] = ordersList

            else:

                ordersList = []

                ordersList.append(order)

                billingWarehouseIdMap[billingWarehouseId] = ordersList

            if billingWarehouseTxnMap.has_key(billingWarehouseId):

                transactionAmount , transactionWeight = billingWarehouseTxnMap.get(billingWarehouseId)

                transactionAmount = transactionAmount+order.total_amount

                transactionWeight = transactionWeight+order.total_weight

                billingWarehouseTxnMap[billingWarehouseId] = transactionAmount , transactionWeight

            else:

                billingWarehouseTxnMap[billingWarehouseId] = order.total_amount , order.total_weight

            subOrderAmountsMap[long(order.lineitems[0].unit_price)] = order

            order.fulfilmentWarehouseId = fulfilmentWhId

            order.warehouse_id = billingWarehouseId

            if order.productCondition != ProductCondition.BAD:

                inventory_client.reserveItemInWarehouse(item_id, order.fulfilmentWarehouseId, sourceId, order.id, to_java_date(order.created_timestamp), to_java_date(order.promised_shipping_time), order.lineitems[0].quantity)

            try:

                item_pricing = inventory_client.getItemPricing(item_id, -1)

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

                order.lineitems[0].nlc = item_pricing.nlc        

            except:

                print "Not able to get transfer price. Skipping"

    session.commit()

    if new_status in (TransactionStatus.AUTHORIZED, TransactionStatus.FLAGGED, TransactionStatus.COD_IN_PROCESS):

        try:

            if order.source == OrderSource.WEBSITE:    

                if new_status == TransactionStatus.COD_IN_PROCESS:

                    transaction_requiring_extra_processing = TransactionRequiringExtraProcessing()

                    transaction_requiring_extra_processing.category = 'COD_VERIFICATION'

                    transaction_requiring_extra_processing.transaction_id = transaction_id

                    session.commit()

                elif new_status == TransactionStatus.FLAGGED:

                    transaction_requiring_extra_processing = TransactionRequiringExtraProcessing()

                    transaction_requiring_extra_processing.category = 'PAYMENT_FLAGGED'

                    transaction_requiring_extra_processing.transaction_id = transaction_id

                    session.commit()

            else:

                order.otg = False

                session.commit()

        except Exception as e:

            print "Error inserting transaction Id: " + str(transaction_id) + " due to " + str(e)

    return True

    transaction_ids=[1043579, 1043580, 1043581, 1043582, 1043584, 1043588, 1043589]

    for transaction_id in transaction_ids:

        process_failed_payment(TransactionStatus.AUTHORIZED, transaction_id, "Transaction Authorised", 1, PickUpType.SELF)