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

 package com.spice.profitmandi.web.controller;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
-import java.text.DecimalFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.ZoneOffset;
 import java.util.ArrayList;
 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.MediaType;
 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.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.BrandStockPrice;
 import com.spice.profitmandi.common.model.Notification;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
-import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.Interface.Campaign;
 import com.spice.profitmandi.dao.entity.dtr.Document;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
-import com.spice.profitmandi.dao.entity.dtr.Retailer;
 import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
-import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
-import com.spice.profitmandi.dao.entity.fofo.HygieneData;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
-import com.spice.profitmandi.dao.entity.fofo.PartnerTarget;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
-import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
-import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
-import com.spice.profitmandi.dao.repository.dtr.InsuranceProviderRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
-import com.spice.profitmandi.dao.repository.dtr.NotificationPanelRepository;
-import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
 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.HygieneDataRepository;
 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.dao.repository.fofo.TargetSlabRepository;
-import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.authentication.RoleManager;
-import com.spice.profitmandi.service.inventory.InventoryService;
-import com.spice.profitmandi.service.slab.TargetSlabService;
-import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
-import com.spice.profitmandi.web.util.MVCResponseSender;
 @Controller
 @Transactional(rollbackOn = Throwable.class)
 public class DashboardController {
 	@Autowired
 	private CookiesProcessor cookiesProcessor;
 	@Autowired
-	private ResponseSender<?> responseSender;
-	@Autowired
-	private ItemRepository itemRepository;
-	@Autowired
-	private TargetSlabService targetSlabService;
-	@Autowired
 	private PartnerTargetRepository partnerTargetRepository;
 	@Autowired
-	private TargetSlabRepository targetSlabRepository;
+	private ResponseSender<?> responseSender;
 	@Autowired
 	private RoleManager roleManager;
 	@Autowired
 	@Autowired
 	private PartnerInvestmentService partnerInvestmentService;
 	@Autowired
-	private InsurancePolicyRepository insurancePolicyRepository;
-	/*
-	 * @Autowired private ScanRepository scanRepository;
+	DocumentRepository documentRepository;
-	 */
-	@Autowired
-	private RechargeTransactionRepository rechargeTransactionRepository;
-	@Autowired
-	private TransactionService transactionService;
-	@Autowired
-	private InventoryService inventoryService;
-	@Autowired
-	private MVCResponseSender mvcResponseSender;
-	@Autowired
-	private NotificationPanelRepository notificationPanelRepository;
 	@Autowired
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	@Autowired
 	private FofoOrderItemRepository fofoOrderItemRepository;
 	@Autowired
-	private InsuranceProviderRepository insuranceProviderRepository;
-	@Autowired
 	private PartnerTypeChangeService partnerTypeChangeService;
 	@Autowired
 	private HygieneDataRepository hygieneDataRepository;
 	@Autowired
 	private NotificationCampaignRepository notificationCampaignRepository;
 	@Autowired
-	private DocumentRepository documentRepository;
-	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private Gson gson;
 		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();
-		List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectBetweenCreatedTime(fofoId, curDate,
+		float todaySale = fofoOrderItemRepository.selectSumBetweenCreatedTime(fofoId, curDate,
 				curDate.with(LocalTime.MAX));
-		List<FofoOrderItem> mtdFofoOrderItems = fofoOrderItemRepository.selectBetweenCreatedTime(fofoId,
+		float mtdSale = fofoOrderItemRepository.selectSumBetweenCreatedTime(fofoId, curDate.withDayOfMonth(1),
-				curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
+				curDate.with(LocalTime.MAX));
-		double todaySale = fofoOrderItems.stream()
+		float lmtdSale = fofoOrderItemRepository.selectSumBetweenCreatedTime(fofoId,
-				.collect(Collectors.summingDouble(x -> x.getSellingPrice() * x.getQuantity()));
-		double mtdSale = mtdFofoOrderItems.stream()
-				.collect(Collectors.summingDouble(x -> x.getSellingPrice() * x.getQuantity()));
+				curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
 		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
 				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
 		if (partnerTargetDetails.isEmpty()) {
 			partnerTargetDetails = partnerTargetRepository
-					.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now().minusMonths(2));
+					.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now().minusMonths(3));
+		}
-		List<Integer> targetIds = partnerTargetRepository
-				.selectAllPartnerTargetForPartner(fofoId,
-						partnerTargetDetails.stream().map(x -> x.getId()).collect(Collectors.toList()))
-				.stream().map(x -> x.getTargetId()).collect(Collectors.toList());
-		if (targetIds.size() > 0) {
-			PartnerTarget target = partnerTargetRepository.selectAllPartnerTargetForPartner(fofoId, targetIds).get(0);
+		PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId, LocalDate.now());
-			double targetValue = (double) target.getTargetValue();
+		int currentRate = (int) (mtdSale / monthLength);
-			int remainingDays = monthLength - curDate.getDayOfMonth() + 1;
+		salesMap.put("requiredType", partnerType.next());
-			// Should not consider today's sale while evaluating today's target.
+		float reqdAmount = partnerTypeChangeService.getMinimumAmount(partnerType.next());
-			double todayTargetValue = Math.round((targetValue - (mtdSale - todaySale)) / remainingDays);
+		int requiredRate = (int) ((reqdAmount - mtdSale) / (monthLength - curDate.getDayOfMonth()));
-			DecimalFormat df = new DecimalFormat("#.##");
-			String targetValueString = df.format(targetValue / 100000) + "Lac";
-			salesMap.put("todayTarget", todayTargetValue);
+		salesMap.put("requiredRate", requiredRate);
-			salesMap.put("monthTarget", targetValueString);
+		salesMap.put("requiredTypeImage", PartnerType.imageMap.get(partnerType.next()));
-		} else {
-			salesMap.put("todayTarget", 0d);
-			salesMap.put("monthTarget", 0d);
-		}
 		salesMap.put("todaySale", todaySale);
 		salesMap.put("mtdSale", mtdSale);
+		salesMap.put("lmtdSale", lmtdSale);
+		PartnerType currentType = partnerTypeChangeService.getPartnerTypeByAmount(currentRate * monthLength);
+		salesMap.put("currentRate", currentRate);
+		salesMap.put("currentType", currentType);
+		salesMap.put("currentTypeImage", PartnerType.imageMap.get(currentType));
 		return salesMap;
+	}
 	/*
 	 * private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws
 	 * 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, @RequestParam(name = "offset", defaultValue = "0") int offset,
+	public String dashboard(HttpServletRequest request, Model model) throws Exception {
-			@RequestParam(name = "limit", defaultValue = "20") int limit, Model model) throws Exception {
 		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
 		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
 		model.addAttribute("isAdmin", isAdmin);
 		FofoStore fofoStore = null;
+				}
 				LOGGER.info("partnerType {}", partnerType);
 				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);
+			}
+		}
 		LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);
-		List<HygieneData> hygieneData = hygieneDataRepository
+		LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);
+		double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), currentMonthStart,
+				currentMonthEnd);
+		double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), currentMonthStart,
+				currentMonthEnd);
-				.selectAll(loginDetails.getFofoId(), currentMonthStart,
+		double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), currentMonthStart,
+				currentMonthEnd);
+		model.addAttribute("currentMonthRating", currentMonthRating);
-						LocalDateTime.now().plusMonths(1).withDayOfMonth(1))
+		model.addAttribute("lastMonthRating", lastMonthRating);
-				.stream().filter(x -> x.getDisposedTimestamp() != null).collect(Collectors.toList());
+		model.addAttribute("ratingTillDate", ratingTillDate);
+		long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart,
-		LOGGER.info("hygieneData" + hygieneData);
+				currentMonthEnd);
-		int successHygieneData = hygieneData.stream().filter(x -> x.getHygieneRating() == true)
+		long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false,
-				.collect(Collectors.toList()).size();
+				currentMonthStart, currentMonthEnd);
-		int unsuccessfullHygieneData = hygieneData.stream().filter(x -> x.getHygieneRating() == false)
+		if (hygieneCount == 0 && invalidHygieneCount == 0) {
-				.collect(Collectors.toList()).size();
+			invalidHygieneCount = 1;
+		}
-		model.addAttribute("successHygieneData", successHygieneData);
-		model.addAttribute("fullHygieneData", successHygieneData + unsuccessfullHygieneData);
+		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";
+	}
+				}
+			}
+		}
 		model.addAttribute("notifications", notifications);
+		LOGGER.info("notifications" + notifications);
 		return "notification-template";
+	}
 	@RequestMapping(value = "/notifyDocument/documentId", method = RequestMethod.GET)
 	public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,
 		headers.set("Content-Type", contentType);
 		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);
-		// return
-		// responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
+	}
+}

Subversion Repositories SmartDukaan

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