WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/purchase/main/handler/PurchaseServiceHandler.py

 from shop2020.thriftpy.generic.ttypes import ExceptionType
 from shop2020.thriftpy.model.v1.inventory.ttypes import WarehouseType, \
     InventoryType
 from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus
 from shop2020.thriftpy.purchase.ttypes import PurchaseServiceException, POStatus, \
-    PurchaseOrder as TPurchaseOrder, LineItem as TLineItem
+    PurchaseOrder as TPurchaseOrder, LineItem as TLineItem, POType,\
+    PurchaseReturnType
 from shop2020.utils.Utils import to_py_date
 from sqlalchemy import create_engine
 from sqlalchemy.sql.expression import or_
 import datetime
 import logging
         setup_all(True)
     def getPOforOurExternalBilling(self):
         todayDate = datetime.datetime.now()
         todayDate = todayDate.replace(hour=0)
-        purchaseOrder = PurchaseOrder.query.filter(PurchaseOrder.supplierId == 1).filter(PurchaseOrder.createdAt > todayDate).first()
+        purchaseOrder = PurchaseOrder.query.filter(PurchaseOrder.supplierId == 1).filter(PurchaseOrder.createdAt > todayDate).filter(PurchaseOrder.type == POType.VIRTUAL).first()
         if purchaseOrder is None:
             t_purchaseOrder = TPurchaseOrder()
             t_purchaseOrder.supplierId = 1
             t_purchaseOrder.createdAt = datetime.datetime.now()
             t_purchaseOrder.status = 0
             t_purchaseOrder.totalCost = 0
             t_purchaseOrder.poNumber = 'Ours-Ext-' + str(todayDate.year) + "-" + str(todayDate.month) + "-" + str(todayDate.day)
+            t_purchaseOrder.type = POType.VIRTUAL
             purchaseOrder = PurchaseOrder(t_purchaseOrder)
             session.commit()
         return purchaseOrder.id
     def updatelineItemforOursExternalBilling(self, poId, itemId, unitPrice):
         Parameters:
          - status
         """
         try:
-            pos = PurchaseOrder.query.filter_by(status=status).all()
+            pos = PurchaseOrder.query.filter_by(status=status, type=POType.REAL).all()
             return [po.to_thrift_object() for po in pos ]
         finally:
             self.close_session()
     def getPurchaseOrder(self, id):
                         if availability.has_key(item.id):
                             availability[item.id] = [availability[item.id][0] + quantity, item]
                         else:
                             availability[item.id] = [quantity, item]
-            unfulfilledPurchaseOrders = PurchaseOrder.query.filter(or_(PurchaseOrder.status == POStatus.PARTIALLY_FULFILLED, PurchaseOrder.status == POStatus.READY)).all()
+            unfulfilledPurchaseOrders = PurchaseOrder.query.filter(or_(PurchaseOrder.status == POStatus.PARTIALLY_FULFILLED, PurchaseOrder.status == POStatus.READY)).filter(PurchaseOrder.type == POType.REAL).all()
             for purchaseOrder in unfulfilledPurchaseOrders:
                 for lineitem in purchaseOrder.lineitems:
                     if availability.has_key(lineitem.itemId):
                         availability[lineitem.itemId] = [availability[lineitem.itemId][0] + lineitem.unfulfilledQuantity, availability[lineitem.itemId][1]]
                     else:
                     if order.cod:
                         if (codRequirements.has_key(lineitem.item_id)):
                             codRequirements[lineitem.item_id] += lineitem.quantity
                         else:
                             codRequirements[lineitem.item_id] = lineitem.quantity
+            advancedPOParameters = {}
+            for key in requirements:
+                inventory_client = InventoryClient().get_client()
+                oosStatuses = inventory_client.getOosStatusesForXDaysForItem(key,5)
+                salesCount = 0
+                numDaysInStock = 0
+                for oosStatus in oosStatuses:
+                    if oosStatus.status == False:
+                        salesCount = salesCount + oosStatus.num_orders
+                        numDaysInStock = numDaysInStock + 1
+                avgSales = salesCount/numDaysInStock
+                if avgSales>1:
+                    itemStockPurchaseParam = inventory_client.getItemStockPurchaseParams(key)
+                advancedPOParameters[key] = [avgSales * itemStockPurchaseParam.numOfDaysStock, avgSales, numDaysInStock, itemStockPurchaseParam.minStockLevel, itemStockPurchaseParam.numOfDaysStock]
             netRequirements = {}
             for itemId in requirements.keys():
                 requirementsCount = requirements.get(itemId)
                 if  availability.has_key(itemId):
                     availabilityCount = availability.get(itemId)[0]
                     t_po_lineitem.modelNumber = item.modelNumber
                     t_po_lineitem.modelName = item.modelName
                     t_po_lineitem.color = item.color
                     t_po_lineitem.itemId = item.id
                     t_po_lineitem.quantity = quantity
+                    t_po_lineitem.availableQuantity = availability[item.id][0]
+                    t_po_lineitem.reservedQuantity = requirements[lineitem.item_id]
+                    t_po_lineitem.suggestedQuantity = advancedPOParameters[item.id][0]
+                    t_po_lineitem.avgSales = advancedPOParameters[item.id][1]
+                    t_po_lineitem.numberOfDaysInStock = advancedPOParameters[item.id][2]
+                    t_po_lineitem.minStockLevel = advancedPOParameters[item.id][3]
+                    t_po_lineitem.numberOfDaysStock = advancedPOParameters[item.id][2]
                     if codRequirements.has_key(item.id):
                         t_po_lineitem.codCount = min(codRequirements[item.id], quantity)
                     try:
                         item_pricing = inventory_client.getItemPricing(item.id, vendorId)
                     except Exception as e:
             purchaseReturn = PurchaseReturn(t_purchaseReturn.vendorId, t_purchaseReturn.amount)
             purchaseReturn.vendorId = t_purchaseReturn.vendorId
             purchaseReturn.amount = t_purchaseReturn.amount
             purchaseReturn.returnTimestamp = to_py_date(t_purchaseReturn.returnTimestamp)
             purchaseReturn.isSettled = False
+            purchaseReturn.type = t_purchaseReturn.type
             session.commit()
             return purchaseReturn.id
         except Exception as e:
             print e
             raise PurchaseServiceException(101, 'Exception while creating  Purchase Return for ' + purchaseReturn.vendorId + ' for Rs' + purchaseReturn.amount)
     def getUnsettledPurchaseReturns(self):
         '''
         For getting all unsettled Purchase Returns
         '''
         try:
-            purchaseReturns = PurchaseReturn.query.filter_by(isSettled=False).all()
+            purchaseReturns = PurchaseReturn.query.filter_by(isSettled=False).filter_by(type=PurchaseReturnType.REAL).all()
             return [purchasereturn.to_thrift_object() for purchasereturn in purchaseReturns]
         except Exception as e:
             print e
             raise PurchaseServiceException(101, 'Exception while fetching all Unsettled Purchase Returns')
         finally:

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/purchase/main/handler/PurchaseServiceHandler.py – Rev 6762 → 6821