Subversion Repositories SmartDukaan

Rev

Rev 17750 | Rev 18189 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
13755 kshitij.so 1 
import pymongo
2 
from elixir import *
3 
from shop2020.model.v1.catalog.impl import DataService
4 
from shop2020.model.v1.catalog.impl.DataService import Item
5 
from shop2020.clients.InventoryClient import InventoryClient
6 
from dtr.utils.utils import to_java_date
7 
from datetime import datetime, timedelta
8 
import time
14258 kshitij.so 9 
import optparse
14325 kshitij.so 10 
from dtr.storage.MemCache import MemCache
16635 manish.sha 11 
import traceback
13755 kshitij.so 12 
 
14258 kshitij.so 13 
parser = optparse.OptionParser()
14263 kshitij.so 14 
parser.add_option("-H", "--host", dest="hostname",
14258 kshitij.so 15 
                      default="localhost",
16 
                      type="string", help="The HOST where the DB server is running",
17 
                      metavar="host")
18 
parser.add_option("-m", "--m", dest="mongoHost",
19 
                      default="localhost",
20 
                      type="string", help="The HOST where the mongo server is running",
21 
                      metavar="mongo_host")
13755 kshitij.so 22 
 
14258 kshitij.so 23 
(options, args) = parser.parse_args()
14325 kshitij.so 24 
 
25 
mc = MemCache(options.mongoHost)
26 
 
14258 kshitij.so 27 
DataService.initialize(db_hostname=options.hostname)
28 
 
13755 kshitij.so 29 
con = None
17034 kshitij.so 30 
SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4, 'SHOPCLUES.COM':5,'PAYTM.COM':6,'HOMESHOP18.COM':7}
13755 kshitij.so 31 
DISCOUNT_TYPE = {'MRP':1,'DP':2}
32 
LATEST_UPDATED_ITEMS = []
16253 kshitij.so 33 
STATUS_WEIGHTAGE = {1 : 1.0, 2 : 2.0, 3 : 1.0, 4 : 0.5}
13755 kshitij.so 34 
 
16868 kshitij.so 35 
DEAL_POINTS_MAP = {}
36 
 
13755 kshitij.so 37 
now = datetime.now()
38 
 
16868 kshitij.so 39 
class __DealPoints:
40 
 
41 
    def __init__(self, manualDealThresholdPrice, points):
42 
        self.manualDealThresholdPrice = manualDealThresholdPrice
43 
        self.points = points
44 
 
45 
 
13755 kshitij.so 46 
class __SkuInfo:
47 
 
48 
    def __init__(self, _id, skuBundleId, category_id, mrp, available_price, source_id, rank, maxNlc, minNlc, schemeAmount, minDiscount, \
16534 kshitij.so 49 
                 maxDiscount, discountType, dp, nlcPoints, status, in_stock, maxprice, brand, dealType, brand_id, manualDealThresholdPrice,\
17713 kshitij.so 50 
                 codAvailable,showDp,gross_price, subCategoryId,subCategory,shippingCost):
13755 kshitij.so 51 
        self._id = _id
52 
        self.skuBundleId = skuBundleId
53 
        self.category_id = category_id
54 
        self.mrp = mrp
55 
        self.available_price = available_price
56 
        self.source_id = source_id
57 
        self.rank = rank
58 
        self.maxNlc = maxNlc
59 
        self.minNlc = minNlc
60 
        self.schemeAmount = schemeAmount
61 
        self.minDiscount = minDiscount
62 
        self.maxDiscount = maxDiscount
63 
        self.discountType = discountType
64 
        self.dp = dp
65 
        self.nlcPoints = nlcPoints
13824 kshitij.so 66 
        self.status = status
67 
        self.in_stock = in_stock
68 
        self.maxprice = maxprice
14035 kshitij.so 69 
        self.brand = brand
14306 kshitij.so 70 
        self.dealType = dealType
15063 kshitij.so 71 
        self.brand_id = brand_id
15271 kshitij.so 72 
        self.manualDealThresholdPrice = manualDealThresholdPrice
16019 kshitij.so 73 
        self.codAvailable = codAvailable
16253 kshitij.so 74 
        self.showDp = showDp
16456 kshitij.so 75 
        self.gross_price = gross_price
17649 kshitij.so 76 
        self.subCategoryId = subCategoryId
17678 kshitij.so 77 
        self.subCategory = subCategory
17713 kshitij.so 78 
        self.shippingCost = shippingCost
13755 kshitij.so 79 
 
80 
 
14258 kshitij.so 81 
def get_mongo_connection(host=options.mongoHost, port=27017):
13755 kshitij.so 82 
    global con
83 
    if con is None:
84 
        print "Establishing connection %s host and port %d" %(host,port)
85 
        try:
86 
            con = pymongo.MongoClient(host, port)
87 
        except Exception, e:
88 
            print e
89 
            return None
90 
    return con
91 
 
92 
def populateStuff():
93 
    print "Inside populate"
94 
    global LATEST_UPDATED_ITEMS
95 
    """Fetch latest updated items across portals
96 
       and calculate max and min R-Nlc"""
97 
    offset= 0
98 
    while(True):
99 
        print "Fetching records offset %d and limit %d" %(offset,300)
100 
        topSkus = list(get_mongo_connection().Catalog.MasterData.find( {"$and":[{'updatedOn': { "$gt": to_java_date(now - timedelta(hours=4))} }, { 'source_id' : { "$in": SOURCE_MAP.values() } }] }).skip(offset).limit(300))
101 
        if len((topSkus)) == 0:
102 
            break
103 
        #topSkus = collection.find( {'_id':664})
104 
        for sku in topSkus:
13908 kshitij.so 105 
            """Fix this """
106 
            #TODO Compute deal flags else where.
13755 kshitij.so 107 
            info = __SkuInfo(sku['_id'], sku['skuBundleId'], sku['category_id'], sku['mrp'], sku['available_price'], sku['source_id'], sku['rank'], None, None, 0.0, None, \
17678 kshitij.so 108 
                             None, None, None, None, sku['status'], sku['in_stock'],sku['maxPrice'],sku['brand'].strip().upper(), 0, sku['brand_id'], None, sku['codAvailable'], 0, sku['gross_price'], sku['subCategoryId'], \
17748 kshitij.so 109 
                             sku['subCategory'],sku['shippingCost'])
15854 kshitij.so 110 
            exceptionalNlc = list(get_mongo_connection().Catalog.ExceptionalNlc.find( {"$and" : [ {'skuBundleId':info.skuBundleId}, {'overrideNlc':1} ]} ))
13755 kshitij.so 111 
            if len(exceptionalNlc) > 0:
112 
                """Exceptional nlc found, no need to calculate max and min R-nlc"""
113 
                info.maxNlc = exceptionalNlc[0]['maxNlc']
114 
                info.minNlc = exceptionalNlc[0]['minNlc']
14842 kshitij.so 115 
                if info.maxprice == 0:
116 
                    info.maxprice = exceptionalNlc[0]['maxNlc']
13755 kshitij.so 117 
                LATEST_UPDATED_ITEMS.append(info)
118 
                continue
119 
 
15854 kshitij.so 120 
            skuSchemeDetails = list(get_mongo_connection().Catalog.SkuSchemeDetails.find( {'skuBundleId':info.skuBundleId}))
13755 kshitij.so 121 
            if len(skuSchemeDetails) > 0:
122 
                """Sku scheme details, populate scheme amount (Recently added)"""
13824 kshitij.so 123 
 
124 
                #TODO Add start date and end date of scehems
125 
 
13755 kshitij.so 126 
                info.schemeAmount = float(skuSchemeDetails[0]['schemeAmount'])
127 
 
15854 kshitij.so 128 
            skuDealerPrices = list(get_mongo_connection().Catalog.SkuDealerPrices.find( {'skuBundleId':info.skuBundleId} ) )
13755 kshitij.so 129 
            if len(skuDealerPrices) > 0:
130 
                info.dp = skuDealerPrices[0]['dp']
16253 kshitij.so 131 
                info.showDp = skuDealerPrices[0]['showDp']
15854 kshitij.so 132 
            skuDiscount = list(get_mongo_connection().Catalog.SkuDiscountInfo.find( {'skuBundleId':info.skuBundleId} ) )
13755 kshitij.so 133 
            if len(skuDiscount) > 0:
134 
                """Sku rule found, populate max , min Discount and discount type"""
135 
                info.maxDiscount = skuDiscount[0]['max_discount']
136 
                info.minDiscount = skuDiscount[0]['min_discount']
137 
                info.discountType = DISCOUNT_TYPE.get(skuDiscount[0]['discountType'].upper())
138 
                LATEST_UPDATED_ITEMS.append(info)
139 
                continue
140 
 
14035 kshitij.so 141 
            categoryDiscount = list(get_mongo_connection().Catalog.CategoryDiscount.find( {"$and" : [{'brand':sku['brand'].strip().upper()}, {'category_id':sku['category_id']} ]} ))
13755 kshitij.so 142 
            if len(categoryDiscount) > 0:
143 
                info.maxDiscount = categoryDiscount[0]['max_discount']
144 
                info.minDiscount = categoryDiscount[0]['min_discount']
145 
                info.discountType = DISCOUNT_TYPE.get(categoryDiscount[0]['discountType'].upper())
146 
 
147 
            LATEST_UPDATED_ITEMS.append(info)
148 
        offset = offset + 300
149 
    for lol in LATEST_UPDATED_ITEMS:
150 
        print lol.__dict__
151 
 
152 
 
153 
def calculateNlc():
154 
    global LATEST_UPDATED_ITEMS
155 
    populated = 0
156 
    while(populated <= len(LATEST_UPDATED_ITEMS)):
157 
        inventory_client = InventoryClient().get_client()
158 
        for obj in LATEST_UPDATED_ITEMS[populated:300+populated]:
159 
            if obj.maxNlc > 0 and obj.minNlc > 0:
160 
                continue
161 
            saholic_sku = list(get_mongo_connection().Catalog.MasterData.find( {"$and":[{'skuBundleId': obj.skuBundleId}, { 'source_id' : SOURCE_MAP.get('SAHOLIC')}] }))
162 
            identifier = None
163 
            if len(saholic_sku) > 0:
164 
                identifier = saholic_sku[0]['identifier']
165 
            if obj.discountType == DISCOUNT_TYPE.get('MRP'):
166 
                if obj.mrp == 0:
167 
                    """Now mrp is zero, so we have to use saholic MRP"""
168 
                    if identifier is not None:
169 
                        it = Item.query.filter_by(catalog_item_id=identifier).first()
170 
                        obj.mrp = it.mrp
171 
                if obj.mrp > 0:
14842 kshitij.so 172 
                    print obj._id
13755 kshitij.so 173 
                    obj.minNlc = obj.mrp - (obj.mrp * obj.maxDiscount/100) - obj.schemeAmount
13824 kshitij.so 174 
                    obj.maxNlc = obj.mrp - (obj.mrp * obj.minDiscount/100) - obj.schemeAmount
14842 kshitij.so 175 
                    if obj.maxprice == 0:
176 
                        obj.maxprice = obj.maxNlc
13755 kshitij.so 177 
            elif obj.discountType == DISCOUNT_TYPE.get('DP'):
178 
                if obj.dp == 0:
179 
                    """Now dp is zero, so we have to use saholic minimum dp for item"""
180 
                    if identifier is not None:
181 
                        it = Item.query.filter_by(catalog_item_id=identifier).first()
182 
                        try:
183 
                            vendorPricing = inventory_client.getAllItemPricing(it.id)
184 
                            min_dp = min(pricing.dealerPrice for pricing in vendorPricing)
185 
                            obj.dp = min_dp
16253 kshitij.so 186 
                            obj.showDp = 1
13755 kshitij.so 187 
                        except:
188 
                            pass
189 
                if obj.dp > 0:
190 
                    obj.minNlc = obj.dp - (obj.dp * obj.maxDiscount/100) - obj.schemeAmount
13824 kshitij.so 191 
                    obj.maxNlc = obj.dp - (obj.dp * obj.minDiscount/100) - obj.schemeAmount
14842 kshitij.so 192 
                    if obj.maxprice == 0:
193 
                        obj.maxprice = obj.maxNlc
13755 kshitij.so 194 
            else:
195 
                """No rule found, use saholic min nlc as max and min R-Nlc"""
196 
                if identifier is not None:
197 
                    it = Item.query.filter_by(catalog_item_id=identifier).first()
198 
                    try:
199 
                        vendorPricing = inventory_client.getAllItemPricing(it.id)
200 
                        min_nlc = min(pricing.nlc for pricing in vendorPricing)
201 
                        obj.maxNlc = min_nlc
13824 kshitij.so 202 
                        obj.minNlc = min_nlc
14842 kshitij.so 203 
                        if obj.maxprice == 0:
204 
                            obj.maxprice = obj.maxNlc
13755 kshitij.so 205 
                    except:
206 
                        pass
207 
        populated = populated + 300
208 
        time.sleep(10)
209 
 
14306 kshitij.so 210 
def addManualDealsInfo():
211 
    for sku in LATEST_UPDATED_ITEMS:
212 
        manualDeal = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':sku.source_id, 'sku':sku._id}))
213 
        if len(manualDeal) > 0:
214 
            sku.dealType = manualDeal[0]['dealType']
14310 kshitij.so 215 
 
216 
    """Remove deal flag from expired deals"""
14311 kshitij.so 217 
    manualDeals = list(get_mongo_connection().Catalog.Deals.find({'dealType':1}))
14310 kshitij.so 218 
    for manualDeal in manualDeals:
14389 kshitij.so 219 
        d_manualDeal = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':manualDeal['source_id'], 'sku':manualDeal['_id']}))
220 
        if len(d_manualDeal) > 0:
14310 kshitij.so 221 
            continue
222 
        else:
16507 kshitij.so 223 
            get_mongo_connection().Catalog.Deals.update({'_id':manualDeal['_id']},{"$set":{'dealType':0}},upsert=False, multi=False)
14306 kshitij.so 224 
 
13755 kshitij.so 225 
def calculateNlcPoints():
226 
    global LATEST_UPDATED_ITEMS
14842 kshitij.so 227 
    print "inside nlc oints"
13755 kshitij.so 228 
    for sku in LATEST_UPDATED_ITEMS:
229 
        if sku.maxNlc and sku.minNlc:
14842 kshitij.so 230 
            print sku._id
13824 kshitij.so 231 
 
232 
            """Create map - TODO"""
233 
 
234 
            if sku.status == 2:
235 
                eolWeight = .60
236 
            else:
237 
                eolWeight = 1.0
238 
            if sku.category_id == 3:
239 
                basePointPercentage = 5.0
240 
                maxNlcPoints = 200
241 
            elif sku.category_id == 5:
242 
                basePointPercentage = 8.0
243 
                maxNlcPoints = 150
17540 kshitij.so 244 
            elif sku.category_id == 6:
245 
                basePointPercentage = 5.0
246 
                maxNlcPoints = 200
247 
 
13824 kshitij.so 248 
            else:
249 
                basePointPercentage = 10.0
250 
                maxNlcPoints = 150
14842 kshitij.so 251 
            discFromMinNlc = float((sku.minNlc - sku.available_price))/sku.available_price *100
252 
            discFromMaxNlc = float((sku.maxNlc - sku.available_price))/sku.available_price *100
253 
            print discFromMinNlc
254 
            print discFromMaxNlc
13755 kshitij.so 255 
            if discFromMinNlc > 0:
13824 kshitij.so 256 
                nlcPoints = 100/basePointPercentage * discFromMinNlc
13755 kshitij.so 257 
            elif discFromMinNlc < 0 and discFromMaxNlc > 0:
258 
                nlcPoints = 0
259 
            else:
13824 kshitij.so 260 
                nlcPoints = 100/basePointPercentage * discFromMinNlc
261 
            if (min(nlcPoints,maxNlcPoints)) > 0:
262 
                sku.nlcPoints = (min(nlcPoints,maxNlcPoints)) * eolWeight
263 
            else:
264 
                sku.nlcPoints = (min(nlcPoints,maxNlcPoints))
13755 kshitij.so 265 
        else:
266 
            sku.nlcPoints = 0
267 
 
268 
def commitData():
269 
    global LATEST_UPDATED_ITEMS
270 
    for sku in LATEST_UPDATED_ITEMS:
271 
        #get_mongo_connection().Catalog.Deals.update({'_id':sku._id},{'$set' : sku.__dict__},upsert=True,multi=True)
14020 amit.gupta 272 
        get_mongo_connection().Catalog.Deals.update({'_id':sku._id},{"$set":sku.__dict__},upsert=True)
13755 kshitij.so 273 
 
274 
 
275 
def addBestSellerPoints():
276 
    allItems = list(get_mongo_connection().Catalog.Deals.find({}))
277 
    for sku in allItems:
13824 kshitij.so 278 
        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'] }] } ))
13755 kshitij.so 279 
        if len(bestSellerPoints) > 0:
13824 kshitij.so 280 
            print bestSellerPoints[0]['points']
281 
            if (bestSellerPoints[0]['points']) > 0:
16253 kshitij.so 282 
                sku['bestSellerPoints'] = (bestSellerPoints[0]['points']) * bestSellerPoints[0]['weightage'] * STATUS_WEIGHTAGE.get(sku['status'])
13824 kshitij.so 283 
            else:
284 
                sku['bestSellerPoints'] = (bestSellerPoints[0]['points'])
13755 kshitij.so 285 
        else:
17708 kshitij.so 286 
            if sku['category_id'] == 6:
17763 kshitij.so 287 
                sku['bestSellerPoints'] = 0
17708 kshitij.so 288 
            else:
289 
                sku['bestSellerPoints'] = -120
14114 kshitij.so 290 
        #sku['totalPoints'] = sku['bestSellerPoints'] + sku['nlcPoints']
291 
        get_mongo_connection().Catalog.Deals.update({'_id':sku['_id']},{'$set':{'bestSellerPoints':sku['bestSellerPoints']}},multi=False)
292 
 
14390 kshitij.so 293 
    shortageSkus = get_mongo_connection().Catalog.MasterData.find({"$and":[{'is_shortage': 1 }, { 'source_id' : { "$in": SOURCE_MAP.values() } }] }).distinct('_id')
294 
    print "Shortage skus"
295 
    print shortageSkus
14388 kshitij.so 296 
 
14114 kshitij.so 297 
    for sku in allItems:
298 
        deal_item = list(get_mongo_connection().Catalog.Deals.find({'skuBundleId':sku['skuBundleId']}).sort('bestSellerPoints',pymongo.DESCENDING).limit(1))
14142 kshitij.so 299 
        sku['catalogBestSellerPoints'] = deal_item[0]['bestSellerPoints']
14388 kshitij.so 300 
        shortagePoints = 50 if sku['_id'] in shortageSkus else 0
14391 kshitij.so 301 
        print "Shortage points for ",sku['_id']
302 
        print shortagePoints
16868 kshitij.so 303 
 
304 
        dealPoints = DEAL_POINTS_MAP.get(sku['skuBundleId'])
305 
 
306 
        if dealPoints is not None and dealPoints.manualDealThresholdPrice >= sku['available_price']:
307 
            sku['dealPoints'] = dealPoints.points
308 
            sku['manualDealThresholdPrice'] = dealPoints.manualDealThresholdPrice
309 
        else:
310 
            sku['dealPoints'] = 0
311 
            sku['manualDealThresholdPrice'] = None
312 
 
313 
 
314 
        sku['totalPoints'] = sku['catalogBestSellerPoints'] + sku['nlcPoints'] + shortagePoints + sku['dealPoints']
315 
        get_mongo_connection().Catalog.Deals.update({'_id':sku['_id']},{'$set':{'catalogBestSellerPoints':sku['catalogBestSellerPoints'],'totalPoints':sku['totalPoints'],'dealPoints':sku['dealPoints'], \
316 
                                                                                    'manualDealThresholdPrice':sku['manualDealThresholdPrice']}},multi=False)
15271 kshitij.so 317 
 
318 
 
13755 kshitij.so 319 
 
14325 kshitij.so 320 
def populateNegativeDeals():
321 
    negativeDeals = get_mongo_connection().Catalog.NegativeDeals.find().distinct('sku')
322 
    mc.set("negative_deals", negativeDeals, 600)
323 
 
16868 kshitij.so 324 
def eliminateSimilarDeals():
13912 kshitij.so 325 
    allItems = get_mongo_connection().Catalog.Deals.find().distinct('skuBundleId')
326 
    for skuBundleId in allItems:
327 
        print skuBundleId
328 
        similarItems = list(get_mongo_connection().Catalog.Deals.find({'skuBundleId':skuBundleId}).sort([('available_price',pymongo.ASCENDING)]))
13828 kshitij.so 329 
        bestPrice = float("inf")
330 
        bestOne = None
331 
        bestSellerPoints = 0
332 
        toUpdate = []
16019 kshitij.so 333 
        prepaidBestPrice = float("inf")
334 
        prepaidBestOne = None
335 
        prepaidBestSellerPoints = 0
13828 kshitij.so 336 
        for similarItem in similarItems:
16019 kshitij.so 337 
            if similarItem['codAvailable'] ==1:
338 
                if mc.get("negative_deals") is None:
339 
                    populateNegativeDeals()
16171 kshitij.so 340 
                if similarItem['in_stock'] == 0  or similarItem['_id'] in mc.get("negative_deals"):
16019 kshitij.so 341 
                    get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0, 'prepaidDeal':0 }})
342 
                    continue
17675 kshitij.so 343 
                if similarItem['source_id'] == SOURCE_MAP.get('SHOPCLUES.COM') and similarItem['rank']==0 and similarItem['category_id']!=6:
16019 kshitij.so 344 
                    get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':0 }})
345 
                    continue
346 
                if similarItem['available_price'] < bestPrice:
347 
                    bestOne = similarItem
348 
                    bestPrice = similarItem['available_price']
349 
                    bestSellerPoints = similarItem['bestSellerPoints']
350 
                elif similarItem['available_price'] == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
351 
                    bestOne = similarItem
352 
                    bestPrice = similarItem['available_price']
353 
                    bestSellerPoints = similarItem['bestSellerPoints']
354 
                else:
355 
                    pass
13828 kshitij.so 356 
            else:
16019 kshitij.so 357 
                if mc.get("negative_deals") is None:
358 
                    populateNegativeDeals()
16171 kshitij.so 359 
                if similarItem['in_stock'] == 0  or similarItem['_id'] in mc.get("negative_deals"):
16019 kshitij.so 360 
                    get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0, 'prepaidDeal':0 }})
361 
                    continue
17750 kshitij.so 362 
                if similarItem['source_id'] == SOURCE_MAP.get('SHOPCLUES.COM') and similarItem['rank']==0 and similarItem['category_id']!=6:
16019 kshitij.so 363 
                    get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':0 }})
364 
                    continue
16869 kshitij.so 365 
                if similarItem['source_id'] == SOURCE_MAP.get('PAYTM.COM'):
366 
                    similarItem['available_price'] = similarItem['gross_price']
16019 kshitij.so 367 
                if similarItem['available_price'] < prepaidBestPrice:
368 
                    prepaidBestOne = similarItem
369 
                    prepaidBestPrice = similarItem['available_price']
370 
                    prepaidBestSellerPoints = similarItem['bestSellerPoints']
371 
                elif similarItem['available_price'] == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
372 
                    prepaidBestOne = similarItem
373 
                    prepaidBestPrice = similarItem['available_price']
374 
                    prepaidBestSellerPoints = similarItem['bestSellerPoints']
375 
                else:
376 
                    pass
16026 kshitij.so 377 
        if bestOne is not None or prepaidBestOne is not None:
13828 kshitij.so 378 
            for similarItem in similarItems:
379 
                toUpdate.append(similarItem['_id'])
16026 kshitij.so 380 
            if bestOne is not None:
381 
                toUpdate.remove(bestOne['_id'])
382 
                get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDeal':1,'prepaidDeal':0 }})
383 
            if prepaidBestOne is not None:
16071 kshitij.so 384 
                if bestOne is not None:
385 
                    if prepaidBestOne['available_price'] < bestOne['available_price']:
386 
                        toUpdate.remove(prepaidBestOne['_id'])
387 
                        get_mongo_connection().Catalog.Deals.update({ '_id' : prepaidBestOne['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':1 }})
388 
                else:
389 
                    toUpdate.remove(prepaidBestOne['_id'])
390 
                    get_mongo_connection().Catalog.Deals.update({ '_id' : prepaidBestOne['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':1 }})
13828 kshitij.so 391 
        if len(toUpdate) > 0:
16019 kshitij.so 392 
            get_mongo_connection().Catalog.Deals.update({ '_id' : { "$in": toUpdate } }, {'$set':{'showDeal':0,'prepaidDeal':0 }},upsert=False, multi=True)
13755 kshitij.so 393 
 
16868 kshitij.so 394 
def populateDealPointsBundle():
395 
    global DEAL_POINTS_MAP
396 
    activeDealPoints = get_mongo_connection().Catalog.DealPoints.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}})
397 
    for activeDeal in activeDealPoints:
398 
        dealPoints = __DealPoints(activeDeal['dealThresholdPrice'], activeDeal['dealPoints'])
399 
        DEAL_POINTS_MAP[activeDeal['skuBundleId']] = dealPoints
400 
 
13755 kshitij.so 401 
def main():
14263 kshitij.so 402 
    try:
403 
        populateStuff()
404 
        calculateNlc()
14306 kshitij.so 405 
        addManualDealsInfo()
14263 kshitij.so 406 
    finally:
407 
        session.close()
13755 kshitij.so 408 
    calculateNlcPoints()
409 
    commitData()
16868 kshitij.so 410 
    populateDealPointsBundle()
13755 kshitij.so 411 
    addBestSellerPoints()
16868 kshitij.so 412 
    eliminateSimilarDeals()
13755 kshitij.so 413 
 
13828 kshitij.so 414 
 
13755 kshitij.so 415 
if __name__=='__main__':
14842 kshitij.so 416 
    main()