运管处路单上传BUG修改

zlz
1 parent cf74bb31
Showing 1 changed file with 42 additions and 4 deletions
src/main/java/com/bsth/service/traffic/impl/YgcBasicDataServiceImpl.java
@@ -7,6 +7,7 @@ import org.apache.axiom.om.*;
 import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.client.Options;
 import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.rpc.client.RPCServiceClient;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -18,6 +19,7 @@ import org.w3c.dom.Document;
 import org.w3c.dom.NodeList;
 import javax.activation.DataHandler;
+import javax.xml.namespace.QName;
 import javax.xml.parsers.DocumentBuilder;
 import javax.xml.parsers.DocumentBuilderFactory;
 import java.io.*;
@@ -42,14 +44,17 @@ public class YgcBasicDataServiceImpl implements YgcBasicDataService{
     JdbcTemplate jdbcTemplate;
     private static String IP = "218.242.195.76:9091";
-    private static String targetEndpoint = "http://" + IP +"/ygc.TransManager.Basicdown?wsdl";
+    private static String downTargetEndpoint = "http://" + IP +"/ygc.TransManager.Basicdown?wsdl";
+    private static String upTargetEndpoint = "http://" + IP +"/ygc.TransManager.BasicUpload?wsdl";
     private static String namespace = "http://service.shygc.com";
     private static String userName = "admin";
     private static String passWord = "000000";
-    private static EndpointReference targetEPR;
+    private static EndpointReference downTargetEPR;
+    private static EndpointReference upTargetEPR;
     {
         try {
-            targetEPR = new EndpointReference(targetEndpoint);
+            downTargetEPR = new EndpointReference(downTargetEndpoint);
+            upTargetEPR = new EndpointReference(upTargetEndpoint);
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -102,7 +107,7 @@ public class YgcBasicDataServiceImpl implements YgcBasicDataService{
             ServiceClient sender = new ServiceClient();
             Options options = sender.getOptions();
             options.setProperty("SO_TIMEOUT", Integer.valueOf(1800000));
-            options.setTo(targetEPR);
+            options.setTo(downTargetEPR);
             sender.setOptions(options);
             System.out.println("The data in method download: " + data);
             data.build();
@@ -280,4 +285,37 @@ public class YgcBasicDataServiceImpl implements YgcBasicDataService{
         flag = true;
         return flag;
     }
+
+    /**
+     * 调用方法
+     * @param methodName 方法名
+     * @param param 参数
+     * @return
+     */
+    public String invokeMethod(String methodName,String param){
+        String result = null;
+        try {
+            // 获得客户端
+            RPCServiceClient serviceClient = new RPCServiceClient();
+            // 可以在该对象中设置服务端的验证信息
+            Options options = serviceClient.getOptions();
+            options.setTo(upTargetEPR);
+            // 在创建QName对象时，QName类的构造方法的第一个参数表示WSDL文件的命名空间名，也就是<wsdl:definitions>元素的targetNamespace属性值
+            QName opAddEntry = new QName(namespace,methodName);
+            // 参数，如果有多个，继续往后面增加即可，不用指定参数的名称
+            Object[] opAddEntryArgs = new Object[] {param };
+            // 返回参数类型，这个和axis1有点区别
+            // invokeBlocking方法有三个参数，其中第一个参数的类型是QName对象，表示要调用的方法名；
+            // 第二个参数表示要调用的WebService方法的参数值，参数类型为Object[]；
+            // 第三个参数表示WebService方法的返回值类型的Class对象，参数类型为Class[]。
+            // 当方法没有参数时，invokeBlocking方法的第二个参数值不能是null，而要使用new Object[]{}
+            // 如果被调用的WebService方法没有返回值，应使用RPCServiceClient类的invokeRobust方法，
+            // 该方法只有两个参数，它们的含义与invokeBlocking方法的前两个参数的含义相同
+            Class[] classes = new Class[] { String.class };
+            result = serviceClient.invokeBlocking(opAddEntry,opAddEntryArgs, classes)[0].toString();
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+        return result;
+    }
 }