Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.datalogger.EventType;

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

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

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

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

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

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

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

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

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

import in.shop2020.serving.utils.DesEncrypter;

import in.shop2020.serving.utils.Utils;

import in.shop2020.thrift.clients.HelperClient;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.thrift.clients.UserClient;

import in.shop2020.utils.DataLogger;

import in.shop2020.utils.Mail;

import java.util.ArrayList;

import java.util.List;

import java.util.Random;

import nl.captcha.Captcha;

import org.apache.log4j.Logger;

import org.apache.struts2.convention.annotation.Result;

import org.apache.struts2.convention.annotation.Results;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

@Results({

    @Result(name="recharge-pay-options-redirect", type="redirectAction", params = {"actionName" , "recharge-pay-options", "rechargeOrderId", "${rechargeOrderId}"}),

    @Result(name="create-recharge-redirect", type="redirectAction", params = {"actionName" , "wallet-only-payment", "rechargeOrderId", "${rechargeOrderId}"}),

    @Result(name="recharge-redirect", type="redirectAction", params = {"actionName" , "recharge", "error", "${errorMessage}"})

})

public class ConfirmController extends BaseController{

    /**

     * 

     */

    private static final long serialVersionUID = 1L;

    private long rechargeOrderId = 0;

    private String amount = "";

    private String walletAmountUsed = "0";

    private String operator = "";

    private String number = "";

    private String email = "";

    private String rechargeType = "";

    private DesEncrypter desEncrypter = new DesEncrypter("saholic");

    private List<String> couponIds = null;

    private List<RechargeCoupon> coupons = null;

    private String userId;

    private String message = "";

    private String errorMessage = "";

    private String totalAmount = "";

    private String plan = "";

    private String circleCode;

    private static final String chars = "abcdefghijklmonpqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";

    private static final Random random = new Random();

    private static final int LENGTH = 10;

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

    public String index() {

        return "index";

    }

    public String create() {

    	errorMessage = validateRecharge();

    	if(!errorMessage.equals("SUCCESS")){

    		DataLogger.logData(EventType.PROVIDER_FETCH_FAILURE, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),

    				rechargeType.toString(), number, operator);

    		return "recharge-redirect";

    	}

    	setErrorMessage("");

        setTotalAmount(amount);

        if(userinfo.isLoggedIn()) {

            setUserId("" + userinfo.getUserId());

            try {

            TransactionClient tc = new TransactionClient();

            UserWallet wallet = tc.getClient().getUserWallet(userinfo.getUserId());

            long amountA = 0;

            if(wallet.getAmount() == 0){

                setMessage("Your RechargeWallet is empty.");

            } else if ((amountA = wallet.getAmount() - Long.parseLong(amount)) >= 0) {

                setAmount("0");

                setMessage("You now have Rs. " + amountA + " left in your RechargeWallet.");

                setWalletAmountUsed("" + (wallet.getAmount() - amountA));

            } else {

                setAmount("" + (0-amountA));

                setMessage("You have used all the amount in your RechargeWallet.");

                setWalletAmountUsed(("" + wallet.getAmount()));

            }

            } catch (Exception e) {

                log.error("Unable to get user wallet", e);

            }

        } else {

            long tempUserId = createUserAndSendMail(email);

            if(tempUserId == -1)

            {

            	errorMessage = "Oops! There seems to be a problem. Please try after some time";

                return "recharge-redirect";

            } else {

                setUserId("" + tempUserId);

            }

        }

        return index();

    }

    public String validateRecharge(){

    	TransactionClient tcl;

    	try {

    		tcl = new TransactionClient();

    		return tcl.getClient().validateRecharge(RechargeType.findByValue(Integer.parseInt(this.rechargeType)), number, Long.parseLong(operator));

    	} catch (Exception e) {

    		log.error("Unable to get service provider for Device number " + number + " and rechargeType : " +  rechargeType, e);

    	}

    	return "Oops! There seems to be a problem. Please try after some time";

    }

    public boolean shouldPromptForWallet(){

        if(!isLoggedIn()) {

            try {

                TransactionClient tc = new TransactionClient();

                UserWallet wallet = tc.getClient().getUserWallet(Long.parseLong(userId));

                if(wallet.getAmount() != 0) {

                    return true;

                }

            } catch (Exception e) {

                log.error("Unable to get wallet for userId : " + userId, e);

            }

        }

        return false;

    }

    public String createRecharge(){

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

            if (!verifyCaptcha()) {

                setErrorMessage("Invalid captcha. Try Again.");

                log.info("Invalid captcha error msg has been added");

                return index();

            }

        }

        try {

            TransactionClient tc = new TransactionClient();

            List<RechargePlan> plans = tc.getClient().getPlansForOperator(Long.parseLong(operator));

            List<String> planNameList = new ArrayList<String>();

            if (plans == null || plans.isEmpty()) {

                setPlan("");

            } else {

                for (RechargePlan tempPlan : plans) {

                    planNameList.add(tempPlan.getName());

                }

                if (!planNameList.contains(plan)) {

                    errorMessage = "Oops! There seems to be a problem. Please try after some time";

                    log.warn("OperatorId : " + operator + " and plan : " + plan + " do not match");

                    return "recharge-redirect";

                }

            }

            RechargeOrder rechargeOrder = new RechargeOrder();

            rechargeOrder.setTotalAmount(Long.parseLong(totalAmount));

            rechargeOrder.setUserEmailId(email);

            rechargeOrder.setUserId(Long.parseLong(userId));

            rechargeOrder.setDeviceNumber(number);

            rechargeOrder.setPlan(plan);

            rechargeOrder.setOperatorId(Long.parseLong(operator));

            rechargeOrder.setRechargeType(RechargeType.findByValue(Integer.parseInt(rechargeType)));

            rechargeOrder.setStatus(RechargeOrderStatus.PAYMENT_PENDING);

            rechargeOrder.setOrderType(OrderType.B2C);

            rechargeOrder.setWalletAmount(Long.parseLong(getWalletAmountUsed()));

            TransactionClient tc1 = new TransactionClient();

            rechargeOrder = tc1.getClient().createRechargeOrder(rechargeOrder);

            setRechargeOrderId(rechargeOrder.getId());

        } catch (Exception e) {

            log.error("Unable to create recharge order", e);

            errorMessage = "Oops! There seems to be a problem. Please try after some time";

            return "recharge-redirect";

        }

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

            return "create-recharge-redirect";

        } else {

            return "recharge-pay-options-redirect";

        }

    }

    private boolean verifyCaptcha() {

        String cookieCaptchaAnswer = getCookie(Captcha.NAME, true, "saholic");

        String captchaReceived = (String) request.getParameter("captcha_response_field");

        if (captchaReceived.equalsIgnoreCase(cookieCaptchaAnswer)) {

            try {

                DataLogger.logData(EventType.CAPTCHA_SUCCESS, getSessionId(), userinfo.getUserId(), userinfo.getEmail());

            } catch (Exception e1) {

                log.warn("Unable to log orders through the datalogger", e1);

            }

            return true;

        } 

        else {

            try {

                DataLogger.logData(EventType.CAPTCHA_FAILED, getSessionId(), userinfo.getUserId(), userinfo.getEmail());

            } catch (Exception e1) {

                log.warn("Unable to log orders through the datalogger", e1);

            }

            return false;

        }

    }

    private static String generateNewPassword() {

        char[] buf = new char[LENGTH];

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

            buf[i] = chars.charAt(random.nextInt(chars.length()));

        }

        return new String(buf);

    }

    private long createUserAndSendMail(String email) {

        User user = null;

        String password = null;

        try{

        UserClient ucl = new UserClient();

        user = ucl.getClient().getUserByEmail(email);

        if(user.getUserId() == -1) {

            user.setEmail(email);

            password = generateNewPassword();

            String encryptedPassword = desEncrypter.encrypt(password);

            user.setPassword(encryptedPassword);

            user.setCommunicationEmail(email);

            UserClient userContextServiceClient = new UserClient();

            in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

            user = userClient.createUser(user);

            List<String> toList = new ArrayList<String>();

            toList.add(email);

            HelperClient helperServiceClient = null;

                helperServiceClient = new HelperClient();

                in.shop2020.utils.HelperService.Client client = helperServiceClient.getClient();

                Mail mail = new Mail();

                mail.setSubject("Saholic Registration successful");

                mail.setTo(toList);

                mail.setData("Your have successfully registered with Saholic.com. Your user name is: " + email + " and your password is: " +  password);

                client.sendMail(mail);

            }

        }catch (UserContextException ux){

            return -1;               

        } catch (TTransportException e) {

            return -1;

        } catch (TException e) {

            return -1;

        } catch (Exception e) {

            log.error("Unexpected error while mailing the new password");

            return -1;

        }

        return user.getUserId();

    }

    public String getOperatorName() {

    	String operatorName = null;

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

    		operatorName = Utils.getMobileProvidersMap().get(Long.parseLong(operator));	

    	}

    	if(rechargeType.equals("2")){

    		operatorName = Utils.getDthProvidersMap().get(Long.parseLong(operator));	

    	}

    	if(operatorName == null){

    		operatorName = "N/A";	

    	}

    	return operatorName;

    }

    public String getAmount() {

        return amount;

    }

    public void setAmount(String amount) {

        this.amount = amount;

    }

    public void setDthamount(String amount) {

    	this.amount = amount;

    }

    public String getOperator() {

        return operator;

    }

    public void setOperator(String operator) {

        this.operator = operator;

    }

    public String getNumber() {

        return number;

    }

    public void setNumber(String number) {

        this.number = number;

    }

    public void setDthnumber(String dthnumber) {

    	this.number = dthnumber;

    }

    public String getEmail() {

        return email;

    }

    public void setEmail(String email) {

        this.email = email;

    }

    public void setCouponIds(List<String> couponIds) {

        this.couponIds = couponIds;

    }

    public List<String> getCouponIds() {

        return couponIds;

    }

    public void setCoupons(List<RechargeCoupon> coupons) {

        this.coupons = coupons;

    }

    public List<RechargeCoupon> getCoupons() {

        return coupons;

    }

    public String getRechargeType() {

        return rechargeType;

    }

    public void setRechargeType(String rechargeType) {

        this.rechargeType = rechargeType;

    }

    public String getUserId() {

        return userId;

    }

    public void setUserId(String userId) {

        this.userId = userId;

    }

    public boolean isLoggedIn() {

        return userinfo.isLoggedIn();

    }

    public void setMessage(String message) {

        this.message = message;

    }

    public String getMessage() {

        return message;

    }

    public long getRechargeOrderId() {

        return rechargeOrderId;

    }

    public void setRechargeOrderId(long l) {

        this.rechargeOrderId = l;

    }

    public String getTotalAmount() {

        return totalAmount;

    }

    public void setTotalAmount(String amount) {

        this.totalAmount  = amount;

    }

    public String getWalletAmountUsed() {

        return walletAmountUsed;

    }

    public void setWalletAmountUsed(String walletAmountUsed) {

        this.walletAmountUsed = walletAmountUsed;

    }

    public String getPlan() {

        return plan;

    }

    public void setPlan(String plan) {

        this.plan = plan;

    }

    public String getErrorMessage() {

        return errorMessage;

    }

    public void setErrorMessage(String errorMessage) {

        this.errorMessage = errorMessage;

    }

    public String getCircleCode() {

        return circleCode;

    }

    public void setCircleCode(String circleCode) {

        this.circleCode = circleCode;

    }

}