Subversion Repositories SmartDukaan

package com.spice.profitmandi.common.util;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.net.URISyntaxException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Collections;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.apache.commons.io.FileUtils;

import org.apache.commons.io.IOUtils;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.spice.profitmandi.common.model.GstRate;

import com.spice.profitmandi.thrift.clients.CatalogClient;

import com.spice.profitmandi.thrift.clients.InventoryClient;

import com.spice.profitmandi.thrift.clients.TransactionClient;

import com.spice.profitmandi.thrift.clients.config.ConfigClient;

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

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

import in.shop2020.model.v1.inventory.InventoryService;

import in.shop2020.model.v1.inventory.StateInfo;

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

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

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

public class Utils {

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

	  public static final String EXPORT_ENTITIES_PATH = getExportPath();

	  public static final String PRODUCT_PROPERTIES_SNIPPET = "ProductPropertiesSnippet.html";

	  public static final String DOCUMENT_STORE = "/profitmandi/documents/";

	  private static final Map<Integer, String> helpMap = new HashMap(6);

	  private static final Map<Integer, String> dthIdAliasMap = new HashMap(7);

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

	  private static Map<Long, String> mobileProvidersMap;

	  private static Map<Long, String> dthProvidersMap;

	  private static final String SMS_GATEWAY = "http://103.15.179.45:8085/SMSGateway/sendingSMS";

	  private static Map<Long, String> allProviders;

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

	  static {

	    helpMap.put(Integer.valueOf(1), "Your VC number starts with 0 and is 11 digits long.");

	    helpMap.put(Integer.valueOf(2), "Smart card number starts with 2 and is 12 digits long.");

	    helpMap.put(Integer.valueOf(3), "Smart card number starts with 4 and is 11 digits long.");

	    helpMap.put(Integer.valueOf(4), "Subscriber ID starts with 1 and is 10 digits long.");

	    helpMap.put(Integer.valueOf(5), "For customer ID, SMS ID to 9212012299 from your registered mobile no.");

	    helpMap.put(Integer.valueOf(26), "Customer ID starts with 3 and is 10 digits long.");

	    dthIdAliasMap.put(Integer.valueOf(1), "VC Number :");

	    dthIdAliasMap.put(Integer.valueOf(2), "Smart Card Number :");

	    dthIdAliasMap.put(Integer.valueOf(3), "Smart Card Number :");

	    dthIdAliasMap.put(Integer.valueOf(4), "Subscriber Id :");

	    dthIdAliasMap.put(Integer.valueOf(5), "Customer Id :");

	    dthIdAliasMap.put(Integer.valueOf(0), "Account Number :");

	    dthIdAliasMap.put(Integer.valueOf(26), "Customer Id :");

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

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

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

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

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

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

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

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

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

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

	    rechargeStatusMap.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);

	      logger.info("mobileProvidersMap" + mobileProvidersMap);

	      logger.info("dthProvidersMap" + dthProvidersMap);

	      allProviders = mobileProvidersMap;

	      logger.info("allProviders" + allProviders);

	      allProviders.putAll(dthProvidersMap);

	      logger.info("allProviders" + allProviders);

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

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

	        if (!plans.isEmpty())

	          operatorPlanMap.put(operatorId, plans);

	      }

	    } catch (Exception e) {

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

	    }

	  }

	@SuppressWarnings("serial")

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

			new HashMap<String, String>(){

				{

					put("image/png", "png");

					put("image/jpeg", "jpeg");

					put("image/pjpeg", "jpeg");

					put("application/pdf","pdf");

				}

			});

	private static String getExportPath(){

		String exportPath=null;

		ConfigClient client = ConfigClient.getClient();

		try{

			exportPath = client.get("export_entities_path");

		}catch(Exception ce){

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

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

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

		}

		return exportPath;

	}

	public static String getRechargeDisplayStatus(RechargeOrderStatus status) {

	    if (status == null) {

	      status = RechargeOrderStatus.INIT;

	    }

	    String displayStatus = (String)rechargeStatusMap.get(status);

	    if (displayStatus == null) {

	      return "";

	    }

	    return displayStatus;

	  }

	public static boolean copyDocument(String documentPath){

		File source = new File(documentPath);

		File dest = new File(DOCUMENT_STORE+source.getName());

		try {

			FileUtils.copyFile(source, dest);

		} catch (IOException e) {

			e.printStackTrace();

			return false;

		}

		return true;

	}

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

		return mobileProvidersMap;

	}

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

		return dthProvidersMap;

	}

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

		return allProviders;

	}

	public static String getProvider(long operatorId) {

    	return allProviders.get(operatorId);

    }

	public static void sendSms(String text, String mobileNumber) throws URISyntaxException, IOException{

		URIBuilder generalSearchUrl = new URIBuilder(SMS_GATEWAY);

		generalSearchUrl.addParameter("ani", "91"+mobileNumber);

		generalSearchUrl.addParameter("uname", "srlsaholic");                  

		generalSearchUrl.addParameter("passwd", "sr18mar"); 					  

		generalSearchUrl.addParameter("cli", "PROFTM");             			  

		generalSearchUrl.setParameter("message", text);

		URL url = generalSearchUrl.build().toURL();

		InputStream is = url.openStream();

		String response;

		try{

			response = IOUtils.toString(is, "UTF-8");

			System.out.println("response sms gateway "+response);

		}

		finally{

			is.close();

		}

	}

	public static String[] getOrderStatus(RechargeOrderStatus status){

		if (status == null){

			status = RechargeOrderStatus.INIT;

		}

		if(status.equals(RechargeOrderStatus.PAYMENT_FAILED)||status.equals(RechargeOrderStatus.PAYMENT_PENDING)){

			return new String[]{"false", "PAYMENT FAILED", "Payment failed at the payment gateway."};

		}

		else if(status.equals(RechargeOrderStatus.PAYMENT_SUCCESSFUL) || status.equals(RechargeOrderStatus.RECHARGE_UNKNOWN)) {

			if(status.equals(RechargeOrderStatus.PAYMENT_SUCCESSFUL)){

				return new String[]{"false", "PAYMENT SUCCESSFUL", "Your Payment was successful but due to some internal error with the operator's system we are not sure if the recharge was successful."

						+ " We have put your recharge under process."

						+ " As soon as we get a confirmation on this transaction, we will notify you."};

			}

			else{

				return new String[]{"false", "RECHARGE IN PROCESS", "Your Payment is successful.We have put your recharge under process." +

				" Please wait while we check with the operator."};

			}

		}

		else if (status.equals(RechargeOrderStatus.RECHARGE_FAILED) || status.equals(RechargeOrderStatus.RECHARGE_FAILED_REFUNDED)){

			return new String[]{"false", "RECHARGE IN PROCESS", "Your Payment was successful but unfortunately the recharge failed.Don't worry your payment is safe with us."

					+ " The entire Amount has been refunded to your wallet."};

		} else if(status.equals(RechargeOrderStatus.RECHARGE_SUCCESSFUL)){

			return new String[] {"false", "SUCCESS", "Congratulations! Your device is successfully recharged."};

		} else if (status.equals(RechargeOrderStatus.PARTIALLY_REFUNDED) || status.equals(RechargeOrderStatus.REFUNDED)) {

			return new String[]{"false", "PAYMENT REFUNDED","The payment associated with this recharge order has been refunded."};

		} else {

			return new String[]{"true", "ERROR", "INVALID INPUT"};

		}

	}

	public static Map<String, GstRate> getInterGstRates(){

		try{

			CatalogService.Client catalogClient = getCatalogClient();

			return toGstRateMap(catalogClient.getInterStateGstRates());

		}catch (Exception e) {

			e.printStackTrace();

			return new HashMap<>();

		}

	}

	public static Map<String, GstRate> getGstRates(String stateName){

		try{

			CatalogService.Client catalogClient = getCatalogClient();

			long stateId = getStateId(stateName);

			StateGstRates stateGstRates = catalogClient.getGstRatesByState(stateId);

			return toGstRateMap(stateGstRates.getGstRatesMap());

		}catch(Exception e){

			e.printStackTrace();

			return new HashMap<>();

		}

	}

	private static CatalogService.Client getCatalogClient() throws Exception{

		try{

			CatalogClient client = new CatalogClient();

			CatalogService.Client catalogClient = client.getClient();

			return catalogClient;

		}catch (Exception e) {

			throw e;

		}

	}

	private static Map<String, GstRate> toGstRateMap(Map<String, in.shop2020.model.v1.catalog.GstRate> hsnCodeGstRateMap){

		Map<String, GstRate> gstRateMap = new HashMap<>();

		for(Map.Entry<String, in.shop2020.model.v1.catalog.GstRate> entry : hsnCodeGstRateMap.entrySet()){

			in.shop2020.model.v1.catalog.GstRate tGstRate = entry.getValue();

			GstRate gstRate = new GstRate();

			gstRate.setHsnCode(entry.getKey());

			gstRate.setIgstRate(Double.valueOf(tGstRate.getIgstRate()).floatValue());

			gstRate.setCgstRate(Double.valueOf(tGstRate.getCgstRate()).floatValue());

			gstRate.setSgstRate(Double.valueOf(tGstRate.getSgstRate()).floatValue());

			gstRateMap.put(entry.getKey(), gstRate);

		}

		return gstRateMap;

	}

	public static String getStateCode(String stateName) throws Exception{

		return getStateInfo(stateName).getStateCode();

	}

	public static long getStateId(String stateName) throws Exception{

		return getStateInfo(stateName).getId();

	}

	public static StateInfo getStateInfo(String stateName) throws Exception{

		try{

			InventoryClient client = new InventoryClient();

			InventoryService.Client inventoryClient = client.getClient();

			Map<Long, StateInfo> map = inventoryClient.getStateMaster();

			List<StateInfo> stateInfos = new ArrayList<>(map.values());

			for(StateInfo stateInfo : stateInfos){

				if(stateName.equals(stateInfo.getStateName())){

					return stateInfo;

				}

			}

			throw new Exception("Not found");

		}catch (Exception e) {

			e.printStackTrace();

			throw e;

		}

	}

}