| Line 11... |
Line 11... |
| 11 |
import os
|
11 |
import os
|
| 12 |
import pymongo
|
12 |
import pymongo
|
| 13 |
import pysolr
|
13 |
import pysolr
|
| 14 |
import shutil
|
14 |
import shutil
|
| 15 |
import traceback
|
15 |
import traceback
|
| - |
|
16 |
from dtr.utils.utils import to_java_date
|
| 16 |
#import pymongo
|
17 |
#import pymongo
|
| 17 |
#import pysolr
|
18 |
#import pysolr
|
| 18 |
|
19 |
|
| 19 |
|
20 |
|
| 20 |
parser = optparse.OptionParser()
|
21 |
parser = optparse.OptionParser()
|
| 21 |
parser.add_option("-d", "--d", dest="dbHost",
|
22 |
parser.add_option("-d", "--d", dest="dbHost",
|
| 22 |
default="127.0.0.1",
|
23 |
default="127.0.0.1",
|
| 23 |
type="string", help="The HOST where the mysql server is running",
|
24 |
type="string", help="The HOST where the mysql server is running",
|
| 24 |
metavar="DBHOST")
|
25 |
metavar="DBHOST")
|
| 25 |
parser.add_option("-s", "--s", dest="solrPath",
|
26 |
parser.add_option("-s", "--s", dest="solrPath",
|
| 26 |
default="http://localhost:8984/solr/demo1",
|
27 |
default="http://localhost:8984/solr/ 1",
|
| 27 |
type="string", help="Complete solr path",
|
28 |
type="string", help="Complete solr path",
|
| 28 |
metavar="SOLRHOST")
|
29 |
metavar="SOLRHOST")
|
| 29 |
parser.add_option("-m", "--m", dest="mongoHost",
|
30 |
parser.add_option("-m", "--m", dest="mongoHost",
|
| 30 |
default="localhost",
|
31 |
default="localhost",
|
| 31 |
type="string", help="Complete solr path",
|
32 |
type="string", help="Complete solr path",
|
| Line 158... |
Line 159... |
| 158 |
#A very big number
|
159 |
#A very big number
|
| 159 |
catalogObj['rank'] = 50000000
|
160 |
catalogObj['rank'] = 50000000
|
| 160 |
traceback.print_exc()
|
161 |
traceback.print_exc()
|
| 161 |
#Mobile and tablets are showcased in same category
|
162 |
#Mobile and tablets are showcased in same category
|
| 162 |
catalogObj['categoryId'] = 3 if item.category in [10006, 10009] else 6
|
163 |
catalogObj['categoryId'] = 3 if item.category in [10006, 10009] else 6
|
| - |
|
164 |
catalogObj['create_timestamp'] = to_java_date(tag.create_timestamp)
|
| 163 |
catalogMap[item.catalog_item_id] = catalogObj
|
165 |
catalogMap[item.catalog_item_id] = catalogObj
|
| 164 |
|
166 |
|
| 165 |
catalogObj = catalogMap.get(item.catalog_item_id)
|
167 |
catalogObj = catalogMap.get(item.catalog_item_id)
|
| 166 |
|
168 |
|
| 167 |
if tag.hot_deals:
|
169 |
if tag.hot_deals:
|
| Line 183... |
Line 185... |
| 183 |
for tag in tags:
|
185 |
for tag in tags:
|
| 184 |
itemObj = {'id':('itemtag-%s-%s'%(itemId, tag.tag_id)), 'color_s':itemMap['color'], 'itemId_i': itemId, 'tagId_i':tag.tag_id,
|
186 |
itemObj = {'id':('itemtag-%s-%s'%(itemId, tag.tag_id)), 'color_s':itemMap['color'], 'itemId_i': itemId, 'tagId_i':tag.tag_id,
|
| 185 |
'mop_f': tag.mop, 'sellingPrice_f': tag.selling_price}
|
187 |
'mop_f': tag.mop, 'sellingPrice_f': tag.selling_price}
|
| 186 |
itemObjs.append(itemObj)
|
188 |
itemObjs.append(itemObj)
|
| 187 |
catalogObj = {'id':'catalog' + str(catalogId), 'rank_i':catalogMap['rank'], 'title_s': catalogMap['title'],'hot_deals_b':catalogMap['hot_deals'], '_childDocuments_':itemObjs, 'catalogId_i':catalogId, 'imageUrl_s': catalogMap['imageUrl'],
|
189 |
catalogObj = {'id':'catalog' + str(catalogId), 'rank_i':catalogMap['rank'], 'title_s': catalogMap['title'],'hot_deals_b':catalogMap['hot_deals'], '_childDocuments_':itemObjs, 'catalogId_i':catalogId, 'imageUrl_s': catalogMap['imageUrl'],
|
| 188 |
'brand_s': catalogMap['brand']}
|
190 |
'brand_s': catalogMap['brand'], 'create_i':catalogMap['create_timestamp']}
|
| 189 |
catalogObjs.append(catalogObj)
|
191 |
catalogObjs.append(catalogObj)
|
| 190 |
solr.delete(q='*:*')
|
192 |
solr.delete(q='*:*')
|
| 191 |
solr.add(catalogObjs)
|
193 |
solr.add(catalogObjs)
|
| 192 |
|
194 |
|
| 193 |
|
195 |
|