Subversion Repositories SmartDukaan

Rev

Rev 10082 | Rev 10084 | 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 
 
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();
10049 vikram.rag 63 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = new CatalogClient().getClient();
10081 vikram.rag 64 
		List<Item> aliveItems = null;
65 
		List<FlipkartItem> flipkartItems = null;
66 
		try {
10078 vikram.rag 67 
			flipkartItems = catalogClient.getAllFlipkartItems();
10081 vikram.rag 68 
		} catch (TException e1) {
10077 vikram.rag 69 
			catalogClient = new CatalogClient().getClient();
10078 vikram.rag 70 
			flipkartItems = catalogClient.getAllFlipkartItems();
10081 vikram.rag 71 
			e1.printStackTrace();
10077 vikram.rag 72 
		}
10082 vikram.rag 73 
		boolean ex = true;
74 
		while(ex){
75 
			try {
76 
				aliveItems = catalogClient.getAllAliveItems();
77 
				ex =false;
10083 vikram.rag 78 
			} catch (Exception e1) {
10082 vikram.rag 79 
				catalogClient = new CatalogClient().getClient();
80 
				aliveItems = catalogClient.getAllAliveItems();
81 
				e1.printStackTrace();
82 
			}
10081 vikram.rag 83 
		}
10066 vikram.rag 84 
		Map<Long,FlipkartItem> flipkartItemsMap = new HashMap<Long,FlipkartItem>();
10049 vikram.rag 85 
		Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
86 
		for(Item item:aliveItems){
87 
			aliveItemsMap.put(item.getId(),item);
88 
		}
89 
		for(FlipkartItem flipkartItem:flipkartItems){
90 
			if(flipkartItem.isIsListedOnFlipkart() && !flipkartItem.isSetSuppressInventoryFeed()){
91 
				flipkartItemsMap.put(flipkartItem.getItem_id(), flipkartItem);
92 
			}
93 
		}
94 
		Client inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();
95 
		List<FlipkartInventorySnapshot> flipkartInventorySnapshot;
96 
		try {
97 
			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();
98 
		} catch (TException e) {
99 
			e.printStackTrace();
100 
			inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();
101 
			flipkartInventorySnapshot = inventoryServiceClient.getFlipkartInventorySnapshot();
102 
		}
103 
		FlipkartItem flipkartItem;
104 
		Long availabilityAtFlipkart = 0L;
105 
		Item item;
106 
		String tableHeader = "<html><table border=\"1\" align=\"center\"><tr>"
107 
			+ "<td><b>" + "Product Name" +"</b></td>"
108 
			+"<td><b>" + "Item ID" + "</b></td>"
109 
			+"<td><b>" + "Inventory Sent" + "</b></td>"
110 
			+"<td><b>" + "Inventory Updated" + "</b></td>"
111 
			+"<td><b>" + "Orders Added" + "</b></td>"
112 
			+"<td><b>" + "Order Held" + "</b></td>"
113 
			+"<td><b>" + "Difference" + "</b></td>"
114 
			+"</tr>";
115 
		String tableFooter = "</table></html>";
116 
		StringBuffer reconcilledItems = new StringBuffer();
117 
		for(FlipkartInventorySnapshot snapshot:flipkartInventorySnapshot){
118 
			System.out.println("Item ID " + snapshot.getItem_id());
119 
			System.out.println("Sent Inventory " + snapshot.getAvailability());
120 
			System.out.println("Held Orders " + snapshot.getHeldOrders());
121 
			System.out.println("Created Orders " + snapshot.getCreatedOrders());
122 
			flipkartItem = flipkartItemsMap.get(snapshot.getItem_id());
123 
			availabilityAtFlipkart = itemInventoryMap.get(flipkartItem.getSkuAtFlipkart());
124 
			item = aliveItemsMap.get(snapshot.getItem_id());
125 
			snapshot.getItem_id();
126 
			snapshot.getAvailability();
127 
			snapshot.getCreatedOrders();
128 
			snapshot.getHeldOrders();
129 
			if(snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders() !=0){
10081 vikram.rag 130 
				reconcilledItems .append("<tr>"
131 
						+ "<td>" +getProductName(item)+"</td>"
132 
						+"<td>" + snapshot.getItem_id() + "</td>"
133 
						+"<td>" + snapshot.getAvailability() + "</td>"
134 
						+"<td>" + availabilityAtFlipkart + "</td>"
135 
						+"<td>" + snapshot.getCreatedOrders() + "</td>"
136 
						+"<td>" + snapshot.getHeldOrders() + "</td>"
137 
						+"<td>" + (snapshot.getAvailability() - snapshot.getCreatedOrders() - snapshot.getHeldOrders()) + "</td>"
138 
						+"</tr>");
10049 vikram.rag 139 
			}
140 
		}
141 
		String text = tableHeader+reconcilledItems.toString()+tableFooter;
142 
		try {
143 
			mailer.sendSSLMessage(sendTo,"Flipkart Inventory Reconcillation ", emailFromAddress, password, text);
144 
		} catch (MessagingException e) {
145 
			e.printStackTrace();
146 
		}
147 
	}
10058 vikram.rag 148 
	public static Map<String, Long> FetchInventoryAtFlipkart() throws ClientProtocolException, IOException{
149 
		Map<String,Long> itemInventoryMap = new HashMap<String,Long>();
10049 vikram.rag 150 
		HttpClient client = new DefaultHttpClient();
151 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
152 
		BufferedReader rd= null;
153 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
154 
		nameValuePairs.add(new BasicNameValuePair("authName",
155 
		"flipkart"));
156 
		nameValuePairs.add(new BasicNameValuePair("username",
157 
		"flipkart-support@saholic.com"));
158 
		nameValuePairs.add(new BasicNameValuePair("password",
159 
		"076c27ee24d7596b06608a8ed2559f87"));
160 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
161 
		HttpResponse response = client.execute(post);
162 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
163 
		String line ="";
164 
		while ((line  = rd.readLine()) != null) {
165 
			//System.out.println(line);
166 
		}
167 
		HttpGet get = new HttpGet("https://seller.flipkart.com/sellerListing/listing/downloadTemplateForExistingProducts?category=Mobiles+%26+Cameras&sellerId=m2z93iskuj81qiid&feedType=PRICING_STOCK&useDefaultTemplate=false");
168 
		response = client.execute(get);
169 
		InputStream in = response.getEntity().getContent();
170 
		Workbook wb = new HSSFWorkbook(in);
171 
		Sheet sheet = wb.getSheetAt(0);
172 
		Row firstRow = sheet.getRow(0);
173 
		Row SecondRow = sheet.getRow(1);
174 
		for (Row row : sheet) {
175 
			if(row.equals(firstRow) || row.equals(SecondRow))
176 
				continue;
177 
			row.getCell(6).setCellType(Cell.CELL_TYPE_STRING);
178 
			row.getCell(15).setCellType(Cell.CELL_TYPE_STRING);
179 
			System.out.println("SKU " + row.getCell(6).getStringCellValue() + " " + "Quantity "+ row.getCell(15).getStringCellValue());
180 
			if(!row.getCell(15).getStringCellValue().equals("")){
10058 vikram.rag 181 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(), Long.parseLong(row.getCell(15).getStringCellValue()));
10049 vikram.rag 182 
			}
183 
			else{
10058 vikram.rag 184 
				itemInventoryMap.put(row.getCell(6).getStringCellValue(),0L);
10049 vikram.rag 185 
			}
186 
		}
187 
		return itemInventoryMap;
188 
	}
189 
	static String getProductName(Item item){
190 
		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor());
191 
 
192 
	}
193 
	static String getName(String name){
194 
		if(name==null || name.length()==0){
195 
			return "";
196 
		}
197 
		else{
198 
			return name;
199 
		}
200 
	}
201 
 
202 
 
203 
}