Subversion Repositories SmartDukaan

package in.shop2020.dtrapi.controllers;

import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
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 String memory = "";
        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).userAgent("Mozilla/5.0 (Macintosh; Intel Mac OS X 10_9_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.152 Safari/537.36")
                                .get();
                                doc.outputSettings().charset("UTF-8");
                                //System.out.println(doc);
                                JSONArray jsonArray = new JSONArray(doc.getElementById("attributesJson").text());
                                for (int element=0; element<jsonArray.length();element++){
                                        if (jsonArray.getJSONObject(element).getString("subAttributeType").equalsIgnoreCase("memory")){
                                                try{
                                                        JSONArray subAttributeArray = jsonArray.getJSONObject(element).getJSONArray("subAttributes");
                                                        for (int innerElement=0; innerElement< subAttributeArray.length(); innerElement++){
                                                                if (supc.equalsIgnoreCase(subAttributeArray.getJSONObject(innerElement).getString("supc"))){
                                                                        System.out.println(subAttributeArray.getJSONObject(element).getString("value"));
                                                                        memory = subAttributeArray.getJSONObject(element).getString("value");
                                                                        color = jsonArray.getJSONObject(element).getString("value");
                                                                        break;
                                                                }
                                                        }
                                                }
                                                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){
                        e.printStackTrace();
                }
                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.trim()+" color to get this price.");
                        if (memory !=null && !memory.isEmpty()){
                                ump.setMessage("Please select "+color.trim()+" " +memory.trim()+" 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, MalformedURLException{
                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;
                }
//              URL url = new URL(productUrl);
//              String protocol = url.getProtocol();
//              if (protocol ==null || protocol == "http"){
//                      productUrl.replace("http", "https");
//              }
        }

        private void populateCache(String supc, String color){
                Object cacheValue = memcachedClient.get(KEY);
                HashMap<String, HashMap<String, String>> supcMap = new HashMap<String,  HashMap<String, String>>();
                if (cacheValue != null) {
                        supcMap=(HashMap<String,  HashMap<String, String>>)cacheValue;
                }
                HashMap<String, String> productDetailMap = new HashMap<String, String>();
                productDetailMap.put("color", color);
                productDetailMap.put("memory", memory);
                supcMap.put(supc, productDetailMap);
                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,  HashMap<String, String>> supcMap = new HashMap<String,  HashMap<String, String>>();
                                supcMap=(HashMap<String,  HashMap<String, String>>)cacheValue;
                                System.out.println("supc map "+supcMap);
                                HashMap<String, String> details = supcMap.get(supc);
                                if (details ==null){
                                        return false;
                                }
                                if (!(details.get("color")==null || details.get("color").isEmpty())){
                                        color = details.get("color");
                                        memory = details.get("memory");
                                        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 = "aHR0cHM6Ly93d3cuc25hcGRlYWwuY29tL3Byb2R1Y3QvaXBob25lLTZzLTY0Z2IvNjczMzYyNjQyNTUwP3N1cGM9U0RMNzcwODU3MDUx";
                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"));
        }

}