WebSVN – SmartDukaan – Diff – /trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/RechargeController.java

 package com.spice.profitmandi.web.controller;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 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.enumuration.SchemeType;
 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.RechargeCommissionRequest;
+import com.spice.profitmandi.common.model.RechargeCredential;
 import com.spice.profitmandi.common.model.RechargeRequest;
+import com.spice.profitmandi.dao.entity.dtr.RechargeCommission;
 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.RechargeCommissionRepository;
 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;
 @Transactional(rollbackFor=Throwable.class)
 public class RechargeController {
 	private static final Logger LOGGER = LoggerFactory.getLogger(RechargeController.class);
+	@Value("${recharge.transaction.scheme.type}")
+	private String rechargeTransactionSchemeType;
-	@Value("${recharge.api.host}")
+	@Value("${recharge.transaction.host}")
-	private String rechargeApiHost;
+	private String rechargeTransactionHost;
-	@Value("${recharge.api.port}")
+	@Value("${recharge.transaction.port}")
-	private int rechargeApiPort;
+	private int rechargeTransactionPort;
+	@Value("${recharge.transaction.uri}")
+	private String rechargeTransactionUri;
 	@Value("${recharge.auth.key}")
 	private String rechargeAuthKey;
+	@Value("${recharge.transaction.scheme.type}")
+	private String rechargeEnquirySchemeType;
-	@Value("${recharge.validation.api.host}")
+	@Value("${recharge.transaction.host}")
-	private String rechargeValidationApiHost;
+	private String rechargeEnquiryHost;
+	@Value("${recharge.transaction.port}")
+	private int rechargeEnquiryPort;
+	@Value("${recharge.transaction.uri}")
+	private String rechargeEnquiryUri;
+	@Value("${recharge.validation.scheme.type}")
+	private String rechargeValidationSchemeType;
+	@Value("${recharge.validation.host}")
+	private String rechargeValidationHost;
-	@Value("${recharge.validation.api.port}")
+	@Value("${recharge.validation.port}")
-	private int rechargeValidationApiPort;
+	private int rechargeValidationPort;
+	@Value("${recharge.validation.uri}")
+	private String rechargeValidationUri;
 	@Value("${recharge.validation.auth.key}")
 	private String rechargeValidationAuthKey;
 	@Autowired
 	@Autowired
 	private RechargeTransactionRepository rechargeTransactionRepository;
 	@Autowired
+	private RechargeCommissionRepository rechargeCommissionRepository;
+	@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("rechargeOperators", rechargeOperators);
 		return "create-recharge";
+	}
-	private Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap(List<RechargeTransaction> rechargeTransactions){
+	private Map<Integer, String> rechargeTransactionsToRechargeOperatorIdNameMap(List<RechargeTransaction> rechargeTransactions){
 		Map<Integer, String> rechargeOperatorIdrechargeOperatorNameMap = new HashMap<>();
 		if(rechargeTransactions.isEmpty()) {
 			return rechargeOperatorIdrechargeOperatorNameMap;
+		}
 		Set<Integer> operatorIds = new HashSet<>();
 			rechargeOperatorIdrechargeOperatorNameMap.put(rechargeOperator.getId(), rechargeOperator.getName());
+		}
 		return rechargeOperatorIdrechargeOperatorNameMap;
+	}
+	private Map<Integer, RechargeOperator> rechargeCommissionsOperatorIdRechargeOperatorMap(List<RechargeCommission> rechargeCommissions){
+		Map<Integer, RechargeOperator> rechargeOperatorIdNameMap = new HashMap<>();
+		if(rechargeCommissions.isEmpty()) {
+			return rechargeOperatorIdNameMap;
+		}
+		Set<Integer> operatorIds = new HashSet<>();
+		for(RechargeCommission rechargeCommission : rechargeCommissions) {
+			operatorIds.add(rechargeCommission.getOperatorId());
+		}
+		List<RechargeOperator> rechargeOperators = rechargeOperatorRepository.selectAllByIds(operatorIds);
+		for(RechargeOperator rechargeOperator : rechargeOperators) {
+			rechargeOperatorIdNameMap.put(rechargeOperator.getId(), rechargeOperator);
+		}
+		return rechargeOperatorIdNameMap;
+	}
 	@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{
+		LOGGER.info("Recharge request body {}", rechargeRequest);
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
+		RechargeCredential rechargeTransactionCredential = new RechargeCredential();
+		rechargeTransactionCredential.setRechargeSchemeType(SchemeType.valueOf(rechargeTransactionSchemeType.toUpperCase()));
+		rechargeTransactionCredential.setRechargeHost(rechargeTransactionHost);
+		rechargeTransactionCredential.setRechargePort(rechargeTransactionPort);
+		rechargeTransactionCredential.setRechargeAuthKey(rechargeAuthKey);
+		rechargeTransactionCredential.setRechargeUri(rechargeTransactionUri);
+		RechargeCredential rechargeValidationCredential = new RechargeCredential();
+		rechargeValidationCredential.setRechargeSchemeType(SchemeType.valueOf(rechargeValidationSchemeType.toUpperCase()));
+		rechargeValidationCredential.setRechargeHost(rechargeValidationHost);
+		rechargeValidationCredential.setRechargePort(rechargeValidationPort);
+		rechargeValidationCredential.setRechargeAuthKey(rechargeValidationAuthKey);
+		rechargeValidationCredential.setRechargeUri(rechargeValidationUri);
-		rechargeService.doRecharge(rechargeApiHost, rechargeApiPort, rechargeAuthKey, rechargeValidationApiHost, rechargeValidationApiPort, rechargeValidationAuthKey, loginDetails.getFofoId(), rechargeRequest);
+		rechargeService.doRecharge(rechargeTransactionCredential, rechargeValidationCredential, 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);
+		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeTransactionsToRechargeOperatorIdNameMap(rechargeTransactions);
 		model.addAttribute("rechargeTransactions", rechargeTransactions);
 		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
 		if (rechargeTransactions.size() < limit){
 	@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);
+		RechargeCredential rechargeEnquiryCredential = new RechargeCredential();
+		rechargeEnquiryCredential.setRechargeSchemeType(SchemeType.valueOf(rechargeEnquirySchemeType.toUpperCase()));
+		rechargeEnquiryCredential.setRechargeHost(rechargeEnquiryHost);
+		rechargeEnquiryCredential.setRechargePort(rechargeEnquiryPort);
+		rechargeEnquiryCredential.setRechargeAuthKey(rechargeAuthKey);
-		rechargeService.checkStatus(rechargeApiHost, rechargeApiPort, rechargeAuthKey, loginDetails.getFofoId(), requestId);
+		rechargeService.checkStatus(rechargeEnquiryCredential, 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);
+		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeTransactionsToRechargeOperatorIdNameMap(rechargeTransactions);
 		model.addAttribute("rechargeTransactions", rechargeTransactions);
 		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);
 		if(RechargeType.valueOf(rechargeTypeString) == RechargeType.MOBILE) {
 			return "mobile-recharges-paginated";
 	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);
+		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeTransactionsToRechargeOperatorIdNameMap(rechargeTransactions);
 		model.addAttribute("rechargeTransactions", rechargeTransactions);
 		model.addAttribute("rechargeOperatorIdRechargeOperatorNameMap", rechargeOperatorIdRechargeOperatorNameMap);
 		model.addAttribute("start", offset + 1);
 		model.addAttribute("size", size);
 		if (rechargeTransactions.size() < limit){
 	@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);
+		Map<Integer, String> rechargeOperatorIdRechargeOperatorNameMap = this.rechargeTransactionsToRechargeOperatorIdNameMap(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)
+	@RequestMapping(value = "/getRechargeOperators", method = RequestMethod.GET)
-	public String getOperators(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.OPERATOR_TYPE) String operatorTypeString, Model model){
+	public String getRechargeOperators(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";
+	}
+	@RequestMapping(value = "/getRechargeCommissionOperators", method = RequestMethod.GET)
+	public String getRechargeCommissionOperators(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.OPERATOR_TYPE) String operatorTypeString, Model model) throws ProfitMandiBusinessException{
 		//model.addAttribute("rechargeOperators", rechargeOperatorRepository.selectAllByRechargeType(RechargeType.MOBILE));
 		//model.addAttribute("rechargeTypes", RechargeType.values());
 		OperatorType operatorType = OperatorType.valueOf(operatorTypeString);
 		List<RechargeOperator> rechargeOperators = rechargeOperatorRepository.selectAllByOperatorType(operatorType);
+		List<Integer> rechargeOperatorIds = rechargeCommissionRepository.selectAllOperatorIds();
+		if(!rechargeOperatorIds.isEmpty()) {
+			rechargeOperators = this.filterRechargeOperators(rechargeOperators, rechargeOperatorIds);
+			if(rechargeOperators.isEmpty()) {
+				throw new ProfitMandiBusinessException(ProfitMandiConstants.OPERATOR_TYPE, operatorType, "RCHRG_1003");
+			}
+		}
 		model.addAttribute("rechargeOperators", rechargeOperators);
 		return "recharge-operators";
+	}
+	@RequestMapping(value = "/createRechargeCommission", method = RequestMethod.GET)
+	public String createRechargeCommission(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.RECHARGE_TYPE) String rechargeTypeString, Model model) throws ProfitMandiBusinessException{
+		//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);
+		}
+		List<Integer> rechargeOperatorIds = rechargeCommissionRepository.selectAllOperatorIds();
+		if(!rechargeOperatorIds.isEmpty()) {
+			rechargeOperators = this.filterRechargeOperators(rechargeOperators, rechargeOperatorIds);
+			if(rechargeOperators.isEmpty()) {
+				throw new ProfitMandiBusinessException(ProfitMandiConstants.RECHARGE_TYPE, rechargeType, "RCHRG_1003");
+			}
+		}
+		model.addAttribute("rechargeOperators", rechargeOperators);
+		return "create-recharge-commission";
+	}
+	private List<RechargeOperator> filterRechargeOperators(List<RechargeOperator> rechargeOperators, List<Integer> rechargeOperatorIds){
+		List<RechargeOperator> filteredRechargeOperators = new ArrayList<>();
+		for(RechargeOperator rechargeOperator : rechargeOperators) {
+			if(!rechargeOperatorIds.contains(rechargeOperator.getId())) {
+				filteredRechargeOperators.add(rechargeOperator);
+			}
+		}
+		return filteredRechargeOperators;
+	}
+	@RequestMapping(value = "/createRechargeCommission", method = RequestMethod.POST)
+	public String createRechargeCommission(HttpServletRequest request, @RequestBody RechargeCommissionRequest rechargeCommissionRequest, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{
+		rechargeService.createRechargeCommission(rechargeCommissionRequest);
+		List<RechargeCommission> rechargeCommissions = rechargeCommissionRepository.selectAllPaginated(offset, limit);
+		long size = rechargeCommissionRepository.selectAllCount();
+		Map<Integer, RechargeOperator> rechargeOperatorIdRechargeOperatorMap = this.rechargeCommissionsOperatorIdRechargeOperatorMap(rechargeCommissions);
+		model.addAttribute("rechargeCommissions", rechargeCommissions);
+		model.addAttribute("rechargeOperatorIdRechargeOperatorMap", rechargeOperatorIdRechargeOperatorMap);
+		model.addAttribute("start", offset + 1);
+		model.addAttribute("size", size);
+		if (rechargeCommissions.size() < limit){
+			model.addAttribute("end", offset + rechargeCommissions.size());
+		}else{
+			model.addAttribute("end", offset + limit);
+		}
+		return "recharge-commissions";
+	}
+	@RequestMapping(value = "/getRechargeCommissions", method = RequestMethod.GET)
+	public String getRechargeCommissions(HttpServletRequest request, @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<RechargeCommission> rechargeCommissions = rechargeCommissionRepository.selectAllPaginated(offset, limit);
+		long size = rechargeCommissionRepository.selectAllCount();
+		Map<Integer, RechargeOperator> rechargeOperatorIdRechargeOperatorMap = this.rechargeCommissionsOperatorIdRechargeOperatorMap(rechargeCommissions);
+		model.addAttribute("rechargeCommissions", rechargeCommissions);
+		model.addAttribute("rechargeOperatorIdRechargeOperatorMap", rechargeOperatorIdRechargeOperatorMap);
+		model.addAttribute("start", offset + 1);
+		model.addAttribute("size", size);
+		if (rechargeCommissions.size() < limit){
+			model.addAttribute("end", offset + rechargeCommissions.size());
+		}else{
+			model.addAttribute("end", offset + limit);
+		}
+		return "recharge-commissions";
+	}
+	@RequestMapping(value = "/getPaginatedRechargeCommissions", method = RequestMethod.GET)
+	public String getPaginatedRechargeCommissions(HttpServletRequest request, @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<RechargeCommission> rechargeCommissions = rechargeCommissionRepository.selectAllPaginated(offset, limit);
+		Map<Integer, RechargeOperator> rechargeOperatorIdRechargeOperatorMap = this.rechargeCommissionsOperatorIdRechargeOperatorMap(rechargeCommissions);
+		model.addAttribute("rechargeCommissions", rechargeCommissions);
+		model.addAttribute("rechargeOperatorIdRechargeOperatorMap", rechargeOperatorIdRechargeOperatorMap);
+		return "recharge-commissions-paginated";
+	}
+	@RequestMapping(value = "/getRechargeCommissionByOperatorId", method = RequestMethod.GET)
+	public String getRechargeCommissionByOperatorId(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.OPERATOR_ID) int operatorId, Model model)  throws ProfitMandiBusinessException{
+		RechargeOperator rechargeOperator = rechargeOperatorRepository.selectById(operatorId);
+		RechargeCommission rechargeCommission = rechargeCommissionRepository.selectByOperatorId(operatorId);
+		model.addAttribute("rechargeCommission", rechargeCommission);
+		model.addAttribute("rechargeOperator", rechargeOperator);
+		return "recharge-commission-details";
+	}
+	@RequestMapping(value = "/updateRechargeCommission", method = RequestMethod.PUT)
+	public String updateRechargeCommission(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.OPERATOR_ID) int operatorId, @RequestParam(name = ProfitMandiConstants.AMOUNT_TYPE) String amountTypeString, @RequestParam(name = ProfitMandiConstants.AMOUNT) float amount, @RequestParam(name = "offset", defaultValue = "0") int offset, @RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws ProfitMandiBusinessException{
+		rechargeService.updateRechargeCommission(operatorId, amountTypeString, amount);
+		List<RechargeCommission> rechargeCommissions = rechargeCommissionRepository.selectAllPaginated(offset, limit);
+		Map<Integer, RechargeOperator> rechargeOperatorIdRechargeOperatorMap = this.rechargeCommissionsOperatorIdRechargeOperatorMap(rechargeCommissions);
+		model.addAttribute("rechargeCommissions", rechargeCommissions);
+		model.addAttribute("rechargeOperatorIdRechargeOperatorMap", rechargeOperatorIdRechargeOperatorMap);
+		return "recharge-commissions-paginated";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/RechargeController.java – Rev 23505 → 23528