WebSVN – SmartDukaan – Diff – /trunk/SnapDealFeeds/src/main/java/in/shop2020/UpdateSDInventoryUsingPanelNew.java

 import in.shop2020.model.v1.inventory.ItemInventory;
 import in.shop2020.model.v1.inventory.SnapdealInventoryItem;
 import in.shop2020.model.v1.inventory.Warehouse;
 import in.shop2020.model.v1.inventory.WarehouseLocation;
 import in.shop2020.model.v1.inventory.WarehouseType;
+import in.shop2020.serving.services.SnapdealSessionCookie;
 import in.shop2020.thrift.clients.CatalogClient;
 import in.shop2020.thrift.clients.InventoryClient;
 import in.shop2020.thrift.clients.TransactionClient;
 import in.shop2020.utils.GmailUtils;
 import inventory.Inventory;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.ss.usermodel.Sheet;
 import org.apache.poi.ss.usermodel.Workbook;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TTransportException;
+import org.json.JSONException;
+import org.json.JSONObject;
 import com.google.gson.Gson;
 public class UpdateSDInventoryUsingPanelNew {
 	private static final boolean PANEL = true;
 	static String emailFromAddress;
 	static String password;
 	static GmailUtils mailer;
 	static String sendTo[];
 	static StringBuffer notMappedItems=null;
+	static Map<String, String> headers = new HashMap<String, String>();
+	static {
+		headers.put("User-agent", "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11");
+		headers.put("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
+		headers.put("Accept-Language", "en-US,en;q=0.8");
+		headers.put("Accept-Charset", "ISO-8859-1,utf-8;q=0.7,*;q=0.3");
+	}
 	public static void initilaize() {
 		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
 		emailFromAddress = "build@shop2020.in";
 		password = "cafe@nes";
 			e.printStackTrace();
+		}
+	}
-	private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
+	private static void fetchinventoryhistoryfromsnapdeal() throws Exception{
 		int i = 1;
 		Gson gson = new Gson();
 		inventoryhistoryItemMap = new HashMap<String,InventoryHistory>();
 		boolean exitfetchinghistory = true;
 		System.out.println("Fetching history inventory");
 		HttpGet get;
 		HttpResponse response = null;
 		BufferedReader rd = null;
+		SnapdealSessionCookie sdSessionCookie = new SnapdealSessionCookie();
+		String cookies = "";
+		JSONObject cookieObject = null;
 		while(exitfetchinghistory){
 			System.out.println("Fetching inventory history page " +i);
 			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=dsc");
+			cookies = sdSessionCookie.getCookies();
+			cookieObject = new JSONObject(cookies);
+			for(String key:headers.keySet())
+				get.addHeader(key, headers.get(key));
+			get.addHeader("Cookie","SERVERID="+cookieObject.get("SERVERID")+";sfJSESSIONID="+cookieObject.get("sfJSESSIONID")+";");
 			try {
 				response = client.execute(get);
 			} catch (ClientProtocolException e) {
 				e.printStackTrace();
 				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
+			}
 		}*/
+	}
-	private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
+	private static void fetchcurrentinventoryfromsnapdeal() throws Exception{
 		int i = 1;
 		int items=0;
 		Gson gson = new Gson();
 		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
 		currentInventoryItemList = new ArrayList<Inventory>();
 		HttpGet get;
 		HttpResponse response = null;
 		BufferedReader rd= null;
 		System.out.println("Fetching current inventory ");
 		notMappedItems = new StringBuffer();
+		SnapdealSessionCookie sdSessionCookie = new SnapdealSessionCookie();
+		String cookies = "";
+		JSONObject cookieObject = null;
 		while(true){
 			//System.out.println("Fetching current inventory page " +i);
 			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
+			cookies = sdSessionCookie.getCookies();
+			cookieObject = new JSONObject(cookies);
+			for(String key:headers.keySet())
+				get.addHeader(key, headers.get(key));
+			get.addHeader("Cookie","SERVERID="+cookieObject.get("SERVERID")+";sfJSESSIONID="+cookieObject.get("sfJSESSIONID")+";");
 			try {
 				response = client.execute(get);
 			} catch (ClientProtocolException e) {
 				e.printStackTrace();
+			}
 			itemIdpendingOrdersMap.put(sku, pending_orders);
+		}
+	}
-	public static void handleLogout(){
-		HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/logout?service=http://seller.snapdeal.com/");
-		HttpResponse response = null;
-		try {
-			response = client.execute(get);
-		} catch (ClientProtocolException e) {
-			e.printStackTrace();
-		} catch (IOException e) {
-			e.printStackTrace();
-		}
-		BufferedReader rd = null;
-		try {
-			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
-		} catch (IllegalStateException e1) {
-			e1.printStackTrace();
-		} catch (IOException e1) {
-			e1.printStackTrace();
-		}
-		String line = "";
-		try{
-			while ((line = rd.readLine()) != null) {
-				//System.out.println(line);
-			}
-		}catch (IOException e1) {
-			e1.printStackTrace();
-		}
-	}
-	public static void handleLogin() throws ClientProtocolException, IOException{
-		HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/login?service=http%3A%2F%2Fseller.snapdeal.com%2Fj_spring_cas_security_check");
-		HttpResponse response = null;
-		try {
-			response = client.execute(get);
-		} catch (ClientProtocolException e) {
-			e.printStackTrace();
-		} catch (IOException e) {
-			e.printStackTrace();
-		}
-		BufferedReader rd = null;
-		try {
-			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
-		} catch (IllegalStateException e1) {
-			e1.printStackTrace();
-		} catch (IOException e1) {
-			e1.printStackTrace();
-		}
-		String line = "";
-		StringBuffer sb = new StringBuffer();
-		try {
-			while ((line = rd.readLine()) != null) {
-				sb.append(line);
-				//System.out.println(line);
-			}
-		} catch (IOException e) {
-			e.printStackTrace();
-		}
-		int i= sb.toString().indexOf("name=\"lt\" value=");
-		char[] charArray = sb.toString().toCharArray();
-		String lt = "";
-		int j=0;
-		for(j=i+16;j<=charArray.length;j++){
-			if(charArray[j]==' '){
-				break;
-			}
-		}
-		lt = sb.substring(i+17,j-1);
-		System.out.println("LT VALUE " + lt);
-		i= sb.toString().indexOf("name=\"execution\" value=");
-		charArray = sb.toString().toCharArray();
-		String ex = "";
-		j=0;
-		for(j=i+24;j<=charArray.length;j++){
-			if(charArray[j]==' '){
-				break;
-			}
-		}
-		ex = sb.substring(i+24,j-1);
-		System.out.println("EXECUTION VALUE " + ex);
-		HttpPost post = new HttpPost("http://selleraccounts.snapdeal.com/login?service=http%3A%2F%2Fseller.snapdeal.com%2Fj_spring_cas_security_check");
-		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
-		//nameValuePairs.add(new BasicNameValuePair("username",
-		//"khushal.bhatia@saholic.com"));
-		nameValuePairs.add(new BasicNameValuePair("username",
-		"saholic-snapdeal@saholic.com"));
-		//nameValuePairs.add(new BasicNameValuePair("password",
-		//"sonline"));
-		nameValuePairs.add(new BasicNameValuePair("password",
-		"saholic15"));
-		nameValuePairs.add(new BasicNameValuePair("_eventId","submit"));
-		nameValuePairs.add(new BasicNameValuePair("execution",ex));
-		nameValuePairs.add(new BasicNameValuePair("lt",lt));
-		//nameValuePairs.add(new BasicNameValuePair("submit","LOGIN"));
-		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
-		response = client.execute(post);
-		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
-		line = "";
-		while ((line = rd.readLine()) != null) {
-			System.out.println(line);
-		}
-		get = new HttpGet("http://seller.snapdeal.com/inventory/");
-		response = client.execute(get);
-		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
-		while ((line = rd.readLine()) != null) {
-			//System.out.println(line);
-		}
-	}
 	@SuppressWarnings("deprecation")
 	public static void sendsnapdealinventory (){
 		initilaize();
 		try {
-			handleLogin();
-		} catch (ClientProtocolException e2) {
-			System.out.println("Handle login failed");
-			e2.printStackTrace();
-		} catch (IOException e2) {
-			System.out.println("Handle login failed");
-			e2.printStackTrace();
-		}
-		try {
 			fetchinventoryhistoryfromsnapdeal();
 		} catch (UnsupportedEncodingException e2) {
 			System.out.println("History Inventory Fetch failed");
 			e2.printStackTrace();
 		} catch (TException e) {
 			e.printStackTrace();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
 		try {
 			fetchcurrentinventoryfromsnapdeal();
 		} catch (UnsupportedEncodingException e2) {
 			System.out.println("Current Inventory Fetch failed");
 			e2.printStackTrace();
 		} catch (TException e) {
 			e.printStackTrace();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
 		calculateinventory();
 		FileInputStream fis = null;
 		Workbook hwb = null;
 		Sheet sheet = null;
+		SnapdealSessionCookie sdSessionCookie = new SnapdealSessionCookie();
+		String cookies = "";
+		JSONObject cookieObject = null;
 		if(!PANEL){
 			try {
 				fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
 			} catch (FileNotFoundException e) {
 				System.out.println("Template File not found");
+					}
 					else{
 						System.out.println("Incremental check success");
 						try {
 							HttpPost post = new HttpPost("http://seller.snapdeal.com/inventory/update");
+							try {
+								cookies = sdSessionCookie.getCookies();
+							} catch (Exception e) {
+								e.printStackTrace();
+							}
+							try {
+								cookieObject = new JSONObject(cookies);
+							} catch (JSONException e) {
+								e.printStackTrace();
+							}
+							for(String key:headers.keySet())
+								post.addHeader(key, headers.get(key));
+							try {
+								post.addHeader("Cookie","SERVERID="+cookieObject.get("SERVERID")+";sfJSESSIONID="+cookieObject.get("sfJSESSIONID")+";");
+							} catch (JSONException e) {
+								e.printStackTrace();
+							}
 							List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
 							System.out.println("Calling update inventory: Supc: "+inventory.getSupc()+ " to be update stock: "+ sent_inventory);
 							nameValuePairs.add(new BasicNameValuePair("changedField",
 									"inventory"));
 							nameValuePairs.add(new BasicNameValuePair("changedValue",
 				} catch (UnsupportedEncodingException e1) {
 					System.out.println("Error while fetching inventory update result");
 					e1.printStackTrace();
 				} catch (TException e) {
 					e.printStackTrace();
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
 				if(inventoryhistoryItemMap.entrySet().size()==iterator -1){
 					feedsuccess = true;
 					break;
+				}
 				System.out.println("++++++++++++++++++++++++++++++");
 				Thread.sleep(30*60*1000);
 			} catch (InterruptedException e) {
 				e.printStackTrace();
+			}
-			handleLogout();
+		}
 		else{
 			try {
 				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal inventory to update "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Inventory to be updated ", emailFromAddress, password, new ArrayList<File>());
 			} catch (Exception e) {
 				System.out.println("++++++++++++++++++++++++++++++");
 				Thread.sleep(30*60*1000);
 			} catch (InterruptedException e) {
 				e.printStackTrace();
+			}
-			handleLogout();
+		}
 		String tableHeader = "<tr>"
 			+ "<td>" + "Product Name" +"</td>"
 			+"<td>" + "SKU at Snapdeal" + "</td>"
 			+"<td>" + "SUPC" + "</td>"

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/UpdateSDInventoryUsingPanelNew.java – Rev 15223 → 15602