Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.ZoneOffset;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.HashMap;

import java.util.HashSet;

import java.util.LinkedHashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Optional;

import java.util.Set;

import java.util.stream.Collectors;

import javax.servlet.http.HttpServletRequest;

import javax.transaction.Transactional;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.json.JSONObject;

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

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

import org.springframework.core.io.InputStreamResource;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

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

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

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

import com.google.gson.Gson;

import com.mongodb.DBObject;

import com.spice.profitmandi.common.enumuration.ContentType;

import com.spice.profitmandi.common.enumuration.MessageType;

import com.spice.profitmandi.common.enumuration.ReporticoProject;

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.common.web.util.ResponseSender;

import com.spice.profitmandi.dao.Interface.Campaign;

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

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

import com.spice.profitmandi.dao.entity.cs.Position;

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

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

import com.spice.profitmandi.dao.entity.fofo.FofoStore;

import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;

import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;

import com.spice.profitmandi.dao.entity.fofo.PartnerType;

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

import com.spice.profitmandi.dao.enumuration.cs.EscalationType;

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

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

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

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

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.repository.auth.MenuCategoryRepository;

import com.spice.profitmandi.dao.repository.auth.MenuRepository;

import com.spice.profitmandi.dao.repository.catalog.OfferMarginRepository;

import com.spice.profitmandi.dao.repository.catalog.OfferPartnerRepository;

import com.spice.profitmandi.dao.repository.catalog.OfferRepository;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import com.spice.profitmandi.service.PartnerInvestmentService;

import com.spice.profitmandi.service.PartnerStatsService;

import com.spice.profitmandi.service.authentication.RoleManager;

import com.spice.profitmandi.service.inventory.InventoryService;

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

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

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

@Controller

@Transactional(rollbackOn = Throwable.class)

public class DashboardController {

	private static final double ONE_LAC = 1 * 1000 * 100;

	private static final double TWO_LAC = 2 * 1000 * 100;

	private static final double FOUR_LAC = 4 * 1000 * 100;

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

	private String webApiHost;

	@Value("${web.api.scheme}")

	private String webApiScheme;

	@Value("${web.api.root}")

	private String webApiRoot;

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

	private int webApiPort;

	@Autowired

	private CookiesProcessor cookiesProcessor;

	@Autowired

	private PartnerStatsService partnerStatsService;

	@Autowired

	private MenuRepository menuRepository;

	@Autowired

	private MenuCategoryRepository menuCategoryRepository;

	@Autowired

	private CsService csService;

	@Autowired

	private PartnerTargetRepository partnerTargetRepository;

	@Autowired

	private ResponseSender<?> responseSender;

	@Autowired

	RetailerService retailerService;

	@Autowired

	private RoleManager roleManager;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Autowired

	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;

	@Autowired

	private PartnerInvestmentService partnerInvestmentService;

	@Autowired

	DocumentRepository documentRepository;

	@Autowired

	InventoryItemRepository inventoryItemRepository;

	@Autowired

	InventoryService inventoryService;

	@Autowired

	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;

	@Autowired

	private FofoOrderItemRepository fofoOrderItemRepository;

	@Autowired

	private TicketCategoryRepository ticketCategoryRepository;

	@Autowired

	private PartnerTypeChangeService partnerTypeChangeService;

	@Autowired

	private HygieneDataRepository hygieneDataRepository;

	@Autowired

	private UserCampaignRepository userCampaignRepository;

	@Autowired

	private PositionRepository positionRepository;

	@Autowired

	private PartnersPositionRepository partnerPositionRepository;

	@Autowired

	private UserAccountRepository userAccountRepository;

	@Autowired

	private NotificationCampaignRepository notificationCampaignRepository;

	@Autowired

	private Mongo mongoClient;

	@Autowired

	private AuthRepository authRepository;

	@Autowired

	private FofoOrderRepository fofoOrderRepository;

	@Autowired

	private Gson gson;

	@Autowired

	TicketRepository ticketRepository;

	@Autowired

	private LeadRepository leadRepository;

	@Autowired

	private OfferRepository offerRepository;

	@Autowired

	private OfferPartnerRepository offerPartnerRepository;

	@Autowired

	private OfferMarginRepository offerMarginRepository;

	private static final Logger LOGGER = LogManager.getLogger(DashboardController.class);

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

	public String dashboard1(HttpServletRequest request, Model model, @RequestParam int fofoId) throws Exception {

		boolean isAdmin = false;

		model.addAttribute("isAdmin", isAdmin);

		model.addAttribute("webApiHost", webApiHost);

		model.addAttribute("webApiPort", webApiPort);

		model.addAttribute("webApiScheme", webApiScheme);

		model.addAttribute("webApiRoot", webApiRoot);

		if (isAdmin) {

			return "dashboard1";

		}

		FofoStore fofoStore = null;

		try {

			CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);

			fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);

			if (!fofoStore.isActive()) {

				return "redirect:/login";

			}

			PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());

			model.addAttribute("partnerType", partnerType);

			model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));

			model.addAttribute("fofoStore", customRetailer);

			model.addAttribute("partnerType", partnerType);

			model.addAttribute("hasGift", hasGift(fofoId));

			model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);

			model.addAttribute("brandStockPrices", this.getBrandStockPrices(fofoId));

			model.addAttribute("salesMap", this.getSales(fofoId));

			model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(fofoId));

			// this.setInvestments

			//

			model.addAttribute("investments", this.getInvestments(fofoId));

			model.addAttribute("isInvestmentOk",

					partnerInvestmentService.isInvestmentOk(fofoId, 10, ProfitMandiConstants.CUTOFF_INVESTMENT));

		} catch (ProfitMandiBusinessException e) {

			LOGGER.error("FofoStore Code not found of fofoId {}", fofoId);

		}

		LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);

		LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);

		double currentMonthRating = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd)

				/ 2;

		double lastMonthRating = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd) / 2;

		double ratingTillDate = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd) / 2;

		model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);

		model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);

		model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);

		long hygieneCount = hygieneDataRepository.selectHygieneCount(fofoId, true, currentMonthStart, currentMonthEnd);

		long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(fofoId, false, currentMonthStart,

				currentMonthEnd);

		if (hygieneCount == 0 && invalidHygieneCount == 0) {

			invalidHygieneCount = 1;

		}

		model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));

		model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());

		model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());

		return "12dashboard34";

	}

	private Map<String, Object> getInvestments(int fofoId) throws Exception {

		Map<String, Object> investments = new LinkedHashMap<>();

		PartnerDailyInvestment investment = partnerInvestmentService.getInvestment(fofoId, 0);

		LocalDate currentMonthStart = LocalDate.now().withDayOfMonth(1);

		LocalDate yesterDate = LocalDate.now().minusDays(1);

		PartnerDailyInvestment yesterdayInvestment = partnerDailyInvestmentRepository.select(fofoId, yesterDate);

		if (yesterdayInvestment == null) {

			yesterdayInvestment = new PartnerDailyInvestment();

		}

		List<PartnerDailyInvestment> currentMonthInvestments = partnerDailyInvestmentRepository.selectAll(fofoId,

				currentMonthStart, currentMonthStart.withDayOfMonth(currentMonthStart.lengthOfMonth()));

		long okInvestmentDays = currentMonthInvestments.stream().filter(x -> x.getShortPercentage() <= 10)

				.collect(Collectors.counting());

		investments.put("today", investment.getTotalInvestment());

		investments.put("investment", investment);

		investments.put("inStock", investment.getInStockAmount());

		investments.put("minimum", investment.getMinInvestmentString());

		investments.put("short", investment.getShortPercentage());

		investments.put("activated_stock", investment.getActivatedStockAmount());

		investments.put("okDays", okInvestmentDays);

		return investments;

	}

	private Map<String, Object> getSales(int fofoId) {

		Map<String, Object> salesMap = new LinkedHashMap<>();

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

		int monthLength = LocalDate.now().lengthOfMonth();

		Double todaySale = fofoOrderItemRepository

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

		Double mtdSale = fofoOrderItemRepository

				.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId, false)

				.get(fofoId);

		Double lmtdSale = fofoOrderItemRepository

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

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

				.get(fofoId);

		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository

				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());

		if (partnerTargetDetails.isEmpty()) {

			partnerTargetDetails = partnerTargetRepository

					.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now().minusMonths(3));

		}

		PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId, LocalDate.now());

		int currentRate = (int) (mtdSale / curDate.getDayOfMonth());

		salesMap.put("requiredType", partnerType.next());

		float reqdAmount = partnerTypeChangeService.getMinimumAmount(partnerType.next());

		int requiredRate = (int) ((reqdAmount - mtdSale) / (monthLength - curDate.getDayOfMonth()));

		salesMap.put("requiredRate", requiredRate);

		salesMap.put("requiredTypeImage", PartnerType.imageMap.get(partnerType.next()));

		salesMap.put("todaySale", todaySale == null ? 0 : todaySale);

		salesMap.put("mtdSale", mtdSale == null ? 0 : mtdSale);

		salesMap.put("lmtdSale", lmtdSale == null ? 0 : lmtdSale);

		PartnerType currentType = partnerTypeChangeService.getPartnerTypeByAmount(mtdSale.floatValue());

		salesMap.put("currentRate", currentRate);

		salesMap.put("currentType", currentType);

		salesMap.put("currentTypeImage", PartnerType.imageMap.get(currentType));

		return salesMap;

	}

	private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws Exception {

		Map<String, BrandStockPrice> brandStockPricesMap = inventoryService.getBrandWiseStockValue(fofoId);

		List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);

		List<BrandStockPrice> brandStockPrices = new ArrayList<>();

		mobileBrands.stream().forEach(x -> {

			String brand = (String) x.get("name");

			if (brandStockPricesMap.containsKey(brand)) {

				BrandStockPrice brandStockPrice = brandStockPricesMap.get(brand);

				brandStockPrice.setBrandUrl((String) x.get("url"));

				brandStockPrice.setRank(((Double) x.get("rank")).intValue());

				brandStockPrices.add(brandStockPrice);

			}

		});

		return brandStockPrices.stream().filter(x -> x.getTotalQty() > 0).sorted((x, y) -> x.getRank() - y.getRank())

				.collect(Collectors.toList());

	}

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

	public String dashboard(HttpServletRequest request, Model model) throws Exception {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		String email = loginDetails.getEmailId();

		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());

		model.addAttribute("isAdmin", isAdmin);

		model.addAttribute("webApiHost", webApiHost);

		model.addAttribute("webApiPort", webApiPort);

		model.addAttribute("webApiScheme", webApiScheme);

		model.addAttribute("webApiRoot", webApiRoot);

		if (isAdmin) {

			return adminPanel(loginDetails.getFofoId(), email, model);

		} else {

			FofoStore fofoStore = null;

			try {

				fofoStore = fofoStoreRepository.selectByRetailerId(loginDetails.getFofoId());

				if (!fofoStore.isActive()) {

					return "redirect:/login";

				}

				PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());

				model.addAttribute("partnerType", partnerType);

				model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));

				model.addAttribute("fofoStore", fofoStore);

				model.addAttribute("partnerType", partnerType);

				model.addAttribute("hasGift", hasGift(loginDetails.getFofoId()));

				model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);

				model.addAttribute("retailers", new JSONObject().append("code", fofoStore.getCode())

						.append("partnerId", fofoStore.getId()).toString());

				model.addAttribute("activatedImeis",

						inventoryItemRepository.selectCountByActivatedNotSold(loginDetails.getFofoId()));

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

				Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository

						.selectSumSaleGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),

								curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));

				LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);

				Double accesoriesStock = currentInventorySnapshotRepository

						.selectSumStockGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),

								Optional.of(false))

						.get(loginDetails.getFofoId());

				model.addAttribute("accesoriesStock", String.format("%.0f", accesoriesStock));

				model.addAttribute("brandStockPrices", this.getBrandStockPrices(loginDetails.getFofoId()));

				model.addAttribute("salesMap", this.getSales(loginDetails.getFofoId()));

				ChartModel cm = this.getBrandChart(loginDetails.getFofoId());

				LOGGER.info("chartMap" + gson.toJson(cm));

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

				// this.setInvestments

				//

				model.addAttribute("investments", this.getInvestments(loginDetails.getFofoId()));

				model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(loginDetails.getFofoId(),

						10, ProfitMandiConstants.CUTOFF_INVESTMENT));

				// Hardcoded for valentine

				// Hardcoded for valentine

				/*List<Offer> offers = offerRepository.selectAllBeforeEndDate();

				if (!offers.isEmpty()) {

					List<CreateOfferRequest> cors = new ArrayList<>();

					for (Offer offer : offers) {

						List<OfferPartner> offerPartners = offerPartnerRepository.selectByOfferId(offer.getId());

						for (OfferPartner offerPartner : offerPartners) {

							if (offerPartner.getFofoId() == loginDetails.getFofoId()) {

								if (LocalDateTime.now().isAfter(offer.getStartDateTime())

										&& LocalDateTime.now().isBefore(offer.getEndDateTime())) {

									LocalDateTime cur = LocalDate.now().minusMonths(4).atStartOfDay();

									LOGGER.info("value" + cur);

									Map<Integer, Double> value = offerRepository.selectSumOfferByRetailer(

											offer.getStartDateTime(), offer.getEndDateTime(), loginDetails.getFofoId(),

											offer, true);

									CreateOfferRequest createOfferRequest = new CreateOfferRequest();

									List<Offermargin> offerMargins = offerMarginRepository

											.selectByOfferId(offer.getId());

									LOGGER.info("value" + offer.getId());

									LOGGER.info("value" + value);

									for (Offermargin om : offerMargins) {

										if (value.get(loginDetails.getFofoId()) <= om.getValue()) {

											createOfferRequest.setMargin(om.getMargin());

											createOfferRequest.setShortAmount(

													om.getValue() - value.get(loginDetails.getFofoId()));

											break;

										} else {

											createOfferRequest.setMargin(om.getMargin());

										}

									}

									createOfferRequest.setName(offer.getName());

									createOfferRequest.setDescription(offer.getDescription());

									createOfferRequest.setTargetType(offer.getTargetType());

									createOfferRequest.setAmountType(offer.getAmountType());

									createOfferRequest.setStartDate(offer.getStartDateTime());

									createOfferRequest.setEndDate(offer.getEndDateTime());

									createOfferRequest.setTotalSale(value.get(loginDetails.getFofoId()));

									cors.add(createOfferRequest);

									model.addAttribute("sales", value.get(loginDetails.getFofoId()));

								}

							}

						}

					}

					model.addAttribute("offers", cors);

				}*/

			} catch (ProfitMandiBusinessException e) {

				LOGGER.error("FofoStore Code not found of fofoId {}", loginDetails.getFofoId());

			}

		}

		LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);

		LocalDateTime lastMonthStart = currentMonthStart.minusMonths(1);

		LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);

		double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), currentMonthStart,

				currentMonthEnd) / 2;

		double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), lastMonthStart,

				currentMonthStart) / 2;

		double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), LocalDateTime.MIN,

				currentMonthEnd) / 2;

		model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);

		model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);

		model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);

		long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart,

				currentMonthEnd);

		long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false,

				currentMonthStart, currentMonthEnd);

		if (hygieneCount == 0 && invalidHygieneCount == 0) {

			invalidHygieneCount = 1;

		}

		model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));

		model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());

		model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());

		return "dashboard1";

	}

	private ChartModel getBrandChart(int fofoId) {

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

		LOGGER.info("cur Date" + curDate.withDayOfMonth(1));

		LOGGER.info("curDateYear" + curDate.with(LocalTime.MAX));

		Map<String, Double> brandwisesale = fofoOrderItemRepository

				.selectSumAmountGroupByBrand(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId);

		Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(

				fofoId, curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));

		LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);

		LOGGER.info("brandwisesale" + brandwisesale);

		Map<String, Double> lmtdBrandWiseSale = fofoOrderItemRepository.selectSumAmountGroupByBrand(

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

		Map<Integer, Double> accesorieslmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(

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

				Optional.of(false));

		LOGGER.info("accesorieslmtdsale" + accesorieslmtdsale);

		ChartModel cm = new ChartModel();

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

		labels.addAll(brandwisesale.keySet());

		labels.add("accessories");

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

		values.addAll(brandwisesale.values());

		values.addAll(accesoriesmtdsale.values());

		List<Double> lmtdValues = new ArrayList<>();

		lmtdValues.addAll(lmtdBrandWiseSale.values());

		lmtdValues.addAll(accesorieslmtdsale.values());

		DatasetModel dsm = new DatasetModel();

		dsm.setLabel("mtd sales");

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

		for (Entry<String, Double> bs : brandwisesale.entrySet()) {

			backgroundColor.add("#3e95cd");

		}

		backgroundColor.add("#3e95cd");

		dsm.setBackgroundColor(backgroundColor);

		dsm.setData(values);

		DatasetModel lmtddsm = new DatasetModel();

		lmtddsm.setLabel("lmtd sales");

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

		for (Entry<String, Double> bs : lmtdBrandWiseSale.entrySet()) {

			background.add("#8e5ea2");

		}

		background.add("#8e5ea2");

		lmtddsm.setBackgroundColor(background);

		lmtddsm.setData(lmtdValues);

		List<DatasetModel> datasets = new ArrayList<>();

		datasets.add(dsm);

		datasets.add(lmtddsm);

		DataModel dm = new DataModel();

		dm.setDatasets(datasets);

		dm.setLabels(labels);

		LegendModel lm = new LegendModel();

		lm.setDisplay(true);

		TitleModel tm = new TitleModel();

		tm.setText("Brand Wise Sale Graph");

		tm.setDisplay(true);

		OptionsModel om = new OptionsModel();

		om.setLegend(lm);

		om.setTitle(tm);

		cm.setType("bar");

		cm.setData(dm);

		cm.setOptions(om);

		return cm;

	}

	private String adminPanel(int fofoId, String email, Model model) throws Exception {

		List<Menu> menus = null;

		try {

			AuthUser authUser = authRepository.selectByEmailOrMobile(email);

			List<Position> positions = positionRepository.selectAll(authUser.getId());

			Map<Integer, AuthUser> authIdAndAuthUserMap = null;

			Map<Integer, PartnerDetailModel> 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));

					AuthUser dummyAuthUser = new AuthUser();

					dummyAuthUser.setFirstName("Total");

					dummyAuthUser.setLastName("Values");

					authIdAndAuthUserMap.put(0, dummyAuthUser);

					authIdAndallValues = this.getL2AuthUserPartnerDetail();

				}

			}

			if (Arrays.asList("amit.gupta@shop2020.in", "tejbeer.kaur@shop2020.in").contains(email)) {

				menus = menuRepository.selectAll();

			} else if (positions.size() > 0) {

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

					menus = menuRepository.selectAll();

				} else {

					List<Integer> menuIds = menuCategoryRepository.selectAllByPositions(positions).stream()

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

					LOGGER.info("Menu Ids are {}", menuIds);

					if (menuIds.size() > 0) {

						menus = menuRepository.selectAllByIds(menuIds);

					}

				}

				List<Position> salesPositions = positions.stream()

						.filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES)

						.collect(Collectors.toList());

				if (salesPositions.size() > 0) {

					Set<CustomRetailer> positionRetailers = new HashSet<>();

					csService.getPositionCustomRetailerMap(salesPositions).values().forEach(customRetailers -> {

						positionRetailers.addAll(customRetailers);

					});

					model.addAttribute("retailers", gson.toJson(positionRetailers));

					model.addAttribute("reporticoProjectMap", ReporticoProject.salesReporticoProjectMap);

					model.addAttribute("warehouses", getWarehouses(positionRetailers));

				}

				List<Position> warehousePositions = positions.stream()

						.filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_WAREHOUSE)

						.collect(Collectors.toList());

				if (warehousePositions.size() > 0) {

					Set<CustomRetailer> positionRetailers = new HashSet<>();

					csService.getPositionCustomRetailerMap(warehousePositions).values().forEach(customRetailers -> {

						positionRetailers.addAll(customRetailers);

					});

					model.addAttribute("reporticoProjectMap", ReporticoProject.warehouseReporticoMap);

					model.addAttribute("retailers", gson.toJson(positionRetailers));

					model.addAttribute("warehouses", getWarehouses(positionRetailers));

				}

				model.addAttribute("authId", authUser.getId());

			}

			model.addAttribute("authIdAndallValues", authIdAndallValues);

			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);

			LOGGER.info("authIdAndallValues1" + authIdAndallValues);

		} catch (ProfitMandiBusinessException e) {

		}

		List<Menu> menuList = (menus != null) ? this.prepareMenu(menus) : new ArrayList<>();

		LOGGER.info("menu" + menuList);

		model.addAttribute("menu", menuList);

		return "admin";

	}

	/*

	 * @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

	 * l1AuthId : 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(l1AuthId, LeadStatus.followUp)

	 * .stream().collect(Collectors.groupingBy(Lead::getAssignTo,

	 * Collectors.counting()));

	 * 

	 * AuthUser authUser = authRepository.selectById(l1AuthId);

	 * 

	 * authIdAndAuthUserMap.put(l1AuthId, authUser);

	 * 

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

	 * 

	 * Map<Integer, PartnerDailyInvestment> partnerInvestentMap =

	 * partnerInvestmentService .getInvestment(fofoIds,

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

	 * 

	 * for (Integer fId : fofoIds) { try { PartnerDailyInvestment investment =

	 * partnerInvestentMap.get(fId); totalTodayInvestment +=

	 * investment.getTotalInvestment(); totalStockInInvestment +=

	 * investment.getInStockAmount(); } catch (Exception e) { }

	 * 

	 * 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 (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(l1AuthId) != null) {

	 * pm.setLeads(leadCount.get(l1AuthId).intValue()); } else { pm.setLeads(0); }

	 * 

	 * pm.setInvestment(totalTodayInvestment);

	 * pm.setStockInInvestment(totalStockInInvestment);

	 * pm.setTicket(totalTicketCount); pm.setHygiene((double)

	 * Math.round(totalHygieneRating)); authIdAndallValues.put(l1AuthId, 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();

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

		Map<Integer, PartnerDetailModel> fofoIdAndallValues = partnerStatsService.getAllPartnerStats();

		if (authId != 0) {

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

			fofoIdAndallValues = fofoIdAndallValues.entrySet().stream().filter(x -> fofoIds.contains(x.getKey()))

					.collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));

		} else {

		}

		model.addAttribute("fofoIdAndallValues", fofoIdAndallValues);

		model.addAttribute("fofoIdAndPartnerMap", fofoIdAndPartnerMap);

		return "auth_user_partner_detail";

	}

	private String getWarehouses(Set<CustomRetailer> positionRetailers) {

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

		positionRetailers.stream().forEach(x -> {

			if (x.getWarehouseId() != 0) {

				warehouses.put(x.getWarehouseId(), ProfitMandiConstants.WAREHOUSE_MAP.get(x.getWarehouseId()));

			}

		});

		return gson.toJson(warehouses);

	}

	private List<Menu> prepareMenu(List<Menu> menus) {

		List<Menu> returnMenu = new ArrayList<>();

		Map<Menu, List<Menu>> subMenuMap = new HashMap<Menu, List<Menu>>();

		for (Menu menu : menus) {

			if (menu.get_parent() == null) {

				if (!subMenuMap.containsKey(menu)) {

					subMenuMap.put(menu, new ArrayList<>());

				}

			} else {

				Menu parentMenu = menu.get_parent();

				if (!subMenuMap.containsKey(parentMenu)) {

					subMenuMap.put(parentMenu, new ArrayList<>());

				}

				subMenuMap.get(parentMenu).add(menu);

			}

		}

		subMenuMap.entrySet().stream().forEach(entry -> {

			entry.getKey().setSubMenus(entry.getValue());

			returnMenu.add(entry.getKey());

		});

		return returnMenu;

	}

	// This method is currently hardcoded to faciliate watches sold as gift.

	private boolean hasGift(int fofoId) {

		try {

			return currentInventorySnapshotRepository.selectByItemIdAndFofoId(ProfitMandiConstants.GIFT_ID, fofoId)

					.getAvailability() > 0;

		} catch (ProfitMandiBusinessException e) {

			return false;

		}

	}

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

	public String contactUs(HttpServletRequest request, Model model) throws Throwable {

		model.addAttribute("appContextPath", request.getContextPath());

		return "contact-us";

	}

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

	public String getNotificationsWithType(HttpServletRequest request,

			@RequestParam(required = false) MessageType messageType,

			@RequestParam(name = "offset", defaultValue = "0") int offset,

			@RequestParam(name = "limit", defaultValue = "20") int limit, Model model) throws Exception {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		int userId = 0;

		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());

		if (isAdmin) {

			userId = loginDetails.getFofoId();

		} else {

			userId = userAccountRepository.selectUserIdByRetailerId(loginDetails.getFofoId());

		}

		List<Notification> notifications = null;

		List<NotificationCampaign> notificationCampaigns = notificationCampaignRepository.getNotifications(messageType,

				userId, offset, limit);

		LOGGER.info("messageType" + messageType);

		notifications = getNotifications(notificationCampaigns, messageType);

		model.addAttribute("notifications", notifications);

		LOGGER.info("notifications" + notifications);

		return "notification-template";

	}

	public List<Notification> getNotifications(List<NotificationCampaign> nc, MessageType messageType)

			throws ProfitMandiBusinessException {

		List<Notification> notifications = new ArrayList<>();

		Document document = null;

		if (messageType != null) {

			for (NotificationCampaign notificationCampaign : nc) {

				if (notificationCampaign.getMessageType() == messageType) {

					Notification ns = new Notification();

					SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),

							SimpleCampaignParams.class);

					Campaign campaign = new SimpleCampaign(scp);

					LocalDateTime expire = campaign.getExpireTimestamp();

					ns.setCid(Integer.toString(notificationCampaign.getId()));

					ns.setType(campaign.getType());

					ns.setMessage(campaign.getMessage());

					ns.setTitle(campaign.getTitle());

					if (notificationCampaign.getDocumentId() != null) {

						document = documentRepository.selectById(notificationCampaign.getDocumentId());

						ns.setDocumentName(document.getDisplayName());

					}

					ns.setUrl(campaign.getUrl());

					ns.setShowImage(campaign.getShowImage());

					ns.setImageUrl(campaign.getImageUrl());

					ns.setDocumentId(notificationCampaign.getDocumentId());

					ns.setMessageType(notificationCampaign.getMessageType());

					ns.setCreated(

							notificationCampaign.getCreatedTimestamp().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30))

									* 1000);

					if (LocalDateTime.now().isAfter(expire)) {

						ns.setExpired(true);

					} else {

						ns.setExpired(false);

					}

					notifications.add(ns);

				}

			}

		} else {

			for (NotificationCampaign notificationCampaign : nc) {

				Notification ns = new Notification();

				SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),

						SimpleCampaignParams.class);

				Campaign campaign = new SimpleCampaign(scp);

				LocalDateTime expire = campaign.getExpireTimestamp();

				ns.setCid(Integer.toString(notificationCampaign.getId()));

				ns.setType(campaign.getType());

				ns.setMessage(campaign.getMessage());

				ns.setTitle(campaign.getTitle());

				if (notificationCampaign.getDocumentId() != null) {

					document = documentRepository.selectById(notificationCampaign.getDocumentId());

					ns.setDocumentName(document.getDisplayName());

				}

				ns.setUrl(campaign.getUrl());

				ns.setShowImage(campaign.getShowImage());

				ns.setImageUrl(campaign.getImageUrl());

				ns.setDocumentId(notificationCampaign.getDocumentId());

				ns.setMessageType(notificationCampaign.getMessageType());

				ns.setCreated(notificationCampaign.getCreatedTimestamp().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30))

						* 1000);

				if (LocalDateTime.now().isAfter(expire)) {

					ns.setExpired(true);

				} else {

					ns.setExpired(false);

				}

				notifications.add(ns);

			}

		}

		return notifications;

	}

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

	public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,

			@RequestParam(name = ProfitMandiConstants.DOCUMENT_ID) int documentId, @RequestParam int cid)

			throws ProfitMandiBusinessException {

		Document document = documentRepository.selectById(documentId);

		NotificationCampaign nc = notificationCampaignRepository.selectById(cid);

		if (nc.getDocumentId() == null) {

			throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");

		}

		if (nc.getDocumentId() != documentId) {

			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, documentId, "RTLR_1014");