WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py

     returnOrderInfo.warehouse_id = order.warehouse_id
     session.commit()
     return returnOrderInfo
-def create_return_order_info(returnInfo, order=None):
+def create_return_order_info(returnInfo, order=None, itemCondition="DAMAGED"):
     returnOrderInfo = ReturnOrderInfo()
     returnOrderInfo.orderId = returnInfo.orderId
     returnOrderInfo.lineItemId = order.lineitems[0].id
     returnOrderInfo.returnQuantity = returnInfo.returnQuantity
     returnOrderInfo.createdAt = datetime.datetime.now()
     all_return_orders_as_per_warehouse = ReturnOrderInfo.query.filter(ReturnOrderInfo.processedAt==None).filter(ReturnOrderInfo.warehouse_id <= warehouseId).all()
     if all_return_orders_as_per_warehouse is None:
         all_return_orders_as_per_warehouse = []
     return all_return_orders_as_per_warehouse
-def create_return_transaction(returnTransaction):
+def create_return_transaction(returnTransaction, itemCondition, overrideWarranty):
     t_orders = returnTransaction.returnOrders
     if not t_orders:
         raise TransactionServiceException(101, "Return Orders missing from the transaction")
+    returnOrdersMap = {}
+    for tOrder in t_orders:
+        returnOrdersMap[tOrder.orderId] = tOrder.returnQuantity
+    if validate_return_transaction(returnTransaction.customer_id, returnOrdersMap, itemCondition, overrideWarranty):
-    returnTxn = ReturnTransaction()
+        returnTxn = ReturnTransaction()
-    singleOrder = get_order(t_orders[0].orderId)
+        singleOrder = get_order(t_orders[0].orderId)
-    returnTxn.customer_id = returnTransaction.customer_id
+        returnTxn.customer_id = returnTransaction.customer_id
-    returnTxn.status = ReturnTransactionStatus._VALUES_TO_NAMES[ReturnTransactionStatus.INITIATED]
+        returnTxn.status = ReturnTransactionStatus._VALUES_TO_NAMES[ReturnTransactionStatus.INITIATED]
-    returnTxn.customer_email = singleOrder.customer_email
+        returnTxn.customer_email = singleOrder.customer_email
-    returnTxn.customer_name = singleOrder.customer_name
+        returnTxn.customer_name = singleOrder.customer_name
-    returnTxn.createdAt = datetime.datetime.now()
+        returnTxn.createdAt = datetime.datetime.now()
-    returnTxn.address_id = returnTransaction.address_id
+        returnTxn.address_id = returnTransaction.address_id
-    returnTxn.ticketId = returnTransaction.ticketId
-    returnTxn.customerAddress = returnTransaction.customerAddress
+        returnTxn.customerAddress = returnTransaction.customerAddress
-    returnTxn.customerCity = returnTransaction.customerCity
+        returnTxn.customerCity = returnTransaction.customerCity
-    returnTxn.customerPhone = returnTransaction.customerPhone
+        returnTxn.customerPhone = returnTransaction.customerPhone
-    returnTxn.customerState = returnTransaction.customerState
+        returnTxn.customerState = returnTransaction.customerState
-    returnTxn.pincode = returnTransaction.pincode
+        returnTxn.pincode = returnTransaction.pincode
-    for t_order in t_orders:
+        for t_order in t_orders:
-        order = get_order(t_order.orderId)
+            order = get_order(t_order.orderId)
-        returnOrder = create_return_order_info(t_order, order)
+            returnOrder = create_return_order_info(t_order, order, itemCondition)
-        returnOrder.returnTransaction = returnTxn
+            returnOrder.returnTransaction = returnTxn
-        lineitem = order.lineitems[0]
+            lineitem = order.lineitems[0]
-        lineitem.returnQty = lineitem.returnQty + returnOrder.returnQuantity
+            lineitem.returnQty = lineitem.returnQty + returnOrder.returnQuantity
-        order.status = OrderStatus.PARTIAL_RETURN_IN_PROCESS
+            order.status = OrderStatus.PARTIAL_RETURN_IN_PROCESS
-        order.statusDescription = "Partial Return In Process"
+            order.statusDescription = "Partial Return In Process"
-    session.commit()
-    try:
+        try:
-        crmServiceClient = CRMClient().get_client()
+            crmServiceClient = CRMClient().get_client()
-        ticket =Ticket()
+            ticket =Ticket()
-        activity = Activity()
+            activity = Activity()
-        description = "Creating Ticket for return requested by customer:- " + str(returnTransaction.customer_name)  + " Return Transaction Id:- "+ str(returnTxn.id)
+            description = "Creating Ticket for return requested by customer:- " + str(returnTransaction.customer_name)  + " Return Transaction Id:- "+ str(returnTxn.id)
-        ticket.creatorId = 1
+            ticket.creatorId = 1
-        ticket.assigneeId = 34
+            ticket.assigneeId = 34
-        ticket.category = TicketCategory.RETURN_FORM
+            ticket.category = TicketCategory.RETURN_FORM
-        ticket.priority = TicketPriority.HIGH
+            ticket.priority = TicketPriority.HIGH
-        ticket.status = TicketStatus.OPEN
+            ticket.status = TicketStatus.OPEN
-        ticket.description = description
+            ticket.description = description
-        ticket.orderId = order.id
+            ticket.orderId = order.id
-        activity.creatorId = 1
+            activity.creatorId = 1
-        activity.ticketAssigneeId = ticket.assigneeId
+            activity.ticketAssigneeId = ticket.assigneeId
-        activity.type = ActivityType.OTHER
+            activity.type = ActivityType.OTHER
-        activity.description = description
+            activity.description = description
-        activity.ticketCategory = ticket.category
+            activity.ticketCategory = ticket.category
-        activity.ticketDescription = ticket.description
+            activity.ticketDescription = ticket.description
-        activity.ticketPriority = ticket.priority
+            activity.ticketPriority = ticket.priority
-        activity.ticketStatus = ticket.status
+            activity.ticketStatus = ticket.status
-        ticket.customerId= returnTransaction.customer_id
+            ticket.customerId= returnTransaction.customer_id
-        ticket.customerEmailId = returnTransaction.customer_email
+            ticket.customerEmailId = returnTransaction.customer_email
-        ticket.customerMobileNumber = returnTransaction.customerPhone
+            ticket.customerMobileNumber = returnTransaction.customerPhone
-        ticket.customerName = returnTransaction.customer_name
+            ticket.customerName = returnTransaction.customer_name
-        activity.customerId = ticket.customerId
+            activity.customerId = ticket.customerId
-        activity.customerEmailId = returnTransaction.customer_email
+            activity.customerEmailId = returnTransaction.customer_email
-        activity.customerMobileNumber = returnTransaction.customerPhone
+            activity.customerMobileNumber = returnTransaction.customerPhone
-        activity.customerName = returnTransaction.customer_name
+            activity.customerName = returnTransaction.customer_name
-        crmServiceClient.insertTicket(ticket, activity)
+            returnTxn.ticketId = crmServiceClient.insertTicket(ticket, activity)
-    except:
+        except:
-        print "Ticket for RTO Refund is not created."
+            print "Ticket for RTO Refund is not created."
+        session.commit()
-    return returnTxn.id
+        return returnTxn.id
+    return 0
 def get_return_transactions_for_customer(statusList, customerMobile, customerEmail, returnTransactionId, customer_id):
     query = ReturnTransaction.query
     if statusList is not None and len(statusList) >0:
         statuses = []
             return True
         else:
             session.commit()
             return True
-def communicate_pickup_details_to_customer(returnPickupRequest):
+def communicate_pickup_details_to_customer(returnPickupRequest, returnOrders):
-    returnOrders = ReturnOrderInfo.query.filter(ReturnOrderInfo.logisticsRequestId==returnPickupRequest.id).all()
+    returnTxn = returnOrders[0].returnTransaction
-    subject = 'Pickup details'
+    subject = 'Pickup details for '+str(returnTxn.id)
     filename = "/PickupDetails/" +  str(returnPickupRequest.pickupRequestNo) +".pdf"
     try:
         inventory_client = InventoryClient().get_client()
         warehouse = inventory_client.getWarehouse(returnOrders[0].warehouse_id)
         logistics_client = LogisticsClient().get_client()
         provider = logistics_client.getProvider(returnPickupRequest.logisticsProviderId)
         provider_name = provider.name
-        returnTxn = returnOrders[0].returnTransaction
         to_addr = returnTxn.customer_email
         promised_pickup_time = returnPickupRequest.promised_pickup_timestamp.date().strftime("%d-%B-%Y (%A)")
         customer_address = returnTxn.customer_name +"\n" + returnTxn.customerAddress +"\n"
         customer_address = customer_address + returnTxn.customerCity + "\n"
         customer_address = customer_address + returnTxn.customerState + "\n"
                 else:
                     returnOrder.returnStatus = OrderStatus._VALUES_TO_NAMES[OrderStatus.RET_PICKUP_CONFIRMED]
         if returnPickupRequest.pickupStatus == ReturnTxnPickupStatus.PICKUP_SCHEDULED:
             returnPickupReq.pickupStatus = ReturnTxnPickupStatus._VALUES_TO_NAMES[returnPickupRequest.pickupStatus]
             returnPickupReq.promised_pickup_timestamp = datetime.datetime.now()+timedelta(days=2)
+            returnOrdersMap = {}
+            returnOrders = ReturnOrderInfo.query.filter(ReturnOrderInfo.logisticsRequestId==returnPickupRequest.id).all()
+            for returnOrder in returnOrders:
+                returnTxn = returnOrders[0].returnTransaction
+                if returnOrdersMap.has_key(returnTxn.address_id):
+                    retOrders = returnOrdersMap.get(returnTxn.address_id)
+                    retOrders.append(returnOrder)
+                    returnOrdersMap[returnTxn.address_id] = retOrders
+                else:
+                    retOrders = []
+                    retOrders.append(returnOrder)
+                    returnOrdersMap[returnTxn.address_id] = retOrders
+            for returnOrdersList in returnOrdersMap.values():
-            try:
+                try:
-                communicate_pickup_details_to_customer(returnPickupReq)
+                    communicate_pickup_details_to_customer(returnPickupReq, returnOrdersList)
-            except:
+                except:
-                print "Customer Communication Failed for the pickup Information"
+                    print "Customer Communication Failed for the pickup Information"
         if returnPickupRequest.pickedUpAt:
             returnPickupReq.pickedUpAt = to_py_date(returnPickupRequest.pickedUpAt)
             returnPickupReq.pickupStatus = ReturnTxnPickupStatus._VALUES_TO_NAMES[ReturnTxnPickupStatus.PICKUP_IN_TRANSIT]
             for returnOrder in ReturnOrderInfo.query.filter(ReturnOrderInfo.logisticsRequestId==returnPickupRequest.id).all():
                 if returnOrder.returnStatus == OrderStatus._VALUES_TO_NAMES[OrderStatus.DOA_PICKUP_CONFIRMED]:
     return orders
 def get_eligible_return_orders_for_pickup(customerId):
     return ReturnOrderInfo.query.filter(ReturnOrderInfo.returnTransaction.customer_id==customerId).filter(or_(ReturnOrderInfo.returnStatus==OrderStatus._VALUES_TO_NAMES[OrderStatus.RET_PICKUP_REQUEST_RAISED], ReturnOrderInfo.returnStatus==OrderStatus._VALUES_TO_NAMES[OrderStatus.DOA_PICKUP_REQUEST_RAISED])).all()
+def validate_return_transaction(customerId, returnOrdersMap, itemCondition, overrideWarranty):
+    eligibleOrders = get_eligible_orders_for_return(customerId, itemCondition, overrideWarranty)
+    ordersMap = {}
+    for order in eligibleOrders:
+        ordersMap[order.id] = order.lineitems[0].quantity - order.lineitems[0].returnQty
+    for orderId, returnOrderQty in returnOrdersMap.items():
+        if returnOrderQty > ordersMap.get(orderId):
+            return False
+    return True
 if __name__ == '__main__':
     print get_orders_by_mobile_number("9650889334")

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 19733 → 19735