/*根據wsdl定位動態調用其提供的服務 */
package com.gpdi.www.ws.client;

import org.apache.axis.Constants;
import org.apache.axis.encoding.ser.SimpleDeserializer;
import org.apache.axis.wsdl.gen.Parser;
import org.apache.axis.wsdl.symbolTable.*;

import javax.swing.JOptionPane;
import javax.wsdl.*;
import javax.wsdl.extensions.soap.SOAPAddress;
import javax.xml.namespace.QName;
import javax.xml.rpc.Call;
import javax.xml.rpc.encoding.Deserializer;
import javax.xml.rpc.encoding.DeserializerFactory;

import java.util.*;

// Web Service Dynamic Invoker
public class DynamicInvoker
{
	private Parser wsdlParser = null;
	private Map services = null;
    //構造函數
	public DynamicInvoker(String wsdlURL) throws Exception
	{
		//構造一個wsdl分析器
		wsdlParser = new Parser();
		//分析wsdl
		wsdlParser.run(wsdlURL);
		//根據wsdl得到此wsdl提供的服務集合.
		services = enumSymTabEntry(ServiceEntry.class);
	}

	public Map invoke(String serviceName,
					  String portName,
					  String operationName,
					  Vector parameterValues) throws Exception
	{
		//參數的集合.
		Vector inputs = new Vector();
		String returnName = null;
        //根據服務的鍵取得值.
		ServiceEntry serviceEntry = (ServiceEntry) services.get(serviceName);
		//得到wsdl提供的服務對象.
		Service service = serviceEntry.getService();
		//a Service will be created with a WSDL document and along with a serviceName 
		//you can then ask for a Call object that will allow you to invoke a Web Service. 
		org.apache.axis.client.Service clientService = new
			org.apache.axis.client.Service(wsdlParser, service.getQName());

		Call call = clientService.createCall(QName.valueOf(portName),
											 QName.valueOf(operationName));
		//設置超時時間為一分鐘
		( (org.apache.axis.client.Call) call).setTimeout(new Integer(60 * 1000));

		BindingEntry bindingEntry = getBindingEntry(serviceName, portName);
		//根據方法名得到某一方法.
		Operation o = getOperation(bindingEntry, operationName);
		//得到某一方法的參數
		Parameters parameters = bindingEntry.getParameters(o);

		if (parameters.returnParam != null)
		{
			QName returnType = org.apache.axis.wsdl.toJava.Utils.
				getXSIType(parameters.returnParam);
			QName returnQName = parameters.returnParam.getQName();
			returnName = returnQName.getLocalPart();
		}

		int size = parameters.list.size();
		//遍歷參數集合.再根據參數的類型(輸入、輸出、輸入輸出)分別構造參數對象再加到集合里.
		for (int i = 0; i < size; i++)
		{
			Parameter p = (Parameter) parameters.list.get(i);
			switch (p.getMode())
			{
			case Parameter.IN:
				inputs.add(getParamData( (org.apache.axis.client.Call) call,
										p,
										(String) parameterValues.elementAt(i)));
				break;
			case Parameter.OUT:
				break;
			case Parameter.INOUT:
				inputs.add(getParamData( (org.apache.axis.client.Call) call,
										p,
										(String) parameterValues.elementAt(i)));
				break;
			}
		}

		Object ret = call.invoke(inputs.toArray());
		Map outputs = call.getOutputParams();
		HashMap map = new HashMap();
		if (ret != null && returnName != null)
		{
			map.put(returnName, ret);
		}
		//當輸出參數不為空時，則遍歷輸出參數的集合.
		if (outputs != null)
		{
			for (Iterator i = outputs.keySet().iterator(); i.hasNext(); )
			{
				Object obj = i.next();
				String name;
				Object value;
				//如果輸出參數為String類型則直接轉換。
				if (obj.getClass().getName().equals("java.lang.String"))
				{
					name = (String) obj;
				}
				else
				{
					name = ( (QName) obj).getLocalPart();
				}
				value = outputs.get(obj);
				map.put(name, value);
			}
		}
		return map;
	}

	public Vector enumServiceNames()
	{
		Vector v = new Vector();
		Iterator i = services.keySet().iterator();
		while (i.hasNext())
		{
			String s = (String) i.next();
			v.addElement(s);
		}
		return v;
	}

	public Vector enumPortNames(String serviceName)
	{
		Vector v = new Vector();
		ServiceEntry serviceEntry = (ServiceEntry) services.get(serviceName);
		Map ports = serviceEntry.getService().getPorts();
		Iterator i = ports.keySet().iterator();
		while (i.hasNext())
		{
			String s = (String) i.next();
			v.addElement(s);
		}
		return v;
	}

	public Vector enumOperationNames(String serviceName, String portName)
	{
		Vector v = new Vector();
		BindingEntry entry = getBindingEntry(serviceName, portName);
		Set operations = entry.getOperations();
		Iterator i = operations.iterator();
		while (i.hasNext())
		{
			Operation o = (Operation) i.next();
			String s = o.getName();
			v.addElement(s);
		}
		return v;
	}

	public Parameters enumParameters(String serviceName, String portName,
									 String operationName)
	{
		BindingEntry entry = getBindingEntry(serviceName, portName);
		Operation o = getOperation(entry, operationName);
		Parameters parameters = entry.getParameters(o);
		return parameters;
	}

	public String getParameterModeString(Parameter p)
	{
		String ret = null;
		switch (p.getMode())
		{
		case Parameter.IN:
			ret = "[IN]";
			break;
		case Parameter.INOUT:
			ret = "[IN, OUT]";
			break;
		case Parameter.OUT:
			ret = "[OUT]";
			break;
		}
		return ret;
	}

	private BindingEntry getBindingEntry(String serviceName, String portName)
	{
		//得到指定的web服務.從Map里根據主鍵找值.
		ServiceEntry serviceEntry = (ServiceEntry) services.get(serviceName);
		//根據web服務得到端口.
		Port port = serviceEntry.getService().getPort(portName);
		//綁定端口.
		Binding binding = port.getBinding();
		SymbolTable table = wsdlParser.getSymbolTable();
		return table.getBindingEntry(binding.getQName());
	}
    //根據方法名從端口綁定的服務的集合里得到某一個方法對象.
	private Operation getOperation(BindingEntry entry, String operationName)
	{
		Set operations = entry.getOperations();
		Iterator i = operations.iterator();
		while (i.hasNext())
		{
			Operation o = (Operation) i.next();
			if (operationName.equals(o.getName()))
			{
				return o;
			}
		}
		return null;
	}

	// return Map of <QName.getLocalPart, SymTabEntry>
	private Map enumSymTabEntry(Class cls)
	{
		//用來返回的Hashmap
		HashMap ret = new HashMap();
		//根據wsdl分析器分析出來的
		HashMap map = wsdlParser.getSymbolTable().getHashMap();
		//HashMap的方法entrySet()將HashMap里一行記錄(鍵值)變成一個對象(Map.Entry)放到Set集合里去.
		Iterator iterator = map.entrySet().iterator();
		while (iterator.hasNext())
		{
			//HashMap根據值取主鍵
			Map.Entry entry = (Map.Entry) iterator.next();
			//取鍵
			QName key = (QName) entry.getKey();
			//取值
			Vector v = (Vector) entry.getValue();
			//得到SymTabEntry的個數.
			int size = v.size();
			for (int i = 0; i < size; ++i)
			{
				SymTabEntry symTabEntry = (SymTabEntry) v.elementAt(i);
				//判斷傳進來的對象同wsdl分析器分析出來的對象是否為同一類型對象.如是則將其加入到返回的HashMap里去.
				if (cls.isInstance(symTabEntry))
				{
					ret.put(key.getLocalPart(), symTabEntry);
				}
			}
		}
		return ret;
	}
    //打包參數對象
	private Object getParamData(org.apache.axis.client.Call c, Parameter p,
								String arg) throws Exception
	{
		// Get the QName representing the parameter type
		QName paramType = org.apache.axis.wsdl.toJava.Utils.getXSIType(p);

		TypeEntry type = p.getType();
		//如果參數的類型為基本的數據類型就序列化它。否則拋出不能轉換的巽常!
		if (type instanceof BaseType && ( (BaseType) type).isBaseType())
		{
			DeserializerFactory factory = c.getTypeMapping().getDeserializer(
				paramType);
			Deserializer deserializer = factory.getDeserializerAs(Constants.
				AXIS_SAX);
			if (deserializer instanceof SimpleDeserializer)
			{
				return ( (SimpleDeserializer) deserializer).makeValue(arg);
			}
		}
		throw new RuntimeException("not know how to convert '" + arg
								   + "' into " + c);
	}
}