Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
339 rajveer 1
package in.shop2020.serving.controllers;
1044 chandransh 2
 
2263 vikas 3
import in.shop2020.datalogger.EventType;
3561 rajveer 4
import in.shop2020.serving.cache.EhcacheWrapper.CacheKeys;
5
import in.shop2020.serving.cache.SnippetCacheWrapper;
339 rajveer 6
import in.shop2020.serving.services.SolrSearchService;
637 rajveer 7
import in.shop2020.serving.utils.Utils;
2511 vikas 8
import in.shop2020.utils.DataLogger;
339 rajveer 9
 
10
import java.io.UnsupportedEncodingException;
11
import java.net.URLEncoder;
12
import java.util.ArrayList;
13
import java.util.Arrays;
354 rajveer 14
import java.util.HashMap;
339 rajveer 15
import java.util.LinkedHashMap;
16
import java.util.List;
17
import java.util.Map;
2948 chandransh 18
import java.util.Map.Entry;
339 rajveer 19
 
20
import org.apache.commons.lang.StringUtils;
832 rajveer 21
import org.apache.log4j.Logger;
820 rajveer 22
import org.apache.struts2.convention.annotation.Result;
339 rajveer 23
 
1044 chandransh 24
 
339 rajveer 25
/**
545 rajveer 26
 * @author rajveer
339 rajveer 27
 *
28
 */
820 rajveer 29
@Result(name="redirect", location="${location}", type="redirect")
517 rajveer 30
public class SearchController extends BaseController {
339 rajveer 31
 
1044 chandransh 32
	private static final long serialVersionUID = -8392433517042806559L;
1999 vikas 33
	private static Logger log = Logger.getLogger(Class.class);
1044 chandransh 34
 
790 vikas 35
	private List<String> results;
517 rajveer 36
 
339 rajveer 37
	/**
38
	 * 
39
	 */
517 rajveer 40
	private Map<String, String> snippets;
339 rajveer 41
 
42
	/**
43
	 * 
44
	 */
545 rajveer 45
	private Map<String, List<String[]>> facets = null;
339 rajveer 46
 
47
	/**
48
	 * 
49
	 */
50
	private List<String[]> crumbs;
51
 
517 rajveer 52
	private String  query;
569 rajveer 53
	private String sortOrder = null;
545 rajveer 54
	private Double minPrice = null;
55
	private Double maxPrice = null;
354 rajveer 56
 
545 rajveer 57
	private long windowSize = 10;
58
	private long page = 1;
59
	private long totalResults;
60
	private long beginIndex = 0;
61
	private String url;
1921 vikas 62
	private String priceUrl = "?";
3561 rajveer 63
	private long categoryId = Utils.ROOT_CATEGORY;
569 rajveer 64
	private String sortUrl;
820 rajveer 65
	private String location;
4137 varun.gupt 66
 
339 rajveer 67
	/**
68
	 * 
69
	 * @return
70
	 * @throws UnsupportedEncodingException
71
	 */
72
    // GET /query
820 rajveer 73
 
74
    public String index() throws UnsupportedEncodingException {
517 rajveer 75
 
650 rajveer 76
    	log.info("this.request=" + this.request);
637 rajveer 77
 
545 rajveer 78
    	//url = this.request.getRequestURL();
79
		query = this.request.getParameter("q");
80
		url = "q="+ URLEncoder.encode(query, "UTF-8");
569 rajveer 81
 
82
 
83
		if(this.request.getParameter("category") != null){
84
    		this.categoryId = Long.parseLong(this.request.getParameter("category"));
85
    		url= url + "&category=" + this.request.getParameter("category");
86
    	}
820 rajveer 87
		if(query.trim().isEmpty()){
2606 rajveer 88
			if(categoryId == Utils.MOBILE_PHONES_CATEGORY){
1472 rajveer 89
				location = "/all-mobile-phones/" + categoryId;
820 rajveer 90
				return "redirect";
2606 rajveer 91
			}else if(categoryId == Utils.MOBILE_ACCESSORIES_CATEGORY){
1472 rajveer 92
				location = "/all-mobile-accessories/" + categoryId;
93
				return "redirect";
3656 mandeep.dh 94
			} else if(categoryId == Utils.TABLETS_CATEGORY){
2606 rajveer 95
				location = "/all-tablets/" + categoryId;
96
				return "redirect";
3656 mandeep.dh 97
			} else if(categoryId == Utils.LAPTOPS_CATEGORY){
98
                location = "/all-laptops/" + categoryId;
99
                return "redirect";
5873 amit.gupta 100
			} else if(categoryId == Utils.CAMERAS_CATEGORY){
101
				location = "/all-cameras/" + categoryId;
102
				return "redirect";
3656 mandeep.dh 103
            }else{
820 rajveer 104
				return "index";
105
			}
106
		}
569 rajveer 107
		sortUrl = url;
108
		if(this.request.getParameter("sort") != null){
109
    		url= url + "&sort=" + this.request.getParameter("sort");
110
    		sortOrder = this.request.getParameter("sort");
111
    	}
1921 vikas 112
		priceUrl += url;
545 rajveer 113
    	if(this.request.getParameter("page") != null){
114
    		this.page = Long.parseLong(this.request.getParameter("page"));
115
    		this.beginIndex = this.windowSize * (this.page-1);
536 rajveer 116
    	}
3173 rajveer 117
    	if(this.request.getParameter("minPrice") != null){
118
    		this.minPrice = (new Double(this.request.getParameter("minPrice")));
119
    		url= url + "&minPrice=" + this.request.getParameter("minPrice");
545 rajveer 120
    	}
3173 rajveer 121
    	if(this.request.getParameter("maxPrice") != null){
122
    		this.maxPrice = (new Double(this.request.getParameter("maxPrice")));
123
    		url= url + "&maxPrice=" + this.request.getParameter("maxPrice");
545 rajveer 124
    	}    	
339 rajveer 125
 
569 rajveer 126
 
339 rajveer 127
    	String[] fqrys = this.request.getParameterValues("fq");
545 rajveer 128
 
339 rajveer 129
    	this.crumbs = new ArrayList<String[]>();
130
 
4137 varun.gupt 131
    	String[] facetDefIDs = Utils.facetDefIDs;
132
    	String[] facetLabels = Utils.facetLabels;
569 rajveer 133
 
134
    	String urlCrumb = "";
135
    	if(query != null) {
136
	    	urlCrumb = url; 
137
	    }else {
138
 
139
    	}
140
 
339 rajveer 141
    	if(fqrys != null) {
142
	    	log.info("fqrys=" + Arrays.toString(fqrys));
569 rajveer 143
	    	List<String> arrList = Arrays.asList(facetDefIDs);
144
	    	for(int i=0; i<fqrys.length; i++){
145
	    		urlCrumb += "&fq=" + URLEncoder.encode(fqrys[i], "UTF-8");
146
	    		priceUrl += "&fq=" + URLEncoder.encode(fqrys[i], "UTF-8");
147
	    		sortUrl += "&fq=" + URLEncoder.encode(fqrys[i], "UTF-8");
2948 chandransh 148
	    		StringBuilder filterUrl = new StringBuilder(url);
545 rajveer 149
	    		String facetName = StringUtils.split(fqrys[i], ":")[0];
339 rajveer 150
	    		String facetValue = StringUtils.split(fqrys[i], ":")[1];
569 rajveer 151
	    		String facetLabel = facetLabels[arrList.indexOf(facetName)];  
152
	    		for(int j=0; j<fqrys.length; j++) {
153
	    			if(i==j){
154
	    				continue;
155
	    			}
2948 chandransh 156
	    			filterUrl.append("&fq=" + URLEncoder.encode(fqrys[j], "UTF-8"));
569 rajveer 157
		    	}
2948 chandransh 158
	    		String[] acrumb = new String[] { facetLabel, facetValue, filterUrl.toString() };
569 rajveer 159
	    		log.info("acrumb=" + Arrays.toString(acrumb));
160
	    		this.crumbs.add(acrumb);
161
	    	}
162
    	}
163
    	url = urlCrumb;
517 rajveer 164
 
165
 
339 rajveer 166
 
3561 rajveer 167
    	SolrSearchService search = new SolrSearchService(query, fqrys, facetDefIDs, (page-1)*windowSize, windowSize, minPrice, maxPrice, categoryId, sortOrder, sourceId);
790 vikas 168
 
354 rajveer 169
    	this.results =  search.getResultMap(); 
339 rajveer 170
 
545 rajveer 171
    	// Facets
339 rajveer 172
 
173
    	String qryString = this.request.getQueryString();
174
    	log.info("qryString=" + qryString);
175
 
5525 phani.kuma 176
    	String[] toshowfacetDefIDs;
177
    	String[] toshowfacetLabels;
178
 
179
    	if (categoryId == Utils.ROOT_CATEGORY || categoryId == Utils.MOBILE_ACCESSORIES_CATEGORY ){
180
    		toshowfacetDefIDs = Utils.rootfacetDefIDs;
181
        	toshowfacetLabels = Utils.rootfacetLabels;
182
    	}
183
    	else {
184
    		toshowfacetDefIDs = Utils.facetDefIDs;
185
        	toshowfacetLabels = Utils.facetLabels;
186
    	}
187
 
545 rajveer 188
		this.facets = new LinkedHashMap<String, List<String[]>>();
5525 phani.kuma 189
    	for (int i=0; i<toshowfacetDefIDs.length; i++) {
190
    		String facetDefID = toshowfacetDefIDs[i];
191
    		String facetLabel = toshowfacetLabels[i];
5729 amit.gupta 192
    		Map<String, Integer> facetDetailMap = search.getFacetDetails(facetDefID);
354 rajveer 193
    		if(facetDetailMap==null)
194
    			continue;
195
    		List<String[]> values = new ArrayList<String[]>();
2948 chandransh 196
    		for(Entry<String, Integer> facetEntry : facetDetailMap.entrySet()){
197
    		    String facet = facetEntry.getKey();
545 rajveer 198
    			String drilldownURL = url;  
199
      			drilldownURL += "&fq=" + facetDefID + ":" + 
354 rajveer 200
    				URLEncoder.encode(facet, "UTF-8"); 
201
      			String[] afacet = new String[] { facet, 
2948 chandransh 202
      			      facetEntry.getValue().toString(), drilldownURL  };
354 rajveer 203
      			values.add(afacet);    
204
 
205
    		}
206
 
207
    		this.facets.put(facetLabel, values);
208
    	}
209
 
210
    	Map<String, Double> priceMap = search.getPriceStatsMap();
517 rajveer 211
    	if(priceMap != null){
212
    		this.minPrice = priceMap.get("min");
213
    		this.maxPrice = priceMap.get("max");
214
    	}else{
215
    		this.minPrice = 0.0;
216
    		this.maxPrice = 0.0;
217
    	}
354 rajveer 218
 
545 rajveer 219
    	this.totalResults = search.getTotalResults();
3185 vikas 220
        DataLogger.logData(EventType.PRODUCT_SEARCH, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),
2157 vikas 221
                query, Long.toString(categoryId), Long.toString(totalResults));
820 rajveer 222
    	return "index";
339 rajveer 223
    }
517 rajveer 224
 
225
 
226
    public Map<String, String> getSnippets() throws Exception {
3273 vikas 227
        if(results != null){
228
            snippets = new HashMap<String, String>();   
229
            for(String docId: results){
3561 rajveer 230
                String snippet = (String)SnippetCacheWrapper.getSnippet(CacheKeys.SEARCH_SNIPPET_CACHE_KEY, docId, sourceId);
3273 vikas 231
                if (snippet != null) {
232
                    snippets.put(docId, snippet);
233
                }
234
            }
235
        }
236
        return snippets;
517 rajveer 237
    }
238
 
239
    /**
240
     * 
241
     * @return
242
     */
243
    public String getQuery() {
244
    	return this.query;
245
    }
339 rajveer 246
 
517 rajveer 247
 
339 rajveer 248
    /**
249
     * 
250
     * @return
251
     */
790 vikas 252
    public List<String> getResults() {
339 rajveer 253
    	return this.results;
254
    }
255
 
256
    /**
257
     * 
258
     * @return
259
     */
260
    public Map<String, List<String[]>> getFacets() {
261
    	return this.facets;
262
    }
263
 
545 rajveer 264
    public long getTotalResults(){
265
    	return totalResults;
266
    }
267
 
268
    public String getUrl(){
269
    	return this.url;
270
    }
271
 
272
    public String getPriceUrl(){
273
    	return this.priceUrl;
274
    }
275
 
569 rajveer 276
    public String getSortUrl(){
277
    	return this.sortUrl;
278
    }
279
 
545 rajveer 280
	public long getBeginIndex(){
281
		if(totalResults>0)
282
			return beginIndex+1;
283
		return beginIndex;
284
	}
285
 
286
	public long getTotalPages() {
1376 rajveer 287
		return 1 + (totalResults-1)/windowSize;
545 rajveer 288
	}
289
 
290
	public long getCurrentPage() {
291
		return this.page;
292
	}
293
 
354 rajveer 294
    public Double getMinPrice() {
295
    	return this.minPrice;
296
    }
297
 
298
    public Double getMaxPrice() {
299
    	return this.maxPrice;
300
    }
301
 
339 rajveer 302
    public List<String[]> getCrumbs() {
303
    	return this.crumbs;
304
    }
569 rajveer 305
 
786 rajveer 306
    public String getSortOrder(){
307
    	return this.sortOrder;
308
    }
820 rajveer 309
 
310
    public String getLocation(){
311
    	return this.location;
312
    }
339 rajveer 313
}