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 String getColorMessage() throws IOException, JSONException, URISyntaxException{
        try{
            parseUrl();
            if (!checkCache()){
                System.out.println(productUrl);
                Document doc = Jsoup.connect(productUrl).get();
                doc.outputSettings().charset("UTF-8");
                JSONArray jsonArray = new JSONArray(doc.getElementById("productAttributesJson").attr("value"));
                for (int element=0; element<jsonArray.length();element++){
                    if (supc.equalsIgnoreCase(jsonArray.getJSONObject(element).getString("supc"))){
                        color = jsonArray.getJSONObject(element).getString("value");
                        populateCache(supc, color);
                    }
                }
            }
        }
        catch (Exception e){
            log.error("Error while getting product details " +e);
        }
        setResultJson(getMsg());
        return INDEX;

    }
    
    private UserMessagePojo getMsg(){
        UserMessagePojo ump = new UserMessagePojo();
        if (color.isEmpty()){
                ump.setResult(false);
                ump.setMessage("");
        }
        else{
                ump.setResult(true);
                ump.setMessage("Please select "+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){
        System.out.println("populating cache");
        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())){
                    return true;
                }
            }
        }
        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 = "http://m.snapdeal.com/product/samsung-galaxy-grand-max/647437791381?supc=SDL021483758&aff_id=1&bhalala=0";
        s.setUrl(Base64.encode(url.getBytes()));
        s.getColorMessage();
        System.out.println(s.getResultJson());
    }

}