package client;
	import javax.xml.namespace.QName;
	import org.apache.axis2.addressing.EndpointReference;
	import org.apache.axis2.client.Options;
	import org.apache.axis2.rpc.client.RPCServiceClient;
	public class TestAms {
		public static void main(String[] args) throws Exception  
	    {
			AmsStub1 stub=new AmsStub1();
			AmsStub1.SetAlarmServerCfgMsg setmsg= new AmsStub1.SetAlarmServerCfgMsg();
			//ServiceStub.SetAlarmServerCfgMsgResponse re=new ServiceStub.SetAlarmServerCfgMsgResponse();
			 String str="{\"name\":\"demo\",\"id\":21,\"code\":\"161021021040288690\"}";//對(duì)應(yīng)的參數(shù)
			setmsg.setPAlarmCfgMsg(str); //設(shè)置參數(shù)
 
			String re=stub.setAlarmServerCfgMsg(setmsg).getResponse(); //調(diào)用并獲取返回值
			System.out.println(re);
	    }
	}	

public String getOnline(String url){
		int errCode=0;
		JSONObject resultJson=new JSONObject();
		String result="";
		Service service = new Service();
		Call call;
		try {
			call=(Call) service.createCall();
			QName opAddEntry = new QName("urn:demo", "GetOnlineInfo"); //設(shè)置命名空間和需要調(diào)用的方法名
			call.setTargetEndpointAddress(url); //設(shè)置請(qǐng)求路徑
			call.setOperationName("GetNcgOnlineInfo"); //調(diào)用的方法名
			call.setTimeout(Integer.valueOf(2000));		//設(shè)置請(qǐng)求超時(shí)    		
			call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//設(shè)置返回類(lèi)型 
			result= (String) call.invoke(opAddEntry,new Object[]{});
			
		} catch (ServiceException e) {
			// TODO Auto-generated catch block
			System.out.println("查詢?cè)诰€狀態(tài)1:"+e.getMessage());
			errCode=1;
		} catch (RemoteException e) {
			// TODO Auto-generated catch block
                        System.out.println("查詢?cè)诰€狀態(tài)2:"+e.getMessage());
			errCode=2;
		}
		resultJson.put("errCode", errCode);
	    resultJson.put("data", result);
 
		return resultJson.toString();
	}

public String ncgConnection(String url,String method){
		 URL wsUrl;
	        int errCode=0;
			JSONObject resultJson=new JSONObject();
			String result="";
			try {
				wsUrl = new URL(url+"/"+method);
				 HttpURLConnection conn = (HttpURLConnection) wsUrl.openConnection();
			        
			        conn.setDoInput(true);
			        conn.setDoOutput(true);
			        conn.setRequestMethod("POST");
			        conn.setRequestProperty("Content-Type", "text/xml;charset=UTF-8");
			        conn.setConnectTimeout(2000);
			        conn.setReadTimeout(2000);
			        OutputStream os = conn.getOutputStream();
			        //請(qǐng)求體
			        
			        //<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"><soapenv:Body><ns1:DeleteCascadeFromCms soapenv:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:ns1="urn:ncg"><ncg-code-list xsi:type="xsd:string">["11241525"]</ncg-code-list></ns1:DeleteCascadeFromCms></soapenv:Body></soapenv:Envelope>
 
			        String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
			        		+ "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"><soapenv:Body><ns1:"+method+" soapenv:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:ns1=\"urn:ncg\"/></soapenv:Body></soapenv:Envelope>";
			        os.write(soap.getBytes());
			        InputStream is = conn.getInputStream();
			        
			        byte[] b = new byte[1024];
			        int len = 0;
			        String s = "";
			        while((len = is.read(b)) != -1){
			            String ss = new String(b,0,len,"UTF-8");
			            s += ss;
			        }
                                 result=s.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0];
			        
			        is.close();
			        os.close();
			        conn.disconnect();
			} catch (MalformedURLException e) {
				// TODO Auto-generated catch block
				System.out.println("通訊模塊1:"+e.getMessage());
				errCode=1;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				System.out.println("通訊模塊2:"+e.getMessage());
				errCode=2;
			}
			resultJson.put("errCode", errCode);
			resultJson.put("data", result);
	     
	        return resultJson.toString();
	}

public void demo(String url){
		
		HttpClient httpClient=new HttpClient();
		PostMethod postMethod=new PostMethod();
		postMethod.setPath(url+"/ncg.wsdl"); //路徑和wsdl名
		
		String soap = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" "
        		+ "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"><soapenv:Body><ns1:GetNcgOnlineInfo soapenv:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:ns1=\"urn:ncg\"/></soapenv:Body></soapenv:Envelope>";
       
		try {
			byte[] b=soap.getBytes("utf-8");
			
			InputStream is = new ByteArrayInputStream(b, 0, b.length);
			RequestEntity re = new InputStreamRequestEntity(is, b.length,
			                 "application/soap+xml; charset=utf-8");
			postMethod.setRequestEntity(re);
			int statusCode = httpClient.executeMethod(postMethod);
			
			String soapResponseData = postMethod.getResponseBodyAsString();
			
			postMethod.releaseConnection();
                        //解析
                        System.out.println(soapResponseData.split("<response xsi:type=\"xsd:string\">")[1].split("</response>")[0]);
		} catch (UnsupportedEncodingException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		} catch (HttpException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}