Subversion Repositories SmartDukaan

package in.shop2020.payment.service.handler;

import in.shop2020.config.ConfigException;

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

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

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

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

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

import in.shop2020.payment.domain.Payment;

import in.shop2020.payments.Attribute;

import in.shop2020.payments.PaymentException;

import in.shop2020.payments.PaymentStatus;

import in.shop2020.thrift.clients.TransactionClient;

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

import java.io.File;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Random;

import org.apache.log4j.Logger;

import org.apache.thrift.TException;

import com.aciworldwide.commerce.gateway.plugins.NotEnoughDataException;

import com.aciworldwide.commerce.gateway.plugins.e24PaymentPipe;

import com.aciworldwide.commerce.gateway.plugins.e24TranPipe;

public class HdfcPaymentHandler implements IPaymentHandler {

	private static final int CAPTURE_STATUS_FOR_CONNECTION_ISSUE = -1;

    private static Logger log = Logger.getLogger(HdfcPaymentHandler.class);

	private static String aliasName;

	private static String responseURL;

	private static String errorURL;

	private static final String regex = "[^a-zA-Z0-9\\s\\-\\@\\/\\.]";

	private static final String replacement = " ";

	private static final int MAX_UDF_LENGTH = 30;

	private static final String currencyCode = "356";

	private static String resourceDirPath = "/tmp/resource";

	private static final String resourceFileName = "resource.cgn";

	private enum ActionType{

		PURCHASE("1"),

		AUTH ("4"),

		CAPTURE("5");

		private String value;

		ActionType(String value) {

			this.value = value;

		}

		public String value(){

			return this.value;

		}

	}

	public HdfcPaymentHandler() {

		// TODO Auto-generated constructor stub

	}

	static{

		try {

			InputStream inputStream = Class.class.getResourceAsStream(ConfigClient.getClient().get("payment_resource_file_path") + resourceFileName);

			File resourceDir = new File(resourceDirPath);

			if(!resourceDir.exists()){

				resourceDir.mkdir();

			}

			OutputStream outStream = new FileOutputStream(resourceDirPath + File.separator + resourceFileName);

			byte buf[]=new byte[1024];

			int len;

			while((len=inputStream.read(buf))>0)

				outStream.write(buf,0,len);

			outStream.close();

			inputStream.close();

	        aliasName  = ConfigClient.getClient().get("payment_alias_name");

			responseURL = ConfigClient.getClient().get("payment_response_url");

			errorURL = ConfigClient.getClient().get("payment_error_url");

		} catch (ConfigException e) {

			log.error("Unable to get data from config server.");

		} catch (FileNotFoundException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		} catch (IOException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

	public static Map<String, String> capturePayment(Payment payment){

		String amount = "" + payment.getAmount();

		String gatewayPaymentId = payment.getGatewayPaymentId();

		log.info("Capturing amount: Rs " + amount + " for payment Id: " + gatewayPaymentId);

		//Prepare resultMap to elicit failure behaviour in case anything goes wrong.

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

	    resultMap.put(STATUS, Errors.CAPTURE_FAILURE.code);

        resultMap.put(ERR_CODE, Errors.CAPTURE_FAILURE.code);

        resultMap.put(ERROR, Errors.CAPTURE_FAILURE.message);

		e24TranPipe pipe = new e24TranPipe();

		pipe.setResourcePath(resourceDirPath);

		pipe.setAlias(aliasName);

		pipe.setAction(ActionType.CAPTURE.value());

		pipe.setAmt(amount);

		pipe.setTrackId("" + payment.getId());

		pipe.setMember("SAHOLIC");

		pipe.setCurrencyCode(currencyCode);

		pipe.setTransId(payment.getGatewayTxnId());

		//Check if the values have been set properly

		log.info("Pipe Amount: " + pipe.getAmt());

		log.info("Pipe Action Code: " + pipe.getAction());

		log.info("Pipe Currency Code: " + pipe.getCurrencyCode());

		log.info("Pipe Track Id: " + pipe.getTrackId());

		log.info("Pipe Trans Id:" + pipe.getTransId());

		int captureStatus = e24TranPipe.FAILURE;

		try {

			captureStatus = pipe.performTransaction();

			log.info("Capture Status: " + captureStatus);

			log.info("Gateway Txn Status: " + pipe.getResult());

			log.info("Debug Msg: " + pipe.getDebugMsg());

			log.info("Auth: " + pipe.getAuth());

			log.info("Ref: " + pipe.getRef());

			log.info("TransId:" + pipe.getTransId());

			log.info("Amount: " + pipe.getAmt());

			resultMap.put(STATUS, "" + captureStatus);

			String result = pipe.getResult();

			resultMap.put(GATEWAY_STATUS, result.substring(0, Math.min(result.length(), 20)).trim());		//This will return the result of the transaction. (Successful or Failed)

			if(captureStatus != e24TranPipe.SUCCESS || !"CAPTURED".equals(result)){

				resultMap.put(ERROR, pipe.getErrorMsg());				// In case of any error, we only need to get the error message

				if (captureStatus == CAPTURE_STATUS_FOR_CONNECTION_ISSUE) {

	                resultMap.put(ERR_CODE, Errors.CONN_FAILURE.code);

	            }

			}

			else {

				resultMap.put(CAPTURE_AUTH_ID, pipe.getAuth());			// Unique ID generated by Authorizer of the transaction

				resultMap.put(CAPTURE_REF_ID, pipe.getRef());			// Unique reference number generated during the transaction

				resultMap.put(CAPTURE_TXN_ID, pipe.getTransId());		// Unique Transaction ID generated after every successful transaction

				resultMap.put(CAPTURE_AMNT, pipe.getAmt());			// Original Amount of the transaction

			}

		} catch (NotEnoughDataException e) {

            log.error(Errors.CAPTURE_FAILURE.message, e);

            resultMap.put(ERR_CODE, Errors.CAPTURE_FAILURE.code);

            resultMap.put(ERROR, e.getMessage());

		}

		return resultMap;

	}

	public static String initializeHdfcPayment(Payment payment, PaymentServiceHandler handler) throws Exception{

		long merchantPaymentId = payment.getId();

		double amount = payment.getAmount();

		e24PaymentPipe pipe = new e24PaymentPipe();

		try {

			initializePayment(pipe, merchantPaymentId, amount);

		} catch (ShoppingCartException e1) {

			log.error("Error while creating hdfc payment.", e1);

			throw e1;    //Payment couldn't be initialized. Will be redirected to the shipping page.

		} catch (TException e1) {

			log.error("Error while creating hdfc payment.", e1);

			throw e1;   //Payment couldn't be initialized. Will be redirected to the shipping page.

		}

		List<Attribute> attributes = null;

		try {

			attributes = getAttributesAndSetUdfs(pipe, payment.getMerchantTxnId());

		} catch (TransactionServiceException e1) {

			log.error("Error while setting udfs to payment.", e1);

			throw e1;   //Payment couldn't be initialized. Will be redirected to the shipping page.

		} catch (TException e1) {

			log.error("Error while setting udfs to payment.", e1);

			throw e1;   //Payment couldn't be initialized. Will be redirected to the shipping page.

		}

		try {

			if(pipe.performPaymentInitialization() != e24PaymentPipe.SUCCESS) {

				log.error("Error sending Payment Initialization Request: ");

				handler.updatePaymentDetails(merchantPaymentId, null, "", "", pipe.getErrorMsg(), "", "", "", "", PaymentStatus.INIT, "", attributes);

			} else {

				log.info("Payment Initialization Request processed successfully for payment Id: " + merchantPaymentId);

				String paymentID = pipe.getPaymentId();

				handler.updatePaymentDetails(merchantPaymentId, paymentID, "", "", "", "", "", "", "", PaymentStatus.INIT, "", attributes);

				String payURL = pipe.getPaymentPage();

				return payURL + "?PaymentID=" + paymentID;

			}

		} catch (NotEnoughDataException e) {

			log.error("Error while initializing payment.", e);

		}catch (Exception e) {

			log.error("Error while initializing payment.", e);

		}

		//If the code reaches here, the payment initialization was not successful and we've not returned the redirect URL.

		//Throw the exception so that any failovers can happen.

		throw new PaymentException(115, "Unable to initialize HDFC payment");

	}

	private static List<Attribute> getAttributesAndSetUdfs(e24PaymentPipe pipe, long txnId) throws TransactionServiceException, TException{

		StringBuilder orderDetails = new StringBuilder();

		StringBuilder billingAddress = new StringBuilder();

		String email = "";

		String contactNumber = "";

		//get udfs

		Transaction transaction;

		TransactionClient transactionServiceClient = null;

		try {

			transactionServiceClient = new TransactionClient();

		} catch (Exception e) {

			log.error("Unable to get transaction details", e);

		}

		in.shop2020.model.v1.order.TransactionService.Client txnClient = transactionServiceClient.getClient();

		transaction = txnClient.getTransaction(txnId);

		orderDetails.append(transaction.getOrdersSize() + " ");

		for (Order order : transaction.getOrders()) {

			contactNumber= order.getCustomer_mobilenumber();

			email = order.getCustomer_email();

			billingAddress.append(" ");

			if(order.getCustomer_pincode()!=null){

				billingAddress.append(order.getCustomer_pincode());

			}

			if(order.getCustomer_city()!=null){

				billingAddress.append(" " + order.getCustomer_city());

			}

			if(order.getCustomer_address1()!=null){

				billingAddress.append(" " + order.getCustomer_address1());

			}

			if(order.getCustomer_address2()!=null){

				billingAddress.append(" " + order.getCustomer_address2());

			}

			if(order.getCustomer_state()!=null){

				billingAddress.append(" " + order.getCustomer_state());

			}

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

				if(line.getBrand() != null){

					orderDetails.append(line.getBrand());

				}

				if(line.getModel_name() != null){

					orderDetails.append(line.getModel_name()); 

				}

				if(line.getModel_number() != null){

					orderDetails.append(line.getModel_number());

				}

				if(line.getColor() != null){

					orderDetails.append(line.getColor());

				}

				orderDetails.append(" ");

			}

		}

		Random random = new Random();

		String merchantInfo = ""+random.nextLong(); 

	    String udf1 = formatUdf(orderDetails.toString()); 

	    String udf2 = formatUdf(email);

	    String udf3 = formatUdf(contactNumber);

	    String udf4 = formatUdf(billingAddress.toString());

	    String udf5 = merchantInfo;

	    log.info("udf1:"  + udf1);

	    log.info("udf2:"  + udf2);

	    log.info("udf3:"  + udf3);

	    log.info("udf4:"  + udf4);

	    log.info("udf5:"  + udf5);

	    pipe.setUdf1(udf1);      //	UDF 1 - Order details

		pipe.setUdf2(udf2);      //	UDF 2 - Email ID

		pipe.setUdf3(udf3);      //	UDF 3 - Contact Number. 

		pipe.setUdf4(udf4);      //	UDF 4 - Billing Address

		pipe.setUdf5(udf5);		 //	UDF 5 - Merchant specific

		List<Attribute> attributes = new ArrayList<Attribute>();

		Attribute attribute1 = new Attribute("udf1",udf1);

		Attribute attribute2 = new Attribute("udf2",udf2);

		Attribute attribute3 = new Attribute("udf3",udf3);

		Attribute attribute4 = new Attribute("udf4",udf4);

		Attribute attribute5 = new Attribute("udf5",udf5);

		attributes.add(attribute1);

		attributes.add(attribute2);

		attributes.add(attribute3);

		attributes.add(attribute4);

		attributes.add(attribute5);

		return attributes;

	}

	private static void initializePayment(e24PaymentPipe pipe, long merchantPaymentId, double amounta) throws ShoppingCartException, TException{

		String amount = (new Double(amounta)).toString();

		//Following is the code which initilize e24PaymentPipe with proper value

		pipe.setResourcePath(resourceDirPath);	//mandatory 

		String as = pipe.getResourcePath();

		log.info("Resource= " +as);

		pipe.setAlias(aliasName);			//mandatory 

		String ab=pipe.getAlias();

		log.info("Alias= " +ab);

		pipe.setAction(ActionType.AUTH.value());			//mandatory 

		String ac=pipe.getAction();

		log.info("Action= " +ac);

		pipe.setResponseURL( responseURL );	//mandatory

		String at=pipe.getResponseURL();

		log.info("ResponseURL= "+at);

		//pipe.setErrorURL( errorURL + "?paymentId=" + merchantPaymentId );		//mandatory

		pipe.setErrorURL( errorURL);

	    String ak=pipe.getErrorURL();

	    log.info("ErrorURL= " + ak);

		pipe.setAmt(amount);		

		String ap=pipe.getAmt();

		log.info("Amt= " + ap);

		pipe.setCurrency(currencyCode);

		String a=pipe.getCurrency();

		log.info("Currency= " + a);

		pipe.setLanguage("USA");

		String p=pipe.getLanguage();

		log.info("Language= "+ p);

		pipe.setTrackId((new Long(merchantPaymentId)).toString());

	}

	private static String formatUdf(String udfString){

		udfString = udfString.replaceAll(regex, replacement);

		if(udfString.length() > MAX_UDF_LENGTH){

			udfString = udfString.substring(0, MAX_UDF_LENGTH);

		}

		return udfString;

	}

}