WebSVN – SmartDukaan – Diff – //trunk/ContentStore/src/main/java/in/shop2020/util/ContentGenerationUtility.java

     private Date 				  timeStamp			  		  = null;
     private CommandLine           cmd                         = null;
     private Map<Long, List<Item>> entityIdItemMap             = new LinkedHashMap<Long, List<Item>>();
     private Long                  lastGenerationTime          = 0l;
     private Map<Long, Entity>     entities;
+    private List<Long> removeEntities = new ArrayList<Long>();
     private List<Item>            items;
     private List<Source>          sources;
     private CatalogClient         csc;
     private Client                client;
     private List<Item>			  alertItems;
             log.info("Before removing old resources.");
             removeOldResources();
+        }
-        // this still needs to be evolved. Must not be used.
-        if (GENERATION_TYPE.equals(GENERATION_TYPE_INCREMENTAL)) {
+/*        if (GENERATION_TYPE.equals(GENERATION_TYPE_INCREMENTAL)) {
+        }
+*/
-        // Populate the entityIdIemMap
         populateEntityIdItemMap();
         // Generate partners and json objects for phones only
         if (!GENERATION_TYPE.equals(GENERATION_TYPE_ONE)) {
         	try	{
 	        	ProductListGenerator generator = new ProductListGenerator(entityIdItemMap);
             boolean domainOnce = true;
             boolean sourceOnce = true;
             for(String domainPath : DOMAINPATHS){
             	String domainName = domainPath;
             	String pathName = domainPath.split("\\.")[0].split(":")[0];
-            	//Special check for store.
-            	minPrice = priceInserter.insertPriceInHtml(items, entityId,
+            	if(!removeEntities.contains(entityId)){
-            			domainName, Utils.EXPORT_PATH + "html/entities-" +  pathName + "/", null);
+            		priceInserter.insertPriceInHtml(items, entityId, domainName, Utils.EXPORT_PATH + "html/entities-" +  pathName + "/", null);
+            	}
             	if(domainOnce){
+            		minPrice = getMinPrice(items, entityId, null);
             		priceString.append("<field name=\"F_50002\">" + minPrice + "</field>");
             		availabilityString.append("<field name=\"F_50028\">" + availability + "</field>");
             		if(entityTags.containsKey(entityId)) {
             			List<String> tags = entityTags.get(entityId);
             			for(String tag: tags){
+            		}
             		domainOnce = false;
+            	}
             	if(sources != null){
             		for (Source source : sources) {
-                        minPrice = priceInserter.insertPriceInHtml(items, entityId,
-                                domainName, Utils.EXPORT_PATH + "html/entities-" + pathName + "/",
+						priceInserter.insertPriceInHtml(items, entityId,domainName, Utils.EXPORT_PATH + "html/entities-" + pathName + "/",source);
-                                source);
                         if(sourceOnce){
+                        	minPrice = getMinPrice(items, entityId, source);
                         	priceString.append("<field name=\"F_50002_"
                                 + source.getId() + "\">" + minPrice + "</field>");
+                        }
+            		}
             		sourceOnce = false;
             if (isValidEntity(entities.get(entityID))) {
                 validEntities.add(entities.get(entityID));
                 validEntityIds.add(entityID);
+            }
+        }
+        log.info("Generating synonyms");
+        SynonymExporter sx = new SynonymExporter();
+        sx.storeSynonyms(validEntities);
         // Calculate comparison scores
         log.info("Calculating comparison scores");
         NewCMP cmp = new NewCMP(validEntities);
         Map<Long, Map<Long, Double>> slideScoresByEntity = cmp.getSlideScores();
+        }
         for (Map.Entry<Long, List<Item>> entry : entityIdItemMap.entrySet()) {
             List<Item> items = entry.getValue();
             for (Item item : items) {
-                if ( (item.getItemStatus() == status.CONTENT_COMPLETE && validEntityIds.contains(item.getCatalogItemId()))
+                if (item.getItemStatus() == status.CONTENT_COMPLETE
                 		|| item.getItemStatus() == status.COMING_SOON) {
                 	if(item.getStartDate() <= new Date().getTime() + ONE_DAY){
                 		item.setItemStatus(status.ACTIVE);
                 		item.setStatus_description("This item is active");
                 	} else {
+        }
         Utils.info("Processing " + entityIdItemMap.size() + " entities");
         // Remove all items which have not been updated since last content
         // generation.
-        List<Long> removeEntities = new ArrayList<Long>();
+        if (!(UPDATE_TYPE_CONTENT.equals(UPDATE_TYPE) || lastGenerationTime == 0)) {
-        for (Long entityId : entityIdItemMap.keySet()) {
+	        for (Long entityId : entityIdItemMap.keySet()) {
-            boolean isValidEntity = false;
+	            boolean isValidEntity = false;
-            // If any one of the items has been updated before current
+	            // If any one of the items has been updated before current
-            // timestamp, than we generate content for whole entity
+	            // timestamp, than we generate content for pricing
-            for (Item item : entityIdItemMap.get(entityId)) {
+	            for (Item item : entityIdItemMap.get(entityId)) {
-                if (item.getUpdatedOn() > lastGenerationTime || item.getItemStatus()==status.COMING_SOON) {
+	                if (item.getUpdatedOn() > lastGenerationTime) {
-                    isValidEntity = true;
+	                    isValidEntity = true;
-                }
+	                }
-            }
+	            }
-            if (!isValidEntity) {
+	            if (!isValidEntity) {
-                removeEntities.add(entityId);
+	                removeEntities.add(entityId);
-            }
+	            }
-        }
+	        }
-        for (Long entityId : removeEntities) {
-            entityIdItemMap.remove(entityId);
+        }
         Utils.info("Final valid entities to be processed: " + entityIdItemMap.size());
+    }
 			DBUtils.store(gson.toJson(finalsynonyms), autosuggestFilename);
 		} catch (Exception e) {
 			e.printStackTrace();
+		}
+    }
+	public double getMinPrice(List<Item> items, long catalogId, Source source) {
+		Item minPriceItem = null;
+		for (Item item : items) {
+			if (minPriceItem == null
+					|| minPriceItem.getSellingPrice() > item.getSellingPrice()) {
+				minPriceItem = item;
+			}
+		}
+		return minPriceItem.getSellingPrice();
+	}
+}

Subversion Repositories SmartDukaan

(root)//trunk/ContentStore/src/main/java/in/shop2020/util/ContentGenerationUtility.java – Rev 7506 → 7662