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.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://api.pinnacle.in/index.php/sms/send";

	private static final int len = 5;

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

	// This should remain unused reference template id is -->

	private static final String orderConfirmationText = "Dear customer, your order of <productname> <+3 more pcs> has been  successfully placed with SmartDukaan. We will get in touch with you soon.\n"

			+ "SmartDukaan Team";

	@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 mobile, OtpType otpType) throws Exception, ProfitMandiBusinessException {

		OTPResponse otpResponse = new OTPResponse();

		List<Otp> otps = otpRepository.selectAllByMobileWithTime(mobile);

		String otpCode = 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))) {

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

			} else {

				;

			}

		}

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

			otpCode = getOtp();

		}

		Otp otp = new Otp();

		otp.setMobile(mobile);

		otp.setOtp(otpCode);

		otp.setOtpType(otpType);

		otp.setCreatedOn(LocalDateTime.now());

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

		otpRepository.persist(otp);

		if (prodEnv) {

			sendOtp(otp);

		}

		otpResponse.setReference_id(otp.getId());

		otpResponse.setMessage("OTP generated successfully");

		otpResponse.setResult(true);

		otpResponse.setOtp(otp.getOtp());

		return otpResponse;

	}

	public OTPResponse validateOtp(int referenceId, String mobile, String otpCode)

			throws Exception, ProfitMandiBusinessException {

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

			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;

	}

	public void sendOtp(Otp otp) throws Exception {

		// In case of Cant receive SMS?

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

		String otpString = otp.getOtp();

		try {

			this.sendSms(String.format(OTP_TEMPLATE, otpString), otp.getMobile());

		} catch (Exception e) {

			e.printStackTrace();

		}

	}

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

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

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

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

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

		map.put("sender", "SMTDKN");

		map.put("numbers", "91"+mobileNumber);

		map.put("message", message);

		map.put("messagetype", "TXT");

		//SD

		map.put("dltentityid", "1501589330000013091");

		//SMTDKN

		map.put("dltheaderid", "1505159255691251261");

		//OTP Message Template

		map.put("dlttempid", "1507159265839999722");

		//Consent Template

		map.put("dlttagid", "");

		//Speqtra Innov - Our SMS Provider

		map.put("tmid", "1502472910000014692");

		String response = restClient.post(SMS_GATEWAY, map, headersMap);

		LOGGER.info(response);

	}

	public void sendSmsNew(String message, String mobileNumber) throws Exception {

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

		obj.put("message", message);

		String response = restClient.get(String.format(SMS_GATEWAY, mobileNumber), null, null);

		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;

		}

	}

}