Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.processor;

import java.io.IOException;

import java.net.URISyntaxException;

import java.time.LocalDateTime;

import java.util.List;

import java.util.Random;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.util.Utils;

import com.spice.profitmandi.dao.entity.dtr.Otp;

import com.spice.profitmandi.dao.enumuration.dtr.OtpType;

import com.spice.profitmandi.dao.repository.dtr.OtpRepository;

import com.spice.profitmandi.web.res.OTPResponse;

@Component

public class OtpProcessor {

	private static final int len = 5;

	private static final String numbers = "0123456789";

	private static final String text = "Dear Customer, {0} is the OTP that you have requested to login into SmartDukaan. Don't share your OTP with anyone.";

	@Autowired

	OtpRepository otpRepository;

	private String getOtp() {

		Random rndm_method = new Random();

		char[] otp = new char[len];

		for (int i = 0; i < len; i++) {

			otp[i] = numbers.charAt(rndm_method.nextInt(numbers.length()));

		}

		return String.valueOf(otp);

	}

	public OTPResponse generateOtp(String email, String phone, OtpType otpType)

			throws Exception, ProfitMandiBusinessException {

		OTPResponse otpResponse = new OTPResponse();

		List<Otp> otps = otpRepository.selectAllByEmailWithTime(email);

		String otp = null;

		if (otps.size() >= 5) {

			otpResponse.setReference_id(0);

			otpResponse.setResult(false);

			otpResponse.setMessage("Maximum limit reached for the day");

			return otpResponse;

		}

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

				otpResponse.setOtp(otps.get(0).getOtp());

				return otpResponse;

			} else if (otps.get(0).getCreatedOn().isAfter(LocalDateTime.now().minusMinutes(10))) {

				otp = otps.get(0).getOtp();

			} else {

				;

			}

		}

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

			otp = getOtp();

		}

		sendOtp(otp, phone);

		Otp otp_bean = new Otp();

		otp_bean.setEmail(email);

		otp_bean.setMobile(phone);

		otp_bean.setOtp(otp);

		otp_bean.setOtpType(otpType);

		otp_bean.setCreatedOn(LocalDateTime.now());

		otp_bean.setExpiryTimestamp(LocalDateTime.now().plusMinutes(10));

		otpRepository.persist(otp_bean);

		otpResponse.setReference_id(otp_bean.getId());

		otpResponse.setMessage("OTP generated successfully");

		otpResponse.setResult(true);

		otpResponse.setOtp(otp_bean.getOtp());

		return otpResponse;

	}

	public OTPResponse validateOtp(String email, int reference_id, String otp_number)

			throws Exception, ProfitMandiBusinessException {

		OTPResponse otpResponse = new OTPResponse();

		Otp otp = otpRepository.selectById(reference_id);

		otp.setTryCount(otp.getTryCount() + 1);

		otpResponse.setReference_id(reference_id);

		if (!otp.getEmail().equalsIgnoreCase(email) || !otp.getOtp().equalsIgnoreCase(otp_number)) {

			otpResponse.setMessage("Invalid otp");

			otpResponse.setResult(false);

			otpRepository.persist(otp);

			return otpResponse;

		}

		if (otp.isExpired() || otp.isVerified() || otp.getExpiryTimestamp().isBefore(LocalDateTime.now())) {

			otpResponse.setMessage("OTP expired");

			otpResponse.setResult(false);

			return otpResponse;

		}

		if (otp.getTryCount() > 5) {

			otpResponse.setMessage("Maximum try count reached");

			otpResponse.setResult(false);

			return otpResponse;

		}

		otp.setExpired(true);

		otp.setVerified(true);

		otpRepository.persist(otp);

		otpResponse.setMessage("OTP validated successfully");

		otpResponse.setResult(true);

		return otpResponse;

	}

	private void sendOtp(String otp_text, String phone) {

		String msg = java.text.MessageFormat.format(text, otp_text);

		try {

			Utils.sendSms(msg, phone);

		} catch (Exception e) {

			e.printStackTrace();

		}

	}

}