Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.datalogger.EventType;

import in.shop2020.model.v1.user.UserContextService.Client;

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

import in.shop2020.serving.utils.FileUtils;

import in.shop2020.serving.utils.Utils;

import in.shop2020.thrift.clients.UserClient;

import in.shop2020.utils.DataLogger;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.lang.StringUtils;

import org.apache.log4j.Logger;

import org.apache.struts2.convention.annotation.Action;

import org.apache.struts2.convention.annotation.InterceptorRef;

import org.apache.struts2.convention.annotation.Result;

import org.apache.struts2.convention.annotation.Results;

import org.apache.thrift.TException;

import org.json.JSONArray;

import org.json.JSONException;

@SuppressWarnings("serial")

@Results({

	@Result(name="success", location="myresearch-success.vm")

})

public class MyresearchController extends BaseController {

    private UserClient userServiceClient = null;

	private Client client;

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

    private static final String htmlSnippetFileName = "MyResearchSnippet.html";

    private String htmlSnippet = "";

    private String snippets="";

    private List<String> items;

    private String itemsInJson;

    private int totalItems = 0;

	public MyresearchController(){

		super();

		try {

			userServiceClient = new UserClient();

			client = userServiceClient.getClient();

		} catch (Exception e) {

		    log.error("Unable to initialize the user service client", e);

		}

	}

	@Action(value="myresearch",interceptorRefs={@InterceptorRef("myDefault")})

	public String index() {

	    try {

	        JSONArray itemsJson =  new JSONArray();

            List<Long> widgetItemIds = client.getMyResearchItems(userinfo.getUserId());

            for (Long itemId : widgetItemIds) {

                itemsJson.put(itemId);

            }

            itemsInJson = itemsJson.toString();

        } catch (WidgetException e) {

            log.error("Unable to get the myresearch widget", e);

        } catch (TException e) {

            log.error("Unable to get the myresearch widget", e);

        }

		return "index";

	}

	//myresearch/[1,2,3]

	@Action(value="myresearch",interceptorRefs={@InterceptorRef("caching"),@InterceptorRef("myDefault")})

	public String show() {

	    if(items != null){

            for(String itemId: items){

                try {

                    snippets = snippets + FileUtils.read( Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

                    totalItems++;

                }

                catch (FileNotFoundException e) {

                    log.error("File not found : " + Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

                }

                catch (IOException e) {

                    log.error("IO exception : " + Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

                }

            }

        }

        return "show";

    }

	//Handle /addtoresearch/{id}

	@Action(value="addtoresearch",interceptorRefs={@InterceptorRef("createuser"),@InterceptorRef("myDefault")})

	public String create() throws WidgetException, TException, IOException {

	    if(userinfo.getUserId() != -1){

			for (String item : items){

	            long itemId = Long.parseLong(item);

	            boolean isNew = client.updateMyResearch(userinfo.getUserId(), itemId);

	            String fromsrc = "";

	            if(isNew){

	                try {

	                    htmlSnippet = htmlSnippet + FileUtils.read( Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

	                }

	                catch (FileNotFoundException e) {

	                    log.error("File not found : " + Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

	                }

	                catch (IOException e) {

	                    log.error("IO exception : " + Utils.EXPORT_ENTITIES_PATH + itemId + File.separator + htmlSnippetFileName);

	                }

	                if(request.getParameter("fromsrc") != null){

	                	fromsrc = request.getParameter("fromsrc");

	                }

                    DataLogger.logData(EventType.RESEARCH_ADD, getSessionId(), userinfo.getUserId(), userinfo.getEmail(), StringUtils.join(items, "_"), fromsrc);

                }

	        }

		}

		return "success";

	}

	@Action(value="deletefromresearch",interceptorRefs={@InterceptorRef("createuser"),@InterceptorRef("myDefault")})

	public String destroy(){

		for (String item : items){

			long itemId = Long.parseLong(item);

			deleteFromMyResearch(userinfo.getUserId(), itemId);

			DataLogger.logData(EventType.RESEARCH_DELETE, getSessionId(), userinfo.getUserId(), userinfo.getEmail(), StringUtils.join(items, "_"));

		}

		return "success";

	}

	private void deleteFromMyResearch(long userId, long itemId) {

		try {

			UserClient userServiceClient = new UserClient();

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

			userClient.deleteItemFromMyResearch(userId, itemId);

		} catch (WidgetException e) {

		    log.error("Unable to delete item from the myresearch widget", e);

		} catch (TException e) {

		    log.error("Unable to delete item from the myresearch widget", e);

		} catch (Exception e) {

		    log.error("Unable to delete item from the myresearch widget", e);

		}

	}

	public String getHtmlSnippet(){

		if(htmlSnippet == "")	{

			htmlSnippet = "0";

		}

		return htmlSnippet;

	}

	public String getSnippets() {

        return snippets;

    }

	public int getTotalItems() {

        return totalItems;

    }

	public void setProductid(String itemsString) {

        setId(itemsString);

    }

	public void setId(String itemsString) {

        JSONArray itemJson = null;

        try {

            itemJson = new JSONArray(itemsString);

        } catch (JSONException e) {

            log.error("Bad json : " + itemsString);

            return;

        }

        items = new ArrayList<String>();

        for (int i=0; i<itemJson.length(); i++) {

            try {

                items.add(itemJson.getString(i));

            } catch (JSONException e) {

                log.error("Bad item at index : " + i);

            }

        }

    }

    public String getItemsInJson() {

        return this.itemsInJson;

    }

}