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

 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.DataInputStream;
 import java.io.File;
 import java.io.FileInputStream;
+import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
+import java.io.FileReader;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 import java.io.OutputStream;
+import java.io.Reader;
 import java.text.MessageFormat;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 import org.apache.commons.chain.CatalogFactory;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang.StringUtils;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
 /*
  * @author rajveer
+ *
+ *
  */
 		/*List<Long> entityId = Arrays.asList(1001674l,1002575l,1005331l,1005165l,1005164l,1005111l,1005109l,1004952l,1004940l,1004871l,1004701l,1004429l,1004197l,1006174l,1006077l,1005901l,1005757l,1005754l,1005724l,1005704l,1005598l,1005576l,1005558l,1007394l,1007230l,1007226l,1007218l,1007089l,1006925l,1006822l,1006814l,1006175l);
 		for (Long eId : entityId){
 			contentmigrator.touchEntityState(eId);
 		}*/
 		contentmigrator.step6();
+		//System.out.println(contentmigrator.getItems().size());
+	}
 	private void updateSources() throws Exception{
 		Map<Long,List<ExpertReview>> erMap = CreationUtils.getExpertReviews();
+	}
 	private void touchEntityState(Long eId) throws Exception {
 		EntityState es = CreationUtils.getEntityState(eId);
 		es.setMerkedReadyOn(new Date());
 		CreationUtils.updateEntityState(es);
-		System.out.println("Touched " + eId + " successfully!");
+	}
 	private void updateModelForBBQ10() throws Exception{
 		Long entityId = 1007315l;
 		EntityState e1 = CreationUtils.getEntityState(entityId);
 		Entity e2 = CreationUtils.getEntity(entityId);
+			}
+		}
+	}
 	private void step6() throws Exception {
 		//Get All Enum Values of Communication facilities 70114;
-		Map <Long, Entity> allEntities = CreationUtils.getEntities();
+		DefinitionsContainer defc = Catalog.getInstance().getDefinitionsContainer();
-		/*Map <Long, Entity> allEntities = new HashMap<Long, Entity>();
+		Map <Long, Long> allEntities = getValues();
-		allEntities.put(1002529l, CreationUtils.getEntity(1002529l));
-		allEntities.put(1007932l, CreationUtils.getEntity(1007932l));
-		allEntities.put(1007930l, CreationUtils.getEntity(1007930l));
-		allEntities.put(1007934l, CreationUtils.getEntity(1007934l));
-		allEntities.put(1007936l, CreationUtils.getEntity(1007936l));
-		allEntities.put(1007935l, CreationUtils.getEntity(1007935l));*/
-		for (Map.Entry<Long, Entity> entry:allEntities.entrySet()){
+		for (Map.Entry<Long, Long> entry:allEntities.entrySet()){
-			Entity entity = entry.getValue();
+			Long entityId = entry.getKey();
+			Entity entity = CreationUtils.getEntity(entityId);
 			Long categoryId = entity.getCategoryID();
+			boolean found = false;
 			//System.out.println("entity : " + entity.getID());
-			DefinitionsContainer defc = Catalog.getInstance().getDefinitionsContainer();
 			EntityState es = CreationUtils.getEntityState(entity.getID());
 			if(!es.getStatus().equals(EntityStatus.UNASSIGNED)) {
 				if ((categoryId == 10002 || categoryId == 10003 || categoryId == 10004 || categoryId == 10005)
 						&& es != null) {
-					List<Slide> allSlides = entity.getSlides();
-					if(allSlides!=null){
-						Iterator<Slide> slideIterator = allSlides.iterator();
-						while(slideIterator.hasNext()){
-							Slide sl = slideIterator.next();
-							if(defc.getSlideDefinition(sl.getSlideDefinitionID()) == null) {
-								System.out.println("removed slide : " + sl.getSlideDefinitionID());
-								slideIterator.remove();
-								if (entity.getSlideSequence().remove(sl.getSlideDefinitionID())){
-									System.out.println("removed from category slide sequence: " + sl.getSlideDefinitionID());
-								}else {
-									System.out.println("not found category slide sequence: " + sl.getSlideDefinitionID());
-								}
-							}
-						}
-					}
 					Slide videoSlide = entity.getSlide(130031l);
 					if(videoSlide != null){
-						FreeformContent videoffc  = videoSlide.getFreeformContent();
+						List<Feature> features = videoSlide.getFeatures();
-						if (videoffc != null) {
+						if(features != null) {
+							Iterator<Feature> iter = features.iterator();
+							while(iter.hasNext()){
-							videoffc.setFreeformTexts(null);
+								Feature f = iter.next();
+								if(f.getFeatureDefinitionID() == 120475l){
+									found = true;
+									if(!entry.getValue().equals(((EnumDataObject)f.getBullets().get(0).getDataObject()).getEnumValueID())){
+										f.getBullets().get(0).setDataObject(new EnumDataObject(entry.getValue()));
+										try{
+											System.out.println("Recording feature updated:" + entityId);
+											CreationUtils.updateEntity(entity);
+											touchEntityState(entityId);
+										}catch (Exception e){
+											System.out.println("Could not update entity : " + entity.getID());
+										}
+									}
+									break;
-						}
+								}
-					}
+							}
-					Slide batterySlide = entity.getSlide(130043l);
-					if(batterySlide != null){
+							if(!found){
-						List <Feature> features = batterySlide.getFeatures();
+								Feature f = new Feature(120475l);
-						Iterator<Feature> fIterator = features.iterator();
+								f.setBullets(Arrays.asList(new Bullet(new EnumDataObject(entry.getValue()))));
-						while (fIterator.hasNext()){
+								features.add(f);
+								try{
+									System.out.println("Recording feature created:" + entityId);
-							Feature f = fIterator.next();
+									CreationUtils.updateEntity(entity);
-							long fId = f.getFeatureDefinitionID();
+									touchEntityState(entityId);
-							if(fId == 120073){
+								}catch (Exception e){
+									System.out.println("Could not update entity : " + entity.getID());
-								fIterator.remove();
+								}
+							}
+						}
+					}
-					try{
-						CreationUtils.updateEntity(entity);
-					}catch (Exception e){
-						System.out.println("Could not update entity : " + entity.getID());
-					}
-					touchEntityState(entity.getID());
+				}
+			}
+		}
+	}
+	private Map<Long,Long> getValues() {
+		try {
+			Reader reader = new FileReader("/root/sample.json");
+			return new Gson().fromJson(reader, new TypeToken<Map<Long,Long>>() {}.getType());
+		} catch (FileNotFoundException e) {
+			e.printStackTrace();
+			return new HashMap<Long, Long>();
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/ContentStore/src/main/java/in/shop2020/util/ContentMigrator.java – Rev 8009 → 8014