Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.utils.DataLogger;

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.RechargeType;

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

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

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

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

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

import in.shop2020.serving.interceptors.TrackingInterceptor;

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.HelperServiceException;

import in.shop2020.utils.Mail;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.Random;

import javax.servlet.http.Cookie;

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;

@SuppressWarnings({ "serial", "serial" })

@Results({

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

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

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

})

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 totalAmount = "";

    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() {

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

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

    				rechargeType.toString(), number, operator);

    		return "recharge-redirect";

    	}

        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)

            {

                return "recharge-redirect";

            } else {

                setUserId("" + tempUserId);

            }

        }

        return index();

    }

    public String getProvider(){

    	TransactionClient tcl;

    	try {

    		tcl = new TransactionClient();

    		return tcl.getClient().getServiceProviderForDevice(RechargeType.findByValue(Integer.parseInt(this.rechargeType)), number) + "";

    	} catch (Exception e) {

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

    	}

    	return 0 + "";

    }

    private void setTotalAmount(String amount2) {

        this.totalAmount  = amount2;

    }

    public String createRecharge(){

        try {

            TransactionClient tc = new TransactionClient();

            RechargeOrder rechargeOrder = new RechargeOrder();

            rechargeOrder.setTotalAmount(Long.parseLong(amount) + Long.parseLong(getWalletAmountUsed()));

            rechargeOrder.setUserEmailId(email);

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

            rechargeOrder.setDeviceNumber(number);

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

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

            setRechargeOrderId(rechargeOrder.getId());

        } catch (TransactionServiceException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (TException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

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

            return "create-recharge-redirect";

        } else {

            return "recharge-pay-options-redirect";

        }

    }

    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("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 temp() {

        try {

            UserClient ucl = new UserClient();

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

            if(user == null) {

                user = new User();

                String password = null;

                boolean isValid = true;

                /**

                 * TODO : Generate password

                 * password = this.request.getParameter("txtPassword");

                 * 

                 */

                if(!Utils.isValidEmail(email))  {

                    addActionError("Please enter valid email address.");

                    isValid = false;

                }

                user.setEmail(email);

                String encryptedPassword = desEncrypter.encrypt(password);

                user.setPassword(encryptedPassword);

                user.setCommunicationEmail(email);

                Cookie sourceCookie = (Cookie) cookiesMap.get(TrackingInterceptor.SRC_COOKIE);

                if (sourceCookie != null) {

                    DesEncrypter des = new DesEncrypter(TrackingInterceptor.ENCRIPTION_STRING);

                    String sourceCookieVal = des.decrypt(sourceCookie.getValue());

                    user.setSource(sourceCookieVal);

                }

                Cookie sourceTimeCookie = (Cookie) cookiesMap.get(TrackingInterceptor.SRC_TIME_COOKIE);

                long sourceTime = 0;

                if (sourceTimeCookie != null) {

                    try {

                        sourceTime = Long.parseLong(sourceTimeCookie.getValue());

                    }

                    catch (Exception e) {

                        log.warn("Unable to parse session src time cookie.");

                    }

                    user.setSourceStartTime(sourceTime);

                }

                user.setSex(Sex.WONT_SAY);

                UserClient userContextServiceClient;

                userContextServiceClient = new UserClient();

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

                user = userClient.createUser(user);

                HelperClient hc = new HelperClient();

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

                mailingList.add(email);

                hc.getClient().saveUserEmailForSending(mailingList, "help@saholic.com", "Login Details", "/*body*/", "/*source*/", "/*emailType*/", null, null);

            }

            //setUserId("" + user.getUserId());

            /*****************************

             * 

             * TODO : Handle Wallets

             * 

             */

            //TransactionClient tc = new TransactionClient();

            //setCoupons(tc.getClient().getRechargeCoupons(user.getUserId(), RechargeCouponStatus.ACTIVE));

        } catch (TTransportException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (UserContextException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (TException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (HelperServiceException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        return index();

    }

    public String getOperatorName() {

        try {

        TransactionClient tc = new TransactionClient();

        Map<Long, String> providers = tc.getClient().getServiceProviders(RechargeType.findByValue(Integer.parseInt(rechargeType)));

        return providers.get(Long.parseLong(operator));

        } catch(Exception e) {

        log.error("Unable to get operator name");

        }

        return "N/A";

    }

    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 String getWalletAmountUsed() {

        return walletAmountUsed;

    }

    public void setWalletAmountUsed(String walletAmountUsed) {

        this.walletAmountUsed = walletAmountUsed;

    }

}