Subversion Repositories SmartDukaan

Rev

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