Subversion Repositories SmartDukaan

package in.shop2020;

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

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

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

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

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.InventoryClient;

import in.shop2020.utils.GmailUtils;

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 in.shop2020.WebClientWrapper;

import javax.mail.MessagingException;

import inventory.FlipkartJSONreponse;

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 FlipkartInventoryAtEOD {

	private static List<FlipkartItem> flipkartItems;

	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","manoj.pal@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};

		 */		List<String> flipkartorderids = null;

		 Client catalogServiceClient = null;

		 try {

			 catalogServiceClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();

		 } catch (TTransportException e) {

			 e.printStackTrace();

		 }

		 try {

			 flipkartItems = catalogServiceClient.getAllFlipkartItems();

		 } catch (TException 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

		HttpGet httpget;

		BufferedReader rd = null;

		Gson gson = new Gson();

		List<FlipkartStockAtEOD> allflipkartstock = new ArrayList<FlipkartStockAtEOD>();

		FlipkartStockAtEOD stockItem;

		Long time = System.currentTimeMillis();

		for(FlipkartItem flipkartItem:flipkartItems){

			httpget = new HttpGet("https://api.flipkart.net/sellers/skus/"+flipkartItem.getSkuAtFlipkart()+"/listings"); // PROD

			HttpResponse response = null;

			try {

				response = httpclient.execute(httpget);

			} catch (IOException e) {

				e.printStackTrace();

			}

			try {

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

			} catch (Exception e) {

				e.printStackTrace();

			}

			/*try {

				System.out.println("Response :" + rd.readLine());

			} catch (IOException e) {

				e.printStackTrace();

			}*/

			FlipkartJSONreponse flipkartJSONreponse = (FlipkartJSONreponse) gson.fromJson(rd, FlipkartJSONreponse.class);

			if(flipkartJSONreponse!=null){

				stockItem = new FlipkartStockAtEOD(); 

				System.out.println("Item ID :" + flipkartItem.getSkuAtFlipkart());

				stockItem.setItem_id(flipkartItem.getItem_id());

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

				System.out.println("Listing ID :" + flipkartJSONreponse.getListingId());

				System.out.println("SKU at Flipkart :" + flipkartJSONreponse.getSkuId());

				System.out.println("Stock Count :" + flipkartJSONreponse.getAttributes().getStock_count());

				stockItem.setAvailability(Long.valueOf(flipkartJSONreponse.getAttributes().getStock_count()));

				stockItem.setDate(time);

				allflipkartstock.add(stockItem);

			}

		}

		try{

			new InventoryClient().getClient().updateFlipkartStockAtEOD(allflipkartstock);

		}

		catch(Exception e){

			new InventoryClient().getClient().updateFlipkartStockAtEOD(allflipkartstock);

		}

	}

}