Subversion Repositories SmartDukaan

Rev

Rev 13840 | Rev 13910 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 13840 Rev 13907
Line 2... Line 2...
2 
from datetime import datetime
 2 
from datetime import datetime
3 
from dtr.utils.utils import to_java_date
 3 
from dtr.utils.utils import to_java_date
4 
from operator import itemgetter
4 
from operator import itemgetter
5 
 
 5 
 
6 
con = None
 6 
con = None
- 
 
 7 
cashBackMap = {}
7 
 
 8 
 
8 
def get_mongo_connection(host='localhost', port=27017):
 9 
def get_mongo_connection(host='localhost', port=27017):
9 
    global con
 10 
    global con
10 
    if con is None:
 11 
    if con is None:
11 
        print "Establishing connection %s host and port %d" %(host,port)
 12 
        print "Establishing connection %s host and port %d" %(host,port)
Line 14... Line 15...
14 
        except Exception, e:
 15 
        except Exception, e:
15 
            print e
 16 
            print e
16 
            return None
 17 
            return None
17 
    return con
 18 
    return con
18 
 
 19 
 
- 
 
 20 
def populateCashBack():
- 
 
 21 
    global cashBackMap
- 
 
 22 
    cashBack = list(get_mongo_connection().Catalog.CategoryCashBack.find())
- 
 
 23 
    for row in cashBack:
- 
 
 24 
        if cashBackMap.has_key(row['source_id']):
- 
 
 25 
            temp_map = {}
- 
 
 26 
            temp_list = []
- 
 
 27 
            arr = cashBackMap.get(row['source_id'])
- 
 
 28 
            for val in arr:
- 
 
 29 
                temp_list.append(val)
- 
 
 30 
            temp_map[row['category_id']] = row
- 
 
 31 
            temp_list.append(temp_map)
- 
 
 32 
            cashBackMap[row['source_id']] = temp_list
- 
 
 33 
        else:
- 
 
 34 
            temp_map = {}
- 
 
 35 
            temp_list = []
- 
 
 36 
            temp_map[row['category_id']] = row
- 
 
 37 
            temp_list.append(temp_map)
- 
 
 38 
            cashBackMap[row['source_id']] = temp_list
- 
 
 39 
    for x, y in cashBackMap.iteritems():
- 
 
 40 
        print x
- 
 
 41 
        print y
- 
 
 42 
        print "================="
- 
 
 43
- 
 
 44 
 
19 
def addCategoryDiscount(data):
 45 
def addCategoryDiscount(data):
20 
    collection = get_mongo_connection().Dtr.CategoryDiscount
 46 
    collection = get_mongo_connection().Dtr.CategoryDiscount
21 
    query = []
 47 
    query = []
22 
    data['brand'] = data['brand'].strip().upper()
 48 
    data['brand'] = data['brand'].strip().upper()
23 
    query.append({"brand":data['brand']})
 49 
    query.append({"brand":data['brand']})
Line 122... Line 148...
122 
        direct = -1
 148 
        direct = -1
123 
    else:
 149 
    else:
124 
        sortField = sort
 150 
        sortField = sort
125 
        direct = direction
 151 
        direct = direction
126 
    if category_id == 0:
 152 
    if category_id == 0:
- 
 
 153 
        print "All categories deals"
- 
 
 154 
        print category_id
- 
 
 155 
        print sortField
- 
 
 156 
        print offset
- 
 
 157 
        print limit
- 
 
 158 
        print direct
127 
        data = list(get_mongo_connection().Catalog.Deals.find({'rank':{'$gt':0},'showDeal':1}).sort([(sortField,direct)]).skip(offset).limit(limit))
 159 
        data = list(get_mongo_connection().Catalog.Deals.find({'rank':{'$gt':0},'showDeal':1}).sort([(sortField,direct)]).skip(offset).limit(limit))
128 
    else:
 160 
    else:
- 
 
 161 
        print "selective category deals"
- 
 
 162 
        print category_id
- 
 
 163 
        print sortField
- 
 
 164 
        print offset
- 
 
 165 
        print limit
- 
 
 166 
        print direct
129 
        data = list(get_mongo_connection().Catalog.Deals.find({'rank':{'$gt':0},'category_id':category_id,'showDeal':1}).sort([(sortField,direct)]).skip(offset).limit(limit))
 167 
        data = list(get_mongo_connection().Catalog.Deals.find({'rank':{'$gt':0},'category_id':category_id,'showDeal':1}).sort([(sortField,direct)]).skip(offset).limit(limit))
130 
    print data[0]['_id']
 168 
    print data[0]['_id']
131 
    for d in data:
 169 
    for d in data:
132 
        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
 170 
        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
133 
        if not deals.has_key(item[0]['identifier']):
 171 
        if not deals.has_key(item[0]['identifier']):
Line 163... Line 201...
163
201
164
202
165
203
166 
 
 204 
 
167 
def main():
 205 
def main():
168 
    getDeals(3, 0, 10,"","")
 206 
    populateCashBack()
169
207
170 
if __name__=='__main__':
 208 
if __name__=='__main__':
171 
    main()
 209 
    main()
172 

            210