I3_YF_SEAT
/
i3plus-pojo
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加脚本支持，修改返回为resultBean

Browse Source
yun-zuoyi
castle.zang 4 years ago
parent 55af273ea7
commit aa3ece8336
6 changed files with 332 additions and 203 deletions
Show Stats Download Patch File Download Diff File

75
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/client/bean/po/EngineScriptPersistence.java
Unescape Escape View File

@ -0,0 +1,75 @@
package cn.estsh.i3plus.pojo.bsp.client.bean.po;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import io.swagger.annotations.Api;
import lombok.Data;
import javax.persistence.Inheritance;
import javax.persistence.InheritanceType;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import javax.persistence.*;
/**
* 脚本持久化实体类
*
* @author Rock.Yu
* @since 2019-03-18 14:22
*/
@Data
@Entity
@DynamicInsert
@DynamicUpdate
@NoArgsConstructor
@EqualsAndHashCode(callSuper = true)
@Inheritance(strategy = InheritanceType.JOINED)
@Table(name = "SCRIPT_PERSISTENCE", uniqueConstraints = {
@UniqueConstraint(columnNames = {"ORGANIZE_CODE", "SCRIPT_NO"})
})
@Api("系统动态脚本")
public class EngineScriptPersistence extends BaseBean {
private static final long serialVersionUID = 7893111140559759490L;
// 脚本调用的唯一编号，例如：WMS_PDA_0001
@Column(name = "SCRIPT_NO", length = 50)
private String scriptNo;
// 脚本的中文名称
@Column(name = "SCRIPT_NAME", length = 50)
private String scriptName;
// 10=组件脚本，20=表单脚本，30=报表脚本，40=JOB脚本，50=其他脚本
@Column(name = "SCRIPT_TYPE")
private Integer scriptType;
// 脚本编写的语言
// 10=Groovy, 20=Jython, 30=JavaScript, 40=Scala, 50=JRuby
@Column(name = "LANGUAGE_TYPE")
private Integer languageType;
// 脚本的具体内容
@Lob
@Column(name = "SCRIPT_CONTENT", columnDefinition = "TEXT")
private String scriptContent;
// 脚本的描述，包含脚本的用法，参数说明等
@Column(name = "SCRIPT_REMARK", length = 2000)
private String scriptRemark;
// 编译后的脚本内容，通过预编译加快脚本的运行速度
@Transient
private Object compiledScript;
// 构造方法，便于批量创建数据
public EngineScriptPersistence(Long id, String scriptNo, String scriptName, Integer scriptType, Integer languageType,
String scriptContent, String scriptRemark) {
this.id = id;
this.scriptNo = scriptNo;
this.scriptName = scriptName;
this.scriptType = scriptType;
this.languageType = languageType;
this.scriptContent = scriptContent;
this.scriptRemark = scriptRemark;
}
}

11
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/common/GroovyCommonUtil.java
Unescape Escape View File

@ -0,0 +1,11 @@
package cn.estsh.i3plus.pojo.bsp.common;
/**
* @Description :
* @Reference :
* @Author : Castle
* @CreateDate : 2021/7/22 15:38
* @Modify:
**/
public class GroovyCommonUtil {
}

296
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/common/HttpUtils.java
Unescape Escape View File

@ -1,147 +1,149 @@
package cn.estsh.i3plus.pojo.bsp.common; //package cn.estsh.i3plus.pojo.bsp.common;
//
import org.slf4j.Logger; //import cn.estsh.i3plus.pojo.base.bean.BaseResultBean;
import org.slf4j.LoggerFactory; //import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import javax.net.ssl.*; //
import java.io.BufferedReader; //import javax.net.ssl.*;
import java.io.DataOutputStream; //import java.io.BufferedReader;
import java.io.InputStreamReader; //import java.io.DataOutputStream;
import java.net.HttpURLConnection; //import java.io.InputStreamReader;
import java.net.URL; //import java.net.HttpURLConnection;
import java.security.cert.CertificateException; //import java.net.URL;
import java.security.cert.X509Certificate; //import java.security.cert.CertificateException;
//import java.security.cert.X509Certificate;
/** //
* @Description : ///**
* @Reference : // * @Description :
* @Author : Castle // * @Reference :
* @CreateDate : 2021/6/17 13:37 // * @Author : Castle
* @Modify: // * @CreateDate : 2021/6/17 13:37
**/ // * @Modify:
public class HttpUtils { // **/
private static Logger logger = LoggerFactory.getLogger(HttpUtils.class); //public class HttpUtils {
// private static Logger logger = LoggerFactory.getLogger(HttpUtils.class);
// trust-https start //
private static void trustAllHosts(HttpsURLConnection connection) { // // trust-https start
try { // private static void trustAllHosts(HttpsURLConnection connection) {
SSLContext sc = SSLContext.getInstance("TLS"); // try {
sc.init(null, trustAllCerts, new java.security.SecureRandom()); // SSLContext sc = SSLContext.getInstance("TLS");
SSLSocketFactory newFactory = sc.getSocketFactory(); // sc.init(null, trustAllCerts, new java.security.SecureRandom());
// SSLSocketFactory newFactory = sc.getSocketFactory();
connection.setSSLSocketFactory(newFactory); //
} catch (Exception e) { // connection.setSSLSocketFactory(newFactory);
logger.error(e.getMessage(), e); // } catch (Exception e) {
} // logger.error(e.getMessage(), e);
connection.setHostnameVerifier(new HostnameVerifier() { // }
@Override // connection.setHostnameVerifier(new HostnameVerifier() {
public boolean verify(String hostname, SSLSession session) { // @Override
return true; // public boolean verify(String hostname, SSLSession session) {
} // return true;
}); // }
} // });
// }
private static final TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() { //
@Override // private static final TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() { // @Override
return new X509Certificate[]{}; // public X509Certificate[] getAcceptedIssuers() {
} // return new X509Certificate[]{};
// }
@Override //
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { // @Override
} // public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
// }
@Override //
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { // @Override
} // public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}}; // }
// trust-https end // }};
// // trust-https end
//
/** //
* post // /**
* // * post
* @param url // *
* @param timeout // * @param url
* @param requestObj // * @param timeout
* @return // * @param requestObj
*/ // * @return
public static ReturnT postBody(String url, int timeout, Object requestObj) { // */
HttpURLConnection connection = null; // public static ResultBean postBody(String url, int timeout, Object requestObj) {
BufferedReader bufferedReader = null; // HttpURLConnection connection = null;
try { // BufferedReader bufferedReader = null;
// connection // try {
URL realUrl = new URL(url); // // connection
connection = (HttpURLConnection) realUrl.openConnection(); // URL realUrl = new URL(url);
// connection = (HttpURLConnection) realUrl.openConnection();
// trust-https //
boolean useHttps = url.startsWith("https"); // // trust-https
if (useHttps) { // boolean useHttps = url.startsWith("https");
HttpsURLConnection https = (HttpsURLConnection) connection; // if (useHttps) {
trustAllHosts(https); // HttpsURLConnection https = (HttpsURLConnection) connection;
} // trustAllHosts(https);
// }
// connection setting //
connection.setRequestMethod("POST"); // // connection setting
connection.setDoOutput(true); // connection.setRequestMethod("POST");
connection.setDoInput(true); // connection.setDoOutput(true);
connection.setUseCaches(false); // connection.setDoInput(true);
connection.setReadTimeout(timeout * 1000); // connection.setUseCaches(false);
connection.setConnectTimeout(3 * 1000); // connection.setReadTimeout(timeout * 1000);
connection.setRequestProperty("connection", "Keep-Alive"); // connection.setConnectTimeout(3 * 1000);
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); // connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); // connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
// connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8");
// do connection //
connection.connect(); // // do connection
// connection.connect();
// write requestBody //
if (requestObj != null) { // // write requestBody
String requestBody = GsonTool.toJson(requestObj); // if (requestObj != null) {
// String requestBody = GsonTool.toJson(requestObj);
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); //
dataOutputStream.write(requestBody.getBytes("UTF-8")); // DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.flush(); // dataOutputStream.write(requestBody.getBytes("UTF-8"));
dataOutputStream.close(); // dataOutputStream.flush();
} // dataOutputStream.close();
// }
// valid StatusCode //
int statusCode = connection.getResponseCode(); // // valid StatusCode
if (statusCode != 200) { // int statusCode = connection.getResponseCode();
// if (statusCode != 200) {
return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting fail, StatusCode(" + statusCode + ") invalid. for url : " + url); // return ResultBean.fail("rpc remoting fail, StatusCode(" + statusCode + ") invalid. for url : " + url);
} //// return new BaseResultBean().errorMsg("rpc remoting fail, StatusCode(" + statusCode + ") invalid. for url : " + url);
//// return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting fail, StatusCode(" + statusCode + ") invalid. for url : " + url);
// result // }
bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); //
StringBuilder result = new StringBuilder(); // // result
String line; // bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
while ((line = bufferedReader.readLine()) != null) { // StringBuilder result = new StringBuilder();
result.append(line); // String line;
} // while ((line = bufferedReader.readLine()) != null) {
String resultJson = result.toString(); // result.append(line);
// parse returnT // }
try { // String resultJson = result.toString();
return GsonTool.fromJson(resultJson, ReturnT.class); // // parse returnT
} catch (Exception e) { // try {
logger.error("rpc remoting (url=" + url + ") response content invalid(" + resultJson + ").", e); // return GsonTool.fromJson(resultJson, BaseResultBean.class);
return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting (url=" + url + ") response content invalid(" + resultJson + ")."); // } catch (Exception e) {
} // logger.error("rpc remoting (url=" + url + ") response content invalid(" + resultJson + ").", e);
} catch (Exception e) { // return ResultBean.fail("rpc remoting fail, StatusCode(" + statusCode + ") invalid. for url : " + url);
logger.error(e.getMessage(), e); // }
return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting error(" + e.getMessage() + "), for url : " + url); // } catch (Exception e) {
} finally { // logger.error(e.getMessage(), e);
try { // return ResultBean.fail("rpc remoting fail, error message(" + e.getMessage() + ") invalid. for url : " + url);
if (bufferedReader != null) { // } finally {
bufferedReader.close(); // try {
} // if (bufferedReader != null) {
if (connection != null) { // bufferedReader.close();
connection.disconnect(); // }
} // if (connection != null) {
} catch (Exception e2) { // connection.disconnect();
logger.error(e2.getMessage(), e2); // }
} // } catch (Exception e2) {
} // logger.error(e2.getMessage(), e2);
} // }
// }
} // }
//
//}

112
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/common/ReturnT.java
Unescape Escape View File

@ -1,56 +1,56 @@
package cn.estsh.i3plus.pojo.bsp.common; //package cn.estsh.i3plus.pojo.bsp.common;
//
import java.io.Serializable; //import java.io.Serializable;
//
/** ///**
* @author Castle // * @author Castle
*/ // */
public class ReturnT<T> implements Serializable { //public class ReturnT<T> implements Serializable {
public static final long serialVersionUID = 42L; // public static final long serialVersionUID = 42L;
//
public static final int SUCCESS_CODE = 200; // public static final int SUCCESS_CODE = 200;
public static final int FAIL_CODE = 500; // public static final int FAIL_CODE = 500;
//
public static final ReturnT<String> SUCCESS = new ReturnT<String>(null); // public static final ReturnT<String> SUCCESS = new ReturnT<String>(null);
public static final ReturnT<String> FAIL = new ReturnT<String>(FAIL_CODE, null); // public static final ReturnT<String> FAIL = new ReturnT<String>(FAIL_CODE, null);
//
private int code; // private int code;
private String msg; // private String msg;
private T content; // private T content;
//
public ReturnT(){} // public ReturnT(){}
public ReturnT(int code, String msg) { // public ReturnT(int code, String msg) {
this.code = code; // this.code = code;
this.msg = msg; // this.msg = msg;
} // }
//
public ReturnT(T content) { // public ReturnT(T content) {
this.code = SUCCESS_CODE; // this.code = SUCCESS_CODE;
this.content = content; // this.content = content;
} // }
//
public int getCode() { // public int getCode() {
return code; // return code;
} // }
public void setCode(int code) { // public void setCode(int code) {
this.code = code; // this.code = code;
} // }
public String getMsg() { // public String getMsg() {
return msg; // return msg;
} // }
public void setMsg(String msg) { // public void setMsg(String msg) {
this.msg = msg; // this.msg = msg;
} // }
public T getContent() { // public T getContent() {
return content; // return content;
} // }
public void setContent(T content) { // public void setContent(T content) {
this.content = content; // this.content = content;
} // }
//
@Override // @Override
public String toString() { // public String toString() {
return "ReturnT [code=" + code + ", msg=" + msg + ", content=" + content + "]"; // return "ReturnT [code=" + code + ", msg=" + msg + ", content=" + content + "]";
} // }
//
} //}

27
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/bean/model/RouteParam.java
Unescape Escape View File

@ -0,0 +1,27 @@
package cn.estsh.i3plus.pojo.bsp.server.bean.model;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.HashMap;
import java.util.List;
/**
* @Description :路由参数
* @Reference :
* @Author : Castle
* @CreateDate : 2021/7/5 14:02
* @Modify:
**/
@Data
@ApiModel("路由参数")
public class RouteParam {
@ApiModelProperty(value = "执行方法Id")
private Long methodId;
@ApiModelProperty(value = "路由的权重配置")
private HashMap<String,Integer> weightConfig;
@ApiModelProperty(value = "执行器地址列表")
private List<String> addressList;
}

14
modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/repository/ScriptRepository.java
Unescape Escape View File

@ -0,0 +1,14 @@
package cn.estsh.i3plus.pojo.bsp.server.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.bsp.client.bean.po.EngineScriptPersistence;
/**
* @Description :
* @Reference :
* @Author : Castle
* @CreateDate : 2021/7/22 13:51
* @Modify:
**/
public interface ScriptRepository extends BaseRepository<EngineScriptPersistence,Long> {
}
Write Preview
Loading…
Cancel
Save