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.time.format.DateTimeFormatter;

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.catalog.Item;

import com.spice.profitmandi.dao.entity.catalog.Offer;

import com.spice.profitmandi.dao.entity.catalog.OfferPartner;

import com.spice.profitmandi.dao.entity.catalog.Offermargin;

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.fofo.PartnerTypeChange;

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

import com.spice.profitmandi.dao.enumuration.catalog.ItemCriteriaType;

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

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

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

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

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

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.model.WarehouseWiseBrandStockModel;

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

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

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.ItemRepository;

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.PartnerTypeChangeRepository;

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

import com.spice.profitmandi.dao.repository.inventory.SaholicInventorySnapshotRepository;

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 PartnerTypeChangeRepository partnerTypeChangeRepository;

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

	@Autowired

	private ItemRepository itemRepository;

	@Autowired

	private SaholicInventorySnapshotRepository saholicInventorySnapshotRepository;

	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

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

		Double mtdSale = fofoOrderItemRepository

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

				.get(fofoId);

		Double lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(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(currentRate * monthLength);

		salesMap.put("currentRate", currentRate);

		salesMap.put("currentType", currentType);

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

		return salesMap;

	}

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

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

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		int fofoId = loginDetails.getFofoId();

		Map<Integer, MonthSaleModel> monthSaleMap = new HashMap<>();

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

		int dayOfMonth = curDate.getDayOfMonth();

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

			LocalDateTime startOfMonth = curDate.withDayOfMonth(1).minusMonths(i);

			double monthSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth,

					startOfMonth.plusMonths(1), loginDetails.getFofoId(), false).get(fofoId);

			double mtdSales = fofoOrderItemRepository.selectSumMopGroupByRetailer(startOfMonth,

					startOfMonth.plusDays(dayOfMonth), loginDetails.getFofoId(), false).get(fofoId);

			PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId, startOfMonth.toLocalDate());

			MonthSaleModel ms = new MonthSaleModel();

			ms.setMtdSales(this.format((long) mtdSales));

			ms.setMonthlySales(this.format(((long) monthSales)));

			ms.setPartnerType(partnerType);

			ms.setMonth(startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));

			monthSaleMap.put(i, ms);

		}

		model.addAttribute("monthSales", monthSaleMap);

		return "monthSales";

	}

	private String format(long value) {

		String finalval = null;

		if (value >= 100000 && value < 10000000) {

			long reminder = value / 100000;

			long quitonent = value % 100000;

			finalval = reminder + "." + quitonent;

			String secondval = String.valueOf(quitonent);

			if (secondval.length() >= 2) {

				secondval = secondval.substring(0, 2);

				finalval = reminder + "." + secondval;

			}

			return String.valueOf(finalval) + " Lacs";

		} else if (value >= 1000 && value < 100000) {

			long reminder = value / 1000;

			long quitonent = value % 1000;

			finalval = reminder + "." + quitonent;

			String secondval = String.valueOf(quitonent);

			if (secondval.length() >= 2) {

				secondval = secondval.substring(0, 2);

				finalval = reminder + "." + secondval;

			}

			return String.valueOf(finalval) + " K";

		} else if (value >= 10000000 && value < 1000000000) {

			long reminder = value / 10000000;

			long quitonent = value % 10000000;

			finalval = reminder + "." + quitonent;

			String secondval = String.valueOf(quitonent);

			if (secondval.length() >= 2) {

				secondval = secondval.substring(0, 2);

				finalval = reminder + "." + secondval;

			}

			return String.valueOf(finalval) + " Cr";

		}

		return String.valueOf(finalval);

	}

	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.selectOfferByStatus(true);

				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())) {

								 */

								int todayMonth = LocalDateTime.now().getMonthValue();

								if (todayMonth == offer.getStartDateTime().getMonthValue()

										|| todayMonth == offer.getEndDateTime().getMonthValue()) {

									LocalDateTime cur = LocalDate.now().minusMonths(2).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.setValue(om.getValue());

											createOfferRequest.setShortAmount(

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

											break;

										} else {

											createOfferRequest.setMargin(om.getMargin());

										}

									}

									createOfferRequest.setId(offer.getId());

									createOfferRequest.setName(offer.getName());

									createOfferRequest.setDescription(offer.getDescription());

									createOfferRequest.setTargetType(offer.getTargetType());

									createOfferRequest.setAmountType(offer.getAmountType());

									createOfferRequest.setStartDateTime(offer.getStartDateTime().toLocalDate());

									createOfferRequest.setEndDateTime(offer.getEndDateTime().toLocalDate());

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

									createOfferRequest.setOfferMargin(offerMargins);

									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());

		if (loginDetails.isReadOnly()) {

			return "dashboard-readonly";

		} else {

			return "dashboard1";

		}

	}

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

	public String getOfferMargins(HttpServletRequest request,

			@RequestParam(name = "offerId", defaultValue = "0") int offerId, Model model) throws Exception {

		Offer offer = offerRepository.selectById(offerId);

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

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

				offer.getEndDateTime(), 0, offer, true);

		LOGGER.info("value" + value);

		List<Offermargin> offerMargin = offerMarginRepository.selectByOfferId(offerId);

		ItemTypeParams scp = gson.fromJson(offer.getItemParam(), ItemTypeParams.class);

		if (offer.getItemCriteria().equals(ItemCriteriaType.Multiple_Brand)) {

			List<String> brands = scp.getBrands();

			model.addAttribute("brands", brands);

		}

		if (offer.getItemCriteria().equals(ItemCriteriaType.Item_Model)) {

			List<Integer> catalogIds = scp.getCatalogId();

			List<Item> newList = new ArrayList<>();

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

			List<Item> items = itemRepository.selectAllByCatalogIds(catalogIds.stream().collect(Collectors.toSet()));

			for (Item item : items) {

				if (catalogId.add(item.getCatalogItemId())) {

					newList.add(item);

				}

			}

			model.addAttribute("items", newList);

		}

		model.addAttribute("offerMargin", offerMargin);

		model.addAttribute("offer", offer);

		return "offer_margin_detail_partner";

	}

	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, WarehouseWiseStockModel> warehouseStockMap = new HashMap<>();

			Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;

			Map<Integer, PartnerDetailModel> authIdAndallValues = null;

			if (positions.size() > 0) {

				if (positions.stream()

						.filter(x -> x.getEscalationType().equals(EscalationType.L3)

								|| x.getEscalationType().equals(EscalationType.L4)

								|| x.getEscalationType().equals(EscalationType.L5))

						.count() > 0) {

					authIdAndAuthUserMap = authRepository.selectAllActiveUser().stream()

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

					AuthUser unmappedAuthUser = new AuthUser();

					unmappedAuthUser.setFirstName("Unmapped");

					unmappedAuthUser.setLastName("Partners");

					authIdAndAuthUserMap.put(-1, unmappedAuthUser);

					AuthUser dummyAuthUser = new AuthUser();

					dummyAuthUser.setFirstName("Total");

					dummyAuthUser.setLastName("Values");

					authIdAndAuthUserMap.put(0, dummyAuthUser);

					warehouseStockMap = saholicInventorySnapshotRepository.selectGroupByWarehouse().stream()

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

					LOGGER.info("warehouseStockMap" + warehouseStockMap);

					authIdAndallValues = this.getL2AuthUserPartnerDetail();

				}

			}

			if (Arrays.asList("amit.gupta@shop2020.in", "tejbeer.kaur@shop2020.in", "manish.tiwari@smartdukaan.com")

					.contains(email)) {

				menus = menuRepository.selectAll();

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

				if (positions.stream().filter(x -> x.getEscalationType().equals(EscalationType.L5)).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);

			model.addAttribute("warehouseMap", warehouseMap);

			model.addAttribute("warehouseStockMap", warehouseStockMap);

		} 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(false);

		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";

	}

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

	public String getWarehouseWiseBrandStock(HttpServletRequest request, Model model, @RequestParam int warehouseId)

			throws Exception {