Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

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

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

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

import com.spice.profitmandi.common.model.OperatorType;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

import com.spice.profitmandi.common.model.RechargeRequest;

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

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

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

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

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

import com.spice.profitmandi.service.recharge.RechargeService;

import com.spice.profitmandi.web.model.LoginDetails;

import com.spice.profitmandi.web.util.CookiesProcessor;

@Controller

@Transactional(rollbackFor=Throwable.class)

public class RechargeController {

	private static final Logger LOGGER = LoggerFactory.getLogger(RechargeController.class);

	@Value("${recharge.api.host}")

	private String rechargeApiHost;

	@Value("${recharge.api.port}")

	private int rechargeApiPort;

	@Value("${recharge.auth.key}")

	private String rechargeAuthKey;

	@Value("${recharge.validation.api.host}")

	private String rechargeValidationApiHost;

	@Value("${recharge.validation.api.port}")

	private int rechargeValidationApiPort;

	@Value("${recharge.validation.auth.key}")

	private String rechargeValidationAuthKey;

	@Autowired

	private RechargeService rechargeService;

	@Autowired

	private RechargeOperatorRepository rechargeOperatorRepository;

	@Autowired

	private RechargeTransactionRepository rechargeTransactionRepository;

	@Autowired

	private CookiesProcessor cookiesProcessor;

	@RequestMapping(value = "/createRecharge", method = RequestMethod.GET)

	public String createRecharge(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.RECHARGE_TYPE) String rechargeTypeString, Model model){

		//model.addAttribute("rechargeOperators", rechargeOperatorRepository.selectAllByRechargeType(RechargeType.MOBILE));

		//model.addAttribute("rechargeTypes", RechargeType.values());

		RechargeType rechargeType = RechargeType.valueOf(rechargeTypeString);

		List<RechargeOperator> rechargeOperators = null;

		if(rechargeType == RechargeType.MOBILE) {

			model.addAttribute("operatorTypes", OperatorType.values());

			rechargeOperators = rechargeOperatorRepository.selectAllByOperatorType(OperatorType.PREPAID);

		}else {

			rechargeOperators = rechargeOperatorRepository.selectAllByRechargeType(rechargeType);

		}

		model.addAttribute("rechargeOperators", rechargeOperators);

		return "create-recharge";

	}

	private Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap(List<RechargeTransaction> rechargeTransactions){

		Map<Integer, String> rechargeOperatorIdrechargeOperatorNameMap = new HashMap<>();

		if(rechargeTransactions.isEmpty()) {

			return rechargeOperatorIdrechargeOperatorNameMap;

		}

		Set<Integer> operatorIds = new HashSet<>();

		for(RechargeTransaction rechargeTransaction : rechargeTransactions) {

			operatorIds.add(rechargeTransaction.getOperatorId());

		}

		List<RechargeOperator> rechargeOperators = rechargeOperatorRepository.selectAllByIds(operatorIds);

		for(RechargeOperator rechargeOperator : rechargeOperators) {

			rechargeOperatorIdrechargeOperatorNameMap.put(rechargeOperator.getId(), rechargeOperator.getName());

		}

		return rechargeOperatorIdrechargeOperatorNameMap;

	}

	@RequestMapping(value = "/createRecharge", method = RequestMethod.POST)

	public String createRecharge(HttpServletRequest request, @RequestBody RechargeRequest rechargeRequest, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		rechargeService.doRecharge(rechargeApiHost, rechargeApiPort, rechargeAuthKey, rechargeValidationApiHost, rechargeValidationApiPort, rechargeValidationAuthKey, loginDetails.getFofoId(), rechargeRequest);

		RechargeType rechargeType = RechargeType.valueOf(rechargeRequest.getRechargeType());

		List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllByRetailerIdAndType(loginDetails.getFofoId(), rechargeType, offset, limit);

		long size = rechargeTransactionRepository.selectCountByRetailerIdAndType(loginDetails.getFofoId(), rechargeType);

		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeOperatorIdRechargeOperatorNameMap(rechargeTransactions);

		model.addAttribute("rechargeTransactions", rechargeTransactions);

		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);

		model.addAttribute("start", offset + 1);

		model.addAttribute("size", size);

		if (rechargeTransactions.size() < limit){

			model.addAttribute("end", offset + rechargeTransactions.size());

		}else{

			model.addAttribute("end", offset + limit);

		}

		if(RechargeType.valueOf(rechargeRequest.getRechargeType()) == RechargeType.MOBILE) {

			return "mobile-recharges";

		}else {

			return "dth-recharges";

		}

	}

	@RequestMapping(value = "/getRechargeById", method = RequestMethod.GET)

	public String getRechargeById(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.RECHARGE_TRANSACTION_ID) int rechargeTransactionId, Model model)  throws ProfitMandiBusinessException{

		RechargeTransaction rechargeTransaction = rechargeTransactionRepository.selectById(rechargeTransactionId);

		model.addAttribute("rechargeTransaction", rechargeTransaction);

		return "recharge-details";

	}

	@RequestMapping(value = "/checkStatus", method = RequestMethod.GET)

	public String checkStatus(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.REQUEST_ID) String requestId, @RequestParam(name = ProfitMandiConstants.RECHARGE_TYPE) String rechargeTypeString, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{

		LOGGER.info("RequestId [{}], rechargeType [{}]", requestId, rechargeTypeString);

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		rechargeService.checkStatus(rechargeApiHost, rechargeApiPort, rechargeAuthKey, loginDetails.getFofoId(), requestId);

		RechargeType rechargeType = RechargeType.valueOf(rechargeTypeString);

		List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllByRetailerIdAndType(loginDetails.getFofoId(), rechargeType, offset, limit);

		//long size = rechargeTransactionRepository.selectCountByRetailerId(loginDetails.getFofoId());

		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeOperatorIdRechargeOperatorNameMap(rechargeTransactions);

		model.addAttribute("rechargeTransactions", rechargeTransactions);

		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);

		if(RechargeType.valueOf(rechargeTypeString) == RechargeType.MOBILE) {

			return "mobile-recharges-paginated";

		}else {

			return "dth-recharges-paginated";

		}

	}

	@RequestMapping(value = "/getRecharges", method = RequestMethod.GET)

	public String getRecharges(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.RECHARGE_TYPE) String rechargeTypeString, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		RechargeType rechargeType = RechargeType.valueOf(rechargeTypeString);

		List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllByRetailerIdAndType(loginDetails.getFofoId(), rechargeType, offset, limit);

		long size = rechargeTransactionRepository.selectCountByRetailerIdAndType(loginDetails.getFofoId(), rechargeType);

		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeOperatorIdRechargeOperatorNameMap(rechargeTransactions);

		model.addAttribute("rechargeTransactions", rechargeTransactions);

		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);

		model.addAttribute("start", offset + 1);

		model.addAttribute("size", size);

		if (rechargeTransactions.size() < limit){

			model.addAttribute("end", offset + rechargeTransactions.size());

		}else{

			model.addAttribute("end", offset + limit);

		}

		if(RechargeType.valueOf(rechargeTypeString) == RechargeType.MOBILE) {

			return "mobile-recharges";

		}else {

			return "dth-recharges";

		}

	}

	@RequestMapping(value = "/getPaginatedRecharges", method = RequestMethod.GET)

	public String getPaginatedRecharges(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.RECHARGE_TYPE) String rechargeTypeString, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		RechargeType rechargeType = RechargeType.valueOf(rechargeTypeString);

		List<RechargeTransaction> rechargeTransactions = rechargeTransactionRepository.selectAllByRetailerIdAndType(loginDetails.getFofoId(), rechargeType, offset, limit);

		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeOperatorIdRechargeOperatorNameMap(rechargeTransactions);

		model.addAttribute("rechargeTransactions", rechargeTransactions);

		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);

		if(RechargeType.valueOf(rechargeTypeString) == RechargeType.MOBILE) {

			return "mobile-recharges-paginated";

		}else {

			return "dth-recharges-paginated";

		}

	}

	@RequestMapping(value = "/getOperators", method = RequestMethod.GET)

	public String getOperators(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.OPERATOR_TYPE) String operatorTypeString, Model model){

		//model.addAttribute("rechargeOperators", rechargeOperatorRepository.selectAllByRechargeType(RechargeType.MOBILE));

		//model.addAttribute("rechargeTypes", RechargeType.values());

		OperatorType operatorType = OperatorType.valueOf(operatorTypeString);

		List<RechargeOperator> rechargeOperators = rechargeOperatorRepository.selectAllByOperatorType(operatorType);

		model.addAttribute("rechargeOperators", rechargeOperators);

		return "recharge-operators";

	}

}