Subversion Repositories SmartDukaan

Rev

Rev 9858 | Rev 9892 | 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 
		}
9891 vikram.rag 216 
		System.out.println("Before exit");
217 
		System.exit(0);
9776 vikram.rag 218 
		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerPricing.xls");
219 
		Workbook hwb = new HSSFWorkbook(fis);
220 
		Sheet sheet = hwb.getSheetAt(0);
221 
		Row row;
222 
		int iterator = 1;
9821 vikram.rag 223 
		Map<String,Double> toUpdateSkuMap = new HashMap<String,Double>();
9776 vikram.rag 224 
		for(MarketPlaceItemPrice marketPlaceItemPrice:marketPlaceItemsPrices){
225 
			System.out.println(marketPlaceItemPrice.getItem_id() + " " + marketPlaceItemPrice.getSellingPrice());
226 
			if(itemSnapdealMap.containsKey(marketPlaceItemPrice.getItem_id()) && marketPlaceItemPrice.getLastUpdatedOn() > marketPlaceItemPrice.getLastUpdatedOnMarketplace() && !marketPlaceItemPrice.isIsPriceOverride() && marketPlaceItemPrice.isIsListedOnSource()){
227 
				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 228 
					row =   sheet.getRow((short) iterator);
9776 vikram.rag 229 
					row.getCell((short) 0).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getSupc());
230 
					row.getCell((short) 1).setCellValue(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal());
231 
					row.getCell((short) 2).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getProductName());
232 
					row.getCell((short) 3).setCellValue(marketPlaceItemPrice.getSellingPrice());
233 
					row.getCell((short) 4).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getLive());
9821 vikram.rag 234 
					toUpdateSkuMap.put(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal(),marketPlaceItemPrice.getSellingPrice());
9776 vikram.rag 235 
					iterator++;
236 
				}
237 
			}
238 
		}
239 
		if(iterator!=1){
240 
			FileOutputStream fileOut = null;
241 
			fis.close();
242 
			try {
243 
				System.out.println("Before writing file ");
244 
				fileOut = new FileOutputStream(SNAPDEAL_PRICING_SHEET);
245 
			} catch (FileNotFoundException e) {
246 
				e.printStackTrace();
247 
			}
248 
			try {
249 
 
250 
				hwb.write(fileOut);
251 
			} catch (IOException e) {
252 
				// TODO Auto-generated catch block
253 
				e.printStackTrace();
254 
			}
9858 vikram.rag 255 
			HttpPost post = new HttpPost("http://seller.snapdeal.com/pricing/upload");
9776 vikram.rag 256 
			File file = new File(SNAPDEAL_PRICING_SHEET);
257 
			MultipartEntity mpEntity = new MultipartEntity();
258 
			ContentBody cbFile = new FileBody(file,"application/vnd.ms-excel");
259 
			mpEntity.addPart("file", cbFile);
260 
			post.setEntity(mpEntity);
261 
			response = client.execute(post);
262 
			try {
263 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
264 
			} catch (IllegalStateException e1) {
265 
				e1.printStackTrace();
266 
			} catch (IOException e1) {
267 
				e1.printStackTrace();
268 
			}
9858 vikram.rag 269 
			String line = "";
9776 vikram.rag 270 
			String feedresponse = null;
271 
			try {
272 
				while ((line = rd.readLine()) != null) {
273 
					feedresponse = line;
274 
				}
275 
			} catch (IOException e) {
276 
				// TODO Auto-generated catch block
277 
				e.printStackTrace();
278 
			}
279 
			int retry = 5;
280 
			boolean exitfetchinghistory;
281 
			int successfullyUpdated;
9821 vikram.rag 282 
			Map<String,Double> updatedSkuMap = new HashMap<String,Double>();
9776 vikram.rag 283 
			System.out.println("Feed response " + feedresponse);
284 
			if(feedresponse.contains("Error")){
285 
				System.out.println("Error while uploading sheet");
286 
				try {
9891 vikram.rag 287 
					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 288 
				} catch (MessagingException e) {
289 
					e.printStackTrace();
290 
				}
291 
				System.exit(0);
292 
			}
293 
			String uploadId = "UID"+feedresponse.split("UID")[1];
294 
			System.out.println("Feed Upload Id is " + uploadId);
295 
			int j = 1;
296 
			i=1;
297 
			while(retry > 0){
298 
				Thread.sleep(5*60*1000);
299 
				exitfetchinghistory = true;
300 
				System.out.println("Fetching history prices " + j);
301 
				successfullyUpdated =0;
302 
				while(exitfetchinghistory){
303 
					get = new HttpGet("http://seller.snapdeal.com/pricing/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=asc");
304 
					response = client.execute(get);
305 
					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
306 
					pricingHistoryItems = (PricingHistoryItems) gson.fromJson(rd, PricingHistoryItems.class);
9778 vikram.rag 307 
					if(pricingHistoryItems.getRows().size()!=0 &&  successfullyUpdated != (iterator - 1)){
9776 vikram.rag 308 
						for(PricingHistory pricingHistory:pricingHistoryItems.getRows()){
309 
							if(Long.parseLong(pricingHistory.getModifiedOn()) > time && pricingHistory.getApprovalStatus().equals("Done") && pricingHistory.getUploadId().equals(uploadId)){
310 
								successfullyUpdated++;
9821 vikram.rag 311 
								updatedSkuMap.put(pricingHistory.getSellerSku(),Double.parseDouble(pricingHistory.getLineitems().get(0).getNewValue()));
9778 vikram.rag 312 
								System.out.println("SKU Updated " + pricingHistory.getSellerSku() + " " + pricingHistory.getUploadId());
9776 vikram.rag 313 
							}
314 
						}
315 
					}
316 
					else{
317 
						exitfetchinghistory = false;
9778 vikram.rag 318 
						if(successfullyUpdated == (iterator-1)){
9776 vikram.rag 319 
							retry = 0;
320 
						}
321 
					}
322 
					i++;
323 
				}
324 
				retry--;
325 
				j++;
326 
			}
327 
			CatalogClient catalogServiceClient = null;
328 
			try {
329 
				catalogServiceClient = new CatalogClient();
330 
			} catch (TTransportException e1) {
331 
				e1.printStackTrace();
332 
			}
333 
			in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
334 
			List<Long> updatedItems = new ArrayList<Long>();
9821 vikram.rag 335 
			String tableHeader = "<tr>"
336 
				+ "<td>" + "Product Name" +"</td>"
337 
				+"<td>" + "Item ID" + "</td>"
338 
				+"<td>" + "SKU at Snapdeal" + "</td>"
339 
				+"<td>" + "Old Price" + "</td>"
340 
				+"<td>" + "New Price" + "</td>"
341 
				+"</tr>";
342 
			if(toUpdateSkuMap.size() != updatedSkuMap.size()){
343 
				StringBuffer notUpdatedMailBody =new StringBuffer();
344 
				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
345 
					toUpdateSkuMap.remove(entry.getKey());
346 
				}
347 
				for(Entry<String, Double> entry:toUpdateSkuMap.entrySet()){
348 
					notUpdatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
9824 vikram.rag 349 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
350 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getSkuAtSnapdeal() + "</td>"
351 
							+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
352 
							+"<td>" + entry.getValue() +"</td>");
353 
 
9821 vikram.rag 354 
				}
355 
				String text = "<html><table border=\"1\" align=\"center\">"
9824 vikram.rag 356 
					+ tableHeader
357 
					+ notUpdatedMailBody.toString() + "</table></html>";
358 
 
9776 vikram.rag 359 
				System.out.println("SKUs not updated");
360 
				try {
9821 vikram.rag 361 
					mailer.sendSSLMessage(sendTo,"Snapdeal Item Prices were not updated "+ sdf.format(System.currentTimeMillis()),emailFromAddress, password, text);
9776 vikram.rag 362 
				} catch (MessagingException e) {
363 
					// TODO Auto-generated catch block
364 
					e.printStackTrace();
365 
				}
9824 vikram.rag 366 
 
9776 vikram.rag 367 
			}
9821 vikram.rag 368 
			if(updatedSkuMap.size()>0){
369 
				StringBuffer updatedMailBody =new StringBuffer();
370 
				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
371 
					updatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
372 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
9824 vikram.rag 373 
							+"<td>" + snapdealItemMap.get(entry.getKey()).getSkuAtSnapdeal() + "</td>"
9821 vikram.rag 374 
							+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
375 
							+"<td>" + entry.getValue() +"</td>");
9824 vikram.rag 376 
					updatedItems.add(snapdealItemMap.get(entry.getKey()).getItem_id());
9776 vikram.rag 377 
				}
378 
				try {
9817 vikram.rag 379 
					catalogClient.updateMarketPlacePriceUpdateStatus(updatedItems,time,7);
9776 vikram.rag 380 
				} catch (TException e) {
381 
					try {
9817 vikram.rag 382 
						new CatalogClient().getClient().updateMarketPlacePriceUpdateStatus(updatedItems, time,7);
9776 vikram.rag 383 
					} catch (TTransportException e1) {
384 
						e1.printStackTrace();
385 
					} catch (TException e1) {
386 
						e1.printStackTrace();
387 
					}
388 
					e.printStackTrace();
389 
				}
9821 vikram.rag 390 
				String text = "<html><table border=\"1\" align=\"center\">"
391 
					+ tableHeader
392 
					+ updatedMailBody.toString() + "</table></html>";
9824 vikram.rag 393 
 
9776 vikram.rag 394 
				try {
9778 vikram.rag 395 
					System.out.println("Snapdeal Item Prices updated Successfully");
9821 vikram.rag 396 
					if(updatedSkuMap.size()==1){
397 
						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Item Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
9797 vikram.rag 398 
					}
399 
					else{
9821 vikram.rag 400 
						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Items Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
9797 vikram.rag 401 
					}
9776 vikram.rag 402 
				} catch (MessagingException e) {
403 
					e.printStackTrace();
404 
				}
405 
			}
406 
		}
407 
		else{
408 
			try {
409 
				System.out.println("Prices are same as the snapdeal prices");
410 
				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>());
411 
			} catch (MessagingException e) {
412 
				e.printStackTrace();
413 
			}
9824 vikram.rag 414 
 
9776 vikram.rag 415 
		}
416 
 
417 
	}
418 
 
419 
 
420 
}