Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller.checkout;

import java.security.MessageDigest;

import java.security.NoSuchAlgorithmException;

import java.util.List;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Component;

import com.spice.profitmandi.thrift.clients.PaymentClient;

import com.spice.profitmandi.thrift.clients.TransactionClient;

import com.spice.profitmandi.thrift.clients.config.ConfigClient;

import com.spice.profitmandi.web.payment.IPaymentService;

import com.spice.profitmandi.web.payment.PaymentUtils;

import com.spice.profitmandi.web.res.order.PayuPayPojo;

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.payments.Attribute;

import in.shop2020.payments.Payment;

@Component

public class PayuHandler {

	private static final Logger log = LoggerFactory.getLogger(PayuHandler.class);

	private static String accountId;

	private static String returnUrl = "/payu-pay-response";

	private static String cancelUrl = "/pay-options";

	public static String successUrl;

	public static String errorUrl;	

	private static String salt;

	private static String postActionUrl;

	private String phone;//This is used for recharge orders of value less than 1000.

	private String resultJson;//This is used for recharge orders of value less than 1000.

	static{

		try {

			ConfigClient client = ConfigClient.getClient();

			accountId = client.get("payu_account_id");

			salt = client.get("payu_secret_key");

			returnUrl = client.get("payu_return_url");

			cancelUrl = client.get("pay_options_url");

			postActionUrl = client.get("payu_post_url");

			successUrl = client.get("payu_success_url");

			errorUrl = client.get("payu_error_url");

			//"https://test.payu.in/_payment";

		} catch (ConfigException e) {

			log.error("Unable to get PayU payment configuration.");

		}

	}

	public PayuPayPojo getPayuParams(long paymentId) throws Exception{

		PaymentClient paymentServiceClient = new PaymentClient();

		Payment payment = paymentServiceClient.getClient().getPayment(paymentId);

		long txnId = payment.getMerchantTxnId();

		TransactionClient transactionServiceClient = new TransactionClient();

		in.shop2020.model.v1.order.TransactionService.Client txnClient = transactionServiceClient.getClient();

		Transaction transaction = txnClient.getTransaction(txnId);

		Order order = transaction.getOrders().get(0);

		String paymentOption = getPaymentOption(payment);

		PayuPayPojo ppp = new PayuPayPojo();

		ppp.setKey(accountId);

		ppp.setAmount(payment.getAmount() + "");

		ppp.setEmail(order.getCustomer_email());

		ppp.setPhone(order.getCustomer_mobilenumber());

		ppp.setAddress1(order.getCustomer_address1());

		ppp.setAddress2(order.getCustomer_address2());

		ppp.setCity(order.getCustomer_city());

		ppp.setState(order.getCustomer_state());

		ppp.setProductinfo(getDescription(order));

		ppp.setZipcode(order.getCustomer_pincode());

		ppp.setPg(PaymentUtils.getPayugatewayCode(paymentOption));

		ppp.setBankcode(PaymentUtils.getPayubankCode(paymentOption));

		ppp.setFurl(returnUrl);

		ppp.setSurl(returnUrl);

		ppp.setCurl(cancelUrl);

		String[] name = order.getCustomer_name().split(" ");

		ppp.setFirstname(name[0]);

		if(name.length==2){

			ppp.setLastname(name[1]);

		}

		ppp.setTxnid(Long.toHexString(txnId));

		ppp.setCountry("India");

		ppp.setPostActionUrl(postActionUrl);

		ppp.setHash(getSecureHash(paymentId, ppp));

		return ppp;

	}

	/**

	 * This method is used for Recharge payments. It is being called by RechargePaymentController.

	 * @return

	 */

	private String getDescription (Order order){

		StringBuilder descriptionBuilder = new StringBuilder(255);

		for(LineItem line: order.getLineitems()){

			if(line.getBrand() != null){

				descriptionBuilder.append(line.getBrand() + " ");

			}

			if(line.getModel_name() != null){

				descriptionBuilder.append(line.getModel_name() + " "); 

			}

			if(line.getModel_number() != null){

				descriptionBuilder.append(line.getModel_number() + " ");

			}

			if(line.getColor() != null){

				descriptionBuilder.append(line.getColor() + " ");

			}

		}

		String desc = descriptionBuilder.toString();

		desc.replaceAll("[^a-zA-Z0-9\\s\\-\\@\\/\\.]", "");

		descriptionBuilder = new StringBuilder(desc);

		if(descriptionBuilder.length() >= 255)

			return descriptionBuilder.substring(0, 255).trim();

		else

			return descriptionBuilder.toString().trim();

	}

	public String getAccountId() {

		return accountId;

	}

	public static String getReturnUrl() {

		return returnUrl;

	}

	private String getPaymentOption(Payment payment) {

		String paymentType = null;

		String paymentOpt = null;

		List<Attribute> attributes = payment.getAttributes();

		if(attributes == null)

			return "";

		for(Attribute attr : attributes){

			if(attr.getName().equals(IPaymentService.PAYMENT_METHOD))

				paymentOpt = attr.getValue();

			if(attr.getName().equals(IPaymentService.PAYMENT_TYPE))

				paymentType = attr.getValue();

		}

		return paymentType+paymentOpt;

	}

	private String getSecureHash(long paymentId, PayuPayPojo ppp) throws NoSuchAlgorithmException{

		String pass = accountId + "|" + paymentId + "|" + ppp.getAmount()  + "|" + ppp.getProductinfo() + "|" +  ppp.getFirstname() + "|" + ppp.getEmail() + "|||||||||||" + salt;

		log.info("Secure hash-->accountId|paymentId|ppp.getAmount()|ppp.getProductinfo()|ppp.getFirstname()|ppp.getEmail()|||||||||||salt");

		log.info("Pass-->" + pass);

		MessageDigest md = MessageDigest.getInstance("SHA-512");

		md.update(pass.getBytes(), 0, pass.getBytes().length);

		byte[] mdbytes = md.digest();

		//	convert the byte to hex format method

		StringBuffer sb = new StringBuffer();

		for (int i = 0; i < mdbytes.length; i++) {

			sb.append(Integer.toString((mdbytes[i] & 0xff) + 0x100, 16).substring(1));

		}

		return sb.toString();

	}

	public void setPhone(String phone) {

		this.phone = phone;

	}

	public String getPhone() {

		return phone;

	}

    public void setResultJson(String resultJson) {

		this.resultJson = resultJson;

	}

	public String getResultJson() {

		log.info(resultJson);

		return resultJson;

	}

	public static class ContactDetails{

		private String name;

		private String email;

		private String address;

		private String city;

		private String state;

		private String postalCode;

		private String country;

		private String phone;

		public ContactDetails(String name, String email, String address,

				String city, String state, String postalCode, String country,

				String phone) {

			this.name = name;

			this.email = email;

			this.address = address;

			this.city = city;

			this.state = state;

			this.postalCode = postalCode;

			this.country = country;

			this.phone = phone;

		}

		@Override

		public String toString() {

			return "ContactDetails [name=" + name + ", email=" + email

					+ ", address=" + address + ", city=" + city + ", state="

					+ state + ", postalCode=" + postalCode + ", country="

					+ country + ", phone=" + phone + "]";

		}

		public String getName() {

			return name;

		}

		public String getEmail() {

			return email;

		}

		public String getAddress() {

			return address;

		}

		public String getCity() {

			return city;

		}

		public String getState() {

			return state;

		}

		public String getPostalCode() {

			return postalCode;

		}

		public String getCountry() {

			return country;

		}

		public String getPhone() {

			return phone;

		}

	}

}