WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/service/solr/FofoSolr.java

 package com.spice.profitmandi.dao.service.solr;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.gson.Gson;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.dao.entity.catalog.SuperCatalogMapping;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.catalog.TagRanking;
 import com.spice.profitmandi.dao.entity.dtr.WebProductListing;
 import com.spice.profitmandi.dao.entity.similarModel.SimilarModel;
+import com.spice.profitmandi.dao.repository.catalog.SuperCatalogMappingRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagRankingRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.WebListingRepository;
 import com.spice.profitmandi.dao.repository.dtr.WebProductListingRepository;
 import com.spice.profitmandi.dao.repository.similarModel.SimilarModelRepository;
+import com.spice.profitmandi.service.catalog.SuperCatalogModel;
 import com.spice.profitmandi.service.tag.ItemTagModel;
 import in.shop2020.model.v1.catalog.status;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.apache.solr.client.solrj.SolrClient;
     private WebListingRepository webListingRepository;
     @Autowired
     private WebProductListingRepository webProductListingRepository;
+    @Autowired
+    private SuperCatalogMappingRepository superCatalogMappingRepository;
     @Value("${new.solr.url}")
     private String solrUrl;
     @Value("${reportico.url}")
     private String reporticoUrl;
         List<status> statuses = Arrays.asList(status.ACTIVE, status.PAUSED_BY_RISK, status.PARTIALLY_ACTIVE);
         Map<Integer, List<String>> catalogLabelMap = this.getLabels();
-        logger.info("catalogLabelMap {}", catalogLabelMap);
+        //logger.info("catalogLabelMap {}", catalogLabelMap);
         List<ItemTagModel> itemTagModels = tagListingRepository.getAllItemTagByStatus(statuses);
         Map<String, Object> projection = new HashMap<>();
         projection.put("defaultImageUrl", 1);
             List<TagListing> tagPricing = (List<TagListing>) itemMap.get("tagPricing");
             tagPricing.add(tagListing);
+        }
         //logger.info("catalogObj {}", catalogMap);
+        List<SuperCatalogModel> superCatalogMappingList = superCatalogMappingRepository.selectJoinedData();
+        List<SuperCatalogMapping> superCatalogs = superCatalogMappingRepository.selectAll();
         List<SolrInputDocument> catalogSolrObjs = new ArrayList<>();
         for (Entry<Integer, Map<String, Object>> entry : catalogMap.entrySet()) {
             int catalogId = entry.getKey();
+            Optional<SuperCatalogModel> superCatalogMapping = findMappingByCatalogId(superCatalogMappingList, catalogId);
             Map<String, Object> catalogValMap = entry.getValue();
             Map<Integer, Object> itemsMap = (Map<Integer, Object>) catalogValMap.get("items");
             boolean active = false;
             // Map<Integer, Object> itemsMap = (Map<String, Object>)
                     mop = taglist.getMop();
                     dp = taglist.getSellingPrice();
+                }
                 itemObjs.add(itemObj);
+            }
-            //logger.info("catalogValMap {}", catalogValMap);
-            //logger.info("rank {}", catalogValMap.get("rank"));
             SolrInputDocument catalogSolrObj = new SolrInputDocument();
             catalogSolrObj.setField("id", "catalog" + catalogId);
             catalogSolrObj.setField("rank_i", catalogValMap.get("rank"));
             catalogSolrObj.setField("title_s", catalogValMap.get("title"));
-            // catalogSolrObj.setField("_childDocuments_", itemObjs);
             catalogSolrObj.addChildDocuments(itemObjs);
             catalogSolrObj.setField("child_b", itemObjs.size() > 0);
             catalogSolrObj.setField("catalogId_i", catalogId);
+            if (superCatalogMapping.isPresent()) {
+                int superCatalogId = superCatalogMapping.get().getSuperCatalogId();
+                String superCatalogMappingVariants = findMappingVariantsByCatalogId(superCatalogs, superCatalogId);
+                catalogSolrObj.setField("superCatalog_i", superCatalogId);
+                catalogSolrObj.setField("superCatalog_s", superCatalogMapping.get().getSuperCatalogName());
+                catalogSolrObj.setField("superCatalogVariants_s", superCatalogMappingVariants);
+            } else {
+                catalogSolrObj.setField("superCatalog_i", 0);
+                catalogSolrObj.setField("superCatalog_s", "_");
+                catalogSolrObj.setField("superCatalogVariants_s", "[]");
+            }
             catalogSolrObj.setField("imageUrl_s",
                     catalogValMap.get("imageUrl").toString().replace("saholic", "smartdukaan"));
             catalogSolrObj.setField("feature_s", catalogValMap.get("feature"));
             catalogSolrObj.setField("brand_ss", catalogValMap.get("brand"));
             catalogSolrObj.setField("create_s", catalogValMap.get("create_timestamp"));
             String[] brands = (String[]) catalogValMap.get("brand");
             for (String brand : brands) {
                 if (brand.equals("FOC")) {
                     catalogSolrObj.setField("show_default_b", false);
+                }
                 if (brand.equals("Live Demo")) {
                     catalogSolrObj.setField("show_default_b", false);
+                }
+            }
             Map<Integer, Integer> avColorMap = (Map<Integer, Integer>) catalogValMap.get("avColor");
             for (Integer warehouseId : ProfitMandiConstants.WAREHOUSE_MAP.keySet()) {
                 catalogSolrObj.setField("w" + warehouseId + "_i", 0);
+            }
             for (Entry<Integer, Integer> avColorEntry : avColorMap.entrySet()) {
                 int whId = avColorEntry.getKey();
+                    }
                     if (modelPrice > endPrice) break;
+                }
                 similalarModels.remove(Integer.valueOf(catalogId));
+            }
-            catalogSolrObj.setField("similarModels_ii", similalarModels == null ? Collections.EMPTY_LIST : similalarModels);
+            catalogSolrObj.setField("similarModels_is", similalarModels == null ? Collections.EMPTY_LIST : similalarModels);
             catalogSolrObj.setField("active_b", active);
-            logger.info("catalogSolrObj {}", catalogSolrObj.get("rank_i"));
             catalogSolrObjs.add(catalogSolrObj);
+        }
-        logger.info("catalogSolrObjs {}", catalogSolrObjs);
         String solrPath = "http://" + solrUrl + ":8984/solr/demo";
         SolrClient solr = new HttpSolrClient.Builder(solrPath).build();
         solr.deleteByQuery("*:*");
         solr.add(catalogSolrObjs);
+    }
     public void pushData() throws Exception {
         this.populateTagItems();
+    }
+    public Optional<SuperCatalogModel> findMappingByCatalogId(List<SuperCatalogModel> superCatalogMappingList, int id) {
+        return superCatalogMappingList.parallelStream()
+                .filter(mapping -> mapping.getCatalogId() == id)
+                .findFirst();
+    }
+    public String findMappingVariantsByCatalogId(List<SuperCatalogMapping> superCatalogMappingList, int id) throws JsonProcessingException {
+        List<Map<String, Object>> variantList = new ArrayList<>();
+        List<SuperCatalogMapping> matchingVariantNames = superCatalogMappingList.parallelStream()
+                .filter(mapping -> mapping.getSuperCatalogId() == id)
+                .collect(Collectors.toList());
+        if (!matchingVariantNames.isEmpty()) {
+            for (SuperCatalogMapping matchingVariantName : matchingVariantNames) {
+                logger.info("matchingVariantName: "+matchingVariantName);
+                   if (matchingVariantName != null && matchingVariantName.getVariantName() != null) {
+                    Map<String, Object> variantObj = new HashMap<>();
+                    variantObj.put("catalogId", matchingVariantName.getCatalogId());
+                    variantObj.put("variantName", matchingVariantName.getVariantName());
+                    variantList.add(variantObj);
+                }
+            }
+        }
+        if (variantList.isEmpty()) {
+            return "[]";
+        }
+        variantList.sort((v1, v2) -> {
+            int[] n1 = extractNumbers((String) v1.get("variantName"));
+            int[] n2 = extractNumbers((String) v2.get("variantName"));
+            int cmp = Integer.compare(n1[0], n2[0]);
+            return cmp != 0 ? cmp : Integer.compare(n1[1], n2[1]);
+        });
+        ObjectMapper mapper = new ObjectMapper();
+        return mapper.writeValueAsString(variantList);
+    }
+    private int[] extractNumbers(String input) {
+        String[] parts = input.split("\\s+");
+        int[] result = new int[2];
+        for (int i = 0; i < Math.min(parts.length, 2); i++) {
+            String part = parts[i].toUpperCase();
+            if (part.endsWith("GB")) {
+                result[i] = Integer.parseInt(part.replace("GB", "").trim());
+            } else if (part.endsWith("TB")) {
+                result[i] = Integer.parseInt(part.replace("TB", "").trim()) * 1024;
+            }
+        }
+        return result;
+    }
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/service/solr/FofoSolr.java – Rev 33574 → 33973