Subversion Repositories SmartDukaan

package in.shop2020.support.utils;

import in.shop2020.model.v1.catalog.AmazonPromotion;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.security.DigestInputStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
import java.util.Calendar;
import java.util.List;

import org.apache.commons.codec.binary.Base64;

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.IdList;
import com.amazonaws.mws.model.SubmitFeedRequest;
import com.amazonaws.mws.model.SubmitFeedResponse;
import com.ibm.icu.text.SimpleDateFormat;

public class PromotionFeed {
        public String CreatePromotionFeed(List<AmazonPromotion> amazonPromotions) throws IOException{ 
                BufferedReader reader = null;
                BufferedWriter writer = null;
                String promotionFilename = null;
                SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
                Calendar calendar = Calendar.getInstance();
                try {
                        promotionFilename = "/tmp/Promotion-"+System.currentTimeMillis()+".txt";
                        reader = new BufferedReader(new FileReader("/tmp/p.txt"));
                        writer = new BufferedWriter(new FileWriter(promotionFilename));
                        String Line;
                        while ((Line = reader.readLine()) != null) {
                                writer.write(Line+"\n");
                        }
                        for(AmazonPromotion am:amazonPromotions){
                            calendar.setTimeInMillis(am.getStartDate());
                        String start = formatter.format(calendar.getTime());
                        calendar.setTimeInMillis(am.getEndDate());
                String end = formatter.format(calendar.getTime());
                                writer.write(am.getSku()+"\t"+
                                                ""+"\t"
                                                +""+"\t"
                                                +""+"\t"
                                                +""+"\t"
                                                +""+"\t"
                                                +"\t"
                                                +"\t"
                                                +"\t"
                                                +"\t"
                                                +"PartialUpdate"+"\t"
                                                +am.getStandardPrice()+"\t"
                                                +""+"\t"        
                                                +""+"\t"
                                                +""+"\t"
                                                +""+"\t"
                                                +"1"+"\t"
                                                +am.getSalePrice()+"\t"
                                                +start+"\t"
                                                +end+"\t"
                                                +""+"\t"+"\n");
                        }

                } catch (FileNotFoundException e1) {
                        e1.printStackTrace();
                }
                finally{
                        writer.close();
                        reader.close();
                        System.out.println("Done");
                }
                return promotionFilename;
        }
        public String SubmitPromotionFeed(String file) throws FileNotFoundException, InterruptedException, MarketplaceWebServiceException{
                MarketplaceWebService service = getMarketplaceServiceInstance();
                SubmitFeedRequest requestPromotion = new SubmitFeedRequest();
                requestPromotion.setMerchant("AF6E3O0VE0X4D");
                requestPromotion.setMarketplaceIdList(new IdList(Arrays.asList("A21TJRUUN4KGV")));
                requestPromotion.setFeedType("_POST_FLAT_FILE_LISTINGS_DATA_");
                FileInputStream promotionfis = new FileInputStream(file);
                requestPromotion.setContentMD5(computeContentMD5HeaderValue(promotionfis));
                requestPromotion.setFeedContent(promotionfis);
                return invokeSubmitFeed(service,requestPromotion);
        }
        public MarketplaceWebService getMarketplaceServiceInstance(){
                final String accessKeyId = "AKIAII3SGRXBJDPCHSGQ";
                final String secretAccessKey = "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";
                final String appName = "Test";
                final String appVersion = "1.0";
                MarketplaceWebServiceConfig config = new MarketplaceWebServiceConfig();
                config.setServiceURL("https://mws.amazonservices.in");
                return new MarketplaceWebServiceClient(
                                accessKeyId, secretAccessKey, appName, appVersion, config);
        }
        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) {
                        e.printStackTrace();
                } catch (IOException e) {
                        e.printStackTrace();
                }
                return null;
        }
        public String invokeSubmitFeed(MarketplaceWebService service,SubmitFeedRequest request) throws InterruptedException, MarketplaceWebServiceException {
                                SubmitFeedResponse response = service.submitFeed(request);
                                return response.getSubmitFeedResult().getFeedSubmissionInfo().getFeedSubmissionId();
        }
}