WebSVN – SmartDukaan – Diff – /RechargeDashboard/src/main/java/in/shop2020/recharge/controllers/ConfirmController.java

 import in.shop2020.model.v1.order.FRC;
 import in.shop2020.model.v1.order.RechargePlan;
 import in.shop2020.model.v1.order.RechargeTransaction;
 import in.shop2020.model.v1.order.RechargeType;
+import in.shop2020.model.v1.order.TelecomCircle;
 import in.shop2020.thrift.clients.TransactionClient;
 import java.math.BigInteger;
 import java.util.ArrayList;
 import java.util.List;
 import org.apache.log4j.Logger;
 import org.apache.struts2.convention.annotation.Result;
 import org.apache.struts2.convention.annotation.Results;
 @Results({
-    @Result(name="recharge-redirect", type="redirectAction", params = {"actionName" , "/", "errorMsg", "${errorMessage}"}),
+    @Result(name="recharge-redirect", type="redirectAction", params = {"actionName" , "home", "errorMsg", "${errorMessage}"}),
     @Result(name="recharge-result", type="redirectAction", params = {"actionName" , "recharge-result", "rechargeId", "${rechargeOrderId}"})
 })
 public class ConfirmController extends BaseController{
     private String cafNum = "";
     private String simNum = "";
     private String altNum = "";
     private String name = "";
     private String plan = "";
-    private String circleId = "";
     private String discount = "";
+    private String circlecode = "";
     private String message = "";
     private String errorMessage = "";
     private String totalAmount = "";
     private String couponCode = "";
     private static final BigInteger key = new BigInteger("0333910847013829827302347601486730417451");
     private static final Random random = new Random();
     private static final int LENGTH = 10;
     private static final String HEADER_X_FORWARDED_FOR = "X-FORWARDED-FOR";
+    private static final String DISHTV = "DISH TV";
     private static Logger log = Logger.getLogger(Class.class);
     public String index() {
         return "index";
+    }
     public String create() {
+        try {
+            String loginStatus = (String) request.getSession().getAttribute("LOGGED_IN");
+            if(loginStatus == null || !loginStatus.equals("TRUE")){
+                return "authfail";
+            }
+            String result = validateFields();
+            if(!result.equals("SUCCESS")) {
+                errorMessage = result;
+                return "recharge-redirect";
+            }
+            TransactionClient tcl = new TransactionClient();
+            boolean discountRemove = true;
+            Long circleId = 0l;
+            if(circlecode != null && !circlecode.equals("")) {
+                TransactionClient tcl1 = new TransactionClient();
+                TelecomCircle circle = tcl1.getClient().getTelecomCircle(-1, circlecode);
+                if(circle != null) {
+                    circleId = circle.getId();
+                }
+            }
+            if(rechargeType.equals("2")) {
+                for (FRC frc : tcl.getClient().getFRCs(circleId, Long.parseLong(mobileOperator))) {
+                    if(frc.getDenomination() == Long.parseLong(amount)) {
+                        if(frc.getMaxDiscount() < Long.parseLong(discount)) {
+                            errorMessage = "MaxDiscount : " + frc.getMaxDiscount() + " is less than discount amount entered";
+                            log.warn("MaxDiscount : " + frc.getMaxDiscount() + " is less than discount amount entered");
+                            return "recharge-redirect";
+                        } else {
+                            discountRemove = false;
+                        }
+                    }
+                }
+                if(discountRemove) {
+                    setDiscount("0");
+                }
+            }
+        } catch (Exception e) {
+            log.warn("Unable to get frc for operatorId : " + mobileOperator, e);
+        }
         return index();
+    }
     public String createRecharge(){
         try {
+            String loginStatus = (String) request.getSession().getAttribute("LOGGED_IN");
+            if(loginStatus == null || !loginStatus.equals("TRUE")){
-            //TODO REmove this
+                return "authfail";
+            }
+            String result = validateFields();
+            if(!result.equals("SUCCESS")) {
-            setStoreId("1");
+                errorMessage = result;
-            setCircleId("5");
+                return "recharge-redirect";
-            //
+            }
             TransactionClient tc = new TransactionClient();
             List<RechargePlan> plans = tc.getClient().getPlansForOperator(Long.parseLong(mobileOperator));
             List<String> planNameList = new ArrayList<String>();
             if (plans == null || plans.isEmpty()) {
                 setPlan("");
                     return "recharge-redirect";
+                }
+            }
             RechargeTransaction rechargeOrder = new RechargeTransaction();
             rechargeOrder.setAmount(Long.parseLong(amount));
             rechargeOrder.setEmail(email);
             rechargeOrder.setDeviceNum(number.trim());
             rechargeOrder.setPlan(plan);
+            rechargeOrder.setAlternateNumber(altNum);
+            rechargeOrder.setStoreId(Long.parseLong((String) request.getSession().getAttribute("STORE_ID")));
+            rechargeOrder.setIpAddress(remoteAddr(request));
+            rechargeOrder.setDeviceType(RechargeType.findByValue((int) Long.parseLong(deviceType)));
+            rechargeOrder.setName(name);
+            rechargeOrder.setIsFrc(Long.parseLong(rechargeType) == 1 ? false : true);
+            rechargeOrder.setCafNum(cafNum);
+            rechargeOrder.setSimNum(simNum);
             if(deviceType.equals("1")) {
                 rechargeOrder.setOperatorId(Long.parseLong(mobileOperator));
             } else if (deviceType.equals("2")) {
                 rechargeOrder.setOperatorId(Long.parseLong(dthOperator));
+            }
-            rechargeOrder.setIsFrc(Long.parseLong(rechargeType) == 1 ? false : true);
+            rechargeOrder.setPaymentAmount(Long.parseLong(amount) - Long.parseLong(discount));
+            Long circleId = 0l;
+            if(circlecode != null && !circlecode.equals("")) {
+                TransactionClient tcl1 = new TransactionClient();
+                TelecomCircle circle = tcl1.getClient().getTelecomCircle(-1, circlecode);
+                if(circle != null) {
+                    circleId = circle.getId();
+                    if(rechargeOrder.isIsFrc()) {
+                        Long storeCircle = (Long.parseLong((String) request.getSession().getAttribute("CIRCLE_ID")));
+                        if(storeCircle == circle.getId()) {
+                            rechargeOrder.setCircleId(storeCircle);
+                        } else {
+                            errorMessage = "FRC is not possible because this number is of : "  + circle.getName() + " circle.";
+                            log.warn("FRC is not possible because this number is of : "  + circle.getName() + " circle & storeCircle : " + storeCircle);
+                            return "recharge-redirect";
+                        }
+                    } else {
-            rechargeOrder.setCafNum(cafNum);
+                        rechargeOrder.setCircleId(circle.getId());
+                    }
+                } else {
-            rechargeOrder.setSimNum(simNum);
+                    rechargeOrder.setCircleId(0);
+                }
+            }
             rechargeOrder.setDiscount(0);
             TransactionClient tcl = new TransactionClient();
             if(rechargeOrder.isIsFrc()) {
-                for (FRC frc : tcl.getClient().getFRCs(Long.parseLong(circleId), rechargeOrder.getOperatorId())) {
+                for (FRC frc : tcl.getClient().getFRCs(circleId, rechargeOrder.getOperatorId())) {
                     if(frc.getDenomination() == rechargeOrder.getAmount()) {
                         if(frc.getMaxDiscount() < Long.parseLong(discount)) {
                             errorMessage = "MaxDiscount : " + frc.getMaxDiscount() + " is less than discount amount entered";
                             log.warn("MaxDiscount : " + frc.getMaxDiscount() + " is less than discount amount entered");
                             return "recharge-redirect";
                         } else {
                             rechargeOrder.setDiscount(Double.parseDouble(discount));
-                            break;
+                        }
+                    }
+                }
+            }
-            rechargeOrder.setAlternateNumber(altNum);
-            /**
-             *  WHAT TODO ABOUT THIS???
-             */
-            rechargeOrder.setStoreId(Long.parseLong(storeId));
-            /****************************************************
-             *  TODO        *
-             * rechargeORder.setCircleId(circle);               *
-             *          *
-             ****************************************************/
-            rechargeOrder.setIpAddress(remoteAddr(request));
             TransactionClient tc1 = new TransactionClient();
             rechargeOrder = tc1.getClient().createRechargeTransaction(rechargeOrder);
             setRechargeOrderId(rechargeOrder.getId());
         } catch (Exception e) {
         if(rechargeType == null || rechargeType == "") {
             log.warn("rechargeType received is empty or null");
             return "Oops! There seems to be a problem. Please try after some time";
+        }
-        if(email == null || email == "") {
+        if(deviceType == null || rechargeType == "") {
-            log.warn("Email received is empty or null");
+            log.warn("rechargeType received is empty or null");
-            return "Email address cannot be empty";
-        }
-        try {
-            InternetAddress emailAdd = new InternetAddress(email);
+            return "Oops! There seems to be a problem. Please try after some time";
-            emailAdd.validate();
-        } catch (AddressException e1) {
-            log.warn("Invalid email address : " + email, e1);
-            return "ERROR : Invalid email address.";
+        }
-        if (RechargeType.findByValue(Integer.parseInt(this.rechargeType)) == RechargeType.DTH) {
+        if (RechargeType.findByValue(Integer.parseInt(this.deviceType)) == RechargeType.DTH) {
             if (Long.parseLong(totalAmount) < 250 || Long.parseLong(totalAmount) > 2000) {
-//                if(operator.equals("1")) {
+                if(rechargeType.equals("2") && getOperatorName().equals(DISHTV)) {
-//                    return "DishTv recharge amount should be between Rs.250 and Rs.2000";
+                    return "DishTv recharge amount should be between Rs.250 and Rs.2000";
-//                }
+                }
                 if (!(Long.parseLong(totalAmount) >= 200 && Long.parseLong(totalAmount) < 250)) {
                     return "DTH recharge amount should be between Rs.200 and Rs.2000";
+                }
+            }
-        } else if (RechargeType.findByValue(Integer.parseInt(this.rechargeType)) == RechargeType.MOBILE) {
+        } else if (RechargeType.findByValue(Integer.parseInt(this.deviceType)) == RechargeType.MOBILE) {
-            if (Long.parseLong(totalAmount) < 10 || Long.parseLong(totalAmount) > 1000) {
+            if (Long.parseLong(amount) < 10 || Long.parseLong(amount) > 1000) {
                 return "Recharge amount should be between Rs.10 and Rs.1000";
+            }
             if (number.length() != 10) {
                 return "Number should be of 10 digits";
+            }
         } else {
-            log.warn("Invalid rechargeType : " + rechargeType);
+            log.warn("Invalid rechargeType : " + deviceType);
+            return "Oops! There seems to be a problem. Please try after some time";
+        }
+        if (mobileOperator == null || mobileOperator == "") {
+            log.warn("Invalid operator : " + mobileOperator);
+            return "Oops! There seems to be a problem. Please try after some time";
+        }
+        if (dthOperator == null || dthOperator == "") {
+            log.warn("Invalid operator : " + dthOperator);
             return "Oops! There seems to be a problem. Please try after some time";
+        }
-//        if (operator == null || operator == "") {
-//            log.warn("Invalid operator : " + operator);
-//            return "Oops! There seems to be a problem. Please try after some time";
-//        }
         return "SUCCESS";
+    }
     public String getAmount() {
         return amount;
     public String getDiscount() {
         return discount;
+    }
-    public void setCircleId(String circleId) {
+    public void setCirclecode(String circlecode) {
-        this.circleId = circleId;
+        this.circlecode = circlecode;
+    }
-    public String getCircleId() {
+    public String getCirclecode() {
-        return circleId;
+        return circlecode;
+    }
+}

Subversion Repositories SmartDukaan

(root)/RechargeDashboard/src/main/java/in/shop2020/recharge/controllers/ConfirmController.java – Rev 7080 → 7096