WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

+    }
     private Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() throws ProfitMandiBusinessException {
         Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();
         Map<String, SaleRoles> partnerEmailRBMMap = new HashMap<>();
+        Map<String, SaleRoles> partnerEmailABMMap = new HashMap<>();
-        List<Position> positions = positionRepository.selectPositionByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM));
+        List<Position> positions = positionRepository.selectPositionByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM,ProfitMandiConstants.TICKET_CATEGORY_ABM));
         Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         Map<Integer, List<CustomRetailer>> positionIdRetailerMap = csService.getPositionCustomRetailerMap(positions);
         for (Position position : positions) {
             List<CustomRetailer> crList = positionIdRetailerMap.get(position.getId());
             if (crList == null)
                         saleRoles.getL2().add(name);
                     }*/
+                }
+            }
+            if (position.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_ABM) {
+                for (CustomRetailer cr : crList) {
+                    if (!partnerEmailABMMap.containsKey(cr.getEmail())) {
+                        partnerEmailABMMap.put(cr.getEmail(), new SaleRoles());
+                    }
+                    SaleRoles saleRoles = partnerEmailABMMap.get(cr.getEmail());
+                    AuthUser authUser = authUsersMap.get(position.getAuthUserId());
+                    if (authUser == null) {
+                        continue;
+                    }
+                    String name = authUser.getFirstName() + " " + authUser.getLastName();
+                    if (position.getEscalationType().equals(EscalationType.L1) || position.getEscalationType().equals(EscalationType.L1)) {
+                        saleRoles.getL1().add(name);
+                    }
+                    else if (position.getEscalationType().equals(EscalationType.L2)) {
+                        saleRoles.getL2().add(name);
+                    }
+                }
+            }
+        }
         Set<CustomRetailer> allCrList = new HashSet<>();
         for (List<CustomRetailer> cr : positionIdRetailerMap.values()) {
             allCrList.addAll(cr);
             Exception {
         String timeString = "Today %s";
         LocalDateTime now = LocalDateTime.now();
         DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h:m a");
-        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_LOGISTICS, ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES, ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT, ProfitMandiConstants.TICKET_CATEGORY_TECHNOLOGY);
+        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_LOGISTICS, ProfitMandiConstants.TICKET_CATEGORY_FINANCIAL_SERVICES, ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT, ProfitMandiConstants.TICKET_CATEGORY_TECHNOLOGY);
         Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false);
         for (Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
             String email = storeGuyEntry.getKey();
+                }
+            }
             if (!salesEscalatedRemarksMap.isEmpty()) {
                 //
-                for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
+                for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
                     List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
                             .map(x -> salesEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
                     String subject = "Partners escalated to Sales";
                     String messageText = this.getMessageForSalesEscalatedPartners(filteredRows);
             ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
         List<NonSdBuying> nonSdByuingActiveList = nonSdBuyingRepository.selectAllActiveNonSDBuyingList(true);
         Map<Integer, NonSdBuying> unAuthorizedBuyingMap = nonSdByuingActiveList.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         if (!unAuthorizedBuyingMap.isEmpty()) {
-            for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES), true).entrySet()) {
+            for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM), true).entrySet()) {
                 List<NonSdBuying> unAuthorizedfilteredRows = storeGuyEntry.getValue().stream()
                         .map(x -> unAuthorizedBuyingMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
                 if (!unAuthorizedfilteredRows.isEmpty()) {
                     String subject = "Unauthorized Buying";
                     String messageText = this.getMessageForUnauthorizedBuying(unAuthorizedfilteredRows);
     public void sendDefaultLoanAlert(List<Loan> defaultLoans) throws
             ProfitMandiBusinessException, MessagingException, IOException {
         String subject = "Default Partners";
-        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
+        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = new ArrayList<>();
             for (Loan loan : defaultLoans) {
+        }
+    }
     private void sendDueDateCrossLoanAlert(List<Loan> dueDateCrossLoans) throws Exception {
-        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
+        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = new ArrayList<>();
             for (Loan loan : dueDateCrossLoans) {
     public void monthlyTargetForInternalTeam() throws MessagingException, ProfitMandiBusinessException, IOException {
         LocalDateTime curDate = LocalDateTime.now();
-        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
+        List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false);
         List<MonthlyTarget> monthlyTargets = monthlyTargetRepository.selectByDate(YearMonth.now());
         List<Integer> categoryIds = Arrays.asList(
                 ProfitMandiConstants.TICKET_CATEGORY_CATEGORY,
                 ProfitMandiConstants.TICKET_CATEGORY_RBM,
                 ProfitMandiConstants.TICKET_CATEGORY_SALES,
+                ProfitMandiConstants.TICKET_CATEGORY_ABM,
                 ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS,
                 ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         /*for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = defaultLoans.stream()

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 34858 → 34903