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

     public void test() throws Exception {
         //List<TotalLoanAmountDueModel> totalLoanAmountDueModels = loanRepository.getDueLoansByFofoId(175139438);
         //System.out.println(totalLoanAmountDueModels);
         //runOnceTasks.findCNDiff();
-        this.updatePartnerLimit();
+        /*this.updatePartnerLimit();
         System.out.println(getSuggestedLimit(300000d));
         System.out.println(getSuggestedLimit(400000d));
         System.out.println(getSuggestedLimit(500000d));
         System.out.println(getSuggestedLimit(600000d));
         System.out.println(getSuggestedLimit(700000d));
         System.out.println(getSuggestedLimit(1500000d));
         System.out.println(getSuggestedLimit(2000000d));
-        System.out.println(getSuggestedLimit(2500000d));
+        System.out.println(getSuggestedLimit(2500000d));*/
         //Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@smartdukaan.com"}, null, "DTDC AWb", "PFA");
+    }
     public void test4() throws Exception {
         List<Integer> offerIds = Arrays.asList(2882, 2881, 2880, 2879, 2878, 2877, 2876, 2875, 2874, 2873, 2872, 2871, 2870, 2869, 2868, 2867, 2866, 2865, 2864, 2863, 2862, 2861, 2860, 2859, 2858, 2857, 2856, 2855, 2854, 2853, 2852, 2851, 2850, 2849, 2847, 2846, 2845, 2844, 2843, 2842, 2841, 2840, 2839, 2838, 2837, 2836, 2835, 2834, 2833, 2832, 2831, 2830, 2829, 2828, 2827, 2826, 2825, 2824, 2823, 2822, 2821, 2820, 2819, 2818, 2817, 2816, 2815, 2814, 2813, 2812, 2811, 2810, 2809, 2808, 2807, 2806, 2805, 2804, 2803, 2802, 2801, 2800, 2799, 2798, 2797, 2796, 2795, 2794, 2793, 2792, 2791, 2790, 2789, 2788, 2787, 2786, 2785, 2784, 2783, 2782, 2781, 2780, 2777, 2776, 2775, 2774, 2773, 2772, 2771, 2770, 2769, 2768, 2767, 2766, 2765, 2764, 2763, 2762, 2761, 2760, 2759, 2758, 2757, 2756, 2755, 2754, 2753, 2752, 2751, 2750, 2749, 2748, 2747, 2746, 2745, 2744, 2723, 2722, 2721, 2720, 2719, 2718, 2717, 2716, 2715, 2714, 2713, 2712, 2711, 2710, 2709, 2708, 2707, 2706, 2705, 2704, 2703, 2702, 2701, 2700, 2699, 2698, 2697, 2696, 2695, 2694, 2693, 2692, 2691, 2690, 2494, 2493, 2492, 2491, 2490, 2489, 2488, 2487, 2486, 2485, 2484, 2483, 2482, 2481, 2480, 2479, 2478, 2477, 2476, 2475, 2474, 2473, 2472, 2471, 2470, 2469, 2466, 2465, 2464, 2463, 2462, 2461, 2460, 2459, 2458, 2457, 2456, 2455, 2454, 2453, 2452, 2451, 2450, 2449, 2448, 2447, 2446, 2445, 2444, 2443, 2442, 2441, 2440, 2439, 2407, 2406, 2405, 2404, 2403, 2402, 2401, 2400, 2399, 2398, 2397, 2396, 2395, 2394, 2393, 2392, 2391, 2390, 2389, 2388, 2387, 2386, 2385, 2384, 2383, 2382, 2381, 2117, 2116, 2115, 2114, 2113, 2112, 2111, 2110, 2109, 2108, 2107, 2106, 2105, 2104, 2103, 2102, 2101, 2100, 2099, 2098, 2077);
                         Map.Entry::getValue,
                         Collectors.mapping(Map.Entry::getKey, Collectors.toList())
                 ));
         LOGGER.info("regionPartnerMap  - {}", regionPartnerMap.keySet());
         for (Map.Entry<Set<Integer>, List<Integer>> regionPartnerEntry : regionPartnerMap.entrySet()) {
-            LOGGER.info("regionPartnerEntry - {}", regionPartnerEntry.getKey());
+            //LOGGER.info("regionPartnerEntry - {}", regionPartnerEntry.getKey());
             Set<Integer> regionIds = regionPartnerEntry.getKey();
             List<Integer> partnerIds = regionPartnerEntry.getValue();
-            if(regionIds.contains(5)) {
-                partnerIds.addAll(fofoStoreMap.keySet());
-                partnerIds = partnerIds.stream().distinct().collect(toList());
+            if(regionIds.stream().anyMatch(x->!regionFocusedModelsMap.containsKey(x))) continue;
-            }
             LOGGER.info("regionIds" + regionIds);
             if (regionIds == null || regionIds.size() == 0) {
                 LOGGER.info("No region found for partner {}", partnerIds);
                 continue;
+            }
+            if(regionIds.contains(5)) {
-            regionIds.forEach(regionId -> LOGGER.info("Region: {}, Models: {}", regionId, regionFocusedModelsMap.get(regionId)));
+                partnerIds.addAll(fofoStoreMap.keySet());
+            }
             Map<Integer, Optional<Integer>> focusedCatalogIdAndQtyMap = regionIds.stream().map(regionFocusedModelsMap::get).flatMap(x -> x != null ? x.stream() : Stream.empty())
                     .collect(groupingBy(FocusedModel::getCatalogId, mapping(FocusedModel::getObsMinimumQty, Collectors.maxBy(Integer::compareTo))));
-            LOGGER.info("focusedCatalogIdAndQtyMap {}",focusedCatalogIdAndQtyMap);
+            //LOGGER.info("focusedCatalogIdAndQtyMap {}",focusedCatalogIdAndQtyMap);
             if(focusedCatalogIdAndQtyMap.size() == 0) continue;
             for (int partnerId : partnerIds) {
+                if(partnerId==0) continue;
                 FofoStore fofoStore = fofoStoreMap.get(partnerId);
                 List<FocusedModelShortageModel> focusedModelShortageList = new ArrayList<>();
                 focusedModelShortageReportMap.put(fofoStore.getId(), focusedModelShortageList);
                 LOGGER.info("Before retailerService.getFofoRetailer(fofoId)");
                 CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoStore.getId());
         LOGGER.info("focusedModelShortageReportMap {}", focusedModelShortageReportMap);
         if (!focusedModelShortageReportMap.isEmpty()) {
             String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
             Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
             Map<String, List<List<?>>> emailRowsMap = new HashMap<>();
+            //String email = "tarun.verma@smartdukaan.com";
             focusedModelShortageReportMap.entrySet().forEach(x -> {
-                storeGuyMap.entrySet().forEach(y -> {
+                storeGuyMap.entrySet().stream()
+                        //.filter(entry->entry.getKey().equals(email))
+                        .forEach(y -> {
                     if (y.getValue().contains(x.getKey())) {
                         if (!emailRowsMap.containsKey(y.getKey())) {
                             emailRowsMap.put(y.getKey(), new ArrayList<>());
+                        }
+                    }
                 });
             });
+            //LOGGER.info("emailRowsMap {}", emailRowsMap);
             List<String> headers = Arrays.asList("Store Code", "Store Name", "Brand", "Model Name", "Model Number", "DP", "Warehouse Name", "State Manager", "Territory Manager", "Pending Indent", "InStock", "Shortage Qty", "Availability");
             emailRowsMap.entrySet().forEach(entry -> {
                 ByteArrayOutputStream baos = null;

Subversion Repositories SmartDukaan

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