Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.processor;

import java.time.LocalDateTime;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Random;

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 com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

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

import com.spice.profitmandi.common.web.client.RestClient;

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.service.scheme.SchemeServiceImpl;

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

@Component

public class OtpProcessor {

	private static final Logger LOGGER = LogManager.getLogger(SchemeServiceImpl.class);

	private static final String SMS_GATEWAY = "http://sms.smartdukaan.com/index.php/sms/templatesms";

	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;

	@Autowired

	JavaMailSender mailSender;

	@Value("${prod}")

	private boolean prodEnv;

	@Autowired

	RestClient restClient;

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

		}

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

		if (prodEnv) {

			sendOtp(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(Otp otp) throws Exception {

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

		String otpString = otp.getOtp();

		Utils.sendMailWithAttachments(mailSender, otp.getEmail(), null, "One Time Password - Smartdukaan", msg, null);

		try {

			this.sendSms(otpString, otp.getMobile());

		} catch (Exception e) {

			e.printStackTrace();

		}

	}

	public void sendSms(String text, String mobileNumber) throws Exception {

		Map<String, String> headersMap = new HashMap<>();

		headersMap.put("Content-Type", "application/json");

		headersMap.put("apikey", "b866f7-c6c483-682ff5-054420-ad9e2c");

		SmsMessage smsMessage = new SmsMessage();

		Message message = new Message();

		message.setNumber(mobileNumber);

		Map<String, String> map = new HashMap<>();

		map.put("F1", text);

		message.setText(map);

		List<Message> messages = new ArrayList<>();

		messages.add(message);

		smsMessage.setMessage(messages);

		String response = restClient.postJson(SMS_GATEWAY, smsMessage, headersMap);

		LOGGER.info(response);

	}

	class SmsMessage {

		private String sender = "SMTDKN";

		@JsonProperty(value = "templateid")

		private String templateId = "54";

		private List<Message> message;

		@JsonProperty(value = "messagetype")

		private String messageType = "TXT";

		@Override

		public String toString() {

			return "SmsMessage [sender=" + sender + ", templateId=" + templateId + ", message=" + message

					+ ", messageType=" + messageType + "]";

		}

		public String getMessageType() {

			return messageType;

		}

		public void setMessageType(String messageType) {

			this.messageType = messageType;

		}

		public String getSender() {

			return sender;

		}

		public void setSender(String sender) {

			this.sender = sender;

		}

		public String getTemplateId() {

			return templateId;

		}

		public void setTemplateId(String templateId) {

			this.templateId = templateId;

		}

		public List<Message> getMessage() {

			return message;

		}

		public void setMessage(List<Message> message) {

			this.message = message;

		}

	}

	class Message {

		private String number;

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

		}

		public Map<String, String> getText() {

			return text;

		}

		public void setText(Map<String, String> text) {

			this.text = text;

		}

	}

}