Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.entity.user.Lead;

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

import com.spice.profitmandi.dao.model.PartnerDetailModel;

import com.spice.profitmandi.dao.repository.cs.PartnersPositionRepository;

import com.spice.profitmandi.dao.repository.cs.TicketRepository;

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

	private PartnersPositionRepository partnerPositionRepository;

	@Autowired

	@Autowired

	TicketRepository ticketRepository;

	@Autowired

	private LeadRepository leadRepository;

			Map<Integer, AuthUser> authIdAndAuthUserMap = null;

			Map<Integer, Object> authIdAndallValues = null;

			if (positions.size() > 0) {

				if (positions.stream().filter(x -> x.getEscalationType().equals(EscalationType.L3)).count() > 0) {

					authIdAndAuthUserMap = authRepository.selectAllActiveUser().stream()

							.collect(Collectors.toMap(x -> x.getId(), x -> x));

					authIdAndallValues = csService.getL2AuthUserPartnerDetail();

					LOGGER.info("authIdAndallValues" + authIdAndallValues);

				}

			}

			model.addAttribute("authIdAndallValues", authIdAndallValues);

			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);

			LOGGER.info("authIdAndallValues1" + authIdAndallValues);

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

	public String L1AuthUsersDetail(HttpServletRequest request, Model model, @RequestParam int authId)

			throws Exception {

		Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();

		LocalDateTime curDate = LocalDate.now().atStartOfDay();

		Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumAmountGroupByRetailer(

				curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);

		Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1),

				curDate.with(LocalTime.MAX), 0, false);

		Map<Integer, List<Integer>> L2L1Mapping = csService.getL1L2Mapping();

		LOGGER.info("L2L1Mapping" + L2L1Mapping);

		List<Integer> l1authIds = L2L1Mapping.get(authId);

		Map<Integer, Object> authIdAndallValues = new LinkedHashMap<>();

		Map<Integer, Object> authIdAndAuthUserMap = new LinkedHashMap<>();

		Map<Integer, Long> ticketMap = ticketRepository.selectAllNotClosedTicketsGroupByRetailer();

		for (Integer auth : l1authIds) {

			double totallmtdAmount = 0;

			double totalmtdAmount = 0;

			int totalTicketCount = 0;

			float totalTodayInvestment = 0;

			float totalStockInInvestment = 0;

			double currentMonthRatingAllPartners = 0;

			Map<Integer, Long> leadCount = leadRepository.selectByAssignAuthIdAndStatus(auth, LeadStatus.followUp)

					.stream().collect(Collectors.groupingBy(Lead::getAssignTo, Collectors.counting()));

			AuthUser authUser = authRepository.selectById(auth);

			authIdAndAuthUserMap.put(auth, authUser);

			List<Integer> fofoIds = pp.get(auth);

			for (Integer fId : fofoIds) {

				Map<String, Object> investmentMap = this.getInvestments(fId);

				double currentMonthRating = hygieneDataRepository.selectRatingAvg(fId,

						curDate.withDayOfMonth(1).minusMonths(1), curDate.plusMonths(1).withDayOfMonth(1));

				currentMonthRatingAllPartners += currentMonthRating;

				fofoIds.size();

				Double lmtdAmount = lmtdSale.get(fId);

				Double mtdAmount = mtdSale.get(fId);

				Long ticketCount = ticketMap.get(fId);

				if (!investmentMap.isEmpty()) {

					totalTodayInvestment += (float) investmentMap.get("today");

					totalStockInInvestment += (float) investmentMap.get("inStock");

				}

				LOGGER.info("totalTodayInvestment" + totalTodayInvestment);

				LOGGER.info("totalStockInInvestment" + totalStockInInvestment);

				if (ticketCount != null) {

					totalTicketCount += ticketCount;

				}

				if (lmtdAmount != null) {

					totallmtdAmount += lmtdAmount;

				}

				if (mtdAmount != null) {

					totalmtdAmount += mtdAmount;

				}

			}

			LOGGER.info("currentMonthRatingAllPartners" + currentMonthRatingAllPartners);

			LOGGER.info("size" + fofoIds.size());

			double totalHygieneRating = currentMonthRatingAllPartners / fofoIds.size();

			LOGGER.info("totalHygieneRating" + totalHygieneRating);

			PartnerDetailModel pm = new PartnerDetailModel();

			pm.setLmtd(totallmtdAmount);

			pm.setMtd(totalmtdAmount);

			if (leadCount.get(auth) != null) {

				pm.setLeads(leadCount.get(auth).intValue());

			} else {

				pm.setLeads(0);

			}

			pm.setInvestment(totalTodayInvestment);

			pm.setStockInInvestment(totalStockInInvestment);

			pm.setTicket(totalTicketCount);

			pm.setHygiene((double) Math.round(totalHygieneRating));

			authIdAndallValues.put(auth, pm);

		}

		model.addAttribute("authIdAndallValues", authIdAndallValues);

		model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);

		LOGGER.info("authIdAndallValues" + authIdAndallValues);

		return "auth_user_detail";

	}

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

	public String AuthUserPartnersDetail(HttpServletRequest request, Model model, @RequestParam int authId)

			throws Exception {

		Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();

		List<Integer> fofoIds = pp.get(authId);

		Map<Integer, Long> ticketMap = ticketRepository.selectAllNotClosedTicketsGroupByRetailer();

		Map<Integer, Object> fofoIdAndallValues = new LinkedHashMap<>();

		Map<Integer, Object> fofoIdAndPartnerMap = new LinkedHashMap<>();

		for (Integer fofoId : fofoIds) {

			CustomRetailer cr = retailerService.getFofoRetailer(fofoId);

			fofoIdAndPartnerMap.put(fofoId, cr);

			LocalDateTime curDate = LocalDate.now().atStartOfDay();

			Double lmtdSale = fofoOrderItemRepository

					.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1).minusMonths(1),

							curDate.with(LocalTime.MAX).minusMonths(1), fofoId, false)

					.get(fofoId);

			Double mtdSale = fofoOrderItemRepository.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1),

					curDate.with(LocalTime.MAX), fofoId, false).get(fofoId);

			Map<String, Object> investmentMap = this.getInvestments(fofoId);

			double currentMonthRating = hygieneDataRepository.selectRatingAvg(fofoId,

					curDate.withDayOfMonth(1).minusMonths(1), curDate.plusMonths(1).withDayOfMonth(1));

			Long ticketCount = ticketMap.get(fofoId);

			float totalTodayInvestment = (float) investmentMap.get("today");

			float totalStockInInvestment = (float) investmentMap.get("inStock");

			PartnerDetailModel pm = new PartnerDetailModel();

			pm.setLmtd(lmtdSale);

			pm.setMtd(mtdSale);

			pm.setInvestment(totalTodayInvestment);

			pm.setStockInInvestment(totalStockInInvestment);

			if (ticketCount != null) {

				pm.setTicket(ticketCount.intValue());

			} else {

				pm.setTicket(0);

			}

			pm.setHygiene((double) Math.round(currentMonthRating));

			fofoIdAndallValues.put(fofoId, pm);

		}

		model.addAttribute("fofoIdAndallValues", fofoIdAndallValues);

		model.addAttribute("fofoIdAndPartnerMap", fofoIdAndPartnerMap);

		return "auth_user_partner_detail";

	}