Subversion Repositories SmartDukaan

package in.shop2020.serving.services;

import in.shop2020.config.ConfigException;

import in.shop2020.serving.model.ShipmentUpdate;

import in.shop2020.thrift.clients.config.ConfigClient;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.StringReader;

import java.util.ArrayList;

import java.util.List;

import javax.xml.xpath.XPath;

import javax.xml.xpath.XPathConstants;

import javax.xml.xpath.XPathExpressionException;

import javax.xml.xpath.XPathFactory;

import org.apache.http.HttpResponse;

import org.apache.http.client.HttpClient;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.log4j.Logger;

import org.w3c.dom.Element;

import org.w3c.dom.NodeList;

import org.xml.sax.InputSource;

public class DelhiveryTrackingService {

    //public static String Delhivery_URL = "http://track.delhivery.com/api/packages/xml/?token=bda066415b6b56698559e80b1a8345980882c90f&";

    private static Logger log = Logger.getLogger(Class.class);

    private static String Delhivery_URL;

    static{

        try {

        	Delhivery_URL = ConfigClient.getClient().get("Delhivery_update_url");

        } catch (ConfigException e) {

            log.error("Unable to get the tracking url from the config service", e);

        }

    }

    public List<ShipmentUpdate> getUpdates(String awbNumber){

    	String uri = Delhivery_URL + "waybill=" + awbNumber;

    	log.info("Delhivery Update URL: " + uri);

    	try {

    		HttpClient client = new DefaultHttpClient();

    		HttpGet get_new = new HttpGet(uri);

    		HttpResponse response = client.execute(get_new);

    		BufferedReader rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

    		String line = "";

    		int i=1;

    		List<ShipmentUpdate> updates = new ArrayList<ShipmentUpdate>();

    		while ((line = rd.readLine()) != null) {

    			System.out.println(line);

    			if(i==1){

    				i++;

    				continue;

    			}

    			InputSource inputSource = new InputSource(new StringReader(line));

    			XPath xpath = XPathFactory.newInstance().newXPath();

    			String expression = "/ShipmentData/Shipment/Scans/ScanDetail";

    			NodeList nodes = null;

    			nodes = (NodeList) xpath.evaluate(expression, inputSource,  XPathConstants.NODESET);

    			System.out.println("Action date\t\t\tUpdate City\t\t\tTracki Code Desc" );

    			for(int j=0; j<=nodes.getLength()-1; j++) {

    				Element hawbUpdate = (Element) nodes.item(j);

    				ShipmentUpdate update = new ShipmentUpdate();

    				String dateString = getElementTextContent(hawbUpdate, "ScanDateTime");

    				String[] tokens = dateString.split("T");

    				update.date = tokens[0];

    				String[] timetokens = tokens[1].split("\\.");

    				update.time = timetokens[0];

    				update.city = getElementTextContent(hawbUpdate, "ScannedLocation");

    				update.description = getElementTextContent(hawbUpdate, "Scan") + " - " + getElementTextContent(hawbUpdate, "Instructions");         

    				updates.add(update);

    			}

    		}

    		return updates;

    	} catch(Exception xpee) {

    		xpee.printStackTrace();

    		return null;

    	}

    }

    private String getElementTextContent(Element element, String tagName){

        return element.getElementsByTagName(tagName).item(0).getTextContent();

    }

    public static void main(String[] args){

        System.out.println("Delhivery number is " + "13410934216");

        DelhiveryTrackingService service = new DelhiveryTrackingService();

        List<ShipmentUpdate> updates;

		try {

			updates = service.getUpdates("13410934216");

			for(ShipmentUpdate update: updates){

	            System.out.println(update.toString());

	        }

		} catch (Exception e) {

			e.printStackTrace();

		}

    }

}