Subversion Repositories SmartDukaan

package in.shop2020;

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

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

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

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

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

import in.shop2020.model.v1.inventory.InventoryService.Client;

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.InventoryClient;

import in.shop2020.utils.GmailUtils;

import java.io.BufferedReader;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.PrintStream;

import java.io.UnsupportedEncodingException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.mail.MessagingException;

import org.apache.http.HttpResponse;

import org.apache.http.NameValuePair;

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.impl.client.DefaultHttpClient;

import org.apache.http.message.BasicNameValuePair;

import org.apache.poi.hssf.usermodel.HSSFSheet;

import org.apache.poi.hssf.usermodel.HSSFWorkbook;

import org.apache.poi.ss.usermodel.Cell;

import org.apache.poi.ss.usermodel.Row;

import org.apache.poi.ss.usermodel.Sheet;

import org.apache.poi.ss.usermodel.Workbook;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

public class FlipkartInventoryReconcillation {

	public static void main(String... args) throws ClientProtocolException, IOException, TException{

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

		String emailFromAddress = "build@shop2020.in";

		String password = "cafe@nes";

		GmailUtils mailer = new GmailUtils();

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

		String[] 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"};

		Map<String,Long> itemInventoryMap = FetchInventoryAtFlipkart();

		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = null;

		List<Item> aliveItems = null;

		List<FlipkartItem> flipkartItems = null;

		boolean ex = true;

		while(ex){

			try {

				catalogClient = new CatalogClient().getClient();

				flipkartItems = catalogClient.getAllFlipkartItems();

				ex =false;

			} catch (Exception e) {

				e.printStackTrace();

			}

		}

		ex=true;

		while(ex){

			try {

				aliveItems = catalogClient.getAllAliveItems();

				ex =false;

			} catch (Exception e) {

				try {

					catalogClient = new CatalogClient().getClient();

				} catch (Exception e1) {

					e1.printStackTrace();

				}

			}

		}

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

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

		for(Item item:aliveItems){

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

		}

		for(FlipkartItem flipkartItem:flipkartItems){

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

		}

		Client inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();

		List<FlipkartInventorySnapshot> flipkartInventorySnapshot;

		try {

			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();

		} catch (TException e) {

			e.printStackTrace();

			inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();

			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();

		}

		FlipkartItem flipkartItem;

		Long availabilityAtFlipkart = 0L;

		Item item;

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

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

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

			+"<td><b>" + "Inventory Sent" + "</b></td>"

			+"<td><b>" + "Orders Added" + "</b></td>"

			+"<td><b>" + "Order Held" + "</b></td>"

			+"<td><b>" + "Inventory Updated" + "</b></td>"

			+"<td><b>" + "Difference" + "</b></td>"

			+"</tr>";

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

		StringBuffer reconcilledItems = new StringBuffer();

		for(FlipkartInventorySnapshot snapshot:flipkartInventorySnapshot){

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

			System.out.println("Sent Inventory " + snapshot.getAvailability());

			System.out.println("Held Orders " + snapshot.getHeldOrders());

			System.out.println("Created Orders " + snapshot.getCreatedOrders());

			flipkartItem = flipkartItemsMap.get(snapshot.getItem_id());

			System.out.println("SKU at Flipkart " + flipkartItem.getSkuAtFlipkart());

			availabilityAtFlipkart = itemInventoryMap.get(flipkartItem.getSkuAtFlipkart());

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

			snapshot.getItem_id();

			snapshot.getAvailability();

			snapshot.getCreatedOrders();

			snapshot.getHeldOrders();

			if(snapshot.getAvailability()==25){

				snapshot.setCreatedOrders(0);

			}

			if((snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders() - availabilityAtFlipkart)!=0){

				reconcilledItems .append("<tr>" 

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

						+"<td>" + snapshot.getItem_id() + "</td>"

						+"<td>" + snapshot.getAvailability() + "</td>"

						+"<td>" + snapshot.getCreatedOrders() + "</td>"

						+"<td>" + snapshot.getHeldOrders() + "</td>"

						+"<td>" + availabilityAtFlipkart + "</td>"

						+"<td>" + (snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders() - availabilityAtFlipkart) + "</td>"

						+"</tr>");

			}

		}

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

		try {

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

		} catch (MessagingException e) {

			e.printStackTrace();

		}

	}

	public static Map<String, Long> FetchInventoryAtFlipkart() throws ClientProtocolException, IOException{

		Map<String,Long> itemInventoryMap = new HashMap<String,Long>();

		HttpClient client = new DefaultHttpClient();

		HttpPost post = new HttpPost("https://seller.flipkart.com/login");

		BufferedReader rd= null;

		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();

		nameValuePairs.add(new BasicNameValuePair("authName",

		"flipkart"));

		nameValuePairs.add(new BasicNameValuePair("username",

		"flipkart-support@saholic.com"));

		nameValuePairs.add(new BasicNameValuePair("password",

		"076c27ee24d7596b06608a8ed2559f87"));

		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));

		HttpResponse response = client.execute(post);

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

		String line ="";

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

			//System.out.println(line);

		}

		HttpGet get = new HttpGet("https://seller.flipkart.com/sellerListing/listing/downloadTemplateForExistingProducts?category=Mobiles+%26+Cameras&sellerId=m2z93iskuj81qiid&feedType=PRICING_STOCK&useDefaultTemplate=false");

		response = client.execute(get);

		InputStream in = response.getEntity().getContent();

		Workbook wb = new HSSFWorkbook(in);

		Sheet sheet = wb.getSheetAt(0);

		Row firstRow = sheet.getRow(0);

		Row SecondRow = sheet.getRow(1);

		for (Row row : sheet) {

			if(row.equals(firstRow) || row.equals(SecondRow))

				continue;

			row.getCell(6).setCellType(Cell.CELL_TYPE_STRING);

			row.getCell(15).setCellType(Cell.CELL_TYPE_STRING);

			System.out.println("SKU " + row.getCell(6).getStringCellValue() + " " + "Quantity "+ row.getCell(15).getStringCellValue());

			if(!row.getCell(15).getStringCellValue().equals("")){

				itemInventoryMap.put(row.getCell(6).getStringCellValue(), Long.parseLong(row.getCell(15).getStringCellValue()));

			}

			else{

				itemInventoryMap.put(row.getCell(6).getStringCellValue(),0L);

			}

		}

		return itemInventoryMap;

	}

	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;

		}

	}

}