Subversion Repositories SmartDukaan

/*******************************************************************************
 *  Copyright 2009 Amazon Services.
 *  Licensed under the Apache License, Version 2.0 (the "License"); 
 *  
 *  You may not use this file except in compliance with the License. 
 *  You may obtain a copy of the License at: http://aws.amazon.com/apache2.0
 *  This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
 *  CONDITIONS OF ANY KIND, either express or implied. See the License for the 
 *  specific language governing permissions and limitations under the License.
 * ***************************************************************************** 
 *
 *  Marketplace Web Service Java Library
 *  API Version: 2009-01-01
 *  Generated: Wed Feb 18 13:28:48 PST 2009 
 * 
 */

package com.amazonaws.mws.samples;

import java.io.ByteArrayInputStream;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.nio.channels.FileChannel;
import java.security.DigestInputStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.List;
import java.util.ArrayList;
import java.util.TimeZone;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBException;
import javax.xml.bind.Marshaller;
import javax.xml.datatype.DatatypeConfigurationException;
import javax.xml.datatype.DatatypeFactory;
import javax.xml.datatype.XMLGregorianCalendar;

import com.amazonaws.mws.*;
import com.amazonaws.mws.model.*;
import com.amazonaws.mws.mock.MarketplaceWebServiceMock;
import org.apache.commons.codec.binary.*;

import in.shop2020.feeds.products.AmazonEnvelope;
import in.shop2020.feeds.products.BaseCurrencyCodeWithDefault;
import in.shop2020.feeds.products.CE;
import in.shop2020.feeds.products.HandheldOrPDA;
import in.shop2020.feeds.products.Header;
import in.shop2020.feeds.products.Inventory;
import in.shop2020.feeds.products.Listings;
import in.shop2020.feeds.products.OverrideCurrencyAmount;
import in.shop2020.feeds.products.Price;
import in.shop2020.feeds.products.Product;
import in.shop2020.feeds.products.StandardProductID;
import in.shop2020.model.v1.catalog.CatalogService.Client;
import in.shop2020.model.v1.catalog.CatalogServiceException;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.model.v1.inventory.InventoryServiceException;
import in.shop2020.model.v1.inventory.ItemInventory;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.InventoryClient;

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

/**
 * 
 * Submit Feed Samples
 * 
 * 
 */
public class SubmitFeed {

    /**
     * Just add a few required parameters, and try the service Submit Feed
     * functionality
     * 
     * @param args
     *            unused
     *            
     */
    /**
     * @param args
     * @throws TException 
     * @throws CatalogServiceException 
     */
        
        final public static String AMAZON_LISTING_XML = "/home/vikram/listing.xml";
        final public static String AMAZON_INVENTORY_XML = "/home/vikram/inventory.xml";
        final public static String AMAZON_PRICING_XML   = "/home/vikram/pricing.xml";
    public static void main(String... args) throws CatalogServiceException, TException {

        /************************************************************************
         * Access Key ID and Secret Access Key ID, obtained from:
         * http://aws.amazon.com
         ***********************************************************************/
        

        //public static final String marketplaceId = "A21TJRUUN4KGV";

        
                
        
        final String accessKeyId = "AKIAII3SGRXBJDPCHSGQ";
        final String secretAccessKey = "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";

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

        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);


        /************************************************************************
         * Setup request parameters and uncomment invoke to try out sample for
         * Submit Feed
         ***********************************************************************/

        /************************************************************************
         * Marketplace and Merchant IDs are required parameters for all
         * Marketplace Web Service calls.
         ***********************************************************************/
        //final String merchantId = "AF6E300VE0X4D";
        final String merchantId = "AF6E3O0VE0X4D";      
        // marketplaces to which this feed will be submitted; look at the
        // API reference document on the MWS website to see which marketplaces are
        // included if you do not specify the list yourself
        final IdList marketplaces = new IdList(Arrays.asList(
                        "A21TJRUUN4KGV"));

        SubmitFeedRequest requestlisting = new SubmitFeedRequest();
        SubmitFeedRequest requestinventory = new SubmitFeedRequest();
        SubmitFeedRequest requestpricing = new SubmitFeedRequest();
        requestlisting.setMerchant(merchantId);
        requestinventory.setMerchant(merchantId);
        requestpricing.setMerchant(merchantId);
        requestlisting.setMarketplaceIdList(marketplaces);
        requestinventory.setMarketplaceIdList(marketplaces);
        requestpricing.setMarketplaceIdList(marketplaces);
        requestlisting.setFeedType("_POST_PRODUCT_DATA_");
        requestinventory.setFeedType("_POST_INVENTORY_AVAILABILITY_DATA_");
        requestpricing.setFeedType("_POST_PRODUCT_PRICING_DATA_");
        // MWS exclusively offers a streaming interface for uploading your
        // feeds. This is because
        // feed sizes can grow to the 1GB+ range - and as your business grows
        // you could otherwise
        // silently reach the feed size where your in-memory solution will no
        // longer work, leaving you
        // puzzled as to why a solution that worked for a long time suddenly
        // stopped working though
        // you made no changes. For the same reason, we strongly encourage you
        // to generate your feeds to
        // local disk then upload them directly from disk to MWS via Java -
        // without buffering them in JavaFileNotFoundException
        // memory in their entirety.
        // Note: MarketplaceWebServiceClient will not retry a submit feed request
        // because there is no way to reset the InputStream from our client. 
        // To enable retry, recreate the InputStream and resubmit the feed
        // with the new InputStream. 
        //
        try {
                
                createListingFeed();
                createInventoryFeed();
                createPricingFeed();
                FileInputStream listingfis = new FileInputStream(AMAZON_LISTING_XML);
                FileInputStream inventoryfis = new FileInputStream(AMAZON_INVENTORY_XML);
                FileInputStream pricingfis = new FileInputStream(AMAZON_PRICING_XML);
                requestlisting.setContentMD5(computeContentMD5HeaderValue(listingfis));
                requestinventory.setContentMD5(computeContentMD5HeaderValue(inventoryfis));
                requestpricing.setContentMD5(computeContentMD5HeaderValue(pricingfis));
                        requestlisting.setFeedContent(listingfis);
                        requestinventory.setFeedContent(inventoryfis);
                        requestpricing.setFeedContent(pricingfis);
                } catch (FileNotFoundException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
                try {
                        invokeSubmitFeed(service,requestlisting);
                        Thread.sleep(60000);
                        invokeSubmitFeed(service,requestinventory);
                        Thread.sleep(60000);
                        invokeSubmitFeed(service,requestpricing);
                        Thread.sleep(60000);
                } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }

    }

    /**
     * Submit Feed request sample Uploads a file for processing together with
     * the necessary metadata to process the file, such as which type of feed it
     * is. PurgeAndReplace if true means that your existing e.g. inventory is
     * wiped out and replace with the contents ocf this feed - use with caution
     * (the default is false).
     * 
     * @param service
     *            instance of MarketplaceWebService service
     * @param request
     *            Action to invoke
     */
    public static void invokeSubmitFeed(MarketplaceWebService service,
            SubmitFeedRequest request) {
        try {

            SubmitFeedResponse response = service.submitFeed(request);

            System.out.println("SubmitFeed Action Response");
            System.out
            .println("=============================================================================");
            System.out.println();

            System.out.print("    SubmitFeedResponse");
            System.out.println();
            if (response.isSetSubmitFeedResult()) {
                System.out.print("        SubmitFeedResult");
                System.out.println();
                SubmitFeedResult submitFeedResult = response
                .getSubmitFeedResult();
                if (submitFeedResult.isSetFeedSubmissionInfo()) {
                    System.out.print("            FeedSubmissionInfo");
                    System.out.println();
                    FeedSubmissionInfo feedSubmissionInfo = submitFeedResult
                    .getFeedSubmissionInfo();
                    if (feedSubmissionInfo.isSetFeedSubmissionId()) {
                        System.out.print("                FeedSubmissionId");
                        System.out.println();
                        System.out.print("                    "
                                + feedSubmissionInfo.getFeedSubmissionId());
                        System.out.println();
                    }
                    if (feedSubmissionInfo.isSetFeedType()) {
                        System.out.print("                FeedType");
                        System.out.println();
                        System.out.print("                    "
                                + feedSubmissionInfo.getFeedType());
                        System.out.println();
                    }
                    if (feedSubmissionInfo.isSetSubmittedDate()) {
                        System.out.print("                SubmittedDate");
                        System.out.println();
                        System.out.print("                    "
                                + feedSubmissionInfo.getSubmittedDate());
                        System.out.println();
                    }
                    if (feedSubmissionInfo.isSetFeedProcessingStatus()) {
                        System.out
                        .print("                FeedProcessingStatus");
                        System.out.println();
                        System.out.print("                    "
                                + feedSubmissionInfo.getFeedProcessingStatus());
                        System.out.println();
                    }
                    if (feedSubmissionInfo.isSetStartedProcessingDate()) {
                        System.out
                        .print("                StartedProcessingDate");
                        System.out.println();
                        System.out
                        .print("                    "
                                + feedSubmissionInfo
                                .getStartedProcessingDate());
                        System.out.println();
                    }
                    if (feedSubmissionInfo.isSetCompletedProcessingDate()) {
                        System.out
                        .print("                CompletedProcessingDate");
                        System.out.println();
                        System.out.print("                    "
                                + feedSubmissionInfo
                                .getCompletedProcessingDate());
                        System.out.println();
                    }
                }
            }
            if (response.isSetResponseMetadata()) {
                System.out.print("        ResponseMetadata");
                System.out.println();
                ResponseMetadata responseMetadata = response
                .getResponseMetadata();
                if (responseMetadata.isSetRequestId()) {
                    System.out.print("            RequestId");
                    System.out.println();
                    System.out.print("                "
                            + responseMetadata.getRequestId());
                    System.out.println();
                }
            }
            System.out.println(response.getResponseHeaderMetadata());
            System.out.println();
            System.out.println();

        } catch (MarketplaceWebServiceException ex) {

            System.out.println("Caught Exception: " + ex.getMessage());
            System.out.println("Response Status Code: " + ex.getStatusCode());
            System.out.println("Error Code: " + ex.getErrorCode());
            System.out.println("Error Type: " + ex.getErrorType());
            System.out.println("Request ID: " + ex.getRequestId());
            System.out.print("XML: " + ex.getXML());
            System.out.println("ResponseHeaderMetadata: " + ex.getResponseHeaderMetadata());
        }
    }
    
public static void createListingFeed() throws CatalogServiceException, TException{
                
                
                File file = new File(AMAZON_LISTING_XML);
                AmazonEnvelope amazonenvelope =  new AmazonEnvelope();
                Header header = new Header();
                header.setDocumentVersion("1.0");
                header.setMerchantIdentifier("AF6E3O0VE0X4D");
                header.setOverrideReleaseId(null);
                amazonenvelope.setHeader(header);
                amazonenvelope.setMessageType("Product");
                amazonenvelope.setMarketplaceName(null);
                amazonenvelope.setPurgeAndReplace(false);
                JAXBContext context;
                Marshaller m=null;
                try {
                        context = JAXBContext.newInstance(AmazonEnvelope.class);
                        m = context.createMarshaller();
                } catch (JAXBException e1) {
                        e1.printStackTrace();
                }
                
                
                XMLGregorianCalendar today = null;
                Calendar localCalendar = Calendar.getInstance(TimeZone.getDefault());
            
            int currentMonth = localCalendar.get(Calendar.MONTH);
            int currentYear = localCalendar.get(Calendar.YEAR);
            int currentDayOfMonth = localCalendar.get(Calendar.DAY_OF_MONTH);


                try {
                  today = DatatypeFactory.newInstance()
                    .newXMLGregorianCalendar(
                                new GregorianCalendar(currentYear,currentMonth,currentDayOfMonth));
                } catch (DatatypeConfigurationException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
                }

                amazonenvelope.setEffectiveDate(today);
                List <AmazonEnvelope.Message> messages = amazonenvelope.getMessage();
                AmazonEnvelope.Message message1 = new AmazonEnvelope.Message();
                //Listings listing1 = new Listings();
                Product product = new Product();
            CatalogClient catalogServiceClient = null;
                try {
                        catalogServiceClient = new CatalogClient();
                } catch (TTransportException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
            Client catalogClient = catalogServiceClient.getClient();
            in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(2483);
            System.out.println(thriftItem);
            product.setSKU(String.valueOf(thriftItem.getId()));
            StandardProductID spid = new StandardProductID();
            spid.setType("EAN");
            spid.setValue("8806085002418");
            product.setItemPackageQuantity(BigInteger.valueOf(1));          
            product.setStandardProductID(spid);
            Product.DescriptionData descdata = new Product.DescriptionData();
            descdata.setBrand(thriftItem.getBrand());
            descdata.setAutographed(false);
                if(thriftItem.getModelName()!=null){
                        descdata.setTitle(thriftItem.getModelName());   
                }
                else{
                        descdata.setTitle(thriftItem.getModelNumber());
                }
            
            descdata.setManufacturer(thriftItem.getBrand());
            product.setDescriptionData(descdata);
            Product.ProductData productdata = new Product.ProductData();
            CE ce = new CE();
            ce.setColor(thriftItem.getColor());
            ce.setModel(thriftItem.getModelNumber());
            ce.setModelName(thriftItem.getModelName());
            HandheldOrPDA hhd = new HandheldOrPDA();
            CE.ProductType productype = new CE.ProductType();
            productype.setHandheldOrPDA(hhd);
            ce.setProductType(productype);
            productdata.setCE(ce);
            product.setProductData(productdata);
            message1.setMessageID(BigInteger.valueOf(41));
            //listing1.setProduct(product);
                //message1.setListings(listing1);
                message1.setProduct(product);
                messages.add(message1);
                try {
                        m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
                        m.marshal(amazonenvelope, file);
                        m.marshal(amazonenvelope, System.out);
                        
                } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
                        
                }

public static void createInventoryFeed() throws CatalogServiceException, TException{
        
        
        File file = new File(AMAZON_INVENTORY_XML);
        AmazonEnvelope amazonenvelope =  new AmazonEnvelope();
        Header header = new Header();
        header.setDocumentVersion("1.0");
        header.setMerchantIdentifier("AF6E3O0VE0X4D");
        header.setOverrideReleaseId(null);
        amazonenvelope.setHeader(header);
        amazonenvelope.setMessageType("Inventory");
        amazonenvelope.setMarketplaceName(null);
        amazonenvelope.setPurgeAndReplace(false);
        JAXBContext context;
        Marshaller m=null;
        try {
                context = JAXBContext.newInstance(AmazonEnvelope.class);
                m = context.createMarshaller();
        } catch (JAXBException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
        }
        
        XMLGregorianCalendar today = null;
        Calendar localCalendar = Calendar.getInstance();
    
    int currentMonth = localCalendar.get(Calendar.MONTH);
    int currentYear = localCalendar.get(Calendar.YEAR);
    int currentDayOfMonth = localCalendar.get(Calendar.DAY_OF_MONTH);

        try {
          today = DatatypeFactory.newInstance()
            .newXMLGregorianCalendar(
                        new GregorianCalendar(currentYear,currentMonth,currentDayOfMonth));
        } catch (DatatypeConfigurationException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
        amazonenvelope.setEffectiveDate(today);
        List <AmazonEnvelope.Message> messages = amazonenvelope.getMessage();
        AmazonEnvelope.Message message1 = new AmazonEnvelope.Message();
        //Listings listing1 = new Listings();
        Inventory inventory = new Inventory();
    InventoryClient inventoryServiceClient = null;
        try {
                inventoryServiceClient = new InventoryClient();
        } catch (TTransportException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
        in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
    ItemInventory availability=null;
        try {
                availability = inventoryClient.getItemInventoryByItemId(2483);
        } catch (InventoryServiceException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
        }
    if(availability.getAvailabilitySize() > 0)
    //inventory.setAvailable(true);
    inventory.setSKU("2483");
    inventory.setRestockDate(today);
    inventory.setFulfillmentLatency(BigInteger.valueOf(1));
    inventory.setQuantity(BigInteger.valueOf(availability.getAvailabilitySize()));
    //inventory.setQuantity(BigInteger.valueOf(availability.getAvailabilitySize()));
    inventory.setSwitchFulfillmentTo("MFN");
    message1.setMessageID(BigInteger.valueOf(42));
    //listing1.setProduct(product);
        //message1.setListings(listing1);
        message1.setInventory(inventory);
        messages.add(message1);
        try {
                m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
                m.marshal(amazonenvelope, file);
                m.marshal(amazonenvelope, System.out);
                
        } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
        
                
        }

public static void createPricingFeed() throws CatalogServiceException, TException{
        
        
        File file = new File(AMAZON_PRICING_XML);
        AmazonEnvelope amazonenvelope =  new AmazonEnvelope();
        Header header = new Header();
        header.setDocumentVersion("1.0");
        header.setMerchantIdentifier("AF6E3O0VE0X4D");
        header.setOverrideReleaseId(null);
        amazonenvelope.setHeader(header);
        amazonenvelope.setMessageType("Price");
        amazonenvelope.setMarketplaceName(null);
        amazonenvelope.setPurgeAndReplace(false);
        JAXBContext context;
        Marshaller m=null;
        try {
                context = JAXBContext.newInstance(AmazonEnvelope.class);
                m = context.createMarshaller();
        } catch (JAXBException e1) {
                e1.printStackTrace();
        }
        XMLGregorianCalendar today = null;
        Calendar localCalendar = Calendar.getInstance(TimeZone.getDefault());
    
    int currentMonth = localCalendar.get(Calendar.MONTH);
    int currentYear = localCalendar.get(Calendar.YEAR);
    int currentDayOfMonth = localCalendar.get(Calendar.DAY_OF_MONTH);


        try {
          today = DatatypeFactory.newInstance()
            .newXMLGregorianCalendar(
                        new GregorianCalendar(currentYear,currentMonth,currentDayOfMonth));
        } catch (DatatypeConfigurationException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
        amazonenvelope.setEffectiveDate(today);
        List <AmazonEnvelope.Message> messages = amazonenvelope.getMessage();
        AmazonEnvelope.Message message1 = new AmazonEnvelope.Message();
        Price price = new Price();
        //Product product = new Product();
    CatalogClient catalogServiceClient = null;
        try {
                catalogServiceClient = new CatalogClient(); 
        } catch (TTransportException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
    Client catalogClient = catalogServiceClient.getClient();
    List<in.shop2020.model.v1.catalog.Amazonlisted> AItem = catalogClient.getAllAmazonListedItems();
    System.out.println("Amazon items are" + AItem);
    in.shop2020.model.v1.catalog.Item thriftItem = catalogClient.getItem(2483);
    price.setSKU(String.valueOf(thriftItem.getId()));
    OverrideCurrencyAmount overridecurrencyamount = new OverrideCurrencyAmount();
    overridecurrencyamount.setCurrency(BaseCurrencyCodeWithDefault.DEFAULT);
    overridecurrencyamount.setValue(BigDecimal.valueOf(thriftItem.getSellingPrice()));
    price.setStandardPrice(overridecurrencyamount);
    message1.setMessageID(BigInteger.valueOf(43));
    //listing1.setProduct(product);
        //message1.setListings(listing1);
        message1.setPrice(price);
        messages.add(message1);
        try {
                m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
                m.marshal(amazonenvelope, file);
                m.marshal(amazonenvelope, System.out);
                
        } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
        
                
        }

    
    public static String computeContentMD5HeaderValue( FileInputStream fis) {
        try {
                        DigestInputStream dis = new DigestInputStream( fis,
                                        MessageDigest.getInstance( "MD5" ));
                        byte[] buffer = new byte[8192];
                        while( dis.read( buffer ) > 0 );
                        String md5Content = new String(Base64.encodeBase64(dis.getMessageDigest().digest())
                                );
 // Effectively resets the stream to be beginning of the file via a
                        fis.getChannel().position( 0 );
                        return md5Content;
                } catch (NoSuchAlgorithmException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                return null;
                
 }


    
    

}