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