Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.config.ConfigException;

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

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

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

import in.shop2020.payments.Payment;

import in.shop2020.payments.PaymentException;

import in.shop2020.payments.PaymentStatus;

import in.shop2020.serving.utils.ebs.Base64;

import in.shop2020.serving.utils.ebs.RC4;

import in.shop2020.thrift.clients.PaymentClient;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.thrift.clients.UserClient;

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

import java.io.BufferedReader;

import java.io.ByteArrayInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.util.List;

import java.util.Map;

import java.util.StringTokenizer;

import java.util.TreeMap;

import javax.servlet.http.HttpServletRequest;

import org.apache.log4j.Logger;

import org.apache.thrift.TException;

public class WalletOnlyPaymentController {

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

    private static final String FLAG_KEY = "IsFlagged";

    private static final String TXN_KEY = "TransactionID";

    private static final String AUTH_TXN_ID = "AuthTxnId";

    private static String successUrl;

    private static String errorUrl;

    private static String rechargeResultUri;

    private RechargeOrder rechargeOrder = null;

    /**

     * The secret key used to decode RC4 encoded data.

     */

    private static String accountKey;

    private String redirectUrl;

    static{

        try {

            successUrl = ConfigClient.getClient().get("ebs_success_url");

            errorUrl = ConfigClient.getClient().get("ebs_error_url");

            rechargeResultUri = ConfigClient.getClient().get("recharge_success_url");

            accountKey = ConfigClient.getClient().get("ebs_secret_key");

        } catch (ConfigException e) {

            log.error("Unable to get success and error usr info from config server.");

        }

    }

    private Map<String, String> paymentParams = new TreeMap<String, String>();

    private String rechargeOrderId;

    private HttpServletRequest request;

    public String index() {

        StringBuffer data1 = new StringBuffer(rechargeOrderId);

        log.info("Received rechargeORder Id : " + data1.toString());

        //byte[] result = decodeRecvdData(data1);

        //String recvString = parseRecvdData(result);

        //updatePaymentParams(recvString);

        PaymentClient paymentServiceClient = null;

        TransactionClient transactionServiceClient = null;

        UserClient userServiceClient = null;

        try {

            paymentServiceClient = new PaymentClient();

            transactionServiceClient = new TransactionClient();

            userServiceClient = new UserClient();

        } catch (Exception e) {

            log.error("Unable to initialize one of the clients", e);

        }

        //long merchantPaymentId = Long.parseLong(paymentParams.get("MerchantRefNo"));

        //String gatewayPaymentId = paymentParams.get("PaymentID");

        //double amount = Double.parseDouble(paymentParams.get("Amount"));

//        String isFlagged = paymentParams.get(FLAG_KEY);

//        String gatewayTxnStatus = paymentParams.get("ResponseCode");

//        String description = paymentParams.get("ResponseMessage");

//        String authTxnId = paymentParams.get(TXN_KEY);

        Payment payment = null;

        Long txnId = null;

        try {

            //payment = paymentServiceClient.getClient().getPayment(merchantPaymentId);

            //txnId = payment.getMerchantTxnId();

            /**

             * CREATE PAYMENT

             */

            rechargeOrder = transactionServiceClient.getClient().getRechargeOrder(Long.parseLong(rechargeOrderId));

            List<Payment> payments = paymentServiceClient.getClient().getPaymentForRechargeTxnId(rechargeOrder.getTransactionId());

            if(payments.size() > 0) {

                throw new PaymentException(rechargeOrder.getId(), "Payment already exists for recharge");

            }

            Long merchantPaymentId = 0l;

            if (rechargeOrder.getWalletAmount() != rechargeOrder.getTotalAmount() || rechargeOrder.getWalletAmount() <= 0) {

                log.error("Wallet amount is " + rechargeOrder.getWalletAmount() + " and total amount is " + rechargeOrder.getTotalAmount());

                merchantPaymentId = paymentServiceClient.getClient().createPayment(rechargeOrder.getUserId(), rechargeOrder.getTotalAmount(), 8, rechargeOrder.getTransactionId(), true);

                paymentServiceClient.getClient().updatePaymentDetails(merchantPaymentId, "",

                        "", "0", "", "", "", "", "", PaymentStatus.FAILED, "", null);

                transactionServiceClient.getClient().updateRechargeOrderStatus(rechargeOrder.getId(),  RechargeOrderStatus.PAYMENT_FAILED);

            } else {

                merchantPaymentId = paymentServiceClient.getClient().createPayment(rechargeOrder.getUserId(), rechargeOrder.getTotalAmount(), 8, rechargeOrder.getTransactionId(), true);

                //Update payment status as authorized

                paymentServiceClient.getClient().updatePaymentDetails(merchantPaymentId, "",

                        "", "0", "", "", "", "", "", PaymentStatus.SUCCESS, "", null);

                transactionServiceClient.getClient().updateRechargeOrderStatus(rechargeOrder.getId(),  RechargeOrderStatus.PAYMENT_SUCCESSFUL);

            }

            this.redirectUrl = rechargeResultUri + "?paymentId=" + merchantPaymentId;

        } catch (PaymentException e) {

            log.error("Unable to mark the payment as authorized", e);

        } catch (TException e) {

            log.error("Unable to mark the payment as authorized", e);

        } catch (TransactionServiceException e) {

            // TODO Auto-generated catch block

            log.error("Unable to recharge");

        }

            //DataLogger.logData(EventType.PAYMENT_FAILURE, getSessionId(), userinfo.getUserId(), userinfo.getEmail(), Long.toString(merchantPaymentId), gatewayPaymentId,

            //        gatewayTxnStatus, description);

        log.info("User will be redirected to: " + this.redirectUrl);

        return "index";

    }

    public String getRedirectUrl(){

        return this.redirectUrl;

    }

    public void setServletRequest(HttpServletRequest request) {

        this.request = request;

    }

    public Map<String, String> getPaymentParams() {

        return paymentParams;

    }

    public static String getRechargeResultUri() {

        return rechargeResultUri;

    }

    public String getRechargeOrderId() {

        return rechargeOrderId;

    }

    public void setRechargeOrderId(String rechargeOrderId) {

        this.rechargeOrderId = rechargeOrderId;

    }

}