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

 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.cglib.core.Local;
 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 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 ONE_LAC = 1 * 1000 * 100;
-	private static final double TWO_LAC = 2*1000*100;
+	private static final double TWO_LAC = 2 * 1000 * 100;
-	private static final double FOUR_LAC = 4*1000*100;
+	private static final double FOUR_LAC = 4 * 1000 * 100;
 	@Value("${web.api.host}")
 	private String webApiHost;
 	@Value("${web.api.scheme}")
 	@Value("${web.api.port}")
 	private int webApiPort;
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
+	@Autowired
+	private PartnerStatsService partnerStatsService;
 	@Autowired
 	private MenuRepository menuRepository;
 	@Autowired
 				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";
+	}
 				.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
 				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",
-				model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(loginDetails.getFofoId()));
+						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);
 				// this.setInvestments
 				//
 				model.addAttribute("investments", this.getInvestments(loginDetails.getFofoId()));
 				model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(loginDetails.getFofoId(),
 , ProfitMandiConstants.CUTOFF_INVESTMENT));
-				//Hardcoded for valentine
+				// Hardcoded for valentine
-				//Hardcoded for valentine
+				// Hardcoded for valentine
-				if(LocalDate.now().isBefore(LocalDate.of(2020, 3, 11))) {
+				if (LocalDate.now().isBefore(LocalDate.of(2020, 3, 11))) {
+					double valentineSales = fofoOrderItemRepository
-					double valentineSales = fofoOrderItemRepository.selectSumAmountGroupByRetailer(LocalDate.of(2020, 3, 6).atStartOfDay(),
+							.selectSumAmountGroupByRetailer(LocalDate.of(2020, 3, 6).atStartOfDay(),
-							LocalDate.of(2020, 3, 10).atStartOfDay(), loginDetails.getFofoId(), false).get(loginDetails.getFofoId());
+									LocalDate.of(2020, 3, 10).atStartOfDay(), loginDetails.getFofoId(), false)
+							.get(loginDetails.getFofoId());
-					if(valentineSales < ONE_LAC) {
+					if (valentineSales < ONE_LAC) {
 						model.addAttribute("valentineSale", "ONE_LAC");
 						model.addAttribute("valentineShort", ONE_LAC - valentineSales);
-					} else if(valentineSales < TWO_LAC) {
+					} else if (valentineSales < TWO_LAC) {
 						model.addAttribute("valentineSale", "TWO_LAC");
 						model.addAttribute("valentineShort", TWO_LAC - valentineSales);
 					} else if (valentineSales < FOUR_LAC) {
 						model.addAttribute("valentineSale", "FOUR_LAC");
 						model.addAttribute("valentineShort", FOUR_LAC - valentineSales);
 		List<Menu> menus = null;
 		try {
 			AuthUser authUser = authRepository.selectByEmailOrMobile(email);
 			List<Position> positions = positionRepository.selectAll(authUser.getId());
 			Map<Integer, AuthUser> authIdAndAuthUserMap = null;
-			Map<Integer, Object> authIdAndallValues = 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));
 					authIdAndallValues = this.getL2AuthUserPartnerDetail();
-					LOGGER.info("authIdAndallValues" + authIdAndallValues);
+				}
+			}
 			if (Arrays.asList("amit.gupta@shop2020.in", "tejbeer.kaur@shop2020.in").contains(email)) {
 				menus = menuRepository.selectAll();
 		LOGGER.info("menu" + menuList);
 		model.addAttribute("menu", menuList);
 		return "admin";
+	}
-	@RequestMapping(value = "/getL1AuthUser", method = RequestMethod.GET)
+/*	@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();
 			authIdAndAuthUserMap.put(l1AuthId, authUser);
 			List<Integer> fofoIds = pp.get(l1AuthId);
-			Map<Integer, PartnerDailyInvestment> partnerInvestentMap = partnerInvestmentService.getInvestment(fofoIds, 0).stream()
+			Map<Integer, PartnerDailyInvestment> partnerInvestentMap = partnerInvestmentService
-					.collect(Collectors.toMap(x->x.getFofoId(), x->x));
+					.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) {
+				} catch (Exception e) {
+				}
 				double currentMonthRating = hygieneDataRepository.selectRatingAvg(fId,
 						curDate.withDayOfMonth(1).minusMonths(1), curDate.plusMonths(1).withDayOfMonth(1));
 		model.addAttribute("authIdAndallValues", authIdAndallValues);
 		model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
 		LOGGER.info("authIdAndallValues" + authIdAndallValues);
 		return "auth_user_detail";
-	}
+	}*/
-	@RequestMapping(value = "/getAuthUserPartners", method = RequestMethod.GET)
+/*	@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);
 		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) {
 		headers.set("Content-disposition", "inline; filename=" + document.getName());
 		headers.setContentLength(document.getSize());
 		final InputStreamResource inputStreamResource = new InputStreamResource(file);
 		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
+	}
-	public Map<Integer, Object> getL2AuthUserPartnerDetail() throws Exception {
+	public Map<Integer, PartnerDetailModel> getL2AuthUserPartnerDetail() throws Exception {
 		List<Position> pos = positionRepository.selectPositionbyCategoryIdAndEscalationType(
 				ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L2);
 		LOGGER.info("getL2AuthUserPartnerDetail Started");
-		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>> pp = csService.getAuthUserIdPartnerIdMapping();
+		Map<Integer, List<Integer>> L2L1Mapping = csService.getL2L1Mapping();
-		Map<Integer, Long> ticketMap = ticketRepository.selectAllNotClosedTicketsGroupByRetailer();
 		Map<Integer, Integer> authIdAndleadsCountMap = new HashMap<>();
-		Map<Integer, List<Integer>> L2L1Mapping = csService.getL1L2Mapping();
 		for (Entry<Integer, List<Integer>> l2l1 : L2L1Mapping.entrySet()) {
 			List<Integer> authIds = l2l1.getValue();
 			authIds.add(l2l1.getKey());
 			List<Lead> leads = leadRepository.selectByAssignAuthIdsAndStatus(authIds, LeadStatus.followUp);
 			} else {
 				authIdAndleadsCountMap.put(auth.getId(), 0);
+			}
+		}
-		LOGGER.info("authIdAndleadsCountMap" + authIdAndleadsCountMap);
+		Map<Integer, PartnerDetailModel> partnerStats = partnerStatsService.getAllPartnerStats();
-		Map<Integer, Object> authIdAndallValues = new LinkedHashMap<>();
-		for (Position po : pos) {
-			double totallmtdAmount = 0;
-			double totalmtdAmount = 0;
-			int totalTicketCount = 0;
-			float totalTodayInvestment = 0;
-			float totalStockInInvestment = 0;
-			double currentMonthRatingAllPartners = 0;
-			AuthUser auth = authRepository.selectById(po.getAuthUserId());
-			LOGGER.info("Auth User {}", auth);
-			List<Integer> fofoIds = pp.get(po.getAuthUserId());
-			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("authIdAndleadsCountMap" + authIdAndleadsCountMap);
-				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("authIdAndleadsCountMap" + authIdAndleadsCountMap.get(po.getAuthUserId()));
+		Map<Integer, PartnerDetailModel> authIdAndallValues = new LinkedHashMap<>();
-			PartnerDetailModel pm = new PartnerDetailModel();
+		Map<Integer, List<Integer>> pp = csService.getAuthUserIdPartnerIdMapping();
-			pm.setLmtd(totallmtdAmount);
+		for (int authUserId : pp.keySet()) {
-			pm.setMtd(totalmtdAmount);
+			if (L2L1Mapping.keySet().contains(authUserId)) {
-			if(authIdAndleadsCountMap.get(po.getAuthUserId())!= null) {
+				List<Integer> fofoIds = pp.get(authUserId);
+				List<PartnerDetailModel> partnerDetails = fofoIds.stream().map(x->partnerStats.get(x)).collect(Collectors.toList());
+				PartnerDetailModel partnerDetailModel = partnerStatsService.getAggregateStats(partnerDetails);
-			pm.setLeads(authIdAndleadsCountMap.get(po.getAuthUserId()));
+				authIdAndallValues.put(authUserId, partnerDetailModel);
+			}
-			pm.setInvestment(totalTodayInvestment);
-			pm.setStockInInvestment(totalStockInInvestment);
-			pm.setTicket(totalTicketCount);
-			pm.setHygiene((double) Math.round(totalHygieneRating));
-			authIdAndallValues.put(auth.getId(), pm);
+		}
+		PartnerDetailModel partnerDetailModel = partnerStatsService.getAggregateStats(new ArrayList<>(partnerStats.values()));
+		authIdAndallValues.put(0, partnerDetailModel);
 		return authIdAndallValues;
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/DashboardController.java – Rev 26458 → 26460