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

 import math
 import simplejson as json
 import xlwt
 import optparse
 import sys
+import smtplib
+from email import encoders
+from email.mime.text import MIMEText
+from email.mime.base import MIMEBase
+from email.mime.multipart import MIMEMultipart
 config_client = ConfigClient()
 host = config_client.get_property('staging_hostname')
 DataService.initialize(db_hostname=host)
 import logging
         self.ourSp = ourSp
         self.secondLowestSellerTp = secondLowestSellerTp
         self.lowestPossibleSp = lowestPossibleSp
 def fetchItemsForAutoDecrease(time):
+    successfulAutoDecrease = []
     autoDecrementItems = session.query(MarketPlaceHistory).join((MarketplaceItems,MarketPlaceHistory.item_id==MarketplaceItems.itemId))\
     .filter(MarketPlaceHistory.timestamp==time).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.COMPETITIVE)\
     .filter(MarketplaceItems.source==OrderSource.SNAPDEAL).filter(MarketplaceItems.autoDecrement==True).all()
     #autoDecrementItems = MarketplaceItems.query.filter(MarketplaceItems.autoDecrement==True).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
     inventory_client = InventoryClient().get_client()
         autoDecrementItem.competitorEnoughStock = True
         autoDecrementItem.ourEnoughStock = True
         #autoDecrementItem.avgSales = avgSalePerDay
         autoDecrementItem.decision = Decision.AUTO_DECREMENT_SUCCESS
         autoDecrementItem.reason = 'All conditions for auto decrement true'
+        successfulAutoDecrease.append(autoDecrementItem)
         lgr.info("Auto decrement success for itemId "+str(autoDecrementItem.item_id)+" Days of stock "+str(daysOfStock)+" avg sales "+str(avgSalePerDay))
     session.commit()
+    return successfulAutoDecrease
 def fetchItemsForAutoIncrease(time):
+    successfulAutoIncrease = []
     autoIncrementItems = session.query(MarketPlaceHistory).join((MarketplaceItems,MarketPlaceHistory.item_id==MarketplaceItems.itemId))\
     .filter(MarketPlaceHistory.timestamp==time).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX)\
     .filter(MarketplaceItems.source==OrderSource.SNAPDEAL).filter(MarketplaceItems.autoIncrement==True).all()
     #autoIncrementItems = MarketplaceItems.query.filter(MarketplaceItems.autoIncrement==True).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
     #inventory_client = InventoryClient().get_client()
         autoIncrementItem.ourEnoughStock = False
         #autoIncrementItem.avgSales = avgSalePerDay
         autoIncrementItem.decision = Decision.AUTO_INCREMENT_SUCCESS
         autoIncrementItem.reason = 'All conditions for auto increment true'
+        successfulAutoIncrease.append(autoIncrementItem)
         lgr.info("Auto increment success for itemId "+str(autoIncrementItem.item_id)+" Days of stock "+str(daysOfStock)+" avg sales "+str(avgSalePerDay))
     session.commit()
+    return successfulAutoIncrease
 def calculateAverageSale(oosStatus):
     count,sale = 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)
-    return avgSalePerDay
+    return round(avgSalePerDay,2)
 def getNetAvailability(itemInventory):
     totalAvailability, totalReserved = 0,0
     availableMap  = itemInventory.availability
     reserveMap = itemInventory.reserved
     for obj in oosStatus:
         if obj.is_oos:
             lastNdaySale += "X-"
         else:
             lastNdaySale += str(obj.num_orders) + "-"
-    return lastNdaySale
+    return lastNdaySale[:-1]
 def markAutoFavourite():
     previouslyAutoFav = []
     nowAutoFav = []
     marketplaceItems = session.query(MarketplaceItems).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
     fromDate = datetime.now()-timedelta(days = 3, hours=datetime.now().hour, minutes=datetime.now().minute, seconds=datetime.now().second)
     toDate = datetime.now()-timedelta(days = 0, hours=datetime.now().hour, minutes=datetime.now().minute, seconds=datetime.now().second)
-    items = session.query(MarketPlaceHistory.item_id,func.max(MarketPlaceHistory.timestamp)).group_by(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.run==RunType.FULL).filter(MarketPlaceHistory.timestamp.between (fromDate,toDate)).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
+    items = session.query(MarketPlaceHistory.item_id,func.max(MarketPlaceHistory.timestamp)).group_by(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.timestamp.between (fromDate,toDate)).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
     toUpdate = [key for key, value in itemSaleMap.items() if value[3] >= 3]
     buyBoxLast3days = []
     for item in items:
         buyBoxLast3days.append(item[0])
     for marketplaceItem in marketplaceItems:
             target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
         else:
             proposed_tp  = snapdealPricing.lowestTp - max(10, snapdealPricing.lowestTp*0.001)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
             target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-        sheet.write(sheet_iterator, 26, proposed_tp)
+        sheet.write(sheet_iterator, 26, round(proposed_tp,2))
-        sheet.write(sheet_iterator, 27, proposed_sp)
+        sheet.write(sheet_iterator, 27, round(proposed_sp,2))
-        sheet.write(sheet_iterator, 28, target_nlc)
+        sheet.write(sheet_iterator, 28, round(target_nlc,2))
         sheet.write(sheet_iterator, 29, getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
         sheet_iterator+=1
     sheet = wbk.add_sheet('Lowest')
             #target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
         else:
             proposed_tp  = max(snapdealPricing.secondLowestSellerTp - max((20, snapdealPricing.secondLowestSellerTp*0.002)), snapdealPricing.lowestPossibleTp)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
             #target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-        sheet.write(sheet_iterator, 25, proposed_tp)
+        sheet.write(sheet_iterator, 25, round(proposed_tp,2))
-        sheet.write(sheet_iterator, 26, proposed_sp)
+        sheet.write(sheet_iterator, 26, round(proposed_sp,2))
-        sheet.write(sheet_iterator, 27, proposed_tp - snapdealPricing.ourTp)
+        sheet.write(sheet_iterator, 27, round((proposed_tp - snapdealPricing.ourTp),2))
         sheet_iterator+=1
     sheet = wbk.add_sheet('Can Compete-With Inventory')
     heading_xf = xlwt.easyxf('font: bold on; align: wrap off, vert centre, horiz center')
             proposed_sp = max(snapdealDetails.lowestSp - max((10, snapdealDetails.lowestSp*0.001)), snapdealPricing.lowestPossibleSp)
             proposed_tp = getTargetTp(proposed_sp,mpItem)
         else:
             proposed_tp  = max(snapdealPricing.lowestTp - max((10, snapdealPricing.lowestTp*0.001)), snapdealPricing.lowestPossibleTp)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
-        sheet.write(sheet_iterator, 26, proposed_tp)
+        sheet.write(sheet_iterator, 26, round(proposed_tp,2))
-        sheet.write(sheet_iterator, 27, proposed_sp)
+        sheet.write(sheet_iterator, 27, round(proposed_sp,2))
         sheet.write(sheet_iterator, 28, getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
         sheet_iterator+=1
     sheet = wbk.add_sheet('Negative Margin')
         else:
             sheet.write(sheet_iterator, 15, getNetAvailability(inventoryMap.get(snapdealItemInfo.item_id)))
         sheet.write(sheet_iterator, 16, getOosString((itemSaleMap.get(snapdealItemInfo.item_id))[1]))
         sheet.write(sheet_iterator, 17, (itemSaleMap.get(snapdealItemInfo.item_id))[3])
         sheet.write(sheet_iterator, 18, snapdealItemInfo.nlc)
-        sheet.write(sheet_iterator, 19, snapdealPricing.ourTp - snapdealPricing.lowestPossibleTp)
+        sheet.write(sheet_iterator, 19, round((snapdealPricing.ourTp - snapdealPricing.lowestPossibleTp),2))
         sheet_iterator+=1
     sheet = wbk.add_sheet('Exception Item List')
     heading_xf = xlwt.easyxf('font: bold on; align: wrap off, vert centre, horiz center')
                 target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
             else:
                 proposed_tp  = snapdealPricing.lowestTp - max(10, snapdealPricing.lowestTp*0.001)
                 proposed_sp = getTargetSp(proposed_tp,mpItem)
                 target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            sheet.write(sheet_iterator, 26, proposed_tp)
+            sheet.write(sheet_iterator, 26, round(proposed_tp,2))
-            sheet.write(sheet_iterator, 27, proposed_sp)
+            sheet.write(sheet_iterator, 27, round(proposed_sp,2))
-            sheet.write(sheet_iterator, 28, target_nlc)
+            sheet.write(sheet_iterator, 28, round(target_nlc,2))
             sheet.write(sheet_iterator, 29, getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
             sheet_iterator+=1
     sheet = wbk.add_sheet('Can Compete-No Inv On SD')
                 target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
             else:
                 proposed_tp  = snapdealPricing.lowestTp - max(10, snapdealPricing.lowestTp*0.001)
                 proposed_sp = getTargetSp(proposed_tp,mpItem)
                 target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            sheet.write(sheet_iterator, 26, proposed_tp)
+            sheet.write(sheet_iterator, 26, round(proposed_tp,2))
-            sheet.write(sheet_iterator, 27, proposed_sp)
+            sheet.write(sheet_iterator, 27, round(proposed_sp,2))
-            sheet.write(sheet_iterator, 28, target_nlc)
+            sheet.write(sheet_iterator, 28, round(target_nlc,2))
             sheet.write(sheet_iterator, 29, getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
             sheet_iterator+=1
     if (runType=='FULL'):
         sheet = wbk.add_sheet('Auto Favorites')
     sheet.write(0, 0, "Item ID", heading_xf)
     sheet.write(0, 1, "Brand", heading_xf)
     sheet.write(0, 2, "Product Name", heading_xf)
     sheet.write(0, 3, "Decision", heading_xf)
     sheet.write(0, 4, "Reason", heading_xf)
+    sheet.write(0, 5, "Old Selling Price", heading_xf)
-    sheet.write(0, 5, "Selling Price Updated",heading_xf)
+    sheet.write(0, 6, "Selling Price Updated",heading_xf)
     sheet_iterator=1
     for autoPricingItem in autoPricingItems:
         mpHistory = autoPricingItem[0]
         item = autoPricingItem[1]
+        it = Item.query.filter_by(id=item.id).one()
         sheet.write(sheet_iterator, 0, item.id)
         sheet.write(sheet_iterator, 1, it.brand)
         sheet.write(sheet_iterator, 2, xstr(it.brand)+" "+xstr(it.model_name)+" "+xstr(it.model_number)+" "+xstr(it.color))
         sheet.write(sheet_iterator, 3, Decision._VALUES_TO_NAMES.get(mpHistory.decision))
         sheet.write(sheet_iterator, 4, mpHistory.reason)
         if Decision._VALUES_TO_NAMES.get(mpHistory.decision) == "AUTO_DECREMENT_SUCCESS":
+            sheet.write(sheet_iterator, 5, mpHistory.ourSellingPrice)
-            sheet.write(sheet_iterator, 5, math.ceil(mpHistory.proposedSellingPrice))
+            sheet.write(sheet_iterator, 6, math.ceil(mpHistory.proposedSellingPrice))
         if Decision._VALUES_TO_NAMES.get(mpHistory.decision) == "AUTO_INCREMENT_SUCCESS":
+            sheet.write(sheet_iterator, 5, mpHistory.ourSellingPrice)
-            sheet.write(sheet_iterator, 5, math.ceil(mpHistory.ourSellingPrice+max(10,.01*mpHistory.ourSellingPrice)))
+            sheet.write(sheet_iterator, 6, math.ceil(mpHistory.ourSellingPrice+max(10,.01*mpHistory.ourSellingPrice)))
         sheet_iterator+=1
     filename = "/tmp/snapdeal-report-"+runType+" " + str(timestamp) + ".xls"
     wbk.save(filename)
-    EmailAttachmentSender.mail("build@shop2020.in", "cafe@nes", ["kshitij.sood@saholic.com"], " Snapdeal Auto Pricing " + str(timestamp), "", [get_attachment_part(filename)], ["kshitij.sood@saholic.com"], [])
+    EmailAttachmentSender.mail("build@shop2020.in", "cafe@nes", ["rajneesh.arora@saholic.com","rajveer.singh@saholic.com","kshitij.sood@saholic.com"], " Snapdeal Auto Pricing " + str(timestamp), "", [get_attachment_part(filename)], [""], [])
+def sendAutoPricingMail(successfulAutoDecrease,successfulAutoIncrease):
+    xstr = lambda s: s or ""
+    message="""<html>
+            <body>
+            <h4>Auto Decrease Items</h4>
+            <table border="1">
+            <thead>
+            <tr><th>Item Id</th>
+            <th>Product Name</th>
+            <th>Old Price</th>
+            <th>New Price</th>
+            </tr></thead>
+            <tbody>"""
+    for item in successfulAutoDecrease:
+        it = Item.query.filter_by(id=item.item_id).one()
+        message+="""<tr>
+                <td style="text-align:center">"""+str(item.item_id)+"""</td>
+                <td style="text-align:center">"""+xstr(it.brand)+" "+xstr(it.model_name)+" "+xstr(it.model_number)+" "+xstr(it.color)+"""</td>
+                <td style="text-align:center">"""+str(item.ourSellingPrice)+"""</td>
+                <td style="text-align:center">"""+str(item.proposedSellingPrice)+"""</td></tr>"""
+    message+="""</tbody></table><h4>Auto Increase Items</h4><table border="1" style="width: 40%;">
+            <thead>
+            <tr><th>Item Id</th>
+            <th>Product Name</th>
+            <th>Old Price</th>
+            <th>New Price</th>
+            </tr></thead>
+            <tbody>"""
+    for item in successfulAutoIncrease:
+        it = Item.query.filter_by(id=item.item_id).one()
+        message+="""<tr>
+                <td style="text-align:center">"""+str(item.item_id)+"""</td>
+                <td style="text-align:center">"""+xstr(it.brand)+" "+xstr(it.model_name)+" "+xstr(it.model_number)+" "+xstr(it.color)+"""</td>
+                <td style="text-align:center">"""+str(item.ourSellingPrice)+"""</td>
+                <td style="text-align:center">"""+str(item.proposedSellingPrice)+"""</td></tr>"""
+    message+="""</tbody></table></body></html>"""
+    print message
+    mailServer = smtplib.SMTP("smtp.gmail.com", 587)
+    mailServer.ehlo()
+    mailServer.starttls()
+    mailServer.ehlo()
+    # Create the container (outer) email message.
+    msg = MIMEMultipart()
+    msg['Subject'] = "Snapdeal Auto Pricing" + ' - ' + str(datetime.now())
+    msg['From'] = ""
+    msg['To'] = 'sku-recipients@saholic.com'
+    msg.preamble = "Snapdeal Auto Pricing" + ' - ' + str(datetime.now())
+    html_msg = MIMEText(message, 'html')
+    msg.attach(html_msg)
+    mailServer.login("build@shop2020.in", "cafe@nes")
+    mailServer.sendmail("cafe@nes", ['rajneesh.arora@saholic.com','rajveer.singh@saholic.com','kshitij.sood@saholic.com'], msg.as_string())
 def commitExceptionList(exceptionList,timestamp):
     exceptionItems=[]
     for item in exceptionList:
         mpHistory = MarketPlaceHistory()
         mpHistory.ourTp = snapdealPricing.ourTp
         mpHistory.ourNlc = snapdealItemInfo.nlc
         if (snapdealPricing.competitionBasis=='SP'):
             proposed_sp = max(snapdealDetails.lowestSp - max((10, snapdealDetails.lowestSp*0.001)), snapdealPricing.lowestPossibleSp)
             proposed_tp = getTargetTp(proposed_sp,mpItem)
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
         else:
             proposed_tp  = max(snapdealPricing.lowestTp - max((10, snapdealPricing.lowestTp*0.001)), snapdealPricing.lowestPossibleTp)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
         mpHistory.margin = mpHistory.ourTp - mpHistory.lowestPossibleTp
         mpHistory.totalSeller = snapdealDetails.totalSeller
         mpHistory.avgSales = (itemSaleMap.get(snapdealItemInfo.item_id))[2]
         mpHistory.salesPotential = SalesPotential._NAMES_TO_VALUES.get(getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
         mpHistory.timestamp = timestamp
         mpHistory.ourTp = snapdealPricing.ourTp
         mpHistory.ourNlc = snapdealItemInfo.nlc
         if (snapdealPricing.competitionBasis=='SP'):
             proposed_sp = max(snapdealDetails.lowestSp - max((10, snapdealDetails.lowestSp*0.001)), snapdealPricing.lowestPossibleSp)
             proposed_tp = getTargetTp(proposed_sp,mpItem)
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
         else:
             proposed_tp  = max(snapdealPricing.lowestTp - max((10, snapdealPricing.lowestTp*0.001)), snapdealPricing.lowestPossibleTp)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
         mpHistory.margin = mpHistory.ourTp - mpHistory.lowestPossibleTp
         mpHistory.totalSeller = snapdealDetails.totalSeller
         mpHistory.avgSales = (itemSaleMap.get(snapdealItemInfo.item_id))[2]
         mpHistory.salesPotential = SalesPotential._NAMES_TO_VALUES.get(getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
         mpHistory.timestamp = timestamp
         mpHistory.ourNlc = snapdealItemInfo.nlc
         if (snapdealPricing.competitionBasis=='SP'):
             proposed_sp = snapdealDetails.lowestSp - max(10, snapdealDetails.lowestSp*0.001)
             proposed_tp = getTargetTp(proposed_sp,mpItem)
             target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
-            mpHistory.targetNlc = target_nlc
+            mpHistory.targetNlc = round(target_nlc,2)
         else:
             proposed_tp  = snapdealPricing.lowestTp - max(10, snapdealPricing.lowestTp*0.001)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
             target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
-            mpHistory.targetNlc = target_nlc
+            mpHistory.targetNlc = round(target_nlc,2)
         mpHistory.margin = mpHistory.ourTp - mpHistory.lowestPossibleTp
         mpHistory.totalSeller = snapdealDetails.totalSeller
         mpHistory.avgSales = (itemSaleMap.get(snapdealItemInfo.item_id))[2]
         mpHistory.salesPotential = SalesPotential._NAMES_TO_VALUES.get(getSalesPotential(snapdealDetails.lowestOfferPrice,snapdealItemInfo.nlc))
         mpHistory.timestamp = timestamp
         mpHistory.secondLowestTp = snapdealPricing.secondLowestSellerTp
         if (snapdealPricing.competitionBasis=='SP'):
             proposed_sp = max(snapdealDetails.secondLowestSellerSp - max((20, snapdealDetails.secondLowestSellerSp*0.002)), snapdealPricing.lowestPossibleSp)
             proposed_tp = getTargetTp(proposed_sp,mpItem)
             #target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
             #mpHistory.targetNlc = target_nlc
         else:
             proposed_tp  = max(snapdealPricing.secondLowestSellerTp - max((20, snapdealPricing.secondLowestSellerTp*0.002)), snapdealPricing.lowestPossibleTp)
             proposed_sp = getTargetSp(proposed_tp,mpItem)
             #target_nlc = proposed_tp - snapdealPricing.lowestPossibleTp + snapdealItemInfo.nlc
-            mpHistory.proposedSellingPrice = proposed_sp
+            mpHistory.proposedSellingPrice = round(proposed_sp,2)
-            mpHistory.proposedTp = proposed_tp
+            mpHistory.proposedTp = round(proposed_tp,2)
             #mpHistory.targetNlc = target_nlc
         mpHistory.margin = mpHistory.ourTp - mpHistory.lowestPossibleTp
         mpHistory.marginIncreasedPotential = proposed_tp - snapdealPricing.ourTp
         mpHistory.totalSeller = snapdealDetails.totalSeller
         mpHistory.avgSales = (itemSaleMap.get(snapdealItemInfo.item_id))[2]
     if val.parent_category==10011:
         commissionPercentage = spm.competitorCommissionAccessory
     else:
         commissionPercentage = spm.competitorCommissionOther
     if snapdealDetails.rank==1:
-        return snapdealDetails.secondLowestSellerSp- snapdealDetails.secondLowestSellerSp*(commissionPercentage/100+spm.emiFee/100)*(1+(spm.serviceTax/100))-(val.courierCost+spm.closingFee)*(1+(spm.serviceTax/100));
+        otherTp = snapdealDetails.secondLowestSellerSp- snapdealDetails.secondLowestSellerSp*(commissionPercentage/100+spm.emiFee/100)*(1+(spm.serviceTax/100))-(val.courierCost+spm.closingFee)*(1+(spm.serviceTax/100));
+        return round(otherTp,2)
-    return snapdealDetails.lowestSp- snapdealDetails.lowestSp*(commissionPercentage/100+spm.emiFee/100)*(1+(spm.serviceTax/100))-(val.courierCost+spm.closingFee)*(1+(spm.serviceTax/100));
+    otherTp = snapdealDetails.lowestSp- snapdealDetails.lowestSp*(commissionPercentage/100+spm.emiFee/100)*(1+(spm.serviceTax/100))-(val.courierCost+spm.closingFee)*(1+(spm.serviceTax/100));
+    return round(otherTp,2)
 def getLowestPossibleTp(snapdealDetails,val,spm,mpItem):
     if snapdealDetails.rank==0:
         return mpItem.minimumPossibleTp
     vat = (snapdealDetails.ourSp/(1+(val.vatRate/100))-(val.nlc/(1+(val.vatRate/100))))*(val.vatRate/100);
     inHouseCost = 15+vat+(mpItem.returnProvision/100)*snapdealDetails.ourSp+mpItem.otherCost;
     lowest_possible_tp = val.nlc+inHouseCost;
-    return lowest_possible_tp
+    return round(lowest_possible_tp,2)
 def getOurTp(snapdealDetails,val,spm,mpItem):
     if snapdealDetails.rank==0:
         return mpItem.currentTp
-    return snapdealDetails.ourSp- snapdealDetails.ourSp*(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))-(val.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100));
+    ourTp = snapdealDetails.ourSp- snapdealDetails.ourSp*(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))-(val.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100));
+    return round(ourTp,2)
 def getLowestPossibleSp(snapdealDetails,val,spm,mpItem):
     if snapdealDetails.rank==0:
         return mpItem.minimumPossibleSp
+    lowestPossibleSp = (val.nlc+(val.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100))*(1+(val.vatRate/100))+(15+mpItem.otherCost)*(1+(val.vatRate)/100))/(1-(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))*(1+(val.vatRate)/100)-(mpItem.returnProvision/100)*(1+(val.vatRate)/100));
-    return (val.nlc+(val.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100))*(1+(val.vatRate/100))+(15+mpItem.otherCost)*(1+(val.vatRate)/100))/(1-(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))*(1+(val.vatRate)/100)-(mpItem.returnProvision/100)*(1+(val.vatRate)/100));
+    return round(lowestPossibleSp,2)
 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));
+    targetTp = targetSp- targetSp*(mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))-(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100));
+    return round(targetTp,2)
 def getTargetSp(targetTp,mpItem):
-    return float(targetTp+(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100)))/(1-((mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))))
+    targetSp = float(targetTp+(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100)))/(1-((mpItem.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))))
+    return round(targetSp,2)
 def getSalesPotential(lowestOfferPrice,ourNlc):
     if lowestOfferPrice - ourNlc < 0:
         return 'HIGH'
     elif (float(lowestOfferPrice - ourNlc))/lowestOfferPrice >=0 and (float(lowestOfferPrice - ourNlc))/lowestOfferPrice <=.02:
     cantComepeteItems = commitCantCompete(cantCompete,timestamp)
     buyBoxList = commitBuyBox(buyBoxItems,timestamp)
     competitiveItems = commitCompetitive(competitive,timestamp)
     competitiveNoInventoryItems = commitCompetitiveNoInventory(competitiveNoInventory,timestamp)
     negativeMarginItems = commitNegativeMargin(negativeMargin,timestamp)
-    fetchItemsForAutoDecrease(timestamp)
+    successfulAutoDecrease = fetchItemsForAutoDecrease(timestamp)
-    fetchItemsForAutoIncrease(timestamp)
+    successfulAutoIncrease = fetchItemsForAutoIncrease(timestamp)
     if options.runType=='FULL':
         previousAutoFav, nowAutoFav = markAutoFavourite()
+    if options.runType=='FULL':
-    writeReport(cantCompete, buyBoxItems, competitive, competitiveNoInventory, exceptionList, negativeMargin, previousAutoFav, nowAutoFav,timestamp, options.runType)
+        writeReport(cantCompete, buyBoxItems, competitive, competitiveNoInventory, exceptionList, negativeMargin, previousAutoFav, nowAutoFav,timestamp, options.runType)
+    else:
+        writeReport(cantCompete, buyBoxItems, competitive, competitiveNoInventory, exceptionList, negativeMargin, None, None, timestamp, options.runType)
+    sendAutoPricingMail(successfulAutoDecrease,successfulAutoIncrease)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

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