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

             markReasonForMpItem(autoDecrementItem,'Proposed SP greater than or equal to current SP',Decision.AUTO_DECREMENT_FAILED)
             continue
         if autoDecrementItem.proposedSellingPrice < autoDecrementItem.lowestPossibleSp:
             markReasonForMpItem(autoDecrementItem,'Proposed SP less than lowest possible SP',Decision.AUTO_DECREMENT_FAILED)
             continue
-        totalAvailability, totalReserved = 0,0
-        if (not inventoryMap.has_key(autoDecrementItem.item_id)):
-            markReasonForMpItem(autoDecrementItem,'Inventory info not available',Decision.AUTO_DECREMENT_FAILED)
-            continue
-        itemInventory=inventoryMap[autoDecrementItem.item_id]
-        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(autoDecrementItem,'Net availability is 0',Decision.AUTO_DECREMENT_FAILED)
-            continue
-        avgSalePerDay = (itemSaleMap.get(autoDecrementItem.item_id))[2]
-        try:
-            daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
-        except ZeroDivisionError,e:
-            daysOfStock = float("inf")
-        if daysOfStock<2 and autoDecrementItem.risky:
-            markReasonForMpItem(autoDecrementItem,'Our stock is not enough',Decision.AUTO_DECREMENT_FAILED)
-            continue
         if autoDecrementItem.competitiveCategory == CompetitionCategory.PREF_BUT_NOT_CHEAP:
             avgSaleLastTwoDay = (itemSaleMap.get(autoDecrementItem.item_id))[6]
-            if avgSaleLastTwoDay >= 3:
+            if avgSaleLastTwoDay >= .5:
                 markReasonForMpItem(autoDecrementItem,'Last two day avg sale is greater than 2',Decision.AUTO_DECREMENT_FAILED)
                 continue
+        totalAvailability, totalReserved = 0,0
+        if autoDecrementItem.risky:
+            if (not inventoryMap.has_key(autoDecrementItem.item_id)):
+                markReasonForMpItem(autoDecrementItem,'Inventory info not available',Decision.AUTO_DECREMENT_FAILED)
+                continue
+            itemInventory=inventoryMap[autoDecrementItem.item_id]
+            availableMap  = itemInventory.availability
+            reserveMap = itemInventory.reserved
+            for warehouse,availability in availableMap.iteritems():
+                if warehouse==16 or warehouse==1771:
+                    continue
+                totalAvailability = totalAvailability+availability
+            for warehouse,reserve in reserveMap.iteritems():
+                if warehouse==16 or warehouse==1771:
+                    continue
+                totalReserved = totalReserved+reserve
+            if (totalAvailability-totalReserved)<=0:
+                markReasonForMpItem(autoDecrementItem,'Net availability is 0',Decision.AUTO_DECREMENT_FAILED)
+                continue
+            avgSalePerDay = (itemSaleMap.get(autoDecrementItem.item_id))[2]
+            try:
+                daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
+            except ZeroDivisionError,e:
+                daysOfStock = float("inf")
+            if daysOfStock<2 and autoDecrementItem.risky:
+                markReasonForMpItem(autoDecrementItem,'Our stock is not enough',Decision.AUTO_DECREMENT_FAILED)
+                continue
         autoDecrementItem.ourEnoughStock = True
         autoDecrementItem.decision = Decision.AUTO_DECREMENT_SUCCESS
         autoDecrementItem.reason = 'All conditions for auto decrement true'
         successfulAutoDecrease.append(autoDecrementItem)
         #    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
+        if autoIncrementItem.risky:
-        if (not inventoryMap.has_key(autoIncrementItem.item_id)):
+            if (not inventoryMap.has_key(autoIncrementItem.item_id)):
-            markReasonForMpItem(autoIncrementItem,'Inventory info not available',Decision.AUTO_INCREMENT_FAILED)
+                markReasonForMpItem(autoIncrementItem,'Inventory info not available',Decision.AUTO_INCREMENT_FAILED)
-            continue
-        itemInventory=inventoryMap[autoIncrementItem.item_id]
-        availableMap  = itemInventory.availability
-        reserveMap = itemInventory.reserved
-        for warehouse,availability in availableMap.iteritems():
-            if warehouse==16:
                 continue
+            itemInventory=inventoryMap[autoIncrementItem.item_id]
+            availableMap  = itemInventory.availability
+            reserveMap = itemInventory.reserved
+            for warehouse,availability in availableMap.iteritems():
+                if warehouse==16 or warehouse==1771:
+                    continue
-            totalAvailability = totalAvailability+availability
+                totalAvailability = totalAvailability+availability
-        for warehouse,reserve in reserveMap.iteritems():
+            for warehouse,reserve in reserveMap.iteritems():
+                if warehouse==16 or warehouse==1771:
+                    continue
+                totalReserved = totalReserved+reserve
+            #if (totalAvailability-totalReserved)<=0:
+            #    markReasonForMpItem(autoIncrementItem,'Our stock is 0',Decision.AUTO_INCREMENT_FAILED)
+            #    continue
+            avgSalePerDay = (itemSaleMap.get(autoIncrementItem.item_id))[2]
+            if (avgSalePerDay==0):
+                markReasonForMpItem(autoIncrementItem,'Average sale per day is zero',Decision.AUTO_INCREMENT_FAILED)
+                continue
+            daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
-            if warehouse==16:
+            if daysOfStock>5:
+                markReasonForMpItem(autoIncrementItem,'Our stock is enough',Decision.AUTO_INCREMENT_FAILED)
                 continue
-            totalReserved = totalReserved+reserve
-        #if (totalAvailability-totalReserved)<=0:
-        #    markReasonForMpItem(autoIncrementItem,'Our stock is 0',Decision.AUTO_INCREMENT_FAILED)
-        #    continue
-        avgSalePerDay = (itemSaleMap.get(autoIncrementItem.item_id))[2]
-        if (avgSalePerDay==0):
-            markReasonForMpItem(autoIncrementItem,'Average sale per day is zero',Decision.AUTO_INCREMENT_FAILED)
-            continue
-        daysOfStock = (float(totalAvailability-totalReserved))/avgSalePerDay
-        if daysOfStock>5:
-            markReasonForMpItem(autoIncrementItem,'Our stock is enough',Decision.AUTO_INCREMENT_FAILED)
-            continue
         autoIncrementItem.ourEnoughStock = False
         autoIncrementItem.decision = Decision.AUTO_INCREMENT_SUCCESS
         autoIncrementItem.reason = 'All conditions for auto increment true'
         successfulAutoIncrease.append(autoIncrementItem)
         flipkartDetails.shippingTimeLowerLimitLowestSeller = flipkartDetails.shippingTimeLowerLimitOur
         flipkartDetails.shippingTimeUpperLimitLowestSeller = flipkartDetails.shippingTimeUpperLimitOur
         flipkartDetails.lowestSellerName = 'Saholic'
         flipkartDetails.lowestSellerCode = flipkartDetails.ourCode
         flipkartDetails.lowestSellerBuyTrend = flipkartDetails.ourBuyTrend
+        flipkartDetails.rank=1
+        flipkartDetails.ourBuyTrend ='NPrefCheap'
     return flipkartDetails
 def calculateAverageSale(oosStatus):
     count,sale = 0,0
 def getNetAvailability(itemInventory):
     totalAvailability, totalReserved = 0,0
     availableMap  = itemInventory.availability
     reserveMap = itemInventory.reserved
     for warehouse,availability in availableMap.iteritems():
-        if warehouse==16:
+        if warehouse==16 or warehouse==1771:
             continue
         totalAvailability = totalAvailability+availability
     for warehouse,reserve in reserveMap.iteritems():
-        if warehouse==16:
+        if warehouse==16 or warehouse==1771:
             continue
         totalReserved = totalReserved+reserve
     return totalAvailability - totalReserved
 def getOosString(oosStatus):
         spm = val.sourcePercentage
         flipkartDetails = val.flipkartDetails
         if (flipkartDetails is None or flipkartDetails.totalAvailableSeller==0):
             exceptionItems.append(val)
             continue
+        if ((flipkartDetails.rank=='' or flipkartDetails.rank==0) and val.ourFlipkartInventory!=0):
+            exceptionItems.append(val)
+            continue
         mpItem = MarketplaceItems.get_by(itemId=val.item_id,source=OrderSource.FLIPKART)
         if flipkartDetails.rank==0:
             flipkartDetails.ourSp = mpItem.currentSp
             ourSp = mpItem.currentSp
         try:
             smtpServer.sendmail(sender, recipients, msg.as_string())
             print "Successfully sent email"
         except:
             print "Error: unable to send email."
+def sendAlertForCompetitiveNoInventory(timestamp):
+    xstr = lambda s: s or ""
+    competitiveNoInv = session.query(MarketPlaceHistory,Item).join((Item,MarketPlaceHistory.item_id==Item.id)).filter(MarketPlaceHistory.timestamp==timestamp).filter(MarketPlaceHistory.source==OrderSource.FLIPKART).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.COMPETITIVE_NO_INVENTORY).all()
+    if len(competitiveNoInv) == 0:
+        return
+    message="""<html>
+            <body>
+            <h3 style="color:red;font-weight:bold;">Flipkart Competitive But No Inventory</h3>
+            <table border="1" style="width:100%;">
+            <thead>
+            <tr><th>Item Id</th>
+            <th>Product Name</th>
+            <th>SP</th>
+            <th>TP</th>
+            <th>Lowest Possible SP</th>
+            <th>Lowest Possible TP</th>
+            <th>Lowest Seller</th>
+            <th>Lowest Seller SP</th>
+            <th>Margin</th>
+            <th>Margin %</th>
+            <th>Commission %</th>
+            <th>Return Provision %</th>
+            <th>Flipkart Inventory</th>
+            <th>Total Inventory</th>
+            <th>Sales History</th>
+            </tr></thead>
+            <tbody>"""
+    for item in competitiveNoInv:
+        mpHistory = item[0]
+        catItem = item[1]
+        netInventory=''
+        if not inventoryMap.has_key(mpHistory.item_id):
+            netInventory='Info Not Available'
+        else:
+            netInventory = str(getNetAvailability(inventoryMap.get(mpHistory.item_id)))
+        mpItem = MarketplaceItems.get_by(itemId=mpHistory.item_id,source=OrderSource.FLIPKART)
+        message+="""<tr>
+            <td style="text-align:center">"""+str(mpHistory.item_id)+"""</td>
+            <td style="text-align:center">"""+xstr(catItem.brand)+" "+xstr(catItem.model_name)+" "+xstr(catItem.model_number)+" "+xstr(catItem.color)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.ourSellingPrice)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.ourTp)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.lowestPossibleSp)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.lowestPossibleTp)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.lowestSellerName)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.lowestSellingPrice)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.margin)+"""</td>
+            <td style="text-align:center">"""+str(round((mpHistory.margin/mpHistory.ourSellingPrice)*100,1))+" %"+"""</td>
+            <td style="text-align:center">"""+str(mpItem.commission)+"""</td>
+            <td style="text-align:center">"""+str(mpItem.returnProvision)+" %"+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.ourInventory)+"""</td>
+            <td style="text-align:center">"""+netInventory+"""</td>
+            <td style="text-align:center">"""+getOosString((itemSaleMap.get(mpHistory.item_id))[1])+"""</td>
+            </tr>"""
+    message+="""</tbody></table></body></html>"""
+    print message
+    mailServer = smtplib.SMTP("smtp.gmail.com", 587)
+    mailServer.ehlo()
+    mailServer.starttls()
+    mailServer.ehlo()
+    #recipients = ['kshitij.sood@saholic.com']
+    recipients = ['rajneesh.arora@saholic.com','anikendra.das@saholic.com','vikram.raghav@saholic.com','kshitij.sood@saholic.com','khushal.bhatia@saholic.com','chaitnaya.vats@saholic.com','chandan.kumar@saholic.com','manoj.kumar@saholic.com','yukti.jain@saholic.com','ankush.dhingra@saholic.com','manoj.pal@saholic.com']
+    msg = MIMEMultipart()
+    msg['Subject'] = "Flipkart Competitive But No Inventory" + ' - ' + str(datetime.now())
+    msg['From'] = ""
+    msg['To'] = ",".join(recipients)
+    msg.preamble = "Flipkart Competitive But No Inventory" + ' - ' + str(datetime.now())
+    html_msg = MIMEText(message, 'html')
+    msg.attach(html_msg)
+    try:
+        mailServer.login("build@shop2020.in", "cafe@nes")
+        #mailServer.sendmail("cafe@nes", ['kshitij.sood@saholic.com'], msg.as_string())
+        mailServer.sendmail("cafe@nes", recipients, msg.as_string())
+    except Exception as e:
+        print e
+        print "Unable to send Flipkart Competitive But No Inventory mail.Lets try local SMTP"
+        smtpServer = smtplib.SMTP('localhost')
+        smtpServer.set_debuglevel(1)
+        sender = 'build@shop2020.in'
+        try:
+            smtpServer.sendmail(sender, recipients, msg.as_string())
+            print "Successfully sent email"
+        except:
+            print "Error: unable to send email."
+def sendAlertForInactiveAutoPricing(timestamp):
+    xstr = lambda s: s or ""
+    inactiveAutoPricing = session.query(MarketPlaceHistory,Item,MarketplaceItems).join((Item,MarketPlaceHistory.item_id==Item.id)).join((MarketplaceItems,MarketPlaceHistory.item_id==MarketplaceItems.itemId)).filter(MarketplaceItems.source==OrderSource.FLIPKART).filter(MarketPlaceHistory.timestamp==timestamp).filter(MarketPlaceHistory.source==OrderSource.FLIPKART).filter(or_(MarketplaceItems.autoDecrement==0,MarketplaceItems.autoIncrement==0)).filter(MarketPlaceHistory.competitiveCategory.in_([CompetitionCategory.BUY_BOX,CompetitionCategory.COMPETITIVE,CompetitionCategory.PREF_BUT_NOT_CHEAP])).all()
+    if len(inactiveAutoPricing) == 0:
+        return
+    message="""<html>
+            <body>
+            <h3 style="color:red;font-weight:bold;">Flipkart Competitive But No Inventory</h3>
+            <table border="1" style="width:100%;">
+            <thead>
+            <tr><th>Item Id</th>
+            <th>Product Name</th>
+            <th>Selling Price</th>
+            <th>Competitive Category</th>
+            <th>Margin</th>
+            <th>Margin %</th>
+            <th>Commission %</th>
+            <th>Return Provision %</th>
+            <th>Flipkart Inventory</th>
+            <th>Total Inventory</th>
+            <th>Sales History</th>
+            </tr></thead>
+            <tbody>"""
+    for item in inactiveAutoPricing:
+        mpHistory = item[0]
+        catItem = item[1]
+        mpItem = item[2]
+        netInventory=''
+        if not inventoryMap.has_key(mpHistory.item_id):
+            netInventory='Info Not Available'
+        else:
+            netInventory = str(getNetAvailability(inventoryMap.get(mpHistory.item_id)))
+        mpItem = MarketplaceItems.get_by(itemId=mpHistory.item_id,source=OrderSource.FLIPKART)
+        message+="""<tr>
+            <td style="text-align:center">"""+str(mpHistory.item_id)+"""</td>
+            <td style="text-align:center">"""+xstr(catItem.brand)+" "+xstr(catItem.model_name)+" "+xstr(catItem.model_number)+" "+xstr(catItem.color)+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.ourSellingPrice)+"""</td>
+            <td style="text-align:center">"""+str(CompetitionCategory._VALUES_TO_NAMES.get(mpHistory.competitiveCategory))+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.margin)+"""</td>
+            <td style="text-align:center">"""+str(round((mpHistory.margin/mpHistory.ourSellingPrice)*100,1))+" %"+"""</td>
+            <td style="text-align:center">"""+str(mpItem.commission)+"""</td>
+            <td style="text-align:center">"""+str(mpItem.returnProvision)+" %"+"""</td>
+            <td style="text-align:center">"""+str(mpHistory.ourInventory)+"""</td>
+            <td style="text-align:center">"""+netInventory+"""</td>
+            <td style="text-align:center">"""+getOosString((itemSaleMap.get(mpHistory.item_id))[1])+"""</td>
+            </tr>"""
+    message+="""</tbody></table></body></html>"""
+    print message
+    mailServer = smtplib.SMTP("smtp.gmail.com", 587)
+    mailServer.ehlo()
+    mailServer.starttls()
+    mailServer.ehlo()
+    #recipients = ['kshitij.sood@saholic.com']
+    recipients = ['rajneesh.arora@saholic.com','anikendra.das@saholic.com','vikram.raghav@saholic.com','kshitij.sood@saholic.com','khushal.bhatia@saholic.com','chaitnaya.vats@saholic.com','chandan.kumar@saholic.com','manoj.kumar@saholic.com','yukti.jain@saholic.com','ankush.dhingra@saholic.com','manoj.pal@saholic.com']
+    msg = MIMEMultipart()
+    msg['Subject'] = "Flipkart Auto Pricing Inactive" + ' - ' + str(datetime.now())
+    msg['From'] = ""
+    msg['To'] = ",".join(recipients)
+    msg.preamble = "Flipkart Auto Pricing Inactive" + ' - ' + str(datetime.now())
+    html_msg = MIMEText(message, 'html')
+    msg.attach(html_msg)
+    try:
+        mailServer.login("build@shop2020.in", "cafe@nes")
+        #mailServer.sendmail("cafe@nes", ['kshitij.sood@saholic.com'], msg.as_string())
+        mailServer.sendmail("cafe@nes", recipients, msg.as_string())
+    except Exception as e:
+        print e
+        print "Unable to send Flipkart Auto Pricing Inactive mail.Lets try local SMTP"
+        smtpServer = smtplib.SMTP('localhost')
+        smtpServer.set_debuglevel(1)
+        sender = 'build@shop2020.in'
+        try:
+            smtpServer.sendmail(sender, recipients, msg.as_string())
+            print "Successfully sent email"
+        except:
+            print "Error: unable to send email."
 def main():
     parser = optparse.OptionParser()
         processLostBuyBoxItems(previousProcessingTimestamp[0],timestamp)
     if options.runType=='FULL':
         cheapButNotPrefAlert(timestamp)
         sendPricingMismatch(timestamp)
         sendAlertForNegativeMargins(timestamp)
+        sendAlertForCompetitiveNoInventory(timestamp)
+        sendAlertForInactiveAutoPricing(timestamp)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/catalog/script/FlipkartHistoryPopulator.py – Rev 12237 → 12317