Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
9776 vikram.rag 1 
package in.shop2020;
2 
 
3 
import in.shop2020.model.v1.catalog.MarketPlaceItemPrice;
4 
import in.shop2020.model.v1.catalog.SnapdealItemDetails;
5 
import in.shop2020.thrift.clients.CatalogClient;
6 
import in.shop2020.utils.GmailUtils;
7 
import inventory.Inventory;
8 
import inventory.InventoryHistoryItems;
9 
 
10 
import java.io.BufferedReader;
11 
import java.io.File;
12 
import java.io.FileInputStream;
13 
import java.io.FileNotFoundException;
14 
import java.io.FileOutputStream;
15 
import java.io.IOException;
16 
import java.io.InputStreamReader;
9858 vikram.rag 17 
import java.io.UnsupportedEncodingException;
9776 vikram.rag 18 
import java.text.SimpleDateFormat;
19 
import java.util.ArrayList;
20 
import java.util.HashMap;
21 
import java.util.List;
22 
import java.util.Map;
9821 vikram.rag 23 
import java.util.Map.Entry;
9776 vikram.rag 24 
 
25 
import javax.mail.MessagingException;
26 
 
27 
import org.apache.http.HttpResponse;
28 
import org.apache.http.NameValuePair;
29 
import org.apache.http.client.ClientProtocolException;
30 
import org.apache.http.client.entity.UrlEncodedFormEntity;
31 
import org.apache.http.client.methods.HttpGet;
32 
import org.apache.http.client.methods.HttpPost;
33 
import org.apache.http.entity.mime.MultipartEntity;
34 
import org.apache.http.entity.mime.content.ContentBody;
35 
import org.apache.http.entity.mime.content.FileBody;
36 
import org.apache.http.impl.client.DefaultHttpClient;
37 
import org.apache.http.message.BasicNameValuePair;
38 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
39 
import org.apache.poi.ss.usermodel.Row;
40 
import org.apache.poi.ss.usermodel.Sheet;
41 
import org.apache.poi.ss.usermodel.Workbook;
42 
import org.apache.thrift.TException;
43 
import org.apache.thrift.transport.TTransportException;
44 
 
45 
import pricing.CurrentPricing;
46 
import pricing.CurrentPricingItems;
47 
import pricing.PricingHistory;
48 
import pricing.PricingHistoryItems;
49 
 
50 
import com.google.gson.Gson;
51 
 
52 
public class CreateSnapdealPricingFeed {
53 
 
54 
	private static DefaultHttpClient client = new DefaultHttpClient();
55 
	private static long time = System.currentTimeMillis();
56 
	private static String SNAPDEAL_PRICING_SHEET;
57 
	static Map<String,SnapdealItemDetails> snapdealItemMap = new HashMap<String,SnapdealItemDetails>();
58 
	static Map<Long,SnapdealItemDetails> itemSnapdealMap = new HashMap<Long,SnapdealItemDetails>();
59 
	static List<MarketPlaceItemPrice> marketPlaceItemsPrices;
60 
	static Map<String,CurrentPricing> currentPricesMap = new HashMap<String,CurrentPricing>();
61 
	static PricingHistoryItems pricingHistoryItems;
62 
	static CurrentPricingItems currentPricingItems;
63 
	private static SimpleDateFormat sdf;
64 
	private static String emailFromAddress;
65 
	private static String password;
66 
	private static GmailUtils mailer;
67 
	private static String[] sendTo;
68 
 
69 
	static {
70 
		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
71 
		emailFromAddress = "build@shop2020.in";
72 
		password = "cafe@nes";
73 
		mailer = new GmailUtils();
9800 vikram.rag 74 
		//sendTo = new String[]{"vikram.raghav@shop2020.in"};
75 
		sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
9776 vikram.rag 76 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
77 
				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
78 
		CatalogClient catalogServiceClient = null;
79 
		try {
80 
			catalogServiceClient = new CatalogClient();
81 
		} catch (TTransportException e1) {
82 
			e1.printStackTrace();
83 
		}
84 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
85 
		List<SnapdealItemDetails> allSnapdealItems = null;
86 
		try {
87 
			allSnapdealItems = catalogClient.getAllSnapdealItems();
88 
			time = System.currentTimeMillis();
89 
			SNAPDEAL_PRICING_SHEET = "/home/snapdeal/snapdeal-pricing-"+time+".xls";
90 
			marketPlaceItemsPrices = catalogClient.getMarketPlaceItemsForPriceUpdate(7);
91 
			if(marketPlaceItemsPrices.size()==0){
92 
				System.out.println("No Change in Price to update");
93 
				try {
94 
					mailer.sendSSLMessage(sendTo,"No changes in Snapdeal Item Prices "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Prices to be update ", emailFromAddress, password, new ArrayList<File>());
95 
				} catch (MessagingException e) {
96 
					e.printStackTrace();
97 
				}
98 
				System.exit(0);
99 
			}
100 
		} catch (TException e) {
101 
			e.printStackTrace();
102 
		}
103 
		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
104 
			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
105 
			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
106 
		}
107 
 
108 
	}
9858 vikram.rag 109 
	public static void handleLogin() throws ClientProtocolException, IOException{
110 
		HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/keymaker/login");
9776 vikram.rag 111 
		HttpResponse response = null;
112 
		try {
9858 vikram.rag 113 
			response = client.execute(get);
9776 vikram.rag 114 
		} catch (ClientProtocolException e) {
115 
			// TODO Auto-generated catch block
116 
			e.printStackTrace();
117 
		} catch (IOException e) {
118 
			// TODO Auto-generated catch block
119 
			e.printStackTrace();
120 
		}
9858 vikram.rag 121 
		BufferedReader rd = null;
9776 vikram.rag 122 
		try {
123 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
124 
		} catch (IllegalStateException e1) {
9891 vikram.rag 125 
			// TODO Auto-generated catch block
9776 vikram.rag 126 
			e1.printStackTrace();
127 
		} catch (IOException e1) {
128 
			// TODO Auto-generated catch block
129 
			e1.printStackTrace();
130 
		}
131 
		String line = "";
9858 vikram.rag 132 
		StringBuffer sb = new StringBuffer();
9776 vikram.rag 133 
		try {
134 
			while ((line = rd.readLine()) != null) {
9858 vikram.rag 135 
				sb.append(line);
136 
				System.out.println(line);
9776 vikram.rag 137 
			}
138 
		} catch (IOException e) {
139 
			// TODO Auto-generated catch block
140 
			e.printStackTrace();
141 
		}
9858 vikram.rag 142 
		int i= sb.toString().indexOf("name=\"lt\" value=");
143 
		char[] charArray = sb.toString().toCharArray();
144 
		String lt = "";
145 
		int j=0;
146 
		for(j=i+16;j<=charArray.length;j++){
147 
 
148 
			if(charArray[j]==' '){
149 
				break;
150 
			}
151 
		}
152 
		lt = sb.substring(i+17,j-1);
153 
		System.out.println("LT VALUE " + lt);
154 
		i= sb.toString().indexOf("name=\"execution\" value=");
155 
		charArray = sb.toString().toCharArray();
156 
		String ex = "";
157 
		j=0;
158 
		for(j=i+24;j<=charArray.length;j++){
159 
			if(charArray[j]==' '){
160 
				break;
161 
			}
162 
		}
163 
		ex = sb.substring(i+24,j-1);
164 
		System.out.println("EXECUTION VALUE " + ex);
165 
		HttpPost post = new HttpPost("http://selleraccounts.snapdeal.com/keymaker/login");
166 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
167 
		nameValuePairs.add(new BasicNameValuePair("username",
168 
		"khushal.bhatia@saholic.com"));
169 
		nameValuePairs.add(new BasicNameValuePair("password",
170 
		"sonline"));
171 
		nameValuePairs.add(new BasicNameValuePair("_eventId","submit"));
172 
		nameValuePairs.add(new BasicNameValuePair("execution",ex));
173 
		nameValuePairs.add(new BasicNameValuePair("lt",lt));
174 
		nameValuePairs.add(new BasicNameValuePair("submit","LOGIN"));
175 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
176 
		response = client.execute(post);
177 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
178 
		line = "";
179 
		while ((line = rd.readLine()) != null) {
180 
			//System.out.println(line);
181 
		}
182 
		get = new HttpGet("http://seller.snapdeal.com/pricing/");
183 
		response = client.execute(get);
184 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
185 
		while ((line = rd.readLine()) != null) {
186 
			//System.out.println(line);
187 
		}
188 
	}
189 
 
190 
 
191 
	public static void main(String... args) throws IOException, InterruptedException{
192 
		handleLogin();
193 
		HttpGet get;
194 
		BufferedReader rd= null;
9776 vikram.rag 195 
		Gson gson = new Gson();
196 
		int i = 1;
197 
		boolean exitfetchingcurrent = true;
198 
		System.out.println("Fetching current prices");
9858 vikram.rag 199 
		HttpResponse response;
9776 vikram.rag 200 
		while(exitfetchingcurrent){
201 
			get = new HttpGet("http://seller.snapdeal.com/pricing/search?gridType=normal&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=asc");
202 
			response = client.execute(get);
203 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
204 
			currentPricingItems = (CurrentPricingItems) gson.fromJson(rd, CurrentPricingItems.class);
205 
			if(currentPricingItems.getRows().size()!=0){
206 
				for(CurrentPricing currentPricing:currentPricingItems.getRows()){
207 
					currentPricesMap.put(currentPricing.getSellerSku(),currentPricing);
9891 vikram.rag 208 
					System.out.println(currentPricing.getSellerSku()+" "+currentPricing.getSellingPrice());
9776 vikram.rag 209 
				}
210 
			}
211 
			else{
212 
				exitfetchingcurrent = false;
213 
			}
214 
			i++;
215 
		}
216 
		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerPricing.xls");
217 
		Workbook hwb = new HSSFWorkbook(fis);
218 
		Sheet sheet = hwb.getSheetAt(0);
219 
		Row row;
220 
		int iterator = 1;
9821 vikram.rag 221 
		Map<String,Double> toUpdateSkuMap = new HashMap<String,Double>();
9776 vikram.rag 222 
		for(MarketPlaceItemPrice marketPlaceItemPrice:marketPlaceItemsPrices){
223 
			System.out.println(marketPlaceItemPrice.getItem_id() + " " + marketPlaceItemPrice.getSellingPrice());
224 
			if(itemSnapdealMap.containsKey(marketPlaceItemPrice.getItem_id()) && marketPlaceItemPrice.getLastUpdatedOn() > marketPlaceItemPrice.getLastUpdatedOnMarketplace() && !marketPlaceItemPrice.isIsPriceOverride() && marketPlaceItemPrice.isIsListedOnSource()){
225 
				if(currentPricesMap.containsKey(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()) && Double.parseDouble(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getSellingPrice()) != marketPlaceItemPrice.getSellingPrice() && marketPlaceItemPrice.getSellingPrice()!=0){
9799 vikram.rag 226 
					row =   sheet.getRow((short) iterator);
9776 vikram.rag 227 
					row.getCell((short) 0).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getSupc());
228 
					row.getCell((short) 1).setCellValue(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal());
229 
					row.getCell((short) 2).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getProductName());
230 
					row.getCell((short) 3).setCellValue(marketPlaceItemPrice.getSellingPrice());
231 
					row.getCell((short) 4).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getLive());
9821 vikram.rag 232 
					toUpdateSkuMap.put(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal(),marketPlaceItemPrice.getSellingPrice());
9776 vikram.rag 233 
					iterator++;
234 
				}
235 
			}
236 
		}
237 
		if(iterator!=1){
238 
			FileOutputStream fileOut = null;
239 
			fis.close();
240 
			try {
241 
				System.out.println("Before writing file ");
242 
				fileOut = new FileOutputStream(SNAPDEAL_PRICING_SHEET);
243 
			} catch (FileNotFoundException e) {
244 
				e.printStackTrace();
245 
			}
246 
			try {
247 
 
248 
				hwb.write(fileOut);
249 
			} catch (IOException e) {
250 
				// TODO Auto-generated catch block
251 
				e.printStackTrace();
252 
			}
9858 vikram.rag 253 
			HttpPost post = new HttpPost("http://seller.snapdeal.com/pricing/upload");
9776 vikram.rag 254 
			File file = new File(SNAPDEAL_PRICING_SHEET);
255 
			MultipartEntity mpEntity = new MultipartEntity();
256 
			ContentBody cbFile = new FileBody(file,"application/vnd.ms-excel");
257 
			mpEntity.addPart("file", cbFile);
258 
			post.setEntity(mpEntity);
259 
			response = client.execute(post);
260 
			try {
261 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
262 
			} catch (IllegalStateException e1) {
263 
				e1.printStackTrace();
264 
			} catch (IOException e1) {
265 
				e1.printStackTrace();
266 
			}
9858 vikram.rag 267 
			String line = "";
9776 vikram.rag 268 
			String feedresponse = null;
269 
			try {
270 
				while ((line = rd.readLine()) != null) {
271 
					feedresponse = line;
272 
				}
273 
			} catch (IOException e) {
274 
				// TODO Auto-generated catch block
275 
				e.printStackTrace();
276 
			}
277 
			int retry = 5;
278 
			boolean exitfetchinghistory;
279 
			int successfullyUpdated;
9821 vikram.rag 280 
			Map<String,Double> updatedSkuMap = new HashMap<String,Double>();
9776 vikram.rag 281 
			System.out.println("Feed response " + feedresponse);
282 
			if(feedresponse.contains("Error")){
283 
				System.out.println("Error while uploading sheet");
284 
				try {
9891 vikram.rag 285 
					mailer.sendSSLMessage(sendTo,"Error at Snapdeal while Uploading Pricing feed "+ sdf.format(System.currentTimeMillis()),"This Error means that there is some problem while uploading pricing feed to snapdeal", emailFromAddress, password, new ArrayList<File>());
9776 vikram.rag 286 
				} catch (MessagingException e) {
287 
					e.printStackTrace();
288 
				}
289 
				System.exit(0);
290 
			}
291 
			String uploadId = "UID"+feedresponse.split("UID")[1];
292 
			System.out.println("Feed Upload Id is " + uploadId);
293 
			int j = 1;
294 
			i=1;
295 
			while(retry > 0){
296 
				Thread.sleep(5*60*1000);
297 
				exitfetchinghistory = true;
298 
				System.out.println("Fetching history prices " + j);
299 
				successfullyUpdated =0;
300 
				while(exitfetchinghistory){
301 
					get = new HttpGet("http://seller.snapdeal.com/pricing/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=asc");
302 
					response = client.execute(get);
303 
					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
304 
					pricingHistoryItems = (PricingHistoryItems) gson.fromJson(rd, PricingHistoryItems.class);
9778 vikram.rag 305 
					if(pricingHistoryItems.getRows().size()!=0 &&  successfullyUpdated != (iterator - 1)){
9776 vikram.rag 306 
						for(PricingHistory pricingHistory:pricingHistoryItems.getRows()){
307 
							if(Long.parseLong(pricingHistory.getModifiedOn()) > time && pricingHistory.getApprovalStatus().equals("Done") && pricingHistory.getUploadId().equals(uploadId)){
308 
								successfullyUpdated++;
9821 vikram.rag 309 
								updatedSkuMap.put(pricingHistory.getSellerSku(),Double.parseDouble(pricingHistory.getLineitems().get(0).getNewValue()));
9778 vikram.rag 310 
								System.out.println("SKU Updated " + pricingHistory.getSellerSku() + " " + pricingHistory.getUploadId());
9776 vikram.rag 311 
							}
312 
						}
313 
					}
314 
					else{
315 
						exitfetchinghistory = false;
9778 vikram.rag 316 
						if(successfullyUpdated == (iterator-1)){
9776 vikram.rag 317 
							retry = 0;
318 
						}
319 
					}
320 
					i++;
321 
				}
322 
				retry--;
323 
				j++;
324 
			}
325 
			CatalogClient catalogServiceClient = null;
326 
			try {
327 
				catalogServiceClient = new CatalogClient();
328 
			} catch (TTransportException e1) {
329 
				e1.printStackTrace();
330 
			}
331 
			in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
332 
			List<Long> updatedItems = new ArrayList<Long>();
9821 vikram.rag 333 
			String tableHeader = "<tr>"
334 
				+ "<td>" + "Product Name" +"</td>"
335 
				+"<td>" + "Item ID" + "</td>"
336 
				+"<td>" + "SKU at Snapdeal" + "</td>"
337 
				+"<td>" + "Old Price" + "</td>"
338 
				+"<td>" + "New Price" + "</td>"
339 
				+"</tr>";
340 
			if(toUpdateSkuMap.size() != updatedSkuMap.size()){
341 
				StringBuffer notUpdatedMailBody =new StringBuffer();
342 
				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
343 
					toUpdateSkuMap.remove(entry.getKey());
344 
				}
345 
				for(Entry<String, Double> entry:toUpdateSkuMap.entrySet()){
346 
					notUpdatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
9824 vikram.rag 347 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
348 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getSkuAtSnapdeal() + "</td>"
349 
							+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
350 
							+"<td>" + entry.getValue() +"</td>");
351 
 
9821 vikram.rag 352 
				}
353 
				String text = "<html><table border=\"1\" align=\"center\">"
9824 vikram.rag 354 
					+ tableHeader
355 
					+ notUpdatedMailBody.toString() + "</table></html>";
356 
 
9776 vikram.rag 357 
				System.out.println("SKUs not updated");
358 
				try {
9821 vikram.rag 359 
					mailer.sendSSLMessage(sendTo,"Snapdeal Item Prices were not updated "+ sdf.format(System.currentTimeMillis()),emailFromAddress, password, text);
9776 vikram.rag 360 
				} catch (MessagingException e) {
361 
					// TODO Auto-generated catch block
362 
					e.printStackTrace();
363 
				}
9824 vikram.rag 364 
 
9776 vikram.rag 365 
			}
9821 vikram.rag 366 
			if(updatedSkuMap.size()>0){
367 
				StringBuffer updatedMailBody =new StringBuffer();
368 
				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
369 
					updatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
370 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
9824 vikram.rag 371 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getSkuAtSnapdeal() + "</td>"
9821 vikram.rag 372 
							+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
373 
							+"<td>" + entry.getValue() +"</td>");
9824 vikram.rag 374 
					updatedItems.add(snapdealItemMap.get(entry.getKey()).getItem_id());
9776 vikram.rag 375 
				}
376 
				try {
9817 vikram.rag 377 
					catalogClient.updateMarketPlacePriceUpdateStatus(updatedItems,time,7);
9776 vikram.rag 378 
				} catch (TException e) {
379 
					try {
9817 vikram.rag 380 
						new CatalogClient().getClient().updateMarketPlacePriceUpdateStatus(updatedItems, time,7);
9776 vikram.rag 381 
					} catch (TTransportException e1) {
382 
						e1.printStackTrace();
383 
					} catch (TException e1) {
384 
						e1.printStackTrace();
385 
					}
386 
					e.printStackTrace();
387 
				}
9821 vikram.rag 388 
				String text = "<html><table border=\"1\" align=\"center\">"
389 
					+ tableHeader
390 
					+ updatedMailBody.toString() + "</table></html>";
9824 vikram.rag 391 
 
9776 vikram.rag 392 
				try {
9778 vikram.rag 393 
					System.out.println("Snapdeal Item Prices updated Successfully");
9821 vikram.rag 394 
					if(updatedSkuMap.size()==1){
395 
						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Item Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
9797 vikram.rag 396 
					}
397 
					else{
9821 vikram.rag 398 
						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Items Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
9797 vikram.rag 399 
					}
9776 vikram.rag 400 
				} catch (MessagingException e) {
401 
					e.printStackTrace();
402 
				}
403 
			}
404 
		}
405 
		else{
406 
			try {
407 
				System.out.println("Prices are same as the snapdeal prices");
408 
				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal Item Prices "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Prices to be update ", emailFromAddress, password, new ArrayList<File>());
409 
			} catch (MessagingException e) {
410 
				e.printStackTrace();
411 
			}
9824 vikram.rag 412 
 
9776 vikram.rag 413 
		}
414 
 
415 
	}
416 
 
417 
 
418 
}