Rev 20080 | Rev 20086 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
from walrus import *from dtr.utils.utils import get_mongo_connection, REVERSE_SOURCE_MAP, CATEGORY_MAP, SUB_CATEGORY_MAPimport randomxstr = lambda s: s or ""database = Database()ac = database.autocomplete()class Suggestion():def __init__(self, category_id, subCategoryId, suggestion, word):self.category_id = category_idself.subCategoryId = subCategoryIdself.suggestion = suggestionself.word = worddef filterSuggestions(categorySuggestion):returnObj = []for cat in ('Mobiles','Tablets'):v = categorySuggestion.get(CATEGORY_MAP.get(cat))if v is not None:returnObj.append(v[0].__dict__)select_range = 2 if len(v[1:]) > 2 else len(v[1:])random_list = random.sample(set(v[1:]), select_range)for random_suggestion in random_list:returnObj.append(random_suggestion.__dict__)categorySuggestion.pop(CATEGORY_MAP.get(cat))for v in categorySuggestion.itervalues():returnObj.append(v[0].__dict__)select_range = 2 if len(v[1:]) > 2 else len(v[1:])random_list = random.sample(set(v[1:]), select_range)for random_suggestion in random_list:returnObj.append(random_suggestion.__dict__)return returnObjdef getSuggestions(search_text):categorySuggestion = {}results = list(ac.search(search_text))returnObj = []if len(results) > 10:"""Lets group data"""for i in results:if i.get('subCategoryId'):if not categorySuggestion.has_key(i.get('subCategoryId')):suggestion_obj_primary = Suggestion(i.get('category_id'),i.get('subCategoryId'),search_text+" in "+SUB_CATEGORY_MAP.get(i.get('subCategoryId')), search_text)suggestion_obj = Suggestion(i.get('category_id'),i.get('subCategoryId'),i.get('title'), i.get('title'))categorySuggestion[i.get('subCategoryId')] = [suggestion_obj_primary,suggestion_obj]else:suggestion_obj = Suggestion(i.get('category_id'),i.get('subCategoryId'),i.get('title'), i.get('title'))categorySuggestion.get(i.get('subCategoryId')).append(suggestion_obj)else:if not categorySuggestion.has_key(i.get('category_id')):suggestion_obj_primary = Suggestion(i.get('category_id'),i.get('subCategoryId'),search_text+" in "+CATEGORY_MAP.get(i.get('category_id')), search_text)suggestion_obj = Suggestion(i.get('category_id'),i.get('subCategoryId'),i.get('title'), i.get('title'))categorySuggestion[i.get('category_id')] = [suggestion_obj_primary, suggestion_obj]else:suggestion_obj = Suggestion(i.get('category_id'),i.get('subCategoryId'),i.get('title'), i.get('title'))categorySuggestion.get(i.get('category_id')).append(suggestion_obj)returnObj = filterSuggestions(categorySuggestion)else:for i in results:returnObj.append({'suggestion':i.get('title'),'category_id':i.get('category_id'),'subCategoryId':i.get('subCategoryId')})return returnObjdef main():passif __name__ == "__main__":main()