Subversion Repositories SmartDukaan

package in.shop2020.support.services;

import in.shop2020.model.v1.user.PromotionService.Client;

import in.shop2020.model.v1.user.Voucher;

import in.shop2020.model.v1.user.VoucherType;

import in.shop2020.thrift.clients.PromotionClient;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.net.URL;

import java.net.URLConnection;

import java.util.Date;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class SpiceDeckRechargeService {

	private static Logger logger = LoggerFactory.getLogger(SpiceDeckRechargeService.class);

	private static final String voucherGenerationUrl = "http://www.spicedeck.com/mcommerce/couponregister.sdesk";

	private static final String voucherActivationUrl = "http://www.spicedeck.com/mcommerce/couponassign.sdesk";

	public static void storeVoucher(String username, String password, long amount) throws Exception{

		String coupon = generateVoucher(username, password, amount);

		Voucher voucher = new Voucher();

		voucher.setVoucherType(VoucherType.MOBILE);

		voucher.setAmount(amount);

		voucher.setVoucherCode(coupon);

		voucher.setIssuedOn(new Date().getTime());

		Client pc = new PromotionClient().getClient();

		pc.addVoucher(voucher);

	}

	public static void issueVoucher(String username, String password, long userId, String userEmail, long amount) throws Exception{

		Client pc = new PromotionClient().getClient();

		Voucher voucher = pc.assignVoucher(userId, userEmail, VoucherType.MOBILE, amount);

		boolean isActivated = activateVoucher(username, password, voucher.getVoucherCode(), voucher.getUserEmail());

		if(!isActivated){

			throw new Exception("Voucher could not get activated.");

		}

	}

	public static String generateVoucher(String username, String password, long amount) throws Exception{

		String params = "userid=" + username + "&password=" + password + "&amount=" + amount;

		String returnValue = sendGetRequest(voucherGenerationUrl, params);

		if("-1".equals(returnValue)){

			throw new Exception("Credit balance low.");

		}else if("0".equals(returnValue)){

			throw new Exception("Network or some other failure.");

		}

		return returnValue;

	}

	public static boolean activateVoucher(String username, String password, String voucherCode, String userEmail) throws Exception{

		String params = "userid=" + username + "&password=" + password + "&cid=" + voucherCode + "&email=" + userEmail; 

		String returnValue = sendGetRequest(voucherActivationUrl, params);

		if("1".equals(returnValue)){

			return true;

		}else if("-1".equals(returnValue)){

			throw new Exception("Invalid voucher.");

		}else if("0".equals(returnValue)){

			throw new Exception("Network or some other failure.");

		}

		return false;

	}

	private static String sendGetRequest(String endpoint, String requestParameters)

	{

		String result = null;

		try

		{

			String urlStr = endpoint;

			if (requestParameters != null && requestParameters.length () > 0){

				urlStr += "?" + requestParameters;

			}

			URL url = new URL(urlStr);

			URLConnection conn = url.openConnection ();

			// Get the response

			BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));

			StringBuffer sb = new StringBuffer();

			String line;

			while ((line = rd.readLine()) != null)

			{

				sb.append(line);

			}

			rd.close();

			result = sb.toString();

		} catch (Exception e){

			e.printStackTrace();

	    	logger.error("Not able to get data from server");

		}

		return result;

	}

	public static void main(String args[]) throws Exception{

		//System.out.println(SpiceDeckRechargeService.generateVoucher("sachingyal", "abc1234", 1));

		//System.out.println(SpiceDeckRechargeService.activateVoucher("sachingyal", "abc1234", "SHL1340274524944", "rajveer.singh@saholic.com"));

		//storeVoucher("sachingyal", "abc1234", 5);

		issueVoucher("sachingyal", "abc1234", 191919, "anupam.singh@shop2020.in", 5);

	}

}