Subversion Repositories SmartDukaan

Rev

Rev 11644 | Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
11636 vikram.rag 1 
/**
2 
 *
3 
 */
4 
package in.shop2020.serving.controllers;
5 
 
6 
import in.shop2020.model.v1.catalog.CatalogServiceException;
7 
import in.shop2020.serving.cache.EhcacheWrapper;
8 
import in.shop2020.serving.services.ContentServingService;
9 
import in.shop2020.serving.utils.SnippetType;
10 
import in.shop2020.thrift.clients.CatalogClient;
11 
 
12 
import java.util.ArrayList;
13 
import java.util.List;
14 
 
15 
import net.sf.ehcache.CacheManager;
16 
 
17 
import org.apache.log4j.Logger;
18 
import org.apache.struts2.convention.annotation.Result;
19 
import org.apache.struts2.convention.annotation.Results;
20 
import org.apache.struts2.rest.DefaultHttpHeaders;
21 
import org.apache.struts2.rest.HttpHeaders;
22 
import org.apache.thrift.TException;
23 
 
24 
/**
25 
 * get private deals items from the catalog service
26 
 * @author rajveer
27 
 *
28 
 */
29 
@Results({
30 
    @Result(name = "redirect", location = "${redirectUrl}", type = "redirect", params={"statusCode", "301"})
31 
})
32 
 
33 
public class PrivateDealsController extends BaseController {
34 
 
35 
	private static final long serialVersionUID = -6862524269260661024L;
36 
 
37 
	private static Logger log = Logger.getLogger(Class.class);
38 
	private static final int windowSize = 20;
39 
 
40 
    private static final String SHOWCASE_PRIVATE_DEALS_CACHE_KEY = "SHOWCASE_PRIVATE_DEALS";
41 
    private static final String SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY = "SHOWCASE_PRIVATE_DEALS_COUNT";
42 
 
43 
	private long beginIndex = 0;
44 
 
45 
	private Long totalItems = 0l;
46 
 
47 
	private String id;
48 
 
49 
	private String redirectUrl;
50 
 
51 
	List<Long> items = null;
52 
 
53 
	private List<String> snippets = null;
54 
 
55 
	CatalogClient catalogClientService = null;
56 
 
57 
	public PrivateDealsController() {
58 
		super();
59 
		try {
60 
			catalogClientService = new CatalogClient();
61 
		} catch (Exception e) {
62 
			log.error("Unable to get catalog service client.", e);
63 
		}
64 
	}
65 
 
66 
    // GET /index
67 
    public HttpHeaders index() throws Exception {
68 
    	long categoryId = Long.parseLong(request.getParameter("categoryid"));
69 
        String brandName = request.getParameter("brand");
70 
        //Right now if we have brand name, we can just send back data for all categories
71 
        if(brandName != null){
72 
            categoryId = -1;
73 
        }
74 
    	in.shop2020.model.v1.catalog.CatalogService.Client client = catalogClientService.getClient();
75 
    	this.items = client.getPrivateDealsCatalogIds(beginIndex, windowSize);
76 
    	setSnippets();
77 
    	return new DefaultHttpHeaders("index");
78 
    }
79 
 
80 
    // GET /show
81 
    @SuppressWarnings("unchecked")
82 
    public HttpHeaders show() {
83 
    	if(getCurrentPage() > 1){
84 
    		log.info("Redirecting.");
85 
    		redirectUrl = "/private-deals/1";
86 
            return new DefaultHttpHeaders("redirect");
87 
    	}
88 
        EhcacheWrapper<String, Object> showcasePageSnippetsCache = new EhcacheWrapper<String, Object>(
89 
                EhcacheWrapper.SHOWCASE_PAGE_SNIPPET_CACHE_NAME, CacheManager.create());
90 
        if(sourceId == -1){
91 
	        this.snippets = (List<String>)showcasePageSnippetsCache.get(SHOWCASE_PRIVATE_DEALS_CACHE_KEY + beginIndex);
92 
	        this.totalItems = (Long)showcasePageSnippetsCache.get(SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY);
93 
	        if(this.snippets != null && !this.snippets.isEmpty() && this.totalItems > 0) {
94 
	            log.info("Using Cache.");
95 
	            return new DefaultHttpHeaders("show");
96 
	        }
97 
        }
98 
        log.info("Getting private deals from snippets.");
99 
    	in.shop2020.model.v1.catalog.CatalogService.Client client = catalogClientService.getClient();
100 
    	try {
101 
    		long count = client.getPrivateDealsCatalogIds(beginIndex, totalItems).size();
102 
			this.setTotalItems(count > 20 ? 20 : count);
103 
			if(sourceId == -1){
104 
				showcasePageSnippetsCache.put(SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY, this.totalItems);
105 
			}
106 
			this.items = client.getPrivateDealsCatalogIds(beginIndex, windowSize);
107 
			setSnippets();
108 
			if(sourceId == -1){
109 
				showcasePageSnippetsCache.put(SHOWCASE_PRIVATE_DEALS_CACHE_KEY + beginIndex, this.snippets);
110 
			}
111 
		} catch (CatalogServiceException e) {
112 
			log.error("Unable to get private deals from inventory service.", e);
113 
		} catch (TException e) {
114 
			log.error("Unable to get private deals from inventory service.", e);
115 
		}
116 
    	return new DefaultHttpHeaders("show");
117 
    }
118 
 
119 
    private void setSnippets(){
120 
    	this.snippets = new ArrayList<String>();
121 
    	if(items != null){
122 
    		for(long item: items){
123 
    			snippets.add(ContentServingService.getSnippet(SnippetType.PRIVATE_DEAL_SNIPPET, item+"", sourceId));
124 
			}
125 
    	}
126 
    }
127 
 
128 
    public List<String> getSnippets() {
129 
    	return snippets;
130 
    }
131 
 
132 
	public void setId(String id) {
133 
		this.id = id;
134 
		this.beginIndex = windowSize * (Long.parseLong(id)-1);
135 
	}
136 
 
137 
	public String getId() {
138 
		return id;
139 
	}
140 
 
141 
	public long getBeginIndex(){
142 
		if(totalItems>0)
143 
			return beginIndex+1;
144 
		return beginIndex;
145 
	}
146 
 
147 
	public void setTotalItems(long totalItems) {
148 
		this.totalItems = totalItems;
149 
	}
150 
 
151 
	public long getTotalItems() {
152 
		return totalItems;
153 
	}
154 
 
155 
	public long getTotalPages() {
156 
	    return 1 + (totalItems-1)/windowSize;
157 
	}
158 
 
159 
	public long getCurrentPage() {
160 
		return Long.parseLong(getId());
161 
	}
162 
 
163 
	public String getRedirectUrl(){
164 
		return redirectUrl;
165 
    }
166 
}