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.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 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 String responseURLforRecharge;

    private static String errorURLforRecharge;
        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");
                        errorURL = ConfigClient.getClient().get("payment_error_url");
                        responseURLforRecharge = ConfigClient.getClient().get("payment_response_url_for_recharge");
                        errorURLforRecharge = ConfigClient.getClient().get("recharge_success_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 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 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 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 message

                                if (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 transaction
                                resultMap.put(REFUND_REF_ID, pipe.getRef());                    // Unique reference number generated during the transaction
                                resultMap.put(REFUND_TXN_ID, pipe.getTransId());                // Unique Transaction ID generated after every successful transaction
                                resultMap.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 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 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) throws Exception{
                long merchantPaymentId = payment.getId();
                double amount = payment.getAmount();
                e24PaymentPipe pipe = new e24PaymentPipe();
                
                try {
                        initializePayment(pipe, merchantPaymentId, amount, false);
                } 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, boolean isDigital) 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);
        
                 
                String ac=pipe.getAction();
                log.info("Action= " +ac);
                
                if(isDigital) {
                    pipe.setAction(ActionType.PURCHASE.value());          //mandatory
                    pipe.setResponseURL( responseURLforRecharge );   //mandatory
                    pipe.setErrorURL( errorURLforRecharge); //mandatory
                } else {
                    pipe.setAction(ActionType.AUTH.value());          //mandatory
                    pipe.setResponseURL( responseURL );
                    pipe.setErrorURL( errorURL);
                }
                String at=pipe.getResponseURL();
                log.info("ResponseURL= "+at);
        
                //pipe.setErrorURL( errorURL + "?paymentId=" + merchantPaymentId );             //mandatory
            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;
        }

    public static String initializeHdfcPayment(in.shop2020.payment.domain.Payment payment, RechargeOrder rechargeOrder,
            String phone, PaymentServiceHandler paymentServiceHandler) throws Exception {
        Long merchantPaymentId = payment.getId();
        double amount = payment.getAmount();
        e24PaymentPipe pipe = new e24PaymentPipe();
        
        try {
            initializePayment(pipe, merchantPaymentId, amount, true);
        } 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 udfs
        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");//city
            billingAddress.append(" " + merchantPaymentId);//line1
            billingAddress.append(" " + merchantPaymentId);//line2
            billingAddress.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 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;
    }
}