Subversion Repositories SmartDukaan

Rev

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

Rev 15381 Rev 21826
Line 1... Line 1...
1 
package in.shop2020.dtrapi.Storage;
 1 
package in.shop2020.dtrapi.Storage;
2 
 
 2 
 
3 
 
 3 
 
- 
 
 4 
import in.shop2020.dtrapi.models.FofoForm;
4 
import in.shop2020.dtrapi.models.MasterData;
 5 
import in.shop2020.dtrapi.models.MasterData;
5 
import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
 - 
 
6 
 
 6 
 
7 
import java.awt.List;
 7 
import java.awt.List;
8 
import java.net.UnknownHostException;
 8 
import java.net.UnknownHostException;
9 
import java.util.ArrayList;
 9 
import java.util.ArrayList;
10 
 
 10 
 
Line 13... Line 13...
13 
import com.mongodb.DB;
 13 
import com.mongodb.DB;
14 
import com.mongodb.DBCollection;
 14 
import com.mongodb.DBCollection;
15 
import com.mongodb.DBCursor;
 15 
import com.mongodb.DBCursor;
16 
import com.mongodb.DBObject;
 16 
import com.mongodb.DBObject;
17 
import com.mongodb.MongoClient;
 17 
import com.mongodb.MongoClient;
- 
 
 18 
import com.mongodb.util.JSON;
18 
 
 19 
 
19 
 
 20 
 
20 
public class Mongo {
 21 
public class Mongo {
21 
 
 22 
 
22 
	private static MongoClient mongo;
 23 
	private static MongoClient mongo;
23 
	private static final String CATALOG_DB = "Catalog";
 24 
	private static final String CATALOG_DB = "Catalog";
24 
	private static final String MASTER_DATA = "MasterData";
 25 
	private static final String MASTER_DATA = "MasterData";
- 
 
 26 
	private static final String FOFO_DB = "Fofo";
- 
 
 27 
	private static final String FOFO_FORM_COLLECTION = "RegistrationForm";
25 
 
 28 
 
26 
	static {
 29 
	static {
27 
		try {
 30 
		try {
28 
			mongo = new MongoClient( "localhost" , 27017 );
 31 
			mongo = new MongoClient( "localhost" , 27017 );
29 
		} catch (UnknownHostException e) {
 32 
		} catch (UnknownHostException e) {
Line 61... Line 64...
61 
			MasterData masterData = gson.fromJson(result.next().toString(), MasterData.class);
 64 
			MasterData masterData = gson.fromJson(result.next().toString(), MasterData.class);
62 
			items.add(masterData);
 65 
			items.add(masterData);
63 
		}
 66 
		}
64 
		return items;
 67 
		return items;
65 
	}
 68 
	}
- 
 
 69
- 
 
 70 
	public static void persistFofoRegInfo(FofoForm ff){
- 
 
 71 
		DB db = mongo.getDB(FOFO_DB);
- 
 
 72 
		DBCollection collection = db.getCollection(FOFO_FORM_COLLECTION);
- 
 
 73 
		BasicDBObject orderBy = new BasicDBObject();
- 
 
 74 
		orderBy.put("_id", -1);
- 
 
 75 
		DBCursor cursor = collection.find().sort(orderBy).limit(1);
- 
 
 76 
		long id = 1l;
- 
 
 77 
		while (cursor.hasNext()) {
- 
 
 78 
			Gson gson = new Gson();
- 
 
 79 
			FofoForm existingFofo = gson.fromJson(cursor.next().toString(), FofoForm.class);
- 
 
 80 
			id = existingFofo.get_id() + 1;
- 
 
 81 
		}
- 
 
 82 
		ff.set_id(id);
- 
 
 83 
		Gson gs = new Gson();
- 
 
 84 
		DBObject dbObject = (DBObject) JSON.parse(gs.toJson(ff));
- 
 
 85 
		collection.insert(dbObject);
- 
 
 86 
	}
66 
 
 87 
 
67 
	public static void main(String[] args) throws Exception{
 88 
	public static void main(String[] args) throws Exception{
68 
		System.out.println(getItemsByBundleId(100000));
 89 
		System.out.println(getItemsByBundleId(100000));
69 
	}
 90 
	}
70 
}
 91 
}
71 

            92