WebSVN – SmartDukaan – Diff – //trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/service/OtpProcessor.java

-package com.spice.profitmandi.web.processor;
+package com.spice.profitmandi.dao.service;
-import java.time.LocalDateTime;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
+import com.spice.profitmandi.common.web.client.RestClient;
+import com.spice.profitmandi.dao.entity.dtr.Otp;
+import com.spice.profitmandi.dao.entity.onBoarding.LoiForm;
+import com.spice.profitmandi.dao.enumuration.dtr.OtpType;
+import com.spice.profitmandi.dao.repository.dtr.OtpRepository;
+import com.spice.profitmandi.dao.repository.user.LoiFormRepository;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
-import com.fasterxml.jackson.annotation.JsonProperty;
+import java.time.LocalDateTime;
-import com.google.common.collect.ImmutableMap;
+import java.util.HashMap;
-import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.web.client.RestClient;
-import com.spice.profitmandi.dao.entity.dtr.Otp;
+import java.util.List;
-import com.spice.profitmandi.dao.enumuration.dtr.OtpType;
+import java.util.Map;
-import com.spice.profitmandi.dao.repository.dtr.OtpRepository;
-import com.spice.profitmandi.service.scheme.SchemeServiceImpl;
-import com.spice.profitmandi.web.res.OTPResponse;
+import java.util.Random;
 @Component
 public class OtpProcessor {
+    public static final String SELF_CANCELLED_TEMPLATE = "Order Cancelled PO%s: Dear Customer, your order with SmartDukaan of %s has been cancelled on %s as per your request. Team SmartDukaan";
+    public static final String SELF_CANCELLED_TEMPLATE_ID = "1507161943392646481";
+    public static final String TEMPLATE_ORDER_CREATED = "Order Placed PO%d: Dear Customer, your order with SmartDukaan of %s worth Rs.%.0f has been placed successfully. Our team will get in touch with you soon. Team SmartDukaan";
+    public static final String TEMPLATE_ORDER_CREATED_ID = "1507162021138742118";
+    public static final String LOI_ACCEPTANCE_OTP_TEMPLATE_ID = "1707171687739961361";
+    public static final String DLT_PRINCIPLE_ENTITY_ID = "1501589330000013091";
+    public static final String LOI_ACCEPTANCE_OTP_TEMPLATE = "Dear %s,\nThank you for showing your interest in the SmartDukaan franchise.\n%s is the OTP for your LOI acceptance.\nPlease read the LOI and provide your consent by sharing OTP with the SmartDukaan team.\nBest Regards,\nSmartDukaan Team.";
-    private static final Logger LOGGER = LogManager.getLogger(SchemeServiceImpl.class);
+    private static final Logger LOGGER = LogManager.getLogger(OtpProcessor.class);
     private static final String SMS_GATEWAY = "http://sms.speqtrainnov.com/api/v4/?api_key=A7897cd4627a8781e176fd31710b057a9";
     private static final int len = 5;
     private static final String SENDER = "SMTDKN";
     private static final String numbers = "0123456789";
     private static final String OTP_TEMPLATE = "Dear Customer, %s is the OTP that you have requested to login into SmartDukaan. Don't share your OTP with anyone";
     private static final String OTP_TEMPLATE_ID = "1507161889822750240";
+    //TODO LOI OTP
-    public static final String SELF_CANCELLED_TEMPLATE = "Order Cancelled PO%s: Dear Customer, your order with SmartDukaan of %s has been cancelled on %s as per your request. Team SmartDukaan";
+    private static final String USER = "smartdukaanOTP";
-    public static final String SELF_CANCELLED_TEMPLATE_ID = "1507161943392646481";
+    private static final String PASS1 = "Amit@Smart123";
-    public static final String TEMPLATE_ORDER_CREATED = "Order Placed PO%d: Dear Customer, your order with SmartDukaan of %s worth Rs.%.0f has been placed successfully. Our team will get in touch with you soon. Team SmartDukaan";
-    public static final String TEMPLATE_ORDER_CREATED_ID = "1507162021138742118";
+    private static String NEXG_API_ENDPOINT = "https://api2.nexgplatforms.com/sms/1/text/query";
     @Autowired
     OtpRepository otpRepository;
     @Autowired
     JavaMailSender mailSender;
-    @Value("${prod}")
-    private boolean prodEnv;
     @Autowired
     RestClient restClient;
+    @Autowired
+    LoiFormRepository partnerOnBoardingDataRepository;
+    @Value("${prod}")
+    private boolean prodEnv;
     private String getOtp() {
         Random rndm_method = new Random();
         char[] otp = new char[len];
     public OTPResponse generateOtp(String mobile, OtpType otpType) throws Exception, ProfitMandiBusinessException {
         LOGGER.info("Try generating otp for mobile -- {}", mobile);
         OTPResponse otpResponse = new OTPResponse();
         List<Otp> otps = otpRepository.selectAllByMobileWithTime(mobile);
         String otpCode = null;
+        LOGGER.info("Try to size of otps -- {}", otps.size());
         if (otps.size() >= 5) {
             otpResponse.setReference_id(0);
             otpResponse.setResult(false);
             otpResponse.setMessage("Maximum limit reached for the day");
             return otpResponse;
+        }
+        LOGGER.info("Try to check otps isEmpty", otps.isEmpty());
         if (!otps.isEmpty()) {
             if (otps.get(0).getCreatedOn().isAfter(LocalDateTime.now().minusMinutes(2))) {
                 otpResponse.setMessage("OTP generated less than 2 minutes ago");
                 otpResponse.setReference_id(otps.get(0).getId());
                 otpResponse.setResult(true);
                 otpCode = otps.get(0).getOtp();
             } else {
+                ;
+            }
+        }
+        LOGGER.info("Try to check otp null-- {}", otpCode == null);
         if (otpCode == null || otpCode.isEmpty()) {
             otpCode = getOtp();
+        }
         Otp otp = new Otp();
         otp.setOtp(otpCode);
         otp.setOtpType(otpType);
         otp.setCreatedOn(LocalDateTime.now());
         otp.setExpiryTimestamp(LocalDateTime.now().plusMinutes(10));
         otpRepository.persist(otp);
         //sendOtp(otp);
-        if (prodEnv) {
+        if (otpType.equals(OtpType.REGISTRATION)) {
             sendOtp(otp);
+        } else if (otpType.equals(OtpType.LOI_ACCEPTANCE)) {
+            sendOtpForLoiAcceptance(otp);
         } else {
             otpResponse.setOtp(otp.getOtp());
+        }
+        if (otpType.equals(OtpType.LOI_ACCEPTANCE)) {
+            LOGGER.info("otp_type-" + otpType);
+            sendOtpForLoiAcceptance(otp);
+        }
         otpResponse.setReference_id(otp.getId());
         otpResponse.setMessage("OTP generated successfully");
         otpResponse.setResult(true);
         return otpResponse;
+    }
     public OTPResponse validateOtp(int referenceId, String mobile, String otpCode)
             throws Exception, ProfitMandiBusinessException {
+        LOGGER.info("validate_call");
         OTPResponse otpResponse = new OTPResponse();
         Otp otp = otpRepository.selectById(referenceId);
         otp.setTryCount(otp.getTryCount() + 1);
         otpResponse.setReference_id(referenceId);
         if (!otp.getMobile().equals(mobile) || !otp.getOtp().equalsIgnoreCase(otpCode)) {
             otpResponse.setMessage("Invalid otp");
             otpResponse.setResult(false);
+            LOGGER.info("Invalid otp");
             return otpResponse;
+        }
         if (otp.isExpired() || otp.isVerified() || otp.getExpiryTimestamp().isBefore(LocalDateTime.now())) {
             otpResponse.setMessage("OTP expired");
             otpResponse.setResult(false);
+            LOGGER.info("OTP expired");
             return otpResponse;
+        }
         if (otp.getTryCount() > 5) {
             otpResponse.setMessage("Maximum try count reached");
             otpResponse.setResult(false);
+            LOGGER.info("Maximum try count reached");
             return otpResponse;
+        }
         otp.setExpired(true);
         otp.setVerified(true);
         otpRepository.persist(otp);
         otpResponse.setMessage("OTP validated successfully");
         otpResponse.setResult(true);
+        LOGGER.info("OTP validated successfully");
         return otpResponse;
+    }
     public void sendOtp(Otp otp) throws Exception {
         // In case of Cant receive SMS?
             e.printStackTrace();
+        }
+    }
+    //todo
+    public void sendOtpForLoiAcceptance(Otp otp1) throws Exception {
+        String otp = otp1.getOtp();
+        LoiForm pod = partnerOnBoardingDataRepository.selectByEmailOrMobile(otp1.getMobile());
+        String ownerName = pod.getFirstName();
+        String message = String.format(LOI_ACCEPTANCE_OTP_TEMPLATE, ownerName, otp);
+        this.sendSms(LOI_ACCEPTANCE_OTP_TEMPLATE_ID, message, otp1.getMobile());
+    }
-    public void sendSms(String dltTemplateId, String message, String mobileNumber) throws Exception {
+    public String sendSms(String dltTemplateId, String message, String mobileNumber) throws Exception {
         Map<String, String> queryParams = new HashMap<>();
-        queryParams.put("sender", SENDER);
+        queryParams.put("from", SENDER);
-        queryParams.put("method", "sms");
+        queryParams.put("indiaDltContentTemplateId", dltTemplateId);
+        queryParams.put("indiaDltPrincipalEntityId", DLT_PRINCIPLE_ENTITY_ID);
         queryParams.put("to", "91" + mobileNumber);
-        queryParams.put("message", message);
+        queryParams.put("text", message);
+        queryParams.put("password", PASS1);
-        queryParams.put("format", "json");
+        queryParams.put("username", USER);
         //OTP Message Template
-        String response = restClient.post(SMS_GATEWAY, queryParams, new HashMap<>(), new HashMap<>());
+        String response = restClient.post(NEXG_API_ENDPOINT, queryParams, new HashMap<>(), new HashMap<>());
         LOGGER.info(response);
+        return response;
+    }
     class SmsMessage {
         private String sender = "SMTDKN";
+    }
     class Message {
         private String number;
+        private Map<String, String> text;
         public String getNumber() {
             return number;
+        }
         public void setNumber(String number) {
             this.number = number;
+        }
-        private Map<String, String> text;
         @Override
         public String toString() {
             return "Message [number=" + number + ", text=" + text + "]";
+        }

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/service/OtpProcessor.java – Rev 31828 → 33510