Subversion Repositories SmartDukaan

Rev

Rev 1069 | Rev 1153 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1069 Rev 1070
Line 16... Line 16...
16 
import in.shop2020.metamodel.core.Entity;
 16 
import in.shop2020.metamodel.core.Entity;
17 
import in.shop2020.metamodel.core.EntityState;
 17 
import in.shop2020.metamodel.core.EntityState;
18 
import in.shop2020.metamodel.core.FreeformContent;
 18 
import in.shop2020.metamodel.core.FreeformContent;
19 
import in.shop2020.metamodel.core.Media;
 19 
import in.shop2020.metamodel.core.Media;
20 
import in.shop2020.metamodel.core.Slide;
 20 
import in.shop2020.metamodel.core.Slide;
21 
import in.shop2020.metamodel.definitions.OldEntityContainer;
 21 
//import in.shop2020.metamodel.definitions.OldEntityContainer;
22 
import in.shop2020.metamodel.util.CreationUtils;
 22 
import in.shop2020.metamodel.util.CreationUtils;
23 
import in.shop2020.metamodel.util.ExpandedBullet;
 23 
import in.shop2020.metamodel.util.ExpandedBullet;
24 
import in.shop2020.metamodel.util.OldCreationUtils;
 24 
//import in.shop2020.metamodel.util.OldCreationUtils;
25 
import in.shop2020.storage.bdb.StorageManager;
 25 
import in.shop2020.storage.bdb.StorageManager;
26 
 
 26 
 
27 
 
 27 
 
28 
/*
 28 
/*
29 
 * @author rajveer
29 
 * @author rajveer
Line 59... Line 59...
59 
	public ContentMigratorToBDB(String sourceDbPath, String destinationDbPath) {
 59 
	public ContentMigratorToBDB(String sourceDbPath, String destinationDbPath) {
60 
		this.sourceDbPath = sourceDbPath;
 60 
		this.sourceDbPath = sourceDbPath;
61 
		this.destinationDbPath = destinationDbPath;
 61 
		this.destinationDbPath = destinationDbPath;
62 
	}
 62 
	}
63
63
64 
	public boolean addLearnedFields() throws Exception{
 64 
//	public boolean addLearnedFields() throws Exception{
65 
		OldEntityContainer oldEnts = new OldEntityContainer(sourceDbPath);
 65 
//		OldEntityContainer oldEnts = new OldEntityContainer(sourceDbPath);
66 
		Map<Long, List<ExpandedBullet>> learnedBullets = oldEnts.getLearnedBullets();
 66 
//		Map<Long, List<ExpandedBullet>> learnedBullets = oldEnts.getLearnedBullets();
67 
		CreationUtils.storeLearnedBullets(learnedBullets);
 67 
//		CreationUtils.storeLearnedBullets(learnedBullets);
68 
		return true;
 68 
//		return true;
69
69 
//
70 
	}
 70 
//	}
71
71 
//
72 
	public boolean addMedia() throws NumberFormatException, IOException, Exception{
 72 
//	public boolean addMedia() throws NumberFormatException, IOException, Exception{
73 
	    FileInputStream fstream = new FileInputStream("/home/rajveer/Desktop/test1");
 73 
//	    FileInputStream fstream = new FileInputStream("/home/rajveer/Desktop/test1");
74 
	    DataInputStream in = new DataInputStream(fstream);
 74 
//	    DataInputStream in = new DataInputStream(fstream);
75 
	    BufferedReader br = new BufferedReader(new InputStreamReader(in));
 75 
//	    BufferedReader br = new BufferedReader(new InputStreamReader(in));
76 
	    String strLine;
 76 
//	    String strLine;
77
77 
//
78 
	    while ((strLine = br.readLine()) != null)   {
 78 
//	    while ((strLine = br.readLine()) != null)   {
79 
	    	String[] parts  = strLine.split(":");
 79 
//	    	String[] parts  = strLine.split(":");
80 
	    	long entityID = Long.parseLong(parts[0]);
 80 
//	    	long entityID = Long.parseLong(parts[0]);
81 
	    	long slideID = Long.parseLong(parts[1]);
 81 
//	    	long slideID = Long.parseLong(parts[1]);
82 
	    	Entity entity = StorageManager.getStorageManager().getEntity(entityID);
 82 
//	    	Entity entity = StorageManager.getStorageManager().getEntity(entityID);
83 
	    	Map<String, Media> medias =  OldCreationUtils.getRawMedia(entityID);
 83 
//	    	Map<String, Media> medias =  OldCreationUtils.getRawMedia(entityID);
84 
	    	String imageLabels = parts[2];
 84 
//	    	String imageLabels = parts[2];
85 
	    	String videoLabels = parts[3];
 85 
//	    	String videoLabels = parts[3];
86 
	    	if(!imageLabels.equalsIgnoreCase("null")){
 86 
//	    	if(!imageLabels.equalsIgnoreCase("null")){
87 
	    		String[] labels = imageLabels.split(",");
 87 
//	    		String[] labels = imageLabels.split(",");
88 
	    		for(int i = 0; i < labels.length; i++){
 88 
//	    		for(int i = 0; i < labels.length; i++){
89 
	    			if(medias.containsKey(labels[i])){
 89 
//	    			if(medias.containsKey(labels[i])){
90 
	    				Media media = medias.get(labels[i]);
 90 
//	    				Media media = medias.get(labels[i]);
91 
	    				entity.getSlide(slideID).getFreeformContent().addMedia(media);
 91 
//	    				entity.getSlide(slideID).getFreeformContent().addMedia(media);
92 
	    			}
 92 
//	    			}
93 
	    		}
 93 
//	    		}
94 
	    	}
 94 
//	    	}
95 
	    	if(!videoLabels.equalsIgnoreCase("null")){
 95 
//	    	if(!videoLabels.equalsIgnoreCase("null")){
96 
	    		String[] labels = videoLabels.split(",");
 96 
//	    		String[] labels = videoLabels.split(",");
97 
	    		for(int i = 0; i < labels.length; i++){
 97 
//	    		for(int i = 0; i < labels.length; i++){
98 
	    			if(medias.containsKey(labels[i])){
 98 
//	    			if(medias.containsKey(labels[i])){
99 
	    				Media media = medias.get(labels[i]);
 99 
//	    				Media media = medias.get(labels[i]);
100 
	    				entity.getSlide(slideID).getFreeformContent().addMedia(media);
 100 
//	    				entity.getSlide(slideID).getFreeformContent().addMedia(media);
101 
	    			}
 101 
//	    			}
102 
	    		}
 102 
//	    		}
103 
	    	}
 103 
//	    	}
104 
	    	StorageManager.getStorageManager().updateEntity(entity);
 104 
//	    	StorageManager.getStorageManager().updateEntity(entity);
105 
	    }
 105 
//	    }
106 
	    in.close();
 106 
//	    in.close();
107 
	    return true;
 107 
//	    return true;
108 
}
 108 
//}
109 
 
 109 
 
110 
	/**
 110 
	/**
111 
	 * this function will read source definition and source entities, and will convert
 111 
	 * this function will read source definition and source entities, and will convert
112 
	 * source entities to destination entities according to destination definitions.
112 
	 * source entities to destination entities according to destination definitions.
113 
	 *
113 
	 *
114 
	 * @return boolean
 114 
	 * @return boolean
115 
	 * @throws Exception
115 
	 * @throws Exception
116 
	 */
 116 
	 */
117 
	public boolean migrate() throws Exception{
 117 
//	public boolean migrate() throws Exception{
118 
		OldEntityContainer sourceEnts = new OldEntityContainer(sourceDbPath);
 118 
//		OldEntityContainer sourceEnts = new OldEntityContainer(sourceDbPath);
119
119 
//
120 
		StringBuilder sb = new StringBuilder();
 120 
//		StringBuilder sb = new StringBuilder();
121 
		Map<Long, Entity> entities = sourceEnts.getEntities();
 121 
//		Map<Long, Entity> entities = sourceEnts.getEntities();
122 
		for(Long entityId: entities.keySet()){
 122 
//		for(Long entityId: entities.keySet()){
123 
			Entity entity = OldCreationUtils.getEntity(entityId);
 123 
//			Entity entity = OldCreationUtils.getEntity(entityId);
124 
			if(entity.getID() == 0){
 124 
//			if(entity.getID() == 0){
125 
				continue;
 125 
//				continue;
126 
			}
 126 
//			}
127 
			Entity newEntity = new Entity(entity.getID(), entity.getCategoryID());
 127 
//			Entity newEntity = new Entity(entity.getID(), entity.getCategoryID());
128 
			newEntity.setBrand(entity.getBrand());
 128 
//			newEntity.setBrand(entity.getBrand());
129 
			newEntity.setModelName(entity.getModelName());
 129 
//			newEntity.setModelName(entity.getModelName());
130 
			newEntity.setModelNumber(entity.getModelNumber());
 130 
//			newEntity.setModelNumber(entity.getModelNumber());
131
131 
//
132 
			newEntity.setSlideSequence(OldCreationUtils.getSlideSequence(entity.getID()));
 132 
//			newEntity.setSlideSequence(OldCreationUtils.getSlideSequence(entity.getID()));
133
133 
//
134 
			List<Slide> slides = entity.getSlides();
 134 
//			List<Slide> slides = entity.getSlides();
135 
			if(slides!=null){
 135 
//			if(slides!=null){
136 
			for(Slide slide: slides){
 136 
//			for(Slide slide: slides){
137 
				FreeformContent ffc = slide.getFreeformContent();
 137 
//				FreeformContent ffc = slide.getFreeformContent();
138 
				//sb.append(entityId+ ":" + slide.getSlideDefinitionID() + ":"+ ffc.getFreeformTexts()+"\n");
 138 
//				//sb.append(entityId+ ":" + slide.getSlideDefinitionID() + ":"+ ffc.getFreeformTexts()+"\n");
139 
				FreeformContent newFfc = new FreeformContent();
 139 
//				FreeformContent newFfc = new FreeformContent();
140 
				newFfc.setFreeformTexts(ffc.getFreeformTexts());
 140 
//				newFfc.setFreeformTexts(ffc.getFreeformTexts());
141 
				slide.setFreeformContent(newFfc);
 141 
//				slide.setFreeformContent(newFfc);
142 
				//if(ffc.getAllLabels()!=null && !ffc.getAllLabels().isEmpty()){
 142 
//				//if(ffc.getAllLabels()!=null && !ffc.getAllLabels().isEmpty()){
143 
					//sb.append(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getAllLabels() + "\n");
 143 
//					//sb.append(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getAllLabels() + "\n");
144 
					//sb.append(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getImageLabels() + ":" + ffc.getYoutubeLabels() + "\n");
 144 
//					//sb.append(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getImageLabels() + ":" + ffc.getYoutubeLabels() + "\n");
145 
					//System.out.println(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getImageLabels() + ":" + ffc.getYoutubeLabels());
 145 
//					//System.out.println(entity.getID() + ":" + slide.getSlideDefinitionID() + ":" + ffc.getImageLabels() + ":" + ffc.getYoutubeLabels());
146 
//					System.out.println("some image found");
 146 
////					System.out.println("some image found");
147 
//					System.out.println(ffc.getImageLabels());
 147 
////					System.out.println(ffc.getImageLabels());
148 
//					System.out.println(ffc.getYoutubeLabels());
 148 
////					System.out.println(ffc.getYoutubeLabels());
149 
				//}
 149 
//				//}
150 
				//System.out.println(ffc.getImageLabels());
 150 
//				//System.out.println(ffc.getImageLabels());
151 
				//System.out.println(ffc.getYoutubeLabels());
 151 
//				//System.out.println(ffc.getYoutubeLabels());
152 
				//FreeformContent newFfc = new FreeformContent();
 152 
//				//FreeformContent newFfc = new FreeformContent();
153 
				//newFfc.setFreeformTexts(ffc.getFreeformTexts());
 153 
//				//newFfc.setFreeformTexts(ffc.getFreeformTexts());
154 
			}
 154 
//			}
155 
			}
 155 
//			}
156 
			newEntity.setSlides(slides);
 156 
//			newEntity.setSlides(slides);
157 
			EntityState entityMetadata = new EntityState(entityId, "admin");
 157 
//			EntityState entityMetadata = new EntityState(entityId, "admin");
158 
			StorageManager.getStorageManager().createEntity(newEntity, entityMetadata);
 158 
//			StorageManager.getStorageManager().createEntity(newEntity, entityMetadata);
159
159 
//
160 
			//System.out.println(StorageManager.getStorageManager().getStorageManager().getEntity(entityId).getSlide(130033).getFreeformContent().getFreeformTexts());
 160 
//			//System.out.println(StorageManager.getStorageManager().getStorageManager().getEntity(entityId).getSlide(130033).getFreeformContent().getFreeformTexts());
161
161 
//
162 
			//StorageManager.getStorageManager().close();
 162 
//			//StorageManager.getStorageManager().close();
163 
			//System.out.println("Entity id is" + entity.getID());
 163 
//			//System.out.println("Entity id is" + entity.getID());
164 
		}
 164 
//		}
165
165 
//
166 
		StorageManager.getStorageManager().close();
 166 
//		StorageManager.getStorageManager().close();
167 
		//System.out.println(sb.toString());
 167 
//		//System.out.println(sb.toString());
168 
		return true;
 168 
//		return true;
169 
	}
 169 
//	}
170 
}
 170 
}