Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

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 java.util.ArrayList;

import java.util.List;

import java.util.Map;

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}"}),

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

})

public class ConfirmController extends BaseController{

    /**

     * 

     */

    private static final long serialVersionUID = 1L;

    private long rechargeOrderId = 0;

    private String amount = "";

    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 long userId;

    private String message = "";

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

    public String index() {

        return "index";

    }

    public String create() {

        if(userinfo.isLoggedIn()) {

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

            } else {

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

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

            }

            } catch (Exception e) {

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

            }

        }

        return index();

    }

    public String createRecharge(){

        if(userinfo.isLoggedIn()) {

            setUserId(userinfo.getUserId());

        }

        try {

            RechargeOrder rechargeOrder = new RechargeOrder();

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

            rechargeOrder.setUserEmailId(email);

            rechargeOrder.setUserId(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(walletAmount);

            TransactionClient tc = new TransactionClient();

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

        }

    }

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

        return userId;

    }

    public void setUserId(long l) {

        this.userId = l;

    }

    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;

    }

}