sagstopcycloc.java

中国移动定位引擎的客户端

package ffcs.lbp.SagClient;

import java.util.Iterator;

import cn.com.chinatelecom.wsdl.ctcc.terminal_location.notification_manager.v2_2.service.TerminalLocationNotificationManager;
import cn.com.chinatelecom.wsdl.ctcc.terminal_location.notification_manager.v2_2.service.TerminalLocationNotificationManagerServiceClient;
import cn.com.chinatelecom.wsdl.ctcc.terminal_location.notification_manager.v2_2.service.TerminalLocationNotificationManagerServiceImpl;
import ffcs.lbp.dao.RouteDAO;
import ffcs.lbp.dao.SentRequest;
import ffcs.lbp.le.message.StopCycLoc;
import ffcs.lbp.le.message.tlv.TLVTable;
import ffcs.logging.Log;
import ffcs.logging.LogFactory;

public class SagStopCycLoc {
	private static Log log = LogFactory.getLog(SagStopCycLoc.class);
	private TLVTable IsdnRange;
	public SagStopCycLoc(StopCycLoc cyc_loc_stop){
		IsdnRange=cyc_loc_stop.getIsdnRange();
	}
	/**
	 * 向isag发出webservice请求
	 *
	 */

	@SuppressWarnings("unchecked")
	public void bulidSagStopCycLoc(){
		 Iterator<String>   range_it  = IsdnRange.values().iterator();
		  TerminalLocationNotificationManagerServiceClient service = new TerminalLocationNotificationManagerServiceClient();
	      TerminalLocationNotificationManager impl;
		 if(range_it.hasNext()){
			 
			 //通过号段，查出Correlator
			 RouteDAO rtdao=new RouteDAO();
			 SentRequest sent_request= rtdao.delSentRequest(range_it.next());
			 if(sent_request!=null){
			//	    	调用WebServiceClient，
	 	try{	 
	 		service.getTerminalLocationNotificationManagerLocalEndpoint(sent_request.getTarget_url());
			impl=new TerminalLocationNotificationManagerServiceImpl();
	    	impl=service.getTerminalLocationNotificationManager(sent_request.getTarget_url());
			impl.endNotification(sent_request.getCorrelator());
	 	}  catch ( Exception e){
     	   log.error("调用ISAG的周期性定位出错"+e);
	 		 }
			 }
		 }
	}
}