WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/DealsController.java

         params.put("rows", similarCatalogIds.size() + "");
         try {
             String response = restClient.get(SchemeType.HTTP, solrUrl, 8984, "solr/demo/select", params);
             JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
             JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
-            return responseSender.ok(this.getCatalogResponse(docs, false, userInfo.getRetailerId()));
+            return responseSender.ok(this.getCatalogResponse(docs, false, userInfo.getRetailerId()).stream().filter(x -> x.isInStock()).collect(Collectors.toList()));
         } catch (HttpHostConnectException e) {
             throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+        }
+    }
                 .collect(Collectors.toMap(x -> x.getCatalogId(), x -> x.getSimilarModelIds()));
         Set<Integer> similarModelIds = similarModelMap.values().stream().flatMap(x -> x.stream()).collect(Collectors.toSet());
         logger.info("similarModelIds - {}", similarModelIds);
         if (similarModelIds.size() > 0) {
-            Map<Integer, FofoCatalogResponse> similarCatalogResponsesMap = this.getSimpleDocs(similarModelIds).stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x));
+            Map<Integer, FofoCatalogResponse> similarCatalogResponsesMap = this.getSimpleDocs(fs, similarModelIds).stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x));
             logger.info("Similar Catalog ResponseMap - {}", similarCatalogResponsesMap.keySet());
             for (FofoCatalogResponse deal : dealResponse) {
                 if (similarModelMap.containsKey(deal.getCatalogId())) {
                     List<Integer> similarCatalogIds = similarModelMap.get(deal.getCatalogId());
+            }
+        }
         return responseSender.ok(dealResponse);
+    }
-    private List<FofoCatalogResponse> getSimpleDocs(Set<Integer> catalogIds) throws ProfitMandiBusinessException {
+    private List<FofoCatalogResponse> getSimpleDocs(FofoStore fofoStore, Set<Integer> catalogIds) throws Exception {
         List<FofoCatalogResponse> fofoCatalogResponses = new ArrayList<>();
         Map<String, String> params = new HashMap<>();
         List<String> mandatoryQ = new ArrayList<>();
         params.put("q", StringUtils.join(mandatoryQ, " "));
         params.put("fl", "*, [child parentFilter=id:catalog* childFilter=active_b:true ]");
         params.put("wt", "json");
         params.put("rows", catalogIds.size() + "");
-        try {
-            String response = restClient.get(SchemeType.HTTP, solrUrl, 8984, "solr/demo/select", params);
-            JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
-            JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
+        String response = restClient.get(SchemeType.HTTP, solrUrl, 8984, "solr/demo/select", params);
+        JSONObject solrResponseJSONObj = new JSONObject(response).getJSONObject("response");
+        JSONArray docs = solrResponseJSONObj.getJSONArray("docs");
+        int warehouseId = fofoStoreRepository.selectByRetailerId(fofoStore.getId()).getWarehouseId();
+        Map<Integer, List<SaholicPOItem>> poItemAvailabilityMap = saholicInventoryService.getSaholicPOItems().get(warehouseId);
-            for (int i = 0; i < docs.length(); i++) {
+        for (int i = 0; i < docs.length(); i++) {
-                JSONObject doc = docs.getJSONObject(i);
+            JSONObject doc = docs.getJSONObject(i);
-                FofoCatalogResponse fofoCatalogResponse = this.toFofoCatalogResponse(doc);
+            FofoCatalogResponse fofoCatalogResponse = this.toFofoCatalogResponse(doc);
+            if (doc.has("_childDocuments_")) {
+                String modelColorClass = "grey";
+                FofoAvailabilityInfo fdiAnyColour = null;
+                // Iterating itemIds
+                for (int j = 0; j < doc.getJSONArray("_childDocuments_").length(); j++) {
+                    JSONObject childItem = doc.getJSONArray("_childDocuments_").getJSONObject(j);
+                    int itemId = childItem.getInt("itemId_i");
+                    List<SaholicCISTable> currentAvailability = saholicCISTableRepository.selectByItemWarehouse(itemId, warehouseId);
+                    List<SaholicPOItem> poItemAvailability = null;
+                    if (poItemAvailabilityMap != null) {
+                        poItemAvailability = poItemAvailabilityMap.get(itemId);
+                    }
+                    for (SaholicCISTable saholicCISTable : currentAvailability) {
+                        saholicCISTable.setWarehouseName(
+                                ProfitMandiConstants.WAREHOUSE_MAP.get(saholicCISTable.getWarehouseFrom()));
+                    }
+                    String poColor = "grey";
+                    boolean active = false;
+                    if (currentAvailability != null && currentAvailability.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) > 0) {
+                        poColor = "green";
+                        modelColorClass = "green";
+                    } else if (poItemAvailability != null && poItemAvailability.stream().collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty)) > 0) {
-                fofoCatalogResponses.add(fofoCatalogResponse);
+                        if (currentAvailability != null && poItemAvailability.stream().collect(Collectors.summingInt(SaholicPOItem::getUnfulfilledQty)) + currentAvailability.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)) <= 0) {
+                            poColor = "grey";
+                        } else {
+                            poColor = "yellow";
+                            if (!modelColorClass.equals("green")) {
+                                modelColorClass = poColor;
+                            }
+                        }
+                    }
+                }
+                fofoCatalogResponse.setInStock(!modelColorClass.equals("grey"));
+            }
-        } catch (HttpHostConnectException e) {
+            fofoCatalogResponses.add(fofoCatalogResponse);
-            throw new ProfitMandiBusinessException("", "", "Could not connect to host");
+        }
-        return fofoCatalogResponses;
+        return fofoCatalogResponses;
+    }
     private FofoCatalogResponse toFofoCatalogResponse(JSONObject doc) {
         FofoCatalogResponse fofoCatalogResponse = new FofoCatalogResponse();
         fofoCatalogResponse.setCatalogId(doc.getInt("catalogId_i"));
             webListing.setFofoCatalogResponses(getDealResponses(userInfo, webListing, 0, 20));
+        }
         return responseSender.ok(webListings);
+    }
-    private List<FofoCatalogResponse> getDealResponses(UserInfo userInfo, WebListing webListing, int offset, int limit) throws Exception {
+    private List<FofoCatalogResponse> getDealResponses(UserInfo userInfo, WebListing webListing, int offset,
+                                                       int limit) throws Exception {
         RestClient rc = new RestClient();
         Map<String, String> params = new HashMap<>();
         List<String> mandatoryQ = new ArrayList<>();
+                    }
+                }
                 if (fdiAnyColour != null) {
                     fdiAnyColour.setColorClass(modelColorClass);
+                }
+                fofoCatalogResponse.setInStock(!modelColorClass.equals("grey"));
+            }
             if (fofoAvailabilityInfoMap.values().size() > 0) {
                 List<FofoAvailabilityInfo> availabilityList = fofoAvailabilityInfoMap.values().stream().sorted(Comparator.comparing(FofoAvailabilityInfo::getAvailability).reversed()).collect(Collectors.toList());
                 fofoCatalogResponse.setItems(availabilityList);
                 if (priceCircularItemModelMap.containsKey(fofoCatalogResponse.getCatalogId())) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/DealsController.java – Rev 33575 → 33576