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

 Created on 29-Mar-2010
 @author: Chandranshu
 '''
-from datetime import date
+from datetime import date, timedelta
 from elixir import *
 from reportlab.lib.units import inch
 from reportlab.pdfgen.canvas import Canvas
 from reportlab.rl_config import defaultPageSize
 from shop2020.clients.CatalogClient import CatalogClient
 from shop2020.model.v1.order.impl.model.ReturnOrder import ReturnOrder
 from shop2020.thriftpy.logistics.ttypes import DeliveryType
 from shop2020.thriftpy.model.v1.catalog.ttypes import BillingType
 from shop2020.thriftpy.model.v1.order.ttypes import Transaction as T_Transaction, \
     TransactionServiceException, TransactionStatus, OrderStatus, DelayReason, \
-    ExtraTransactionProcessingType, HotspotAction
+    ExtraTransactionProcessingType, HotspotAction, TimeoutSummary
 from shop2020.thriftpy.warehouse.ttypes import PurchaseOrder, \
     LineItem as POLineItem, ScanType
 from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part
 from shop2020.utils.Utils import to_py_date, to_java_date
 from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound
                     logging.info("Unable to accept the order")
         else:
             order_outofstock(order.id)
     return
-def mark_orders_as_po_raised(vendorId, itemId, quantity, estimate):
+def mark_orders_as_po_raised(vendorId, itemId, quantity, estimate, isReminder):
+    if isReminder:
+        statuses = tuple([OrderStatus.LOW_INV_PO_RAISED_TIMEOUT, OrderStatus.LOW_INV_REVERSAL_TIMEOUT])
+    else:
+        statuses = tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW])
-    orders = Order.query.filter(Order.status.in_(tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW]))).order_by(Order.expected_shipping_time).all()
+    orders = Order.query.filter(Order.status.in_(statuses)).order_by(Order.expected_shipping_time).all()
     for order in orders:
         lineitem = order.lineitems[0]
         if quantity >= lineitem.quantity and itemId == lineitem.item_id:
             if estimate > 0:
                 add_delay_reason(order.id, DelayReason.OTHERS, estimate)
             order.statusDescription = "PO Raised"
             quantity = quantity - lineitem.quantity
             store_inventory_action(order, itemId, HotspotAction.PO_RAISED, estimate, lineitem.quantity)
             session.commit()
-def mark_orders_as_reversal_initiated(vendorId, itemId, quantity, estimate):
+def mark_orders_as_reversal_initiated(vendorId, itemId, quantity, estimate, isReminder):
+    if isReminder:
+        statuses = tuple([OrderStatus.LOW_INV_PO_RAISED_TIMEOUT, OrderStatus.LOW_INV_REVERSAL_TIMEOUT])
+    else:
+        statuses = tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW])
-    orders = Order.query.filter(Order.status.in_(tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW]))).order_by(Order.expected_shipping_time).all()
+    orders = Order.query.filter(Order.status.in_(statuses)).order_by(Order.expected_shipping_time).all()
     for order in orders:
         lineitem = order.lineitems[0]
         if quantity >= lineitem.quantity and itemId == lineitem.item_id:
             if estimate > 0:
                 add_delay_reason(order.id, DelayReason.OTHERS, estimate)
             order.statusDescription = "Reversal Initiated"
             quantity = quantity - lineitem.quantity
             store_inventory_action(order, itemId, HotspotAction.REVERSAL_INITIATED, estimate, lineitem.quantity)
             session.commit()
-def mark_orders_as_not_available(vendorId, itemId, quantity, estimate):
+def mark_orders_as_not_available(vendorId, itemId, quantity, estimate, isReminder):
+    if isReminder:
+        statuses = tuple([OrderStatus.LOW_INV_PO_RAISED_TIMEOUT, OrderStatus.LOW_INV_REVERSAL_TIMEOUT])
+    else:
+        statuses = tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW])
-    orders = Order.query.filter(Order.status.in_(tuple([OrderStatus.SUBMITTED_FOR_PROCESSING, OrderStatus.INVENTORY_LOW]))).order_by(Order.expected_shipping_time).all()
+    orders = Order.query.filter(Order.status.in_(statuses)).order_by(Order.expected_shipping_time).all()
     for order in orders:
         lineitem = order.lineitems[0]
         if quantity >= lineitem.quantity and itemId == lineitem.item_id:
             order.status = OrderStatus.LOW_INV_NOT_AVAILABLE_AT_HOTSPOT
             order.statusDescription = "Not Available"
             quantity = quantity - lineitem.quantity
             store_inventory_action(order, itemId, HotspotAction.NOT_AVAILABLE, estimate, lineitem.quantity)
             session.commit()
 def store_inventory_action(order, itemId, hotspotAction, estimate, quantity):
+    orderInv = OrderInventory.get_by(order_id=order.id)
+    if not orderInv:
-    orderInv = OrderInventory()
+        orderInv = OrderInventory()
+        orderInv.order = order
     orderInv.hotspotAction = hotspotAction
     orderInv.estimate = estimate
     orderInv.itemId = itemId
     orderInv.timestamp = datetime.datetime.now()
     orderInv.quantity = quantity
-    orderInv.order = order
+def mark_orders_as_timeout(vendorId):
+    ret_timeouts = {}
+    orderInvs = OrderInventory.query.all()
+    for orderInv in orderInvs:
+        if orderInv.timestamp +  timedelta(days=orderInv.estimate) < datetime.datetime.now():
+            if not ret_timeouts.has_key(orderInv.itemId):
+                timeout = TimeoutSummary()
+                ret_timeouts[orderInv.itemId] = timeout
+            else:
+                timeout = ret_timeouts.get(orderInv.itemId)
+            if orderInv.hotspotAction == HotspotAction.PO_RAISED and orderInv.order.status == OrderStatus.LOW_INV_PO_RAISED:
+                if timeout.poRaised:
+                    timeout.poRaised += 1
+                else:
+                    timeout.poRaised = 1
+                if timeout.poEstimate:
+                    timeout.poEstimate += orderInv.estimate
+                else:
+                    timeout.poEstimate = orderInv.estimate
+                orderInv.order.status = OrderStatus.LOW_INV_PO_RAISED_TIMEOUT
+                orderInv.order.statusDescription = "PO Raised Timeout"
+            elif orderInv.hotspotAction == HotspotAction.REVERSAL_INITIATED and orderInv.order.status == OrderStatus.LOW_INV_REVERSAL_IN_PROCESS:
+                if timeout.reversalInitiated:
+                    timeout.reversalInitiated += 1
+                else:
+                    timeout.reversalInitiated = 1
+                if timeout.reversalEstimate:
+                    timeout.reversalEstimate += orderInv.estimate
+                else:
+                    timeout.reversalEstimate = orderInv.estimate
+                orderInv.order.status = OrderStatus.LOW_INV_REVERSAL_TIMEOUT
+                orderInv.order.statusDescription = "Reversal Initiated Timeout"
+            else:
+                orderInv.delete()
+    session.commit()
+    return ret_timeouts
 def close_session():
     if session.is_active:
         print "session is active. closing it."
         session.close()

Subversion Repositories SmartDukaan

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