Subversion Repositories SmartDukaan

package in.shop2020.serving.interceptors;

import in.shop2020.datalogger.EventType;

import in.shop2020.model.v1.user.Affiliate;

import in.shop2020.model.v1.user.Tracker;

import in.shop2020.serving.services.UserSessionInfo;

import in.shop2020.serving.utils.DesEncrypter;

import in.shop2020.thrift.clients.UserContextServiceClient;

import in.shop2020.utils.DataLogger;

import java.util.HashMap;

import java.util.Map;

import javax.servlet.http.Cookie;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

import org.apache.log4j.Logger;

import org.apache.struts2.ServletActionContext;

import com.opensymphony.xwork2.ActionInvocation;

import com.opensymphony.xwork2.interceptor.AbstractInterceptor;

public class TrackingInterceptor extends AbstractInterceptor {

	private static final long serialVersionUID = 1L;

	private static Logger log = Logger.getLogger(TrackingInterceptor.class);

	private static final int SECONDS_IN_TWO_MONTHS = 60*60*24*60;

	private static final int SECONDS_IN_YEAR = 60*60*24*365;

	public static final String TRACKER = "tracker";

	public static final String AFF_COOKIE = "uafc";

	public static final String SRC_COOKIE = "usrcc";

	public static final String SESSION_SRC_COOKIE = "sess_srcc";

	private String cookieDomain = "";

	private Cookie trackerCookie = null;

	private Cookie affCookie = null;

	private Cookie firstSourceCookie = null;

	private Cookie sessionSourceCookie = null;

    private Map<String, Cookie> cookiesMap = null;

    public void setCookieDomain(String cookieDomain) {

        this.cookieDomain = cookieDomain;

    }

    @Override

	public String intercept(ActionInvocation invocation) throws Exception {

		HttpServletRequest request = ServletActionContext.getRequest();

		String affId = request.getParameter("afid");

		createCookiesMap(request);

		cleanTrackerCookie();

		updateFirstSourceCookie();

		updateSessionSourceCookie();

		if(affId != null && !affId.isEmpty()) {

		    updateAffCookie(affId);

		}

        return invocation.invoke();

	}

    /**

     * Update first source cookie

     * 

     */

    private void updateFirstSourceCookie() {

        firstSourceCookie = (Cookie) cookiesMap.get(SRC_COOKIE);

        if (firstSourceCookie != null) {

            return;

        }

        HttpServletRequest request = ServletActionContext.getRequest();

        String src = "";

        String referer = request.getHeader("referer");

        if (referer == null || referer.isEmpty() || referer.contains("saholic") || referer.contains("shop2020")) {

            src = "DIRECT : " + "(" + request.getRequestURL() + ")" ;

        }

        else if (referer.contains("google.co")) {

            src = "ORGANIC : " + "(" + referer + ")";

        }

        else {

            src = referer;

        }

        DesEncrypter des = new DesEncrypter("Saholic");

        String sourceCookieVal = des.encrypt(src);

        firstSourceCookie = new Cookie(SRC_COOKIE, sourceCookieVal);

        firstSourceCookie.setMaxAge(SECONDS_IN_YEAR);

        firstSourceCookie.setPath("/");

        if (!cookieDomain.isEmpty()) {

            firstSourceCookie.setDomain(cookieDomain);

        }

        cookiesMap.put(SRC_COOKIE, firstSourceCookie);

        HttpServletResponse response = ServletActionContext.getResponse();

        response.addCookie(firstSourceCookie);

    }

    /**

     * Update first source cookie

     * 

     */

    private void updateSessionSourceCookie() {

        sessionSourceCookie = (Cookie) cookiesMap.get(SESSION_SRC_COOKIE);

        if (sessionSourceCookie != null) {

            return;

        }

        HttpServletRequest request = ServletActionContext.getRequest();

        String src = "";

        String referer = request.getHeader("referer");

        if (referer == null || referer.isEmpty() || referer.contains("saholic") || referer.contains("shop2020")) {

            src = "DIRECT : " + "(" + request.getRequestURL() + ")" ;

        }

        else if (referer.contains("google.co")) {

            src = "ORGANIC : " + "(" + referer + ")";

        }

        else {

            src = referer;

        }

        DesEncrypter des = new DesEncrypter("Saholic");

        String sessionSourceCookieVal = des.encrypt(src);

        sessionSourceCookie = new Cookie(SESSION_SRC_COOKIE, sessionSourceCookieVal);

        sessionSourceCookie.setPath("/");

        if (!cookieDomain.isEmpty()) {

            sessionSourceCookie.setDomain(cookieDomain);

        }

        cookiesMap.put(SESSION_SRC_COOKIE, sessionSourceCookie);

        HttpServletResponse response = ServletActionContext.getResponse();

        response.addCookie(sessionSourceCookie);

        HttpSession session = request.getSession();

        UserSessionInfo userinfo = (UserSessionInfo) session.getAttribute(UserInterceptor.USER_INFO);

        DataLogger.logData(EventType.NEW_SESSION, request.getSession().getId(), userinfo.getUserId(), userinfo.getEmail(), src);

    }

    private void createCookiesMap(HttpServletRequest request) {

        cookiesMap  = new HashMap<String, Cookie>();

        Cookie[] cookies = request.getCookies();

        // This check is necessary for the first request when no cookies are

        // sent.

        if(cookies==null)

            return;

        for (Cookie cookie : cookies) {

            cookiesMap.put(cookie.getName(), cookie);

        }

    }

    private void cleanTrackerCookie() {

        trackerCookie = (Cookie) cookiesMap.get(TRACKER);

        affCookie = (Cookie) cookiesMap.get(AFF_COOKIE);

        if (trackerCookie != null) {

            if (affCookie == null) {

                try {

                    UserContextServiceClient userContextServiceClient = new UserContextServiceClient();

                    in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

                    Tracker tracker = userClient.getTrackerById(Long.parseLong(trackerCookie.getValue()));

                    affCookie = new Cookie(AFF_COOKIE, String.valueOf(tracker.getAffiliateId()));

                    affCookie.setMaxAge(SECONDS_IN_TWO_MONTHS);

                    affCookie.setPath("/");

                    if (!cookieDomain.isEmpty()) {

                        affCookie.setDomain(cookieDomain);

                    }

                    cookiesMap.put(AFF_COOKIE, trackerCookie);

                    HttpServletResponse response = ServletActionContext.getResponse();

                    response.addCookie(affCookie);

                } catch (Exception e) {

                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

            }

            if (!cookieDomain.isEmpty()) {

                trackerCookie.setDomain(cookieDomain);

            }

            trackerCookie.setPath("/");

            trackerCookie.setMaxAge(0);

            HttpServletResponse response = ServletActionContext.getResponse();

            response.addCookie(trackerCookie);

        }

    }

	private void updateAffCookie(String affId) {

        try {

            UserContextServiceClient userContextServiceClient = new UserContextServiceClient();

            in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient

                    .getClient();

            long affiliateId = Long.parseLong(affId);

            Affiliate affiliate = userClient.getAffiliateById(affiliateId);

            if (affiliate != null) {

                affCookie = (Cookie) cookiesMap.get(AFF_COOKIE);

                if (affCookie != null) {

                    Long.parseLong(affCookie.getValue());

                    if (affiliateId == Long.parseLong(affCookie.getValue())) {

                        return;

                    }

                }

                // create new aff cookie if affCookie ==null or affiliateId() != affCookie.

                Cookie newAffCookie = new Cookie(AFF_COOKIE, String.valueOf(affiliateId));

                newAffCookie.setMaxAge(SECONDS_IN_TWO_MONTHS);

                newAffCookie.setPath("/");

                if (!cookieDomain.isEmpty()) {

                    newAffCookie.setDomain(cookieDomain);

                }

                cookiesMap.put(AFF_COOKIE, newAffCookie);

                HttpServletResponse response = ServletActionContext.getResponse();

                response.addCookie(newAffCookie);

            }

        } catch (Exception e) {

            log.error(e);

        }

	}

}