Subversion Repositories SmartDukaan

package com.amazonaws.mws.samples;

import in.shop2020.model.v1.inventory.AmazonFCWarehouseLocation;
import in.shop2020.model.v1.inventory.AmazonFbaInventorySnapshot;
import in.shop2020.thrift.clients.InventoryClient;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.GregorianCalendar;
import java.util.List;
import java.util.Map;

import javax.xml.datatype.DatatypeConfigurationException;
import javax.xml.datatype.DatatypeFactory;
import javax.xml.datatype.XMLGregorianCalendar;

import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;

import au.com.bytecode.opencsv.CSVReader;

import com.amazonaws.mws.MarketplaceWebService;
import com.amazonaws.mws.MarketplaceWebServiceClient;
import com.amazonaws.mws.MarketplaceWebServiceConfig;
import com.amazonaws.mws.MarketplaceWebServiceException;
import com.amazonaws.mws.model.GetReportListRequest;
import com.amazonaws.mws.model.GetReportRequest;
import com.amazonaws.mws.model.IdList;
import com.amazonaws.mws.model.RequestReportRequest;

public class FetchAmazonInventoryfromFile {
        public static void main(String... args){
                /************************************************************************
                 * Access Key ID and Secret Access Key ID, obtained from:
                 * http://aws.amazon.com
                 ***********************************************************************/
                final String accessKeyId = "AKIAII3SGRXBJDPCHSGQ";
                final String secretAccessKey = "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";

                final String appName = "Test";
                final String appVersion = "1.0";
                final String merchantId = "AF6E3O0VE0X4D";

                MarketplaceWebServiceConfig config = new MarketplaceWebServiceConfig();

                /************************************************************************
                 * Uncomment to set the appropriate MWS endpoint.
                 ************************************************************************/
                // US
                // config.setServiceURL("https://mws.amazonservices.com");
                // UK
                // config.setServiceURL("https://mws.amazonservices.co.uk");
                // Germany
                // config.setServiceURL("https://mws.amazonservices.de");
                // France
                // config.setServiceURL("https://mws.amazonservices.fr");
                // Italy
                // config.setServiceURL("https://mws.amazonservices.it");
                // Japan
                // config.setServiceURL("https://mws.amazonservices.jp");
                // China
                // config.setServiceURL("https://mws.amazonservices.com.cn");
                // Canada
                // config.setServiceURL("https://mws.amazonservices.ca");
                // India
                config.setServiceURL("https://mws.amazonservices.in");

                /************************************************************************
                 * You can also try advanced configuration options. Available options are:
                 *
                 *  - Signature Version
                 *  - Proxy Host and Proxy Port
                 *  - User Agent String to be sent to Marketplace Web Service
                 *
                 ***********************************************************************/

                /************************************************************************
                 * Instantiate Http Client Implementation of Marketplace Web Service        
                 ***********************************************************************/

                MarketplaceWebService service = new MarketplaceWebServiceClient(
                                accessKeyId, secretAccessKey, appName, appVersion, config);

                /************************************************************************
                 * Uncomment to try out Mock Service that simulates Marketplace Web Service 
                 * responses without calling Marketplace Web Service  service.
                 *
                 * Responses are loaded from local XML files. You can tweak XML files to
                 * experiment with various outputs during development
                 *
                 * XML files available under com/amazonaws/mws/mock tree
                 *
                 ***********************************************************************/
                // MarketplaceWebService service = new MarketplaceWebServiceMock();

                /************************************************************************
                 * Setup request parameters and uncomment invoke to try out 
                 * sample for Request Report 
                 ***********************************************************************/

                /************************************************************************
                 * Marketplace and Merchant IDs are required parameters for all 
                 * Marketplace Web Service calls.
                 ***********************************************************************/
                // marketplaces from which data should be included in the report; look at the
                // API reference document on the MWS website to see which marketplaces are
                // included if you do not specify the list yourself
                /*CSVReader reader = null; 
                try {
                        //reader = new CSVReader(new FileReader("/home/vikram/Desktop/amazoninventoryreport.txt"),'\t');
                        reader = new CSVReader(new FileReader("/home/amazoninventoryreport.csv"),'\t');
                } catch (FileNotFoundException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }*/
                BufferedReader reader = null;
                try {
                        reader = new BufferedReader(new FileReader("/home/amazoninventoryreport.csv"));
                } catch (FileNotFoundException e1) {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                }
                String[] nextLine = null;
                String Line;
                List<AmazonFbaInventorySnapshot> allamazoninventory = new ArrayList<AmazonFbaInventorySnapshot>();
                try {
                        while ((Line = reader.readLine()) != null) {
                                nextLine = Line.split("\t");
                                System.out.println("SKU " + nextLine[0] + " "+ nextLine[10] +" "+nextLine[11]+" "+nextLine[12]+" "+nextLine[16]);
                                if(nextLine[0].startsWith("FBA")){
                                        AmazonFbaInventorySnapshot amazonfbainventorysnapshot = new AmazonFbaInventorySnapshot() ;
                                        if(!nextLine[10].isEmpty())
                                                amazonfbainventorysnapshot.setAvailability(Long.parseLong(nextLine[10]));
                                        else{
                                                amazonfbainventorysnapshot.setAvailability(0);
                                        }
                                        amazonfbainventorysnapshot.setItem_id(Long.parseLong(nextLine[0].replaceAll("FBA","")));
                                        amazonfbainventorysnapshot.setLocation(AmazonFCWarehouseLocation.Mumbai);
                                        if(nextLine[12].length()>0){
                                                amazonfbainventorysnapshot.setReserved(Long.parseLong(nextLine[12]));
                                        }
                                        else{
                                                amazonfbainventorysnapshot.setReserved(0);
                                        }
                                        if(nextLine[11].length()>0){
                                                amazonfbainventorysnapshot.setUnfulfillable(Long.parseLong(nextLine[11]));
                                        }
                                        else{
                                                amazonfbainventorysnapshot.setUnfulfillable(0);
                                        }
                                        if(nextLine[16].length()>0){
                                                amazonfbainventorysnapshot.setInbound(Long.parseLong(nextLine[16]));
                                        }
                                        else{
                                                amazonfbainventorysnapshot.setInbound(0);
                                        }
                                        allamazoninventory.add(amazonfbainventorysnapshot); 

                                }
                                else if(nextLine[0].startsWith("FBB")){
                                        AmazonFbaInventorySnapshot amazonfbainventorysnapshot = new AmazonFbaInventorySnapshot() ;
                                        amazonfbainventorysnapshot.setAvailability(Long.parseLong(nextLine[10]));
                                        amazonfbainventorysnapshot.setItem_id(Long.parseLong(nextLine[0].replaceAll("FBB","")));
                                        amazonfbainventorysnapshot.setLocation(AmazonFCWarehouseLocation.Bangalore);
                                        amazonfbainventorysnapshot.setReserved(Long.parseLong(nextLine[12]));
                                        amazonfbainventorysnapshot.setUnfulfillable(Long.parseLong(nextLine[11]));
                                        amazonfbainventorysnapshot.setInbound(Long.parseLong(nextLine[16]));
                                        allamazoninventory.add(amazonfbainventorysnapshot); 
                                }
                        }
                        new InventoryClient().getClient().addOrUpdateAllAmazonFbaInventory(allamazoninventory);
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                } catch (TException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
}