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

 package in.shop2020;
-import in.shop2020.model.v1.order.Order;
 import in.shop2020.model.v1.order.OrderSource;
+import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.thrift.clients.TransactionClient;
 import java.io.BufferedReader;
-import java.io.ByteArrayInputStream;
 import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
-import org.apache.commons.httpclient.methods.GetMethod;
+import org.apache.http.client.methods.HttpGet;
-import org.apache.commons.httpclient.methods.PostMethod;
+import org.apache.http.client.methods.HttpPost;
-import org.apache.commons.httpclient.HttpClient;
+import org.apache.http.impl.client.DefaultHttpClient;
-import org.apache.commons.httpclient.NameValuePair;
+import org.apache.http.message.BasicNameValuePair;
 import org.json.JSONArray;
-import org.json.JSONException;
 import org.json.JSONObject;
-import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
 public class SnapdealOrderStatusReconciliation{
 	private static Logger logger;
-	public static void main(String[] args){
+	public static void main(String[] args) throws UnsupportedEncodingException{
 		logger = LoggerFactory.getLogger(SnapdealOrderStatusReconciliation.class);
+		/*List<OrderStatus> statuses = new ArrayList<OrderStatus>();
+		statuses.add(OrderStatus.SHIPPED_FROM_WH);
+		statuses.add(OrderStatus.SHIPPED_TO_LOGST);*/
 		Map<String,List<List<String>>> orderDataMap = new HashMap<String,List<List<String>>>();
 		List<List<String>> deliveredOrderDataList = new ArrayList<List<String>>();
 		List<List<String>> cancelledOrderDataList = new ArrayList<List<String>>();
 		long minCreationDate = 0l;
 		long currentTime = System.currentTimeMillis();
+		}
 		else{
 			startDate = snapdealDateFormat.format(new Date(currentTime));
+		}
 		logger.info("Snapdeal Order Recon Start Date .. "+startDate);
-		/*startDate = startDate.replace("-", "%2F");*/
+		//startDate = startDate.replace("-", "%2F");
-		String endDate = snapdealDateFormat.format(new Date(currentTime));
+		String endDate = snapdealDateFormat.format(new Date(System.currentTimeMillis()));
 		logger.info("Snapdeal Order Recon End Date .. "+endDate);
-		/*endDate = endDate.replace("-", "%2F");*/
+		//endDate = endDate.replace("-", "%2F");
-		HttpClient newClient = new HttpClient();
+		HttpClient client = new DefaultHttpClient();
-		PostMethod postMethod = new PostMethod("http://shipping.snapdeal.com/login_security_check?spring-security-redirect=http://shipping.snapdeal.com/vendor/product-shipment/shippingDashboard&");
+		HttpPost post = new HttpPost("http://shipping.snapdeal.com/login_security_check?spring-security-redirect=http://shipping.snapdeal.com/vendor/product-shipment/shippingDashboard&");
+		HttpGet get;
+		BufferedReader rd= null;
 		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
-		nameValuePairs.add(new NameValuePair("j_username",
+		nameValuePairs.add(new BasicNameValuePair("j_username",
-		"khushal.bhatia@saholic.com"));
+		"saholic-snapdeal@saholic.com"));
-		nameValuePairs.add(new NameValuePair("j_password",
+		nameValuePairs.add(new BasicNameValuePair("j_password",
-		"s@h0l1c"));
+		"d73eaa39"));
-		NameValuePair[] nameValuePairArray = new NameValuePair[nameValuePairs.size()];
-		nameValuePairArray = nameValuePairs.toArray(nameValuePairArray);
-		postMethod.addParameters(nameValuePairArray);
+		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
-		BufferedReader rd = null;
+		HttpResponse response = null;
-		int statusCode = 0;
-		try{
+		try {
-			statusCode = newClient.executeMethod(postMethod);
+			response = client.execute(post);
-		}catch(Exception e){
+		} catch (Exception e) {
 			logger.error("Unable to get Http Response for snapdeal seller portal login", e);
+		}
 		try {
-			rd = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(postMethod.getResponseBody())));
+			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 		} catch (Exception e1) {
 			logger.error("Unable to read Http Response for snapdeal seller portal login", e1);
+		}
 		String line = "";
 				System.out.println(line);
+			}
 		} catch (Exception e) {
 			logger.error("Unable to extract Http Response for snapdeal seller portal login", e);
+		}
+		JSONObject jsonDataObj = null;
 		JSONArray jsonDataShip = null;
 		String line1 = "";
 		for(long start = start_date.getTime(); start < end_date.getTime();){
 			long end = start + 604800000l;
 			if(end > end_date.getTime()){
 				end = end_date.getTime();
+			}
 			endDate = snapdealDateFormat.format(new Date(end));
 			endDate = endDate.replace("-", "%2F");
 			logger.info("==== Start Date.."+startDate+"\n");
 			logger.info("==== End Date.."+endDate+"\n");
-			logger.info("Getting Delivery Information for DropShip Snapdeal Orders");
-			String dropshipUrl = "http://shipping.snapdeal.com/vendor/DROPSHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=COURIER_DELIVERED&statusColumn=deliveredOn&dispatchCategoryId=0&sCode=COURIER_DELIVERED";
-			logger.info("Drop Ship Url "+dropshipUrl);
-			GetMethod getMethod = new GetMethod(dropshipUrl);
+			logger.info("Getting Delivery Information for DropShip Snapdeal Orders");
+			String dropshipUrl = "http://shipping.snapdeal.com/vendor/DROPSHIP/product-shipment/shippedData/fetch/?startDate="+startDate+"&endDate="+endDate+"&specialPanelAccess=&statusCode=COURIER_DELIVERED&statusColumn=deliveredOn&dispatchCategoryId=0&sCode=COURIER_DELIVERED";
+			logger.info("Drop Ship Url "+dropshipUrl);
+			get = new HttpGet(dropshipUrl);
 			try {
-				statusCode = newClient.executeMethod(getMethod);
+				response = client.execute(get);
 			} catch (Exception e) {
 				logger.error("Unable to get Http Response for snapdeal dropship delivered orders", e);
+			}
 			try {
-				rd = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(getMethod.getResponseBody())));
+				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (Exception e) {
 				logger.error("Unable to read Http Response for snapdeal dropship delivered orders", e);
+			}
 			try {
-				while ((line1 = rd.readLine()) != null) {
+				jsonDataObj = new JSONObject(rd.readLine());
-					if(line1.contains("jsonString")){
-						String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
-						logger.info("Response get from SnapDeal DropShip.. ");
-						jsonDataShip = new JSONArray(jsonString);
+				jsonDataShip = new JSONArray(jsonDataObj.get("jsonDataString").toString());
-						break;
-					}
-				}
 			} catch (Exception e) {
 				logger.error("Unable to extract Http Response for snapdeal dropship delivered orders", e);
+			}
 			if(jsonDataShip!=null && jsonDataShip.length()>0){
 				for(int i=0; i< jsonDataShip.length(); i++){
 					JSONObject jsonObj = null;
 					try {
 						jsonObj = jsonDataShip.getJSONObject(i);
 						if(jsonObj!=null){
-							//System.out.println(jsonObj);
 							String subOrderCode =(String) jsonObj.get("suborderCode");
-							String referenceNumber =(String) jsonObj.get("referenceNumber");
+							String referenceNumber =(String) jsonObj.get("referenceCode");
 							String deliveryDate =(String) jsonObj.get("deliveredOn");
-							//System.out.println("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber+ " ...deliveryDate... "+ deliveryDate);
 							logger.info("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber+ " ...deliveryDate... "+ deliveryDate);
 							deliveryDate = ourDBDateFormat.format(gotSnapdealDateFormat.parse(deliveryDate).getTime());
 							List<String> deliveredOrdelList = new ArrayList<String>();
 							deliveredOrdelList.add(referenceNumber);
 							deliveredOrdelList.add(subOrderCode);
 						logger.error("Unable to add delivered order details for updation regarding snapdeal dropship delivered orders", e);
+					}
+				}
+			}
-			getMethod.releaseConnection();
 			logger.info("Getting Delivery Information for OneShip Snapdeal Orders");
+			//statusCode=CLD&dispatchCategoryId=0&startDate=2013%2F11%2F01&endDate=2013%2F11%2F07&statusColumn=cancelledOn
-			String oneShipUrl = "http://shipping.snapdeal.com/vendor/ONESHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=COURIER_DELIVERED&statusColumn=deliveredOn&dispatchCategoryId=0&sCode=COURIER_DELIVERED";
+			String oneShipUrl = "http://shipping.snapdeal.com/vendor/ONESHIP/product-shipment/shippedData/fetch/?startDate="+startDate+"&endDate="+endDate+"&specialPanelAccess=&statusCode=COURIER_DELIVERED&statusColumn=deliveredOn&dispatchCategoryId=0&sCode=COURIER_DELIVERED";
 			logger.info("One Ship Url "+oneShipUrl);
-			getMethod = new GetMethod(oneShipUrl);
+			get = new HttpGet(oneShipUrl);
 			try {
-				statusCode = newClient.executeMethod(getMethod);
+				response = client.execute(get);
 			} catch (Exception e) {
 				logger.error("Unable to get Http Response for snapdeal oneship delivered orders", e);
+			}
 			try {
-				rd = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(getMethod.getResponseBody())));
+				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (Exception e) {
 				logger.error("Unable to read Http Response for snapdeal oneship delivered orders", e);
 			}
 			try {
-				while ((line1 = rd.readLine()) != null) {
+				jsonDataObj = new JSONObject(rd.readLine());
-					if(line1.contains("jsonString")){
-						String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
-						logger.info("Response get from SnapDeal OneShip.. ");
-						jsonDataShip = new JSONArray(jsonString);
+				jsonDataShip = new JSONArray(jsonDataObj.get("jsonDataString").toString());
-						break;
-					}
-				}
 			} catch (Exception e) {
 				logger.error("Unable to extract Http Response for snapdeal oneship delivered orders", e);
 			}
 			if(jsonDataShip!=null && jsonDataShip.length()>0){
 				for(int i=0; i< jsonDataShip.length(); i++){
 					JSONObject jsonObj = null;
 					try {
 						jsonObj = jsonDataShip.getJSONObject(i);
 						if(jsonObj!=null){
-							//System.out.println(jsonObj);
 							String subOrderCode =(String) jsonObj.get("suborderCode");
-							String referenceNumber =(String) jsonObj.get("referenceNumber");
+							String referenceNumber =(String) jsonObj.get("referenceCode");
 							String deliveryDate =(String) jsonObj.get("deliveredOn");
-							//System.out.println("Snapdeal Oneship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber+ " ...deliveryDate... "+ deliveryDate);
 							logger.info("Snapdeal Oneship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber+ " ...deliveryDate... "+ deliveryDate);
 							deliveryDate = ourDBDateFormat.format(gotSnapdealDateFormat.parse(deliveryDate).getTime());
 							List<String> deliveredOrdelList = new ArrayList<String>();
 							deliveredOrdelList.add(referenceNumber);
 							deliveredOrdelList.add(subOrderCode);
 						logger.error("Unable to add delivered order details for updation regarding snapdeal oneship delivered orders", e);
+					}
+				}
+			}
-			getMethod.releaseConnection();
 			logger.info("Getting Information for Cancelled DropShip Snapdeal Orders");
-			String dropshipCancelUrl = "http://shipping.snapdeal.com/vendor/DROPSHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=CANCELLATION_COMPLETE&statusColumn=cancelledOn&dispatchCategoryId=0&sCode=CANCELLATION_COMPLETE";
+			String dropshipCancelUrl = "http://shipping.snapdeal.com/vendor/DROPSHIP/product-shipment/shippedData/fetch/?statusCode=CLD&dispatchCategoryId=0&startDate="+startDate+"&endDate="+endDate+"&statusColumn=cancelledOn";
 			logger.info("Drop Ship Cancel Url "+dropshipCancelUrl);
-			getMethod = new GetMethod(dropshipCancelUrl);
+			get = new HttpGet(dropshipCancelUrl);
 			try {
-				statusCode = newClient.executeMethod(getMethod);
+				response = client.execute(get);
 			} catch (Exception e) {
 				logger.error("Unable to get Http Response for snapdeal dropship cancelled orders", e);
+			}
 			try {
-				rd = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(getMethod.getResponseBody())));
+				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (Exception e) {
 				logger.error("Unable to read Http Response for snapdeal dropship cancelled orders", e);
+			}
 			try {
-				while ((line1 = rd.readLine()) != null) {
+				jsonDataObj = new JSONObject(rd.readLine());
-					if(line1.contains("jsonString")){
-						String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
-						logger.info("Response get from SnapDeal DropShip Cancelled Orders.. ");
-						jsonDataShip = new JSONArray(jsonString);
+				jsonDataShip = new JSONArray(jsonDataObj.get("jsonDataString").toString());
-						break;
-					}
-				}
 			} catch (Exception e) {
 				logger.error("Unable to extract Http Response for snapdeal dropship cancelled orders", e);
+			}
 			if(jsonDataShip!=null && jsonDataShip.length()>0){
 					JSONObject jsonObj = null;
 					try {
 						jsonObj = jsonDataShip.getJSONObject(i);
 						if(jsonObj!=null){
-							//System.out.println(jsonObj);
 							String subOrderCode =(String) jsonObj.get("suborderCode");
-							String referenceNumber =(String) jsonObj.get("referenceNumber");
+							String referenceNumber =(String) jsonObj.get("referenceCode");
-							//System.out.println("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
 							logger.info("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
 							List<String> cancelledOrdelList = new ArrayList<String>();
 							cancelledOrdelList.add(referenceNumber);
 							cancelledOrdelList.add(subOrderCode);
 							cancelledOrderDataList.add(cancelledOrdelList);
 					} catch (Exception e) {
 						logger.error("Unable to add cancelled order details for updation regarding snapdeal dropship orders", e);
+					}
+				}
+			}
-			getMethod.releaseConnection();
 			logger.info("Getting Information for OneShip Snapdeal Cancelled Orders");
-			String oneShipCancelUrl = "http://shipping.snapdeal.com/vendor/ONESHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=CANCELLATION_COMPLETE&statusColumn=cancelledOn&dispatchCategoryId=0&sCode=CANCELLATION_COMPLETE";
+			String oneShipCancelUrl = "http://shipping.snapdeal.com/vendor/ONESHIP/product-shipment/shippedData/fetch/?statusCode=CLD&dispatchCategoryId=0&startDate="+startDate+"&endDate="+endDate+"&statusColumn=cancelledOn";
 			logger.info("One Ship Cancel Url "+oneShipCancelUrl);
-			getMethod = new GetMethod(oneShipCancelUrl);
+			get = new HttpGet(oneShipCancelUrl);
 			try {
-				statusCode = newClient.executeMethod(getMethod);
+				response = client.execute(get);
 			} catch (Exception e) {
 				logger.error("Unable to get Http Response for snapdeal oneship cancelled orders", e);
+			}
 			try {
-				rd = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(getMethod.getResponseBody())));
+				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (Exception e) {
 				logger.error("Unable to read Http Response for snapdeal oneship cancelled orders", e);
+			}
 			try {
-				while ((line1 = rd.readLine()) != null) {
+				jsonDataObj = new JSONObject(rd.readLine());
-					if(line1.contains("jsonString")){
-						String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
-						logger.info("Response get from SnapDeal OneShip Cancelled Orders.. ");
-						jsonDataShip = new JSONArray(jsonString);
+				jsonDataShip = new JSONArray(jsonDataObj.get("jsonDataString").toString());
-						break;
-					}
-				}
 			} catch (Exception e) {
 				logger.error("Unable to extract Http Response for snapdeal oneship cancelled orders", e);
+			}
 			if(jsonDataShip!=null && jsonDataShip.length()>0){
 				for(int i=0; i< jsonDataShip.length(); i++){
 					JSONObject jsonObj = null;
 					try {
 						jsonObj = jsonDataShip.getJSONObject(i);
 						if(jsonObj!=null){
-							//System.out.println(jsonObj);
 							String subOrderCode =(String) jsonObj.get("suborderCode");
-							String referenceNumber =(String) jsonObj.get("referenceNumber");
+							String referenceNumber =(String) jsonObj.get("referenceCode");
-							//System.out.println("Snapdeal OneShip Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
 							logger.info("Snapdeal OneShip Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
 							List<String> cancelledOrdelList = new ArrayList<String>();
 							cancelledOrdelList.add(referenceNumber);
 							cancelledOrdelList.add(subOrderCode);
 							cancelledOrderDataList.add(cancelledOrdelList);
 						logger.error("Unable to add cancelled order details for updation regarding snapdeal oneship orders", e);
+					}
+				}
+			}
-			getMethod.releaseConnection();
-			start = end + 86400000l;
+			start = end + 86400000l;
+		}
 		if(deliveredOrderDataList!=null && deliveredOrderDataList.size()>0){
 			logger.info("Delivered Orders Size .. "+deliveredOrderDataList.size());
 			orderDataMap.put("Delivered", deliveredOrderDataList);
+		}
 		if(cancelledOrderDataList!=null && cancelledOrderDataList.size()>0){
 			logger.info("Cancelled Orders Size .. "+cancelledOrderDataList.size());
 			orderDataMap.put("Cancelled", cancelledOrderDataList);
+		}
 		if(orderDataMap!=null && orderDataMap.size()>0){
 			try{
 				new TransactionClient().getClient().updateSnapdealOrdersStatus(orderDataMap);
 			} catch(Exception e){
 				logger.error("Unable to update delivery information for snapdeal orders", e);

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/SnapdealOrderStatusReconciliation.java – Rev 9931 → 10178