Subversion Repositories SmartDukaan

package in.shop2020.serving.services;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;

import org.apache.log4j.Logger;
import org.apache.thrift.TException;

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.payments.Attribute;
import in.shop2020.payments.PaymentStatus;
import in.shop2020.thrift.clients.PaymentServiceClient;
import in.shop2020.thrift.clients.TransactionServiceClient;
import in.shop2020.thrift.clients.config.ConfigClient;



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

public class HdfcPaymentService implements IPaymentService {
        private static final long serialVersionUID = 1L;
        private static Logger log = Logger.getLogger(Class.class);
        
        private static String resourceFilePath;
        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 String redirectURL;
        private e24PaymentPipe pipe = null;
        
        private double amount;
        private int gatewayId=1;
        
        private long paymentId;
        
        private enum ActionType{
                PURCHASE("1"),
                AUTH ("4");
                private String value;
                ActionType(String value) {
                        this.value = value;
                }
                public String value(){
                        return this.value;
                }
        }
        
        public HdfcPaymentService() {
        
        }
        
        static{
                try {
                        resourceFilePath = ConfigClient.getClient().get("payment_resource_file_path");
                        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.");
                }
        }
        
        
        public long createPayment(long currentCartId, long userId, long txnId, String paymentOption){
                log.info("Creating payment for the txn#: " + txnId + " for the user: " + userId + " for processing through HDFC");
                CommonPaymentService cps = new CommonPaymentService();
                if(!cps.createPayment(currentCartId, userId, txnId, gatewayId)){
                        log.error("Error while creating the basic payment");
                        return PAYMENT_NOT_CREATED;
                }
                
                paymentId = cps.getPaymentId();
                amount = cps.getAmount();
                
                try {
                        initializePayment(paymentId, amount);
                } catch (ShoppingCartException e1) {
                        log.error("Error while creating hdfc payment.");
                        e1.printStackTrace();
                        return PAYMENT_NOT_CREATED;
                } catch (TException e1) {
                        log.error("Error while creating hdfc payment.");
                        e1.printStackTrace();
                        return PAYMENT_NOT_CREATED;
                }
                
                List<Attribute> attributes = null;
                try {
                        attributes = getAttributesAndSetUdfs(txnId);
                        attributes.add(new Attribute(IPaymentService.PAYMENT_METHOD, paymentOption));
                } catch (TransactionServiceException e1) {
                        log.error("Error while setting udfs to payment.");
                        e1.printStackTrace();
                        return PAYMENT_NOT_CREATED;
                } catch (TException e1) {
                        log.error("Error while setting udfs to payment.");
                        e1.printStackTrace();
                        return PAYMENT_NOT_CREATED;
                }
                
                PaymentServiceClient paymentServiceClient = null;
                try {
                        paymentServiceClient = new PaymentServiceClient();
                } catch (Exception e) {
                        log.error("Error while getting payment client");
                        e.printStackTrace();
                        return PAYMENT_NOT_CREATED;
                }
                
                try {
                        //TODO: Put this in a timed block.
                        short status = pipe.performPaymentInitialization();
                        if(status != e24PaymentPipe.SUCCESS) {
                                log.error("Error sending Payment Initialization Request: ");
                                paymentServiceClient.getClient().updatePaymentDetails(paymentId, null, "", "", pipe.getErrorMsg(), "", "", "", "", PaymentStatus.INIT, "", attributes);
                                redirectURL = errorURL + "?paymentId="+ paymentId + "&ErrorText="+pipe.getErrorMsg();
                                return PAYMENT_NOT_CREATED;
                        }
                        else {
                                log.info("Payment Initialization Request processed successfully for payment Id: " + paymentId);
                                String paymentID = pipe.getPaymentId();
                                paymentServiceClient.getClient().updatePaymentDetails(paymentId, paymentID, "", "", "", "", "", "", "", PaymentStatus.INIT, "", attributes);
                                
                                String payURL = pipe.getPaymentPage();
                                redirectURL = payURL + "?PaymentID=" + paymentID;
                                return paymentId;
                        }
                } catch (NotEnoughDataException e) {
                        log.error("Error while initializing payment." + e.getMessage());
                        e.printStackTrace();
                }catch (Exception e) {
                        log.error("Error while initializing payment." + e.getMessage());
                        e.printStackTrace();
                }
                
                redirectURL = errorURL + "?paymentId="+paymentId + "?ErrorText=Error while initializing payment.";
                return PAYMENT_NOT_CREATED;
        }
        
        private List<Attribute> getAttributesAndSetUdfs(long txnId) throws TransactionServiceException, TException{
                StringBuilder orderDetails = new StringBuilder();
                StringBuilder billingAddress = new StringBuilder();
                String email = "";
                String contactNumber = "";
                
                //get udfs
                Transaction transaction;
                TransactionServiceClient transactionServiceClient = null;
                try {
                        transactionServiceClient = new TransactionServiceClient();
                } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
                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 void initializePayment(long merchantPaymentId, double amounta) throws ShoppingCartException, TException{
                String amount;
                
                amount = (new Double(amounta)).toString();
                
                //Following is the code which initilize e24PaymentPipe with proper value                
                pipe=new e24PaymentPipe();
                pipe.setResourcePath(resourceFilePath); //mandatory 
                String as = pipe.getResourcePath();
                log.info("Resource= " +as);
                
                pipe.setAlias(aliasName);                       //mandatory 
                String ab=pipe.getAlias();
                log.info("Alias= " +ab);
        
                pipe.setAction(ActionType.PURCHASE.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("356");
                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());
        
        }
        
        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 String getRedirectUrl(){
                return this.redirectURL;
        }

}