Subversion Repositories SmartDukaan

Rev

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

Rev 22317 Rev 22318
Line 21... Line 21...
21 
parser.add_option("-d", "--d", dest="dbHost",
 21 
parser.add_option("-d", "--d", dest="dbHost",
22 
                      default="127.0.0.1",
 22 
                      default="127.0.0.1",
23 
                      type="string", help="The HOST where the mysql server is running",
 23 
                      type="string", help="The HOST where the mysql server is running",
24 
                      metavar="DBHOST")
 24 
                      metavar="DBHOST")
25 
parser.add_option("-s", "--s", dest="solrPath",
 25 
parser.add_option("-s", "--s", dest="solrPath",
26 
                      default="http://localhost:8983/solr/demo1",
 26 
                      default="http://localhost:8984/solr/demo1",
27 
                      type="string", help="Complete solr path",
 27 
                      type="string", help="Complete solr path",
28 
                      metavar="SOLRHOST")
 28 
                      metavar="SOLRHOST")
29 
parser.add_option("-m", "--m", dest="mongoHost",
 29 
parser.add_option("-m", "--m", dest="mongoHost",
30 
                      default="localhost",
 30 
                      default="localhost",
31 
                      type="string", help="Complete solr path",
 31 
                      type="string", help="Complete solr path",
Line 124... Line 124...
124 
 
 124 
 
125 
def populateTagItems():
 125 
def populateTagItems():
126
126
127
127
128 
    tagRankingList = session.query(Tag_Ranking.catalogItemId).order_by(desc(Tag_Ranking.rankPoints)).all()
 128 
    tagRankingList = session.query(Tag_Ranking.catalogItemId).order_by(desc(Tag_Ranking.rankPoints)).all()
129
- 
 
130
- 
 
- 
 
 129 
    tagRankingList = [catalogId for (catalogId,) in tagRankingList]
131
130
132 
    catalogMap = {}
 131 
    catalogMap = {}
133 
    #stmt = session.query(PrivateDeals).filter_by(isActive=1).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).subquery()
 132 
    #stmt = session.query(PrivateDeals).filter_by(isActive=1).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).subquery()
134 
    #query = session.query(Item, privateDealAlias.dealPrice).outerjoin((privateDealAlias, Item.id==privateDealAlias.item_id)).filter(Item.status != status.PHASED_OUT)
 133 
    #query = session.query(Item, privateDealAlias.dealPrice).outerjoin((privateDealAlias, Item.id==privateDealAlias.item_id)).filter(Item.status != status.PHASED_OUT)
135 
    tuples = session.query(Tag_Listing, Item).join((Item, Item.id==Tag_Listing.item_id)).filter(or_(Item.status==status.ACTIVE, Item.status==status.PAUSED_BY_RISK)).filter(Tag_Listing.active==True)
 134 
    tuples = session.query(Tag_Listing, Item).join((Item, Item.id==Tag_Listing.item_id)).filter(or_(Item.status==status.ACTIVE, Item.status==status.PAUSED_BY_RISK)).filter(Tag_Listing.active==True)
Line 151... Line 150...
151 
            try:
150 
            try:
152 
                catalogObj['rank'] = tagRankingList.index(item.catalog_item_id)
 151 
                catalogObj['rank'] = tagRankingList.index(item.catalog_item_id)
153 
            except:
 152 
            except:
154 
                #A very big number
 153 
                #A very big number
155 
                catalogObj['rank'] = 500000
 154 
                catalogObj['rank'] = 500000
- 
 
 155 
                traceback.print_exc()
156 
 
 156 
 
157 
            catalogObj['categoryId'] = 3 if item.category in [10006, 10009] else 6
157 
            catalogObj['categoryId'] = 3 if item.category in [10006, 10009] else 6
158 
            catalogMap[item.catalog_item_id] = catalogObj
 158 
            catalogMap[item.catalog_item_id] = catalogObj
159 
 
 159 
 
160 
        catalogObj = catalogMap.get(item.catalog_item_id)
 160 
        catalogObj = catalogMap.get(item.catalog_item_id)
Line 203... Line 203...
203 
    #orderedMap = orderIt
 203 
    #orderedMap = orderIt
204 
    #convertToSolrDoc()
204 
    #convertToSolrDoc()
205
205
206 
if __name__=='__main__':
 206 
if __name__=='__main__':
207 
    pushData()
 207 
    pushData()
- 
 
 208 
    #solr.delete(q='*:*')
- 
 
 209 
    #solr.add([{'_childDocuments_': [{'itemId_i': 26564L, 'mop_f': 100.0, 'tagId_i': 2L, 'sellingPrice_f': 2600.0, 'color_s': '', 'id': 'itemtag-26564-2'}, {'itemId_i': 1, 'mop_f': 460.0, 'tagId_i': 2, 'sellingPrice_f': 500.0, 'color_s': 'Black', 'id': 'dummy'}], 'catalogId_i': 1019937L, 'rank_i': 500000, 'id': 'catalog1019937', 'title_s': 'Micromax Spark Vdeo Q415'}, {'_childDocuments_': [{'itemId_i': 26691L, 'mop_f': 4500.0, 'tagId_i': 4L, 'sellingPrice_f': 4299.0, 'color_s': 'Gold', 'id': 'itemtag-26691-4'}], 'catalogId_i': 1020034L, 'rank_i': 500000, 'id': 'catalog1020034', 'title_s': 'Samsung Z2'}, {'_childDocuments_': [{'itemId_i': 21585L, 'mop_f': 33000.0, 'tagId_i': 4L, 'sellingPrice_f': 31990.0, 'color_s': '', 'id': 'itemtag-21585-4'}], 'catalogId_i': 1015720L, 'rank_i': 500000, 'id': 'catalog1015720', 'title_s': 'HTC One A9 16GB'}, {'_childDocuments_': [{'itemId_i': 15663L, 'mop_f': 8000.0, 'tagId_i': 4L, 'sellingPrice_f': 7529.0, 'color_s': 'Black', 'id': 'itemtag-15663-4'}], 'catalogId_i': 1010735L, 'rank_i': 500000, 'id': 'catalog1010735', 'title_s': 'HTC Desire 210 Dual SIM'}, {'_childDocuments_': [{'itemId_i': 15549L, 'mop_f': 11000.0, 'tagId_i': 4L, 'sellingPrice_f': 10599.0, 'color_s': 'Matte Blue', 'id': 'itemtag-15549-4'}], 'catalogId_i': 1010312L, 'rank_i': 500000, 'id': 'catalog1010312', 'title_s': 'HTC Desire 310'}, {'_childDocuments_': [{'itemId_i': 18083L, 'mop_f': 10500.0, 'tagId_i': 4L, 'sellingPrice_f': 9999.0, 'color_s': 'Black', 'id': 'itemtag-18083-4'}], 'catalogId_i': 1012434L, 'rank_i': 500000, 'id': 'catalog1012434', 'title_s': 'HTC Desire 326G'}, {'_childDocuments_': [{'itemId_i': 26864L, 'mop_f': 3500.0, 'tagId_i': 4L, 'sellingPrice_f': 3299.0, 'color_s': 'Black', 'id': 'itemtag-26864-4'}], 'catalogId_i': 1020180L, 'rank_i': 500000, 'id': 'catalog1020180', 'title_s': 'Intex Aqua A4'}, {'_childDocuments_': [{'itemId_i': 26872L, 'mop_f': 4500.0, 'tagId_i': 4L, 'sellingPrice_f': 4299.0, 'color_s': 'Black', 'id': 'itemtag-26872-4'}], 'catalogId_i': 1020185L, 'rank_i': 500000, 'id': 'catalog1020185', 'title_s': 'Karbonn Indian 9 4G VoLTE'}, {'_childDocuments_': [{'itemId_i': 16404L, 'mop_f': 13950.0, 'tagId_i': 4L, 'sellingPrice_f': 13799.0, 'color_s': 'Pearl White', 'id': 'itemtag-16404-4'}], 'catalogId_i': 1011256L, 'rank_i': 500000, 'id': 'catalog1011256', 'title_s': 'HTC Desire 516 Dual SIM'}, {'_childDocuments_': [{'itemId_i': 26860L, 'mop_f': 3300.0, 'tagId_i': 4L, 'sellingPrice_f': 3199.0, 'color_s': 'Black', 'id': 'itemtag-26860-4'}], 'catalogId_i': 1020025L, 'rank_i': 500000, 'id': 'catalog1020025', 'title_s': 'Karbonn A40 Indian'}, {'_childDocuments_': [{'itemId_i': 26614L, 'mop_f': 4000.0, 'tagId_i': 4L, 'sellingPrice_f': 3890.0, 'color_s': 'Champagne', 'id': 'itemtag-26614-4'}], 'catalogId_i': 1019962L, 'rank_i': 500000, 'id': 'catalog1019962', 'title_s': 'Intex Aqua Strong 5.1 Plus'}])