Subversion Repositories SmartDukaan

Rev

Rev 13120 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 13120 Rev 13479
Line 1... Line 1...
1 
package com.amazonaws.mws.samples;
 1 
package com.amazonaws.mws.samples;
2 
 
 2 
 
3 
import in.shop2020.model.v1.order.AmazonFCWarehouseLocation;
 3 
import in.shop2020.model.v1.order.AmazonFCWarehouseLocation;
- 
 
 4 
import in.shop2020.model.v1.order.AmazonFbaOrderItem;
4 
import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
 5 
import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
5 
import in.shop2020.model.v1.order.AmazonHourlySaleSnapshot;
 6 
import in.shop2020.model.v1.order.AmazonHourlySaleSnapshot;
6 
 
 7 
 
7 
import java.net.UnknownHostException;
 8 
import java.net.UnknownHostException;
8 
import java.util.ArrayList;
 9 
import java.util.ArrayList;
Line 26... Line 27...
26 
{
 27 
{
27 
    private static MongoClient mongo;
 28 
    private static MongoClient mongo;
28 
    private static final String AMAZON_SALES_SNAPSHOT = "AmazonSaleSnapshot";
 29 
    private static final String AMAZON_SALES_SNAPSHOT = "AmazonSaleSnapshot";
29 
    private static final String AMAZON_DAILY_SALE_SNAPSHOT = "AmazonDailySaleSnapshot";
 30 
    private static final String AMAZON_DAILY_SALE_SNAPSHOT = "AmazonDailySaleSnapshot";
30 
    private static final String AMAZON_HOURLY_SALE_SNAPSHOT = "AmazonHourlySaleSnapshot";
 31 
    private static final String AMAZON_HOURLY_SALE_SNAPSHOT = "AmazonHourlySaleSnapshot";
- 
 
 32 
    private static final String AMAZON_SALE_DUMP = "AmazonSaleData";
31 
 
 33 
 
32 
 
 34 
 
33 
    static {
 35 
    static {
34 
        try {
 36 
        try {
35 
            mongo = new MongoClient( "localhost" , 27017 );
 37 
            mongo = new MongoClient( "localhost" , 27017 );
Line 137... Line 139...
137 
        }
 139 
        }
138 
        collection.createIndex((DBObject) JSON.parse("{'dateOfSale':1}"));
 140 
        collection.createIndex((DBObject) JSON.parse("{'dateOfSale':1}"));
139 
        return true;
 141 
        return true;
140 
    }
 142 
    }
141
143
- 
 
 144 
    public static boolean addOrUpdateFbaSales(List<AmazonFbaOrderItem> sales, long startTime, long endTime) throws JSONException{
- 
 
 145 
        DB db = mongo.getDB(AMAZON_SALES_SNAPSHOT);
- 
 
 146 
        DBCollection collection = db.getCollection(AMAZON_SALE_DUMP);
- 
 
 147 
        BasicDBObject query = new BasicDBObject();
- 
 
 148 
        BasicDBObject obj = new BasicDBObject();
- 
 
 149 
        obj.put("$gte", startTime);
- 
 
 150 
        obj.put("$lte", endTime);
- 
 
 151 
        query.put("purchaseDate",obj);
- 
 
 152 
        collection.remove(query);
- 
 
 153 
        System.out.println(query);
- 
 
 154 
        Gson gs = new Gson();
- 
 
 155 
        for (AmazonFbaOrderItem sale :sales){
- 
 
 156 
            DBObject dbObject = (DBObject) JSON.parse(gs.toJson(sale));
- 
 
 157 
            collection.insert(dbObject);
- 
 
 158 
        }
- 
 
 159 
        collection.createIndex((DBObject) JSON.parse("{'purchaseDate':1, 'amazonOrderId':1}"));
- 
 
 160 
        return true;
- 
 
 161 
    }
- 
 
 162
142 
    public static boolean addHourlySnapshot(List<AmazonHourlySaleSnapshot> sales){
 163 
    public static boolean addHourlySnapshot(List<AmazonHourlySaleSnapshot> sales){
143 
        DB db = mongo.getDB(AMAZON_SALES_SNAPSHOT);
 164 
        DB db = mongo.getDB(AMAZON_SALES_SNAPSHOT);
144 
        DBCollection collection = db.getCollection(AMAZON_HOURLY_SALE_SNAPSHOT);
 165 
        DBCollection collection = db.getCollection(AMAZON_HOURLY_SALE_SNAPSHOT);
145 
        Calendar cal = Calendar.getInstance();
 166 
        Calendar cal = Calendar.getInstance();
146 
        cal.add(Calendar.DATE, -1);cal.set(Calendar.HOUR_OF_DAY, 00);cal.set(Calendar.MINUTE,00);cal.set(Calendar.SECOND,00);cal.set(Calendar.MILLISECOND,00);
 167 
        cal.add(Calendar.DATE, -1);cal.set(Calendar.HOUR_OF_DAY, 00);cal.set(Calendar.MINUTE,00);cal.set(Calendar.SECOND,00);cal.set(Calendar.MILLISECOND,00);