Subversion Repositories SmartDukaan

package in.shop2020;

import in.shop2020.logistics.DeliveryType;

import in.shop2020.logistics.LogisticsInfo;

import in.shop2020.logistics.LogisticsServiceException;

import in.shop2020.model.v1.catalog.CatalogService.Client;

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

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

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

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

import in.shop2020.model.v1.inventory.InventoryType;

import in.shop2020.model.v1.inventory.ItemInventory;

import in.shop2020.model.v1.inventory.Warehouse;

import in.shop2020.model.v1.inventory.WarehouseLocation;

import in.shop2020.model.v1.inventory.WarehouseType;

import in.shop2020.model.v1.order.OrderSource;

import in.shop2020.serving.model.Order;

import in.shop2020.serving.model.OrderItems;

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.InventoryClient;

import in.shop2020.thrift.clients.LogisticsClient;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.utils.GmailUtils;

import inventory.FlipkartInventoryItem;

import java.io.BufferedReader;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.UnsupportedEncodingException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import javax.mail.MessagingException;

import org.apache.http.HttpResponse;

import org.apache.http.NameValuePair;

import org.apache.http.auth.AuthScope;

import org.apache.http.auth.UsernamePasswordCredentials;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.HttpClient;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.entity.StringEntity;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.http.message.BasicNameValuePair;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

import com.google.gson.Gson;

public class CreateSubmitFlipkartPricingFeed {

	private static List<MarketPlaceItemPrice> flipkartPricingItems;

	private static Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();

	private static Map<Long,FlipkartItem> flipkartItemsMap = new HashMap<Long,FlipkartItem>();

	static java.text.SimpleDateFormat sdf;

	static String emailFromAddress;

	static String password;

	static GmailUtils mailer;

	static String sendTo[];

	static

	{

		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");

		emailFromAddress = "build@shop2020.in";

		password = "cafe@nes";

		mailer = new GmailUtils();

		sendTo = new String[]{"vikram.raghav@shop2020.in"};

		/*sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",

				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",

				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};

		 */

		 Client catalogServiceClient = null;

		 try {

			 catalogServiceClient = new CatalogClient().getClient();

		 } catch (TTransportException e) {

			 e.printStackTrace();

		 }

		 try {

			 flipkartPricingItems = catalogServiceClient.getMarketPlaceItemsForPriceUpdate(8);

			 List<Item> aliveItems = catalogServiceClient.getAllAliveItems();

				for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){

					aliveItemsMap.put(thriftItem.getId(), thriftItem);

				}

			List<FlipkartItem> flipkartItems = catalogServiceClient.getAllFlipkartItems();

			for(FlipkartItem flipkartItem:flipkartItems){

				flipkartItemsMap.put(flipkartItem.getItem_id(),flipkartItem);

			}

		 } catch (TException e) {

			 e.printStackTrace();

		 }

		 if(flipkartPricingItems.size()==0){

			 String text = "";

			 try {

				 mailer.sendSSLMessage(sendTo,"No items to send prices ", emailFromAddress, password, text);

				 System.exit(0);

			 } catch (MessagingException e) {

				 e.printStackTrace();

			 }

		 }

	}

	public static void main(String[] args) throws ClientProtocolException, TException{

		DefaultHttpClient httpclient = new DefaultHttpClient();

		httpclient = (DefaultHttpClient) WebClientWrapper.wrapClient(httpclient);

		httpclient.getCredentialsProvider().setCredentials(

				new AuthScope("sandbox-api.flipkart.net", 443),

				new UsernamePasswordCredentials("og3yg5994bxbxxc1", "8a137068-417c-4e4f-ae95-9295ab938d88"));/// Test Server Access Keys

		//httpclient.getCredentialsProvider().setCredentials(

		//		new AuthScope("api.flipkart.net", 443),

		//		new UsernamePasswordCredentials("m2z93iskuj81qiid","0c7ab6a5-98c0-4cdc-8be3-72c591e0add4")); //Prod Server Access Keys

		//HttpPost httppost = new HttpPost("https://api.flipkart.net/sellers/skus/listings/bulk"); // PROD

		HttpPost httppost = new HttpPost("https://sandbox-api.flipkart.net/sellers/skus/listings/bulk"); // TEST

		StringBuffer jsonRequest = new StringBuffer();

		StringBuffer jsonStart = new StringBuffer();

		jsonStart = jsonStart.append("{\"listings\":[");

		StringBuffer jsonEnd = new StringBuffer();

		jsonEnd.append("]}");

		//System.out.println("JSON request  " + jsonRequest);

		int i=0;

		StringBuffer pricingItems =new StringBuffer();

		String tableHeader = "<html><table border=\"1\" align=\"center\"><tr>" 

			+ "<td><b>" + "Product Name" +"</b></td>"

			+"<td><b>" + "Item ID" + "</b></td>"

			+"<td><b>" + "Selling Price" + "</b></td>"

			+"</tr>";

		String tableFooter = "</table></html>";

		Item item;

		StringBuffer feedResponse = null;

		for(MarketPlaceItemPrice entry:flipkartPricingItems){

			feedResponse=  new StringBuffer();

			item = aliveItemsMap.get(entry.getItem_id());

			System.out.println("Item ID  " + entry.getItem_id());

			System.out.println("Product Name " + getProductName(item));

			System.out.println("Selling Price " + entry.getSellingPrice());

			jsonRequest.append("{\"skuId\":"+"\""+flipkartItemsMap.get(entry.getItem_id()).getSkuAtFlipkart()+

					"\","+"\"attributeValues\""+":"+

					"{\"selling_price\""+":"+"\""+entry.getSellingPrice()+"}}");

			pricingItems.append("<tr>" 

					+ "<td>" +getProductName(item)+"</td>"

					+"<td>" + item.getId() + "</td>"

					+"<td>" + entry.getSellingPrice() + "</td>"

					+"</tr>");

			if(flipkartPricingItems.size()!=1 && (i!=flipkartPricingItems.size() -1 ) ){

				jsonRequest.append(",");	

			}

			i++;

			if(i%10==0 || i==flipkartPricingItems.size()){

				StringEntity input = null;

				try {

					input = new StringEntity(jsonStart+jsonRequest.toString()+jsonEnd);

					System.out.println("Json input " + jsonStart+jsonRequest.toString()+jsonEnd);

					jsonRequest = new StringBuffer();

				} catch (UnsupportedEncodingException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

				input.setContentType("application/json");

				httppost.setEntity(input);

				HttpResponse response = null;

				try {

					System.out.println("Before send " );

					response = httpclient.execute(httppost);

					System.out.println("After send " );

				} catch (IOException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

				BufferedReader rd = null;

				try {

					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

				} catch (IllegalStateException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				} catch (IOException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

				String line;

				try {

					while ((line = rd.readLine()) != null) {

						System.out.println("Response " + line);

						if(line.equalsIgnoreCase("{\"status\":\"success\"}")){

						}

						else{

							feedResponse.append(line);

						}

					}

				} catch (IOException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

			}

		}

		System.out.println("Before sending email");

		String text = tableHeader+pricingItems.toString()+tableFooter;

		try {

			mailer.sendSSLMessage(sendTo,"Flipkart Inventory Sent Details ", emailFromAddress, password, text);

		} catch (MessagingException e) {

			e.printStackTrace();

		}

		if(feedResponse.toString().length()>0){

			try {

				mailer.sendSSLMessage(sendTo, "Flipkart Inventory could not be updated ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());

			} catch (MessagingException e) {

				e.printStackTrace();

			}

		}

		else{

			try {

				mailer.sendSSLMessage(sendTo, "Flipkart Inventory updated successfully ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());

			} catch (MessagingException e) {

				e.printStackTrace();

			}

		}

	}

	static String getProductName(Item item){

		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor()); 

	}

	static String getName(String name){

		if(name==null || name.length()==0){

			return "";

		}

		else{

			return name;

		}

	}

}