gongjiale
/
gangkou
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: gongjiale:2642714bb440c5bae8da059ec79d5ec0986962d9
Branches Tags
gongjiale:main
...
compare: gongjiale:703065601963da233c2901bce86c546589da6978
Branches Tags
gongjiale:main

2 Commits
2642714bb4 ... 7030656019

Author SHA1 Message Date
biexiande 7030656019 Merge remote-tracking branch 'origin/main' 2024-11-21 10:24:03 +08:00
biexiande 7f54a7aae8 短信发送 工具类 2024-11-21 10:23:47 +08:00
4 changed files with 296 additions and 240 deletions
Show Stats Expand all files Collapse all files

40
RuoYi-Vue-Oracle/pom.xml
View File

@ -200,21 +200,32 @@
</dependency> </dependency>
<dependency> <!-- <dependency>-->
<groupId>org.apache.axis</groupId> <!-- <groupId>org.apache.axis</groupId>-->
<artifactId>axis</artifactId> <!-- <artifactId>axis</artifactId>-->
<version>1.4</version> <!-- <version>1.4</version>-->
</dependency> <!-- </dependency>-->
<dependency> <!-- <dependency>-->
<groupId>org.apache.axis</groupId> <!-- <groupId>org.apache.axis</groupId>-->
<artifactId>axis-jaxrpc</artifactId> <!-- <artifactId>axis-jaxrpc</artifactId>-->
<version>1.4</version> <!-- <version>1.4</version>-->
</dependency> <!-- </dependency>-->
<!-- <dependency>--> <!-- <dependency>-->
<!-- <groupId>com.roufid.tutorials</groupId>--> <!-- <groupId>com.roufid.tutorials</groupId>-->
<!-- <artifactId>example-app</artifactId>--> <!-- <artifactId>example-app</artifactId>-->
<!-- <version>1.0</version>--> <!-- <version>1.0</version>-->
<!-- </dependency>--> <!-- </dependency>-->
<!--cxf-->
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
<version>3.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
<version>3.2.1</version>
</dependency>
<dependency> <dependency>
<groupId>com.banboocloud.Codec </groupId> <groupId>com.banboocloud.Codec </groupId>
@ -331,6 +342,15 @@
<version>${velocity.version}</version> <version>${velocity.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.banboocloud</groupId>
<artifactId>banboocloudCodec</artifactId>
<version>1.0</version>
<scope>system</scope>
<systemPath>${project.basedir}/src/main/java/com/ruoyi/project/system/lib/banboocloud_Codec-0.0.jar</systemPath>
</dependency>
<!-- 定时任务 --> <!-- 定时任务 -->
<dependency> <dependency>
<groupId>org.quartz-scheduler</groupId> <groupId>org.quartz-scheduler</groupId>

93
RuoYi-Vue-Oracle/src/main/java/com/ruoyi/common/wsdl/WebServiceUtil.java
View File

@ -1,6 +1,10 @@
package com.ruoyi.common.wsdl; package com.ruoyi.common.wsdl;
import org.apache.axis.client.Call; import org.apache.cxf.endpoint.Client;
import org.apache.cxf.endpoint.Endpoint;
import org.apache.cxf.endpoint.dynamic.DynamicClientFactory;
import org.apache.cxf.service.model.BindingInfo;
import org.apache.cxf.service.model.BindingOperationInfo;
import org.springframework.util.*; import org.springframework.util.*;
import javax.xml.namespace.QName; import javax.xml.namespace.QName;
import java.util.ArrayList; import java.util.ArrayList;
@ -10,33 +14,33 @@ import java.util.Map;
public class WebServiceUtil { public class WebServiceUtil {
public static String sendMessage(Collection<String> phones, String msg) throws Exception { // public static String sendMessage(Collection<String> phones, String msg) throws Exception {
//
System.out.println("开始调用webservice"); // System.out.println("开始调用webservice");
List<Map<String, Object>> storeItemList_ = new ArrayList<>(); // List<Map<String, Object>> storeItemList_ = new ArrayList<>();
String endpoint = "http://10.171.19.193:8080/dxpt/ws/shortMessageWs?wsdl"; // String endpoint = "http://10.171.19.193:8080/dxpt/ws/shortMessageWs?wsdl";
String soapaction = "http://service.cxf.com/"; // String soapaction = "http://service.cxf.com/";
String method = "returnMassages"; // String method = "returnMassages";
org.apache.axis.client.Service service = new org.apache.axis.client.Service(); // org.apache.axis.client.Service service = new org.apache.axis.client.Service();
Call call = (Call) service.createCall();// 通过service创建call对象 // Call call = (Call) service.createCall();// 通过service创建call对象
call.setTargetEndpointAddress(endpoint); // call.setTargetEndpointAddress(endpoint);
call.setOperationName(new QName(soapaction, method)); // call.setOperationName(new QName(soapaction, method));
call.addParameter(new QName(soapaction, "phone"), // call.addParameter(new QName(soapaction, "phone"),
org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN); // org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
call.addParameter(new QName(soapaction, "msg"), // call.addParameter(new QName(soapaction, "msg"),
org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN); // org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
call.addParameter(new QName(soapaction, "Dwdm"), // call.addParameter(new QName(soapaction, "Dwdm"),
org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN); // org.apache.axis.encoding.XMLType.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
//
call.setUseSOAPAction(true); // call.setUseSOAPAction(true);
//call.setReturnType(org.apache.axis.encoding.XMLType.SOAP_STRING); //返回参数的类型 // //call.setReturnType(org.apache.axis.encoding.XMLType.SOAP_STRING); //返回参数的类型
call.setReturnType(org.apache.axis.encoding.XMLType.SOAP_VECTOR); // call.setReturnType(org.apache.axis.encoding.XMLType.SOAP_VECTOR);
//call.setReturnType(XMLType.XSD_STRING); // //call.setReturnType(XMLType.XSD_STRING);
call.setSOAPActionURI(soapaction + method); // call.setSOAPActionURI(soapaction + method);
java.util.Vector xmlStr = (java.util.Vector) call.invoke(new Object[]{StringUtils.collectionToCommaDelimitedString(phones), msg, "SGJT-山港集团"}); // java.util.Vector xmlStr = (java.util.Vector) call.invoke(new Object[]{StringUtils.collectionToCommaDelimitedString(phones), msg, "SGJT-山港集团"});
System.out.println("webservice response content :" + StringUtils.collectionToCommaDelimitedString(xmlStr)); // System.out.println("webservice response content :" + StringUtils.collectionToCommaDelimitedString(xmlStr));
return StringUtils.collectionToCommaDelimitedString(xmlStr); // return StringUtils.collectionToCommaDelimitedString(xmlStr);
} // }
// public static void main(String[] args) { // public static void main(String[] args) {
// Collection<String> objects = new ArrayList<>(); // Collection<String> objects = new ArrayList<>();
@ -47,4 +51,37 @@ public class WebServiceUtil {
// e.printStackTrace(); // e.printStackTrace();
// } // }
// } // }
public static String sendMessage(List<String> phones, String msg) throws Exception {
//
String result ;
try {
DynamicClientFactory dynamicClientFactory = DynamicClientFactory.newInstance();
Client client = dynamicClientFactory.createClient("http://10.171.19.193:8080/dxpt/ws/shortMessageWs?wsdl");
Endpoint endpoint = client.getEndpoint();
QName opName = new QName(endpoint.getService().getName().getNamespaceURI(), "returnMassages");
BindingInfo bindingInfo = endpoint.getEndpointInfo().getBinding();
if (bindingInfo.getOperation(opName) == null) {
for (BindingOperationInfo operationInfo : bindingInfo.getOperations()) {
if ("returnMassages".equals(operationInfo.getName().getLocalPart())) {
opName = operationInfo.getName();
break;}}}
Object[] res = client.invoke(opName, StringUtils.collectionToCommaDelimitedString(phones),msg,"SGJT");
//System.out.println();
result = String.valueOf(res[0]);
} catch (Exception e) {
throw new RuntimeException(e);
}
return result;
}
} }

399
RuoYi-Vue-Oracle/src/main/java/com/ruoyi/common/wsdl/WebServiceUtils.java
View File

@ -1,200 +1,199 @@
package com.ruoyi.common.wsdl; //package com.ruoyi.common.wsdl;
//
//
import ch.qos.logback.core.net.server.Client; //import ch.qos.logback.core.net.server.Client;
import com.alibaba.fastjson2.JSONObject; //import com.alibaba.fastjson2.JSONObject;
import org.apache.axis.client.Call; //import org.apache.axis.client.Call;
import org.apache.axis.client.Service; //import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType; //import org.apache.axis.encoding.XMLType;
import org.apache.axis.encoding.ser.BeanDeserializerFactory; //import org.apache.axis.encoding.ser.BeanDeserializerFactory;
import org.apache.axis.encoding.ser.BeanSerializerFactory; //import org.apache.axis.encoding.ser.BeanSerializerFactory;
import org.apache.axis.message.SOAPHeaderElement; //import org.apache.axis.message.SOAPHeaderElement;
import org.apache.axis.types.Schema; //import org.apache.axis.types.Schema;
import org.apache.commons.collections4.MapUtils; //import org.apache.commons.collections4.MapUtils;
import org.apache.commons.compress.utils.Lists; //import org.apache.commons.compress.utils.Lists;
//
import javax.xml.namespace.QName; //import javax.xml.namespace.QName;
import javax.xml.rpc.ParameterMode; //import java.util.HashMap;
import java.util.HashMap; //import java.util.List;
import java.util.List; //import java.util.Map;
import java.util.Map; //import java.util.Set;
import java.util.Set; //
//
//
//public class WebServiceUtils {
public class WebServiceUtils { // // 接口调用地址
// 接口调用地址 // private static String url = "http://10.171.19.193:8080/dxpt/ws/shortMessageWs?wsdl";
private static String url = "http://10.171.19.193:8080/dxpt/ws/shortMessageWs?wsdl"; // // 命名空间
// 命名空间 // private static String namespace = "http://service.cxf.com/";
private static String namespace = "http://service.cxf.com/"; //
//
// public static void main(String[] args) {
public static void main(String[] args) { // HashMap<String, String> map = new HashMap<>();
HashMap<String, String> map = new HashMap<>(); // map.put("phone","18437762352");
map.put("phone","18437762352"); // map.put("msg","ceshi");
map.put("msg","ceshi"); // map.put("Dwdm","SGJT-山港集团");
map.put("Dwdm","SGJT-山港集团"); // String call = call("returnMassages", map);
String call = call("returnMassages", map); // System.out.println(call);
System.out.println(call); // }
} //
//
//
//
//
//
// /**
/** // * WebService - 调用接口
* WebService - 调用接口 // *
* // * @param methodName 函数名
* @param methodName 函数名 // * @param params 参数
* @param params 参数 // * @param clazz 返回对象class
* @param clazz 返回对象class // * @return 返回结果(Object)
* @return 返回结果(Object) // */
*/ // public static <T> T call(String methodName, Map<String, String> params, Class<T> clazz) {
public static <T> T call(String methodName, Map<String, String> params, Class<T> clazz) { //// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params));
// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params)); // String soapActionURI = namespace + methodName;
String soapActionURI = namespace + methodName; // try {
try { // Service service = new Service();
Service service = new Service(); //
// SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName); // header.setNamespaceURI(namespace);
header.setNamespaceURI(namespace); //
// Call call = (Call) service.createCall();
Call call = (Call) service.createCall(); // call.setTargetEndpointAddress(url);
call.setTargetEndpointAddress(url); //
// call.setOperationName(new QName(namespace, methodName));
call.setOperationName(new QName(namespace, methodName)); //
// // 添加参数
// 添加参数 // List<String> parameterList = Lists.newArrayList();
List<String> parameterList = Lists.newArrayList(); // if (params != null) {
if (params != null) { // Set<String> paramsKey = params.keySet();
Set<String> paramsKey = params.keySet(); // for (String key : paramsKey) {
for (String key : paramsKey) { // call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN); // String pValue = MapUtils.getString(params, key);
String pValue = MapUtils.getString(params, key); // header.addChildElement(key).setValue(pValue);
header.addChildElement(key).setValue(pValue); // parameterList.add(pValue);
parameterList.add(pValue); // }
} // }
} // call.setUseSOAPAction(true);
call.setUseSOAPAction(true); // call.setSOAPActionURI(soapActionURI);
call.setSOAPActionURI(soapActionURI); // call.addHeader(header);
call.addHeader(header); //
// // 进行序列化 实体类也要序列化 implements Serializable
// 进行序列化 实体类也要序列化 implements Serializable // call.registerTypeMapping(clazz, new QName(namespace, soapActionURI),
call.registerTypeMapping(clazz, new QName(namespace, soapActionURI), // new BeanSerializerFactory(clazz, new QName(namespace, soapActionURI)),
new BeanSerializerFactory(clazz, new QName(namespace, soapActionURI)), // new BeanDeserializerFactory(clazz, new QName(namespace, soapActionURI)));
new BeanDeserializerFactory(clazz, new QName(namespace, soapActionURI))); // // 设置输出的类
// 设置输出的类 // call.setReturnClass(clazz);
call.setReturnClass(clazz); // // 接口返回结果
// 接口返回结果 // T result = (T) call.invoke(parameterList.toArray());
T result = (T) call.invoke(parameterList.toArray()); //// log.info("调用 WebService 接口返回===>" + result);
// log.info("调用 WebService 接口返回===>" + result); // return result;
return result; // } catch (Exception e) {
} catch (Exception e) { //// log.error("调用 WebService 接口错误信息==>" + e.getMessage());
// log.error("调用 WebService 接口错误信息==>" + e.getMessage()); // }
} // return null;
return null; // }
} //
// /**
/** // * WebService - 接口调用
* WebService - 接口调用 // *
* // * @param methodName 函数名
* @param methodName 函数名 // * @param params 参数
* @param params 参数 // * @return 返回结果(String)
* @return 返回结果(String) // */
*/ // public static String call(String methodName, Map<String, String> params) {
public static String call(String methodName, Map<String, String> params) { //// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params));
// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params)); // System.out.println("调用 WebService 发送参数==>" + JSONObject.toJSONString(params));
System.out.println("调用 WebService 发送参数==>" + JSONObject.toJSONString(params)); // String soapActionURI = namespace + methodName;
String soapActionURI = namespace + methodName; // try {
try { // Service service = new Service();
Service service = new Service(); //
// SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName); // header.setNamespaceURI(namespace);
header.setNamespaceURI(namespace); //
// Call call = (Call) service.createCall();
Call call = (Call) service.createCall(); // call.setTargetEndpointAddress(url);
call.setTargetEndpointAddress(url); //
// call.setOperationName(new QName(namespace, methodName));
call.setOperationName(new QName(namespace, methodName)); //
// // 添加参数
// 添加参数 // List<String> parameterList = Lists.newArrayList();
List<String> parameterList = Lists.newArrayList(); // if (params != null) {
if (params != null) { // Set<String> paramsKey = params.keySet();
Set<String> paramsKey = params.keySet(); // for (String key : paramsKey) {
for (String key : paramsKey) { // call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN); // String pValue = MapUtils.getString(params, key);
String pValue = MapUtils.getString(params, key); // header.addChildElement(key).setValue(pValue);
header.addChildElement(key).setValue(pValue); // parameterList.add(pValue);
parameterList.add(pValue); // }
} // }
} // call.setUseSOAPAction(true);
call.setUseSOAPAction(true); // call.setSOAPActionURI(soapActionURI);
call.setSOAPActionURI(soapActionURI); // call.addHeader(header);
call.addHeader(header); // // 设置返回类型
// 设置返回类型 // call.setReturnType(new QName(namespace, methodName), String.class);
call.setReturnType(new QName(namespace, methodName), String.class); // // 接口返回结果
// 接口返回结果 //
// String result = (String) call.invoke(parameterList.toArray());
String result = (String) call.invoke(parameterList.toArray()); //// log.info("调用 WebService 接口返回===>" + result);
// log.info("调用 WebService 接口返回===>" + result); // System.out.println("调用 WebService 接口返回===>" + result);
System.out.println("调用 WebService 接口返回===>" + result); // return result;
return result; // } catch (Exception e) {
} catch (Exception e) { //// log.error("调用 WebService 接口错误信息==>" + e.getMessage());
// log.error("调用 WebService 接口错误信息==>" + e.getMessage()); // System.out.println("调用 WebService 接口返回===>" + e.getMessage());
System.out.println("调用 WebService 接口返回===>" + e.getMessage()); // }
} // return null;
return null; // }
} //
// /**
/** // * WebService - 调用接口
* WebService - 调用接口 // *
* // * @param methodName 函数名
* @param methodName 函数名 // * @param params 参数
* @param params 参数 // * @return 返回结果(String)
* @return 返回结果(String) // */
*/ // public static String call2(String methodName, Map<String, String> params) {
public static String call2(String methodName, Map<String, String> params) { //// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params));
// log.info("调用 WebService 发送参数==>" + JsonUtil.object2Json(params)); // String soapActionURI = namespace + methodName;
String soapActionURI = namespace + methodName; // try {
try { // Service service = new Service();
Service service = new Service(); //
// SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName);
SOAPHeaderElement header = new SOAPHeaderElement(namespace, methodName); // header.setNamespaceURI(namespace);
header.setNamespaceURI(namespace); //
// Call call = (Call) service.createCall();
Call call = (Call) service.createCall(); // call.setTargetEndpointAddress(url);
call.setTargetEndpointAddress(url); //
// call.setOperationName(new QName(namespace, methodName));
call.setOperationName(new QName(namespace, methodName)); //
// // 添加参数
// 添加参数 // List<String> parameterList = Lists.newArrayList();
List<String> parameterList = Lists.newArrayList(); // if (params != null) {
if (params != null) { // Set<String> paramsKey = params.keySet();
Set<String> paramsKey = params.keySet(); // for (String key : paramsKey) {
for (String key : paramsKey) { // call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(namespace, key), XMLType.XSD_STRING, ParameterMode.IN); // String pValue = MapUtils.getString(params, key);
String pValue = MapUtils.getString(params, key); // header.addChildElement(key).setValue(pValue);
header.addChildElement(key).setValue(pValue); // parameterList.add(pValue);
parameterList.add(pValue); // }
} // }
} // call.setUseSOAPAction(true);
call.setUseSOAPAction(true); // call.setSOAPActionURI(soapActionURI);
call.setSOAPActionURI(soapActionURI); // call.addHeader(header);
call.addHeader(header); // // 设置返回类型
// 设置返回类型 // call.setReturnType(XMLType.XSD_SCHEMA);
call.setReturnType(XMLType.XSD_SCHEMA); // // 接口返回结果
// 接口返回结果 // Schema schemaResult = (Schema)call.invoke(parameterList.toArray());
Schema schemaResult = (Schema)call.invoke(parameterList.toArray()); // String result = "";
String result = ""; // for(int i = 0; i<schemaResult.get_any().length; i++){
for(int i = 0; i<schemaResult.get_any().length; i++){ // result = result + schemaResult.get_any()[i];
result = result + schemaResult.get_any()[i]; // }
} //// log.error("调用 WebService 接口返回===>" + result);
// log.error("调用 WebService 接口返回===>" + result); // return result;
return result; // } catch (Exception e) {
} catch (Exception e) { //// log.error("调用 WebService 接口错误信息==>" + e.getMessage());
// log.error("调用 WebService 接口错误信息==>" + e.getMessage()); // }
} // return null;
return null; // }
} //}
}

4
RuoYi-Vue-Oracle/src/main/java/com/ruoyi/project/oil/service/impl/SysSendInfoServiceImpl.java
View File

@ -37,10 +37,10 @@ public class SysSendInfoServiceImpl implements ISysSendInfoService {
if(sendMessageDTO.getIsSendPhone() !=null && sendMessageDTO.getIsSendPhone()){//发送短信 if(sendMessageDTO.getIsSendPhone() !=null && sendMessageDTO.getIsSendPhone()){//发送短信
List<String> phoneList= sendMessageDTO.getPhoneList(); List<String> phoneList= sendMessageDTO.getPhoneList();
String phone = String.join(",", phoneList); String phone = String.join(",", phoneList);
Collection<String> phones = new ArrayList<>(phoneList); List<String> phones = new ArrayList<>(phoneList);
String msg=sendMessageDTO.getSendText(); String msg=sendMessageDTO.getSendText();
String dwdm="SGJT-山港集团"; String dwdm="SGJT";
//todo 调用发送短信接口 //todo 调用发送短信接口
WebServiceUtil.sendMessage(phones,msg); WebServiceUtil.sendMessage(phones,msg);