WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/scripts/DealRecomendation.py

 now = datetime.now()
 class __SkuInfo:
     def __init__(self, _id, skuBundleId, category_id, mrp, available_price, source_id, rank, maxNlc, minNlc, schemeAmount, minDiscount, \
-                 maxDiscount, discountType, dp, nlcPoints, bestSellerPoints, totalPoints):
+                 maxDiscount, discountType, dp, nlcPoints, bestSellerPoints, totalPoints, status, in_stock, maxprice):
         self._id = _id
         self.skuBundleId = skuBundleId
         self.category_id = category_id
         self.mrp = mrp
         self.available_price = available_price
         self.maxDiscount = maxDiscount
         self.discountType = discountType
         self.dp = dp
         self.nlcPoints = nlcPoints
         self.bestSellerPoints = bestSellerPoints
         self.totalPoints = totalPoints
+        self.status = status
+        self.in_stock = in_stock
+        self.maxprice = maxprice
 def get_mongo_connection(host='localhost', port=27017):
     global con
     if con is None:
         if len((topSkus)) == 0:
             break
         #topSkus = collection.find( {'_id':664})
         for sku in topSkus:
             info = __SkuInfo(sku['_id'], sku['skuBundleId'], sku['category_id'], sku['mrp'], sku['available_price'], sku['source_id'], sku['rank'], None, None, 0.0, None, \
-                             None, None, None, None, None, None)
+                             None, None, None, None, None, None, sku['status'], sku['in_stock'],None)
             exceptionalNlc = list(get_mongo_connection().Catalog.ExceptionalNlc.find( {"$and" : [ {'sku':info._id}, {'overrideNlc':1} ]} ))
             if len(exceptionalNlc) > 0:
                 """Exceptional nlc found, no need to calculate max and min R-nlc"""
                 info.maxNlc = exceptionalNlc[0]['maxNlc']
                 info.minNlc = exceptionalNlc[0]['minNlc']
+                info.maxprice = exceptionalNlc[0]['maxNlc']
                 LATEST_UPDATED_ITEMS.append(info)
                 continue
             skuSchemeDetails = list(get_mongo_connection().Catalog.SkuSchemeDetails.find( {'sku':info._id}).sort([('addedOn',pymongo.DESCENDING)]).limit(1))
             if len(skuSchemeDetails) > 0:
                 """Sku scheme details, populate scheme amount (Recently added)"""
+                #TODO Add start date and end date of scehems
                 info.schemeAmount = float(skuSchemeDetails[0]['schemeAmount'])
             skuDealerPrices = list(get_mongo_connection().Catalog.SkuDealerPrices.find( {'sku':info._id} ) )
             if len(skuDealerPrices) > 0:
                 info.dp = skuDealerPrices[0]['dp']
                 info.minDiscount = skuDiscount[0]['min_discount']
                 info.discountType = DISCOUNT_TYPE.get(skuDiscount[0]['discountType'].upper())
                 LATEST_UPDATED_ITEMS.append(info)
                 continue
-            categoryDiscount = list(get_mongo_connection().Dtr.CategoryDiscount.find( {"$and" : [{'brand':sku['brand'].upper()}, {'category_id':sku['category_id']} ]} ))
+            categoryDiscount = list(get_mongo_connection().Catalog.CategoryDiscount.find( {"$and" : [{'brand':sku['brand'].upper()}, {'category_id':sku['category_id']} ]} ))
             if len(categoryDiscount) > 0:
                 info.maxDiscount = categoryDiscount[0]['max_discount']
                 info.minDiscount = categoryDiscount[0]['min_discount']
                 info.discountType = DISCOUNT_TYPE.get(categoryDiscount[0]['discountType'].upper())
                     if identifier is not None:
                         it = Item.query.filter_by(catalog_item_id=identifier).first()
                         obj.mrp = it.mrp
                 if obj.mrp > 0:
                     obj.minNlc = obj.mrp - (obj.mrp * obj.maxDiscount/100) - obj.schemeAmount
                     obj.maxNlc = obj.mrp - (obj.mrp * obj.minDiscount/100) - obj.schemeAmount
+                    obj.maxPrice = obj.maxNlc
             elif obj.discountType == DISCOUNT_TYPE.get('DP'):
                 if obj.dp == 0:
                     """Now dp is zero, so we have to use saholic minimum dp for item"""
                     if identifier is not None:
                         it = Item.query.filter_by(catalog_item_id=identifier).first()
                             obj.dp = min_dp
                         except:
                             pass
                 if obj.dp > 0:
                     obj.minNlc = obj.dp - (obj.dp * obj.maxDiscount/100) - obj.schemeAmount
                     obj.maxNlc = obj.dp - (obj.dp * obj.minDiscount/100) - obj.schemeAmount
+                    obj.maxprice = obj.maxNlc
             else:
                 """No rule found, use saholic min nlc as max and min R-Nlc"""
                 if identifier is not None:
                     it = Item.query.filter_by(catalog_item_id=identifier).first()
                     try:
                         vendorPricing = inventory_client.getAllItemPricing(it.id)
                         min_nlc = min(pricing.nlc for pricing in vendorPricing)
                         obj.maxNlc = min_nlc
                         obj.minNlc = min_nlc
+                        obj.maxprice = obj.maxNlc
                     except:
                         pass
         populated = populated + 300
         time.sleep(10)
 def calculateNlcPoints():
     global LATEST_UPDATED_ITEMS
     for sku in LATEST_UPDATED_ITEMS:
         if sku.maxNlc and sku.minNlc:
+            """Create map - TODO"""
+            if sku.status == 2:
+                eolWeight = .60
+            else:
+                eolWeight = 1.0
+            if sku.category_id == 3:
+                basePointPercentage = 5.0
+                maxNlcPoints = 200
+            elif sku.category_id == 5:
+                basePointPercentage = 8.0
+                maxNlcPoints = 150
+            else:
+                basePointPercentage = 10.0
+                maxNlcPoints = 150
             discFromMinNlc = (sku.minNlc - sku.available_price)/sku.available_price *100
             discFromMaxNlc = (sku.maxNlc - sku.available_price)/sku.available_price *100
             if discFromMinNlc > 0:
-                nlcPoints = 100/5 * discFromMinNlc
+                nlcPoints = 100/basePointPercentage * discFromMinNlc
             elif discFromMinNlc < 0 and discFromMaxNlc > 0:
                 nlcPoints = 0
             else:
-                nlcPoints = 100/5 * discFromMinNlc
+                nlcPoints = 100/basePointPercentage * discFromMinNlc
+            if (min(nlcPoints,maxNlcPoints)) > 0:
+                sku.nlcPoints = (min(nlcPoints,maxNlcPoints)) * eolWeight
+            else:
-            sku.nlcPoints = min(nlcPoints,300)
+                sku.nlcPoints = (min(nlcPoints,maxNlcPoints))
         else:
             sku.nlcPoints = 0
 def commitData():
     global LATEST_UPDATED_ITEMS
 def addBestSellerPoints():
     allItems = list(get_mongo_connection().Catalog.Deals.find({}))
     for sku in allItems:
+        print sku['_id']
+        print sku['category_id']
+        print sku['source_id']
+        print sku['rank']
+        print sku['nlcPoints']
+        print "================="
-        bestSellerPoints = list(get_mongo_connection().Catalog.BestSellerPoints.find( {"$and":[{'min_rank': { "$lte": sku['rank'] } }, {'max_rank': { "$gte": sku['rank'] } } , { 'category_id' : sku['category_id'] }] } ))
+        bestSellerPoints = list(get_mongo_connection().Catalog.BestSellerPoints.find( {"$and":[{'min_rank': { "$lte": sku['rank'] } }, {'max_rank': { "$gte": sku['rank'] } } , { 'category_id' : sku['category_id'] }, { 'source_id' : sku['source_id'] }] } ))
+        print len(bestSellerPoints)
         if len(bestSellerPoints) > 0:
+            print bestSellerPoints[0]['points']
+            if (bestSellerPoints[0]['points']) > 0:
+                sku['bestSellerPoints'] = (bestSellerPoints[0]['points']) * bestSellerPoints[0]['weightage']
+            else:
-            sku['bestSellerPoints'] = bestSellerPoints[0]['points']
+                sku['bestSellerPoints'] = (bestSellerPoints[0]['points'])
         else:
-            sku['bestSellerPoints'] = -50
+            sku['bestSellerPoints'] = -100
+        print sku['bestSellerPoints']
         sku['totalPoints'] = sku['bestSellerPoints'] + sku['nlcPoints']
         get_mongo_connection().Catalog.Deals.update({'_id':sku['_id']},{'$set':{'bestSellerPoints':sku['bestSellerPoints'],'totalPoints':sku['totalPoints']}},multi=False)
 def main():

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/scripts/DealRecomendation.py – Rev 13755 → 13824