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

         // throw new Exception();
+    }
     public void checkfocusedModelInPartnerStock() throws Exception {
-        List<Integer> fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId()).collect(Collectors.toList());
+        List<FofoStore> fofoStores = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).collect(Collectors.toList());
         Map<Integer, Map<Integer, List<SaholicCIS>>> warehouseItemAvailabilityMap = saholicInventoryService.getSaholicStock();
         Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
         Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
+        Map<Integer,List<FocusedModel>> focusedModelsMap = focusedModelRepository.selectAll().stream().collect(Collectors.groupingBy(x->x.getRegionId()));
         Map<Integer, Map<Integer, List<SaholicPOItem>>> warehousePoItemAvailabilityMap = saholicInventoryService.getSaholicPOItems();
         Map<Integer, List<FocusedModelShortageModel>> focusedModelShortageReportMap = new HashMap<>();
+        Map<Integer,List<Integer>> partnerRegionMap = partnerRegionRepository.selectAll().stream().collect(Collectors.groupingBy(x->x.getFofoId(),Collectors.mapping(x->x.getRegionId(),Collectors.toList())));
-        for (Integer fofoId : fofoIds) {
+        for (FofoStore fofoStore : fofoStores) {
+            List<Integer> regionIds = partnerRegionMap.get(fofoStore.getId());
+            LOGGER.info("regionIds" + regionIds);
+            if (regionIds==null || regionIds.size() == 0) {
+                LOGGER.info("No region found for partner {}", fofoStore);
+                continue;
+            }
+            LOGGER.info("before focusedCatalogIdAndQtyMap");
+            Map<Integer, Optional<Integer>> focusedCatalogIdAndQtyMap = regionIds.stream().map(focusedModelsMap::get).flatMap(x->x!=null ? x.stream():Stream.empty())
+                    .collect(groupingBy(FocusedModel::getCatalogId, mapping(FocusedModel::getObsMinimumQty, Collectors.maxBy(Integer::compareTo))));
+            LOGGER.info("after focusedCatalogIdAndQtyMap");
             List<FocusedModelShortageModel> focusedModelShortageList = new ArrayList<>();
-            focusedModelShortageReportMap.put(fofoId, focusedModelShortageList);
+            focusedModelShortageReportMap.put(fofoStore.getId(), focusedModelShortageList);
+            LOGGER.info("Before retailerService.getFofoRetailer(fofoId)");
-            CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
+            CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoStore.getId());
+            LOGGER.info("After retailerService.getFofoRetailer(fofoId)");
             Map<Integer, Integer> processingOrderMap = null;
             Map<Integer, Integer> catalogIdAndQtyMap = null;
             Map<Integer, Integer> grnPendingOrdersMap = null;
-            Map<Integer, Integer> currentInventorySnapshot = currentInventorySnapshotRepository.selectByFofoId(fofoId).stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));
+            Map<Integer, Integer> currentInventorySnapshot = currentInventorySnapshotRepository.selectByFofoId(fofoStore.getId()).stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getAvailability()));
             if (!currentInventorySnapshot.isEmpty()) {
                 catalogIdAndQtyMap = itemRepository.selectByIds(currentInventorySnapshot.keySet()).stream().collect(groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> currentInventorySnapshot.get(x.getId()))));
+            }
-            Map<Integer, Integer> grnPendingOrders = orderRepository.selectPendingGrnOrders(fofoId).stream().collect(groupingBy(x -> x.getLineItem().getItemId(), Collectors.summingInt(x -> x.getLineItem().getQuantity())));
+            Map<Integer, Integer> grnPendingOrders = orderRepository.selectPendingGrnOrders(fofoStore.getId()).stream().collect(groupingBy(x -> x.getLineItem().getItemId(), Collectors.summingInt(x -> x.getLineItem().getQuantity())));
             if (!grnPendingOrders.isEmpty()) {
                 grnPendingOrdersMap = itemRepository.selectByIds(grnPendingOrders.keySet()).stream().collect(groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> grnPendingOrders.get(x.getId()))));
+            }
-            Map<Integer, Integer> processingOrder = orderRepository.selectOrders(fofoId, orderStatusList).stream().collect(groupingBy(x -> x.getLineItem().getItemId(), Collectors.summingInt(x -> x.getLineItem().getQuantity())));
+            Map<Integer, Integer> processingOrder = orderRepository.selectOrders(fofoStore.getId(), orderStatusList).stream().collect(groupingBy(x -> x.getLineItem().getItemId(), Collectors.summingInt(x -> x.getLineItem().getQuantity())));
             if (!processingOrder.isEmpty()) {
                 processingOrderMap = itemRepository.selectByIds(processingOrder.keySet()).stream().collect(groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> processingOrder.get(x.getId()))));
+            }
-            List<String> brands = mongoClient.getMongoBrands(fofoId, null, 3).stream().map(x -> (String) x.get("name")).collect(Collectors.toList());
-            List<Integer> regionIds = partnerRegionRepository.selectByfofoId(fofoId).stream().map(x -> x.getRegionId()).collect(Collectors.toList());
-            LOGGER.info("regionIds" + regionIds);
-            if (regionIds.size() == 0) {
-                LOGGER.info("No region found for partner {}", fofoId);
-                continue;
-            }
-            Map<Integer, Optional<Integer>> focusedCatalogIdAndQtyMap = focusedModelRepository.selectAllByRegionIds(regionIds).stream().collect(groupingBy(FocusedModel::getCatalogId, mapping(FocusedModel::getObsMinimumQty, Collectors.maxBy(Integer::compareTo))));
-            LOGGER.info("focusedCatalogIdAndQtyMap" + focusedCatalogIdAndQtyMap);
-            Map<String, RetailerBlockBrands> retailerBlockBrands = retailerBlockBrandsRepository.selectAllByRetailer(fofoId).stream().collect(Collectors.toMap(x -> x.getBlockBrands(), x -> x));
+            //Map<String, RetailerBlockBrands> retailerBlockBrands = retailerBlockBrandsRepository.selectAllByRetailer(fofoId).stream().collect(Collectors.toMap(x -> x.getBlockBrands(), x -> x));
             for (Entry<Integer, Optional<Integer>> entry : focusedCatalogIdAndQtyMap.entrySet()) {
                 int minQty = entry.getValue().get();
                 int inStockQty = 0;
                 int shortageQty = minQty - totalQty;
                 List<Item> items = itemRepository.selectAllByCatalogItemId(entry.getKey());
                 TagListing tagListing = tagListingRepository.selectByCatalogId(entry.getKey());
-                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
                 Map<Integer, List<SaholicCIS>> itemAvailabilityMap = warehouseItemAvailabilityMap.get(fofoStore.getWarehouseId());
                 Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = warehousePoItemAvailabilityMap.get(fofoStore.getWarehouseId());
                 for (Item item : items) {
+                    }
+                }
                 FocusedModelShortageModel fm = new FocusedModelShortageModel();
-                fm.setFofoId(fofoId);
+                fm.setFofoId(fofoStore.getId());
                 fm.setStoreCode(fofoStore.getCode());
                 fm.setStoreName(customRetailer.getBusinessName());
                 fm.setBrandName(items.get(0).getBrand());
                 fm.setModelName(items.get(0).getModelName());
                 fm.setModelNumber(items.get(0).getModelNumber());
                 fm.setPendingIndentQty(processingQty);
                 fm.setShortageQty(shortageQty);
                 fm.setPoAvailability(allColorPoAvailability);
                 fm.setDp(tagListing.getSellingPrice());
                 fm.setWarehouseName(warehouseMap.get(customRetailer.getWarehouseId()));
-                if (partnerIdSalesHeadersMap.get(fofoId) != null) {
+                if (partnerIdSalesHeadersMap.get(fofoStore) != null) {
-                    fm.setStateManager(partnerIdSalesHeadersMap.get(fofoId).getRegionalManager());
+                    fm.setStateManager(partnerIdSalesHeadersMap.get(fofoStore).getRegionalManager());
-                    fm.setTerritoryManager(partnerIdSalesHeadersMap.get(fofoId).getTerritoryManager());
+                    fm.setTerritoryManager(partnerIdSalesHeadersMap.get(fofoStore).getTerritoryManager());
                 } else {
-                    LOGGER.info("else fofoId - {}", fofoId);
                     fm.setStateManager("");
                     fm.setTerritoryManager("");
+                }
                 fm.setItemName(items.get(0).getBrand() + items.get(0).getModelNumber() + items.get(0).getModelName());

Subversion Repositories SmartDukaan

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