Subversion Repositories SmartDukaan

package in.shop2020.dtrapi.controllers;

import java.io.IOException;

import java.net.URI;

import java.net.URISyntaxException;

import java.util.HashMap;

import java.util.List;

import org.apache.axis.encoding.Base64;

import org.apache.http.NameValuePair;

import org.apache.http.client.utils.URLEncodedUtils;

import org.apache.log4j.Logger;

import org.json.JSONArray;

import org.json.JSONException;

import org.jsoup.Jsoup;

import org.jsoup.nodes.Document;

import com.whalin.MemCached.MemCachedClient;

import in.shop2020.dtrapi.services.MemCache;

import in.shop2020.dtrapi.services.UserMessagePojo;

public class SnapdealProductPageParserController extends BaseController{

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

	private static final long serialVersionUID = 1L;

	private String url;

	private String supc = "";

	private String productUrl = "";

	private String color = "";

	private static final String INDEX = "index";

	private static final String KEY = "snapdealSupcToColorMapping";

	private static MemCache memCache = new MemCache();

	private static MemCachedClient memcachedClient = memCache.getClient();

	public UserMessagePojo getColorMessage() throws IOException, JSONException, URISyntaxException{

		try{

			parseUrl();

			if (!checkCache()){

				Document doc = Jsoup.connect(productUrl).get();

				doc.outputSettings().charset("UTF-8");

				//System.out.println(doc);

				JSONArray jsonArray = new JSONArray(doc.getElementById("attributesJson").text());

				//System.out.println(jsonArray);

				for (int element=0; element<jsonArray.length();element++){

					try{

						JSONArray subAttributeArray = jsonArray.getJSONObject(element).getJSONArray("subAttributes");

						for (int innerElement=0; innerElement< subAttributeArray.length(); innerElement++){

							if (supc.equalsIgnoreCase(subAttributeArray.getJSONObject(innerElement).getString("supc"))){

								color = jsonArray.getJSONObject(element).getString("value");

							}

						}

					}

					catch(Exception e1){

						e1.printStackTrace();

					}

					if (supc.equalsIgnoreCase(jsonArray.getJSONObject(element).getString("supc"))){

						color = jsonArray.getJSONObject(element).getString("value");

					}

					if (color!=null){

						if (!color.isEmpty()){

							populateCache(supc, color);

							break;

						}

					}

				}

			}

		}

		catch (Exception e){

			log.error("Error while getting product details " +e);

		}

		return getMsg();

	}

	private UserMessagePojo getMsg(){

		UserMessagePojo ump = new UserMessagePojo();

		//System.out.println("color is "+color);

		if (color==null || color.isEmpty()){

			ump.setResult(false);

			ump.setMessage("");

		}

		else{

			ump.setResult(true);

			ump.setMessage("Please select "+color+" color to get this price.");

		}

		return ump;

	}

	private String getJavaScriptCode(){

		String jsCode = "javascript:try{var ele=document.getElementById('attribute-select-0');ele.value ="+"'"+color+"'"+";ele.onchange();}catch(error){Android.onError(error.message);}";

		return jsCode;

	}

	private void parseUrl() throws URISyntaxException{

		List<NameValuePair> params = URLEncodedUtils.parse(new URI(url), "UTF-8");

		for (NameValuePair param : params){

			if (param.getName().equalsIgnoreCase("supc")){

				supc = param.getValue();

			}

		}

		productUrl = new URI(url).getHost()+new URI(url).getPath();

		if (!productUrl.startsWith("http")){

			productUrl = "http://"+productUrl;

		}

	}

	private void populateCache(String supc, String color){

		Object cacheValue = memcachedClient.get(KEY);

		HashMap<String, String> supcMap = new HashMap<String, String>();

		if (cacheValue != null) {

			supcMap=(HashMap<String, String>)cacheValue;

		}

		supcMap.put(supc, color);

		memcachedClient.set(KEY, supcMap);

	}

	private boolean checkCache(){

		if (supc!=null){

			Object cacheValue = memcachedClient.get(KEY);

			if (cacheValue != null) {

				System.out.println("cache value is not null");

				HashMap<String, String> supcMap = new HashMap<String, String>();

				supcMap=(HashMap<String, String>)cacheValue;

				System.out.println("supc map "+supcMap);

				color = supcMap.get(supc);

				System.out.println("color "+color);

				if (!(color==null || color.isEmpty())){

					System.out.println("Returning true");

					return true;

				}

			}

		}

		System.out.println("Returning false");

		return false;

	}

	public void setUrl(String url) {

		byte[] decoded = Base64.decode(url);

		this.url = new String(decoded);

	}

	public String getUrl() {

		return url;

	}

	public static void main(String[] args) throws URISyntaxException, IOException, JSONException{

		SnapdealProductPageParserController s = new SnapdealProductPageParserController();

//		//String url = "aHR0cDovL20uc25hcGRlYWwuY29tL3Byb2R1Y3QvaHRjLWRlc2lyZS01MjYtZy82ODE1MDk5MjQyNDg/c3VwYz1TREw1MjU0MDI1OTYmdXRtX3NvdXJjZT1hZmZfcHJvZyZ1dG1fY2FtcGFpZ249YWZ0cyZvZmZlcl9pZD0xNyZhZmZfaWQ9MzM1NTAmYWZmX3N1Yj1TSEEzMTQzMjEwODk3MA==";

		String url = "aHR0cDovL3d3dy5zbmFwZGVhbC5jb20vcHJvZHVjdC9zb255LXhwZXJpYS10Mi11bHRyYS04Z2IvMjE0Njc5OTEyLz9zdXBjPVNETDI4OTYwOTM5NA==";

		byte[] decoded = Base64.decode(url);

		System.out.println(new String(decoded));

		s.setUrl(url);

		System.out.println(s.getColorMessage().getMessage());

		//memcachedClient.set("java", "bawaaaa");

		//System.out.println(memcachedClient.get("hi"));

	}

}