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

 from shop2020.model.v1.order.impl.model.UserWalletHistory import \
     UserWalletHistory
 from shop2020.thriftpy.alert.ttypes import MonitoredEntity, EntityType
 from shop2020.thriftpy.crm.ttypes import *
 from shop2020.thriftpy.logistics.ttypes import DeliveryType, PickUpType
-from shop2020.thriftpy.model.v1.catalog.ttypes import ItemType
+from shop2020.thriftpy.model.v1.catalog.ttypes import ItemType, ItemCondition
 from shop2020.thriftpy.model.v1.inventory.ttypes import BillingType, \
     InventoryServiceException, WarehouseType, InventoryType, VatType, ItemInventory
 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
     HotspotAction, TimeoutSummary, OrderStatusGroups, OrderType, RechargeOrderStatus, \
                 process_credit_transaction(order.transaction.id, order.customer_id, 1, creditTxns, order.invoice_number)
             except:
                 traceback.print_exc()
                 session.rollback()
                 return
+    itemIds = []
+    ordersMap = {}
+    orderItemsMap = {}
+    for order in grouppedOrdersList:
+        if order.lineitems[0].item_id not in itemIds:
+            itemIds.append(order.lineitems[0].item_id)
+        ordersMap[order.id] = order
+        orderItemsMap[order.id] = order.lineitems[0].item_id
+    catalogClient = CatalogClient().get_client()
+    items = catalogClient.getItems(itemIds)
+    catalogIds = []
+    catalogItemsMap = {}
+    for item in items:
+        catalogIds.append(item.catalog_item_id)
+        catalogItemsMap[item.id] = item.catalog_item_id
+    itemWarrantyInfoMap = catalogClient.getWarrantyInfoForItemList(catalogIds, ItemCondition.DAMAGED)
+    itemDOAWarrantyInfoMap = catalogClient.getWarrantyInfoForItemList(catalogIds, ItemCondition.DEFECTIVE)
     for order in grouppedOrdersList:
         if order == None or order.status not in [OrderStatus.SHIPPED_FROM_WH, OrderStatus.SHIPPED_TO_LOGST, OrderStatus.SHIPPED_TO_DESTINATION_CITY, OrderStatus.REACHED_DESTINATION_CITY, OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE, OrderStatus.DOA_PICKUP_REQUEST_RAISED, OrderStatus.DOA_PICKUP_CONFIRMED, OrderStatus.RET_REQUEST_RECEIVED, OrderStatus.RET_PICKUP_CONFIRMED, OrderStatus.RET_REQUEST_AUTHORIZED, OrderStatus.RET_PICKUP_REQUEST_RAISED, OrderStatus.RTO_IN_TRANSIT, OrderStatus.BILLED, OrderStatus.RECEIVED_AT_STORE]:
             raise TransactionServiceException(101, "Either wrong order id or invalid state " + str(orderId))
         # Provider is 4 is for self pickup and hardcoded. We should figure out a way to not to hard code.
             alert_client.endMonitoringEntity(EntityType.COURIER, "orderId = " + str(order.id))
         except Exception as e:
             print "Exception in ending alert in MarkOrderAsDelivered method"
             print e
+    for orderId, order in ordersMap.items():
+        orderItemId = orderItemsMap.get(orderId)
+        orderCatalogItemId = catalogItemsMap.get(orderItemId)
+        itemWarrantyInfo = itemWarrantyInfoMap.get(orderCatalogItemId)
+        itemDOAWarrantyInfo = itemDOAWarrantyInfoMap.get(orderCatalogItemId)
+        itemWarrntyVal = 0
+        doaItemWarrantyVal = 0
+        if itemWarrantyInfo.key()[0]=='M':
+            itemWarrntyVal = 30*itemWarrantyInfo.values()[0]
+        else:
+            itemWarrntyVal = itemWarrantyInfo.values()[0]
+        if itemDOAWarrantyInfo.key()[0]=='M':
+            doaItemWarrantyVal = 30*itemDOAWarrantyInfo.values()[0]
+        else:
+            doaItemWarrantyVal = itemDOAWarrantyInfo.values()[0]
+        order.lineitems[0].warrantry_expiry_timestamp = deliveryTimestamp + timedelta(days=itemWarrntyVal)
+        order.lineitems[0].damaged_expiry_timestamp = deliveryTimestamp + timedelta(days=doaItemWarrantyVal)
     update_trust_level(grouppedOrdersList[0])
     session.commit()
 def mark_order_as_received_at_store(orderId, deliveryTimestamp):
             returnOrder.returnTxnResolutionStatus = ReturnTxnResolutionStatus._VALUES_TO_NAMES[ReturnTxnResolutionStatus.REFUND_DONE]
         else:
             returnOrder.processedAt = datetime.datetime.now()
             returnOrder.refundDescription = str(returnOrder.replacementOrderId) + " has been delivered now"
             returnOrder.returnTxnResolutionStatus = ReturnTxnResolutionStatus._VALUES_TO_NAMES[ReturnTxnResolutionStatus.REPLACEMENT_DONE]
+    session.commit()
+def get_eligible_orders_for_return(customerId, itemCondition, overrideWarranty):
+    query = session.query(Order).join((LineItem,Order.id==LineItem.order_id)).filter(Order.delivery_timestamp != None).filter(LineItem.quantity-LineItem.returnQty>0)
+    if not overrideWarranty and itemCondition is not None:
+        if itemCondition == 'DAMAGED':
+            query = query.filter(LineItem.warranty_expiry_timestamp<=datetime.datetime.now())
+        elif itemCondition == 'DEFECTIVE':
+            query = query.filter(LineItem.damaged_expiry_timestamp<=datetime.datetime.now())
+    orders = query.order_by(desc(Order.delivery_timestamp)).all()
+    return orders
+def get_eligible_return_orders_for_pickup(customerId):
-    session.commit()
+    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()
 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 19693 → 19714