Rev 10968 | Blame | Compare with Previous | Last modification | View Log | RSS feed
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.RechargeOrder;import in.shop2020.model.v1.order.Transaction;import in.shop2020.model.v1.order.TransactionServiceException;import in.shop2020.model.v1.user.Address;import in.shop2020.model.v1.user.ShoppingCartException;import in.shop2020.payment.domain.Payment;import in.shop2020.payment.service.handler.PaymentServiceHandler.HdfcPaymentReturnStatus;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.UserClient;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 mResponseURL;private static String errorURL;private static String mErrorURL;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 String responseURLforRecharge;private static String mResponseURLforRecharge;private static String errorURLforRecharge;private static String mErrorURLforRecharge;private static final String resourceFileName = "resource.cgn";private enum ActionType{PURCHASE("1"),REFUND("2"),AUTH ("4"),CAPTURE("5"),INQUIRY("8");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 + 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");mResponseURL = ConfigClient.getClient().get("m_payment_response_url");errorURL = ConfigClient.getClient().get("payment_error_url");mErrorURL = ConfigClient.getClient().get("m_payment_error_url");responseURLforRecharge = ConfigClient.getClient().get("payment_response_url_for_recharge");mResponseURLforRecharge = ConfigClient.getClient().get("m_payment_response_url_for_recharge");errorURLforRecharge = ConfigClient.getClient().get("recharge_success_url");mErrorURLforRecharge = ConfigClient.getClient().get("m_recharge_success_url");} catch (ConfigException e) {log.error("Unable to get data from config server.");} catch (FileNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.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 properlylog.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 messageif (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 transactionresultMap.put(CAPTURE_REF_ID, pipe.getRef()); // Unique reference number generated during the transactionresultMap.put(CAPTURE_TXN_ID, pipe.getTransId()); // Unique Transaction ID generated after every successful transactionresultMap.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 Map<String, String> refundPayment(Payment payment, double amount){String ramount = "" + amount;String gatewayPaymentId = payment.getGatewayPaymentId();log.info("Refunding 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.REFUND.value());pipe.setAmt(ramount);pipe.setTrackId("" + payment.getId());pipe.setMember("SAHOLIC");pipe.setCurrencyCode(currencyCode);pipe.setTransId(payment.getGatewayTxnId());//Check if the values have been set properlylog.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 refundStatus = e24TranPipe.FAILURE;try {refundStatus = pipe.performTransaction();log.info("Refund Status: " + refundStatus);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, "" + refundStatus);String result = pipe.getResult();log.info("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(refundStatus != e24TranPipe.SUCCESS){resultMap.put(ERROR, pipe.getErrorMsg()); // In case of any error, we only need to get the error messageif (refundStatus == CAPTURE_STATUS_FOR_CONNECTION_ISSUE) {resultMap.put(ERR_CODE, Errors.CONN_FAILURE.code);}}else {resultMap.put(REFUND_AUTH_ID, pipe.getAuth()); // Unique ID generated by Authorizer of the transactionresultMap.put(REFUND_REF_ID, pipe.getRef()); // Unique reference number generated during the transactionresultMap.put(REFUND_TXN_ID, pipe.getTransId()); // Unique Transaction ID generated after every successful transactionresultMap.put(REFUND_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 PaymentStatus validateHdfcPayment(Payment payment, double amount){String ramount = "" + amount;//String gatewayPaymentId = payment.getGatewayPaymentId();e24TranPipe pipe = new e24TranPipe();pipe.setResourcePath(resourceDirPath);pipe.setAlias(aliasName);pipe.setAction(ActionType.INQUIRY.value());pipe.setAmt(ramount);pipe.setTrackId("" + payment.getId());pipe.setMember("SAHOLIC");pipe.setCurrencyCode(currencyCode);pipe.setTransId(payment.getGatewayPaymentId());//Check if the values have been set properlylog.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 refundStatus = e24TranPipe.FAILURE;String gatewayStatus = "";try {refundStatus = pipe.performTransaction();log.info("Inquiry Status: " + refundStatus);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());String result = pipe.getResult();log.info("Result: " + pipe.getResult());gatewayStatus = result.substring(0, Math.min(result.length(), 20)).trim(); //This will return the result of the transaction. (Successful or Failed)if ((""+refundStatus).trim().equals("0")) {if(HdfcPaymentReturnStatus.CAPTURED.value().equals(gatewayStatus)){return PaymentStatus.SUCCESS;}if(HdfcPaymentReturnStatus.APPROVED.value().equals(gatewayStatus)){return PaymentStatus.AUTHORIZED;}if(HdfcPaymentReturnStatus.NOT_CAPTURED.value().equals(gatewayStatus)){return PaymentStatus.FAILED;}if(HdfcPaymentReturnStatus.NOT_APPROVED.value().equals(gatewayStatus)){return PaymentStatus.FAILED;}}} catch (NotEnoughDataException e) {log.error(Errors.CAPTURE_FAILURE.message, e);}return PaymentStatus.INIT;}public static String initializeHdfcPayment(Payment payment, PaymentServiceHandler handler, boolean isMobile) throws Exception{long merchantPaymentId = payment.getId();double amount = payment.getAmount();e24PaymentPipe pipe = new e24PaymentPipe();try {initializePayment(pipe, merchantPaymentId, amount, false, isMobile);} 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 udfsTransaction 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 detailspipe.setUdf2(udf2); // UDF 2 - Email IDpipe.setUdf3(udf3); // UDF 3 - Contact Number.pipe.setUdf4(udf4); // UDF 4 - Billing Addresspipe.setUdf5(udf5); // UDF 5 - Merchant specificList<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, boolean isDigital, boolean isMobile) throws ShoppingCartException, TException{String amount = (new Double(amounta)).toString();//Following is the code which initilize e24PaymentPipe with proper valuepipe.setResourcePath(resourceDirPath); //mandatoryString as = pipe.getResourcePath();log.info("Resource= " +as);pipe.setAlias(aliasName); //mandatoryString ab=pipe.getAlias();log.info("Alias= " +ab);String ac=pipe.getAction();log.info("Action= " +ac);if(isDigital) {pipe.setAction(ActionType.PURCHASE.value()); //mandatoryif(isMobile) {pipe.setResponseURL(mResponseURLforRecharge);pipe.setErrorURL(mErrorURLforRecharge);} else {pipe.setResponseURL( responseURLforRecharge ); //mandatorypipe.setErrorURL( errorURLforRecharge); //mandatory}} else {pipe.setAction(ActionType.AUTH.value());//mandatoryif(isMobile) {pipe.setResponseURL(mResponseURL);pipe.setErrorURL( mErrorURL);} else {pipe.setResponseURL( responseURL );pipe.setErrorURL( errorURL);}}String at=pipe.getResponseURL();log.info("ResponseURL= "+at);//pipe.setErrorURL( errorURL + "?paymentId=" + merchantPaymentId ); //mandatoryString 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;}public static String initializeHdfcPayment(in.shop2020.payment.domain.Payment payment, RechargeOrder rechargeOrder,String phone, PaymentServiceHandler paymentServiceHandler, boolean isMobile) throws Exception {Long merchantPaymentId = payment.getId();log.info("Is mobile ---- " + isMobile);double amount = payment.getAmount();e24PaymentPipe pipe = new e24PaymentPipe();try {initializePayment(pipe, merchantPaymentId, amount, true, isMobile);} 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, rechargeOrder, merchantPaymentId.toString(), phone);} 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: ");paymentServiceHandler.updatePaymentDetails(merchantPaymentId, null, "", "", pipe.getErrorMsg(), "", "", "", "", PaymentStatus.INIT, "", attributes);} else {log.info("Payment Initialization Request processed successfully for payment Id: " + merchantPaymentId);String paymentID = pipe.getPaymentId();paymentServiceHandler.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, RechargeOrder rechargeOrder, String merchantPaymentId, String phone) throws TransactionServiceException, TException {StringBuilder orderDetails = new StringBuilder();StringBuilder billingAddress = new StringBuilder();String email = "";String contactNumber = "";Address address = null;//get udfslog.info("getAttributesAndSetUdfs phone---- " + phone);if (!(phone == null) && !(phone.isEmpty())) {//Remember in RechargePaymentController we kept phone set only for a specific case.//This is the case where we don't need to get the address and can safely set the phone number only.contactNumber = phone;email = rechargeOrder.getUserEmailId();billingAddress.append(" ");billingAddress.append("110001");billingAddress.append(" " + "Delhi");//citybillingAddress.append(" " + merchantPaymentId);//line1billingAddress.append(" " + merchantPaymentId);//line2billingAddress.append(" " + merchantPaymentId);//state} else {try {UserClient userClient = new UserClient();address = userClient.getClient().getAddressById(userClient.getClient().getDefaultAddressId(rechargeOrder.getUserId()));} catch (Exception e) {log.error("Unable to get transaction details", e);}contactNumber= address.getPhone();email = rechargeOrder.getUserEmailId();billingAddress.append(" ");if(address.getPin()!=null){billingAddress.append(address.getPin());}if(address.getCity()!=null){billingAddress.append(" " + address.getCity());}if(address.getLine1()!=null){billingAddress.append(" " + address.getLine1());}if(address.getLine2()!=null){billingAddress.append(" " + address.getLine2());}if(address.getState()!=null){billingAddress.append(" " + address.getState());}}orderDetails.append("Recharge : " + rechargeOrder.getDisplayId());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 detailspipe.setUdf2(udf2); // UDF 2 - Email IDpipe.setUdf3(udf3); // UDF 3 - Contact Number.pipe.setUdf4(udf4); // UDF 4 - Billing Addresspipe.setUdf5(udf5); // UDF 5 - Merchant specificList<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;}}