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



            // Otherwise, use today
            startOfToday = LocalDate.now().atStartOfDay();
            previousDay = startOfToday.with(LocalTime.MAX).minusDays(1);
        }
 
        /*Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();
 
        List<Integer> retailerIds = customRetailers.values().stream()
                .filter(retailer -> {
                    String storeCode = retailer.getCode(); // adjust method name if different
                    return !storeCode.equalsIgnoreCase("UPGBN640") && !storeCode.equalsIgnoreCase("HRYN039");
                })
                .map(CustomRetailer::getPartnerId)
                .collect(Collectors.toList());*/
 
//        List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());
 
        List<Integer> retailerIds = Arrays.asList(175139440,175139441,175139442);
        Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);
 
        //partner daily investment
        List<Loan> defaultLoans = sdCreditService.getDefaultLoans();
        Map<Integer,List<Loan>> defaultLoanMap = defaultLoans.stream().collect(Collectors.groupingBy(Loan::getFofoId));
 

                bmName = authRepository.selectById(bmId).getFullName();
            }
 
            int managerId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES,EscalationType.L1,fofoId);
            String managerName = " ";
            LOGGER.info("managerId {}",managerId);
            if(managerId != 0){
                 managerName = authRepository.selectById(managerId).getFullName();
            }else {
                managerName = bmName;
            }

            int abmL3Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_ABM,EscalationType.L3,fofoId);
            if(abmId !=0){
                abmName = authRepository.selectById(abmId).getFullName();
            }else if(abmL2Id != 0){
                abmName = authRepository.selectById(abmL2Id).getFullName();
            }else if(abmL3Id != 0){
                abmName = authRepository.selectById(abmL3Id).getFullName();
            }
            AST ast = astRepository.selectById(customRetailers.get(fofoId).getAstId());
 
            PartnerType partnerTypeThisMonth = partnerTypeChangeService.getTypeOnMonth(fofoId, currentMonth);

            rows.add(row);
        }
 
        Map<String, Set<Integer>> storeGuyMap = this.generateBiReportHierarchyWise();
 
       /* for (Map.Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
            String storeGuyEmail = storeGuyEntry.getKey();
            Set<Integer> fofoIds = storeGuyEntry.getValue();
            String[] sendToArray = new String[]{storeGuyEmail};
 
            List<List<?>> filteredRows = rows.stream()
                    .filter(row -> row.size() > 5 && fofoIds.contains((Integer) row.get(5)))
                    .collect(Collectors.toList());
            this.sendMailToUser(headerGroup,filteredRows,sendToArray);
        }*/
 
        this.sendMailToUser(headerGroup,rows,new String[]{"ranu.rajput@smartdukaan.com"});
 
 
    }

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasksTest.java – Rev 34918 → 34919

Rev 34918		Rev 34919
Line 475...		Line 475...
475	`// Otherwise, use today`	475	`// Otherwise, use today`
476	`startOfToday = LocalDate.now().atStartOfDay();`	476	`startOfToday = LocalDate.now().atStartOfDay();`
477	`previousDay = startOfToday.with(LocalTime.MAX).minusDays(1);`	477	`previousDay = startOfToday.with(LocalTime.MAX).minusDays(1);`
478	`}`	478	`}`
479		479
480	`Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();`	480	`/*Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();`
481		481
482	`List<Integer> retailerIds = customRetailers.values().stream()`	482	`List<Integer> retailerIds = customRetailers.values().stream()`
483	`.filter(retailer -> {`	483	`.filter(retailer -> {`
484	`String storeCode = retailer.getCode(); // adjust method name if different`	484	`String storeCode = retailer.getCode(); // adjust method name if different`
485	`return !storeCode.equalsIgnoreCase("UPGBN640") && !storeCode.equalsIgnoreCase("HRYN039");`	485	`return !storeCode.equalsIgnoreCase("UPGBN640") && !storeCode.equalsIgnoreCase("HRYN039");`
486	`})`	486	`})`
487	`.map(CustomRetailer::getPartnerId)`	487	`.map(CustomRetailer::getPartnerId)`
488	`.collect(Collectors.toList());`	488	`.collect(Collectors.toList());*/`
489		489
490	`// List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());`	490	`// List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());`
491		491
492	`/* List<Integer> retailerIds = Arrays.asList(175139247,175139660);`	492	`List<Integer> retailerIds = Arrays.asList(175139440,175139441,175139442);`
493	`Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);*/`	493	`Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);`
494		494
495	`//partner daily investment`	495	`//partner daily investment`
496	`List<Loan> defaultLoans = sdCreditService.getDefaultLoans();`	496	`List<Loan> defaultLoans = sdCreditService.getDefaultLoans();`
497	`Map<Integer,List<Loan>> defaultLoanMap = defaultLoans.stream().collect(Collectors.groupingBy(Loan::getFofoId));`	497	`Map<Integer,List<Loan>> defaultLoanMap = defaultLoans.stream().collect(Collectors.groupingBy(Loan::getFofoId));`
498		498
Line 617...		Line 617...
617	`bmName = authRepository.selectById(bmId).getFullName();`	617	`bmName = authRepository.selectById(bmId).getFullName();`
618	`}`	618	`}`
619		619
620	`int managerId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES,EscalationType.L1,fofoId);`	620	`int managerId = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES,EscalationType.L1,fofoId);`
621	`String managerName = " ";`	621	`String managerName = " ";`
-		622	`LOGGER.info("managerId {}",managerId);`
622	`if(managerId != 0){`	623	`if(managerId != 0){`
623	`managerName = authRepository.selectById(managerId).getFullName();`	624	`managerName = authRepository.selectById(managerId).getFullName();`
624	`}else {`	625	`}else {`
625	`managerName = bmName;`	626	`managerName = bmName;`
626	`}`	627	`}`
Line 630...		Line 631...
630	`int abmL3Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_ABM,EscalationType.L3,fofoId);`	631	`int abmL3Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_ABM,EscalationType.L3,fofoId);`
631	`if(abmId !=0){`	632	`if(abmId !=0){`
632	`abmName = authRepository.selectById(abmId).getFullName();`	633	`abmName = authRepository.selectById(abmId).getFullName();`
633	`}else if(abmL2Id != 0){`	634	`}else if(abmL2Id != 0){`
634	`abmName = authRepository.selectById(abmL2Id).getFullName();`	635	`abmName = authRepository.selectById(abmL2Id).getFullName();`
635	`}else {`	636	`}else if(abmL3Id != 0){`
636	`abmName = authRepository.selectById(abmL3Id).getFullName();`	637	`abmName = authRepository.selectById(abmL3Id).getFullName();`
637	`}`	638	`}`
638	`AST ast = astRepository.selectById(customRetailers.get(fofoId).getAstId());`	639	`AST ast = astRepository.selectById(customRetailers.get(fofoId).getAstId());`
639		640
640	`PartnerType partnerTypeThisMonth = partnerTypeChangeService.getTypeOnMonth(fofoId, currentMonth);`	641	`PartnerType partnerTypeThisMonth = partnerTypeChangeService.getTypeOnMonth(fofoId, currentMonth);`
Line 1199...		Line 1200...
1199	`rows.add(row);`	1200	`rows.add(row);`
1200	`}`	1201	`}`
1201		1202
1202	`Map<String, Set<Integer>> storeGuyMap = this.generateBiReportHierarchyWise();`	1203	`Map<String, Set<Integer>> storeGuyMap = this.generateBiReportHierarchyWise();`
1203		1204
1204	`for (Map.Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {`	1205	`/* for (Map.Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {`
1205	`String storeGuyEmail = storeGuyEntry.getKey();`	1206	`String storeGuyEmail = storeGuyEntry.getKey();`
1206	`Set<Integer> fofoIds = storeGuyEntry.getValue();`	1207	`Set<Integer> fofoIds = storeGuyEntry.getValue();`
1207	`String[] sendToArray = new String[]{storeGuyEmail};`	1208	`String[] sendToArray = new String[]{storeGuyEmail};`
1208		1209
1209	`List<List<?>> filteredRows = rows.stream()`	1210	`List<List<?>> filteredRows = rows.stream()`
1210	`.filter(row -> row.size() > 5 && fofoIds.contains((Integer) row.get(5)))`	1211	`.filter(row -> row.size() > 5 && fofoIds.contains((Integer) row.get(5)))`
1211	`.collect(Collectors.toList());`	1212	`.collect(Collectors.toList());`
1212	`this.sendMailToUser(headerGroup,filteredRows,sendToArray);`	1213	`this.sendMailToUser(headerGroup,filteredRows,sendToArray);`
1213	`}`	1214	`}*/`
1214		1215
1215	`this.sendMailToUser(headerGroup,rows,new String[]{"ranu.rajput@smartdukaan.com"});`	1216	`this.sendMailToUser(headerGroup,rows,new String[]{"ranu.rajput@smartdukaan.com"});`
1216		1217
1217		1218
1218	`}`	1219	`}`