Subversion Repositories SmartDukaan

/**
 * 
 */
package in.shop2020.serving.controllers;

import in.shop2020.model.v1.catalog.CatalogServiceException;
import in.shop2020.model.v1.user.UserContextService.Client;
import in.shop2020.serving.cache.EhcacheWrapper;
import in.shop2020.serving.services.ContentServingService;
import in.shop2020.serving.utils.SnippetType;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.UserClient;

import java.util.ArrayList;
import java.util.List;

import net.sf.ehcache.CacheException;
import net.sf.ehcache.CacheManager;

import org.apache.log4j.Logger;
import org.apache.struts2.convention.annotation.InterceptorRef;
import org.apache.struts2.convention.annotation.InterceptorRefs;
import org.apache.struts2.convention.annotation.Result;
import org.apache.struts2.convention.annotation.Results;
import org.apache.struts2.rest.DefaultHttpHeaders;
import org.apache.struts2.rest.HttpHeaders;
import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;

/**
 * get private deals items from the catalog service
 * @author rajveer
 *      
 */
@InterceptorRefs({
            @InterceptorRef("myDefault"),
            @InterceptorRef("login")
})
@Results({
        @Result(name = "redirect", location = "${redirectUrl}", type = "redirect", params={"statusCode", "301"})
})

public class PrivateDealsController extends BaseController {

        private static final long serialVersionUID = -6862524269260661024L;

        private static Logger log = Logger.getLogger(Class.class);
        private static final int windowSize = 20;

        private static final String SHOWCASE_PRIVATE_DEALS_CACHE_KEY = "SHOWCASE_PRIVATE_DEALS";
        private static final String SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY = "SHOWCASE_PRIVATE_DEALS_COUNT";

        private long beginIndex = 0;

        private Long totalItems = 0l;

        private String id;

        private String redirectUrl;

        List<Long> items = null;

        private List<String> snippets = null;

        CatalogClient catalogClientService = null;
        Client uc = null;

        public PrivateDealsController() {
                super();
                try {
                        catalogClientService = new CatalogClient();
                } catch (Exception e) {
                        log.error("Unable to get catalog service client.", e);
                }
        }

        // GET /index
        public HttpHeaders index() throws Exception{
                if(userinfo.isPrivateDealUser()){
                        redirectUrl = "/private-deals/1";
                } else {
                        redirectUrl = "/";
                }
                return new DefaultHttpHeaders("redirect");
        }

        // GET /show
        @SuppressWarnings("unchecked")
        public HttpHeaders show() {
                try {
                        if(userinfo.isPrivateDealUser()){

                                EhcacheWrapper<String, Object> showcasePageSnippetsCache = new EhcacheWrapper<String, Object>(
                                                EhcacheWrapper.PRIVATE_DEAL_PAGE_SNIPPET_CACHE_NAME, CacheManager.create());
                                if(sourceId == -1){
                                        this.snippets = (List<String>)showcasePageSnippetsCache.get(SHOWCASE_PRIVATE_DEALS_CACHE_KEY + beginIndex);
                                        this.totalItems = (Long)showcasePageSnippetsCache.get(SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY);
                                        if(this.snippets != null && !this.snippets.isEmpty() && this.totalItems > 0) {
                                                if(getCurrentPage() > getTotalPages()){
                                                        log.info("Redirecting.");
                                                        redirectUrl = "/private-deals/1";
                                                        return new DefaultHttpHeaders("redirect");
                                                }
                                                log.info("Using Cache.");
                                                return new DefaultHttpHeaders("show");
                                        }
                                }
                                log.info("Getting private deals from snippets.");
                                in.shop2020.model.v1.catalog.CatalogService.Client client = catalogClientService.getClient();
                                try {
                                        int count = client.getPrivateDealsCount();
                                        log.info("Count: " + count);
                                        this.setTotalItems(count);
                                        if(getCurrentPage() > getTotalPages()){
                                                log.info("Redirecting.");
                                                redirectUrl = "/private-deals/1";
                                                return new DefaultHttpHeaders("redirect");
                                        }
                                        if(sourceId == -1){
                                                showcasePageSnippetsCache.put(SHOWCASE_PRIVATE_DEALS_COUNT_CACHE_KEY, this.totalItems);
                                        }
                                        this.items = client.getPrivateDealsCatalogIds(beginIndex, windowSize);
                                        setSnippets();
                                        if(sourceId == -1){
                                                showcasePageSnippetsCache.put(SHOWCASE_PRIVATE_DEALS_CACHE_KEY + beginIndex, this.snippets);
                                        }
                                } catch (CatalogServiceException e) {
                                        log.error("Unable to get private deals from inventory service.", e);
                                } catch (TException e) {
                                        log.error("Unable to get private deals from inventory service.", e);
                                }
                                return new DefaultHttpHeaders("show");
                        }
                        else{
                                redirectUrl = "/";
                                return new DefaultHttpHeaders("redirect");
                        }
                } catch (CacheException e) {
                        log.error("Cache Exception .", e);
                        redirectUrl = "/";
                        return new DefaultHttpHeaders("redirect");
                }
        }

        private void setSnippets(){
                this.snippets = new ArrayList<String>();
                if(items != null){
                        for(long item: items){
                                snippets.add(ContentServingService.getSnippet(SnippetType.PRIVATE_DEAL_SNIPPET, item+"", sourceId));
                        }
                }
        }

        public List<String> getSnippets() {
                return snippets;
        }

        public void setId(String id) {
                this.id = id;
                this.beginIndex = windowSize * (Long.parseLong(id)-1);
        }

        public String getId() {
                return id;
        }

        public long getBeginIndex(){
                if(totalItems>0)
                        return beginIndex+1;
                return beginIndex;
        }

        public void setTotalItems(long totalItems) {
                this.totalItems = totalItems;
        }

        public long getTotalItems() {
                return totalItems;
        }

        public long getTotalPages() {
                return 1 + (totalItems-1)/windowSize;
        }

        public long getCurrentPage() {
                return Long.parseLong(getId());
        }

        public String getRedirectUrl(){
                return redirectUrl;
        }
        public boolean isUserLoggedIn() {
                return userinfo.isLoggedIn();
        }
        
        public String getUserEmail(){
                return userinfo.getEmail().split("@")[0];
        }
}