Subversion Repositories SmartDukaan

package in.shop2020.serving.services;

import in.shop2020.config.ConfigException;

import in.shop2020.logistics.ShipmentUpdate;

import in.shop2020.thrift.clients.LogisticsServiceClient;

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

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.xml.xpath.XPath;

import javax.xml.xpath.XPathConstants;

import javax.xml.xpath.XPathExpressionException;

import javax.xml.xpath.XPathFactory;

import org.apache.thrift.TException;

import org.w3c.dom.Node;

import org.w3c.dom.NodeList;

import org.xml.sax.InputSource;

public class AramaxTrackingService {

	//public static String ARAMAX_URL = "http://www.aramex.com/track_xml.asp?ShipmentNumber=";

	private static String ARAMAX_URL = "file:///home/rajveer/shop2020/logistics/AWB_Track.xml";

	static{

		try {

			ARAMAX_URL = ConfigClient.getClient().get(ARAMAX_URL);

		} catch (ConfigException e) {

			ARAMAX_URL = "http://www.aramex.com/track_xml.asp?ShipmentNumber=";

			e.printStackTrace();

		}

		ARAMAX_URL = "file:///home/rajveer/shop2020/logistics/AWB_Track.xml";

	}

	/*

	private static AramaxTrackingService trackingService;

	static{

		synchronized(AramaxTrackingService.class){

			trackingService = new AramaxTrackingService();

		}

	}

	 */

	/*

	public String getAwbNumber() {

		return awbNumber;

	}

	public void setAwbNumber(String awbNumber) {

		this.awbNumber = awbNumber;

	}

	public InputSource getInputSource() {

		return inputSource;

	}

	public void setInputSource(InputSource inputSource) {

		this.inputSource = inputSource;

	}

	*/

	public static void getShipmentUpdates(String awbNumber){

			String expression = "/HAWBs/HAWBDetails/HAWBHistory/HAWBUpdate";

			//String uri = ARAMAX_URL + awbNumber; 

			String uri = ARAMAX_URL;

			InputSource inputSource = new InputSource(uri);

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

			NodeList nodes = null;

			try {

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

			} 

			catch(XPathExpressionException xpee) {

				return ;

			}

			for(int i=nodes.getLength()-1; i>=0; i--) {

				Node node = nodes.item(i);

				NodeList childNodes = node.getChildNodes();

				ShipmentUpdate update = new ShipmentUpdate();

				update.setDescription(childNodes.item(14).getTextContent());

				update.setPin(childNodes.item(1).getTextContent());

				update.setTimestamp(10);

			try {

				LogisticsServiceClient lsc = new LogisticsServiceClient();

				lsc.getClient().updateShipmentStatus(awbNumber, update);

			} catch (TException e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}catch (Exception e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}

			}	

	}

	public static List<Map<String, String>> getUpdates(String awbNumber){

		//String uri = ARAMAX_URL + awbNumber;

		String uri = ARAMAX_URL;

		InputSource inputSource = new InputSource(uri);

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

		String expression = "/HAWBs/HAWBDetails/HAWBHistory/HAWBUpdate";

		NodeList nodes = null;

		try {

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

		} 

		catch(XPathExpressionException xpee) {

			return null;

		}

		List<Map<String, String>> updates = new ArrayList<Map<String,String>>();

		System.out.println("Action date		"+  "Update City 	" + "Tracki Code Desc" );

		for(int i=nodes.getLength()-1; i>=0; i--) {

			Node node = nodes.item(i);

			NodeList childNodes = node.getChildNodes();

			/*

			System.out.println("Action date is :		" + childNodes.item(0).getTextContent());

			System.out.println("PIN number  is :		" + childNodes.item(1).getTextContent());

			System.out.println("Entry Date  is :		" + childNodes.item(3).getTextContent());

			System.out.println("Update City is :		" + childNodes.item(6).getTextContent());

			System.out.println("Tracking Code Desc is  :" + childNodes.item(7).getTextContent());

			System.out.println("UpdateLocation		is :" + childNodes.item(8).getTextContent());

			System.out.println("UpdateCountry		is :" + childNodes.item(11).getTextContent());

			System.out.println("Tracking Condition	is :" + childNodes.item(12).getTextContent());

			System.out.println("Customer Desc		is :" + childNodes.item(14).getTextContent());

			System.out.println("\n\n\n\n ");

			*/

			System.out.println(childNodes.item(0).getTextContent() +"\t\t"+childNodes.item(6).getTextContent()+"\t\t"

					+childNodes.item(7).getTextContent());

			Map<String,String> update = new HashMap<String,String>();

			String dateString =  childNodes.item(0).getTextContent();

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

			String date = tokens[0];

			String time = tokens[1] + " " + tokens[2];

			String city = childNodes.item(6).getTextContent();

			String status = childNodes.item(7).getTextContent();

			System.out.println("date:"+date+":time:" + time +":city:"+city+":status:"+status);

			update.put("date", date);

			update.put("time", time);

			update.put("city", city);

			update.put("status", status);

			updates.add(update);

		}

		System.out.println("nodes length " +  nodes.getLength() );

		return updates;

		//return nodes.toString(); 

	}

	/*

	public String getOriginCity(){

		String expression = "/HAWBs/HAWBDetails/HAWBOriginEntity";

		NodeList nodes = null;

		try {

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

		} 

		catch(XPathExpressionException xpee) {

			return null;

		}

		System.out.println("nodes length " +  nodes.getLength() + nodes.item(0).getTextContent());

		return nodes.toString(); 

	}

	*/

	public static void main(String[] args){

		System.out.println("Aramax number is " + "6149183666");

	}

}