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

 from dtr.utils.utils import to_java_date
 from datetime import datetime, timedelta
 import time
 import optparse
 from dtr.storage.MemCache import MemCache
-from dtr.utils.utils import getCashBack
 parser = optparse.OptionParser()
 parser.add_option("-H", "--host", dest="hostname",
                       default="localhost",
                       type="string", help="The HOST where the DB server is running",
 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, status, in_stock, maxprice, brand, dealType, dealPoints, brand_id):
+                 maxDiscount, discountType, dp, nlcPoints, status, in_stock, maxprice, brand, dealType, dealPoints):
         self._id = _id
         self.skuBundleId = skuBundleId
         self.category_id = category_id
         self.mrp = mrp
         self.available_price = available_price
         self.in_stock = in_stock
         self.maxprice = maxprice
         self.brand = brand
         self.dealType = dealType
         self.dealPoints = dealPoints
-        self.brand_id = brand_id
 def get_mongo_connection(host=options.mongoHost, port=27017):
     global con
     if con is None:
         #topSkus = collection.find( {'_id':664})
         for sku in topSkus:
             """Fix this """
             #TODO Compute deal flags else where.
             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, sku['status'], sku['in_stock'],None,sku['brand'].strip().upper(), 0, 0, sku['brand_id'])
+                             None, None, None, None, sku['status'], sku['in_stock'],sku['maxPrice'],sku['brand'].strip().upper(), 0, 0)
             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']
+                if info.maxprice == 0:
-                info.maxprice = exceptionalNlc[0]['maxNlc']
+                    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:
                     """Now mrp is zero, so we have to use saholic MRP"""
                     if identifier is not None:
                         it = Item.query.filter_by(catalog_item_id=identifier).first()
                         obj.mrp = it.mrp
                 if obj.mrp > 0:
+                    print obj._id
                     obj.minNlc = obj.mrp - (obj.mrp * obj.maxDiscount/100) - obj.schemeAmount
                     obj.maxNlc = obj.mrp - (obj.mrp * obj.minDiscount/100) - obj.schemeAmount
+                    if obj.maxprice == 0:
-                    obj.maxprice = obj.maxNlc
+                        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()
                         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
+                    if obj.maxprice == 0:
-                    obj.maxprice = obj.maxNlc
+                        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
+                        if obj.maxprice == 0:
-                        obj.maxprice = obj.maxNlc
+                            obj.maxprice = obj.maxNlc
                     except:
                         pass
         populated = populated + 300
         time.sleep(10)
             get_mongo_connection().Catalog.Deals.update({'_id':manualDeal['_id']},{"$set":{'dealType':0}},upsert=False, multi=True)
 def calculateNlcPoints():
     global LATEST_UPDATED_ITEMS
+    print "inside nlc oints"
     for sku in LATEST_UPDATED_ITEMS:
         if sku.maxNlc and sku.minNlc:
+            print sku._id
             """Create map - TODO"""
             if sku.status == 2:
                 eolWeight = .60
                 basePointPercentage = 8.0
                 maxNlcPoints = 150
             else:
                 basePointPercentage = 10.0
                 maxNlcPoints = 150
-            discFromMinNlc = (sku.minNlc - sku.available_price)/sku.available_price *100
+            discFromMinNlc = float((sku.minNlc - sku.available_price))/sku.available_price *100
-            discFromMaxNlc = (sku.maxNlc - sku.available_price)/sku.available_price *100
+            discFromMaxNlc = float((sku.maxNlc - sku.available_price))/sku.available_price *100
+            print discFromMinNlc
+            print discFromMaxNlc
             if discFromMinNlc > 0:
                 nlcPoints = 100/basePointPercentage * discFromMinNlc
             elif discFromMinNlc < 0 and discFromMaxNlc > 0:
                 nlcPoints = 0
             else:
         bestSellerPoints = 0
         toUpdate = []
         for similarItem in similarItems:
             if mc.get("negative_deals") is None:
                 populateNegativeDeals()
-            try:
-                cashBack = getCashBack(similarItem['_id'], similarItem['source_id'], similarItem['category_id'], mc, options.mongoHost)
-                if not cashBack or cashBack.get('cash_back_status')!=1:
-                    pass
-                else:
-                    if cashBack['cash_back_type'] ==1:
-                        similarItem['available_price'] = similarItem['available_price'] - similarItem['available_price'] * float(cashBack['cash_back'])/100
-                    elif cashBack['cash_back_type'] ==2:
-                        similarItem['available_price'] = similarItem['available_price'] - float(cashBack['cash_back'])
-                    else:
-                        pass
-            except Exception as cashBackEx:
-                print cashBackEx
-                print "Error calculating cashback."
             if similarItem['in_stock'] == 0 or similarItem['maxprice'] is None or similarItem['maxprice'] < similarItem['available_price'] or similarItem['_id'] in mc.get("negative_deals"):
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0 }})
                 continue
             if similarItem['available_price'] < bestPrice:
                 bestOne = similarItem
             toUpdate.remove(bestOne['_id'])
             get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDeal':1 }})
         if len(toUpdate) > 0:
             get_mongo_connection().Catalog.Deals.update({ '_id' : { "$in": toUpdate } }, {'$set':{'showDeal':0 }},upsert=False, multi=True)
-def elimiateSimilarDealsOld():
-    allItems = get_mongo_connection().Catalog.Deals.find().distinct('skuBundleId')
-    for skuBundleId in allItems:
-        print skuBundleId
-        similarItems = list(get_mongo_connection().Catalog.Deals.find({'skuBundleId':skuBundleId}).sort([('available_price',pymongo.ASCENDING)]))
-        bestPrice = float("inf")
-        bestOne = None
-        bestSellerPoints = 0
-        toUpdate = []
-        for similarItem in similarItems:
-            if mc.get("negative_deals") is None:
-                populateNegativeDeals()
-            if similarItem['in_stock'] == 0 or similarItem['maxprice'] is None or similarItem['maxprice'] < similarItem['available_price'] or similarItem['_id'] in mc.get("negative_deals"):
-                get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDealOld':0 }})
-                continue
-            if similarItem['available_price'] < bestPrice:
-                bestOne = similarItem
-                bestPrice = similarItem['available_price']
-                bestSellerPoints = similarItem['bestSellerPoints']
-            elif similarItem['available_price'] == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
-                bestOne = similarItem
-                bestPrice = similarItem['available_price']
-                bestSellerPoints = similarItem['bestSellerPoints']
-            else:
-                pass
-        if bestOne is not None:
-            for similarItem in similarItems:
-                toUpdate.append(similarItem['_id'])
-            toUpdate.remove(bestOne['_id'])
-            get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDealOld':1 }})
-        if len(toUpdate) > 0:
-            get_mongo_connection().Catalog.Deals.update({ '_id' : { "$in": toUpdate } }, {'$set':{'showDealOld':0 }},upsert=False, multi=True)
 def main():
     try:
         populateStuff()
         calculateNlc()
         addManualDealsInfo()
         session.close()
     calculateNlcPoints()
     commitData()
     addBestSellerPoints()
     elimiateSimilarDeals()
-    elimiateSimilarDealsOld()
 if __name__=='__main__':
-    main()
     main()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/DealRecomendation.py – Rev 14779 → 14842