Subversion Repositories SmartDukaan

package in.shop2020.ui.util;

import in.shop2020.metamodel.core.EntityState;

import in.shop2020.metamodel.util.CreationUtils;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.Serializable;

import java.net.URL;

import java.net.URLConnection;

import java.util.Comparator;

import java.util.HashMap;

import java.util.LinkedHashMap;

import java.util.Map;

import java.util.Map.Entry;

import java.util.TreeMap;

import org.json.JSONException;

import org.json.JSONObject;

public class ComparisonStatsFetcher implements Serializable{

	private static final long serialVersionUID = 1L;

	public static final String GOOGLE_COMPARE_DATA_URL = "http://saholic-datastore.appspot.com/show-comparisons";

	class ValueComparator implements Comparator, Serializable {

		private static final long serialVersionUID = 6060119992669086920L;

	    Map base;

        public ValueComparator(Map base) {

	    this.base = base;

	  }

	  public int compare(Object a, Object b) {

	    if((Long)base.get(a) < (Long)base.get(b)) {

	      return 1;

	    } else {

	      return -1;

	    }

	  }

	}

	public void fetchAndStoreComparisonStats(long fromDate, long toDate){

		String requestParameters = "fromdate=" +  fromDate + "&todate=" + toDate;

		String data = ComparisonStatsFetcher.sendGetRequest(GOOGLE_COMPARE_DATA_URL, requestParameters);

		try {

			JSONObject json = new JSONObject(data);

			Map<Long, Map<Long, Long>> comparisonStats = new HashMap<Long, Map<Long, Long>>();

			for (String itemId : JSONObject.getNames(json)) {

				Map<Long, Long> freq = new HashMap<Long, Long>();

				JSONObject items = (JSONObject) json.get(itemId);

				for (String comparedItemId : JSONObject.getNames(items)) {

					Integer frequency = (Integer) items.get(comparedItemId);

					freq.put(Long.parseLong(comparedItemId), frequency.longValue());

				}

				comparisonStats.put(Long.parseLong(itemId), freq);

			}

			if(comparisonStats != null){

				Map<Long, Map<Long, Long>> sortedComparisonStats = new HashMap<Long, Map<Long, Long>>();

				for(Entry<Long, Map<Long, Long>> entry: comparisonStats.entrySet()){

					ValueComparator bvc =  new ValueComparator(entry.getValue());

					TreeMap<Long, Long> sortedMap = new TreeMap(bvc);

					sortedMap.putAll(entry.getValue());

					sortedComparisonStats.put(entry.getKey(), sortedMap);

				}

				CreationUtils.storeComparisonStats(sortedComparisonStats);

			}

		} catch (JSONException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		} catch (Exception e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

	private static Map<String, Long> getMostComparedPhones(Map<Long, Map<Long, Long>> comparisonStats){

		Map<String, Long> allCounts = new HashMap<String, Long>(); 

		for(Long key: comparisonStats.keySet()){

			for(Long key1: comparisonStats.get(key).keySet()){

				String newKey;

				if(key<key1){

					newKey = key + " : " + key;

					//newKey = key + "\t" + ComparisonStatsFetcher.getProductName(es) + " : " + key1 + "\t" + ComparisonStatsFetcher.getProductName(es1);   

				}else{

					//newKey = key1 + "\t" + ComparisonStatsFetcher.getProductName(es1) + " : " + key + "\t" + ComparisonStatsFetcher.getProductName(es);

					newKey = key1 + " : " + key;

				}

				allCounts.put(newKey, comparisonStats.get(key).get(key1));

			}

		}

		return allCounts;

	}

	private static Map<Long, Long> getTopComparedPhones(Map<Long, Map<Long, Long>> comparisonStats){

		Map<Long, Long> mostCompared = new LinkedHashMap<Long, Long>(); 

		for(Long key: comparisonStats.keySet()){

			long count = 0;

			for(Long key1: comparisonStats.get(key).keySet()){

				count += comparisonStats.get(key).get(key1);

			}

			mostCompared.put(key, new Long(count));

		}

		return mostCompared;

	}

	public static void main(String[] args) throws Exception{

//		String data = FileUtils.readFileToString(new File("/home/rajveer/Desktop/comparisonStats.json"));

//		JSONObject json = new JSONObject(data);

	}

	/**

	 * 

	 * @param endpoint

	 * @param requestParameters

	 * @return

	 */

	 public static String sendGetRequest(String endpoint, String requestParameters)

     {

             String result = null;

             try

             {

                     String urlStr = endpoint;

                     if (requestParameters != null && requestParameters.length () > 0){

                             urlStr += "?" + requestParameters;

                     }

                     URL url = new URL(urlStr);

                     URLConnection conn = url.openConnection ();

                     // Get the response

                     BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));

                     StringBuffer sb = new StringBuffer();

                     String line;

                     while ((line = rd.readLine()) != null)

                     {

                             sb.append(line);

                     }

                     rd.close();

                     result = sb.toString();

             } catch (Exception e){

                     e.printStackTrace();

             }

             return result;

     }

		/**

	     * Get the name of the product from entity. It considers null values also

	     * @param EntityState

	     * @return

	     */

		public static String getProductName(EntityState EntityState){

			//FIXME Use stringbuilder

			String productName = ((EntityState.getBrand() != null) ? EntityState.getBrand().trim() + " " : "")

			+ ((EntityState.getModelName() != null) ? EntityState.getModelName().trim() + " " : "")

			+ (( EntityState.getModelNumber() != null ) ? EntityState.getModelNumber().trim() : "" );	

			return productName;

		}

}