Subversion Repositories SmartDukaan

package in.shop2020.mobileapi.serving.utils;

import in.shop2020.config.ConfigException;

import in.shop2020.model.v1.catalog.ExclusiveAffiliateItemInfo;

import in.shop2020.model.v1.order.LineItem;

import in.shop2020.model.v1.order.Order;

import in.shop2020.model.v1.order.RechargeOrderStatus;

import in.shop2020.model.v1.order.RechargePlan;

import in.shop2020.model.v1.order.RechargeType;

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

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

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.thrift.clients.config.ConfigClient;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Collections;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.mail.internet.AddressException;

import javax.mail.internet.InternetAddress;

import org.apache.commons.lang.StringUtils;

import org.apache.http.HttpEntity;

import org.apache.http.HttpResponse;

import org.apache.http.client.HttpClient;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.log4j.Logger;

public class Utils {

    private static Logger logger = Logger.getLogger(Utils.class);

	public static final String EXPORT_ENTITIES_PATH = getExportPath();

	public static final String EXPORT_JAVASCRIPT_CONTENT_PATH = "/var/lib/tomcat6/webapps/export/javascripts/";

	public static final String STATIC_SERVER_PATH = "http://static1.saholic.com/images/mobileapi/";

	public static final long ROOT_CATEGORY = 10000;

	public static final long MOBILE_PHONES_CATEGORY = 10001;

	public static final long MOBILE_ACCESSORIES_CATEGORY = 10011;

	public static final long TABLETS_CATEGORY = 10010;

    public static final long LAPTOPS_CATEGORY = 10050;

    public static final long CAMERAS_CATEGORY = 11001;

    private static final String DTR_ENTITY_URL = "http://dtr:8057/ordered-offers/4/%d";

    @SuppressWarnings("serial")

	public static final Map<String, String> NET_BANKING_CODES_MAP = Collections.unmodifiableMap(

    		new HashMap<String, String>(){

	    		{

	    			put("1004","AXIB");

	    			put("1135","CRPB");

	    			put("1029","FEDB");

	    			put("1007","HDFB");

	    			put("1016","ICIB");

	    			put("1032","SBIB");

	    			put("1034","SBHB");

	    			put("1038","SBMB");

	    			put("1039","SBTB");

	    			//put("1127","CITNB");

	    			put("1033","SBBJB");

    				//Oriental Bank of Commerce

	    			//put("1154","");

	    			put("1147","CBIB");

	    			put("1146","YESB");

	    			put("1214","BOIB");

	    			put("1215","CUBB");

	    			put("1212","UNIB");

	    			put("1224","CABB");

	    			put("1210","INGB");

	    			put("1148","162B");

	    			put("1273","DLSB");

	    			put("1015","JAKB");

	    			put("1133","KRKB");

	    			put("1143","INDB");

	    			put("1216","UBIB");

	    			put("1213","INOB");

	    			put("1229","BOMB");

	    			put("1601","CSBN");

	    			put("1602","DCBB");

	    			put("1603","DSHB");

	    			put("1604","IDBB");

	    			put("1605","INIB");

	    			put("1606","KRVB");

	    			put("1607","PNBB");

	    			put("1608","SOIB");

	    			put("1609","SRSWT");

	    			put("1610","VJYB");	    			

	    		}

    		});

    static Map<Long, String> providersMap;

    static Map<Long, String> mobileProvidersMap;

    static Map<Long, String> dthProvidersMap;

    static Map<Long, List<RechargePlan>> operatorPlanMap = new HashMap<Long, List<RechargePlan>>(); 

    private static Map<String, Map<String, String>> uriOperatorMap = new HashMap<String, Map<String,String>>();

    static Map<Long, ExclusiveAffiliateItemInfo> exclusiveAffiliateItems = null;

    static long fifteenMinsCounter = 0l;

    static long thirtyMinsCounter = 0l;

    public static final List<RechargeOrderStatus> refundableRechargeStatusList = new ArrayList<RechargeOrderStatus>(Arrays.asList(new RechargeOrderStatus[] 

                                                                                                                                                     {RechargeOrderStatus.RECHARGE_FAILED, 

                                                                                                                                                      RechargeOrderStatus.RECHARGE_FAILED_REFUNDED}));

    public static Map<RechargeOrderStatus, String> statusMap = new HashMap<RechargeOrderStatus, String>();

    //public static final List<String> multiValuedFacet = Arrays.asList("F_50006");

    public static final  List<String>rootfacetDefIDs = Arrays.asList("F_50010","F_50011", "F_50001", "F_50028");

    public static final  String availabilityFacet = "F_50028";

	public static final Map<String, String> FACET_LABEL_MAP = Collections.unmodifiableMap(

			new HashMap<String, String>(){

				/**

				 * 

				 */

				private static final long serialVersionUID = 1L;

				{

					put("F_50010","Category");

					put("F_50011","Sub Category");

					put("F_50002","Price");

					put("F_50001","Brand");

					put("F_50006","Data Connectivity");

					put("F_50007","Camera Resolution");

					put("F_50012","Display");

					put("F_50013","Operating System");

					put("F_50014","RAM");

					put("F_50015","Storage Capacity");

					put("F_50017","Processor");

					put("F_50018","Capacity");

					put("F_50019","Class");

					put("F_50020","Capacity");

					put("F_50021","Capacity");

					put("F_50022","Type");

					put("F_50023","Interface");

					//Resolution for Composite

					put("F_50024","Resolution");

					put("F_50025","Optical Zoom");

					put("F_50026","Display Size");

					//Resolution for DSLR

					put("F_50027","Resolution");

					put("F_50028","Availability");

					put("F_50031","Operating System");

					put("F_50032","Screen Size");	//Screen size for mobiles

					put("F_50033","Screen Size");	//Screen size for laptop

					put("F_50034","Screen Size"); 	//Screen size for tablets

					put("F_50035","Operating System"); 	//Screen size for tablets

					put("F_50036","Camera Resolution"); 	//Screen size for tablets

					put("F_50037","Voice Call Facility"); 	//Screen size for tablets

					put("F_50038","Mobile Type");

					put("F_50039", "Your Deals");

				}

		});

    static {

        statusMap.put(RechargeOrderStatus.PAYMENT_FAILED, "Payment Unsuccessful");

        statusMap.put(RechargeOrderStatus.PAYMENT_SUCCESSFUL, "Processing Recharge");

        statusMap.put(RechargeOrderStatus.RECHARGE_FAILED, "Recharge Failed");

        statusMap.put(RechargeOrderStatus.RECHARGE_FAILED_REFUNDED, "Recharge Failed Refunded");

        statusMap.put(RechargeOrderStatus.RECHARGE_SUCCESSFUL, "Recharge Successful");

        statusMap.put(RechargeOrderStatus.REFUNDED, "Amount Refunded");

        statusMap.put(RechargeOrderStatus.PARTIALLY_REFUNDED, "Amount Refunded");

        statusMap.put(RechargeOrderStatus.PAYMENT_PENDING, "Payment Failed");

        statusMap.put(RechargeOrderStatus.INIT, "Payment Initiated");

        statusMap.put(RechargeOrderStatus.RECHARGE_UNKNOWN, "Recharge In Process");

        statusMap.put(RechargeOrderStatus.RECHARGE_IN_PROCESS, "Recharge In Process");

        TransactionClient tcl;

        try {

            tcl = new TransactionClient();

            mobileProvidersMap = tcl.getClient().getServiceProviders(RechargeType.MOBILE, true);

            dthProvidersMap = tcl.getClient().getServiceProviders(RechargeType.DTH, true);

//            providersMap.putAll(mobileProvidersMap);

//            providersMap.putAll(dthProvidersMap);

            for (Long operatorId : mobileProvidersMap.keySet()) {

                List<RechargePlan> plans = tcl.getClient().getPlansForOperator(operatorId);

                if (!plans.isEmpty()) {

                    operatorPlanMap.put(operatorId, plans);

                }

            }

            for (Long operatorId : mobileProvidersMap.keySet()) {

            	Map<String,String> valueMap = new HashMap<String,String>();

            	valueMap.put("Id", operatorId+"");

                valueMap.put("Name", mobileProvidersMap.get(operatorId)+"");

                valueMap.put("ServiceType", "1");

                valueMap.put("ServiceName", "Prepaid Mobile");

                uriOperatorMap.put(mobileProvidersMap.get(operatorId).toLowerCase().trim().replace(" ", "-")+"-online-recharge", valueMap);

            }

            for (Long operatorId : dthProvidersMap.keySet()) {

            	Map<String,String> valueMap = new HashMap<String,String>();

            	valueMap.put("Id", operatorId+"");

            	valueMap.put("Name", dthProvidersMap.get(operatorId)+"");

                valueMap.put("ServiceType", "2");

                valueMap.put("ServiceName", "DTH TV");

                uriOperatorMap.put(dthProvidersMap.get(operatorId).toLowerCase().trim().replace(" ", "-")+"-online-recharge", valueMap);

            }

            Map<String,String> valueMap = new HashMap<String,String>();

            valueMap.put("Id", "0");

	    	valueMap.put("Name", "Mobile and DTH");

	        valueMap.put("ServiceType", "1");

	        valueMap.put("ServiceName", "");

	        uriOperatorMap.put("recharge", valueMap);

//            providersMap.putAll(tcl.getClient().getServiceProviders(RechargeType.DTH));

        } catch (Exception e) {

            logger.error("Could not get providers", e);

        }

    }

	private static String getExportPath(){

		String exportPath=null;

		ConfigClient client = ConfigClient.getClient();

		try{

			exportPath = client.get("export_entities_path");

		}catch(ConfigException ce){

			logger.error("Unable to read export path from the config client: ", ce);

			logger.warn("Setting the default export path");

			exportPath = "/var/lib/tomcat6/webapps/export/html/entities/";

		}

		return exportPath;

	}

	public static boolean validatePin(String pincode) {

		int pin;

		try {

			pin = Integer.parseInt(pincode);

		}

		catch (NumberFormatException e) {

			return false;

		}

		if (pin < 100000 || pin > 999999) {

			return false;

		}

		return true;

	}

	public static boolean isValidEmail(String emailAddress)	{

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

			return false;

		}

		try {

			InternetAddress address = new InternetAddress(emailAddress, true);

			address.validate();

			return true;

		} catch (AddressException e) {

			logger.error(emailAddress + " is not valid email address ", e);

			return false;

		}

	}

	public static boolean validatePhone(String phone) {

		long iPhone;

		try {

    		iPhone = Long.parseLong(phone);

		}

		catch (NumberFormatException e) {

			return false;

		}

		if (iPhone < 1000000000l || iPhone > 9999999999l) {

			return false;

		}

		return true;

	}

	public static String getItemIdStringInCart(Cart cart) {

	    List<String> itemIds = new ArrayList<String>();

        for (Line line : cart.getLines()) {

            itemIds.add(Long.toString(line.getItemId()));

        }

        return StringUtils.join(itemIds, '_');

    }

	public static String getItemIdStringFromOrders(List<Order> orders) {

        List<String> itemIds = new ArrayList<String>();

        if (orders != null) {

            for (Order order : orders) {

                for (LineItem lItem : order.getLineitems()) {

                    itemIds.add(Long.toString(lItem.getItem_id()));

                }

            }

        }

        return StringUtils.join(itemIds, '_');

    }

	public static String getRechargeProviderName(long providerId) {

            return providersMap.get(providerId);

	}

    public static Map<Long, String> getMobileProvidersMap() {

        return mobileProvidersMap;

    }

    public static Map<Long, String> getDthProvidersMap() {

        return dthProvidersMap;

    }

    public static Map<Long, List<RechargePlan>> getOperatorPlanMap() {

        return operatorPlanMap;

    }

    public static Map<String, Map<String, String>> getUriOperatorMap(){

    	return uriOperatorMap;

	}

    public static Map<String, String> getOperatorByUri(String uri){

    	return uriOperatorMap.get(uri);

	}

	public static Map<Long, ExclusiveAffiliateItemInfo> getExclusiveAffiliateItems(){

		try{

			Long currentTime = new Date().getTime();

			CatalogClient client = new CatalogClient();

			if(exclusiveAffiliateItems == null || thirtyMinsCounter < currentTime) {

				exclusiveAffiliateItems = client.getClient().getExAffiliateItemInfo();

				thirtyMinsCounter = new Date().getTime() + 15*60000;

			}

		}catch(Exception ce){

			logger.error("Unable to fetch exclusive items from catalog", ce);

		}

		return exclusiveAffiliateItems;

	}

	public static String getDtrAffiliateString(Long entityId){

		HttpClient httpclient = new DefaultHttpClient();

		String url = String.format(DTR_ENTITY_URL, entityId);

		HttpGet httpget = new HttpGet(url);

		String str = "{}";

		// If the response does not enclose an entity, there is no need

	  // to worry about connection release

		try{

			HttpResponse response = httpclient.execute(httpget);

			// Get hold of the response entity

			HttpEntity entity = response.getEntity();

			if (entity != null) {

				InputStream instream = entity.getContent();

				try {   

					BufferedReader reader = new BufferedReader(new InputStreamReader(instream));

					str = reader.readLine();

				} catch (IOException ex) {

					throw ex;

				} catch (RuntimeException ex) {	  

		          httpget.abort();

		          throw ex;

				} finally {

		          // Closing the input stream will trigger connection release

		          instream.close();

				}

			}

		} catch (Exception e){

			e.printStackTrace();

		}

		httpclient.getConnectionManager().shutdown();

		if (str== null){

			str = "{}";

		}

		return str;

	}

}