Subversion Repositories SmartDukaan

Rev

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

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