Browse Source

open

master
pioneer 2 years ago
commit
2f4d976f70
  1. 6
      README.md
  2. BIN
      lib/axis.jar
  3. BIN
      lib/ceibs-sso.jar
  4. BIN
      lib/commons-discovery-0.2.jar
  5. BIN
      lib/commons-logging-1.0.4.jar
  6. BIN
      lib/commons-logging.jar
  7. BIN
      lib/finekit-10.0-20200828.jar
  8. BIN
      lib/jackson-all-1.9.1.jar
  9. BIN
      lib/jaxrpc.jar
  10. BIN
      lib/log4j-1.2.8.jar
  11. BIN
      lib/saaj.jar
  12. BIN
      lib/wsdl4j-1.5.1.jar
  13. 27
      plugin.xml
  14. 12
      src/main/java/com/fr/plugin/FunctionRecoder.java
  15. 72
      src/main/java/com/fr/plugin/GYSMSConfig.java
  16. 18
      src/main/java/com/fr/plugin/GYSMSLifeCycleMonitor.java
  17. 13
      src/main/java/com/fr/plugin/SMControllerRegisterProvider.java
  18. 36
      src/main/java/com/fr/plugin/SMSDBAccess.java
  19. 40
      src/main/java/com/fr/plugin/SMSiteTransformer.java
  20. 15
      src/main/java/com/fr/plugin/dao/SMSDao.java
  21. 26
      src/main/java/com/fr/plugin/entity/SMSConfigEntity.java
  22. 164
      src/main/java/com/fr/plugin/sms/GYSMSSMSProvider.java
  23. 203
      src/main/java/com/fr/plugin/sms/SMSUserInfo.java
  24. 63
      src/main/java/com/fr/plugin/sms/ZSResource.java
  25. 19
      src/main/java/com/fr/plugin/ws/Iosmservice.java
  26. 16
      src/main/java/com/fr/plugin/ws/IosmserviceService.java
  27. 142
      src/main/java/com/fr/plugin/ws/IosmserviceServiceLocator.java
  28. 531
      src/main/java/com/fr/plugin/ws/IosmserviceServiceSoapBindingStub.java
  29. 358
      src/main/java/com/fr/plugin/ws/smservice.wsdl

6
README.md

@ -0,0 +1,6 @@
# open-JSD-10054
JSD-10054 第三方短信平台厂商接入\
免责说明:该源码为第三方爱好者提供,不保证源码和方案的可靠性,也不提供任何形式的源码教学指导和协助!\
仅作为开发者学习参考使用!禁止用于任何商业用途!\
为保护开发者隐私,开发者信息已隐去!若原开发者希望公开自己的信息,可联系【pioneer】处理。

BIN
lib/axis.jar

Binary file not shown.

BIN
lib/ceibs-sso.jar

Binary file not shown.

BIN
lib/commons-discovery-0.2.jar

Binary file not shown.

BIN
lib/commons-logging-1.0.4.jar

Binary file not shown.

BIN
lib/commons-logging.jar

Binary file not shown.

BIN
lib/finekit-10.0-20200828.jar

Binary file not shown.

BIN
lib/jackson-all-1.9.1.jar

Binary file not shown.

BIN
lib/jaxrpc.jar

Binary file not shown.

BIN
lib/log4j-1.2.8.jar

Binary file not shown.

BIN
lib/saaj.jar

Binary file not shown.

BIN
lib/wsdl4j-1.5.1.jar

Binary file not shown.

27
plugin.xml

@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<plugin>
<id>com.eco.plugin.xx.gysms</id>
<name><![CDATA[贵阳烟草短信接口]]></name>
<active>yes</active>
<version>1.0.7</version>
<env-version>10.0</env-version>
<jartime>2021-02-10</jartime>
<vendor>fr.open</vendor>
<main-package>com.fr.plugin</main-package>
<!--用来记录这个任务的创建时间-->
<description><![CDATA[
]]></description>
<!--任务ID: 10054-->
<create-day>2022-4-24 22:29:38</create-day>
<extra-decision>
<ControllerRegisterProvider class="com.fr.plugin.SMControllerRegisterProvider"/>
</extra-decision>
<extra-core>
<SiteTransformer class="com.fr.plugin.SMSiteTransformer"/>
<DBAccessProvider class="com.fr.plugin.SMSDBAccess"/>
<SMSServiceProvider class="com.fr.plugin.sms.GYSMSSMSProvider"/>
</extra-core>
<lifecycle-monitor class="com.fr.plugin.GYSMSLifeCycleMonitor"/>
<function-recorder class="com.fr.plugin.FunctionRecoder"/>
</plugin>

12
src/main/java/com/fr/plugin/FunctionRecoder.java

@ -0,0 +1,12 @@
package com.fr.plugin;
import com.fr.plugin.transform.ExecuteFunctionRecord;
import com.fr.plugin.transform.FunctionRecorder;
@FunctionRecorder
public class FunctionRecoder {
@ExecuteFunctionRecord
public void exe(){
System.out.println("插件功能埋点,虽然不会执行,除非上架应用");
}
}

72
src/main/java/com/fr/plugin/GYSMSConfig.java

@ -0,0 +1,72 @@
package com.fr.plugin;
import com.fr.config.*;
import com.fr.config.holder.Conf;
import com.fr.config.holder.factory.Holders;
@Visualization(category = "xx短信接口配置")
public class GYSMSConfig extends DefaultConfiguration {
private static volatile GYSMSConfig config = null;
public static GYSMSConfig getInstance() {
if (config == null) {
config = ConfigContext.getConfigInstance(GYSMSConfig.class);
}
return config;
}
@Identifier(value = "apiUrl", name = "短信接接口地址", description = "描述", status = Status.SHOW)
private Conf<String> apiUrl = Holders.simple("http://xxx.xxx.xxx.xxx:xxxxx/smservice?wsdl");
@Identifier(value = "username", name = "短信用户名", description = "描述", status = Status.SHOW)
private Conf<String> username = Holders.simple("");
@Identifier(value = "password", name = "短信密码", description = "描述", status = Status.SHOW)
private Conf<String> password = Holders.simple("");
@Identifier(value = "smformat", name = "smformat", description = "描述", status = Status.SHOW)
private Conf<String> smformat = Holders.simple("MSG");
@Identifier(value = "frUrl", name = "帆软本地路径", description = "描述", status = Status.SHOW)
private Conf<String> frUrl = Holders.simple("http://xxx/webroot/decision");
public String getApiUrl() {
return apiUrl.get();
}
public void setApiUrl(String apiUrl) {
this.apiUrl.set(apiUrl);
}
public String getUsername() {
return username.get();
}
public void setUsername(String username) {
this.username.set(username);
}
public String getPassword() {
return password.get();
}
public void setPassword(String password) {
this.password.set(password);
}
public String getSmformat() {
return smformat.get();
}
public void setSmformat(String smformat) {
this.smformat.set(smformat);
}
public String getFrUrl() {
return frUrl.get();
}
public void setFrUrl( String frUrl) {
this.frUrl .set(frUrl);
}
@Override
public Object clone() throws CloneNotSupportedException {
GYSMSConfig cloned = (GYSMSConfig) super.clone();
cloned.apiUrl = (Conf<String>) this.apiUrl.clone();
cloned.username = (Conf<String>) this.username.clone();
cloned.password = (Conf<String>) this.password.clone();
cloned.smformat = (Conf<String>) this.smformat.clone();
cloned.frUrl = (Conf<String>) this.frUrl.clone();
return cloned;
}
}

18
src/main/java/com/fr/plugin/GYSMSLifeCycleMonitor.java

@ -0,0 +1,18 @@
package com.fr.plugin;
import com.fr.plugin.context.PluginContext;
import com.fr.plugin.observer.inner.AbstractPluginLifecycleMonitor;
import com.fr.stable.fun.Authorize;
@Authorize
public class GYSMSLifeCycleMonitor extends AbstractPluginLifecycleMonitor {
@Override
public void afterRun(PluginContext pluginContext) {
GYSMSConfig.getInstance();
}
@Override
public void beforeStop(PluginContext pluginContext) {
}
}

13
src/main/java/com/fr/plugin/SMControllerRegisterProvider.java

@ -0,0 +1,13 @@
package com.fr.plugin;
import com.fr.decision.fun.impl.AbstractControllerRegisterProvider;
import com.fr.plugin.sms.ZSResource;
public class SMControllerRegisterProvider extends AbstractControllerRegisterProvider {
@Override
public Class<?>[] getControllers() {
return new Class[]{
ZSResource.class
};
}
}

36
src/main/java/com/fr/plugin/SMSDBAccess.java

@ -0,0 +1,36 @@
package com.fr.plugin;
import com.fr.db.fun.impl.AbstractDBAccessProvider;
import com.fr.plugin.dao.SMSDao;
import com.fr.plugin.entity.SMSConfigEntity;
import com.fr.stable.db.accessor.DBAccessor;
import com.fr.stable.db.dao.BaseDAO;
import com.fr.stable.db.dao.DAOProvider;
public class SMSDBAccess extends AbstractDBAccessProvider {
private static DBAccessor accessor;
public static DBAccessor getAccessor() {
return accessor;
}
@Override
public DAOProvider[] registerDAO() {
return new DAOProvider[]{
new DAOProvider() {
public Class getEntityClass() {
return SMSConfigEntity.class;
}
public Class<? extends BaseDAO> getDAOClass() {
return SMSDao.class;
}
}
};
}
@Override
public void onDBAvailable(DBAccessor dbAccessor) {
accessor = dbAccessor;
}
}

40
src/main/java/com/fr/plugin/SMSiteTransformer.java

@ -0,0 +1,40 @@
package com.fr.plugin;
import com.fr.stable.StringUtils;
import com.fr.stable.fun.impl.AbstractSiteTransformer;
import java.util.HashMap;
import java.util.Map;
public class SMSiteTransformer extends AbstractSiteTransformer {
//请求转发到本地服务器
// private static final String HOST = "http://localhost:8075/webroot/decision/shequ";
private static final Map<String,String> sites = new HashMap<String,String>(1);
static{
//要转发的具体路由
sites.put("bbs.login.api","/v1/user/login/");
sites.put("sms_app","/v1/sms/");
sites.put("sms_info","/v1/sms/user_info");
sites.put("ping","/v1/ping");
}
@Override
public boolean match(String old) {
return sites.containsKey(old);
}
private static final String HOST = "";
@Override
public String transform(String old){
GYSMSConfig gysmsConfig = GYSMSConfig.getInstance();
String format = String.format("%s/shequ%s",gysmsConfig.getFrUrl(), sites.get(old));
return format;
}
@Override
public String transform() {
return StringUtils.EMPTY;
}
}

15
src/main/java/com/fr/plugin/dao/SMSDao.java

@ -0,0 +1,15 @@
package com.fr.plugin.dao;
import com.fr.plugin.entity.SMSConfigEntity;
import com.fr.stable.db.dao.BaseDAO;
import com.fr.stable.db.session.DAOSession;
public class SMSDao extends BaseDAO<SMSConfigEntity> {
public SMSDao(DAOSession daoSession) {
super(daoSession);
}
protected Class<SMSConfigEntity> getEntityClass() {
return SMSConfigEntity.class;
}
}

26
src/main/java/com/fr/plugin/entity/SMSConfigEntity.java

@ -0,0 +1,26 @@
package com.fr.plugin.entity;
import com.fr.stable.db.entity.BaseEntity;
import com.fr.third.javax.persistence.Column;
import com.fr.third.javax.persistence.Entity;
import com.fr.third.javax.persistence.Table;
@Entity
@Table(
name = "fr_sms_config"
)
public class SMSConfigEntity extends BaseEntity {
@Column(
name = "content"
, length = 1000, nullable = false
)
private String content;
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}

164
src/main/java/com/fr/plugin/sms/GYSMSSMSProvider.java

@ -0,0 +1,164 @@
package com.fr.plugin.sms;
import com.fanruan.api.log.LogKit;
import com.fr.base.sms.SMSContext;
import com.fr.json.JSONArray;
import com.fr.json.JSONObject;
import com.fr.log.FineLoggerFactory;
import com.fr.plugin.GYSMSConfig;
import com.fr.plugin.SMSDBAccess;
import com.fr.plugin.context.PluginContexts;
import com.fr.plugin.dao.SMSDao;
import com.fr.plugin.entity.SMSConfigEntity;
import com.fr.plugin.transform.ExecuteFunctionRecord;
import com.fr.plugin.ws.Iosmservice;
import com.fr.plugin.ws.IosmserviceServiceLocator;
import com.fr.stable.db.action.DBAction;
import com.fr.stable.db.dao.DAOContext;
import com.fr.stable.fun.impl.AbstractSMSServiceProvider;
import com.fr.stable.query.QueryFactory;
import javax.xml.rpc.ServiceException;
import java.net.MalformedURLException;
import java.net.URL;
import java.rmi.RemoteException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
public class GYSMSSMSProvider extends AbstractSMSServiceProvider {
public GYSMSSMSProvider() {
startListener();
}
@Override
@ExecuteFunctionRecord
public Map<String, String> mapping() {
Map<String, String> map = new HashMap<>();
// map.put("10", "尊敬的管理员,abcdefg。");
// map.put("11", "尊敬的#name#,您有一个工单号为:#order_number#的待处理工单,请您及时处理!");
// map.put("13", "您好,#webname#系统内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。");
// map.put("14", "尊敬的管理员,#taskname#于#time#运行失败,请知晓。");
// map.put("15", "您好,#taskname#于#time#运行成功。");
// map.put("16", "您的手机验证码为#Verifiecode#,请于10分钟内正确输入。");
// map.put("17", "您好,#webname#系统内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。");
// map.put("18", "恭喜!您的短信服务已经配置成功。");
// map.put("19", "您好,#taskname#于#time#运行成功。");
// map.put("20", "您的手机验证码为#verifiecode#,请于10分钟内正确输入。");
// map.put("49", "您好,#webname#系统日志文件已大于#logsize#M,请及时登录平台进行日志清理。");
// map.put("50", "您好,#webname#系统#clustername#内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。");
// map.put("51", "你好,#task#出错,请及时处理。该任务开始执行时间:#time#");
// map.put("53", "上报任务 #task#,已经到您这里#time#,请尽快处理!");
// map.put("63", "系统检测到,节点#node_id#的系统时间与其他节点不一致。请配置时间服务器,实现节点时间的自动同步。");
// map.put("64", "节点#node_id#,非正常脱离集群环境。请重启该节点,加入集群。");
// map.put("89", "节点#nodename#,与节点#node1name#的jar包不一致,将影响集群工程的稳定性,请前往集群节点管理页面查看详细异常信息,并及时处理。");
// map.put("90", "节点#nodename#情况异常,用户不能正常访问,请及时检查该节点状态。");
// map.put("125", "您有个#proname#任务即将过期,请您尽快办理。");
// map.put("127", "您有个#proname#任务需要处理,请您尽快办理。发起人:#startpeople#,发起时间:#starttime#。");
// map.put("134", "Redis集群#ip_port#节点已无法正常使用,可能原因为:节点宕机、内存已满、其他异常。为避免影响用户使用,请前往状态服务器配置页面查看详情,并及时处理。");
// map.put("135", "文件服务器出现无法读写的情况,可能原因为:文件服务器宕机、磁盘已满、其他异常。为避免影响用户使用,请及时检查文件服务器状态。");
// map.put("136", "您好,#webname#系统#clustername#当前负载状态过高,可能存在宕机风险,请及时关注。建议使用管理系统-智能运维-云端运维功能分析当前系统存在的性能问题。");
// map.put("239", "您好,预警任务#warningname#达到阈值被触发,请及时关注!模板路径:#templatePath#。");
// map.put("264", "更新任务「#job_name#」结束。任务开始于#year#年#month#月#day#日#hr_min#,累计耗时#c_hr#时#c_min#分#c_sec#秒,完成任务:基础表更新 #success_basetable#/#total_basetable# ,自助数据集更新 #success_dataset#/#total_dataset# , 关联更新 #success_relation#/#total_relation#。");
// map.put("265", "报表系统已宕机,请访问运维工具关注问题处理状态或及时进行系统重启。");
// map.put("269", "检查到系统环境配置存有不合理项,请及时查看并改正不合理项。");
// map.put("266", "报表系统已宕机,自动重启系统失败,请及时进行手动重启。");
// map.put("276", "你好,[#taskname#]备份失败,请及时处理,备份时间:#time#。");
// map.put("367", "集群节点#node_name#与基准节点存在不一致文件,且无法自动同步。请检查该节点状态。");
// map.put("368", "集群节点#node_name#与基准节点存在不一致文件,已自动同步与基准节点一致,不一致文件备份在该节点工程WEB-INF/#directory#/下。");
// map.put("998", "节点#nodename1#与节点#nodename2#之间通信异常,无法加入节点管理,请检查集群节点间通信端口是否已开放[TCP:7800,7810, 7820,7830, 7840, 7850,7860,7870][UDP:45588~65536 随机端口]。");
// map.put("999", "节点#node_name#的#type#模块存在异常,暂无法正常提供服务,请及时对异常状况进行排查");
return getModelsFromDB();
}
private Map<String, String> getModelsFromDB(){
try {
return SMSDBAccess.getAccessor().runQueryAction(new DBAction<Map<String, String>>() {
@Override
public Map<String, String> run(DAOContext daoContext) throws Exception {
List<SMSConfigEntity> all = daoContext.getDAO(SMSDao.class).find(QueryFactory.create());
Map<String,String> map=new HashMap<>();
for (SMSConfigEntity smsConfigEntity : all) {
map.put(smsConfigEntity.getId(),smsConfigEntity.getContent());
}
LogKit.info("初始化短信模板:{}",map);
return map;
}
});
} catch (Exception e) {
e.printStackTrace();
}
return new HashMap<>();
}
@Override
public Response sendTest(String mobile) {
FineLoggerFactory.getLogger().info("测试发送:{}, 手机号:{},参数:{}");
try {
send("测试短信", mobile, new JSONObject(), "");
} catch (Exception e) {
e.printStackTrace();
}
return Response.create(Response.RES_STATUS_SUCCESS, "发送测试短信成功", JSONObject.create());
}
@Override
@ExecuteFunctionRecord
public Response send(String template, String mobile, JSONObject para, String receiver) {
Iterator<String> it = para.keys();
while (it.hasNext()) {
String key = it.next();
template = template.replace(key, para.getString(key));
}
if (!PluginContexts.currentContext().isAvailable()) {
return Response.create(Response.RES_STATUS_FAILED, "发送普通短信失败未授权", JSONObject.create());
}
FineLoggerFactory.getLogger().info("模板:{} 手机号:{},参数:{}", template, mobile, para);
IosmserviceServiceLocator locator = new IosmserviceServiceLocator();
GYSMSConfig gysmsConfig = GYSMSConfig.getInstance();
String apiUrl = gysmsConfig.getApiUrl();
try {
Iosmservice iosmservice = locator.getiosmservicePort(new URL(apiUrl));
String username = gysmsConfig.getUsername();
String password = gysmsConfig.getPassword();
String smformat = gysmsConfig.getSmformat();
iosmservice.sendSMS(username, password, mobile, template, smformat);
} catch (ServiceException | MalformedURLException | RemoteException e1) {
LogKit.error("发送短信失败", e1);
}
return Response.create(Response.RES_STATUS_SUCCESS, "发送普通短信成功", JSONObject.create());
}
@Override
public Response batchSendSMS(String template, List<String> mobiles, JSONArray params, List<String> receivers) throws Exception {
for (int i = 0; i < mobiles.size(); i++) {
String mob = mobiles.get(i);
String rev = receivers.get(i);
JSONObject jsonObject = params.getJSONObject(i);
send(template, mob, jsonObject, rev);
}
return Response.create(Response.RES_STATUS_SUCCESS, "发送批量短信成功", JSONObject.create());
}
/**
* 启动发送短信的监听器
*/
private void startListener() {
SMSContext.addSmsListener(new Listener() {
@Override
public void beforeSend(String text, List<String> mobiles, JSONArray params, List<String> receivers) {
FineLoggerFactory.getLogger().info("发送短信前监听事件");
}
@Override
public void afterSend(String text, List<String> mobiles, JSONArray params, List<String> receivers, Response response) {
FineLoggerFactory.getLogger().info("发送短信后监听事件");
}
});
}
}

203
src/main/java/com/fr/plugin/sms/SMSUserInfo.java

@ -0,0 +1,203 @@
package com.fr.plugin.sms;
import com.fanruan.api.log.LogKit;
import com.fr.json.JSONArray;
import com.fr.json.JSONObject;
import com.fr.plugin.SMSDBAccess;
import com.fr.plugin.dao.SMSDao;
import com.fr.plugin.entity.SMSConfigEntity;
import com.fr.stable.db.action.DBAction;
import com.fr.stable.db.dao.DAOContext;
import com.fr.stable.query.QueryFactory;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author 秃破天际
* @version 10.0
* Created by 秃破天际 on 2021/7/23
**/
public class SMSUserInfo {
private static JSONObject getDatax() {
return JSONObject.create()
.put("balance", 9999)
.put("testSMSNum", 5)
.put("userId", 99999)
.put("sign", getSigns())
.put("public_tpl", getDataTemp())
.put("private_tpl", getPrivateTpl());
}
public static JSONObject getData() {
return JSONObject.create()
.put("data", getDatax())
.put("status", "success");
}
private static JSONArray getSigns() {
return JSONArray.create()
.put(newSign(2, "【贵阳烟草】", null, "success", true));
}
private static JSONArray getDataTemp() {
try {
return SMSDBAccess.getAccessor().runQueryAction(new DBAction<JSONArray>() {
@Override
public JSONArray run(DAOContext daoContext) throws Exception {
JSONArray jsonArray = JSONArray.create();
List<SMSConfigEntity> all = daoContext.getDAO(SMSDao.class).find(QueryFactory.create());
for (SMSConfigEntity smsConfigEntity : all) {
jsonArray.put(newTpl(Integer.parseInt(smsConfigEntity.getId()), smsConfigEntity.getContent(), "zh_CN", true));
}
LogKit.info("初始化短信模板:{}", jsonArray);
return jsonArray;
}
});
} catch (Exception e) {
e.printStackTrace();
}
return JSONArray.create();
}
private static JSONArray getPublicTpl() {
return JSONArray.create()
.put(newTpl(10, "【贵阳烟草】尊敬的管理员,#taskname#于#time#运行失败,请知晓。", "zh_CN", true))
.put(newTpl(11, "【贵阳烟草】尊敬的#name#,您有一个工单号为:#order_number#的待处理工单,请您及时处理!", "zh_CN", true))
.put(newTpl(13, "【贵阳烟草】您好,#webname#系统内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。", "zh_CN", true))
.put(newTpl(14, "【贵阳烟草】尊敬的管理员,#taskname#于#time#运行失败,请知晓。", "zh_CN", true))
.put(newTpl(15, "【贵阳烟草】您好,#taskname#于#time#运行成功。", "zh_CN", true))
.put(newTpl(16, "【贵阳烟草】您的手机验证码为#Verifiecode#,请于10分钟内正确输入。", "zh_CN", true))
.put(newTpl(17, "【贵阳烟草】您好,#webname#系统内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。", "zh_CN", true))
.put(newTpl(18, "【贵阳烟草】恭喜!您的短信服务已经配置成功。", "zh_CN", true))
.put(newTpl(20, "【贵阳烟草】您的手机验证码为#verifiecode#,请于10分钟内正确输入。", "zh_CN", true))
.put(newTpl(49, "【贵阳烟草】您好,#webname#系统日志文件已大于#logsize#M,请及时登录平台进行日志清理。", "zh_CN", true))
.put(newTpl(50, "【贵阳烟草】您好,#webname#系统#clustername#内存持续#m#分钟内存高于#n#,可能存在宕机风险,请及时关注。", "zh_CN", true))
.put(newTpl(51, "【贵阳烟草】你好,#task#出错,请及时处理。该任务开始执行时间:#time#", "zh_CN", true))
.put(newTpl(53, "【贵阳烟草】上报任务 #task#,已经到您这里#time#,请尽快处理!", "zh_CN", true))
.put(newTpl(54, "【贵阳烟草】#name#您好,上报任务#task#已经发起,请尽快处理!", "zh_CN", true))
.put(newTpl(63, "【贵阳烟草】节点#nodename2#,与节点#nodename1#系统时间相差超过#time_different#秒,为避免影响用户使用,请及时调整使各节点时间保持一致。", "zh_CN", true))
.put(newTpl(64, "【贵阳烟草】节点#nodename#已脱离集群环境,可能原因为:节点FullGC、节点宕机、节点间通…其他异常。为避免影响用户使用,请及时检查该节点状态,若该节点长时间无法自行恢复,则建议重启该节点。", "zh_CN", true))
.put(newTpl(89, "【贵阳烟草】节点#nodename#,与节点#node1name#的jar包不一致,将影响集群工程的稳定性,请前往集群节点管理页面查看详细异常信息,并及时处理。", "zh_CN", true))
.put(newTpl(90, "【贵阳烟草】节点#nodename#情况异常,用户不能正常访问,请及时检查该节点状态。", "zh_CN", true))
.put(newTpl(125, "【贵阳烟草】您有个#proname#任务即将过期,请您尽快办理。", "zh_CN", true))
.put(newTpl(127, "【贵阳烟草】您有个#proname#任务需要处理,请您尽快办理。发起人:#startpeople#,发起时间:#starttime#。", "zh_CN", true))
.put(newTpl(134, "【贵阳烟草】Redis集群#ip_port#节点已无法正常使用,可能原因为:节点宕机、内存已满、其他异常。为避免影响用户使用,请前往状态服务器配置页面查看详情,并及时处理。", "zh_CN", true))
.put(newTpl(135, "【贵阳烟草】文件服务器出现无法读写的情况,可能原因为:文件服务器宕机、磁盘已满、其他异常。为避免影响用户使用,请及时检查文件服务器状态。", "zh_CN", true))
.put(newTpl(136, "【贵阳烟草】您好,#webname#系统#clustername#当前负载状态过高,可能存在宕机风险,请及时关注。建议使用管理系统-智能运维-云端运维功能分析当前系统存在的性能问题。", "zh_CN", true))
.put(newTpl(239, "【贵阳烟草】您好,预警任务#warningname#达到阈值被触发,请及时关注!模板路径:#templatePath#", "zh_CN", true))
.put(newTpl(264, "【贵阳烟草】更新任务「#job_name#」结束。任务开始于#year#年#month#月#day#…aset# , 关联更新 #success_relation#/#total_relation#。", "zh_CN", true))
.put(newTpl(265, "【贵阳烟草】贵阳烟草已宕机,请访问运维工具关注问题处理状态或及时进行系统重启。", "zh_CN", true))
.put(newTpl(266, "【贵阳烟草】贵阳烟草已宕机,自动重启系统失败,请及时进行手动重启。", "zh_CN", true))
.put(newTpl(269, "【贵阳烟草】检查到系统环境配置存有不合理项,请及时查看并改正不合理项。", "zh_CN", true))
.put(newTpl(276, "【贵阳烟草】你好,[#taskname#]备份失败,请及时处理,备份时间:#time#", "zh_CN", true))
.put(newTpl(306, "【贵阳烟草】尊敬的管理員,#taskname#於#time#運行失敗,請知曉。", "zh_TW", true))
.put(newTpl(307, "【贵阳烟草】您好,#webname#系統記憶體持續#m#分鐘記憶體高於#n#,可能存在宕機風險,請及時關注。", "zh_TW", true))
.put(newTpl(308, "【贵阳烟草】恭喜!您的簡訊服務已經配置成功。", "zh_TW", true))
.put(newTpl(309, "【贵阳烟草】您的手機驗證碼為#verifiecode#,請於10分鐘內正確輸入。", "zh_TW", true))
.put(newTpl(310, "【贵阳烟草】您好,#webname#系統日誌檔已大於#logsize#M,請及時登入平臺進行日誌清理。", "zh_TW", true))
.put(newTpl(311, "【贵阳烟草】您好,#webname#系統#clustername#記憶體持續#m#分鐘記憶體高於#n#,可能存在宕機風險,請及時關注。", "zh_TW", true))
.put(newTpl(312, "【贵阳烟草】你好,#task#出錯,請及時處理。該任務開始執行時間:#time#", "zh_TW", true))
.put(newTpl(313, "【贵阳烟草】上報任務#task#,已經到您這裡#time#,請儘快處理!", "zh_TW", true))
.put(newTpl(314, "【贵阳烟草】#name#您好,上報任務#task#已經發起,請儘快處理!", "zh_TW", true))
.put(newTpl(315, "【贵阳烟草】系統檢測到,節點#node_id#的系統時間與其他節點不一致。請配置時間伺服器,實現節點時間的自動同步。", "zh_TW", true))
.put(newTpl(316, "【贵阳烟草】節點#nodename#已脫離叢集環境,可能原因為:節點FullGC、節點宕機、節點間通…他异常。為避免影響使用者使用,請及時檢查該節點狀態,若該節點長時間無法自行恢復,則建議重啓該節點。", "zh_TW", true))
.put(newTpl(317, "【贵阳烟草】節點#nodename#,與節點#node1name#的jar包不一致,將影響叢集工程的穩定性,請前往叢集節點管理頁面查看詳細异常資訊,並及時處理。", "zh_TW", true))
.put(newTpl(318, "【贵阳烟草】節點#nodename#情况异常,使用者不能正常訪問,請及時檢查該節點狀態。", "zh_TW", true))
.put(newTpl(319, "【贵阳烟草】您有個#proname#任務即將過期,請您儘快辦理。", "zh_TW", true))
.put(newTpl(320, "【贵阳烟草】您有個#proname#任務需要處理,請您儘快辦理。發起人:#startpeople#,發起時間:#starttime#。", "zh_TW", true))
.put(newTpl(321, "【贵阳烟草】Redis叢集#ip_port#節點已無法正常使用,可能原因為:節點宕機、記憶體已滿、其他異常。為避免影響使用者使用,請前往狀態伺服器配置頁面檢視詳情,並及時處理。", "zh_TW", true))
.put(newTpl(322, "【贵阳烟草】檔案伺服器出現無法讀寫的情况,可能原因為:檔案伺服器宕機、磁片已滿、其他异常。為避免影響使用者使用,請及時檢查檔案伺服器狀態。", "zh_TW", true))
.put(newTpl(323, "【贵阳烟草】您好,#webname#系統#clustername#當前負載狀態過高,可能存在宕機風險,請及時關注。", "zh_TW", true))
.put(newTpl(324, "【贵阳烟草】更新任務「#job_name#」結束。任務開始於#year#年#month#月#day#…dataset#,關聯更新#success_relation#/#total_relation#。", "zh_TW", true))
.put(newTpl(325, "【贵阳烟草】報表系統已宕機,請訪問維運工具關注問題處理狀態或及時進行系統重啓。", "zh_TW", true))
.put(newTpl(326, "【贵阳烟草】報表系統已宕機,自動重啟系統失敗,請及時進行手動重啓。", "zh_TW", true))
.put(newTpl(327, "【贵阳烟草】檢查到系統環境配置存有不合理項,請及時查看並改正不合理項。", "zh_TW", true))
.put(newTpl(328, "【贵阳烟草】你好,[#taskname#]備份失敗,請及時處理,備份時間:#time#", "zh_TW", true))
.put(newTpl(329, "【贵阳烟草】Dear administrator, #taskname# failed to run at #time#.", "en_US", true))
.put(newTpl(330, "【贵阳烟草】Hello, the system memory of #webname# keeps …y be downtime risk. Please pay attention in time.", "en_US", true))
.put(newTpl(331, "【贵阳烟草】Congratulations! Your SMS service has been configured successfully.", "en_US", true))
.put(newTpl(332, "【贵阳烟草】Your mobile phone verification code is #veri…de#. Please input it correctly within 10 minutes.", "en_US", true))
.put(newTpl(333, "【贵阳烟草】Hello, the system log files of #webname# occ…g in the platform to clean the log files in time.", "en_US", true))
.put(newTpl(334, "【贵阳烟草】Hello, the memory of #clustername# in system…y be downtime risk. Please pay attention in time.", "en_US", true))
.put(newTpl(335, "【贵阳烟草】Hello, there is an error in the task #task#,…t in time. The start time of the task is: #time#.", "en_US", true))
.put(newTpl(336, "【贵阳烟草】Reporting task #task# has arrived at #time#. Please deal with it as soon as possible!", "en_US", true))
.put(newTpl(337, "【贵阳烟草】Hello #name#, the reporting task #task# has … initiated. Please handle it as soon as possible!", "en_US", true))
.put(newTpl(338, "【贵阳烟草】The system detects that the system time of n…o realize automatic synchronization of node time.", "en_US", true))
.put(newTpl(339, "【贵阳烟草】Node #nodename# has been out of the cluster …der to avoid affecting the user's use, please che", "en_US", true))
.put(newTpl(340, "【贵阳烟草】The jar packages of node #nodename# and node…iled exception information and handle it in time.", "en_US", true))
.put(newTpl(341, "【贵阳烟草】There exists abnormal condition of node #nod…lly. Please check the status of the node in time.", "en_US", true))
.put(newTpl(342, "【贵阳烟草】Task #proname# will expire recently. Please handle it as soon as possible.", "en_US", true))
.put(newTpl(343, "【贵阳烟草】Task #proname# needs to be handled. Please h…nitiator: #startpeople#. Start time: #starttime#.", "en_US", true))
.put(newTpl(344, "【贵阳烟草】The Redis cluster #ip_port# node is no longe…page, check the details and deal with it in time.", "en_US", true))
.put(newTpl(345, "【贵阳烟草】The file server is unable to read and write.…ease check the status of the file server in time.", "en_US", true))
.put(newTpl(346, "【贵阳烟草】Hello, the load of #clustername# in system #…intenance and use the function of Cloud Operation", "en_US", true))
.put(newTpl(347, "【贵阳烟草】Update task 「#job_name#」is completed. The ta…table#/#total_basetable# basic table, #success_da", "en_US", true))
.put(newTpl(348, "【贵阳烟草】The report system has been down. Please use … processing status or restart the system in time.", "en_US", true))
.put(newTpl(349, "【贵阳烟草】The report system has been down, and automat… restart failed. Please restart manually in time.", "en_US", true))
.put(newTpl(350, "【贵阳烟草】It is found that there are unreasonable item…check and correct the unreasonable items in time.", "en_US", true))
.put(newTpl(351, "【贵阳烟草】Hello, [#taskname#] backup failed. Please handle it in time. Backup time: #time#.", "en_US", true))
.put(newTpl(367, "【贵阳烟草】集群节点#node_name#与基准节点存在不一致文件,且无法自动同步。请检查该节点状态", "zn_CN", true))
.put(newTpl(368, "【贵阳烟草】集群节点#node_name#与基准节点存在不一致文件,已自动同步与基准节点一致,不一致文件备份在该节点工程WEB-INF/#directory#/下", "zh_CN", true))
.put(newTpl(369, "【贵阳烟草】節點#nodename1#與節點#nodename1#之間通訊異常,無法加入節點管理,請…7830, 7840, 7850,7860,7870][UDP:45588~65536 隨機埠]。", "zh_TW", true))
.put(newTpl(370, "【贵阳烟草】節點#node_name#的#type#模組存在異常,暫無法正常提供服務,請及時對異常狀況進行排查", "zh_TW", true))
.put(newTpl(371, "【贵阳烟草】叢集節點#node_name#與基準節點存在不一致檔案,且無法自動同步。請檢查該節點狀態", "zh_TW", true))
.put(newTpl(372, "【贵阳烟草】叢集節點#node_name#與基準節點存在不一致檔案,已自動同步與基準節點一致,不一致檔案備份在該節點工程WEB-INF/#directory#/下", "zh_TW", true))
.put(newTpl(373, "【贵阳烟草】The communication between node #nodename1# a…7850,7860,7870] [UDP: 45588 ~ 65536 random port].", "en_US", true))
.put(newTpl(374, "【贵阳烟草】The #node_name# node #type# module has start…ng. Please check for abnormal conditions in time.", "en_US", true))
.put(newTpl(375, "【贵阳烟草】Cluster node #node_name# has inconsistent fi…ized automatically. Please check the node status.", "en_US", true))
.put(newTpl(376, "【贵阳烟草】The cluster node #node_name# has an inconsis…up under the node project WEB-INF/ #directory# /.", "en_US", true))
.put(newTpl(401, "【贵阳烟草】Hello, #taskname# runs successfully on #time#.", "en_US", true))
.put(newTpl(402, "【贵阳烟草】您好,#taskname#於#time#運行成功運行。", "zh_TW", true))
.put(newTpl(509, "【贵阳烟草】尊敬的管理员,用户管理-同步用户于#time#运行失败,可手动触发同步,以查看详细报错。", "zh_CN", true))
.put(newTpl(550, "【贵阳烟草】Dear administrator, \\\"User>Sync user\\\" failed … sync manually to view the detailed error report.", "en_US", true))
.put(newTpl(551, "【贵阳烟草】尊敬的管理員,使用者管理-同步使用者於#time#執行失敗,可手動觸發同步,以檢視詳細報錯。", "zh_TW", true))
.put(newTpl(998, "【贵阳烟草】节点#nodename1#与节点#nodename2#之间通信异常,无法加入节点管理,请…830, 7840, 7850,7860,7870][UDP:45588~65536 随机端口]。", "zh_CN", true))
.put(newTpl(999, "【贵阳烟草】节点#node_name#的#type#模块存在异常,暂无法正常提供服务,请及时对异常状况进行排查", "zh_CN", true));
}
public static Map<String, String> getTpls() {
JSONArray arrs = getPublicTpl();
Map<String, String> rt = new HashMap<String, String>();
for (int i = 0, len = arrs.length(); i < len; i++) {
JSONObject tpl = arrs.optJSONObject(i);
rt.put("" + tpl.optInt("id"), tpl.optString("content"));
}
arrs = getPrivateTpl();
for (int i = 0, len = arrs.length(); i < len; i++) {
JSONObject tpl = arrs.optJSONObject(i);
rt.put("" + tpl.optInt("id"), tpl.optString("content"));
}
return rt;
}
private static JSONArray getPrivateTpl() {
return JSONArray.create();
}
private static JSONObject newSign(int id, String sign, String remark, String status, boolean isDefault) {
return JSONObject.create()
.put("id", id)
.put("sign", sign)
.put("remark", remark)
.put("status", status)
.put("is_default", isDefault);
}
private static JSONObject newTpl(int id, String content, String language, boolean isDefault) {
return JSONObject.create()
.put("id", id)
.put("content", content)
.put("language", language)
.put("remark", (String) null)
.put("status", "success")
.put("is_default", isDefault);
}
}

63
src/main/java/com/fr/plugin/sms/ZSResource.java

@ -0,0 +1,63 @@
package com.fr.plugin.sms;
import com.fanruan.api.log.LogKit;
import com.fr.decision.webservice.annotation.LoginStatusChecker;
import com.fr.general.GeneralUtils;
import com.fr.json.JSONObject;
import com.fr.log.FineLoggerFactory;
import com.fr.plugin.SMSDBAccess;
import com.fr.plugin.dao.SMSDao;
import com.fr.plugin.entity.SMSConfigEntity;
import com.fr.stable.StringUtils;
import com.fr.stable.db.action.DBAction;
import com.fr.stable.db.dao.DAOContext;
import com.fr.stable.query.QueryFactory;
import com.fr.third.springframework.stereotype.Controller;
import com.fr.third.springframework.web.bind.annotation.RequestMapping;
import com.fr.third.springframework.web.bind.annotation.ResponseBody;
import com.fr.web.utils.WebUtils;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Controller("SmsThirdSheQu")
@RequestMapping(value = "/shequ")
@LoginStatusChecker(required = false)
public class ZSResource {
@RequestMapping(value = "/**")
@ResponseBody
public void dispatcher( HttpServletRequest request, HttpServletResponse response ) throws Exception{
String info = request.getPathInfo();
String method = request.getMethod();
if( "/shequ/v1/user/login/".equals(info) ){
//内网下模拟帆软通行证登录
print(request,response,"{\"code\":200,\"message\":\"success\",\"data\":{\"access_token\":\"Um5rO7Ef5gvCqBWQw08LJkRilxtc4SGN\",\"expires_time\":4070883661,\"refresh_token\":\"HQqs6A9dTn1CElwP3tLJ4McX387pj2Uu\",\"refresh_expires_time\":4070883661,\"client\":{\"appid\":\"shequapp\",\"uid\":99999,\"username\":\"贵阳烟草\"}},\"status\":0}");
}else if("/shequ/v1/sms/".equals(info) && "POST".equals(method)){
//内网下验证短信开启
print(request,response,"{\"status\":\"success\",\"data\":{\"app_key\":\"third_app_key\",\"app_secret\":\"third_app_secret\"}}");
}else if( "/shequ/v1/sms/user_info".equals(info) && "POST".equals(method) ){
//内网下获取短信模板
print( request, response, SMSUserInfo.getData().toString() );
}else if( "/shequ/v1/ping".equals(info) ){
//内网下模拟在线
WebUtils.printAsString(response, StringUtils.EMPTY);
}
}
private static void print(HttpServletRequest req, HttpServletResponse res, String response){
try{
JSONObject obj = new JSONObject(response);
res.setCharacterEncoding("UTF-8");
LogKit.info("接口:{} 返回:{}", req.getRequestURI(), obj.toString());
WebUtils.flushSuccessMessageAutoClose(req,res,obj);
}catch(Exception e){
FineLoggerFactory.getLogger().error(e.getMessage(),e);
}
}
}

19
src/main/java/com/fr/plugin/ws/Iosmservice.java

@ -0,0 +1,19 @@
/**
* Iosmservice.java
*
* This file was auto-generated from WSDL
* by the Apache Axis 1.4 Apr 22, 2006 (06:55:48 PDT) WSDL2Java emitter.
*/
package com.fr.plugin.ws;
public interface Iosmservice extends java.rmi.Remote {
public java.lang.String getContent(java.lang.String arg0) throws java.rmi.RemoteException;
public java.lang.String getSmsendResult(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4, java.lang.String arg5, java.lang.String arg6) throws java.rmi.RemoteException;
public java.lang.String getSmsendInfo(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4, java.lang.String arg5) throws java.rmi.RemoteException;
public java.lang.String msginfo(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException;
public java.lang.String login(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2) throws java.rmi.RemoteException;
public java.lang.String sendSMS(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException;
public java.lang.String sendSMSBatch(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException;
public java.lang.String getSmRevices(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException;
}

16
src/main/java/com/fr/plugin/ws/IosmserviceService.java

@ -0,0 +1,16 @@
/**
* IosmserviceService.java
*
* This file was auto-generated from WSDL
* by the Apache Axis 1.4 Apr 22, 2006 (06:55:48 PDT) WSDL2Java emitter.
*/
package com.fr.plugin.ws;
public interface IosmserviceService extends javax.xml.rpc.Service {
public java.lang.String getiosmservicePortAddress();
public com.fr.plugin.ws.Iosmservice getiosmservicePort() throws javax.xml.rpc.ServiceException;
public com.fr.plugin.ws.Iosmservice getiosmservicePort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException;
}

142
src/main/java/com/fr/plugin/ws/IosmserviceServiceLocator.java

@ -0,0 +1,142 @@
/**
* IoxxServiceLocator.java
*
* This file was auto-generated from WSDL
* by the Apache Axis 1.4 Apr 22, 2006 (06:55:48 PDT) WSDL2Java emitter.
*/
package com.fr.plugin.ws;
public class IoxxServiceLocator extends org.apache.axis.client.Service implements com.fr.plugin.ws.IoxxService {
public IoxxServiceLocator() {
}
public IoxxServiceLocator(org.apache.axis.EngineConfiguration config) {
super(config);
}
public IoxxServiceLocator(java.lang.String wsdlLoc, javax.xml.namespace.QName sName) throws javax.xml.rpc.ServiceException {
super(wsdlLoc, sName);
}
// Use to get a proxy class for ioxxPort
private java.lang.String ioxxPort_address = "http://xx:8060/xx";
public java.lang.String getioxxPortAddress() {
return ioxxPort_address;
}
// The WSDD service name defaults to the port name.
private java.lang.String ioxxPortWSDDServiceName = "ioxxPort";
public java.lang.String getioxxPortWSDDServiceName() {
return ioxxPortWSDDServiceName;
}
public void setioxxPortWSDDServiceName(java.lang.String name) {
ioxxPortWSDDServiceName = name;
}
public com.fr.plugin.ws.Ioxx getioxxPort() throws javax.xml.rpc.ServiceException {
java.net.URL endpoint;
try {
endpoint = new java.net.URL(ioxxPort_address);
}
catch (java.net.MalformedURLException e) {
throw new javax.xml.rpc.ServiceException(e);
}
return getioxxPort(endpoint);
}
public com.fr.plugin.ws.Ioxx getioxxPort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException {
try {
com.fr.plugin.ws.IoxxServiceSoapBindingStub _stub = new com.fr.plugin.ws.IoxxServiceSoapBindingStub(portAddress, this);
_stub.setPortName(getioxxPortWSDDServiceName());
return _stub;
}
catch (org.apache.axis.AxisFault e) {
return null;
}
}
public void setioxxPortEndpointAddress(java.lang.String address) {
ioxxPort_address = address;
}
/**
* For the given interface, get the stub implementation.
* If this service has no port for the given interface,
* then ServiceException is thrown.
*/
public java.rmi.Remote getPort(Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException {
try {
if (com.fr.plugin.ws.Ioxx.class.isAssignableFrom(serviceEndpointInterface)) {
com.fr.plugin.ws.IoxxServiceSoapBindingStub _stub = new com.fr.plugin.ws.IoxxServiceSoapBindingStub(new java.net.URL(ioxxPort_address), this);
_stub.setPortName(getioxxPortWSDDServiceName());
return _stub;
}
}
catch (java.lang.Throwable t) {
throw new javax.xml.rpc.ServiceException(t);
}
throw new javax.xml.rpc.ServiceException("There is no stub implementation for the interface: " + (serviceEndpointInterface == null ? "null" : serviceEndpointInterface.getName()));
}
/**
* For the given interface, get the stub implementation.
* If this service has no port for the given interface,
* then ServiceException is thrown.
*/
public java.rmi.Remote getPort(javax.xml.namespace.QName portName, Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException {
if (portName == null) {
return getPort(serviceEndpointInterface);
}
java.lang.String inputPortName = portName.getLocalPart();
if ("ioxxPort".equals(inputPortName)) {
return getioxxPort();
}
else {
java.rmi.Remote _stub = getPort(serviceEndpointInterface);
((org.apache.axis.client.Stub) _stub).setPortName(portName);
return _stub;
}
}
public javax.xml.namespace.QName getServiceName() {
return new javax.xml.namespace.QName("http://xx.com/", "ioxxService");
}
private java.util.HashSet ports = null;
public java.util.Iterator getPorts() {
if (ports == null) {
ports = new java.util.HashSet();
ports.add(new javax.xml.namespace.QName("http://xx.com/", "ioxxPort"));
}
return ports.iterator();
}
/**
* Set the endpoint address for the specified port name.
*/
public void setEndpointAddress(java.lang.String portName, java.lang.String address) throws javax.xml.rpc.ServiceException {
if ("ioxxPort".equals(portName)) {
setioxxPortEndpointAddress(address);
}
else
{ // Unknown Port Name
throw new javax.xml.rpc.ServiceException(" Cannot set Endpoint Address for Unknown Port" + portName);
}
}
/**
* Set the endpoint address for the specified port name.
*/
public void setEndpointAddress(javax.xml.namespace.QName portName, java.lang.String address) throws javax.xml.rpc.ServiceException {
setEndpointAddress(portName.getLocalPart(), address);
}
}

531
src/main/java/com/fr/plugin/ws/IosmserviceServiceSoapBindingStub.java

@ -0,0 +1,531 @@
/**
* IoxxServiceSoapBindingStub.java
*
* This file was auto-generated from WSDL
* by the Apache Axis 1.4 Apr 22, 2006 (06:55:48 PDT) WSDL2Java emitter.
*/
package com.fr.plugin.ws;
public class IoxxServiceSoapBindingStub extends org.apache.axis.client.Stub implements com.fr.plugin.ws.Ioxx {
private java.util.Vector cachedSerClasses = new java.util.Vector();
private java.util.Vector cachedSerQNames = new java.util.Vector();
private java.util.Vector cachedSerFactories = new java.util.Vector();
private java.util.Vector cachedDeserFactories = new java.util.Vector();
static org.apache.axis.description.OperationDesc [] _operations;
static {
_operations = new org.apache.axis.description.OperationDesc[8];
_initOperationDesc1();
}
private static void _initOperationDesc1(){
org.apache.axis.description.OperationDesc oper;
org.apache.axis.description.ParameterDesc param;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("getContent");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[0] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("getSmsendResult");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "int"), int.class, false, false);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg5"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg6"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[1] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("getSmsendInfo");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "int"), int.class, false, false);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg5"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[2] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("msginfo");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[3] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("login");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[4] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("SendSMS");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[5] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("SendSMSBatch");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[6] = oper;
oper = new org.apache.axis.description.OperationDesc();
oper.setName("getSmRevices");
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg0"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg1"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg2"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "int"), int.class, false, false);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg3"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
param = new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("", "arg4"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"), java.lang.String.class, false, false);
param.setOmittable(true);
oper.addParameter(param);
oper.setReturnType(new javax.xml.namespace.QName("http://www.w3.org/2001/XMLSchema", "string"));
oper.setReturnClass(java.lang.String.class);
oper.setReturnQName(new javax.xml.namespace.QName("", "return"));
oper.setStyle(org.apache.axis.constants.Style.WRAPPED);
oper.setUse(org.apache.axis.constants.Use.LITERAL);
_operations[7] = oper;
}
public IoxxServiceSoapBindingStub() throws org.apache.axis.AxisFault {
this(null);
}
public IoxxServiceSoapBindingStub(java.net.URL endpointURL, javax.xml.rpc.Service service) throws org.apache.axis.AxisFault {
this(service);
super.cachedEndpoint = endpointURL;
}
public IoxxServiceSoapBindingStub(javax.xml.rpc.Service service) throws org.apache.axis.AxisFault {
if (service == null) {
super.service = new org.apache.axis.client.Service();
} else {
super.service = service;
}
((org.apache.axis.client.Service)super.service).setTypeMappingVersion("1.1");
}
protected org.apache.axis.client.Call createCall() throws java.rmi.RemoteException {
try {
org.apache.axis.client.Call _call = super._createCall();
if (super.maintainSessionSet) {
_call.setMaintainSession(super.maintainSession);
}
if (super.cachedUsername != null) {
_call.setUsername(super.cachedUsername);
}
if (super.cachedPassword != null) {
_call.setPassword(super.cachedPassword);
}
if (super.cachedEndpoint != null) {
_call.setTargetEndpointAddress(super.cachedEndpoint);
}
if (super.cachedTimeout != null) {
_call.setTimeout(super.cachedTimeout);
}
if (super.cachedPortName != null) {
_call.setPortName(super.cachedPortName);
}
java.util.Enumeration keys = super.cachedProperties.keys();
while (keys.hasMoreElements()) {
java.lang.String key = (java.lang.String) keys.nextElement();
_call.setProperty(key, super.cachedProperties.get(key));
}
return _call;
}
catch (java.lang.Throwable _t) {
throw new org.apache.axis.AxisFault("Failure trying to get the Call object", _t);
}
}
public java.lang.String getContent(java.lang.String arg0) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[0]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "getContent"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String getSmsendResult(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4, java.lang.String arg5, java.lang.String arg6) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[1]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "getSmsendResult"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, new java.lang.Integer(arg2), arg3, arg4, arg5, arg6});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String getSmsendInfo(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4, java.lang.String arg5) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[2]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "getSmsendInfo"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, new java.lang.Integer(arg2), arg3, arg4, arg5});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String msginfo(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[3]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "msginfo"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, arg2, arg3, arg4});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String login(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[4]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "login"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, arg2});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String sendSMS(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[5]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "SendSMS"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, arg2, arg3, arg4});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String sendSMSBatch(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[6]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "SendSMSBatch"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, arg2, arg3, arg4});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
public java.lang.String getSmRevices(java.lang.String arg0, java.lang.String arg1, int arg2, java.lang.String arg3, java.lang.String arg4) throws java.rmi.RemoteException {
if (super.cachedEndpoint == null) {
throw new org.apache.axis.NoEndPointException();
}
org.apache.axis.client.Call _call = createCall();
_call.setOperation(_operations[7]);
_call.setUseSOAPAction(true);
_call.setSOAPActionURI("");
_call.setEncodingStyle(null);
_call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE);
_call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE);
_call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP12_CONSTANTS);
_call.setOperationName(new javax.xml.namespace.QName("http://xx.com/", "getSmRevices"));
setRequestHeaders(_call);
setAttachments(_call);
try { java.lang.Object _resp = _call.invoke(new java.lang.Object[] {arg0, arg1, new java.lang.Integer(arg2), arg3, arg4});
if (_resp instanceof java.rmi.RemoteException) {
throw (java.rmi.RemoteException)_resp;
}
else {
extractAttachments(_call);
try {
return (java.lang.String) _resp;
} catch (java.lang.Exception _exception) {
return (java.lang.String) org.apache.axis.utils.JavaUtils.convert(_resp, java.lang.String.class);
}
}
} catch (org.apache.axis.AxisFault axisFaultException) {
throw axisFaultException;
}
}
}

358
src/main/java/com/fr/plugin/ws/smservice.wsdl

@ -0,0 +1,358 @@
<?xml version='1.0' encoding='UTF-8'?><wsdl:definitions xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" xmlns:tns="http://smservice.com/" xmlns:soap12="http://schemas.xmlsoap.org/wsdl/soap12/" xmlns:ns1="http://schemas.xmlsoap.org/soap/http" name="iosmserviceService" targetNamespace="http://smservice.com/">
<wsdl:types>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:tns="http://smservice.com/" elementFormDefault="unqualified" targetNamespace="http://smservice.com/" version="1.0">
<xs:element name="SendSMS" type="tns:SendSMS"/>
<xs:element name="SendSMSBatch" type="tns:SendSMSBatch"/>
<xs:element name="SendSMSBatchResponse" type="tns:SendSMSBatchResponse"/>
<xs:element name="SendSMSResponse" type="tns:SendSMSResponse"/>
<xs:element name="getContent" type="tns:getContent"/>
<xs:element name="getContentResponse" type="tns:getContentResponse"/>
<xs:element name="getSmRevices" type="tns:getSmRevices"/>
<xs:element name="getSmRevicesResponse" type="tns:getSmRevicesResponse"/>
<xs:element name="getSmsendInfo" type="tns:getSmsendInfo"/>
<xs:element name="getSmsendInfoResponse" type="tns:getSmsendInfoResponse"/>
<xs:element name="getSmsendResult" type="tns:getSmsendResult"/>
<xs:element name="getSmsendResultResponse" type="tns:getSmsendResultResponse"/>
<xs:element name="login" type="tns:login"/>
<xs:element name="loginResponse" type="tns:loginResponse"/>
<xs:element name="msginfo" type="tns:msginfo"/>
<xs:element name="msginfoResponse" type="tns:msginfoResponse"/>
<xs:complexType name="getContent">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getContentResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmsendResult">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element name="arg2" type="xs:int"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
<xs:element minOccurs="0" name="arg5" type="xs:string"/>
<xs:element minOccurs="0" name="arg6" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmsendResultResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmsendInfo">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element name="arg2" type="xs:int"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
<xs:element minOccurs="0" name="arg5" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmsendInfoResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="msginfo">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element minOccurs="0" name="arg2" type="xs:string"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="msginfoResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="login">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element minOccurs="0" name="arg2" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="loginResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="SendSMS">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element minOccurs="0" name="arg2" type="xs:string"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="SendSMSResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="SendSMSBatch">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element minOccurs="0" name="arg2" type="xs:string"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="SendSMSBatchResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmRevices">
<xs:sequence>
<xs:element minOccurs="0" name="arg0" type="xs:string"/>
<xs:element minOccurs="0" name="arg1" type="xs:string"/>
<xs:element name="arg2" type="xs:int"/>
<xs:element minOccurs="0" name="arg3" type="xs:string"/>
<xs:element minOccurs="0" name="arg4" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType name="getSmRevicesResponse">
<xs:sequence>
<xs:element minOccurs="0" name="return" type="xs:string"/>
</xs:sequence>
</xs:complexType>
</xs:schema>
</wsdl:types>
<wsdl:message name="getContent">
<wsdl:part element="tns:getContent" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="loginResponse">
<wsdl:part element="tns:loginResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="SendSMSResponse">
<wsdl:part element="tns:SendSMSResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="SendSMSBatchResponse">
<wsdl:part element="tns:SendSMSBatchResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmsendResultResponse">
<wsdl:part element="tns:getSmsendResultResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="msginfo">
<wsdl:part element="tns:msginfo" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="login">
<wsdl:part element="tns:login" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getContentResponse">
<wsdl:part element="tns:getContentResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="SendSMS">
<wsdl:part element="tns:SendSMS" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmRevices">
<wsdl:part element="tns:getSmRevices" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="msginfoResponse">
<wsdl:part element="tns:msginfoResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmsendResult">
<wsdl:part element="tns:getSmsendResult" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmsendInfo">
<wsdl:part element="tns:getSmsendInfo" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmsendInfoResponse">
<wsdl:part element="tns:getSmsendInfoResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="getSmRevicesResponse">
<wsdl:part element="tns:getSmRevicesResponse" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:message name="SendSMSBatch">
<wsdl:part element="tns:SendSMSBatch" name="parameters">
</wsdl:part>
</wsdl:message>
<wsdl:portType name="iosmservice">
<wsdl:operation name="getContent">
<wsdl:input message="tns:getContent" name="getContent">
</wsdl:input>
<wsdl:output message="tns:getContentResponse" name="getContentResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmsendResult">
<wsdl:input message="tns:getSmsendResult" name="getSmsendResult">
</wsdl:input>
<wsdl:output message="tns:getSmsendResultResponse" name="getSmsendResultResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmsendInfo">
<wsdl:input message="tns:getSmsendInfo" name="getSmsendInfo">
</wsdl:input>
<wsdl:output message="tns:getSmsendInfoResponse" name="getSmsendInfoResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="msginfo">
<wsdl:input message="tns:msginfo" name="msginfo">
</wsdl:input>
<wsdl:output message="tns:msginfoResponse" name="msginfoResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="login">
<wsdl:input message="tns:login" name="login">
</wsdl:input>
<wsdl:output message="tns:loginResponse" name="loginResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="SendSMS">
<wsdl:input message="tns:SendSMS" name="SendSMS">
</wsdl:input>
<wsdl:output message="tns:SendSMSResponse" name="SendSMSResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="SendSMSBatch">
<wsdl:input message="tns:SendSMSBatch" name="SendSMSBatch">
</wsdl:input>
<wsdl:output message="tns:SendSMSBatchResponse" name="SendSMSBatchResponse">
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmRevices">
<wsdl:input message="tns:getSmRevices" name="getSmRevices">
</wsdl:input>
<wsdl:output message="tns:getSmRevicesResponse" name="getSmRevicesResponse">
</wsdl:output>
</wsdl:operation>
</wsdl:portType>
<wsdl:binding name="iosmserviceServiceSoapBinding" type="tns:iosmservice">
<soap12:binding style="document" transport="http://schemas.xmlsoap.org/soap/http"/>
<wsdl:operation name="getContent">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="getContent">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="getContentResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmsendResult">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="getSmsendResult">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="getSmsendResultResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmsendInfo">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="getSmsendInfo">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="getSmsendInfoResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="msginfo">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="msginfo">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="msginfoResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="login">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="login">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="loginResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="SendSMS">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="SendSMS">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="SendSMSResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="SendSMSBatch">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="SendSMSBatch">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="SendSMSBatchResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getSmRevices">
<soap12:operation soapAction="" style="document"/>
<wsdl:input name="getSmRevices">
<soap12:body use="literal"/>
</wsdl:input>
<wsdl:output name="getSmRevicesResponse">
<soap12:body use="literal"/>
</wsdl:output>
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="iosmserviceService">
<wsdl:port binding="tns:iosmserviceServiceSoapBinding" name="iosmservicePort">
<soap12:address location="http://xx:xx/smservice"/>
</wsdl:port>
</wsdl:service>
</wsdl:definitions>
Loading…
Cancel
Save