Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
14305 amit.gupta 1 
from bson.objectid import ObjectId
2 
from datetime import datetime, timedelta
3 
from dtr.config import PythonPropertyReader
19451 manas 4 
from dtr.dao import FeaturedDeals, AppTransactions, AppOfferObj, Promotion, NotificationCampaign,CrmRefundWallet
14037 kshitij.so 5 
from dtr.storage import DataService
6 
from dtr.storage.DataService import price_preferences, brand_preferences, \
16789 amit.gupta 7 
    user_actions, Brands, app_offers, approved_app_transactions, user_app_cashbacks, \
17280 manish.sha 8 
    user_app_installs, appmasters, notification_campaigns
16304 amit.gupta 9 
from dtr.storage.MemCache import MemCache
16789 amit.gupta 10 
from dtr.utils.MailSender import Email
11 
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT, \
19556 manas 12 
    to_py_date, CB_REJECTED, SUB_CATEGORY_MAP,CREDIT_TYPE_REFUND,CREDIT_TYPE_OFFER,CREDIT_TYPE_ADJUSTMENT,REFUND_ADJUSTMENT_MAP, todict,REVERSE_SOURCE_MAP,\
13 
    get_mongo_connection_dtr_data
16894 manish.sha 14 
from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
14305 amit.gupta 15 
from elixir import *
16 
from operator import itemgetter
16789 amit.gupta 17 
from pymongo.command_cursor import CommandCursor
14305 amit.gupta 18 
import pymongo
16398 amit.gupta 19 
import random
14322 kshitij.so 20 
import re
16789 amit.gupta 21 
import time
14791 kshitij.so 22 
import traceback
16894 manish.sha 23 
from itertools import groupby
17280 manish.sha 24 
import urllib
25 
import urllib2
26 
import json
17367 kshitij.so 27 
import collections
19451 manas 28 
from string import lower
17367 kshitij.so 29 
try:
30 
    import ordereddict
31 
except:
32 
    pass
13572 kshitij.so 33 
 
18830 kshitij.so 34 
 
35 
import bson.son as son
19207 kshitij.so 36 
import math
37 
 
13572 kshitij.so 38 
con = None
17944 kshitij.so 39 
es = None
18052 kshitij.so 40 
try:
41 
    from elasticsearch import Elasticsearch
42 
except:
43 
    pass
17936 kshitij.so 44 
from shop2020.config.client.ConfigClient import ConfigClient
13572 kshitij.so 45 
 
14037 kshitij.so 46 
DataService.initialize(db_hostname="localhost")
16304 amit.gupta 47 
mc = MemCache("127.0.0.1")
17936 kshitij.so 48 
config_client = ConfigClient()
49 
elastic_search_host = config_client.get_property('elastic_search_host')
50 
elastic_search_port = config_client.get_property('elastic_search_port')
14037 kshitij.so 51 
 
17936 kshitij.so 52 
 
17944 kshitij.so 53 
 
17035 kshitij.so 54 
SOURCE_MAP = {1:'AMAZON',2:'FLIPKART',3:'SNAPDEAL',4:'SAHOLIC',5:"SHOPCLUES.COM",6:"PAYTM.COM",7:"HOMESHOP18.COM"}
14482 kshitij.so 55 
 
15853 kshitij.so 56 
COLLECTION_MAP = {
57 
                  'ExceptionalNlc':'skuBundleId',
58 
                  'SkuDealerPrices':'skuBundleId',
59 
                  'SkuDiscountInfo':'skuBundleId',
60 
                  'SkuSchemeDetails':'skuBundleId',
17367 kshitij.so 61 
                  'DealPoints':'skuBundleId',
62 
                  'FeaturedDeals': 'skuBundleId'
15853 kshitij.so 63 
                  }
64 
 
19337 manish.sha 65 
 
17944 kshitij.so 66 
def get_elastic_search_connection():
67 
    global es
68 
    if es is None:
69 
        print "Establishing connection with elastic search %s host and port %s"%(elastic_search_host,elastic_search_port)
70 
        es = Elasticsearch([{'host': elastic_search_host, 'port': elastic_search_port}])
71 
        return es
72 
    return es
73 
 
74 
 
13572 kshitij.so 75 
def get_mongo_connection(host='localhost', port=27017):
76 
    global con
77 
    if con is None:
78 
        print "Establishing connection %s host and port %d" %(host,port)
79 
        try:
80 
            con = pymongo.MongoClient(host, port)
81 
        except Exception, e:
82 
            print e
83 
            return None
84 
    return con
85 
 
13907 kshitij.so 86 
def populateCashBack():
13921 kshitij.so 87 
    print "Populating cashback"
88 
    cashBackMap = {}
89 
    itemCashBackMap = {}
13907 kshitij.so 90 
    cashBack = list(get_mongo_connection().Catalog.CategoryCashBack.find())
91 
    for row in cashBack:
13970 kshitij.so 92 
        temp_map = {}
93 
        temp_list = []
13907 kshitij.so 94 
        if cashBackMap.has_key(row['source_id']):
95 
            arr = cashBackMap.get(row['source_id'])
96 
            for val in arr:
97 
                temp_list.append(val)
98 
            temp_map[row['category_id']] = row
99 
            temp_list.append(temp_map)
100 
            cashBackMap[row['source_id']] = temp_list
101 
        else:
102 
            temp_map[row['category_id']] = row
103 
            temp_list.append(temp_map)
104 
            cashBackMap[row['source_id']] = temp_list
13921 kshitij.so 105 
    itemCashBack = list(get_mongo_connection().Catalog.ItemCashBack.find())
106 
    for row in itemCashBack:
107 
        if not itemCashBackMap.has_key(row['skuId']):
108 
            itemCashBackMap[row['skuId']] = row
14761 kshitij.so 109 
    mc.set("item_cash_back", itemCashBackMap, 24 * 60 * 60)
110 
    mc.set("category_cash_back", cashBackMap, 24 * 60 * 60)
13907 kshitij.so 111 
 
13572 kshitij.so 112 
def addCategoryDiscount(data):
13970 kshitij.so 113 
    collection = get_mongo_connection().Catalog.CategoryDiscount
13572 kshitij.so 114 
    query = []
115 
    data['brand'] = data['brand'].strip().upper()
13970 kshitij.so 116 
    data['discountType'] = data['discountType'].upper().strip()
13572 kshitij.so 117 
    query.append({"brand":data['brand']})
118 
    query.append({"category_id":data['category_id']})
119 
    r = collection.find({"$and":query})
120 
    if r.count() > 0:
13639 kshitij.so 121 
        return {0:"Brand & Category info already present."}
13572 kshitij.so 122 
    else:
123 
        collection.insert(data)
13970 kshitij.so 124 
        get_mongo_connection().Catalog.MasterData.update({'brand':data['brand'],'category_id':data['category_id']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13639 kshitij.so 125 
        return {1:"Data added successfully"}
13572 kshitij.so 126 
 
13970 kshitij.so 127 
def updateCategoryDiscount(data,_id):
128 
    try:
129 
        collection = get_mongo_connection().Catalog.CategoryDiscount
130 
        collection.update({'_id':ObjectId(_id)},{"$set":{'min_discount':data['min_discount'],'max_discount':data['max_discount'],'discountType':data['discountType'].upper().strip()}},upsert=False, multi = False)
131 
        get_mongo_connection().Catalog.MasterData.update({'brand':data['brand'],'category_id':data['category_id']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
132 
        return {1:"Data updated successfully"}
133 
    except:
134 
        return {0:"Data not updated."}
135 
 
136 
 
13572 kshitij.so 137 
def getAllCategoryDiscount():
138 
    data = []
13970 kshitij.so 139 
    collection = get_mongo_connection().Catalog.CategoryDiscount
13572 kshitij.so 140 
    cursor = collection.find()
141 
    for val in cursor:
142 
        data.append(val)
143 
    return data
144 
 
14553 kshitij.so 145 
def __getBundledSkusfromSku(sku):
146 
    masterData =  get_mongo_connection().Catalog.MasterData.find_one({"_id":sku},{"skuBundleId":1})
147 
    if masterData is not None:
148 
        return list(get_mongo_connection().Catalog.MasterData.find({"skuBundleId":masterData.get('skuBundleId')},{'_id':1,'skuBundleId':1}))
149 
    else:
150 
        return []
13572 kshitij.so 151 
 
15853 kshitij.so 152 
def addSchemeDetailsForSku(data):
153 
    collection = get_mongo_connection().Catalog.SkuSchemeDetails
154 
    result = collection.find_one({'skuBundleId':data['skuBundleId']})
155 
    if result is None:
14553 kshitij.so 156 
        collection.insert(data)
15853 kshitij.so 157 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
14553 kshitij.so 158 
        return {1:"Data added successfully"}
15853 kshitij.so 159 
    return {1:"BundleId info already present"}
160 
 
14069 kshitij.so 161 
def getAllSkuWiseSchemeDetails(offset, limit):
13572 kshitij.so 162 
    data = []
13970 kshitij.so 163 
    collection = get_mongo_connection().Catalog.SkuSchemeDetails
14071 kshitij.so 164 
    cursor = collection.find().skip(offset).limit(limit)
13572 kshitij.so 165 
    for val in cursor:
15853 kshitij.so 166 
        master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':val['skuBundleId']})
167 
        if master is not None:
168 
            val['brand'] = master['brand']
169 
            val['source_product_name'] = master['source_product_name']
14069 kshitij.so 170 
        else:
171 
            val['brand'] = ""
172 
            val['source_product_name'] = ""
13572 kshitij.so 173 
        data.append(val)
174 
    return data
175 
 
15853 kshitij.so 176 
def addSkuDiscountInfo(data):
177 
    collection = get_mongo_connection().Catalog.SkuDiscountInfo
178 
    cursor = collection.find_one({"skuBundleId":data['skuBundleId']})
179 
    if cursor is not None:
180 
        return {0:"BundleId information already present."}
13572 kshitij.so 181 
    else:
15853 kshitij.so 182 
        collection.insert(data)
183 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13639 kshitij.so 184 
        return {1:"Data added successfully"}
13572 kshitij.so 185 
 
13970 kshitij.so 186 
def getallSkuDiscountInfo(offset, limit):
13572 kshitij.so 187 
    data = []
13970 kshitij.so 188 
    collection = get_mongo_connection().Catalog.SkuDiscountInfo
189 
    cursor = collection.find().skip(offset).limit(limit)
13572 kshitij.so 190 
    for val in cursor:
15853 kshitij.so 191 
        master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':val['skuBundleId']})
192 
        if master is not None:
193 
            val['brand'] = master['brand']
194 
            val['source_product_name'] = master['source_product_name']
13970 kshitij.so 195 
        else:
196 
            val['brand'] = ""
197 
            val['source_product_name'] = ""
13572 kshitij.so 198 
        data.append(val)
199 
    return data
200 
 
13970 kshitij.so 201 
def updateSkuDiscount(data,_id):
202 
    try:
203 
        collection = get_mongo_connection().Catalog.SkuDiscountInfo
204 
        collection.update({'_id':ObjectId(_id)},{"$set":{'min_discount':data['min_discount'],'max_discount':data['max_discount'],'discountType':data['discountType'].upper().strip()}},upsert=False, multi = False)
15853 kshitij.so 205 
        get_mongo_connection().Catalog.MasterData.update({'_id':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13970 kshitij.so 206 
        return {1:"Data updated successfully"}
207 
    except:
208 
        return {0:"Data not updated."}
209 
 
210 
 
15853 kshitij.so 211 
def addExceptionalNlc(data):
212 
    collection = get_mongo_connection().Catalog.ExceptionalNlc
213 
    cursor = collection.find_one({"skuBundleId":data['skuBundleId']})
214 
    if cursor is not None:
215 
        return {0:"BundleId information already present."}
13572 kshitij.so 216 
    else:
15853 kshitij.so 217 
        collection.insert(data)
218 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13639 kshitij.so 219 
        return {1:"Data added successfully"}
13572 kshitij.so 220 
 
13970 kshitij.so 221 
def getAllExceptionlNlcItems(offset, limit):
13572 kshitij.so 222 
    data = []
13970 kshitij.so 223 
    collection = get_mongo_connection().Catalog.ExceptionalNlc
14071 kshitij.so 224 
    cursor = collection.find().skip(offset).limit(limit)
13572 kshitij.so 225 
    for val in cursor:
15853 kshitij.so 226 
        master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':val['skuBundleId']})
227 
        if master is not None:
228 
            val['brand'] = master['brand']
229 
            val['source_product_name'] = master['source_product_name']
13970 kshitij.so 230 
        else:
231 
            val['brand'] = ""
232 
            val['source_product_name'] = ""
13572 kshitij.so 233 
        data.append(val)
234 
    return data
235 
 
14005 amit.gupta 236 
def getMerchantOrdersByUser(userId, page=1, window=50, searchMap={}):
237 
    if searchMap is None:
238 
        searchMap = {}
13603 amit.gupta 239 
    if page==None:
240 
        page = 1
241 
 
242 
    if window==None:
243 
        window = 50
244 
    result = {}
13582 amit.gupta 245 
    skip = (page-1)*window
14005 amit.gupta 246 
 
14353 amit.gupta 247 
    if userId is not None:
248 
        searchMap['userId'] = userId
13603 amit.gupta 249 
    collection = get_mongo_connection().Dtr.merchantOrder
14609 amit.gupta 250 
    cursor = collection.find(searchMap).sort("orderId",-1)
13603 amit.gupta 251 
    total_count = cursor.count()
252 
    pages = total_count/window + (0 if total_count%window==0 else 1)
253 
    print "total_count", total_count
254 
    if total_count > skip:
13999 amit.gupta 255 
        cursor = cursor.skip(skip).limit(window)
13603 amit.gupta 256 
        orders = []
257 
        for order in cursor:
14002 amit.gupta 258 
            del(order["_id"])
259 
            orders.append(order)
13603 amit.gupta 260 
        result['data'] = orders
261 
        result['window'] = window
262 
        result['totalCount'] = total_count
263 
        result['currCount'] = cursor.count()
264 
        result['totalPages'] = pages
265 
        result['currPage'] = page
266 
        return result
267 
    else:
268 
        return result
13630 kshitij.so 269 
 
13927 amit.gupta 270 
def getRefunds(userId, page=1, window=10):
271 
    if page==None:
272 
        page = 1
273 
 
274 
    if window==None:
13995 amit.gupta 275 
        window = 10
13927 amit.gupta 276 
    result = {}
277 
    skip = (page-1)*window
16737 amit.gupta 278 
    con = get_mongo_connection()
279 
    collection = con.Dtr.refund
280 
    user = con.Dtr.user
16754 amit.gupta 281 
    credited = user.find_one({"userId":userId})
282 
    if credited:
283 
        credited = credited.get("credited")
284 
    else:
285 
        credited=0
286 
 
13927 amit.gupta 287 
    cursor = collection.find({"userId":userId})
288 
    total_count = cursor.count()
289 
    pages = total_count/window + (0 if total_count%window==0 else 1)
290 
    print "total_count", total_count
291 
    if total_count > skip:
14668 amit.gupta 292 
        cursor = cursor.skip(skip).limit(window).sort([('batch',-1)])
13927 amit.gupta 293 
        refunds = []
294 
        for refund in cursor:
295 
            del(refund["_id"])
19511 manas 296 
            if (refund["type"]) == CREDIT_TYPE_REFUND:
19493 manas 297 
                batchDetails = fetchCrmRefundByBatchId(refund["batch"])
298 
                referenceNumber = batchDetails.get('reference_no')
19511 manas 299 
                refund["description"] = "Refunded against Saholic order #%s"%(referenceNumber)
300 
            elif (refund["type"]) == CREDIT_TYPE_ADJUSTMENT:
19493 manas 301 
                batchDetails = fetchCrmRefundByBatchId(refund["batch"])
302 
                referenceNumber = batchDetails.get('reference_no')
19517 manas 303 
                referenceStore = REVERSE_SOURCE_MAP.get(batchDetails.get('store'))
19511 manas 304 
                refund["description"] = "Adjusted against %s order #%s"%(referenceStore,referenceNumber)
19493 manas 305 
            else:
306 
                refund["description"] = ""
13927 amit.gupta 307 
            refunds.append(refund)
16754 amit.gupta 308 
        result['credited'] = credited
13927 amit.gupta 309 
        result['data'] = refunds
310 
        result['window'] = window
311 
        result['totalCount'] = total_count
312 
        result['currCount'] = cursor.count()
313 
        result['totalPages'] = pages
314 
        result['currPage'] = page
315 
        return result
316 
    else:
317 
        return result
318 
 
319 
def getPendingRefunds(userId):
13991 amit.gupta 320 
    print type(userId)
13927 amit.gupta 321 
    result = get_mongo_connection().Dtr.merchantOrder\
322 
        .aggregate([
16398 amit.gupta 323 
                    {'$match':{'subOrders.cashBackStatus':CB_APPROVED, 'userId':userId}},
13927 amit.gupta 324 
                    {'$unwind':"$subOrders"},
16398 amit.gupta 325 
                    {'$match':{'subOrders.cashBackStatus':CB_APPROVED}},
13927 amit.gupta 326 
                    {
327 
                     '$group':{
328 
                               '_id':None,
329 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
330 
                               }
331 
                     }
13987 amit.gupta 332 
                ])['result']
333 
 
334 
    if len(result)>0:
335 
        result = result[0]
336 
        result.pop("_id")
337 
    else:
338 
        result={}
339 
        result['amount'] = 0.0
14305 amit.gupta 340 
    result['nextCredit'] = datetime.strftime(next_weekday(datetime.now(), int(PythonPropertyReader.getConfig('CREDIT_DAY_OF_WEEK'))),"%Y-%m-%d %H:%M:%S")
13927 amit.gupta 341 
    return result
14037 kshitij.so 342 
 
14671 amit.gupta 343 
def getPendingCashbacks(userId):
344 
    result = get_mongo_connection().Dtr.merchantOrder\
345 
        .aggregate([
16398 amit.gupta 346 
                    {'$match':{'subOrders.cashBackStatus':CB_PENDING, 'userId':userId}},
14671 amit.gupta 347 
                    {'$unwind':"$subOrders"},
16398 amit.gupta 348 
                    {'$match':{'subOrders.cashBackStatus':CB_PENDING}},
14671 amit.gupta 349 
                    {
350 
                     '$group':{
351 
                               '_id':None,
352 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
353 
                               }
354 
                     }
355 
                ])['result']
356 
 
357 
    if len(result)>0:
358 
        result = result[0]
359 
        result.pop("_id")
360 
    else:
361 
        result={}
362 
        result['amount'] = 0.0
363 
    return result
364 
 
17369 kshitij.so 365 
def __constructDummyDealObject(skuBundleId):
366 
    temp =[]
19193 kshitij.so 367 
    deals = get_mongo_connection().Catalog.Deals.find({"skuBundleId":skuBundleId,"$or":[{"showDeal":1}, {"prepaidDeal":1}]},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1,'dp':1, 'showDp':1, 'gross_price':1,'subCategoryId':1,'netPriceAfterCashBack':1})
17369 kshitij.so 368 
    for d in deals:
369 
        d['persPoints'] = 0
19559 kshitij.so 370 
        d['internalRank'] = 999999
17369 kshitij.so 371 
        temp.append(d)
372 
    return temp
373 
 
374 
 
375 
 
14037 kshitij.so 376 
def __populateCache(userId):
17369 kshitij.so 377 
    try:
378 
        if mc.get("featured_deals") is None:
379 
            __populateFeaturedDeals()
380 
        featuredDeals = mc.get("featured_deals")
381 
 
382 
    except Exception as e:
383 
        print traceback.print_exc()
17469 kshitij.so 384 
        featuredDeals = {3:{},5:{},6:{}}
17369 kshitij.so 385 
 
19559 kshitij.so 386 
 
387 
    #Not taking into account accessories
388 
    featuredDeals.pop(6,None)
389 
 
17369 kshitij.so 390 
    fd_bundles = []
391 
 
392 
    for catMap in featuredDeals.itervalues():
393 
        for fd_map in catMap.itervalues():
17541 kshitij.so 394 
            if not fd_map.get('skuBundleId') in fd_bundles:
395 
                fd_bundles.append(fd_map.get('skuBundleId'))
17369 kshitij.so 396 
 
14037 kshitij.so 397 
    print "Populating memcache for userId",userId
398 
    outer_query = []
16067 kshitij.so 399 
    outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })
14037 kshitij.so 400 
    query = {}
16170 kshitij.so 401 
    query['$gt'] = -100
14037 kshitij.so 402 
    outer_query.append({'totalPoints':query})
19559 kshitij.so 403 
    outer_query.append({'category_id':{"$in":[3,5]}})
14037 kshitij.so 404 
    brandPrefMap = {}
405 
    pricePrefMap = {}
406 
    actionsMap = {}
407 
    brand_p = session.query(price_preferences).filter_by(user_id=userId).all()
408 
    for x in brand_p:
409 
        pricePrefMap[x.category_id] = [x.min_price,x.max_price]
410 
    for x in session.query(brand_preferences).filter_by(user_id=userId).all():
411 
        temp_map = {}
412 
        if brandPrefMap.has_key((x.brand).strip().upper()):
413 
            val = brandPrefMap.get((x.brand).strip().upper())
414 
            temp_map[x.category_id] = 1 if x.status == 'show' else 0
415 
            val.append(temp_map)
416 
        else:
417 
            temp = []
418 
            temp_map[x.category_id] = 1 if x.status == 'show' else 0
419 
            temp.append(temp_map)
420 
            brandPrefMap[(x.brand).strip().upper()] = temp
421 
 
422 
    for x in session.query(user_actions).filter_by(user_id=userId).all():
423 
        actionsMap[x.store_product_id] = 1 if x.action == 'like' else 0
19193 kshitij.so 424 
    all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1,'dp':1, 'showDp':1, 'gross_price':1, 'subCategoryId':1,'netPriceAfterCashBack':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))
14037 kshitij.so 425 
    mobile_deals = []
426 
    tablet_deals = []
19559 kshitij.so 427 
    #accessories_deals = []
14037 kshitij.so 428 
    for deal in all_deals:
19135 kshitij.so 429 
 
17369 kshitij.so 430 
        try:
431 
            fd_bundles.remove(deal.get('skuBundleId'))
432 
        except:
433 
            pass
434 
 
14037 kshitij.so 435 
        if actionsMap.get(deal['_id']) == 0:
436 
            fav_weight =.25
437 
        elif actionsMap.get(deal['_id']) == 1:
438 
            fav_weight = 1.5
439 
        else:
440 
            fav_weight = 1
441 
 
442 
        if brandPrefMap.get(deal['brand'].strip().upper()) is not None:
17469 kshitij.so 443 
 
14037 kshitij.so 444 
            brand_weight = 1
445 
            for brandInfo in brandPrefMap.get(deal['brand'].strip().upper()):
446 
                if brandInfo.get(deal['category_id']) is not None:
447 
                    if brandInfo.get(deal['category_id']) == 1:
14055 kshitij.so 448 
                        brand_weight = 2.0
14037 kshitij.so 449 
        else:
450 
            brand_weight = 1
451 
 
452 
        if pricePrefMap.get(deal['category_id']) is not None:
453 
 
454 
            if deal['available_price'] >= pricePrefMap.get(deal['category_id'])[0] and deal['available_price'] <= pricePrefMap.get(deal['category_id'])[1]:
455 
                asp_weight = 1.5
456 
            elif  deal['available_price'] >= pricePrefMap.get(deal['category_id'])[0] - 0.5 * pricePrefMap.get(deal['category_id'])[0] and deal['available_price'] <= pricePrefMap.get(deal['category_id'])[1] + 0.5 * pricePrefMap.get(deal['category_id'])[1]:
457 
                asp_weight = 1.2
458 
            else:
459 
                asp_weight = 1
460 
        else:
461 
            asp_weight = 1
462 
 
463 
        persPoints = deal['totalPoints'] * fav_weight * brand_weight * asp_weight
464 
        deal['persPoints'] = persPoints
465 
 
466 
        if deal['category_id'] ==3:
467 
            mobile_deals.append(deal)
468 
        elif deal['category_id'] ==5:
469 
            tablet_deals.append(deal)
19559 kshitij.so 470 
        #elif deal['category_id'] ==6:
471 
        #    accessories_deals.append(deal)
14037 kshitij.so 472 
        else:
473 
            continue
474 
 
14144 kshitij.so 475 
    session.close()
17367 kshitij.so 476 
 
477 
    mobile_deals = sorted(mobile_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
478 
    tablet_deals = sorted(tablet_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
19559 kshitij.so 479 
    #accessories_deals = sorted(accessories_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
17367 kshitij.so 480 
 
481 
 
17369 kshitij.so 482 
    if len(fd_bundles) > 0:
483 
        print "There is still bundle in feature deals with points less than -100.Lets add info"
484 
        for skuBundleId in fd_bundles:
485 
            dummyDealObjList = __constructDummyDealObject(skuBundleId)
486 
            for dummyDealObj in dummyDealObjList:
487 
                if dummyDealObj['category_id'] ==3:
488 
                    mobile_deals.append(dummyDealObj)
489 
                elif dummyDealObj['category_id'] ==5:
490 
                    tablet_deals.append(dummyDealObj)
19559 kshitij.so 491 
                #elif dummyDealObj['category_id'] ==6:
492 
                #    accessories_deals.append(dummyDealObj)
17369 kshitij.so 493 
                else:
494 
                    pass
495 
 
17469 kshitij.so 496 
    for super_category, categoryFeaturedDeals in featuredDeals.iteritems():
497 
        for val in categoryFeaturedDeals.itervalues():
498 
            dummyDealObjList = __constructDummyDealObject(val.get('skuBundleId'))
499 
            for dummyDealObj in dummyDealObjList:
500 
                if super_category == dummyDealObj['category_id']:
501 
                    continue
502 
 
503 
                if super_category ==3:
504 
                    mobile_deals.append(dummyDealObj)
505 
                elif super_category ==5:
506 
                    tablet_deals.append(dummyDealObj)
19559 kshitij.so 507 
                #elif super_category ==6:
508 
                #    accessories_deals.append(dummyDealObj)
17469 kshitij.so 509 
                else:
510 
                    pass
511 
 
17367 kshitij.so 512 
    sortedMapMobiles = {}
513 
    rankMapMobiles = {}
514 
    rankMobiles = 0
515 
 
516 
    blockedRanksMobiles = []
517 
    blockedSkuBundlesMobiles = []
518 
    blockedInfoMobiles = {}
519 
 
520 
    featuredDealsMobiles = featuredDeals.get(3)
521 
 
522 
    for k, v in featuredDealsMobiles.iteritems():
17469 kshitij.so 523 
        blockedRanksMobiles.append(k-1)
524 
        blockedSkuBundlesMobiles.append(v.get('skuBundleId'))
17367 kshitij.so 525 
 
526 
 
527 
    for sorted_deal in mobile_deals:
17369 kshitij.so 528 
 
17367 kshitij.so 529 
        while(True):
530 
            if rankMobiles in blockedRanksMobiles:
531 
                rankMobiles = rankMobiles +1
532 
            else:
533 
                break
534 
 
535 
        if sorted_deal['skuBundleId'] in blockedSkuBundlesMobiles:
536 
            if blockedInfoMobiles.has_key(sorted_deal['skuBundleId']):
537 
                blockedInfoMobiles.get(sorted_deal['skuBundleId']).append(sorted_deal)
538 
            else:
539 
                blockedInfoMobiles[sorted_deal['skuBundleId']] = [sorted_deal]
540 
            continue
541 
 
542 
        if sortedMapMobiles.get(sorted_deal['skuBundleId']) is None:
543 
            sortedMapMobiles[sorted_deal['skuBundleId']] = {rankMobiles:[sorted_deal]}
544 
            rankMapMobiles[rankMobiles] = (sortedMapMobiles[sorted_deal['skuBundleId']].values())[0]
545 
            rankMobiles = rankMobiles +1
546 
        else:
547 
            for temp_list in sortedMapMobiles.get(sorted_deal['skuBundleId']).itervalues():
548 
                temp_list.append(sorted_deal)
549 
            rankMapMobiles[(sortedMapMobiles.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
550 
 
551 
 
552 
    for rank in blockedRanksMobiles:
17369 kshitij.so 553 
        if blockedInfoMobiles.get((featuredDealsMobiles.get(rank+1)).get('skuBundleId')) is not None:
554 
            rankMapMobiles[rank] = blockedInfoMobiles.get((featuredDealsMobiles.get(rank+1)).get('skuBundleId'))
17367 kshitij.so 555 
 
556 
 
557 
    sortedMapTablets = {}
558 
    rankMapTablets = {}
559 
    rankTablets = 0
560 
 
561 
    blockedRanksTablets = []
562 
    blockedSkuBundlesTablets = []
563 
    blockedInfoTablets = {}
564 
 
565 
    featuredDealsTablets = featuredDeals.get(5)
566 
 
567 
 
568 
    for k, v in featuredDealsTablets.iteritems():
17469 kshitij.so 569 
        blockedRanksTablets.append(k-1)
570 
        blockedSkuBundlesTablets.append(v.get('skuBundleId'))
571 
 
17367 kshitij.so 572 
 
573 
    for sorted_deal in tablet_deals:
574 
        while(True):
575 
            if rankTablets in blockedRanksTablets:
576 
                rankTablets = rankTablets +1
577 
            else:
578 
                break
579 
 
580 
        if sorted_deal['skuBundleId'] in blockedSkuBundlesTablets:
581 
            if blockedInfoTablets.has_key(sorted_deal['skuBundleId']):
582 
                blockedInfoTablets.get(sorted_deal['skuBundleId']).append(sorted_deal)
583 
            else:
584 
                blockedInfoTablets[sorted_deal['skuBundleId']] = [sorted_deal]
585 
            continue
586 
 
587 
        if sortedMapTablets.get(sorted_deal['skuBundleId']) is None:
588 
            sortedMapTablets[sorted_deal['skuBundleId']] = {rankTablets:[sorted_deal]}
589 
            rankMapTablets[rankTablets] = (sortedMapTablets[sorted_deal['skuBundleId']].values())[0]
590 
            rankTablets = rankTablets +1
591 
        else:
592 
            for temp_list in sortedMapTablets.get(sorted_deal['skuBundleId']).itervalues():
593 
                temp_list.append(sorted_deal)
594 
            rankMapTablets[(sortedMapTablets.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
595 
 
596 
    for rank in blockedRanksTablets:
17369 kshitij.so 597 
        if blockedInfoTablets.get((featuredDealsTablets.get(rank+1)).get('skuBundleId')) is not None:
598 
            rankMapTablets[rank] = blockedInfoTablets.get((featuredDealsTablets.get(rank+1)).get('skuBundleId'))
17469 kshitij.so 599 
 
17367 kshitij.so 600 
 
19559 kshitij.so 601 
#     sortedMapAccessories = {}
602 
#     rankMapAccessories = {}
603 
#     rankAccessories = 0
604 
#
605 
#     blockedRanksAccessories = []
606 
#     blockedSkuBundlesAccessories = []
607 
#     blockedInfoAccessories = {}
608 
#
609 
#     featuredDealsAccessories = featuredDeals.get(6)
610 
#
611 
#     for k, v in featuredDealsAccessories.iteritems():
612 
#         blockedRanksAccessories.append(k-1)
613 
#         blockedSkuBundlesAccessories.append(v.get('skuBundleId'))
614 
#
615 
#
616 
#     for sorted_deal in accessories_deals:
617 
#
618 
#         while(True):
619 
#             if rankAccessories in blockedRanksAccessories:
620 
#                 rankAccessories = rankAccessories +1
621 
#             else:
622 
#                 break
623 
#
624 
#         if sorted_deal['skuBundleId'] in blockedSkuBundlesAccessories:
625 
#             if blockedInfoAccessories.has_key(sorted_deal['skuBundleId']):
626 
#                 blockedInfoAccessories.get(sorted_deal['skuBundleId']).append(sorted_deal)
627 
#             else:
628 
#                 blockedInfoAccessories[sorted_deal['skuBundleId']] = [sorted_deal]
629 
#             continue
630 
#
631 
#         if sortedMapAccessories.get(sorted_deal['skuBundleId']) is None:
632 
#             sortedMapAccessories[sorted_deal['skuBundleId']] = {rankAccessories:[sorted_deal]}
633 
#             rankMapAccessories[rankAccessories] = (sortedMapAccessories[sorted_deal['skuBundleId']].values())[0]
634 
#             rankAccessories = rankAccessories +1
635 
#         else:
636 
#             for temp_list in sortedMapAccessories.get(sorted_deal['skuBundleId']).itervalues():
637 
#                 temp_list.append(sorted_deal)
638 
#             rankMapAccessories[(sortedMapAccessories.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
639 
#
640 
#
641 
#     for rank in blockedRanksAccessories:
642 
#         if blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId')) is not None:
643 
#             rankMapAccessories[rank] = blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId'))
644 
#
645 
    specialOffer = None
646 
    promoOffer = get_mongo_connection().Catalog.PromoOffer.find_one({'user_id':userId})
647 
    try:
648 
        if promoOffer is not None:
649 
            offer = get_mongo_connection().Catalog.Promotions.find_one({'_id':promoOffer.get('offer_id')})
650 
            if offer is None:
651 
                raise
652 
            promo = Promotion(offer.get('_id'),offer.get('offer_name'),offer.get('offer_description') , offer.get('categories_applicable'), offer.get('sub_categories_not_applicable'),
653 
                     offer.get('startDate'), offer.get('endDate'), promoOffer.get('target1'), promoOffer.get('target1_cash_back_percetage'), promoOffer.get('target2'), promoOffer.get('target2_cash_back_percetage'), promoOffer.get('maxCashBack'),offer.get('url'),
654 
                     promoOffer.get('pending_order_value'), promoOffer.get('delivered_order_value'), promoOffer.get('last_run_timestamp'))
655 
 
656 
            specialOffer = promo
657 
    except:
658 
        traceback.print_exc()
659 
 
660 
 
661 
    mem_cache_val = {3:mobile_deals, 5:tablet_deals,"3_rankMap": rankMapMobiles,"5_rankMap": rankMapTablets, "specialOffer":specialOffer }
662 
    mc.set(str(userId), mem_cache_val)
663 
 
664 
def __populateCacheForAccessories(userId):
665 
    try:
666 
        if mc.get("featured_deals") is None:
667 
            __populateFeaturedDeals()
668 
        featuredDeals = mc.get("featured_deals")
669 
 
670 
    except Exception as e:
671 
        print traceback.print_exc()
672 
        featuredDeals = {3:{},5:{},6:{}}
673 
 
674 
 
675 
    #Not taking into account mobiles, tablets
676 
    featuredDeals.pop(3,None)
677 
    featuredDeals.pop(5,None)
678 
 
679 
    fd_bundles = []
680 
 
681 
    for catMap in featuredDeals.itervalues():
682 
        for fd_map in catMap.itervalues():
683 
            if not fd_map.get('skuBundleId') in fd_bundles:
684 
                fd_bundles.append(fd_map.get('skuBundleId'))
685 
 
686 
    print "Populating accessory memcache for userId",userId
687 
    outer_query = []
688 
    outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })
689 
    query = {}
690 
    query['$gte'] = 0
691 
    outer_query.append({'internalRank':query})
692 
    outer_query.append({'category_id':{"$in":[6]}})
693 
 
694 
    accessories_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'bestSellerPoints':1,'nlcPoints':1,'totalPoints':1,'internalRank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1,'dp':1, 'showDp':1, 'gross_price':1, 'subCategoryId':1,'netPriceAfterCashBack':1}).sort([('internalRank',pymongo.ASCENDING),('bestSellerPoints',pymongo.DESCENDING)]))
695 
 
696 
    actionsMap = {}
697 
 
698 
    actionRank = 3
699 
    for x in session.query(user_actions).filter_by(user_id=userId).order_by(asc(user_actions.created)).all():
700 
        #actionsMap[x.store_product_id] = 1 if x.action == 'like' else 0
701 
        action = 1 if x.action == 'like' else 0
702 
        if action==1:
703 
            actionsMap[x.store_product_id] = {'action':action,'rank':actionRank}
704 
            actionRank = actionRank+3
705 
        else:
706 
            actionsMap[x.store_product_id] = {'action':action,'rank':None}
707 
 
708 
    session.close()
709 
 
710 
    psuedo_count = 1
711 
 
712 
    if actionsMap:
713 
        for k,v in actionsMap.iteritems():
714 
            if v['action'] == 0:
715 
                tmp_deal = get_mongo_connection().Catalog.Deals.find_one({'_id':k})
716 
                if tmp_deal is None:
717 
                    v['rank'] = 999999
718 
                    continue
719 
                max_rank = list(get_mongo_connection().Catalog.Deals.find({'subCategoryId':tmp_deal.get('subCategoryId')}).sort([('internalRank',pymongo.DESCENDING)]).limit(1))
720 
                if len(max_rank) == 0 or max_rank[0].get('internalRank') is None:
721 
                    v['rank'] = 999999
722 
                    continue
723 
                v['rank'] = max_rank[0]['internalRank'] + 1
724 
 
725 
    for deal in accessories_deals:
726 
 
727 
        try:
728 
            fd_bundles.remove(deal.get('skuBundleId'))
729 
        except:
730 
            pass
731 
        if actionsMap and actionsMap.get(deal['_id'])!=None:
732 
            if actionsMap.get(deal['_id']).get('action') ==1:
733 
                actionRank = actionsMap.get(deal['_id']).get('rank')
734 
                if actionRank < psuedo_count:
735 
                    deal['internalRank'] = actionRank
736 
 
737 
            elif actionsMap.get(deal['_id']).get('action') ==0:
738 
                actionRank = actionsMap.get(deal['_id']).get('rank')
739 
                deal['internalRank'] = actionRank
740 
            else:
741 
                pass
742 
        psuedo_count = psuedo_count+1
743 
 
744 
    if actionsMap:
745 
        accessories_deals = sorted(accessories_deals, key = lambda x: (-x['internalRank'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints']),reverse=True)
746 
 
747 
    if len(fd_bundles) > 0:
748 
        print "There is still bundle in feature deals.Lets add info"
749 
        for skuBundleId in fd_bundles:
750 
            dummyDealObjList = __constructDummyDealObject(skuBundleId)
751 
            for dummyDealObj in dummyDealObjList:
752 
                if dummyDealObj['category_id'] ==6:
753 
                    accessories_deals.append(dummyDealObj)
754 
 
755 
    for super_category, categoryFeaturedDeals in featuredDeals.iteritems():
756 
        for val in categoryFeaturedDeals.itervalues():
757 
            dummyDealObjList = __constructDummyDealObject(val.get('skuBundleId'))
758 
            for dummyDealObj in dummyDealObjList:
759 
                if super_category == dummyDealObj['category_id']:
760 
                    continue
761 
                if super_category ==6:
762 
                    accessories_deals.append(dummyDealObj)
763 
 
764 
 
17469 kshitij.so 765 
    sortedMapAccessories = {}
766 
    rankMapAccessories = {}
767 
    rankAccessories = 0
19559 kshitij.so 768 
 
17469 kshitij.so 769 
    blockedRanksAccessories = []
770 
    blockedSkuBundlesAccessories = []
771 
    blockedInfoAccessories = {}
19559 kshitij.so 772 
 
17469 kshitij.so 773 
    featuredDealsAccessories = featuredDeals.get(6)
19559 kshitij.so 774 
 
17469 kshitij.so 775 
    for k, v in featuredDealsAccessories.iteritems():
776 
        blockedRanksAccessories.append(k-1)
777 
        blockedSkuBundlesAccessories.append(v.get('skuBundleId'))
19559 kshitij.so 778 
 
779 
 
17469 kshitij.so 780 
    for sorted_deal in accessories_deals:
19559 kshitij.so 781 
 
17469 kshitij.so 782 
        while(True):
783 
            if rankAccessories in blockedRanksAccessories:
784 
                rankAccessories = rankAccessories +1
785 
            else:
786 
                break
19559 kshitij.so 787 
 
17469 kshitij.so 788 
        if sorted_deal['skuBundleId'] in blockedSkuBundlesAccessories:
789 
            if blockedInfoAccessories.has_key(sorted_deal['skuBundleId']):
790 
                blockedInfoAccessories.get(sorted_deal['skuBundleId']).append(sorted_deal)
791 
            else:
792 
                blockedInfoAccessories[sorted_deal['skuBundleId']] = [sorted_deal]
793 
            continue
19559 kshitij.so 794 
 
17469 kshitij.so 795 
        if sortedMapAccessories.get(sorted_deal['skuBundleId']) is None:
796 
            sortedMapAccessories[sorted_deal['skuBundleId']] = {rankAccessories:[sorted_deal]}
797 
            rankMapAccessories[rankAccessories] = (sortedMapAccessories[sorted_deal['skuBundleId']].values())[0]
798 
            rankAccessories = rankAccessories +1
799 
        else:
800 
            for temp_list in sortedMapAccessories.get(sorted_deal['skuBundleId']).itervalues():
801 
                temp_list.append(sorted_deal)
802 
            rankMapAccessories[(sortedMapAccessories.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
19559 kshitij.so 803 
 
804 
 
17469 kshitij.so 805 
    for rank in blockedRanksAccessories:
806 
        if blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId')) is not None:
807 
            rankMapAccessories[rank] = blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId'))
19559 kshitij.so 808 
 
19288 kshitij.so 809 
    specialOffer = None
810 
    promoOffer = get_mongo_connection().Catalog.PromoOffer.find_one({'user_id':userId})
811 
    try:
812 
        if promoOffer is not None:
813 
            offer = get_mongo_connection().Catalog.Promotions.find_one({'_id':promoOffer.get('offer_id')})
814 
            if offer is None:
815 
                raise
19352 kshitij.so 816 
            promo = Promotion(offer.get('_id'),offer.get('offer_name'),offer.get('offer_description') , offer.get('categories_applicable'), offer.get('sub_categories_not_applicable'),
19331 kshitij.so 817 
                     offer.get('startDate'), offer.get('endDate'), promoOffer.get('target1'), promoOffer.get('target1_cash_back_percetage'), promoOffer.get('target2'), promoOffer.get('target2_cash_back_percetage'), promoOffer.get('maxCashBack'),offer.get('url'),
19350 kshitij.so 818 
                     promoOffer.get('pending_order_value'), promoOffer.get('delivered_order_value'), promoOffer.get('last_run_timestamp'))
17469 kshitij.so 819 
 
19288 kshitij.so 820 
            specialOffer = promo
821 
    except:
19559 kshitij.so 822 
        traceback.print_exc()
19288 kshitij.so 823 
 
824 
 
19559 kshitij.so 825 
    mem_cache_val = {6:accessories_deals,"6_rankMap": rankMapAccessories, "specialOffer":specialOffer }
826 
    mc.set(str(userId)+'_acc', mem_cache_val)
827 
 
14037 kshitij.so 828 
 
829 
 
14531 kshitij.so 830 
def __populateFeaturedDeals():
17367 kshitij.so 831 
    print "Populating featured deals....."
832 
    featuredDealsMobiles = {}
833 
    featuredDealsTablets = {}
17469 kshitij.so 834 
    featuredDealsAccessories = {}
17618 kshitij.so 835 
    activeFeaturedDeals = get_mongo_connection().Catalog.FeaturedDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}})
14531 kshitij.so 836 
    for activeFeaturedDeal in activeFeaturedDeals:
17367 kshitij.so 837 
        deals = get_mongo_connection().Catalog.Deals.find({"skuBundleId":activeFeaturedDeal.get('skuBundleId'),"$or":[{"showDeal":1}, {"prepaidDeal":1}]})
838 
        for deal in deals:
839 
            if deal.get('available_price') <= activeFeaturedDeal.get('thresholdPrice'):
17469 kshitij.so 840 
                for category_id, rank  in activeFeaturedDeal['otherInfo'].iteritems():
841 
                    f_deal = {'skuBundleId':activeFeaturedDeal.get('skuBundleId'), 'thresholdPrice':activeFeaturedDeal.get('thresholdPrice'), 'rank':rank,'category_id':int(category_id),'totalPoints':activeFeaturedDeal.get('totalPoints')}
842 
                    if f_deal['category_id'] == 3:
843 
                        featuredDealsMobiles[rank] = f_deal
844 
                    elif f_deal['category_id']==5:
845 
                        featuredDealsTablets[rank] = f_deal
846 
                    elif f_deal['category_id']==6:
847 
                        featuredDealsAccessories[rank] = f_deal
17367 kshitij.so 848 
                break
17469 kshitij.so 849 
 
850 
#                f_deal = {'skuBundleId':activeFeaturedDeal.get('skuBundleId'), 'thresholdPrice':activeFeaturedDeal.get('thresholdPrice'), 'rank':activeFeaturedDeal.get('rank'),'category_id':activeFeaturedDeal.get('category_id'),'totalPoints':activeFeaturedDeal.get('totalPoints')}
851 
#                 if activeFeaturedDeal.get('category_id') == 3:
852 
#                     featuredDealsMobiles[activeFeaturedDeal.get('rank')] = f_deal
853 
#                 else:
854 
#                     featuredDealsTablets[activeFeaturedDeal.get('rank')] = f_deal
855 
#                 break
856 
 
17367 kshitij.so 857 
 
17469 kshitij.so 858 
    mc.set("featured_deals", {3:featuredDealsMobiles,5:featuredDealsTablets,6:featuredDealsAccessories}, 600)
14037 kshitij.so 859 
 
17618 kshitij.so 860 
def __populateFeaturedDealsForDealObject():
861 
    print "Caching deal objects...."
862 
    featuredDealObjectMobiles = {}
863 
    featuredDealObjectTablets = {}
864 
    featuredDealObjectAccessories = {}
865 
    dealObjects = get_mongo_connection().Catalog.FeaturedDealsDealObject.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}})
866 
    for dealObject in dealObjects:
867 
        d_object = list(get_mongo_connection().Catalog.DealObject.find({'_id':dealObject['_id']}))
868 
        if len(d_object) == 0:
869 
            continue
870 
        for category_id, rank  in dealObject['otherInfo'].iteritems():
871 
            d_object[0]['dealObject'] = 1
19288 kshitij.so 872 
            f_deal = {'rank':rank,'category_id':int(category_id),'object':d_object[0],'offer_id':dealObject.get('offer_id')}
17618 kshitij.so 873 
            if f_deal['category_id'] == 3:
874 
                featuredDealObjectMobiles[rank] = f_deal
875 
            elif f_deal['category_id']==5:
876 
                featuredDealObjectTablets[rank] = f_deal
877 
            elif f_deal['category_id']==6:
878 
                featuredDealObjectAccessories[rank] = f_deal
879 
    mc.set("featured_deals_deal_object", {3:featuredDealObjectMobiles,5:featuredDealObjectTablets,6:featuredDealObjectAccessories}, 600)
17619 kshitij.so 880 
    print mc.get('featured_deals_deal_object')
17618 kshitij.so 881 
 
14791 kshitij.so 882 
def getNewDeals(userId, category_id, offset, limit, sort, direction, filterData=None):
17469 kshitij.so 883 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
13921 kshitij.so 884 
        populateCashBack()
14037 kshitij.so 885 
 
16079 kshitij.so 886 
    dealsListMap = []
14037 kshitij.so 887 
    user_specific_deals = mc.get(str(userId))
888 
    if user_specific_deals is None:
889 
        __populateCache(userId)
890 
        user_specific_deals = mc.get(str(userId))
14038 kshitij.so 891 
    else:
892 
        print "Getting user deals from cache"
14037 kshitij.so 893 
    category_specific_deals = user_specific_deals.get(category_id)
894 
 
17367 kshitij.so 895 
    insert_featured_deals = False
14037 kshitij.so 896 
    if sort is None or direction is None:
17367 kshitij.so 897 
        insert_featured_deals = True
898 
        rankMap = user_specific_deals.get(str(category_id)+"_rankMap")
14037 kshitij.so 899 
    else:
900 
        if sort == "bestSellerPoints":
901 
            sorted_deals = sorted(category_specific_deals, key = lambda x: (x['bestSellerPoints'], x['rank'], x['nlcPoints']),reverse=True)
902 
        else:
903 
            if direction == -1:
904 
                rev = True
905 
            else:
906 
                rev = False
907 
            sorted_deals = sorted(category_specific_deals, key = lambda x: (x['available_price']),reverse=rev)
908 
 
14791 kshitij.so 909 
 
17367 kshitij.so 910 
    filtered_deals = []
17668 kshitij.so 911 
    dataExist = True
14791 kshitij.so 912 
    if filterData is not None:
913 
        try:
17669 kshitij.so 914 
            filtered_deals = filterDeals(category_specific_deals, filterData)
915 
            if len(filtered_deals)==0:
916 
                dataExist = False
14791 kshitij.so 917 
        except:
16067 kshitij.so 918 
            traceback.print_exc()
17668 kshitij.so 919 
    if dataExist:
14791 kshitij.so 920 
 
17668 kshitij.so 921 
        if not insert_featured_deals:
922 
            sortedMap = {}
923 
            rankMap = {}
924 
            rank = 0
925 
            for sorted_deal in sorted_deals:
926 
 
927 
                if len(filtered_deals) > 0 and  sorted_deal['skuBundleId'] not in filtered_deals:
928 
                    continue
929 
 
930 
                if sortedMap.get(sorted_deal['skuBundleId']) is None:
931 
                    sortedMap[sorted_deal['skuBundleId']] = {rank:[sorted_deal]}
932 
                    rankMap[rank] = (sortedMap[sorted_deal['skuBundleId']].values())[0]
933 
                    rank = rank +1
934 
                else:
935 
                    for temp_list in sortedMap.get(sorted_deal['skuBundleId']).itervalues():
936 
                        temp_list.append(sorted_deal)
937 
                    rankMap[(sortedMap.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
938 
        else:
939 
            filterMap = {}
940 
            rank = 0
941 
            if len(filtered_deals) > 0:
942 
                try:
943 
                    od = collections.OrderedDict(sorted(rankMap.items()))
944 
                except:
945 
                    od = ordereddict.OrderedDict(sorted(rankMap.items()))
946 
                for k, v in od.iteritems():
947 
                    if v[0].get('skuBundleId') in filtered_deals:
948 
                        filterMap[rank] = v
949 
                        rank =rank+1
950 
                rankMap = filterMap
951 
 
952 
        rankCounter = offset
953 
        if filterData is None:
954 
            if mc.get("featured_deals_deal_object") is None or not bool(mc.get("featured_deals_deal_object")):
955 
                try:
956 
                    __populateFeaturedDealsForDealObject()
957 
                    fd_dealObject = mc.get("featured_deals_deal_object")
958 
                except:
959 
                    fd_dealObject = {3:{},5:{},6:{}}
17367 kshitij.so 960 
            else:
17668 kshitij.so 961 
                fd_dealObject = mc.get("featured_deals_deal_object")
962 
 
17367 kshitij.so 963 
    else:
17668 kshitij.so 964 
        rankMap = {}
17618 kshitij.so 965 
 
19288 kshitij.so 966 
 
967 
    specialOffer = user_specific_deals.get('specialOffer')
968 
 
17627 kshitij.so 969 
    for dealList in [rankMap.get(k, []) for k in range(offset, offset+limit)]:
17629 kshitij.so 970 
        if filterData is None:
17627 kshitij.so 971 
            while(True):
972 
 
973 
                rankCounter = rankCounter+1
974 
                if (fd_dealObject.get(category_id).get(rankCounter)) is not None:
19288 kshitij.so 975 
                    if (fd_dealObject.get(category_id).get(rankCounter).get('offer_id') !=0):
976 
                        #Check whether user can see offer
19518 manas 977 
                        if specialOffer is None or specialOffer.endDate < to_java_date(datetime.now()):
19288 kshitij.so 978 
                            continue
19334 kshitij.so 979 
                    deal_object_temp = []
980 
                    deal_object_temp.append(fd_dealObject.get(category_id).get(rankCounter).get('object'))
981 
                    dealsListMap.append(deal_object_temp)
17627 kshitij.so 982 
                else:
983 
                    break
17620 kshitij.so 984 
 
16079 kshitij.so 985 
        temp = []
17367 kshitij.so 986 
        if dealList is None or len(dealList)==0:
987 
            continue
16067 kshitij.so 988 
        for d in dealList:
989 
            item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
16320 kshitij.so 990 
            if len(item) ==0:
991 
                continue
16079 kshitij.so 992 
            item[0]['persPoints'] = d['persPoints']
993 
            if d['dealType'] == 1 and d['source_id'] ==1:
16511 kshitij.so 994 
                try:
995 
                    manualDeal = list(get_mongo_connection().Catalog.ManualDeals.find({'sku':d['_id'],'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}}))
996 
                    item[0]['marketPlaceUrl'] = manualDeal[0]['dealUrl'].strip()
997 
                except:
998 
                    pass
16079 kshitij.so 999 
            elif d['source_id'] ==3:
1000 
                item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')
1001 
            else:
1002 
                pass
1003 
            try:
1004 
                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
1005 
                if not cashBack or cashBack.get('cash_back_status')!=1:
14037 kshitij.so 1006 
                    item[0]['cash_back_type'] = 0
1007 
                    item[0]['cash_back'] = 0
16079 kshitij.so 1008 
                else:
17180 kshitij.so 1009 
                    if cashBack.get('maxCashBack') is not None:
1010 
 
1011 
                        if cashBack.get('cash_back_type') ==1 and (float(cashBack.get('cash_back'))*item[0]['available_price'])/100 > cashBack.get('maxCashBack'):
1012 
                            cashBack['cash_back_type'] = 2
1013 
                            cashBack['cash_back'] = cashBack['maxCashBack']
1014 
                        elif cashBack.get('cash_back_type') ==2 and cashBack.get('cash_back') > cashBack.get('maxCashBack'):
1015 
                            cashBack['cash_back'] = cashBack['maxCashBack']
1016 
 
16079 kshitij.so 1017 
                    item[0]['cash_back_type'] = int(cashBack['cash_back_type'])
1018 
                    item[0]['cash_back'] = cashBack['cash_back']
1019 
            except:
1020 
                print "Error in adding cashback to deals"
1021 
                item[0]['cash_back_type'] = 0
1022 
                item[0]['cash_back'] = 0
16252 kshitij.so 1023 
            try:
1024 
                item[0]['dp'] = d['dp']
1025 
                item[0]['showDp'] = d['showDp']
1026 
            except:
1027 
                item[0]['dp'] = 0.0
1028 
                item[0]['showDp'] = 0
16483 kshitij.so 1029 
            try:
1030 
                item[0]['thumbnail'] = item[0]['thumbnail'].strip()
1031 
            except:
17115 manish.sha 1032 
                pass
17603 kshitij.so 1033 
 
1034 
            try:
1035 
                if item[0]['showVideo']==0:
1036 
                    item[0]['videoLink'] =""
1037 
            except:
1038 
                item[0]['videoLink'] =""
17937 kshitij.so 1039 
            try:
1040 
                if item[0]['quantity'] >1:
1041 
                    ppq = float(item[0]['available_price'])/item[0]['quantity']
1042 
 
1043 
                    if ppq == round(ppq):
1044 
                        item[0]['ppq'] = int(ppq)
1045 
                    else:
1046 
                        item[0]['ppq'] = round(ppq,2)
1047 
                else:
1048 
                    item[0]['ppq'] = 0
1049 
            except:
1050 
                item[0]['ppq'] = 0
17627 kshitij.so 1051 
            if filterData is None:
17679 kshitij.so 1052 
                if item[0]['category_id']!=6:
1053 
                    try:
18830 kshitij.so 1054 
                        item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
1055 
                        item[0]['filterTextBrand'] = (item[0]['brand'])
17679 kshitij.so 1056 
                    except:
18830 kshitij.so 1057 
                        pass
17679 kshitij.so 1058 
                else:
1059 
                    try:
17756 kshitij.so 1060 
                        if item[0]['subCategory']=='' or item[0]['subCategory'] is None or item[0]['subCategoryId']==0:
17679 kshitij.so 1061 
                            raise
18830 kshitij.so 1062 
                        item[0]['filterLinkSubCategory'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['subCategory'])+'&filter=subcategory&subcategories='+str(int(item[0]['subCategoryId']))
1063 
                        item[0]['filterTextSubCategory'] = (item[0]['subCategory'])
1064 
                        item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
1065 
                        item[0]['filterTextBrand'] = (item[0]['brand'])
17679 kshitij.so 1066 
                    except:
18830 kshitij.so 1067 
                        pass
17771 kshitij.so 1068 
            try:
1069 
                if item[0]['source_id']==4:
1070 
                    item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
1071 
                    if item_availability_info is None or len(item_availability_info)==0:
1072 
                        item[0]['availabilityInfo'] = [{}]
1073 
                    else:
1074 
                        item[0]['availabilityInfo'] = item_availability_info
1075 
            except:
1076 
                item[0]['availabilityInfo'] = [{}]
19193 kshitij.so 1077 
 
1078 
            if item[0]['source_id']==4:
1079 
                for av_info in item[0]['availabilityInfo']:
1080 
                    if not av_info:
1081 
                        continue
1082 
                    av_info['cash_back'] = item[0]['cash_back']
1083 
                    av_info['cash_back_type'] = item[0]['cash_back_type']
1084 
                    netPriceAfterCashBack = av_info['sellingPrice']
19199 kshitij.so 1085 
                    if av_info['cash_back_type'] ==1:
19207 kshitij.so 1086 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(float(av_info['sellingPrice'])*av_info['cash_back']/100)
19199 kshitij.so 1087 
                    elif av_info['cash_back_type'] ==2:
19207 kshitij.so 1088 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(av_info['cash_back'])
19193 kshitij.so 1089 
                    else:
1090 
                        pass
1091 
                    av_info['netPriceAfterCashBack'] = netPriceAfterCashBack
1092 
 
1093 
            #item[0]['netPriceAfterCashBack'] = d['netPriceAfterCashBack']
1094 
 
1095 
            if item[0]['source_id'] != SOURCE_MAP.get("PAYTM.COM"):
1096 
                if item[0]['codAvailable'] ==1:
1097 
                    paytmPrice = item[0]['available_price']
1098 
                else:
1099 
                    paytmPrice = item[0]['gross_price']
1100 
 
1101 
                if item[0]['cash_back_type'] ==1:
19207 kshitij.so 1102 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(float(paytmPrice)*item[0]['cash_back']/100)
19193 kshitij.so 1103 
                elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 1104 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(item[0]['cash_back'])
19193 kshitij.so 1105 
                else:
1106 
                    item[0]['netPriceAfterCashBack'] = paytmPrice
1107 
 
1108 
            else:
1109 
                if item[0]['cash_back_type'] ==1:
19207 kshitij.so 1110 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(float(item[0]['available_price'])*item[0]['cash_back']/100)
19193 kshitij.so 1111 
                elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 1112 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(item[0]['cash_back'])
19193 kshitij.so 1113 
                else:
1114 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price']
1115 
 
19559 kshitij.so 1116 
            temp.append(item[0])
1117 
        if len(temp) > 1:
1118 
            temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)
1119 
        dealsListMap.append(temp)
1120 
    return dealsListMap
1121 
 
1122 
 
1123 
def getAccesoryDeals(userId, category_id, offset, limit, sort, direction, filterData=None):
1124 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
1125 
        populateCashBack()
1126 
 
1127 
    dealsListMap = []
1128 
    user_specific_deals = mc.get(str(userId)+'_acc')
1129 
    if user_specific_deals is None:
1130 
        __populateCacheForAccessories(userId)
1131 
        user_specific_deals = mc.get(str(userId)+'_acc')
1132 
    else:
1133 
        print "Getting user deals from accessory cache"
1134 
    category_specific_deals = user_specific_deals.get(category_id)
1135 
 
1136 
    insert_featured_deals = False
1137 
    if sort is None or direction is None:
1138 
        insert_featured_deals = True
1139 
        rankMap = user_specific_deals.get(str(category_id)+"_rankMap")
1140 
    else:
1141 
        if sort == "bestSellerPoints":
1142 
            sorted_deals = sorted(category_specific_deals, key = lambda x: (x['bestSellerPoints'], x['internalRank'], x['nlcPoints']),reverse=True)
1143 
        else:
1144 
            if direction == -1:
1145 
                rev = True
1146 
            else:
1147 
                rev = False
1148 
            sorted_deals = sorted(category_specific_deals, key = lambda x: (x['available_price']),reverse=rev)
1149 
 
1150 
 
1151 
    filtered_deals = []
1152 
    dataExist = True
1153 
    if filterData is not None:
1154 
        try:
1155 
            filtered_deals = filterDeals(category_specific_deals, filterData)
1156 
            if len(filtered_deals)==0:
1157 
                dataExist = False
1158 
        except:
1159 
            traceback.print_exc()
1160 
    if dataExist:
1161 
 
1162 
        if not insert_featured_deals:
1163 
            sortedMap = {}
1164 
            rankMap = {}
1165 
            rank = 0
1166 
            for sorted_deal in sorted_deals:
1167 
 
1168 
                if len(filtered_deals) > 0 and  sorted_deal['skuBundleId'] not in filtered_deals:
1169 
                    continue
1170 
 
1171 
                if sortedMap.get(sorted_deal['skuBundleId']) is None:
1172 
                    sortedMap[sorted_deal['skuBundleId']] = {rank:[sorted_deal]}
1173 
                    rankMap[rank] = (sortedMap[sorted_deal['skuBundleId']].values())[0]
1174 
                    rank = rank +1
1175 
                else:
1176 
                    for temp_list in sortedMap.get(sorted_deal['skuBundleId']).itervalues():
1177 
                        temp_list.append(sorted_deal)
1178 
                    rankMap[(sortedMap.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
1179 
        else:
1180 
            filterMap = {}
1181 
            rank = 0
1182 
            if len(filtered_deals) > 0:
1183 
                try:
1184 
                    od = collections.OrderedDict(sorted(rankMap.items()))
1185 
                except:
1186 
                    od = ordereddict.OrderedDict(sorted(rankMap.items()))
1187 
                for k, v in od.iteritems():
1188 
                    if v[0].get('skuBundleId') in filtered_deals:
1189 
                        filterMap[rank] = v
1190 
                        rank =rank+1
1191 
                rankMap = filterMap
1192 
 
1193 
        rankCounter = offset
1194 
        if filterData is None:
1195 
            if mc.get("featured_deals_deal_object") is None or not bool(mc.get("featured_deals_deal_object")):
1196 
                try:
1197 
                    __populateFeaturedDealsForDealObject()
1198 
                    fd_dealObject = mc.get("featured_deals_deal_object")
1199 
                except:
1200 
                    fd_dealObject = {3:{},5:{},6:{}}
1201 
            else:
1202 
                fd_dealObject = mc.get("featured_deals_deal_object")
1203 
 
1204 
    else:
1205 
        rankMap = {}
1206 
 
1207 
 
1208 
    specialOffer = user_specific_deals.get('specialOffer')
1209 
 
1210 
    for dealList in [rankMap.get(k, []) for k in range(offset, offset+limit)]:
1211 
        if filterData is None:
1212 
            while(True):
1213 
 
1214 
                rankCounter = rankCounter+1
1215 
                if (fd_dealObject.get(category_id).get(rankCounter)) is not None:
1216 
                    if (fd_dealObject.get(category_id).get(rankCounter).get('offer_id') !=0):
1217 
                        #Check whether user can see offer
1218 
                        if specialOffer is None or specialOffer.endDate < to_java_date(datetime.now()):
1219 
                            continue
1220 
                    deal_object_temp = []
1221 
                    deal_object_temp.append(fd_dealObject.get(category_id).get(rankCounter).get('object'))
1222 
                    dealsListMap.append(deal_object_temp)
1223 
                else:
1224 
                    break
1225 
 
1226 
        temp = []
1227 
        if dealList is None or len(dealList)==0:
1228 
            continue
1229 
        for d in dealList:
1230 
            item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
1231 
            if len(item) ==0:
1232 
                continue
1233 
            if d['dealType'] == 1 and d['source_id'] ==1:
1234 
                try:
1235 
                    manualDeal = list(get_mongo_connection().Catalog.ManualDeals.find({'sku':d['_id'],'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}}))
1236 
                    item[0]['marketPlaceUrl'] = manualDeal[0]['dealUrl'].strip()
1237 
                except:
1238 
                    pass
1239 
            elif d['source_id'] ==3:
1240 
                item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')
1241 
            else:
1242 
                pass
1243 
            try:
1244 
                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
1245 
                if not cashBack or cashBack.get('cash_back_status')!=1:
1246 
                    item[0]['cash_back_type'] = 0
1247 
                    item[0]['cash_back'] = 0
1248 
                else:
1249 
                    if cashBack.get('maxCashBack') is not None:
1250 
 
1251 
                        if cashBack.get('cash_back_type') ==1 and (float(cashBack.get('cash_back'))*item[0]['available_price'])/100 > cashBack.get('maxCashBack'):
1252 
                            cashBack['cash_back_type'] = 2
1253 
                            cashBack['cash_back'] = cashBack['maxCashBack']
1254 
                        elif cashBack.get('cash_back_type') ==2 and cashBack.get('cash_back') > cashBack.get('maxCashBack'):
1255 
                            cashBack['cash_back'] = cashBack['maxCashBack']
1256 
 
1257 
                    item[0]['cash_back_type'] = int(cashBack['cash_back_type'])
1258 
                    item[0]['cash_back'] = cashBack['cash_back']
1259 
            except:
1260 
                print "Error in adding cashback to deals"
1261 
                item[0]['cash_back_type'] = 0
1262 
                item[0]['cash_back'] = 0
1263 
            try:
1264 
                item[0]['dp'] = d['dp']
1265 
                item[0]['showDp'] = d['showDp']
1266 
            except:
1267 
                item[0]['dp'] = 0.0
1268 
                item[0]['showDp'] = 0
1269 
            try:
1270 
                item[0]['thumbnail'] = item[0]['thumbnail'].strip()
1271 
            except:
1272 
                pass
1273 
 
1274 
            try:
1275 
                if item[0]['showVideo']==0:
1276 
                    item[0]['videoLink'] =""
1277 
            except:
1278 
                item[0]['videoLink'] =""
1279 
            try:
1280 
                if item[0]['quantity'] >1:
1281 
                    ppq = float(item[0]['available_price'])/item[0]['quantity']
1282 
 
1283 
                    if ppq == round(ppq):
1284 
                        item[0]['ppq'] = int(ppq)
1285 
                    else:
1286 
                        item[0]['ppq'] = round(ppq,2)
1287 
                else:
1288 
                    item[0]['ppq'] = 0
1289 
            except:
1290 
                item[0]['ppq'] = 0
1291 
            if filterData is None:
1292 
                if item[0]['category_id']!=6:
1293 
                    try:
1294 
                        item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
1295 
                        item[0]['filterTextBrand'] = (item[0]['brand'])
1296 
                    except:
1297 
                        pass
1298 
                else:
1299 
                    try:
1300 
                        if item[0]['subCategory']=='' or item[0]['subCategory'] is None or item[0]['subCategoryId']==0:
1301 
                            raise
1302 
                        item[0]['filterLinkSubCategory'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['subCategory'])+'&filter=subcategory&subcategories='+str(int(item[0]['subCategoryId']))
1303 
                        item[0]['filterTextSubCategory'] = (item[0]['subCategory'])
1304 
                        item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
1305 
                        item[0]['filterTextBrand'] = (item[0]['brand'])
1306 
                    except:
1307 
                        pass
1308 
            try:
1309 
                if item[0]['source_id']==4:
1310 
                    item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
1311 
                    if item_availability_info is None or len(item_availability_info)==0:
1312 
                        item[0]['availabilityInfo'] = [{}]
1313 
                    else:
1314 
                        item[0]['availabilityInfo'] = item_availability_info
1315 
            except:
1316 
                item[0]['availabilityInfo'] = [{}]
1317 
 
1318 
            if item[0]['source_id']==4:
1319 
                for av_info in item[0]['availabilityInfo']:
1320 
                    if not av_info:
1321 
                        continue
1322 
                    av_info['cash_back'] = item[0]['cash_back']
1323 
                    av_info['cash_back_type'] = item[0]['cash_back_type']
1324 
                    netPriceAfterCashBack = av_info['sellingPrice']
1325 
                    if av_info['cash_back_type'] ==1:
1326 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(float(av_info['sellingPrice'])*av_info['cash_back']/100)
1327 
                    elif av_info['cash_back_type'] ==2:
1328 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(av_info['cash_back'])
1329 
                    else:
1330 
                        pass
1331 
                    av_info['netPriceAfterCashBack'] = netPriceAfterCashBack
1332 
 
1333 
            #item[0]['netPriceAfterCashBack'] = d['netPriceAfterCashBack']
1334 
 
1335 
            if item[0]['source_id'] != SOURCE_MAP.get("PAYTM.COM"):
1336 
                if item[0]['codAvailable'] ==1:
1337 
                    paytmPrice = item[0]['available_price']
1338 
                else:
1339 
                    paytmPrice = item[0]['gross_price']
1340 
 
1341 
                if item[0]['cash_back_type'] ==1:
1342 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(float(paytmPrice)*item[0]['cash_back']/100)
1343 
                elif item[0]['cash_back_type'] ==2:
1344 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(item[0]['cash_back'])
1345 
                else:
1346 
                    item[0]['netPriceAfterCashBack'] = paytmPrice
1347 
 
1348 
            else:
1349 
                if item[0]['cash_back_type'] ==1:
1350 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(float(item[0]['available_price'])*item[0]['cash_back']/100)
1351 
                elif item[0]['cash_back_type'] ==2:
1352 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(item[0]['cash_back'])
1353 
                else:
1354 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price']
1355 
 
19320 kshitij.so 1356 
#             if specialOffer is not None and item[0]['source_id']==4:
1357 
#                 if item[0]['category_id'] in specialOffer.categories_applicable and item[0]['subCategoryId'] not in specialOffer.sub_categories_not_applicable:
1358 
#                     item[0]['specialOffer'] = specialOffer.__dict__
1359 
#             else:
1360 
#                 item[0]['specialOffer'] = {}
19288 kshitij.so 1361 
 
16079 kshitij.so 1362 
            temp.append(item[0])
16125 kshitij.so 1363 
        if len(temp) > 1:
16126 kshitij.so 1364 
            temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)
16079 kshitij.so 1365 
        dealsListMap.append(temp)
1366 
    return dealsListMap
14037 kshitij.so 1367 
 
19559 kshitij.so 1368 
 
14791 kshitij.so 1369 
def filterDeals(deals, filterData):
17658 kshitij.so 1370 
    print "Filter data ", filterData
14791 kshitij.so 1371 
    brandsFiltered = []
17657 kshitij.so 1372 
    subCategoryFiltered = []
14791 kshitij.so 1373 
    filterArray = filterData.split('|')
1374 
    for data in filterArray:
1375 
        try:
1376 
            filter, info = data.split(':')
1377 
        except Exception as ex:
1378 
            traceback.print_exc()
1379 
            continue
17657 kshitij.so 1380 
        if filter == 'brandFilter':
14791 kshitij.so 1381 
            toFilter = info.split('^')
1382 
            print "brand filter ",toFilter
1383 
            for deal in deals:
15151 kshitij.so 1384 
                if str(int(deal['brand_id'])) in toFilter:
14791 kshitij.so 1385 
                    brandsFiltered.append(deal)
17657 kshitij.so 1386 
        elif filter =='subCategoryFilter':
1387 
            toFilter = info.split('^')
1388 
            print "Sub Category filter ",toFilter
1389 
            for deal in deals:
1390 
                if str(int(deal['subCategoryId'])) in toFilter:
1391 
                    subCategoryFiltered.append(deal)
17668 kshitij.so 1392 
    print "No of brand filtered ",len(brandsFiltered)
1393 
    print "No of sub-cat filtered ",len(subCategoryFiltered)
17657 kshitij.so 1394 
    if len(subCategoryFiltered) == 0:
17367 kshitij.so 1395 
        return [trend['skuBundleId'] for trend in brandsFiltered]
17663 kshitij.so 1396 
    elif len(brandsFiltered) == 0:
1397 
        return [trend['skuBundleId'] for trend in subCategoryFiltered]
17669 kshitij.so 1398 
    return [i['skuBundleId'] for i in subCategoryFiltered for j in brandsFiltered if i['_id']==j['_id']]
14791 kshitij.so 1399 
 
1400 
 
14037 kshitij.so 1401 
def getDeals(userId, category_id, offset, limit, sort, direction):
17469 kshitij.so 1402 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
14037 kshitij.so 1403 
        populateCashBack()
1404 
    rank = 1
13771 kshitij.so 1405 
    deals = {}
13910 kshitij.so 1406 
    outer_query = []
1407 
    outer_query.append({"showDeal":1})
1408 
    query = {}
1409 
    query['$gt'] = 0
1410 
    outer_query.append({'totalPoints':query})
1411 
    if category_id in (3,5):
1412 
        outer_query.append({'category_id':category_id})
13803 kshitij.so 1413 
    if sort is None or direction is None:
1414 
        direct = -1
13910 kshitij.so 1415 
        print outer_query
1416 
        data = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query}).sort([('totalPoints',direct),('bestSellerPoints',direct),('nlcPoints',direct),('rank',direct)]).skip(offset).limit(limit))
13795 kshitij.so 1417 
    else:
13910 kshitij.so 1418 
        print outer_query
13803 kshitij.so 1419 
        direct = direction
13910 kshitij.so 1420 
        if sort == "bestSellerPoints":
1421 
            print "yes,sorting by bestSellerPoints"
1422 
            data = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query}).sort([('bestSellerPoints',direct),('rank',direct),('nlcPoints',direct)]).skip(offset).limit(limit))
1423 
        else:
1424 
            data = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query}).sort([(sort,direct)]).skip(offset).limit(limit))
13771 kshitij.so 1425 
    for d in data:
1426 
        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
1427 
        if not deals.has_key(item[0]['identifier']):
13921 kshitij.so 1428 
            item[0]['dealRank'] = rank
1429 
            try:
14761 kshitij.so 1430 
                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
13921 kshitij.so 1431 
                if not cashBack or cashBack.get('cash_back_status')!=1:
13928 kshitij.so 1432 
                    item[0]['cash_back_type'] = 0
1433 
                    item[0]['cash_back'] = 0
13921 kshitij.so 1434 
                else:
14766 kshitij.so 1435 
                    item[0]['cash_back_type'] = int(cashBack['cash_back_type'])
13928 kshitij.so 1436 
                    item[0]['cash_back'] = cashBack['cash_back']
13921 kshitij.so 1437 
            except:
1438 
                print "Error in adding cashback to deals"
13928 kshitij.so 1439 
                item[0]['cash_back_type'] = 0
1440 
                item[0]['cash_back'] = 0
13771 kshitij.so 1441 
            deals[item[0]['identifier']] = item[0]
13921 kshitij.so 1442 
 
13771 kshitij.so 1443 
            rank +=1
13785 kshitij.so 1444 
    return sorted(deals.values(), key=itemgetter('dealRank'))
1445 
 
16222 kshitij.so 1446 
def getItem(skuId,showDp=None):
16224 kshitij.so 1447 
    temp = []
17469 kshitij.so 1448 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
14113 kshitij.so 1449 
        populateCashBack()
13795 kshitij.so 1450 
    try:
16222 kshitij.so 1451 
        skuData = get_mongo_connection().Catalog.MasterData.find_one({'_id':int(skuId)})
1452 
        if skuData is None:
1453 
            raise
1454 
        try:
1455 
            cashBack = getCashBack(skuData['_id'], skuData['source_id'], skuData['category_id'])
1456 
            if not cashBack or cashBack.get('cash_back_status')!=1:
1457 
                skuData['cash_back_type'] = 0
1458 
                skuData['cash_back'] = 0
1459 
            else:
1460 
                skuData['cash_back_type'] = cashBack['cash_back_type']
1461 
                skuData['cash_back'] = cashBack['cash_back']
1462 
        except:
1463 
            print "Error in adding cashback to deals"
1464 
            skuData['cash_back_type'] = 0
1465 
            skuData['cash_back'] = 0
1466 
        skuData['in_stock'] = int(skuData['in_stock'])
1467 
        skuData['is_shortage'] = int(skuData['is_shortage'])
1468 
        skuData['category_id'] = int(skuData['category_id'])
17607 kshitij.so 1469 
        skuData['subCategoryId'] = int(skuData['subCategoryId'])
16222 kshitij.so 1470 
        skuData['status'] = int(skuData['status'])
16483 kshitij.so 1471 
        try:
1472 
            skuData['thumbnail'] = skuData['thumbnail'].strip()
1473 
        except:
1474 
            pass
16222 kshitij.so 1475 
        if showDp is not None:
1476 
            dealerPrice = get_mongo_connection().Catalog.SkuDealerPrices.find_one({'skuBundleId':skuData['skuBundleId']})
1477 
            skuData['dp'] = 0.0
1478 
            skuData['showDp'] = 0
1479 
            if dealerPrice is not None:
1480 
                skuData['dp'] = dealerPrice['dp']
1481 
                skuData['showDp'] = dealerPrice['showDp']
16224 kshitij.so 1482 
        temp.append(skuData)
1483 
        return temp
13795 kshitij.so 1484 
    except:
16224 kshitij.so 1485 
        return []
13836 kshitij.so 1486 
 
14761 kshitij.so 1487 
def getCashBack(skuId, source_id, category_id):
17469 kshitij.so 1488 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
14761 kshitij.so 1489 
        populateCashBack()
1490 
    itemCashBackMap = mc.get("item_cash_back")
13921 kshitij.so 1491 
    itemCashBack = itemCashBackMap.get(skuId)
1492 
    if itemCashBack is not None:
1493 
        return itemCashBack
14761 kshitij.so 1494 
    cashBackMap = mc.get("category_cash_back")
13921 kshitij.so 1495 
    sourceCashBack = cashBackMap.get(source_id)
1496 
    if sourceCashBack is not None and len(sourceCashBack) > 0:
1497 
        for cashBack in sourceCashBack:
1498 
            if cashBack.get(category_id) is None:
1499 
                continue
1500 
            else:
1501 
                return cashBack.get(category_id)
1502 
    else:
1503 
        return {}
16560 amit.gupta 1504 
 
1505 
def getBundleBySourceSku(source_id, identifier):
17035 kshitij.so 1506 
    if source_id in (1,2,4,5,6,7):
16560 amit.gupta 1507 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
1508 
    elif source_id == 3:
1509 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'secondaryIdentifier':identifier.strip(), 'source_id':source_id}))
1510 
    else:
1511 
        return {}
1512 
 
1513 
    if not skuData:
1514 
        return {}
1515 
    else:
16564 amit.gupta 1516 
        bundleId = skuData[0]["skuBundleId"]
17035 kshitij.so 1517 
        itemIds = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':bundleId, 'in_stock':1, 'source_id':{"$in":[1,2,3,5,6,7]}},
16580 amit.gupta 1518 
                       {"source_id":1, "available_price":1, "marketPlaceUrl":1, "gross_price":1, "codAvailable":1, "source_product_name":1, "offer":1, "coupon":1}))
16579 amit.gupta 1519 
        return {'products':itemIds}
16560 amit.gupta 1520 
 
1521 
 
13921 kshitij.so 1522 
 
15129 kshitij.so 1523 
def getDealRank(identifier, source_id, userId):
17035 kshitij.so 1524 
    if source_id in (1,2,4,5,6,7):
15129 kshitij.so 1525 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
1526 
    elif source_id == 3:
1527 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'secondaryIdentifier':identifier.strip(), 'source_id':source_id}))
1528 
    else:
16282 amit.gupta 1529 
        return {'rank':0, 'description':'Source not valid','maxNlc':None, 'minNlc':None,'status':None,'dp':None}
15349 kshitij.so 1530 
    if len(skuData) == 0:
16282 amit.gupta 1531 
        return {'rank':0, 'description':'No matching product identifier found','maxNlc':None, 'minNlc':None,'status':None,'dp':None}
15129 kshitij.so 1532 
    user_specific_deals = mc.get(str(userId))
1533 
    if user_specific_deals is None:
1534 
        __populateCache(userId)
1535 
        user_specific_deals = mc.get(str(userId))
1536 
    else:
1537 
        print "Getting user deals from cache"
1538 
    category_id = skuData[0]['category_id']
1539 
    category_specific_deals = user_specific_deals.get(category_id)
16280 kshitij.so 1540 
 
1541 
    dealsData = get_mongo_connection().Catalog.Deals.find_one({'skuBundleId':skuData[0]['skuBundleId']})
1542 
    if dealsData is None:
1543 
        dealsData = {}
1544 
 
15129 kshitij.so 1545 
    if category_specific_deals is None or len(category_specific_deals) ==0:
16280 kshitij.so 1546 
        return {'rank':0,'description':'Category specific deals is empty','maxNlc':dealsData.get('maxNlc'),'minNlc':dealsData.get('minNlc'),'status':dealsData.get('status'),'dp':dealsData.get('dp')}
15129 kshitij.so 1547 
    sorted_deals = sorted(category_specific_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
16168 kshitij.so 1548 
    sortedMap = {}
1549 
    rankMap = {}
1550 
    rank = 0
15129 kshitij.so 1551 
    for sorted_deal in sorted_deals:
16168 kshitij.so 1552 
        if sortedMap.get(sorted_deal['skuBundleId']) is None:
1553 
            sortedMap[sorted_deal['skuBundleId']] = {rank:[sorted_deal]}
1554 
            rankMap[rank] = (sortedMap[sorted_deal['skuBundleId']].values())[0]
1555 
            rank = rank +1
1556 
        else:
1557 
            for temp_list in sortedMap.get(sorted_deal['skuBundleId']).itervalues():
1558 
                temp_list.append(sorted_deal)
1559 
            rankMap[(sortedMap.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
1560 
 
16187 kshitij.so 1561 
    for dealRank ,dealList in rankMap.iteritems():
16168 kshitij.so 1562 
        for d in dealList:
16186 kshitij.so 1563 
            if d['skuBundleId'] == skuData[0]['skuBundleId']:
16280 kshitij.so 1564 
                return {'rank':dealRank+1,'description':'Rank found','maxNlc':dealsData.get('maxNlc'),'minNlc':dealsData.get('minNlc'),'status':dealsData.get('status'),'dp':dealsData.get('dp')}
16168 kshitij.so 1565 
 
16280 kshitij.so 1566 
    return {'rank':0,'description':'Rank not found','maxNlc':dealsData.get('maxNlc'),'minNlc':dealsData.get('minNlc'),'status':dealsData.get('status'),'dp':dealsData.get('dp')}
15129 kshitij.so 1567 
 
1568 
 
13836 kshitij.so 1569 
def getCashBackDetails(identifier, source_id):
17469 kshitij.so 1570 
    if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
13921 kshitij.so 1571 
        populateCashBack()
13771 kshitij.so 1572 
 
17035 kshitij.so 1573 
    if source_id in (1,2,4,5,6,7):
13839 kshitij.so 1574 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
13840 kshitij.so 1575 
    elif source_id == 3:
13839 kshitij.so 1576 
        skuData = list(get_mongo_connection().Catalog.MasterData.find({'secondaryIdentifier':identifier.strip(), 'source_id':source_id}))
13840 kshitij.so 1577 
    else:
1578 
        return {}
13836 kshitij.so 1579 
    if len(skuData) > 0:
14761 kshitij.so 1580 
        itemCashBackMap = mc.get("item_cash_back")
13921 kshitij.so 1581 
        itemCashBack = itemCashBackMap.get(skuData[0]['_id'])
1582 
        if itemCashBack is not None:
1583 
            return itemCashBack
14761 kshitij.so 1584 
        cashBackMap = mc.get("category_cash_back")
13921 kshitij.so 1585 
        sourceCashBack = cashBackMap.get(source_id)
1586 
        if sourceCashBack is not None and len(sourceCashBack) > 0:
1587 
            for cashBack in sourceCashBack:
1588 
                if cashBack.get(skuData[0]['category_id']) is None:
1589 
                    continue
1590 
                else:
1591 
                    return cashBack.get(skuData[0]['category_id'])
13836 kshitij.so 1592 
        else:
1593 
            return {}
1594 
    else:
1595 
        return {}
13986 amit.gupta 1596 
 
14398 amit.gupta 1597 
def getImgSrc(identifier, source_id):
1598 
    skuData = None
17035 kshitij.so 1599 
    if source_id in (1,2,4,5,6,7):
14414 amit.gupta 1600 
        skuData = get_mongo_connection().Catalog.MasterData.find_one({'identifier':identifier.strip(), 'source_id':source_id})
14398 amit.gupta 1601 
    elif source_id == 3:
14414 amit.gupta 1602 
        skuData = get_mongo_connection().Catalog.MasterData.find_one({'secondaryIdentifier':identifier.strip(), 'source_id':source_id})
14398 amit.gupta 1603 
    if skuData is None:
1604 
        return {}
1605 
    else:
16483 kshitij.so 1606 
        try:
1607 
            return {'thumbnail':skuData.get('thumbnail').strip()}
1608 
        except:
1609 
            return {'thumbnail':skuData.get('thumbnail')}
13986 amit.gupta 1610 
 
1611 
def next_weekday(d, weekday):
1612 
    days_ahead = weekday - d.weekday()
1613 
    if days_ahead <= 0: # Target day already happened this week
1614 
        days_ahead += 7
1615 
    return d + timedelta(days_ahead)
1616 
 
13771 kshitij.so 1617 
 
13970 kshitij.so 1618 
def getAllDealerPrices(offset, limit):
1619 
    data = []
1620 
    collection = get_mongo_connection().Catalog.SkuDealerPrices
1621 
    cursor = collection.find().skip(offset).limit(limit)
1622 
    for val in cursor:
15853 kshitij.so 1623 
        master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':val['skuBundleId']})
1624 
        if master is not None:
1625 
            val['brand'] = master['brand']
1626 
            val['source_product_name'] = master['source_product_name']
13970 kshitij.so 1627 
        else:
1628 
            val['brand'] = ""
1629 
            val['source_product_name'] = ""
16231 kshitij.so 1630 
        val['showDp'] = int(val['showDp'])
13970 kshitij.so 1631 
        data.append(val)
1632 
    return data
1633 
 
15853 kshitij.so 1634 
def addSkuDealerPrice(data):
1635 
    collection = get_mongo_connection().Catalog.SkuDealerPrices
1636 
    cursor = collection.find_one({"skuBundleId":data['skuBundleId']})
1637 
    if cursor is not None:
1638 
        return {0:"BundleId information already present."}
13970 kshitij.so 1639 
    else:
15853 kshitij.so 1640 
        collection.insert(data)
1641 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13970 kshitij.so 1642 
        return {1:"Data added successfully"}
1643 
 
1644 
def updateSkuDealerPrice(data, _id):
1645 
    try:
1646 
        collection = get_mongo_connection().Catalog.SkuDealerPrices
1647 
        collection.update({'_id':ObjectId(_id)},{"$set":{'dp':data['dp']}},upsert=False, multi = False)
15853 kshitij.so 1648 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13970 kshitij.so 1649 
        return {1:"Data updated successfully"}
1650 
    except:
1651 
        return {0:"Data not updated."}
1652 
 
1653 
def updateExceptionalNlc(data, _id):
1654 
    try:
1655 
        collection = get_mongo_connection().Catalog.ExceptionalNlc
1656 
        collection.update({'_id':ObjectId(_id)},{"$set":{'maxNlc':data['maxNlc'], 'minNlc':data['minNlc'], 'overrideNlc':data['overrideNlc']}},upsert=False, multi = False)
15853 kshitij.so 1657 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
13970 kshitij.so 1658 
        return {1:"Data updated successfully"}
1659 
    except:
1660 
        return {0:"Data not updated."}
1661 
 
14041 kshitij.so 1662 
def resetCache(userId):
14043 kshitij.so 1663 
    try:
1664 
        mc.delete(userId)
19559 kshitij.so 1665 
        mc.delete(userId+'_acc')
14043 kshitij.so 1666 
        return {1:'Cache cleared.'}
1667 
    except:
1668 
        return {0:'Unable to clear cache.'}
1669 
 
15853 kshitij.so 1670 
def updateCollection(data):
1671 
    try:
1672 
        collection = get_mongo_connection().Catalog[data['class']]
1673 
        class_name = data.pop('class')
1674 
        _id = data.pop('oid')
1675 
        result = collection.update({'_id':ObjectId(_id)},{"$set":data},upsert=False, multi = False)
1676 
        if class_name != "Notifications":
1677 
            record = list(collection.find({'_id':ObjectId(_id)}))
1678 
            if class_name !="CategoryDiscount":
1679 
                if record[0].has_key('sku'):
1680 
                    field = '_id'
1681 
                    val = record[0]['sku']
14852 kshitij.so 1682 
                else:
15853 kshitij.so 1683 
                    field = 'skuBundleId'
1684 
                    val = record[0]['skuBundleId']
1685 
                get_mongo_connection().Catalog.MasterData.update({field:val},{"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False, multi = True)
1686 
            else:
1687 
                get_mongo_connection().Catalog.MasterData.update({'brand':re.compile(record[0]['brand'], re.IGNORECASE),'category_id':record[0]['category_id']}, \
1688 
                                                                 {"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
16233 kshitij.so 1689 
        if class_name =='SkuDealerPrices':
16237 kshitij.so 1690 
            get_mongo_connection().Catalog.Deals.update({'skuBundleId':val},{"$set":data},upsert=False, multi=True)
15853 kshitij.so 1691 
        return {1:"Data updated successfully"}
1692 
    except Exception as e:
1693 
        print e
1694 
        return {0:"Data not updated."}
14575 kshitij.so 1695 
 
14076 kshitij.so 1696 
 
14553 kshitij.so 1697 
def addNegativeDeals(data, multi):
1698 
    if multi !=1:
1699 
        collection = get_mongo_connection().Catalog.NegativeDeals
1700 
        cursor = collection.find({"sku":data['sku']})
1701 
        if cursor.count() > 0:
1702 
            return {0:"Sku information already present."}
1703 
        else:
1704 
            collection.insert(data)
1705 
            return {1:"Data added successfully"}
14481 kshitij.so 1706 
    else:
14553 kshitij.so 1707 
        skuIds = __getBundledSkusfromSku(data['sku'])
1708 
        for sku in skuIds:
1709 
            data['sku'] = sku.get('_id')
1710 
            collection = get_mongo_connection().Catalog.NegativeDeals
1711 
            cursor = collection.find({"sku":data['sku']})
1712 
            if cursor.count() > 0:
1713 
                continue
1714 
            else:
14558 kshitij.so 1715 
                data.pop('_id',None)
14553 kshitij.so 1716 
                collection.insert(data)
14481 kshitij.so 1717 
        return {1:"Data added successfully"}
1718 
 
1719 
def getAllNegativeDeals(offset, limit):
1720 
    data = []
1721 
    collection = get_mongo_connection().Catalog.NegativeDeals
1722 
    cursor = collection.find().skip(offset).limit(limit)
1723 
    for val in cursor:
1724 
        master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))
1725 
        if len(master) > 0:
1726 
            val['brand'] = master[0]['brand']
1727 
            val['source_product_name'] = master[0]['source_product_name']
1728 
            val['skuBundleId'] = master[0]['skuBundleId']
1729 
        else:
1730 
            val['brand'] = ""
1731 
            val['source_product_name'] = ""
1732 
            val['skuBundleId'] = ""
1733 
        data.append(val)
1734 
    return data
1735 
 
1736 
def getAllManualDeals(offset, limit):
1737 
    data = []
1738 
    collection = get_mongo_connection().Catalog.ManualDeals
15090 kshitij.so 1739 
    cursor = collection.find().skip(offset).limit(limit)
14481 kshitij.so 1740 
    for val in cursor:
1741 
        master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))
1742 
        if len(master) > 0:
1743 
            val['brand'] = master[0]['brand']
1744 
            val['source_product_name'] = master[0]['source_product_name']
1745 
            val['skuBundleId'] = master[0]['skuBundleId']
1746 
        else:
1747 
            val['brand'] = ""
1748 
            val['source_product_name'] = ""
1749 
            val['skuBundleId'] = ""
1750 
        data.append(val)
1751 
    return data
14076 kshitij.so 1752 
 
14553 kshitij.so 1753 
def addManualDeal(data, multi):
1754 
    if multi !=1:
1755 
        collection = get_mongo_connection().Catalog.ManualDeals
15090 kshitij.so 1756 
        cursor = collection.find({'sku':data['sku']})
14553 kshitij.so 1757 
        if cursor.count() > 0:
1758 
            return {0:"Sku information already present."}
1759 
        else:
1760 
            collection.insert(data)
1761 
            get_mongo_connection().Catalog.MasterData.update({'_id':data['sku']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=False)
1762 
            return {1:"Data added successfully"}
14481 kshitij.so 1763 
    else:
14553 kshitij.so 1764 
        skuIds = __getBundledSkusfromSku(data['sku'])
1765 
        for sku in skuIds:
1766 
            data['sku'] = sku.get('_id')
1767 
            collection = get_mongo_connection().Catalog.ManualDeals
15090 kshitij.so 1768 
            cursor = collection.find({'sku':data['sku']})
14553 kshitij.so 1769 
            if cursor.count() > 0:
1770 
                continue
1771 
            else:
14558 kshitij.so 1772 
                data.pop('_id',None)
14553 kshitij.so 1773 
                collection.insert(data)
1774 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':sku.get('skuBundleId')},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
14481 kshitij.so 1775 
        return {1:"Data added successfully"}
14553 kshitij.so 1776 
 
14481 kshitij.so 1777 
def deleteDocument(data):
15853 kshitij.so 1778 
    print "inside detete document"
14481 kshitij.so 1779 
    print data
1780 
    try:
1781 
        collection = get_mongo_connection().Catalog[data['class']]
1782 
        class_name = data.pop('class')
1783 
        _id = data.pop('oid')
1784 
        record = list(collection.find({'_id':ObjectId(_id)}))
1785 
        collection.remove({'_id':ObjectId(_id)})
15075 kshitij.so 1786 
        if class_name != "Notifications":
1787 
            if class_name !="CategoryDiscount":
15853 kshitij.so 1788 
                print record[0]
1789 
                if record[0].has_key('sku'):
1790 
                    field = '_id'
1791 
                    val = record[0]['sku']
1792 
                else:
1793 
                    field = 'skuBundleId'
1794 
                    val = record[0]['skuBundleId']
1795 
                print "Updating master"
1796 
                print field
1797 
                print val
1798 
                get_mongo_connection().Catalog.MasterData.update({field:val},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
15075 kshitij.so 1799 
            else:
1800 
                get_mongo_connection().Catalog.MasterData.update({'brand':re.compile(record[0]['brand'], re.IGNORECASE),'category_id':record[0]['category_id']}, \
1801 
                                                                 {"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
14481 kshitij.so 1802 
        return {1:"Document deleted successfully"}
1803 
    except Exception as e:
1804 
        print e
1805 
        return {0:"Document not deleted."}
13970 kshitij.so 1806 
 
14482 kshitij.so 1807 
def searchMaster(offset, limit, search_term):
1808 
    data = []
14531 kshitij.so 1809 
    if search_term is not None:
14551 kshitij.so 1810 
        terms = search_term.split(' ')
1811 
        outer_query = []
1812 
        for term in terms:
1813 
            outer_query.append({"source_product_name":re.compile(term, re.IGNORECASE)})
14531 kshitij.so 1814 
        try:
14551 kshitij.so 1815 
            collection = get_mongo_connection().Catalog.MasterData.find({"$and":outer_query,'source_id':{'$in':SOURCE_MAP.keys()}}).skip(offset).limit(limit)
14531 kshitij.so 1816 
            for record in collection:
1817 
                data.append(record)
1818 
        except:
1819 
            pass
1820 
    else:
1821 
        collection = get_mongo_connection().Catalog.MasterData.find({'source_id':{'$in':SOURCE_MAP.keys()}}).skip(offset).limit(limit)
14482 kshitij.so 1822 
        for record in collection:
1823 
            data.append(record)
1824 
    return data
14481 kshitij.so 1825 
 
14495 kshitij.so 1826 
def getAllFeaturedDeals(offset, limit):
1827 
    data = []
1828 
    collection = get_mongo_connection().Catalog.FeaturedDeals
17561 kshitij.so 1829 
    cursor = collection.find({}).skip(offset).limit(limit)
14495 kshitij.so 1830 
    for val in cursor:
17367 kshitij.so 1831 
        master = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':val['skuBundleId']}))
14495 kshitij.so 1832 
        if len(master) > 0:
1833 
            val['brand'] = master[0]['brand']
1834 
            val['source_product_name'] = master[0]['source_product_name']
1835 
            val['skuBundleId'] = master[0]['skuBundleId']
1836 
        else:
1837 
            val['brand'] = ""
1838 
            val['source_product_name'] = ""
1839 
            val['skuBundleId'] = ""
1840 
        data.append(val)
1841 
    return data
1842 
 
14553 kshitij.so 1843 
def addFeaturedDeal(data, multi):
17367 kshitij.so 1844 
    collection = get_mongo_connection().Catalog.FeaturedDeals
1845 
    cursor = collection.find({'skuBundleId':data['skuBundleId']})
1846 
    master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':data['skuBundleId']})
1847 
    if master is None:
1848 
        return {0:"BundleId is wrong"}
17469 kshitij.so 1849 
    otherInfoObj = data['otherInfo']
1850 
    toPop = []
1851 
    for x,y in otherInfoObj.iteritems():
1852 
        if y==0:
1853 
            toPop.append(x)
1854 
 
1855 
    for popItem in toPop:
1856 
        otherInfoObj.pop(popItem)
1857 
    if len(otherInfoObj.keys())==0:
1858 
        return {0:"No rank info to add"}
1859 
 
1860 
    for x,y in otherInfoObj.iteritems():
1861 
        exist = get_mongo_connection().Catalog.FeaturedDeals.find({'otherInfo.'+x:y})
1862 
        if exist.count() >0:
1863 
            return {0:"Rank already assigned bundleId %s"%(exist[0]['skuBundleId'])}
17367 kshitij.so 1864 
    if cursor.count() > 0:
1865 
        return {0:"SkuBundleId information already present."}
14495 kshitij.so 1866 
    else:
17367 kshitij.so 1867 
        collection.insert(data)
14495 kshitij.so 1868 
        return {1:"Data added successfully"}
1869 
 
14499 kshitij.so 1870 
def searchCollection(class_name, sku, skuBundleId):
14497 kshitij.so 1871 
    data = []
1872 
    collection = get_mongo_connection().Catalog[class_name]
15076 kshitij.so 1873 
    if class_name == "Notifications":
1874 
        cursor = collection.find({'skuBundleId':skuBundleId})
1875 
        for val in cursor:
1876 
            master = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':val['skuBundleId']}))
1877 
            if len(master) > 0:
1878 
                val['brand'] = master[0]['brand']
1879 
                val['model_name'] = master[0]['model_name']
1880 
                val['skuBundleId'] = master[0]['skuBundleId']
1881 
            else:
1882 
                val['brand'] = ""
1883 
                val['model_name'] = ""
1884 
                val['skuBundleId'] = val['skuBundleId']
1885 
            data.append(val)
15095 kshitij.so 1886 
        return data
15853 kshitij.so 1887 
    master = None
14499 kshitij.so 1888 
    if sku is not None:
15853 kshitij.so 1889 
        if COLLECTION_MAP.has_key(class_name):
1890 
            master = get_mongo_connection().Catalog.MasterData.find_one({'_id':sku})
1891 
            cursor = collection.find({'skuBundleId':master['skuBundleId']})
1892 
        else:
1893 
            cursor = collection.find({'sku':sku})
14499 kshitij.so 1894 
        for val in cursor:
15853 kshitij.so 1895 
            if master is None:
1896 
                master = get_mongo_connection().Catalog.MasterData.find_one({'_id':val['sku']})
1897 
            if master is not None:
1898 
                val['brand'] = master['brand']
1899 
                val['source_product_name'] = master['source_product_name']
1900 
                val['skuBundleId'] = master['skuBundleId']
14499 kshitij.so 1901 
            else:
1902 
                val['brand'] = ""
1903 
                val['source_product_name'] = ""
1904 
                val['skuBundleId'] = ""
1905 
            data.append(val)
1906 
        return data
1907 
    else:
15853 kshitij.so 1908 
        if not COLLECTION_MAP.has_key(class_name):
1909 
            skuIds = get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId}).distinct('_id')
1910 
            for sku in skuIds:
1911 
                cursor = collection.find({'sku':sku})
1912 
                for val in cursor:
1913 
                    master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))
1914 
                    if len(master) > 0:
1915 
                        val['brand'] = master[0]['brand']
1916 
                        val['source_product_name'] = master[0]['source_product_name']
1917 
                        val['skuBundleId'] = master[0]['skuBundleId']
1918 
                    else:
1919 
                        val['brand'] = ""
1920 
                        val['source_product_name'] = ""
1921 
                        val['skuBundleId'] = ""
1922 
                    data.append(val)
1923 
            return data
1924 
        else:
1925 
            cursor = collection.find({'skuBundleId':skuBundleId})
14499 kshitij.so 1926 
            for val in cursor:
15853 kshitij.so 1927 
                master = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':val['skuBundleId']}))
14499 kshitij.so 1928 
                if len(master) > 0:
1929 
                    val['brand'] = master[0]['brand']
1930 
                    val['source_product_name'] = master[0]['source_product_name']
1931 
                else:
1932 
                    val['brand'] = ""
1933 
                    val['source_product_name'] = ""
1934 
                data.append(val)
15853 kshitij.so 1935 
            return data
14495 kshitij.so 1936 
 
15074 kshitij.so 1937 
def __getBrandIdForBrand(brandName, category_id):
1938 
    brandInfo = Brands.query.filter(Brands.category_id==category_id).filter(Brands.name == brandName).all()
1939 
    if brandInfo is None or len(brandInfo)!=1:
1940 
        raise
1941 
    else:
1942 
        return brandInfo[0].id
1943 
 
14588 kshitij.so 1944 
def addNewItem(data):
14594 kshitij.so 1945 
    try:
1946 
        data['updatedOn'] = to_java_date(datetime.now())
1947 
        data['addedOn'] = to_java_date(datetime.now())
1948 
        data['priceUpdatedOn'] = to_java_date(datetime.now())
1949 
        max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
1950 
        max_bundle = list(get_mongo_connection().Catalog.MasterData.find().sort([('skuBundleId',pymongo.DESCENDING)]).limit(1))
1951 
        data['_id'] = max_id[0]['_id'] + 1
1952 
        data['skuBundleId'] = max_bundle[0]['skuBundleId'] + 1
1953 
        data['identifier'] = str(data['identifier'])
1954 
        data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
17115 manish.sha 1955 
        data['model_name'] = str(data['model_name'])
15074 kshitij.so 1956 
        data['brand_id'] = __getBrandIdForBrand(data['brand'], data['category_id'])
17746 kshitij.so 1957 
        data['shippingCost'] = float(data['shippingCost'])
19559 kshitij.so 1958 
        data['internalRank'] = int(data['internalRank'])
17603 kshitij.so 1959 
        if data['category_id'] ==6 and data['subCategoryId'] ==0:
17606 kshitij.so 1960 
            return {0:'Sub-Category not selected'}
17608 kshitij.so 1961 
        elif data['category_id'] !=6 and data['subCategoryId'] !=0:
1962 
            return {0:'Sub-Category not valid'}
1963 
        else:
1964 
            pass
17604 kshitij.so 1965 
        data['subCategory'] = SUB_CATEGORY_MAP.get(data['subCategoryId'])
14594 kshitij.so 1966 
        get_mongo_connection().Catalog.MasterData.insert(data)
1967 
        return {1:'Data added successfully'}
1968 
    except Exception as e:
1969 
        print e
1970 
        return {0:'Unable to add data.'}
15130 kshitij.so 1971 
    finally:
1972 
        session.close()
14588 kshitij.so 1973 
 
1974 
def addItemToExistingBundle(data):
1975 
    try:
1976 
        data['updatedOn'] = to_java_date(datetime.now())
1977 
        data['addedOn'] = to_java_date(datetime.now())
1978 
        data['priceUpdatedOn'] = to_java_date(datetime.now())
14593 kshitij.so 1979 
        max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
14590 kshitij.so 1980 
        data['_id'] = max_id[0]['_id'] + 1
14594 kshitij.so 1981 
        data['identifier'] = str(data['identifier'])
1982 
        data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
17115 manish.sha 1983 
        data['model_name'] = str(data['model_name'])
15074 kshitij.so 1984 
        data['brand_id'] = __getBrandIdForBrand(data['brand'], data['category_id'])
17746 kshitij.so 1985 
        data['shippingCost'] = float(data['shippingCost'])
19559 kshitij.so 1986 
        data['internalRank'] = int(data['internalRank'])
17603 kshitij.so 1987 
        if data['category_id'] ==6 and data['subCategoryId'] ==0:
17606 kshitij.so 1988 
            return {0:'Sub-Category not selected'}
17608 kshitij.so 1989 
        elif data['category_id'] !=6 and data['subCategoryId'] !=0:
1990 
            return {0:'Sub-Category not valid'}
1991 
        else:
1992 
            pass
17604 kshitij.so 1993 
        data['subCategory'] = SUB_CATEGORY_MAP.get(data['subCategoryId'])
14588 kshitij.so 1994 
        get_mongo_connection().Catalog.MasterData.insert(data)
1995 
        return {1:'Data added successfully.'}
14594 kshitij.so 1996 
    except Exception as e:
1997 
        print e
14588 kshitij.so 1998 
        return {0:'Unable to add data.'}
15130 kshitij.so 1999 
    finally:
2000 
        session.close()
14588 kshitij.so 2001 
 
2002 
def updateMaster(data, multi):
15130 kshitij.so 2003 
    try:
2004 
        print data
2005 
        if multi != 1:
2006 
            _id = data.pop('_id')
2007 
            skuBundleId = data.pop('skuBundleId')
2008 
            data['updatedOn'] = to_java_date(datetime.now())
2009 
            data['identifier'] = str(data['identifier'])
2010 
            data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
17115 manish.sha 2011 
            data['model_name'] = str(data['model_name'])
17746 kshitij.so 2012 
            data['shippingCost'] = float(data['shippingCost'])
19559 kshitij.so 2013 
            data['internalRank'] = int(data['internalRank'])
15130 kshitij.so 2014 
            data['brand_id'] = __getBrandIdForBrand(data['brand'], data['category_id'])
17603 kshitij.so 2015 
            if data['category_id'] ==6 and data['subCategoryId'] ==0:
17606 kshitij.so 2016 
                return {0:'Sub-Category not selected'}
17608 kshitij.so 2017 
            elif data['category_id'] !=6 and data['subCategoryId'] !=0:
2018 
                return {0:'Sub-Category not valid'}
2019 
            else:
2020 
                pass
17604 kshitij.so 2021 
            data['subCategory'] = SUB_CATEGORY_MAP.get(data['subCategoryId'])
15130 kshitij.so 2022 
            get_mongo_connection().Catalog.MasterData.update({'_id':_id},{"$set":data},upsert=False)
19559 kshitij.so 2023 
            get_mongo_connection().Catalog.MasterData.update({'skuBundleId':skuBundleId},{"$set":{'internalRank':data['internalRank']}},upsert=False, multi=True)
15130 kshitij.so 2024 
            return {1:'Data updated successfully.'}
2025 
        else:
2026 
            _id = data.pop('_id')
2027 
            skuBundleId = data.pop('skuBundleId')
2028 
            data['updatedOn'] = to_java_date(datetime.now())
2029 
            data['identifier'] = str(data['identifier'])
2030 
            data['secondaryIdentifier'] = str(data['secondaryIdentifier'])
2031 
            data['brand_id'] = __getBrandIdForBrand(data['brand'], data['category_id'])
17115 manish.sha 2032 
            data['model_name'] = str(data['model_name'])
17746 kshitij.so 2033 
            data['shippingCost'] = float(data['shippingCost'])
19559 kshitij.so 2034 
            data['internalRank'] = int(data['internalRank'])
17603 kshitij.so 2035 
            if data['category_id'] ==6 and data['subCategoryId'] ==0:
17606 kshitij.so 2036 
                return {0:'Sub-Category not selected'}
17608 kshitij.so 2037 
            elif data['category_id'] !=6 and data['subCategoryId'] !=0:
2038 
                return {0:'Sub-Category not valid'}
2039 
            else:
2040 
                pass
17604 kshitij.so 2041 
            data['subCategory'] = SUB_CATEGORY_MAP.get(data['subCategoryId'])
15130 kshitij.so 2042 
            get_mongo_connection().Catalog.MasterData.update({'_id':_id},{"$set":data},upsert=False)
2043 
            similarItems = get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId})
2044 
            for item in similarItems:
2045 
                if item['_id'] == _id:
2046 
                    continue
2047 
                item['updatedOn'] = to_java_date(datetime.now())
2048 
                item['thumbnail'] = data['thumbnail']
2049 
                item['category'] = data['category']
2050 
                item['category_id'] = data['category_id']
2051 
                item['is_shortage'] = data['is_shortage']
2052 
                item['mrp'] = data['mrp']
2053 
                item['status'] = data['status']
2054 
                item['maxPrice'] = data['maxPrice']
2055 
                item['brand_id'] = data['brand_id']
17603 kshitij.so 2056 
                item['subCategoryId'] = data['subCategoryId']
2057 
                item['subCategory'] = data['subCategory']
19559 kshitij.so 2058 
                item['internalRank'] = data['internalRank']
15130 kshitij.so 2059 
                similar_item_id = item.pop('_id')
2060 
                get_mongo_connection().Catalog.MasterData.update({'_id':similar_item_id},{"$set":item},upsert=False)
2061 
            return {1:'Data updated successfully.'}
17603 kshitij.so 2062 
    except:
2063 
        return {0:'Unable to update data'}
15130 kshitij.so 2064 
    finally:
2065 
        session.close()
14619 kshitij.so 2066 
 
2067 
def getLiveCricScore():
2068 
    return mc.get('liveScore')
14852 kshitij.so 2069 
 
2070 
def addBundleToNotification(data):
2071 
    try:
15069 kshitij.so 2072 
        collection = get_mongo_connection().Catalog.Notifications
14852 kshitij.so 2073 
        cursor = collection.find({'skuBundleId':data['skuBundleId']})
2074 
        if cursor.count() > 0:
2075 
            return {0:"SkuBundleId information already present."}
2076 
        else:
2077 
            collection.insert(data)
2078 
            return {1:'Data updated successfully.'}
2079 
    except:
2080 
        return {0:'Unable to add data.'}
2081 
 
2082 
def getAllNotifications(offset, limit):
2083 
    data = []
15069 kshitij.so 2084 
    collection = get_mongo_connection().Catalog.Notifications
16450 kshitij.so 2085 
    cursor = collection.find().sort([('endDate',pymongo.DESCENDING)]).skip(offset).limit(limit)
14852 kshitij.so 2086 
    for val in cursor:
15072 kshitij.so 2087 
        master = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':val['skuBundleId']}))
14852 kshitij.so 2088 
        if len(master) > 0:
2089 
            val['brand'] = master[0]['brand']
15071 kshitij.so 2090 
            val['model_name'] = master[0]['model_name']
14852 kshitij.so 2091 
            val['skuBundleId'] = master[0]['skuBundleId']
2092 
        else:
2093 
            val['brand'] = ""
15071 kshitij.so 2094 
            val['model_name'] = ""
2095 
            val['skuBundleId'] = val['skuBundleId']
14852 kshitij.so 2096 
        data.append(val)
2097 
    return data
14997 kshitij.so 2098 
 
2099 
def getBrandsForFilter(category_id):
2100 
    if mc.get("brandFilter") is None:
15095 kshitij.so 2101 
        print "Populating brand data for category_id %d" %(category_id)
17469 kshitij.so 2102 
        tabData, mobData, accData = [], [], []
14997 kshitij.so 2103 
        mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([
16170 kshitij.so 2104 
                                                                      {"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gt":-100}}
14997 kshitij.so 2105 
                                                                    },
2106 
                                                                 {"$group" :
2107 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
2108 
                                                                  }
2109 
                                                                ])
14588 kshitij.so 2110 
 
14997 kshitij.so 2111 
        tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([
16170 kshitij.so 2112 
                                                                      {"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gt":-100}}
14997 kshitij.so 2113 
                                                                    },
2114 
                                                                 {"$group" :
2115 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
2116 
                                                                  }
2117 
                                                                ])
2118 
 
17469 kshitij.so 2119 
        accessoriesDeals = get_mongo_connection().Catalog.Deals.aggregate([
2120 
                                                                      {"$match":{"category_id":6,"showDeal":1,"totalPoints":{"$gt":-100}}
2121 
                                                                    },
2122 
                                                                 {"$group" :
2123 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
2124 
                                                                  }
2125 
                                                                ])
2126 
 
14997 kshitij.so 2127 
        allDeals = get_mongo_connection().Catalog.Deals.aggregate([
16170 kshitij.so 2128 
                                                                   {"$match":{"showDeal":1,"totalPoints":{"$gt":-100}}
14997 kshitij.so 2129 
                                                                    },
2130 
                                                                 {"$group" :
2131 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
2132 
                                                                  }
2133 
                                                                ])
2134 
        #print mobileDeals
2135 
        #print "==========Mobile data ends=========="
2136 
 
2137 
        #print tabletDeals
2138 
        #print "==========Tablet data ends=========="
2139 
 
2140 
        #print allDeals
2141 
        #print "==========All deal data ends========="
2142 
 
2143 
        for mobileDeal in mobileDeals['result']:
2144 
            if mobileDeal.get('_id').get('brand_id') != 0:
2145 
                tempMap = {}
2146 
                tempMap['brand'] = mobileDeal.get('_id').get('brand')
2147 
                tempMap['brand_id'] = mobileDeal.get('_id').get('brand_id')
2148 
                tempMap['count'] = mobileDeal.get('count')
2149 
                mobData.append(tempMap)
2150 
 
2151 
        for tabletDeal in tabletDeals['result']:
2152 
            if tabletDeal.get('_id').get('brand_id') != 0:
2153 
                tempMap = {}
2154 
                tempMap['brand'] = tabletDeal.get('_id').get('brand')
2155 
                tempMap['brand_id'] = tabletDeal.get('_id').get('brand_id')
2156 
                tempMap['count'] = tabletDeal.get('count')
2157 
                tabData.append(tempMap)
2158 
 
17469 kshitij.so 2159 
        for accessoryDeal in accessoriesDeals['result']:
2160 
            if accessoryDeal.get('_id').get('brand_id') != 0:
2161 
                tempMap = {}
2162 
                tempMap['brand'] = accessoryDeal.get('_id').get('brand')
2163 
                tempMap['brand_id'] = accessoryDeal.get('_id').get('brand_id')
2164 
                tempMap['count'] = accessoryDeal.get('count')
2165 
                accData.append(tempMap)
14997 kshitij.so 2166 
 
17469 kshitij.so 2167 
 
14997 kshitij.so 2168 
        brandMap = {}
2169 
        for allDeal in allDeals['result']:
2170 
            if allDeal.get('_id').get('brand_id') != 0:
2171 
                if brandMap.has_key(allDeal.get('_id').get('brand')):
15002 kshitij.so 2172 
                    brand_ids = brandMap.get(allDeal.get('_id').get('brand')).get('brand_ids')
14997 kshitij.so 2173 
                    brand_ids.append(allDeal.get('_id').get('brand_id'))
15003 kshitij.so 2174 
                    brandMap[allDeal.get('_id').get('brand')] = {'brand_ids':brand_ids,'count':brandMap.get(allDeal.get('_id').get('brand')).get('count') + allDeal.get('count')}
14997 kshitij.so 2175 
                else:
2176 
                    temp = []
2177 
                    temp.append(allDeal.get('_id').get('brand_id'))
15002 kshitij.so 2178 
                    brandMap[allDeal.get('_id').get('brand')] = {'brand_ids':temp,'count':allDeal.get('count')}
14997 kshitij.so 2179 
 
17469 kshitij.so 2180 
        mc.set("brandFilter",{0:brandMap, 3:mobData, 5:tabData, 6:accData}, 600)
14997 kshitij.so 2181 
 
15062 kshitij.so 2182 
    return sorted(mc.get("brandFilter").get(category_id), key = lambda x: (-x['count'], x['brand']))
15375 kshitij.so 2183 
 
15459 kshitij.so 2184 
def getStaticDeals(offset, limit, category_id, direction):
15375 kshitij.so 2185 
    user_specific_deals = mc.get("staticDeals")
2186 
    if user_specific_deals is None:
2187 
        __populateStaticDeals()
2188 
        user_specific_deals = mc.get("staticDeals")
15459 kshitij.so 2189 
    rev = False
2190 
    if direction is None or direction == -1:
2191 
        rev=True
2192 
    return sorted((user_specific_deals.get(category_id))[offset:offset+limit],reverse=rev)
15375 kshitij.so 2193 
 
2194 
def __populateStaticDeals():
2195 
    print "Populating memcache for static deals"
2196 
    outer_query = []
2197 
    outer_query.append({"showDeal":1})
2198 
    query = {}
16170 kshitij.so 2199 
    query['$gt'] = -100
15375 kshitij.so 2200 
    outer_query.append({'totalPoints':query})
2201 
    all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))
2202 
    mobile_deals = []
2203 
    tablet_deals = []
2204 
    for deal in all_deals:
2205 
        item = get_mongo_connection().Catalog.MasterData.find({'_id':deal['_id']})
2206 
        if deal['category_id'] ==3:
2207 
            mobile_deals.append(getItemObjForStaticDeals(item[0]))
2208 
        elif deal['category_id'] ==5:
2209 
            tablet_deals.append(getItemObjForStaticDeals(item[0]))
2210 
        else:
2211 
            continue
2212 
 
2213 
    random.shuffle(mobile_deals,random.random)
2214 
    random.shuffle(tablet_deals,random.random)
2215 
 
2216 
    mem_cache_val = {3:mobile_deals, 5:tablet_deals}
2217 
    mc.set("staticDeals", mem_cache_val, 3600)
2218 
 
17733 kshitij.so 2219 
def getItemObjForStaticDeals(item,transform=None):
2220 
    mpu = str(item.get('marketPlaceUrl'))
2221 
    if transform:
2222 
        if mpu.find("snapdeal")!=-1:
2223 
            mpu = "http://m.snapdeal.com"+mpu[mpu.find("/product"):]
2224 
        elif mpu.find("homeshop18")!=-1:
2225 
            mpu = "http://m.homeshop18.com/product.mobi?productId="+item['identifier']
17735 kshitij.so 2226 
        elif mpu.find("saholic.com")!=-1:
17746 kshitij.so 2227 
            mpu = "http://m."+mpu[mpu.find("saholic.com"):]
17735 kshitij.so 2228 
        elif mpu.find("shopclues.com")!=-1:
17733 kshitij.so 2229 
            mpu = "http://m."+mpu[mpu.find("shopclues.com"):]
2230 
        else:
2231 
            pass
2232 
 
2233 
    return {'marketPlaceUrl':mpu,'available_price':int(item.get('available_price')),'source_product_name':item.get('source_product_name'),'thumbnail':item.get('thumbnail'),'source_id':int(item.get('source_id'))}
16300 manas 2234 
 
2235 
def getItemByMerchantIdentifier(identifier, source_id):
2236 
    skuData = None
17035 kshitij.so 2237 
    if source_id in (1,2,4,5,6,7):
16300 manas 2238 
        skuData = get_mongo_connection().Catalog.MasterData.find_one({'identifier':identifier.strip(), 'source_id':source_id})
2239 
    elif source_id == 3:
2240 
        skuData = get_mongo_connection().Catalog.MasterData.find_one({'secondaryIdentifier':identifier.strip(), 'source_id':source_id})
2241 
    if skuData is None:
2242 
        return {}
2243 
    else:
2244 
        return skuData
15375 kshitij.so 2245 
 
17936 kshitij.so 2246 
def getDealsForNotification(skuBundleIds,skipSplitting=False):
2247 
    if not skipSplitting:
2248 
        bundles= [int(skuBundleId) for skuBundleId in skuBundleIds.split(',')]
2249 
        print bundles
2250 
    else:
2251 
        bundles = skuBundleIds
16406 kshitij.so 2252 
    dealsList = []
16364 kshitij.so 2253 
    dealsListMap = []
16406 kshitij.so 2254 
    for bundleId in bundles:
2255 
        outer_query = []
2256 
        outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })
2257 
        outer_query.append({'skuBundleId':bundleId})
2258 
        deals = get_mongo_connection().Catalog.Deals.find({"$and":outer_query})
2259 
        for deal in deals:
2260 
            dealsList.append(deal)
16364 kshitij.so 2261 
    sortedMap = {}
2262 
    rankMap = {}
2263 
    rank = 0
16406 kshitij.so 2264 
    for sorted_deal in dealsList:
16364 kshitij.so 2265 
        if sortedMap.get(sorted_deal['skuBundleId']) is None:
2266 
            sortedMap[sorted_deal['skuBundleId']] = {rank:[sorted_deal]}
2267 
            rankMap[rank] = (sortedMap[sorted_deal['skuBundleId']].values())[0]
2268 
            rank = rank +1
2269 
        else:
2270 
            for temp_list in sortedMap.get(sorted_deal['skuBundleId']).itervalues():
2271 
                temp_list.append(sorted_deal)
2272 
            rankMap[(sortedMap.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
2273 
 
16367 kshitij.so 2274 
    for dealList in [rankMap.get(k, []) for k in range(0, len(bundles))]:
16364 kshitij.so 2275 
        temp = []
2276 
        for d in dealList:
2277 
            item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
2278 
            if len(item) ==0:
2279 
                continue
2280 
            if d['dealType'] == 1 and d['source_id'] ==1:
2281 
                item[0]['marketPlaceUrl'] = "http://www.amazon.in/dp/%s"%(item[0]['identifier'].strip())
2282 
            elif d['source_id'] ==3:
2283 
                item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')
2284 
            else:
2285 
                pass
2286 
            try:
2287 
                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
2288 
                if not cashBack or cashBack.get('cash_back_status')!=1:
2289 
                    item[0]['cash_back_type'] = 0
2290 
                    item[0]['cash_back'] = 0
2291 
                else:
2292 
                    item[0]['cash_back_type'] = int(cashBack['cash_back_type'])
2293 
                    item[0]['cash_back'] = cashBack['cash_back']
2294 
            except:
2295 
                print "Error in adding cashback to deals"
2296 
                item[0]['cash_back_type'] = 0
2297 
                item[0]['cash_back'] = 0
2298 
            try:
2299 
                item[0]['dp'] = d['dp']
2300 
                item[0]['showDp'] = d['showDp']
2301 
            except:
2302 
                item[0]['dp'] = 0.0
2303 
                item[0]['showDp'] = 0
17727 kshitij.so 2304 
 
2305 
            try:
2306 
                if item[0]['showVideo']==0:
2307 
                    item[0]['videoLink'] =""
2308 
            except:
2309 
                item[0]['videoLink'] =""
2310 
            try:
2311 
                if item[0]['quantity'] >1:
2312 
                    ppq = float(item[0]['available_price'])/item[0]['quantity']
2313 
 
2314 
                    if ppq == round(ppq):
2315 
                        item[0]['ppq'] = int(ppq)
2316 
                    else:
2317 
                        item[0]['ppq'] = round(ppq,2)
2318 
                else:
2319 
                    item[0]['ppq'] = 0
2320 
            except:
2321 
                item[0]['ppq'] = 0
2322 
            if item[0]['category_id']!=6:
2323 
                try:
18830 kshitij.so 2324 
                    item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
2325 
                    item[0]['filterTextBrand'] = (item[0]['brand'])
17727 kshitij.so 2326 
                except:
18830 kshitij.so 2327 
                    pass
17727 kshitij.so 2328 
            else:
2329 
                try:
18051 kshitij.so 2330 
                    if item[0]['subCategory']=='' or item[0]['subCategory'] is None or item[0]['subCategoryId']==0:
17727 kshitij.so 2331 
                        raise
18830 kshitij.so 2332 
                    item[0]['filterLinkSubCategory'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['subCategory'])+'&filter=subcategory&subcategories='+str(int(item[0]['subCategoryId']))
2333 
                    item[0]['filterTextSubCategory'] = (item[0]['subCategory'])
2334 
                    item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
2335 
                    item[0]['filterTextBrand'] = (item[0]['brand'])
17727 kshitij.so 2336 
                except:
18830 kshitij.so 2337 
                    pass
17944 kshitij.so 2338 
            try:
2339 
                if item[0]['source_id']==4:
2340 
                    item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
2341 
                    if item_availability_info is None or len(item_availability_info)==0:
2342 
                        item[0]['availabilityInfo'] = [{}]
2343 
                    else:
2344 
                        item[0]['availabilityInfo'] = item_availability_info
2345 
            except:
2346 
                item[0]['availabilityInfo'] = [{}]
19135 kshitij.so 2347 
 
19193 kshitij.so 2348 
            if item[0]['source_id']==4:
2349 
                for av_info in item[0]['availabilityInfo']:
2350 
                    if not av_info:
2351 
                        continue
2352 
                    av_info['cash_back'] = item[0]['cash_back']
2353 
                    av_info['cash_back_type'] = item[0]['cash_back_type']
2354 
                    netPriceAfterCashBack = av_info['sellingPrice']
19199 kshitij.so 2355 
                    if av_info['cash_back_type'] ==1:
19207 kshitij.so 2356 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(float(av_info['sellingPrice'])*av_info['cash_back']/100)
19199 kshitij.so 2357 
                    elif av_info['cash_back_type'] ==2:
19207 kshitij.so 2358 
                        netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(av_info['cash_back'])
19193 kshitij.so 2359 
                    else:
2360 
                        pass
2361 
                    av_info['netPriceAfterCashBack'] = netPriceAfterCashBack
2362 
 
2363 
            if item[0]['source_id'] != SOURCE_MAP.get("PAYTM.COM"):
2364 
                if item[0]['codAvailable'] ==1:
2365 
                    paytmPrice = item[0]['available_price']
2366 
                else:
2367 
                    paytmPrice = item[0]['gross_price']
2368 
 
2369 
                if item[0]['cash_back_type'] ==1:
19207 kshitij.so 2370 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(float(paytmPrice)*item[0]['cash_back']/100)
19193 kshitij.so 2371 
                elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 2372 
                    item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(item[0]['cash_back'])
19193 kshitij.so 2373 
                else:
2374 
                    item[0]['netPriceAfterCashBack'] = paytmPrice
2375 
 
2376 
            else:
2377 
                if item[0]['cash_back_type'] ==1:
19207 kshitij.so 2378 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(float(item[0]['available_price'])*item[0]['cash_back']/100)
19193 kshitij.so 2379 
                elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 2380 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(item[0]['cash_back'])
19193 kshitij.so 2381 
                else:
2382 
                    item[0]['netPriceAfterCashBack'] = item[0]['available_price']
2383 
 
2384 
 
19135 kshitij.so 2385 
            item[0]['totalPoints'] = d['totalPoints']
17727 kshitij.so 2386 
 
16364 kshitij.so 2387 
            temp.append(item[0])
2388 
        if len(temp) > 1:
2389 
            temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)
2390 
        dealsListMap.append(temp)
2391 
    return dealsListMap
2392 
 
16373 manas 2393 
def getSkuBrandData(sku):
2394 
    if sku is None:
2395 
        return {}
2396 
    else:
2397 
        orders = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':sku})
2398 
        if orders is None:
2399 
            return {}
2400 
        return orders
16488 kshitij.so 2401 
 
2402 
def addDealPoints(data):
2403 
    collection = get_mongo_connection().Catalog.DealPoints
2404 
    cursor = collection.find({'skuBundleId':data['skuBundleId']})
2405 
    if cursor.count() > 0:
2406 
        return {0:"Sku information already present."}
2407 
    else:
2408 
        collection.insert(data)
2409 
        get_mongo_connection().Catalog.MasterData.update({'skuBundleId':data['skuBundleId']},{"$set":{'updatedOn':to_java_date(datetime.now())}},multi=True)
2410 
        return {1:"Data added successfully"}
2411 
 
2412 
def getAllBundlesWithDealPoints(offset, limit):
2413 
    data = []
2414 
    collection = get_mongo_connection().Catalog.DealPoints
2415 
    cursor = collection.find().sort([('endDate',pymongo.DESCENDING)]).skip(offset).limit(limit)
2416 
    for val in cursor:
2417 
        master = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':val.get('skuBundleId')})
2418 
        if master is not None:
2419 
            val['brand'] = master['brand']
2420 
            val['source_product_name'] = master['product_name']
2421 
        else:
2422 
            val['brand'] = ""
2423 
            val['source_product_name'] = ""
2424 
        data.append(val)
2425 
    return data
16546 kshitij.so 2426 
 
2427 
def generateRedirectUrl(retailer_id, app_id):
2428 
    try:
16663 manish.sha 2429 
        if retailer_id <= 0:
2430 
            return {'url':"","message":"Retailer Id not valid"}
16546 kshitij.so 2431 
        d_app_offer = app_offers.get_by(id=app_id)
16605 manish.sha 2432 
    except:
2433 
        traceback.print_exc()
16546 kshitij.so 2434 
    finally:
2435 
        session.close()
2436 
    if d_app_offer is None:
2437 
        return {'url':"","message":"App id doesn't exist"}
16364 kshitij.so 2438 
 
16915 manish.sha 2439 
    final_user_payout = 0
2440 
    if d_app_offer.override_payout:
2441 
        final_user_payout = d_app_offer.overriden_payout
2442 
    else:
2443 
        final_user_payout = d_app_offer.user_payout
16546 kshitij.so 2444 
 
16915 manish.sha 2445 
    appTransactions = AppTransactions(app_id, retailer_id, to_java_date(datetime.now()), None, 1, CB_INIT, 1, CB_INIT, None, None, d_app_offer.offer_price, d_app_offer.overriden_payout, d_app_offer.override_payout, d_app_offer.user_payout, final_user_payout)
2446 
 
16546 kshitij.so 2447 
    get_mongo_connection().AppOrder.AppTransaction.insert(appTransactions.__dict__)
2448 
    embedd = str((appTransactions.__dict__).get('_id'))
16548 kshitij.so 2449 
    try:
2450 
        index = d_app_offer.link.index(".freeb.co.in")
2451 
    except:
16605 manish.sha 2452 
        traceback.print_exc()
16548 kshitij.so 2453 
        return {'url':"","message":"Substring not found"}
2454 
    redirect_url = d_app_offer.link[0:index]+"."+embedd+d_app_offer.link[index:]
16546 kshitij.so 2455 
    get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(embedd)},{"$set":{'redirect_url':redirect_url}})
16548 kshitij.so 2456 
    return {'url':redirect_url,"message":"Success"}
16556 kshitij.so 2457 
 
2458 
def addPayout(payout, transaction_id):
2459 
    try:
16764 manish.sha 2460 
        print 'Got Response for Transaction Id:- '+ str(transaction_id)+ ' and Actual Payout:- '+str(payout)
16556 kshitij.so 2461 
        transaction = list(get_mongo_connection().AppOrder.AppTransaction.find({'_id':ObjectId(transaction_id)}))
2462 
        if len(transaction) > 0:
2463 
            if (transaction[0])['payout_status'] ==1:
16753 manish.sha 2464 
                get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':float(payout), 'payout_description': CB_APPROVED,'payout_status':2, 'cashback_status': 2, 'cash_back_description': CB_APPROVED, 'payout_time':to_java_date(datetime.now())}})
16782 manish.sha 2465 
 
2466 
                approvedAppTransaction = approved_app_transactions.get_by(transaction_id=transaction_id)
2467 
                if approvedAppTransaction is None:
2468 
                    approvedAppTransaction = approved_app_transactions()
16919 manish.sha 2469 
                    approvedAppTransaction.app_id = transaction[0].get('app_id')
16782 manish.sha 2470 
                    approvedAppTransaction.cash_back_description = CB_APPROVED
16919 manish.sha 2471 
                    approvedAppTransaction.retailer_id = transaction[0].get('retailer_id')
16782 manish.sha 2472 
                    approvedAppTransaction.transaction_id = transaction_id
16919 manish.sha 2473 
                    approvedAppTransaction.transaction_time = to_py_date(long(transaction[0].get('transaction_time')))
2474 
                    approvedAppTransaction.redirect_url = transaction[0].get('redirect_url')
16782 manish.sha 2475 
                    approvedAppTransaction.payout_status = 2
2476 
                    approvedAppTransaction.payout_description = CB_APPROVED
2477 
                    approvedAppTransaction.cashback_status = 2
2478 
                    approvedAppTransaction.payout_amount = long(payout)
2479 
                    approvedAppTransaction.payout_time = datetime.now()
16919 manish.sha 2480 
                    approvedAppTransaction.offer_price = long(transaction[0].get('offer_price'))
2481 
                    approvedAppTransaction.overridenCashBack = transaction[0].get('overridenCashBack')
2482 
                    approvedAppTransaction.isCashBackOverriden = transaction[0].get('isCashBackOverriden')
2483 
                    approvedAppTransaction.user_payout = transaction[0].get('user_payout')
16782 manish.sha 2484 
                    approvedAppTransaction.cashBackConsidered = False
16915 manish.sha 2485 
                    if transaction[0].get('final_user_payout') is not None:
2486 
                        approvedAppTransaction.final_user_payout = transaction[0].get('final_user_payout')
2487 
                    else:
16919 manish.sha 2488 
                        if transaction[0].get('isCashBackOverriden'):
2489 
                            approvedAppTransaction.final_user_payout = transaction[0].get('overridenCashBack')
16915 manish.sha 2490 
                        else:
16919 manish.sha 2491 
                            approvedAppTransaction.final_user_payout = transaction[0].get('user_payout')
16782 manish.sha 2492 
                    session.commit()
2493 
 
2494 
                    updateResult = _updateApprovedCashbackToUser(approvedAppTransaction.id)
16631 manish.sha 2495 
                else:
16783 manish.sha 2496 
                    approvedAppTransaction.payout_amount = long(payout)
2497 
                    approvedAppTransaction.payout_time = datetime.now()
2498 
                    if approvedAppTransaction.cashBackConsidered == False:
2499 
                        updateResult = _updateApprovedCashbackToUser(approvedAppTransaction.id)
2500 
                    session.commit()
16782 manish.sha 2501 
 
2502 
                    '''
2503 
                    try:
2504 
                        if int(transaction[0]['offer_price']) != payout or int(transaction[0]['user_payout']) < payout:
2505 
                            _sendAlertForAppPayouts(int(transaction[0]['app_id']), int(transaction[0]['offer_price']), int(transaction[0]['user_payout']), payout)
2506 
                    except:
2507 
                        print traceback.print_exc()
2508 
                    '''
16556 kshitij.so 2509 
                return {'status':'ok','message':'Payout updated'}
2510 
            elif (transaction[0])['payout_status'] ==2:
2511 
                return {'status':'ok','message':'Payout already processed'}
2512 
            else:
2513 
                return {'status':'fail','message':'Something is wrong'}
2514 
        else:
2515 
            return {'status':'fail','message':'transaction_id not found'}
2516 
    except:
16657 manish.sha 2517 
        print traceback.print_exc()
16631 manish.sha 2518 
        try:
16753 manish.sha 2519 
            get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':None, 'payout_description': CB_INIT,'payout_status':1, 'cashback_status': 1, 'cash_back_description': CB_INIT, 'payout_time':None}})
16631 manish.sha 2520 
        except:
2521 
            print 'Data Inconsistency in Cashback Process'
16636 manish.sha 2522 
            print traceback.print_exc()
16559 kshitij.so 2523 
        return  {'status':'fail','message':'Something is wrong'}
16885 kshitij.so 2524 
    finally:
2525 
        session.close()
16556 kshitij.so 2526 
 
16631 manish.sha 2527 
def _updateApprovedCashbackToUser(approvedAppTransactionId):
2528 
    approvedAppTransaction = approved_app_transactions.get_by(id=approvedAppTransactionId)
16915 manish.sha 2529 
    if approvedAppTransaction.retailer_id < 0:
2530 
        return False
2531 
 
16631 manish.sha 2532 
    currentMonth = datetime.today().month
2533 
    currentDay = datetime.today().day
2534 
    currentYear = datetime.today().year
2535 
    fortNight = (currentMonth - 1)*2 + (currentDay/15)
2536 
    if currentDay == 30 or currentDay ==31:
2537 
        fortNight = fortNight-1
2538 
    userAppCashbackObj = user_app_cashbacks.query.filter(user_app_cashbacks.yearVal==currentYear).filter(user_app_cashbacks.user_id==approvedAppTransaction.retailer_id).filter(user_app_cashbacks.fortnightOfYear==fortNight).filter(user_app_cashbacks.status=='Approved').first()
2539 
    userAppInstallObj = user_app_installs.query.filter(user_app_installs.user_id==approvedAppTransaction.retailer_id).filter(user_app_installs.app_id==approvedAppTransaction.app_id).filter(user_app_installs.transaction_date==datetime(currentYear, currentMonth, currentDay, 0, 0, 0, 0).date()).first()
2540 
    try:
2541 
        if userAppCashbackObj is None:
2542 
            userAppCashbackObj = user_app_cashbacks()
2543 
            userAppCashbackObj.user_id = approvedAppTransaction.retailer_id
2544 
            userAppCashbackObj.status = 'Approved'
16915 manish.sha 2545 
            userAppCashbackObj.amount = approvedAppTransaction.final_user_payout
16631 manish.sha 2546 
            userAppCashbackObj.fortnightOfYear = fortNight
2547 
            userAppCashbackObj.yearVal = currentYear
2548 
        else:
16915 manish.sha 2549 
            userAppCashbackObj.amount = userAppCashbackObj.amount + approvedAppTransaction.final_user_payout
16631 manish.sha 2550 
 
2551 
        if userAppInstallObj is None:
2552 
            app_offer = app_offers.get_by(id=approvedAppTransaction.app_id)
2553 
            userAppInstallObj = user_app_installs()
2554 
            userAppInstallObj.user_id = approvedAppTransaction.retailer_id
2555 
            userAppInstallObj.fortnightOfYear = fortNight
2556 
            userAppInstallObj.transaction_date = datetime(currentYear, currentMonth, currentDay, 0, 0, 0, 0).date()
2557 
            userAppInstallObj.app_id = approvedAppTransaction.app_id
2558 
            userAppInstallObj.app_name = app_offer.app_name
2559 
            userAppInstallObj.installCount = 1
16915 manish.sha 2560 
            userAppInstallObj.payoutAmount = approvedAppTransaction.final_user_payout
16631 manish.sha 2561 
        else:
2562 
            userAppInstallObj.installCount = userAppInstallObj.installCount + 1
16915 manish.sha 2563 
            userAppInstallObj.payoutAmount = userAppInstallObj.payoutAmount +approvedAppTransaction.final_user_payout
16631 manish.sha 2564 
 
2565 
        approvedAppTransaction.cashBackConsidered = True
2566 
        session.commit()
2567 
        return True
2568 
    except:
2569 
        session.rollback()
16636 manish.sha 2570 
        print traceback.print_exc()
16631 manish.sha 2571 
        return False
16693 manish.sha 2572 
 
2573 
def _sendAlertForAppPayouts(app_id, offerPrice, userPayout, payout):
2574 
    m = Email('localhost')
2575 
    mFrom = "dtr@shop2020.in"
2576 
    m.setFrom(mFrom)
2577 
    mTo = ['rajneesh.arora@saholic.com','kshitij.sood@saholic.com','chaitnaya.vats@saholic.com','manoj.kumar@saholic.com','manish.sharma@shop2020.in']
2578 
    for receipient in mTo:
2579 
        m.addRecipient(receipient)
2580 
    appOffer = app_offers.get_by(id=app_id)
2581 
    if offerPrice != payout:
2582 
        m.setSubject("Mismatch in Offer Price and Actual Pay Out for App Id:- "+str(appOffer.id)+" App Name:- "+str(appOffer.app_name))
2583 
        message1 = "Offer Price:- "+ str(appOffer.offer_price) + "\n" + "Actual Pay Out:- "+ str(payout)
2584 
        m.setTextBody(message1)
2585 
    if userPayout > payout:
2586 
        m.setSubject("User Pay Out greater than actual PayOut for App Id:- "+str(appOffer.id)+" App Name:- "+str(appOffer.app_name))
2587 
        message2 = "User Pay Out Price:- "+ str(appOffer.user_payout) + "\n" + "Actual Pay Out:- "+ str(payout)
2588 
        m.setTextBody(message2)
2589 
    m.send()
16631 manish.sha 2590 
 
16789 amit.gupta 2591 
def rejectCashback(orderId, subOrderId):
16833 amit.gupta 2592 
    cashBack = get_mongo_connection().Dtr.merchantOrder.update({"orderId":orderId, "subOrders.merchantSubOrderId":subOrderId},
16789 amit.gupta 2593 
                                                               {"$set":{"subOrders.$.cashBackStatus":CB_REJECTED}})
16837 amit.gupta 2594 
    print cashBack
16836 amit.gupta 2595 
    return cashBack.get("nModified")
16894 manish.sha 2596 
 
2597 
def getAppOffers(retailer_id):
2598 
    if not bool(mc.get("cached_app_offers_"+str(retailer_id))):
2599 
        populateAppOffers(retailer_id)
2600 
    return mc.get("cached_app_offers_"+str(retailer_id))
2601 
 
2602 
def populateAppOffers(retailerId):
2603 
    retailerId = int(retailerId)
2604 
    #offset = req.get_param_as_int("offset")
2605 
    #limit = req.get_param_as_int("limit")
16941 manish.sha 2606 
    nonPriortizedOffers = session.query(app_offers.id).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).filter(appmasters.rank==0).order_by(desc('user_payout')).all()
2607 
    priortizeders = session.query(app_offers.id, appmasters.rank).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).filter(appmasters.rank>0).order_by(asc(appmasters.rank)).all()
16894 manish.sha 2608 
    #session.query(app_offers.id,app_offers.appmaster_id, app_offers.app_name, app_offers.affiliate_offer_id, app_offers.image_url, app_offers.downloads, app_offers.link, app_offers.offer_price, app_offers.offerCategory, app_offers.package_name, app_offers.promoImage, app_offers.ratings, case([(app_offers.override_payout == True, app_offers.overriden_payout)], else_=app_offers.user_payout).label('user_payout'), case([(appmasters.shortDescription != None, appmasters.shortDescription)], else_=None).label('shortDescription'), case([(appmasters.longDescription != None, appmasters.longDescription)], else_=None).label('longDescription'), appmasters.customerOneLiner, appmasters.retailerOneLiner,app_offers.priority, app_offers.offerCondition, app_offers.location).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).order_by(case([(app_offers.priority.in_(tuple(nullCheckList)), 1)], else_=0), asc(app_offers.priority),desc('user_payout')).all()
2609 
 
2610 
    appOffersMap = {}
2611 
    priorityList = []
2612 
    priorityMap = {}
2613 
    for offer in priortizeders:
16941 manish.sha 2614 
        if priorityMap.has_key(long(offer[1])):
2615 
            offersVal = priorityMap.get(long(offer[1]))
2616 
            offersVal.append(offer)
2617 
            priorityMap[long(offer[1])]=offersVal
2618 
        else:
2619 
            offersVal = []
2620 
            offersVal.append(offer)
2621 
            priorityMap[long(offer[1])]=offersVal
2622 
 
16894 manish.sha 2623 
    priorityList = sorted(priorityMap)
2624 
 
2625 
    maxCount = len(nonPriortizedOffers) + len(priortizeders)
2626 
 
16909 manish.sha 2627 
    if priorityList is not None and len(priorityList)>0:
2628 
        if maxCount < max(priorityList):
2629 
            maxCount = max(priorityList)
16894 manish.sha 2630 
 
2631 
    count = 1
2632 
    blockedPlaces = []
2633 
    availablePlaces = []
2634 
    while count <= maxCount:
2635 
        if count in priorityList:
2636 
            blockedPlaces.append(count)
2637 
        else:
2638 
            availablePlaces.append(count)
2639 
        count = count +1
16941 manish.sha 2640 
    print 'Blocked Places', blockedPlaces
16894 manish.sha 2641 
    for val in blockedPlaces:
16941 manish.sha 2642 
        key = val
2643 
        for offerObj in priorityMap.get(val):
2644 
            while appOffersMap.has_key(key):
2645 
                key = key+1
2646 
            appOffersMap[key] = long(offerObj[0])
2647 
            if key in availablePlaces:
2648 
                availablePlaces.remove(key)
2649 
 
2650 
    print 'Available Places', availablePlaces
2651 
 
16894 manish.sha 2652 
    i=0
2653 
    for val in availablePlaces:
16899 manish.sha 2654 
        if i<len(nonPriortizedOffers):
16902 manish.sha 2655 
            appOffersMap[val]= long(nonPriortizedOffers[i][0])
16899 manish.sha 2656 
        else:
2657 
            break
2658 
        i=i+1
16901 manish.sha 2659 
    print 'AppOffersMap', appOffersMap
16894 manish.sha 2660 
 
2661 
    finalAppOffersMap = {}
2662 
    if len(appOffersMap) > 0:
2663 
        for key in sorted(appOffersMap):
2664 
            finalAppOffersMap[key] = appOffersMap[key]
2665 
 
2666 
        mc.set("cached_app_offers_"+str(retailerId), finalAppOffersMap, 120)
2667 
    else:
2668 
        print 'No Offers'
2669 
        mc.set("cached_app_offers_"+str(retailerId), {}, 10)
17280 manish.sha 2670 
 
19556 manas 2671 
def sendNotification(userIds, campaignName, title, message,notificationtype, url, expiresat='2999-01-01', sendsms=False, smstext=None):
2672 
    max_id = list(get_mongo_connection_dtr_data().User.notificationcampaigns.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
19337 manish.sha 2673 
    if len(max_id) ==0:
2674 
        max_id = 0
2675 
    else:
2676 
        max_id = max_id[0]['_id']
2677 
    max_id = max_id +1
19362 manish.sha 2678 
    campaign = NotificationCampaign(max_id, campaignName, title, message, "SELECT User.id from users User where User.id="+str(userIds[0]), url, to_java_date(datetime.now()), to_java_date(datetime.now()+timedelta(days=730)), notificationtype, 'active', sendsms, smstext, 0, 0, 'BATCH_CREDIT')
19556 manas 2679 
    get_mongo_connection_dtr_data().User.notificationcampaigns.insert(campaign.__dict__)
17302 kshitij.so 2680 
 
2681 
def getDummyDeals(categoryId, offset, limit):
2682 
    outer_query = []
2683 
    outer_query.append({"showDeal":1})
2684 
    outer_query.append({"category_id":categoryId})
2685 
    query = {}
2686 
    query['$gt'] = -100
2687 
    outer_query.append({'totalPoints':query})
2688 
    all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]).skip(offset).limit(limit))
2689 
    returnObj = []
2690 
    for deal in all_deals:
17306 kshitij.so 2691 
        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':deal['_id']}))
17734 kshitij.so 2692 
        returnObj.append(getItemObjForStaticDeals(item[0],transform=True))
17302 kshitij.so 2693 
    return returnObj
17367 kshitij.so 2694 
 
17469 kshitij.so 2695 
def searchDummyDeals(search_term , limit, offset):
17367 kshitij.so 2696 
    data = []
2697 
    uniqueMap = {}
2698 
    if search_term is not None:
2699 
        terms = search_term.split(' ')
2700 
        outer_query = []
2701 
        for term in terms:
2702 
            outer_query.append({"source_product_name":re.compile(term, re.IGNORECASE)})
2703 
        try:
2704 
            collection = get_mongo_connection().Catalog.MasterData.find({"$and":outer_query,'source_id':{'$in':SOURCE_MAP.keys()}})
2705 
            for record in collection:
2706 
                data.append(record)
2707 
        except:
2708 
            pass
2709 
    else:
2710 
        collection = get_mongo_connection().Catalog.MasterData.find({'source_id':{'$in':SOURCE_MAP.keys()}})
2711 
        for record in collection:
2712 
            data.append(record)
2713 
    for x in data:
2714 
        if not uniqueMap.has_key(x['skuBundleId']):
17469 kshitij.so 2715 
            uniqueMap[x['skuBundleId']] = {'source_product_name':x['source_product_name'],'skuBundleId':x['skuBundleId'],'thumbnail':x['thumbnail']}
17367 kshitij.so 2716 
 
17469 kshitij.so 2717 
    if (offset + limit) > len(uniqueMap.values()):
2718 
        limit = len(uniqueMap.values()) - offset - 1
2719 
 
2720 
    count = 0
2721 
#     for x in uniqueMap.values():
2722 
#         print count,
2723 
#         print '\t',
2724 
#         print x
2725 
#         count = count+1
17555 kshitij.so 2726 
 
17469 kshitij.so 2727 
    print offset
2728 
    print limit
2729 
 
2730 
    return uniqueMap.values()[offset:limit+offset]
17367 kshitij.so 2731 
 
17469 kshitij.so 2732 
 
2733 
def getDummyPricing(skuBundleId):
2734 
    collection = get_mongo_connection().Catalog.MasterData.find({'source_id':{'$in':SOURCE_MAP.keys()},'skuBundleId':skuBundleId,'in_stock':1})
2735 
    print collection.count()
2736 
    cheapest = 99999999
2737 
    cheapestDetails= None
2738 
    returnMap = {}
2739 
 
2740 
    for d in collection:
2741 
        if d['available_price'] < cheapest:
2742 
            cheapestDetails = d
2743 
            cheapest = int(d['available_price'])
2744 
        if returnMap.has_key(d['source_id']):
17733 kshitij.so 2745 
            d = getItemObjForStaticDeals(d,transform=True)
17469 kshitij.so 2746 
            d['toShowStore'] = 0
2747 
            returnMap[d['source_id']].append(d)
2748 
        else:
2749 
            temp = []
17733 kshitij.so 2750 
            d = getItemObjForStaticDeals(d,transform=True)
17469 kshitij.so 2751 
            d['toShowStore'] = 1
2752 
            temp.append(d)
2753 
            returnMap[d['source_id']] = temp
2754 
    returnMap['cheapest'] = cheapestDetails
2755 
    for y in returnMap.itervalues():
2756 
        if isinstance(y, (list, tuple)):
2757 
            (y[len(y)-1])['lastElement'] = 1
2758 
        else:
2759 
            pass
2760 
    if returnMap['cheapest'] ==None:
2761 
        dum = get_mongo_connection().Catalog.MasterData.find_one({'skuBundleId':skuBundleId,'source_id':{"$in":SOURCE_MAP.keys()}})
2762 
        returnMap['cheapest'] = {'thumbnail':dum['thumbnail'],'source_product_name':dum['source_product_name']}
2763 
    return returnMap
17555 kshitij.so 2764 
 
17603 kshitij.so 2765 
 
17555 kshitij.so 2766 
def addDealObject(data):
17570 kshitij.so 2767 
    if data.get('img_url') is None or data.get('img_url')=="" or data.get('name') is None or data.get('name')=="":
2768 
        return {0:'Invalid data'}
17555 kshitij.so 2769 
    try:
2770 
        max_id = list(get_mongo_connection().Catalog.DealObject.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
2771 
        if len(max_id) ==0:
2772 
            max_id = 0
17559 kshitij.so 2773 
        else:
2774 
            max_id = max_id[0]['_id']
2775 
        data['_id'] = max_id +1
17555 kshitij.so 2776 
        get_mongo_connection().Catalog.DealObject.insert(data)
2777 
        return {1:'Data added successfully'}
2778 
    except:
2779 
        return {0:'Error in adding data'}
2780 
 
17561 kshitij.so 2781 
def getAllDealObjects(offset, limit):
2782 
    data = []
2783 
    collection = get_mongo_connection().Catalog.DealObject
2784 
    cursor = collection.find({}).skip(offset).limit(limit)
2785 
    for val in cursor:
17564 kshitij.so 2786 
        data.append({'_id':val['_id'],'name':val['name']})
17561 kshitij.so 2787 
    return data
17564 kshitij.so 2788 
 
2789 
def deleteDealObject(id):
2790 
    try:
2791 
        get_mongo_connection().Catalog.DealObject.remove({'_id':id})
17616 kshitij.so 2792 
        get_mongo_connection().Catalog.FeaturedDealsDealObject.remove({'_id':id})
17564 kshitij.so 2793 
        return {1:"Deal Object deleted"}
2794 
    except:
2795 
        return {0:"Error in deleting object"}
17566 kshitij.so 2796 
 
2797 
def getDealObjectById(id):
2798 
    try:
2799 
        data = get_mongo_connection().Catalog.DealObject.find({'_id':id})
2800 
        return data
2801 
    except:
17570 kshitij.so 2802 
        return {}
17561 kshitij.so 2803 
 
17570 kshitij.so 2804 
def updateDealObject(data):
2805 
    try:
2806 
        _id = data['_id']
2807 
        data.pop('_id')
2808 
        get_mongo_connection().Catalog.DealObject.update({'_id':_id},{"$set":data},upsert=False)
2809 
        return {1:"Data updated successfully"}
2810 
    except:
2811 
        return {0:"Error in updating data"}
2812 
 
17610 kshitij.so 2813 
def getAllFeaturedDealsForDealObject(offset, limit):
2814 
    data = []
2815 
    collection = get_mongo_connection().Catalog.FeaturedDealsDealObject
2816 
    cursor = collection.find({}).skip(offset).limit(limit)
2817 
    for val in cursor:
2818 
        data.append(val)
2819 
    return data
2820 
 
2821 
def addFeaturedDealForDealObject(data):
19280 kshitij.so 2822 
    print data
2823 
 
17610 kshitij.so 2824 
    collection = get_mongo_connection().Catalog.FeaturedDealsDealObject
2825 
    cursor = collection.find({'_id':data['_id']})
2826 
    master = get_mongo_connection().Catalog.DealObject.find_one({'_id':data['_id']})
2827 
    if master is None:
2828 
        return {0:"Deal Object id wrong"}
2829 
    otherInfoObj = data['otherInfo']
2830 
    toPop = []
2831 
    for x,y in otherInfoObj.iteritems():
19280 kshitij.so 2832 
        if y==0 or y=="":
17610 kshitij.so 2833 
            toPop.append(x)
2834 
 
2835 
    for popItem in toPop:
2836 
        otherInfoObj.pop(popItem)
2837 
    if len(otherInfoObj.keys())==0:
2838 
        return {0:"No rank info to add"}
2839 
 
2840 
    for x,y in otherInfoObj.iteritems():
2841 
        exist = get_mongo_connection().Catalog.FeaturedDealsDealObject.find({'otherInfo.'+x:y})
2842 
        if exist.count() >0:
2843 
            return {0:"Rank already assigned Deal Object Id %s"%(exist[0]['_id'])}
2844 
    if cursor.count() > 0:
2845 
        return {0:"Deal Object Id information already present."}
2846 
    else:
2847 
        collection.insert(data)
2848 
        return {1:"Data added successfully"}
2849 
 
17616 kshitij.so 2850 
def deleteFeaturedDealObject(id):
2851 
    try:
2852 
        get_mongo_connection().Catalog.FeaturedDealsDealObject.remove({'_id':id})
2853 
        return {1:"Deal Object deleted"}
2854 
    except:
2855 
        return {0:"Error in deleting object"}
17654 kshitij.so 2856 
 
2857 
def getSubCategoryForFilter(category_id):
2858 
    if mc.get("subCategoryFilter") is None:
2859 
        print "Populating subcategory data for category_id %d" %(category_id)
2860 
        tabData, mobData, accData = [], [], []
2861 
 
2862 
        accessoriesDeals = get_mongo_connection().Catalog.Deals.aggregate([
2863 
                                                                      {"$match":{"category_id":6,"showDeal":1,"totalPoints":{"$gt":-100}}
2864 
                                                                    },
2865 
                                                                 {"$group" :
2866 
                                                                  {'_id':{'subCategoryId':'$subCategoryId','subCategory':'$subCategory'},'count':{'$sum':1}}
2867 
                                                                  }
2868 
                                                                ])
2869 
 
2870 
        for accessoryDeal in accessoriesDeals['result']:
2871 
            if accessoryDeal.get('_id').get('subCategoryId') != 0:
2872 
                tempMap = {}
2873 
                tempMap['subCategory'] = accessoryDeal.get('_id').get('subCategory')
2874 
                tempMap['subCategoryId'] = accessoryDeal.get('_id').get('subCategoryId')
2875 
                tempMap['count'] = accessoryDeal.get('count')
2876 
                accData.append(tempMap)
2877 
 
2878 
 
2879 
        mc.set("subCategoryFilter",{3:mobData, 5:tabData, 6:accData}, 600)
2880 
 
2881 
    return sorted(mc.get("subCategoryFilter").get(category_id), key = lambda x: (-x['count'], x['subCategory']))
17610 kshitij.so 2882 
 
17727 kshitij.so 2883 
def dummyLogin(data):
17731 kshitij.so 2884 
    exist = list(get_mongo_connection().Catalog.DummyUser.find({'email':data['email'],'password':data['password']}))
17727 kshitij.so 2885 
    if len(exist) > 0:
17728 kshitij.so 2886 
        return {'user_id':exist[0]['_id'],'fullName':exist[0]['fullName']}
17727 kshitij.so 2887 
    else:
2888 
        return {'user_id':0}
17616 kshitij.so 2889 
 
17727 kshitij.so 2890 
def dummyRegister(data):
2891 
    try:
2892 
        exist = list(get_mongo_connection().Catalog.DummyUser.find({'email':data['email']}))
2893 
        if len(exist) > 0:
2894 
            return {'msg':"Email already registered",'user_id':0}
2895 
        else:
2896 
            max_id = list(get_mongo_connection().Catalog.DummyUser.find().sort([('_id',pymongo.DESCENDING)]).limit(1))
2897 
            if len(max_id) ==0:
2898 
                max_id = 0
2899 
            else:
2900 
                max_id = max_id[0]['_id']
2901 
            data['_id'] = max_id +1
2902 
            get_mongo_connection().Catalog.DummyUser.insert(data)
17728 kshitij.so 2903 
            return {'msg':"Registration successful",'user_id':data['_id'],'fullName':data['fullName']}
17727 kshitij.so 2904 
    except:
2905 
        return {'msg':"Error in registration.",'user_id':0}
2906 
 
17731 kshitij.so 2907 
def getDummyUser(user_id):
2908 
    exist = list(get_mongo_connection().Catalog.DummyUser.find({'_id':user_id}))
2909 
    if len(exist) > 0:
2910 
        return exist[0]
2911 
    else:
2912 
        return {'user_id':0,'fullName':"",'email':"","contactNumber":""}
2913 
 
2914 
def updateDummyUser(data):
2915 
    try:
17732 kshitij.so 2916 
        get_mongo_connection().Catalog.DummyUser.update({'_id':data['user_id']},{"$set":data},upsert=False)
17731 kshitij.so 2917 
        return {'msg':"Data updated successfuly",'response':1}
2918 
    except:
2919 
        return {'msg':"Unable to update data",'response':0}
17936 kshitij.so 2920 
 
18089 kshitij.so 2921 
def getDealsForSearchText(subCategoryIds, searchTerm, offset, limit):
2922 
    subCategories= [int(subCategoryId) for subCategoryId in subCategoryIds.split('^')]
18106 kshitij.so 2923 
    print "SubCategories are ",subCategories
17936 kshitij.so 2924 
    payload = {
18106 kshitij.so 2925 
    "query": {
17936 kshitij.so 2926 
        "bool": {
18106 kshitij.so 2927 
            "must": [{
2928 
                    "match": {
2929 
                        "title": {
2930 
                            "query": searchTerm,
2931 
                            "operator": "and"
2932 
                        }
17936 kshitij.so 2933 
                    }
18106 kshitij.so 2934 
                },
2935 
 
2936 
                {
2937 
                    "in": {
2938 
                        "subCategoryId": subCategories
2939 
                    }
17936 kshitij.so 2940 
                }
18106 kshitij.so 2941 
 
2942 
            ]
17936 kshitij.so 2943 
        }
19135 kshitij.so 2944 
    },
2945 
    "sort": { "dealPoints": { "order": "desc" }}
18106 kshitij.so 2946 
}
17944 kshitij.so 2947 
    result =  get_elastic_search_connection().search(index="my_index", body=payload, from_=offset, size=limit)
17936 kshitij.so 2948 
    totalCount= result['hits']['total']
2949 
    temp = []
2950 
    bundles = []
2951 
    if len(result['hits']['hits']) > 0:
2952 
        for x in result['hits']['hits']:
2953 
            tempMap = {}
2954 
            tempMap = {'skuBundleId':x['_source']['id'],'title':x['_source']['title']}
2955 
            temp.append(tempMap)
2956 
            bundles.append(x['_source']['id'])
18271 kshitij.so 2957 
    #return temp
17936 kshitij.so 2958 
    return getDealsForNotification(bundles, skipSplitting=True)
17731 kshitij.so 2959 
 
18089 kshitij.so 2960 
def getCountForSearchText(subCategoryIds, searchTerm):
2961 
    subCategories= [int(subCategoryId) for subCategoryId in subCategoryIds.split('^')]
17936 kshitij.so 2962 
    payload = {
18106 kshitij.so 2963 
    "query": {
17936 kshitij.so 2964 
        "bool": {
18106 kshitij.so 2965 
            "must": [{
2966 
                    "match": {
2967 
                        "title": {
2968 
                            "query": searchTerm,
2969 
                            "operator": "and"
2970 
                        }
17936 kshitij.so 2971 
                    }
18106 kshitij.so 2972 
                },
2973 
 
2974 
                {
2975 
                    "in": {
2976 
                        "subCategoryId": subCategories
2977 
                    }
17936 kshitij.so 2978 
                }
18106 kshitij.so 2979 
 
2980 
            ]
17936 kshitij.so 2981 
        }
2982 
    }
18106 kshitij.so 2983 
}
17731 kshitij.so 2984 
 
17944 kshitij.so 2985 
    result =  get_elastic_search_connection().search(index="my_index", body=payload)
17936 kshitij.so 2986 
    totalCount= result['hits']['total']
2987 
    return {'searchTerm':searchTerm,'count':totalCount}
18271 kshitij.so 2988 
 
2989 
def getDealById(id):
2990 
    item = list(get_mongo_connection().Catalog.MasterData.find({'_id':int(id)}))
2991 
    d = get_mongo_connection().Catalog.Deals.find_one({'_id':int(id)})
19193 kshitij.so 2992 
    if len(item) ==0:
2993 
        return {}
18271 kshitij.so 2994 
    if d is None:
2995 
        d = {'showDp':0,'dp':0}
2996 
    try:
2997 
        cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
2998 
        if not cashBack or cashBack.get('cash_back_status')!=1:
2999 
            item[0]['cash_back_type'] = 0
3000 
            item[0]['cash_back'] = 0
3001 
        else:
3002 
            if cashBack.get('maxCashBack') is not None:
3003 
 
3004 
                if cashBack.get('cash_back_type') ==1 and (float(cashBack.get('cash_back'))*item[0]['available_price'])/100 > cashBack.get('maxCashBack'):
3005 
                    cashBack['cash_back_type'] = 2
3006 
                    cashBack['cash_back'] = cashBack['maxCashBack']
3007 
                elif cashBack.get('cash_back_type') ==2 and cashBack.get('cash_back') > cashBack.get('maxCashBack'):
3008 
                    cashBack['cash_back'] = cashBack['maxCashBack']
17936 kshitij.so 3009 
 
18271 kshitij.so 3010 
            item[0]['cash_back_type'] = int(cashBack['cash_back_type'])
3011 
            item[0]['cash_back'] = cashBack['cash_back']
3012 
    except:
3013 
        print "Error in adding cashback to deals"
3014 
        item[0]['cash_back_type'] = 0
3015 
        item[0]['cash_back'] = 0
3016 
    try:
3017 
        item[0]['dp'] = d['dp']
3018 
        item[0]['showDp'] = d['showDp']
3019 
    except:
3020 
        item[0]['dp'] = 0.0
3021 
        item[0]['showDp'] = 0
3022 
    try:
3023 
        item[0]['thumbnail'] = item[0]['thumbnail'].strip()
3024 
    except:
3025 
        pass
3026 
 
3027 
    try:
3028 
        if item[0]['showVideo']==0:
3029 
            item[0]['videoLink'] =""
3030 
    except:
3031 
        item[0]['videoLink'] =""
3032 
    try:
3033 
        if item[0]['quantity'] >1:
3034 
            ppq = float(item[0]['available_price'])/item[0]['quantity']
3035 
 
3036 
            if ppq == round(ppq):
3037 
                item[0]['ppq'] = int(ppq)
3038 
            else:
3039 
                item[0]['ppq'] = round(ppq,2)
3040 
        else:
3041 
            item[0]['ppq'] = 0
3042 
    except:
3043 
        item[0]['ppq'] = 0
3044 
    if item[0]['category_id']!=6:
3045 
        try:
18830 kshitij.so 3046 
            item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
3047 
            item[0]['filterTextBrand'] = (item[0]['brand'])
18271 kshitij.so 3048 
        except:
18830 kshitij.so 3049 
            pass
18271 kshitij.so 3050 
    else:
3051 
        try:
3052 
            if item[0]['subCategory']=='' or item[0]['subCategory'] is None or item[0]['subCategoryId']==0:
3053 
                raise
18830 kshitij.so 3054 
            item[0]['filterLinkSubCategory'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['subCategory'])+'&filter=subcategory&subcategories='+str(int(item[0]['subCategoryId']))
3055 
            item[0]['filterTextSubCategory'] = (item[0]['subCategory'])
3056 
            item[0]['filterLinkBrand'] = '/category/'+str(int(item[0]['category_id']))+'?searchFor='+urllib.quote(item[0]['brand'])+'&filter=brand&brands='+str(int(item[0]['brand_id']))
3057 
            item[0]['filterTextBrand'] = (item[0]['brand'])
18271 kshitij.so 3058 
        except:
18830 kshitij.so 3059 
            pass
18271 kshitij.so 3060 
    try:
3061 
        if item[0]['source_id']==4:
3062 
            item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
3063 
            if item_availability_info is None or len(item_availability_info)==0:
3064 
                item[0]['availabilityInfo'] = [{}]
3065 
            else:
3066 
                item[0]['availabilityInfo'] = item_availability_info
3067 
    except:
3068 
        item[0]['availabilityInfo'] = [{}]
19193 kshitij.so 3069 
 
3070 
    if item[0]['source_id']==4:
3071 
        for av_info in item[0]['availabilityInfo']:
3072 
            if not av_info:
3073 
                continue
3074 
            av_info['cash_back'] = item[0]['cash_back']
3075 
            av_info['cash_back_type'] = item[0]['cash_back_type']
3076 
            netPriceAfterCashBack = av_info['sellingPrice']
19199 kshitij.so 3077 
            if av_info['cash_back_type'] ==1:
19207 kshitij.so 3078 
                netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(float(av_info['sellingPrice'])*av_info['cash_back']/100)
19199 kshitij.so 3079 
            elif av_info['cash_back_type'] ==2:
19207 kshitij.so 3080 
                netPriceAfterCashBack = av_info['sellingPrice'] - math.floor(av_info['cash_back'])
19193 kshitij.so 3081 
            else:
3082 
                pass
3083 
            av_info['netPriceAfterCashBack'] = netPriceAfterCashBack
3084 
 
3085 
    if item[0]['source_id'] != SOURCE_MAP.get("PAYTM.COM"):
3086 
        if item[0]['codAvailable'] ==1:
3087 
            paytmPrice = item[0]['available_price']
3088 
        else:
3089 
            paytmPrice = item[0]['gross_price']
3090 
 
3091 
        if item[0]['cash_back_type'] ==1:
19207 kshitij.so 3092 
            item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(float(paytmPrice)*item[0]['cash_back']/100)
19193 kshitij.so 3093 
        elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 3094 
            item[0]['netPriceAfterCashBack'] = paytmPrice -  math.floor(item[0]['cash_back'])
19193 kshitij.so 3095 
        else:
3096 
            item[0]['netPriceAfterCashBack'] = paytmPrice
3097 
 
3098 
    else:
3099 
        if item[0]['cash_back_type'] ==1:
19207 kshitij.so 3100 
            item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(float(item[0]['available_price'])*item[0]['cash_back']/100)
19193 kshitij.so 3101 
        elif item[0]['cash_back_type'] ==2:
19207 kshitij.so 3102 
            item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(item[0]['cash_back'])
19193 kshitij.so 3103 
        else:
3104 
            item[0]['netPriceAfterCashBack'] = item[0]['available_price']
3105 
 
18271 kshitij.so 3106 
    return item[0]
3107 
 
19288 kshitij.so 3108 
def getOfferForUser(userId):
3109 
    specialOffer = {}
3110 
    promoOffer = get_mongo_connection().Catalog.PromoOffer.find_one({'user_id':userId})
3111 
    try:
3112 
        if promoOffer is not None:
3113 
            offer = get_mongo_connection().Catalog.Promotions.find_one({'_id':promoOffer.get('offer_id')})
3114 
            if offer is None:
3115 
                raise
19355 kshitij.so 3116 
            promo = Promotion(offer.get('_id'),offer.get('offer_name'),offer.get('offer_description') , offer.get('categories_applicable'), offer.get('sub_categories_not_applicable'),
19331 kshitij.so 3117 
                     offer.get('startDate'), offer.get('endDate'), promoOffer.get('target1'), promoOffer.get('target1_cash_back_percetage'), promoOffer.get('target2'), promoOffer.get('target2_cash_back_percetage'), promoOffer.get('maxCashBack'), offer.get('url'),
19350 kshitij.so 3118 
                     promoOffer.get('pending_order_value'), promoOffer.get('delivered_order_value'), promoOffer.get('last_run_timestamp'))
19354 kshitij.so 3119 
 
19355 kshitij.so 3120 
            promo.offer_description = "Get upto %d%% cashback"%(promo.target2_cash_back_percetage)
3121 
 
19288 kshitij.so 3122 
            specialOffer = promo.__dict__
3123 
    except:
3124 
        pass
3125 
    return specialOffer
3126 
 
19389 kshitij.so 3127 
def getBrandSubCategoryInfo(category_id, id_list, type):
19402 kshitij.so 3128 
    try:
3129 
        id_list_mapping = {}
3130 
        if type == "brandInfo":
3131 
            brands = [int(brand_id) for brand_id in id_list.split('^')]
3132 
            for brand in brands:
3133 
                tm_brand = get_mongo_connection().Catalog.Deals.find_one({'brand_id':brand},{'brand':1})
3134 
                id_list_mapping[brand] = tm_brand.get('brand')
3135 
        elif type == "subCategoryInfo":
3136 
            subCategories = [int(subCategoryId) for subCategoryId in id_list.split('^')]
3137 
            for subCat in subCategories:
3138 
                id_list_mapping[subCat] = SUB_CATEGORY_MAP.get(subCat)
3139 
        else:
3140 
            return {}
19389 kshitij.so 3141 
 
19402 kshitij.so 3142 
        if mc.get("brandSubCategoryInfo") is None:
3143 
            collection =  get_mongo_connection().Catalog.Deals
3144 
            result = collection.aggregate(
3145 
                    [
3146 
                        {'$match':{'category_id':category_id,'showDeal':1}},
3147 
                        {"$group": { "_id": { "subCategoryId": "$subCategoryId", "brand_id": "$brand_id", "brand":"$brand","subCategory":"$subCategory" }, "count": {"$sum": 1} } }
3148 
                    ]
3149 
                );
3150 
            #from pprint import pprint
3151 
            #pprint(result)
3152 
 
3153 
            subCategoryMap = {}
3154 
            brandMap = {}
3155 
 
3156 
            for data in result['result']:
3157 
                result_set = data['_id']
3158 
                count = data['count']
3159 
                subCategoryId = result_set['subCategoryId']
3160 
                brand_id = result_set['brand_id']
3161 
                subCategory = result_set['subCategory']
3162 
                brand = result_set['brand']
3163 
 
3164 
                if subCategoryMap.has_key(subCategoryId):
3165 
                    subCategoryMap.get(subCategoryId).append({'brand_id':brand_id, 'count':count, 'subCategory':subCategory, 'brand':brand})
3166 
                else:
3167 
                    subCategoryMap[subCategoryId] = [{'brand_id':brand_id, 'count':count, 'subCategory':subCategory, 'brand':brand}]
3168 
 
3169 
                if brandMap.has_key(brand_id):
3170 
                    brandMap.get(brand_id).append({'subCategoryId':subCategoryId, 'count':count, 'subCategory':subCategory, 'brand':brand})
3171 
                else:
3172 
                    brandMap[brand_id] = [{'subCategoryId':subCategoryId, 'count':count, 'subCategory':subCategory, 'brand':brand}]
3173 
 
3174 
            mc.set("brandSubCategoryInfo",{'subCategoryMap':subCategoryMap, 'brandMap': brandMap}, 600)
19389 kshitij.so 3175 
 
19402 kshitij.so 3176 
 
3177 
        returnMap = {}
3178 
        brandSubCategoryInfo = mc.get("brandSubCategoryInfo")
3179 
        if brandSubCategoryInfo is None:
3180 
            return {'idListInfo':id_list_mapping,'result':[]}
3181 
 
3182 
        if type == "subCategoryInfo":
3183 
            if brandSubCategoryInfo.get('subCategoryMap') is None:
3184 
                return {'idListInfo':id_list_mapping,'result':[]}
3185 
            subCategories = [int(subCategoryId) for subCategoryId in id_list.split('^')]
3186 
            subCategoryMap = brandSubCategoryInfo.get('subCategoryMap')
3187 
            for subCategory in subCategories:
3188 
                tempList = subCategoryMap.get(subCategory)
3189 
                print tempList
3190 
                if tempList is None:
3191 
                    continue
3192 
                for v in tempList:
3193 
                    if returnMap.has_key(v['brand_id']):
3194 
                        existing = returnMap.get(v['brand_id'])
3195 
                        existing['count'] = existing['count'] + v['count']
3196 
                    else:
3197 
                        returnMap[v['brand_id']] = {'brand_id':v['brand_id'],'brand':v['brand'],'count':v['count']}
19389 kshitij.so 3198 
 
19402 kshitij.so 3199 
 
3200 
        elif type == "brandInfo":
3201 
            if brandSubCategoryInfo.get('brandMap') is None:
3202 
                return {'idListInfo':id_list_mapping,'result':[]}
3203 
            brands = [int(brand_id) for brand_id in id_list.split('^')]
3204 
            brandMap = brandSubCategoryInfo.get('brandMap')
3205 
            for brand_id in brands:
3206 
                tempList = brandMap.get(brand_id)
3207 
                print tempList
3208 
                if tempList is None:
3209 
                    continue
3210 
                for v in tempList:
3211 
                    if returnMap.has_key(v['subCategoryId']):
3212 
                        existing = returnMap.get(v['subCategoryId'])
3213 
                        existing['count'] = existing['count'] + v['count']
3214 
                    else:
3215 
                        returnMap[v['subCategoryId']] = {'subCategoryId':v['subCategoryId'],'subCategory':v['subCategory'],'count':v['count']}
19389 kshitij.so 3216 
 
19402 kshitij.so 3217 
        return {'idListInfo':id_list_mapping,'result':returnMap.values()}
3218 
    except:
3219 
        traceback.print_exc()
3220 
        return {}
19389 kshitij.so 3221 
 
19451 manas 3222 
def refundAmountInWallet(jsonReq):
3223 
    userId = int(jsonReq.get('user_id'))
3224 
    emailId = jsonReq.get('email_id')
3225 
    amount = int(jsonReq.get('amount'))
3226 
    store = jsonReq.get('store')
3227 
    refundType = jsonReq.get('type')
3228 
    mobileNumber = jsonReq.get('mobile')
3229 
    referenceId = jsonReq.get('reference_no')
3230 
    referenceDescription = jsonReq.get('reference_description')
19514 manas 3231 
    if not store:
19456 manas 3232 
        store = None
19514 manas 3233 
    else:
19517 manas 3234 
        store = store
19451 manas 3235 
    if lower(refundType)=='refund':
19511 manas 3236 
        refundType = CREDIT_TYPE_REFUND
19451 manas 3237 
    elif lower(refundType)=='adjustment':
19511 manas 3238 
        refundType = CREDIT_TYPE_ADJUSTMENT
19451 manas 3239 
    collection = get_mongo_connection().Dtr.crmrefundwallet
19511 manas 3240 
    offer1 = CrmRefundWallet(userId,emailId,mobileNumber,amount,refundType,store,referenceId,referenceDescription,REFUND_ADJUSTMENT_MAP.get(0),to_java_date(datetime.now()))
19451 manas 3241 
    dict1 = todict(offer1)
3242 
    collection.save(dict1)
3243 
    return True
3244 
 
19497 manas 3245 
def updateCrmWalletStatus(status,_id,userId,batchId,approvedBy):
19482 manas 3246 
    if batchId is None:
3247 
        get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now())}})
3248 
    else:
19497 manas 3249 
        get_mongo_connection().Dtr.crmrefundwallet.update({'_id':ObjectId(_id),},{"$set":{"status":status,"update_timestamp":to_java_date(datetime.now()),"batchId":batchId,"approved_by":approvedBy}})
19463 manas 3250 
 
19451 manas 3251 
def fetchCrmRefundUsers(status,offset,limit):
19529 manas 3252 
    if status is not None:
3253 
        cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find({"status":status}).skip(offset).limit(limit).sort("created_timestamp",-1))
3254 
    else:
3255 
        cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find().skip(offset).limit(limit).sort("created_timestamp",-1))
19451 manas 3256 
    return cursor
3257 
 
19485 manas 3258 
def fetchCrmRefundByBatchId(batchId):
19493 manas 3259 
    cursor = get_mongo_connection().Dtr.crmrefundwallet.find_one({"batchId":int(batchId)})
19485 manas 3260 
    return cursor
3261 
 
19453 manas 3262 
 
13572 kshitij.so 3263 
def main():
19512 kshitij.so 3264 
    #getDealsForSearchText("20", 'Samsung', 0, 10)
3265 
 
3266 
    x = getBrandSubCategoryInfo(6,"15^17","subCategoryInfo")
3267 
    print "==============="
3268 
    print x
17944 kshitij.so 3269 
 
13572 kshitij.so 3270 
if __name__=='__main__':
19512 kshitij.so 3271 
    main()
3272 
 
3273