WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/catalog/script/SnapdealHistoryPopulator.py

 from shop2020.config.client.ConfigClient import ConfigClient
 from shop2020.model.v1.catalog.impl import DataService
 from shop2020.model.v1.catalog.impl.DataService import SnapdealItem, MarketplaceItems, Item, \
 Category, SourcePercentageMaster, MarketPlaceHistory
 from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
-from shop2020.thriftpy.model.v1.catalog.ttypes import CompetitionCategory, CompetitionBasis, SalesPotential
+from shop2020.thriftpy.model.v1.catalog.ttypes import CompetitionCategory, CompetitionBasis, SalesPotential,\
+Decision
 from shop2020.clients.CatalogClient import CatalogClient
 from shop2020.clients.InventoryClient import InventoryClient
 import urllib2
 import time
 from datetime import date, datetime
 import sys
 config_client = ConfigClient()
 host = config_client.get_property('staging_hostname')
 DataService.initialize(db_hostname=host)
+import logging
+lgr = logging.getLogger()
+lgr.setLevel(logging.DEBUG)
+fh = logging.FileHandler('snapdeal-history.log')
+fh.setLevel(logging.INFO)
+frmt = logging.Formatter('%(asctime)s - %(name)s - %(message)s')
+fh.setFormatter(frmt)
+lgr.addHandler(fh)
 class __Exception:
     SERVER_SIDE=1
         self.competitionBasis = competitionBasis
         self.ourSp = ourSp
         self.secondLowestSellerTp = secondLowestSellerTp
         self.lowestPossibleSp = lowestPossibleSp
+def fetchItemsForAutoDecrease(time):
+    autoDecrementItems = MarketplaceItems.query.filter(MarketplaceItems.autoDecrement==True,MarketplaceItems.source==OrderSource.SNAPDEAL).all()
+    inventory_client = InventoryClient().get_client()
+    inventoryMap = inventory_client.getInventorySnapshot(0)
+    for autoDecrementItem in autoDecrementItems:
+        mpHistory = MarketPlaceHistory.get_by(source=OrderSource.SNAPDEAL,item_id=autoDecrementItem.itemId,timestamp=time)
+        if not mpHistory.risky:
+            markReasonForMpItem(mpHistory,'Item is not risky',Decision.AUTO_DECREMENT_FAILED)
+            continue
+        if mpHistory.proposedSellingPrice >= mpHistory.ourSellingPrice:
+            markReasonForMpItem(mpHistory,'Proposed SP greater than current SP',Decision.AUTO_DECREMENT_FAILED)
+            continue
+        if not mpHistory.competitiveCategory == CompetitionCategory.COMPETITIVE:
+            markReasonForMpItem(mpHistory,'Category is '+CompetitionCategory._VALUES_TO_NAMES.get(mpHistory.competitiveCategory),Decision.AUTO_DECREMENT_FAILED)
+            continue
+        if mpHistory.otherInventory < 3:
+            markReasonForMpItem(mpHistory,'Competition stock is not enough',Decision.AUTO_DECREMENT_FAILED)
+            continue
+        oosStatus = inventory_client.getOosStatusesForXDaysForItem(autoDecrementItem.itemId,0,3)
+        count,sale,daysOfStock = 0,0,0
+        for obj in oosStatus:
+            if not obj.is_oos:
+                count+=1
+                sale = sale+obj.num_orders
+        avgSalePerDay=0 if count==0 else (float(sale)/count)
+        totalAvailability, totalReserved = 0,0
+        itemInventory=inventoryMap[autoDecrementItem.itemId]
+        availableMap  = itemInventory.availability
+        reserveMap = itemInventory.reserved
+        for warehouse,availability in availableMap.iteritems():
+            if warehouse==16:
+                continue
+            totalAvailability = totalAvailability+availability
+        for warehouse,reserve in reserveMap.iteritems():
+            if warehouse==16:
+                continue
+            totalReserved = totalReserved+reserve
+        if (totalAvailability-totalReserved)<=0:
+            markReasonForMpItem(mpHistory,'Our stock is not enough',Decision.AUTO_DECREMENT_FAILED)
+            continue
+        daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
+        if daysOfStock<2:
+            markReasonForMpItem(mpHistory,'Our stock is not enough',Decision.AUTO_DECREMENT_FAILED)
+            continue
+        mpHistory.competitorEnoughStock = True
+        mpHistory.ourEnoughStock = True
+        mpHistory.avgSales = avgSalePerDay
+        mpHistory.decision = Decision.AUTO_DECREMENT_SUCCESS
+        mpHistory.reason = 'All conditions for auto decrement true'
+        lgr.info("Auto decrement success for itemId "+str(autoDecrementItem.itemId)+" Days of stock "+str(daysOfStock)+" avg sales "+str(avgSalePerDay))
+    session.commit()
+def fetchItemsForAutoIncrease(time):
+    autoIncrementItems = MarketplaceItems.query.filter(MarketplaceItems.autoIncrement==True,MarketplaceItems.source==OrderSource.SNAPDEAL).all()
+    inventory_client = InventoryClient().get_client()
+    inventoryMap = inventory_client.getInventorySnapshot(0)
+    for autoIncrementItem in autoIncrementItems:
+        mpHistory = MarketPlaceHistory.get_by(source=OrderSource.SNAPDEAL,item_id=autoIncrementItem.itemId,timestamp=time)
+        if mpHistory.proposedSellingPrice <= mpHistory.ourSellingPrice:
+            markReasonForMpItem(mpHistory,'Proposed SP less than current SP',Decision.AUTO_INCREMENT_FAILED)
+            continue
+        if mpHistory.totalSeller==1 and mpHistory.ourRank==1:
+            markReasonForMpItem(mpHistory,'We are the only seller',Decision.AUTO_INCREMENT_FAILED)
+            continue
+        oosStatus = inventory_client.getOosStatusesForXDaysForItem(autoIncrementItem.itemId,0,3)
+        count,sale,daysOfStock = 0,0,0
+        for obj in oosStatus:
+            if not obj.is_oos:
+                count+=1
+                sale = sale+obj.num_orders
+        avgSalePerDay=0 if count==0 else (float(sale)/count)
+        totalAvailability, totalReserved = 0,0
+        itemInventory=inventoryMap[autoIncrementItem.itemId]
+        availableMap  = itemInventory.availability
+        reserveMap = itemInventory.reserved
+        for warehouse,availability in availableMap.iteritems():
+            if warehouse==16:
+                continue
+            totalAvailability = totalAvailability+availability
+        for warehouse,reserve in reserveMap.iteritems():
+            if warehouse==16:
+                continue
+            totalReserved = totalReserved+reserve
+        if (totalAvailability-totalReserved)<=0:
+            markReasonForMpItem(mpHistory,'Our stock is 0',Decision.AUTO_INCREMENT_FAILED)
+            continue
+        daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
+        if daysOfStock>5:
+            markReasonForMpItem(mpHistory,'Our stock is enough',Decision.AUTO_INCREMENT_FAILED)
+            continue
+        mpHistory.ourEnoughStock = False
+        mpHistory.avgSales = avgSalePerDay
+        mpHistory.decision = Decision.AUTO_INCREMENT_SUCCESS
+        mpHistory.reason = 'All conditions for auto increment true'
+        lgr.info("Auto increment success for itemId "+str(autoIncrementItem.itemId)+" Days of stock "+str(daysOfStock)+" avg sales "+str(avgSalePerDay))
+    session.commit()
+def markReasonForMpItem(mpHistory,reason,decision):
+    mpHistory.decision = decision
+    mpHistory.reason = reason
 def fetchDetails(supc_code):
     url="http://www.snapdeal.com/json/gvbps?supc=%s&catId=91"%(supc_code)
     print url
     time.sleep(1)
     req = urllib2.Request(url)
 def getTargetTp(targetSp,mpItem):
     return targetSp- targetSp*(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))-(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100));
 def getTargetSp(targetTp,mpItem):
-    return targetTp+(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100))/(1-((mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))))
+    return float(targetTp+(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100)))/(1-((mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))))
 def getSalesPotential(lowestOfferPrice,ourNlc):
     if lowestOfferPrice - ourNlc < 0:
         return 'HIGH'
-    elif (lowestOfferPrice - ourNlc)/lowestOfferPrice >=0 and (lowestOfferPrice - ourNlc)/lowestOfferPrice <=.02:
+    elif (float(lowestOfferPrice - ourNlc))/lowestOfferPrice >=0 and (float(lowestOfferPrice - ourNlc))/lowestOfferPrice <=.02:
         return 'MEDIUM'
     else:
         return 'LOW'
 def main():
     commitCantCompete(cantCompete,timestamp)
     commitBuyBox(buyBoxItems,timestamp)
     commitCompetitive(competitive,timestamp)
     commitCompetitiveNoInventory(competitiveNoInventory,timestamp)
     commitNegativeMargin(negativeMargin,timestamp)
+    fetchItemsForAutoDecrease(timestamp)
+    fetchItemsForAutoIncrease(timestamp)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/catalog/script/SnapdealHistoryPopulator.py – Rev 9888 → 9897