Subversion Repositories SmartDukaan

import java.util.Set;

import java.util.TreeMap;

import org.springframework.util.StringUtils;

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

import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;

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

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

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

import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;

import com.spice.profitmandi.service.PartnerCollectionService;

import com.spice.profitmandi.service.user.RetailerService;

	@Autowired

	private CsService csService;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Autowired

	private PartnerCollectionService partnerCollectionService;

	@Autowired

	private RetailerService retailerService;

	@Autowired

	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;

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

	public String partnerHealth(HttpServletRequest request,

			@RequestParam(name = "email", required = false) String email, Model model) throws Exception {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		if (StringUtils.isEmpty(email)) {

			email = loginDetails.getEmailId();

		} else {

			AuthUser selectedUser = authRepository.selectByEmailOrMobile(email);

			model.addAttribute("selectedUser", selectedUser);

		}

		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());

		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();

		Set<Integer> fofoIds = storeGuyMap.get(email);

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

		if (fofoIds.size() > 0 && fofoIds != null) {

			List<Integer> fofoIdl = new ArrayList<>(fofoIds);

			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIdl).stream()

					.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());

			Map<Integer, PartnerCollectionPlanModel> foundCollectionMap = partnerCollectionService

					.getCollectionMap(fofoIdList, startDate);

			ChartLeadModel cm = this

					.getCollectionCount(foundCollectionMap.values().stream().collect(Collectors.toList()));

			model.addAttribute("chartPartnerHealth", gson.toJson(cm));

			Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();

			List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository

					.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));

			if (!partnerDailyInvestments.isEmpty()) {

				partnerDailyInvestmentMap = partnerDailyInvestments.stream()

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

			}

			Map<LocalDate, Map<Integer, PartnerCollectionPlanModel>> pcpmMap = new TreeMap<>();

			for (int i = 0; i <= 6; i++) {

				Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService

						.getCollectionMap(fofoIdList, startDate.minusDays(i));

				pcpmMap.put(startDate.minusDays(i).toLocalDate(), collectionMap);

			}

			Map<Integer, PartnerCollectionPlanModel> todayPcpmMap = pcpmMap.get(startDate.toLocalDate());

			model.addAttribute("todayPcpmMap", todayPcpmMap);

			Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(fofoIdList);

			List<Integer> allReportees = authService.getAllReportees(authUser.getId());

			LOGGER.info("allReportees" + allReportees);

			List<Integer> salesPositionsAuthIds = positionRepository

					.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES).stream()

					.map(x -> x.getAuthUserId()).collect(Collectors.toList());

			LOGGER.info("salesPositionsAuthIds" + salesPositionsAuthIds);

			List<Integer> rbmPositionsAuthIds = positionRepository

					.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()

					.map(x -> x.getAuthUserId()).collect(Collectors.toList());

			LOGGER.info("rbmPositionsAuthIds" + rbmPositionsAuthIds);

			salesPositionsAuthIds.addAll(rbmPositionsAuthIds);

			LOGGER.info("sdddd" + salesPositionsAuthIds);

			Set<Integer> empHierarchy = allReportees.stream().filter(x -> salesPositionsAuthIds.contains(x))

					.collect(Collectors.toSet());

			LOGGER.info("empHierarchy" + empHierarchy);

			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(new ArrayList<>(empHierarchy));

			LOGGER.info("dddd" + authUsers);

			model.addAttribute("authUsers", authUsers);

			model.addAttribute("partnerCollectionPlanMap", pcpmMap);

			model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);

			model.addAttribute("customRetailers", customRetailers);

			model.addAttribute("rankColorMap", ProfitMandiConstants.Rank_Color_Map);

		}

		return "partner-health";

	}

	public ChartLeadModel getCollectionCount(List<PartnerCollectionPlanModel> pcpm)

			throws ProfitMandiBusinessException {

		Map<Integer, Long> rankCount = pcpm.stream().collect(Collectors.groupingBy(x -> x.getRank(),

				Collectors.mapping(PartnerCollectionPlanModel::getRank, Collectors.counting())));

		ChartLeadModel cm = new ChartLeadModel();

		HashSet<String> labels = new HashSet<String>();

		labels.add("Plan for Today");

		labels.add("Carry Forward");

		labels.add("Untouched");

		labels.add("Plan for Future");

		labels.add("Normal");

		List<String> backgroundColor = new ArrayList<>();

		List<Long> values = new ArrayList<>();

		for (String label : labels) {

			if (label.equals("Plan for Today")) {

				backgroundColor.add("#007bff");

				values.add(rankCount.get(1));

			}

			if (label.equals("Carry Forward")) {

				backgroundColor.add("#ffc107");

				values.add(rankCount.get(2));

			}

			if (label.equals("Untouched")) {

				backgroundColor.add("#dc3545");

				values.add(rankCount.get(3));

			}

			if (label.equals("Plan for Future")) {

				backgroundColor.add("#6c757d");

				values.add(rankCount.get(4));

			}

			if (label.equals("Normal")) {

				backgroundColor.add("White");

				values.add(rankCount.get(5));

			}

		}

		LOGGER.info("backgroundColor" + backgroundColor);

		LOGGER.info("labelsChartLead" + labels);

		LeadStatusData data = new LeadStatusData();

		data.setData(values);

		data.setBackgroundColor(backgroundColor);

		data.setLabel("DataSet 1");

		PieLables label = new PieLables();

		label.setFontColor("black");

		label.setFontSize(15);

		Legend legend = new Legend();

		legend.setLabels(label);

		legend.setPosition("left");

		List<LeadStatusData> dataList = new ArrayList<>();

		dataList.add(data);

		DataLeadModel datasets = new DataLeadModel();

		datasets.setDatasets(dataList);

		datasets.setLabels(labels);

		OptionModel om = new OptionModel();

		om.setLegend(legend);

		cm.setType("pie");

		cm.setData(datasets);

		cm.setOptions(om);

		return cm;

	}