Subversion Repositories SmartDukaan

package in.shop2020.payment.service.handler;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.apache.thrift.TException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import in.shop2020.payment.handler.PaymentGatewayHandler;

import in.shop2020.payment.handler.PaymentHandler;

import in.shop2020.payments.Attribute;

import in.shop2020.payments.Payment;

import in.shop2020.payments.PaymentException;

import in.shop2020.payments.PaymentGateway;

import in.shop2020.payments.PaymentService.Iface;

import in.shop2020.payments.PaymentStatus;

public class PaymentServiceHandler implements Iface {

	public static final long PAYMENT_NOT_CREATED = -1;

	private static final String FLAG_KEY = "IsFlagged";

	private static final String TXN_KEY = "TransactionID";

	private static final String AUTH_TXN_ID = "AuthTxnId";

	private static final String CAPTURE_TXN_ID = "CaptureTxnId";

	private static final String CAPTURE_TIME = "CaptureTime";

	ApplicationContext context = new ClassPathXmlApplicationContext("context.xml");

	PaymentHandler paymentHandler = (PaymentHandler) context.getBean("paymentHandler");

	PaymentGatewayHandler paymentGatewayHandler = (PaymentGatewayHandler) context.getBean("paymentGatewayHandler");

	@Override

	public void closeSession() throws TException {

		// TODO Auto-generated method stub		

	}

	@Override

	public long createPayment(long userId, double amount, long gatewayId, long txnId) throws PaymentException, TException {

		in.shop2020.payment.domain.Payment payment = new in.shop2020.payment.domain.Payment();

		payment.setUserId(userId);

		payment.setAmount(amount);

		payment.setGatewayId(gatewayId);

		payment.setMerchantTxnId(txnId);

		payment.setStatus(PaymentStatus.INIT.getValue());

		return paymentHandler.insertPayment(payment);

	}

	@Override

	public List<Payment> getPaymentsForUser(long userId, long fromTime, long toTime, PaymentStatus status, long gatewayId) throws PaymentException, TException {

		int statusValue = -1;

		if(status != null)

			statusValue = status.getValue();

		else

			statusValue = -1;

		return getThriftPayments(paymentHandler.getPaymentsForUser(userId, fromTime, toTime, statusValue, gatewayId));

	}

	@Override

	public List<Payment> getPayments(long fromTime, long toTime, PaymentStatus status, long gatewayId) throws PaymentException,	TException {

		int statusValue = -1;

		if(status != null)

			statusValue = status.getValue();

		else

			statusValue = -1;

		return getThriftPayments(paymentHandler.getPayments(fromTime, toTime, statusValue, gatewayId));

	}

	@Override

	public PaymentGateway getPaymentGateway(long id) throws PaymentException, TException {

		return paymentGatewayHandler.getPaymentGateway(id).getThriftPaymentGateway();

	}

	@Override

	public Payment getPayment(long id) throws PaymentException, TException {

		return paymentHandler.getPayment(id).getThriftPayment();

	}

	@Override

	public List<Payment> getPaymentForTxnId(long txnId) throws PaymentException, TException {

		return getThriftPayments(paymentHandler.getPaymentForTxn(txnId));

	}

	@Override

	public boolean updatePaymentDetails(long id, String gatewayPaymentId,

			String sessionId, String gatewayTxnStatus, String description,

			String gatewayTxnId, String authCode, String referenceCode,

			String errorCode, PaymentStatus status, String gatewayTxnDate,

			List<Attribute> attributes) throws PaymentException, TException {

		in.shop2020.payment.domain.Payment payment = paymentHandler.getPayment(id);

		payment.setGatewayPaymentId(gatewayPaymentId);

		payment.setSessionId(sessionId);

		payment.setGatewayTxnStatus(gatewayTxnStatus);

		payment.setDescription(description);

		payment.setGatewayTxnId(gatewayTxnId);

		payment.setAuthCode(authCode);

		payment.setReferenceCode(referenceCode);

		payment.setErrorCode(errorCode);

		if(status!=null){

			payment.setStatus(status.getValue());

			if(status.equals(PaymentStatus.SUCCESS))

				payment.setSuccessTimestamp(new Date());

			else if(status.equals(PaymentStatus.FAILED))

				payment.setErrorTimestamp(new Date());

		}

		payment.setGatewayTxnDate(gatewayTxnDate);

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

		if(attributes != null){

			for(Attribute attribute : attributes){

				attrMap.put(attribute.getName(), attribute.getValue());

			}

		}

		paymentHandler.updatePayment(payment, attrMap);

		return true;

	}

	@Override

	public List<Double> getSuccessfulPaymentsAmountRange() throws TException {

		List<Double> minMaxAmounts = new ArrayList<Double>();

		Map<String, Float> minMax = paymentHandler.getMinMaxPaymentAmount();

		minMaxAmounts.add(Double.parseDouble(Float.toString(minMax.get("MIN"))));

		minMaxAmounts.add(Double.parseDouble(Float.toString(minMax.get("MAX"))));

		return minMaxAmounts;

	}

	private List<Payment> getThriftPayments(List<in.shop2020.payment.domain.Payment> daoPayments){

		List<Payment> payments = new ArrayList<Payment>();

		for(in.shop2020.payment.domain.Payment payment : daoPayments){

			payments.add(payment.getThriftPayment());

		}

		return payments;

	}

	@Override

	public Payment updateAndCaptureEbsPayment(Map<String, String> paymentParams) throws PaymentException, TException {

		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);

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

		attributes.add(new Attribute(FLAG_KEY, isFlagged));

		attributes.add(new Attribute(AUTH_TXN_ID, authTxnId));

		Payment payment = null;

		try {

			payment = getPayment(merchantPaymentId);

		} catch (PaymentException e1) {

			throw new PaymentException(e1);

		}

		if(!validatePaymentParams(amount, payment)){

			throw new PaymentException(102, "Checks and balance failed on returned data");

		}

		if(gatewayTxnStatus.equals("0")){

			//Update payment status as authorized

			updatePaymentDetails(merchantPaymentId, gatewayPaymentId, "", gatewayTxnStatus, description, "", "", "", "", PaymentStatus.AUTHORIZED, "", attributes);

			Map<String, String> captureResult = EbsPaymentHandler.capturePayment(amount, "" + gatewayPaymentId);

			String captureStatus = captureResult.get(EbsPaymentHandler.STATUS);

			if("".equals(captureStatus)){

				//Failure

				description = captureResult.get(EbsPaymentHandler.ERROR);

				String errorCode = captureResult.get(EbsPaymentHandler.ERR_CODE);

				updatePaymentDetails(merchantPaymentId, gatewayPaymentId, "", gatewayTxnStatus, description, "", "", "", errorCode, PaymentStatus.FAILED, "", attributes);

			}else{

				//Success

				attributes.add(new Attribute(CAPTURE_TXN_ID, captureResult.get(EbsPaymentHandler.TXN_ID)));

				attributes.add(new Attribute(CAPTURE_TIME, captureResult.get(EbsPaymentHandler.DATE_TIME)));

				updatePaymentDetails(merchantPaymentId, gatewayPaymentId, "", captureStatus, description, "", "", "", "", PaymentStatus.SUCCESS, "", attributes);

			}

		}else{

			updatePaymentDetails(merchantPaymentId, gatewayPaymentId, "", gatewayTxnStatus, description, "", "", "", "", PaymentStatus.FAILED, "", attributes);		

		}

		payment = getPayment(merchantPaymentId);

		return payment;

	}

	@Override

	public String initializeHdfcPayment(long merchantPaymentId) throws PaymentException, TException {

		in.shop2020.payment.domain.Payment payment = paymentHandler.getPayment(merchantPaymentId);

		String redirectURL;

		try {

			redirectURL = HdfcPaymentHandler.initializeHdfcPayment(payment, this);

		} catch (Exception e) {

			throw new PaymentException(102, "Error while initiliazing payment. Check service log for more details.");

		}

		return redirectURL;

	}

	@Override

	public Map<String, String> captureHdfcPayment(long merchantPaymentId){

		in.shop2020.payment.domain.Payment payment = paymentHandler.getPayment(merchantPaymentId);

		return HdfcPaymentHandler.capturePayment(payment);

	}

	@Override

    public long createRefund(long orderId, long merchantTxnId, double amount) throws PaymentException, TException{

		List<in.shop2020.payment.domain.Payment> payments = paymentHandler.getPaymentForTxn(merchantTxnId);

		in.shop2020.payment.domain.Payment payment = null;

		if(payments ==null || payments.isEmpty())

			throw new PaymentException(104, "No payments found corresponding to the merchant txn " + merchantTxnId);

		payment = payments.get(0);

		if(payment.getStatus() != PaymentStatus.SUCCESS.getValue())

			throw new PaymentException(104, "No successful payments found corresponding to the merchant txn " + merchantTxnId);

		//TODO: Create a refund and return its id.

    	return -1;

    }

	private boolean validatePaymentParams(double amount, Payment payment){

		if(payment==null || payment.getAmount()!= amount){

			// We did not request this payment or the authorised amount is different.

			return false;

		}

		return true;

	}

}