Subversion Repositories SmartDukaan

Rev

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

Rev 8843 Rev 8865
Line 4... Line 4...
4 
import in.shop2020.metamodel.core.Entity;
 4 
import in.shop2020.metamodel.core.Entity;
5 
import in.shop2020.metamodel.core.EntityState;
 5 
import in.shop2020.metamodel.core.EntityState;
6 
import in.shop2020.metamodel.core.EntityStatus;
 6 
import in.shop2020.metamodel.core.EntityStatus;
7 
import in.shop2020.metamodel.core.EnumDataObject;
 7 
import in.shop2020.metamodel.core.EnumDataObject;
8 
import in.shop2020.metamodel.core.ExpertReview;
 8 
import in.shop2020.metamodel.core.ExpertReview;
9 
import in.shop2020.metamodel.core.ExpertReviewSource;
 - 
 
10 
import in.shop2020.metamodel.core.Feature;
 9 
import in.shop2020.metamodel.core.Feature;
11 
import in.shop2020.metamodel.core.FreeformContent;
 10 
import in.shop2020.metamodel.core.FreeformContent;
12 
import in.shop2020.metamodel.core.Helpdoc;
 - 
 
13 
import in.shop2020.metamodel.core.Media;
 11 
import in.shop2020.metamodel.core.Media;
14 
import in.shop2020.metamodel.core.Media.Type;
 12 
import in.shop2020.metamodel.core.Media.Type;
15 
import in.shop2020.metamodel.core.PrimitiveDataObject;
 13 
import in.shop2020.metamodel.core.PrimitiveDataObject;
16 
import in.shop2020.metamodel.core.Slide;
 14 
import in.shop2020.metamodel.core.Slide;
17 
import in.shop2020.metamodel.core.SpecialPage;
 - 
 
18 
import in.shop2020.metamodel.definitions.BulletDefinition;
 15 
import in.shop2020.metamodel.definitions.BulletDefinition;
19 
import in.shop2020.metamodel.definitions.Catalog;
 16 
import in.shop2020.metamodel.definitions.Catalog;
20 
import in.shop2020.metamodel.definitions.Category;
 17 
import in.shop2020.metamodel.definitions.Category;
21 
import in.shop2020.metamodel.definitions.CategorySlideDefinition;
 18 
import in.shop2020.metamodel.definitions.CategorySlideDefinition;
22 
import in.shop2020.metamodel.definitions.DefinitionsContainer;
 19 
import in.shop2020.metamodel.definitions.DefinitionsContainer;
Line 28... Line 25...
28 
import in.shop2020.metamodel.util.ExpandedBullet;
 25 
import in.shop2020.metamodel.util.ExpandedBullet;
29 
import in.shop2020.metamodel.util.ExpandedEntity;
 26 
import in.shop2020.metamodel.util.ExpandedEntity;
30 
import in.shop2020.model.v1.catalog.CatalogService.Client;
 27 
import in.shop2020.model.v1.catalog.CatalogService.Client;
31 
import in.shop2020.model.v1.catalog.Item;
 28 
import in.shop2020.model.v1.catalog.Item;
32 
import in.shop2020.model.v1.catalog.status;
 29 
import in.shop2020.model.v1.catalog.status;
33 
import in.shop2020.storage.mongo.StorageManager;
 - 
 
34 
import in.shop2020.thrift.clients.CatalogClient;
 30 
import in.shop2020.thrift.clients.CatalogClient;
35 
import in.shop2020.utils.Logger;
 31 
import in.shop2020.utils.Logger;
36 
 
 32 
 
37 
import java.io.BufferedReader;
 33 
import java.io.BufferedReader;
38 
import java.io.ByteArrayInputStream;
 34 
import java.io.ByteArrayInputStream;
Line 48... Line 44...
48 
import java.io.ObjectInputStream;
 44 
import java.io.ObjectInputStream;
49 
import java.io.ObjectOutputStream;
 45 
import java.io.ObjectOutputStream;
50 
import java.io.OutputStream;
 46 
import java.io.OutputStream;
51 
import java.io.Reader;
 47 
import java.io.Reader;
52 
import java.text.MessageFormat;
 48 
import java.text.MessageFormat;
53 
import java.text.SimpleDateFormat;
 - 
 
54 
import java.util.ArrayList;
 49 
import java.util.ArrayList;
55 
import java.util.Arrays;
 50 
import java.util.Arrays;
56 
import java.util.Calendar;
 51 
import java.util.Calendar;
57 
import java.util.Collection;
 52 
import java.util.Collection;
58 
import java.util.Collections;
 53 
import java.util.Collections;
Line 61... Line 56...
61 
import java.util.Iterator;
 56 
import java.util.Iterator;
62 
import java.util.LinkedHashMap;
 57 
import java.util.LinkedHashMap;
63 
import java.util.List;
 58 
import java.util.List;
64 
import java.util.Map;
 59 
import java.util.Map;
65 
import java.util.Set;
 60 
import java.util.Set;
66 
import java.util.TimeZone;
 - 
 
67 
import java.util.TreeMap;
 61 
import java.util.TreeMap;
68 
 
 62 
 
69 
import org.apache.commons.collections.CollectionUtils;
 63 
import org.apache.commons.collections.CollectionUtils;
70 
import org.apache.commons.io.IOUtils;
 64 
import org.apache.commons.io.IOUtils;
71 
import org.apache.commons.lang.StringUtils;
 65 
import org.apache.commons.lang.StringUtils;
Line 108... Line 102...
108 
		/*contentmigrator.touchEntityState(1008423l);
 102 
		/*contentmigrator.touchEntityState(1008423l);
109 
		contentmigrator.touchEntityState(1008424l);
 103 
		contentmigrator.touchEntityState(1008424l);
110 
		contentmigrator.touchEntityState(1008427l);
 104 
		contentmigrator.touchEntityState(1008427l);
111 
		contentmigrator.touchEntityState(1008428l);*/
 105 
		contentmigrator.touchEntityState(1008428l);*/
112 
 
 106 
 
113 
		//contentmigrator.migrateToMongo();
 107 
		contentmigrator.migrateToMongo();
114 
		contentmigrator.getEditedEntities();
 108 
		//contentmigrator.getEditedEntities();
- 
 
 109 
		/*contentmigrator.touchEntityState(1008706l);
- 
 
 110 
		contentmigrator.touchEntityState(1008707l);
- 
 
 111 
		contentmigrator.touchEntityState(1008708l);
- 
 
 112 
		contentmigrator.touchEntityState(1008709l);
- 
 
 113 
		contentmigrator.touchEntityState(1008710l);
- 
 
 114 
		contentmigrator.touchEntityState(1008711l);
- 
 
 115 
		contentmigrator.touchEntityState(1008714l);
- 
 
 116 
		contentmigrator.touchEntityState(1008715l);
- 
 
 117 
		contentmigrator.touchEntityState(1005505l);
- 
 
 118 
		contentmigrator.touchEntityState(1006864l);*/
115 
	}
 119 
	}
116
120
117 
	private void changeKeys() throws Exception {
 121 
	private void changeKeys() throws Exception {
118 
		Map<Long, Entity>  e = CreationUtils.getEntities();
 122 
		Map<Long, Entity>  e = CreationUtils.getEntities();
119 
		for (Map.Entry<Long, Entity> entry : e.entrySet()) {
 123 
		for (Map.Entry<Long, Entity> entry : e.entrySet()) {
Line 139... Line 143...
139 
 
 143 
 
140 
	private void migrateToMongo() throws Exception{
 144 
	private void migrateToMongo() throws Exception{
141 
		long counter = 0;
 145 
		long counter = 0;
142 
		Collection<EntityState> es = CreationUtils1.getEntitiesState().values();
 146 
		Collection<EntityState> es = CreationUtils1.getEntitiesState().values();
143 
		boolean updated = false;
 147 
		boolean updated = false;
- 
 
 148 
		StringBuffer buffer = new StringBuffer();
144 
		for (EntityState es1 : es) {
 149 
		for (EntityState es1 : es) {
145 
			if(es1.getStatus().equals(EntityStatus.READY)){
 150 
			if(es1.getStatus().equals(EntityStatus.READY)){
- 
 
 151 
				long mongotime = CreationUtils.getEntityState(es1.getID()).getMerkedReadyOn().getTime()/1000;
- 
 
 152 
				long bdbtime = es1.getMerkedReadyOn().getTime()/1000;
- 
 
 153 
				if(bdbtime==mongotime){
146 
				updated = false;
 154 
					updated = false;
147 
				Entity e = CreationUtils1.getEntity(es1.getID());
 155 
					Entity e = CreationUtils1.getEntity(es1.getID());
148 
				List<Slide> slides = e.getSlides();
 156 
					List<Slide> slides = e.getSlides();
149 
				for(Slide slide:slides) {
 157 
					for(Slide slide:slides) {
150 
					FreeformContent ffc = slide.getFreeformContent();
 158 
						FreeformContent ffc = slide.getFreeformContent();
151 
					if (ffc !=null){
 159 
						if (ffc !=null){
152 
						Map<String,Media> m1 = ffc.getMedias();
 160 
							Map<String,Media> m1 = ffc.getMedias();
153 
						if (m1!=null){
 161 
							if (m1!=null){
154 
							Map<String,Media> m = new LinkedHashMap<String, Media>(m1);
 162 
								Map<String,Media> m = new LinkedHashMap<String, Media>(m1);
155 
							for (Map.Entry<String, Media> m2 : m.entrySet()){
 163 
								for (Map.Entry<String, Media> m2 : m.entrySet()){
156 
								m1.put(Long.toString(++counter), m1.remove(m2.getKey()));
 164 
									m1.put(Long.toString(++counter), m1.remove(m2.getKey()));
157 
								updated = true;
 165 
									updated = true;
- 
 
 166 
								}
158 
							}
 167 
							}
159 
						}
 168 
						}
160 
					}
 169 
					}
- 
 
 170 
					if(updated){
- 
 
 171 
						CreationUtils.updateEntity(e);
- 
 
 172 
						System.out.println(e.getID());
161 
				}
 173 
					}
162 
				if(updated){
 174 
				} else {
163 
					CreationUtils.updateEntity(e);
 175 
					buffer.append(es1.getID() + "\n");
164 
				}
 176 
				}
165 
			}
 177 
			}
166 
		}
 178 
		}
- 
 
 179 
		System.out.println("Entities counldnt be updated are :\n" + buffer.toString());
167 
	}
 180 
	}
168 
 
 181 
 
169 
	private void migrateContentStore() throws Exception {
 182 
	private void migrateContentStore() throws Exception {
170 
		for (Map.Entry<Long, Entity> entry :CreationUtils.getEntities().entrySet()){
 183 
		for (Map.Entry<Long, Entity> entry :CreationUtils.getEntities().entrySet()){
171 
			Entity e = entry.getValue();
 184 
			Entity e = entry.getValue();