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

 package com.spice.profitmandi.web.controller;
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
-import java.util.TreeMap;
-import java.util.function.Predicate;
-import java.util.stream.Collectors;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.transaction.Transactional;
-import org.apache.commons.collections.map.HashedMap;
-import org.apache.commons.csv.CSVRecord;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.jsoup.select.Evaluator.IsEmpty;
-import org.springframework.beans.factory.annotation.Autowired;
-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.util.StringUtils;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RequestPart;
-import org.springframework.web.multipart.MultipartFile;
 import com.google.gson.Gson;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.CustomRetailer;
-import com.spice.profitmandi.common.model.Legend;
+import com.spice.profitmandi.common.model.*;
-import com.spice.profitmandi.common.model.OptionModel;
-import com.spice.profitmandi.common.model.PieLables;
-import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
-import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
 import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
-import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadSource;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
-import com.spice.profitmandi.dao.model.ChartLeadModel;
-import com.spice.profitmandi.dao.model.CreateLeacdActivityRequest;
-import com.spice.profitmandi.dao.model.CreateRefferalRequest;
-import com.spice.profitmandi.dao.model.DataLeadModel;
+import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.DateRangeModel;
-import com.spice.profitmandi.dao.model.LeadStatusData;
-import com.spice.profitmandi.dao.model.PartnerCollectionAchievementModel;
-import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
-import com.spice.profitmandi.dao.model.TeamCommitmentModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
-import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
-import com.spice.profitmandi.dao.repository.dtr.FranchiseeActivityRepository;
-import com.spice.profitmandi.dao.repository.dtr.FranchiseeVisitRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
+import com.spice.profitmandi.dao.repository.dtr.*;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.inventory.StateRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.service.AuthService;
 import com.spice.profitmandi.service.PartnerCollectionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.web.model.LoginDetails;
 import com.spice.profitmandi.web.util.CookiesProcessor;
 import com.spice.profitmandi.web.util.MVCResponseSender;
+import org.apache.commons.csv.CSVRecord;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+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.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.transaction.Transactional;
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+import java.util.Map.Entry;
+import java.util.stream.Collectors;
 @Controller
 @Transactional(rollbackOn = Throwable.class)
 public class LeadController {
 	private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
 		ChartLeadModel cm = new ChartLeadModel();
 		HashSet<LeadStatus> labels = new HashSet<LeadStatus>();
 		labels.addAll(leadStatusMap.keySet());
-		HashSet<String> hotLeads = new HashSet<String>();
+		List<String> hotLeads = new ArrayList<>();
 		hotLeads.addAll(leadStatusMap.keySet().stream().map(x -> x.toString()).collect(Collectors.toSet()));
 		hotLeads.add("HotLead");
-		HashSet<String> hotLeadKeys = new HashSet<String>();
+		List<String> hotLeadKeys = new ArrayList<>();
 		hotLeadKeys.add("HotLead");
 		List<String> hotLeadGreen = new ArrayList<>(hotLeadKeys);
 		LOGGER.info("hotLeads" + hotLeads);
+		}
 		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
 		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
-		Set<Integer> fofoIds = storeGuyMap.get(email);
+		List<Integer> fofoIds = new ArrayList<>(storeGuyMap.get(email));
 		LocalDateTime startDate = LocalDate.now().atStartOfDay();
-		if (fofoIds.size() > 0 && fofoIds != null) {
+		if (fofoIds != null && fofoIds.size() > 0) {
-			List<Integer> fofoIdl = new ArrayList<>(fofoIds);
-			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIdl).stream()
+			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()
 					.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
 			Map<Integer, PartnerCollectionPlanModel> foundCollectionMap = partnerCollectionService
 					.getCollectionMap(fofoIdList, startDate);
 		Map<Integer, Long> rankCount = pcpm.stream().collect(Collectors.groupingBy(x -> x.getRank(),
 				Collectors.mapping(PartnerCollectionPlanModel::getRank, Collectors.counting())));
 		ChartLeadModel cm = new ChartLeadModel();
-		HashSet<String> labels = new HashSet<String>();
+		List<String> labels = new ArrayList<>();
 		labels.add("Plan for Today");
 		labels.add("Carry Forward");
 		labels.add("Untouched");
 		labels.add("Plan for Future");
 		labels.add("Normal");
 		return "franchie-visit-detail";
+	}
+	@RequestMapping(value = "/indent/today_target", method = RequestMethod.GET)
+	public String todayTarget(HttpServletRequest request, Model model) throws Exception {
+		//model.addAttribute("warehouseCollectionMap", warehouseCollectionMap);
+		List<RBMPerformanceSummaryModel> summaryModels = new ArrayList<>();
+		List<Integer> rbmPositionsAuthIds = positionRepository
+				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()
+				.map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());
+		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+		List<TeamCommitmentModel> teamCommitmentModels = partnerCollectionPlanRepository.selectTeamCommitmentByDate(LocalDate.now());
+		Map<Integer, TeamCommitmentModel> rbmCommittmentMap = teamCommitmentModels.stream().filter(x -> rbmPositionsAuthIds.contains(x.getAuthId())).collect(Collectors.toMap(x -> x.getAuthId(), x -> x));
+		LocalDateTime startDate = LocalDate.now().atStartOfDay();
+		for (int rbmAuthId : rbmPositionsAuthIds) {
+			RBMPerformanceSummaryModel rbmPerformanceSummaryModel = new RBMPerformanceSummaryModel();
+			rbmPerformanceSummaryModel.setAuthId(rbmAuthId);
+			AuthUser authUser = authRepository.selectById(rbmAuthId);
+			rbmPerformanceSummaryModel.setAuthName(authUser.getFullName());
+			List<Integer> fofoIds = new ArrayList<>(storeGuyMap.get(authUser.getEmailId()));
+			if (fofoIds.size() > 0) {
+				fofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()
+						.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
+				/*Map<Integer, PartnerCollectionPlanModel> foundCollectionMap = partnerCollectionService
+						.getCollectionMap(fofoIds, startDate);*/
+				List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIds);
+				LOGGER.info("remarkIds {}", remarkIds);
+				long todayOverallCall = 0;
+				if (!remarkIds.isEmpty()) {
+					todayOverallCall = partnerCollectionRemarkRepository.selectByIds(remarkIds).stream()
+							.filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
+							.collect(Collectors.counting());
+				}
+				Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService
+						.getCollectionMap(fofoIds, startDate);
+				ChartLeadModel cm = this
+						.getCollectionCount(collectionMap.values().stream().collect(Collectors.toList()));
+				long collectionTarget = collectionMap.values().stream().filter(x -> x.getTargetPlan() != null).collect(Collectors.summingLong(x -> x.getTargetPlan()));
+				long collection = collectionMap.values().stream().filter(x -> x.getTargetPlan() != null && x.getTargetPlan() != 0 && x.getAchievementPlan() != null).collect(Collectors.summingLong(x -> x.getAchievementPlan()));
+				rbmPerformanceSummaryModel.setChartLeadModel(cm);
+				rbmPerformanceSummaryModel.setPartnersCommunicated(todayOverallCall);
+				rbmPerformanceSummaryModel.setCollectionTarget(collectionTarget);
+				rbmPerformanceSummaryModel.setCollection(collection);
+				rbmPerformanceSummaryModel.setSecondaryTarget(rbmCommittmentMap.get(rbmAuthId) == null ? 0 : rbmCommittmentMap.get(rbmAuthId).getTotalTarget() == null ? 0 : rbmCommittmentMap.get(rbmAuthId).getTotalTarget());
+				rbmPerformanceSummaryModel.setSecondary(rbmCommittmentMap.get(rbmAuthId) == null ? 0 : rbmCommittmentMap.get(rbmAuthId).getTotalAchievement() == null ? 0 : rbmCommittmentMap.get(rbmAuthId).getTotalAchievement());
+				summaryModels.add(rbmPerformanceSummaryModel);
+				//cm.getData().getDatasets().get(0).getData().;
+				//cm.getData().getDatasets().get(0).getBackgroundColor();
+				//cm.getData().getLabels()
+			}
+		}
+		model.addAttribute("summaryModels", summaryModels);
+		return "today_target";
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-fofo/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 30582 → 30771