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.Comparator;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Optional;
-import java.util.Set;
-import java.util.TreeMap;
-import java.util.stream.Collectors;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.transaction.Transactional;
-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.MediaType;
-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.mongodb.DBObject;
 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.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
+import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
 import com.spice.profitmandi.dao.entity.catalog.BrandCatalog;
+import com.spice.profitmandi.dao.entity.cs.Position;
 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.*;
-import com.spice.profitmandi.dao.entity.user.LeadActivity;
+import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
-import com.spice.profitmandi.dao.entity.user.LeadBrand;
-import com.spice.profitmandi.dao.entity.user.LeadDetail;
-import com.spice.profitmandi.dao.entity.user.VisitRequest;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.CommunicationType;
 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.LeadBrandModel;
-import com.spice.profitmandi.dao.model.LeadDetailModel;
-import com.spice.profitmandi.dao.model.LeadStatusData;
-import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
-import com.spice.profitmandi.dao.model.RBMPerformanceSummaryModel;
-import com.spice.profitmandi.dao.model.TeamCommitmentModel;
-import com.spice.profitmandi.dao.model.TotalTargetColectionModel;
-import com.spice.profitmandi.dao.model.UserVisitModel;
-import com.spice.profitmandi.dao.model.VisitDescriptionModel;
 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.LeadBrandRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadDetailRepository;
-import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
-import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.*;
-import com.spice.profitmandi.dao.repository.dtr.VisitRequestRepository;
 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.catalog.BrandsService;
 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.MediaType;
+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);
         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()));
+            List<Integer> fofoIdList = new ArrayList<>(storeGuyMap.get(authUser.getEmailId()));
+            List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIdList);
+            Map<Integer, PartnerCollectionRemark> partnerCollectionRemarks = new HashMap<>();
+            if (!remarkIds.isEmpty()) {
+                partnerCollectionRemarks = partnerCollectionRemarkRepository.selectByIds(remarkIds).stream()
+                        .collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
+            }
+            List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId()).stream().collect(Collectors.toList());
+            boolean isRBMAndL1 = positions.stream()
+                    .anyMatch(position ->
+                            ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId()
+                                    && EscalationType.L1.equals(position.getEscalationType()));
+//            this is creating for escalation filtered fofo id in case of if rbm is l1
+            List<Integer> fofoIds = fofoIdList;
+            if (isRBMAndL1) {
+                fofoIds = partnerCollectionRemarks.entrySet().stream()
+                        // Filter for fofoIds where the escalation type is neither RBM nor Sale
+                        .filter(entry -> {
+                            PartnerCollectionRemark pcrMap = entry.getValue();
+                            return !(CollectionRemark.RBM_L2_ESCALATION.equals(pcrMap.getRemark())
+                                    || CollectionRemark.SALES_ESCALATION.equals(pcrMap.getRemark()));
+                        })
+                        .map(Map.Entry::getKey) // Map to the fofoId
+                        .collect(Collectors.toList()); // Collect the result as a List
+            }
             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());

Subversion Repositories SmartDukaan

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