Subversion Repositories SmartDukaan

Rev

Rev 10515 | Rev 11673 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
10155 vikram.rag 1 
 
10049 vikram.rag 2 
package in.shop2020;
3 
 
10079 vikram.rag 4 
import in.shop2020.model.v1.catalog.CatalogServiceException;
10049 vikram.rag 5 
import in.shop2020.model.v1.catalog.FlipkartItem;
6 
import in.shop2020.model.v1.catalog.Item;
7 
import in.shop2020.model.v1.catalog.SnapdealItem;
8 
import in.shop2020.model.v1.inventory.FlipkartInventorySnapshot;
9 
import in.shop2020.model.v1.inventory.InventoryService.Client;
10 
import in.shop2020.thrift.clients.CatalogClient;
11 
import in.shop2020.thrift.clients.InventoryClient;
12 
import in.shop2020.utils.GmailUtils;
13 
 
14 
import java.io.BufferedReader;
15 
import java.io.FileInputStream;
16 
import java.io.FileNotFoundException;
17 
import java.io.FileOutputStream;
18 
import java.io.IOException;
19 
import java.io.InputStream;
20 
import java.io.InputStreamReader;
21 
import java.io.PrintStream;
22 
import java.io.UnsupportedEncodingException;
23 
import java.text.SimpleDateFormat;
24 
import java.util.ArrayList;
25 
import java.util.HashMap;
26 
import java.util.List;
27 
import java.util.Map;
28 
 
29 
import javax.mail.MessagingException;
30 
 
31 
import org.apache.http.HttpResponse;
32 
import org.apache.http.NameValuePair;
33 
import org.apache.http.client.ClientProtocolException;
34 
import org.apache.http.client.HttpClient;
35 
import org.apache.http.client.entity.UrlEncodedFormEntity;
36 
import org.apache.http.client.methods.HttpGet;
37 
import org.apache.http.client.methods.HttpPost;
38 
import org.apache.http.impl.client.DefaultHttpClient;
39 
import org.apache.http.message.BasicNameValuePair;
40 
import org.apache.poi.hssf.usermodel.HSSFSheet;
41 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
42 
import org.apache.poi.ss.usermodel.Cell;
43 
import org.apache.poi.ss.usermodel.Row;
44 
import org.apache.poi.ss.usermodel.Sheet;
45 
import org.apache.poi.ss.usermodel.Workbook;
46 
import org.apache.thrift.TException;
47 
import org.apache.thrift.transport.TTransportException;
48 
 
49 
 
50 
public class FlipkartInventoryReconcillation {
51 
 
10081 vikram.rag 52 
 
10085 vikram.rag 53 
	public static void main(String... args) throws ClientProtocolException, IOException, TException{
10049 vikram.rag 54 
		SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
55 
		String emailFromAddress = "build@shop2020.in";
56 
		String password = "cafe@nes";
57 
		GmailUtils mailer = new GmailUtils();
10091 vikram.rag 58 
		//String[] sendTo = new String[]{"vikram.raghav@shop2020.in"};
59 
		String[] sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
10049 vikram.rag 60 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
61 
				"yukti.jain@shop2020.in","manoj.pal@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
10058 vikram.rag 62 
		Map<String,Long> itemInventoryMap = FetchInventoryAtFlipkart();
10084 vikram.rag 63 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = null;
10081 vikram.rag 64 
		List<Item> aliveItems = null;
65 
		List<FlipkartItem> flipkartItems = null;
10082 vikram.rag 66 
		boolean ex = true;
67 
		while(ex){
68 
			try {
10155 vikram.rag 69 
				catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
10084 vikram.rag 70 
				flipkartItems = catalogClient.getAllFlipkartItems();
71 
				ex =false;
72 
			} catch (Exception e) {
73 
				e.printStackTrace();
74 
			}
75 
		}
10086 vikram.rag 76 
		ex=true;
10084 vikram.rag 77 
		while(ex){
78 
			try {
10082 vikram.rag 79 
				aliveItems = catalogClient.getAllAliveItems();
80 
				ex =false;
10084 vikram.rag 81 
			} catch (Exception e) {
82 
				try {
10155 vikram.rag 83 
					catalogClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
10084 vikram.rag 84 
				} catch (Exception e1) {
85 
					e1.printStackTrace();
86 
				}
10082 vikram.rag 87 
			}
10081 vikram.rag 88 
		}
10066 vikram.rag 89 
		Map<Long,FlipkartItem> flipkartItemsMap = new HashMap<Long,FlipkartItem>();
10049 vikram.rag 90 
		Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
91 
		for(Item item:aliveItems){
92 
			aliveItemsMap.put(item.getId(),item);
93 
		}
94 
		for(FlipkartItem flipkartItem:flipkartItems){
10088 vikram.rag 95 
			flipkartItemsMap.put(flipkartItem.getItem_id(), flipkartItem);
10049 vikram.rag 96 
		}
10155 vikram.rag 97 
		Client inventoryServiceClient = new InventoryClient().getClient();
10049 vikram.rag 98 
		List<FlipkartInventorySnapshot> flipkartInventorySnapshot;
99 
		try {
100 
			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();
101 
		} catch (TException e) {
102 
			e.printStackTrace();
10155 vikram.rag 103 
			inventoryServiceClient = new InventoryClient().getClient();
10049 vikram.rag 104 
			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();
105 
		}
106 
		FlipkartItem flipkartItem;
107 
		Long availabilityAtFlipkart = 0L;
108 
		Item item;
109 
		String tableHeader = "<html><table border=\"1\" align=\"center\"><tr>"
110 
			+ "<td><b>" + "Product Name" +"</b></td>"
111 
			+"<td><b>" + "Item ID" + "</b></td>"
112 
			+"<td><b>" + "Inventory Sent" + "</b></td>"
113 
			+"<td><b>" + "Orders Added" + "</b></td>"
114 
			+"<td><b>" + "Order Held" + "</b></td>"
10089 vikram.rag 115 
			+"<td><b>" + "Inventory Updated" + "</b></td>"
10049 vikram.rag 116 
			+"<td><b>" + "Difference" + "</b></td>"
117 
			+"</tr>";
118 
		String tableFooter = "</table></html>";
119 
		StringBuffer reconcilledItems = new StringBuffer();
120 
		for(FlipkartInventorySnapshot snapshot:flipkartInventorySnapshot){
121 
			System.out.println("Item ID " + snapshot.getItem_id());
122 
			System.out.println("Sent Inventory " + snapshot.getAvailability());
123 
			System.out.println("Held Orders " + snapshot.getHeldOrders());
124 
			System.out.println("Created Orders " + snapshot.getCreatedOrders());
125 
			flipkartItem = flipkartItemsMap.get(snapshot.getItem_id());
10087 vikram.rag 126 
			System.out.println("SKU at Flipkart " + flipkartItem.getSkuAtFlipkart());
10515 vikram.rag 127 
			if(itemInventoryMap.containsKey(flipkartItem.getSkuAtFlipkart())){
128 
				availabilityAtFlipkart = itemInventoryMap.get(flipkartItem.getSkuAtFlipkart());
129 
			}
130 
			else{
131 
				availabilityAtFlipkart = 0L;
132 
			}
10049 vikram.rag 133 
			item = aliveItemsMap.get(snapshot.getItem_id());
10515 vikram.rag 134 
			System.out.println("Availability at Flipkart " + availabilityAtFlipkart);
10109 vikram.rag 135 
			if(snapshot.getAvailability()==25){
136 
				snapshot.setCreatedOrders(0);
137 
			}
10089 vikram.rag 138 
			if((snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders() - availabilityAtFlipkart)!=0){
10081 vikram.rag 139 
				reconcilledItems .append("<tr>"
140 
						+ "<td>" +getProductName(item)+"</td>"
141 
						+"<td>" + snapshot.getItem_id() + "</td>"
142 
						+"<td>" + snapshot.getAvailability() + "</td>"
143 
						+"<td>" + snapshot.getCreatedOrders() + "</td>"
144 
						+"<td>" + snapshot.getHeldOrders() + "</td>"
10089 vikram.rag 145 
						+"<td>" + availabilityAtFlipkart + "</td>"
146 
						+"<td>" + (snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders() - availabilityAtFlipkart) + "</td>"
10081 vikram.rag 147 
						+"</tr>");
10049 vikram.rag 148 
			}
149 
		}
150 
		String text = tableHeader+reconcilledItems.toString()+tableFooter;
151 
		try {
10157 vikram.rag 152 
			mailer.sendSSLMessage(sendTo,"Flipkart Inventory Reconcillation "+sdf.format(System.currentTimeMillis()), emailFromAddress, password, text);
10049 vikram.rag 153 
		} catch (MessagingException e) {
154 
			e.printStackTrace();
155 
		}
156 
	}
10058 vikram.rag 157 
	public static Map<String, Long> FetchInventoryAtFlipkart() throws ClientProtocolException, IOException{
158 
		Map<String,Long> itemInventoryMap = new HashMap<String,Long>();
10049 vikram.rag 159 
		HttpClient client = new DefaultHttpClient();
160 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
161 
		BufferedReader rd= null;
162 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
163 
		nameValuePairs.add(new BasicNameValuePair("authName",
164 
		"flipkart"));
165 
		nameValuePairs.add(new BasicNameValuePair("username",
166 
		"flipkart-support@saholic.com"));
167 
		nameValuePairs.add(new BasicNameValuePair("password",
168 
		"076c27ee24d7596b06608a8ed2559f87"));
169 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
170 
		HttpResponse response = client.execute(post);
171 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
172 
		String line ="";
173 
		while ((line  = rd.readLine()) != null) {
174 
			//System.out.println(line);
175 
		}
176 
		HttpGet get = new HttpGet("https://seller.flipkart.com/sellerListing/listing/downloadTemplateForExistingProducts?category=Mobiles+%26+Cameras&sellerId=m2z93iskuj81qiid&feedType=PRICING_STOCK&useDefaultTemplate=false");
177 
		response = client.execute(get);
178 
		InputStream in = response.getEntity().getContent();
179 
		Workbook wb = new HSSFWorkbook(in);
180 
		Sheet sheet = wb.getSheetAt(0);
181 
		Row firstRow = sheet.getRow(0);
182 
		Row SecondRow = sheet.getRow(1);
183 
		for (Row row : sheet) {
184 
			if(row.equals(firstRow) || row.equals(SecondRow))
185 
				continue;
186 
			row.getCell(6).setCellType(Cell.CELL_TYPE_STRING);
187 
			row.getCell(15).setCellType(Cell.CELL_TYPE_STRING);
188 
			System.out.println("SKU " + row.getCell(6).getStringCellValue() + " " + "Quantity "+ row.getCell(15).getStringCellValue());
189 
			if(!row.getCell(15).getStringCellValue().equals("")){
10058 vikram.rag 190 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(), Long.parseLong(row.getCell(15).getStringCellValue()));
10049 vikram.rag 191 
			}
192 
			else{
10058 vikram.rag 193 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(),0L);
10049 vikram.rag 194 
			}
195 
		}
10772 vikram.rag 196 
		get = new HttpGet("https://seller.flipkart.com/sellerListing/listing/downloadTemplateForExistingProducts?category=Computers+%26+Gaming&sellerId=m2z93iskuj81qiid&feedType=PRICING_STOCK&useDefaultTemplate=false");
197 
		response = client.execute(get);
198 
		in = response.getEntity().getContent();
199 
		wb = new HSSFWorkbook(in);
200 
		sheet = wb.getSheetAt(0);
201 
		firstRow = sheet.getRow(0);
202 
		SecondRow = sheet.getRow(1);
203 
		for (Row row : sheet) {
204 
			if(row.equals(firstRow) || row.equals(SecondRow))
205 
				continue;
206 
			row.getCell(6).setCellType(Cell.CELL_TYPE_STRING);
207 
			row.getCell(15).setCellType(Cell.CELL_TYPE_STRING);
208 
			System.out.println("SKU " + row.getCell(6).getStringCellValue() + " " + "Quantity "+ row.getCell(15).getStringCellValue());
209 
			if(!row.getCell(15).getStringCellValue().equals("")){
210 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(), Long.parseLong(row.getCell(15).getStringCellValue()));
211 
			}
212 
			else{
213 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(),0L);
214 
			}
215 
		}
10049 vikram.rag 216 
		return itemInventoryMap;
217 
	}
218 
	static String getProductName(Item item){
219 
		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor());
220 
 
221 
	}
222 
	static String getName(String name){
223 
		if(name==null || name.length()==0){
224 
			return "";
225 
		}
226 
		else{
227 
			return name;
228 
		}
229 
	}
230 
 
231 
 
232 
}