添加GatewayTool配置。

Author: xwintop

src/main/java/com/easipass/gateway/datasource/bean/DataSourceConfig.java

@@ -0,0 +1,15 @@
+package com.easipass.gateway.datasource.bean;
+
+import java.io.Serializable;
+/**
+ * @ClassName: DataSourceConfig
+ * @Description: 数据源配置
+ * @author: xufeng
+ * @date: 2018/12/6 17:15
+ */
+
+public interface DataSourceConfig extends Serializable {
+    String getId();
+    void setId(String id);
+    boolean isEnable();//是否开启
+}

src/main/java/com/easipass/gateway/datasource/bean/DataSourceConfigDruid.java

@@ -0,0 +1,30 @@
+package com.easipass.gateway.datasource.bean;
+
+import lombok.Data;
+
+@Data
+public class DataSourceConfigDruid implements DataSourceConfig {
+    private String id;//获取数据源时唯一标识，全局不能重复
+    private boolean enable = true;//是否开启
+
+    private String url;//数据库连接url
+    private String username;//用户名
+    private String password;//密码
+    private boolean decrypt = false;//是否使用加密
+    private String publicKey;//加密公钥
+    private String driverClassName = "oracle.jdbc.OracleDriver";
+    private int initialSize = 5;
+    private int minIdle = 5;
+    private int maxActive = 30;
+    private int maxWait = 60000;
+    private int timeBetweenEvictionRunsMillis = 60000;
+    private int minEvictableIdleTimeMillis = 30000;
+    private String validationQuery = "SELECT 1 FROM DUAL";
+    private boolean testWhileIdle = true;
+    private boolean testOnBorrow = false;
+    private boolean testOnReturn = false;
+    private boolean poolPreparedStatements = true;
+    private int maxPoolPreparedStatementPerConnectionSize = 20;
+    private String filters = "stat,wall,slf4";
+    private String connectionProperties = "druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000";
+}

src/main/java/com/easipass/gateway/datasource/package-info.java

@@ -0,0 +1,6 @@
+package com.easipass.gateway.datasource;
+/**
+ * @Description: 数据源管理
+ * @author: xufeng
+ * @date: 2018/12/6 17:09
+ */

src/main/java/com/easipass/gateway/entity/TaskConfig.java

@@ -0,0 +1,47 @@
+package com.easipass.gateway.entity;
+
+import com.easipass.gateway.filter.bean.FilterConfig;
+import com.easipass.gateway.quartz.enums.QuartzTypeEnum;
+import com.easipass.gateway.receiver.entity.ReceiverConfig;
+import com.easipass.gateway.route.entity.SenderConfig;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName: TaskConfig
+ * @Description: 任务配置
+ * @author: xufeng
+ * @date: 2018/6/13 16:17
+ */
+@Data
+public class TaskConfig implements Serializable {
+    private String name;//任务名称(唯一标识，不可重复)
+    private Boolean isEnable = true;//是否开启
+    private String taskType;//任务类型(script/receiver/execute flow)
+    private String triggerType = QuartzTypeEnum.SIMPLE.name();//触发器类型(simple/cron)
+    private Integer intervalTime = 5;//两次任务调度的间隔时间(simple类型触发器显示该信息)，单位为秒
+    private Integer executeTimes = -1;//任务执行次数(simple类型触发器显示该信息，-1表示无限次)
+    private String triggerCron;//任务调度的时间(cron类型触发器显示该信息)
+    private Boolean isStatefulJob = false;//是否为有状态的job
+
+    private List<ReceiverConfig> receiverConfig = new ArrayList<>();//接收器配置集合
+
+    private List<FilterConfig> filterConfigs = new ArrayList<>();//过滤器配置集合
+
+    private List<SenderConfig> senderConfig = new ArrayList<>();//发送器配置集合
+
+    private Map<String, Object> properties = new HashMap();//附加配置属性
+
+    public Object getProperty(String key) {
+        return properties.get(key);
+    }
+
+    public void setProperty(String key, Object value) {
+        properties.put(key, value);
+    }
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfig.java

@@ -0,0 +1,19 @@
+package com.easipass.gateway.filter.bean;
+
+import java.io.Serializable;
+
+/**
+ * @ClassName: FilterConfig
+ * @Description: 中间层过滤类配置
+ * @author: xufeng
+ * @date: 2018/5/28 16:32
+ */
+
+public interface FilterConfig extends Serializable {
+    String getServiceName();
+    String getId();
+    void setId(String id);
+    boolean isEnable();//是否开启
+    boolean isAsync();//是否异步执行
+    boolean isExceptionExit();//是否发生异常时退出任务
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfigBackup.java

@@ -0,0 +1,26 @@
+package com.easipass.gateway.filter.bean;
+
+import com.easipass.gateway.filter.enums.StrategyEnum;
+import lombok.Data;
+
+/**
+ * @ClassName: FilterConfigBackup
+ * @Description: 消息备份操作配置
+ * @author: xufeng
+ * @date: 2018/5/28 16:34
+ */
+@Data
+public class FilterConfigBackup implements FilterConfig {
+    private String serviceName = "filterBackup";//对应服务名称
+    private String id;//如果留空则系统自动分配
+    private boolean enable = true;//是否开启
+    private boolean async = false;//是否异步执行
+    private boolean exceptionExit = true;//是否发生异常时退出任务
+
+    private String path;//备份目录
+    private String tmpPath;//备份缓冲路径(留空为不使用缓冲目录)
+    private boolean createPathFlag = false;//是否自动创建目录
+    private String fileNameVar;//文件名模版
+    private String strategy = StrategyEnum.direct.name();//文件目录策略（direct、day、hour、day_hour）
+    private boolean overload = false;//是否覆盖重名文件
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfigCompress.java

@@ -0,0 +1,26 @@
+package com.easipass.gateway.filter.bean;
+
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName: FilterConfigCompress
+ * @Description: 消息压缩操作配置
+ * @author: xufeng
+ * @date: 2018/6/26 14:28
+ */
+
+@Data
+public class FilterConfigCompress implements FilterConfig {
+    private String serviceName = "filterCompress";//对应服务名称
+    private String id;//如果留空则系统自动分配
+    private boolean enable = true;//是否开启
+    private boolean async = false;//是否异步执行
+    private boolean exceptionExit = false;//是否发生异常时退出任务
+
+    private boolean isAddPostfixName = true;//是否添加压缩后缀名
+    private String method = "zip";//压缩类型
+    private Map args = new HashMap();
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfigDataBusSender.java

@@ -0,0 +1,37 @@
+package com.easipass.gateway.filter.bean;
+
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName: FilterConfigDataBusSender
+ * @Description: 数据总线发送配置
+ * @author: xufeng
+ * @date: 2018/5/30 17:18
+ */
+
+@Data
+public class FilterConfigDataBusSender implements FilterConfig {
+    private String serviceName = "filterDataBusSender";//对应服务名称
+    private String id;//如果留空则系统自动分配
+    private boolean enable = true;//是否开启
+    private boolean async = false;//是否异步执行
+    private boolean exceptionExit = true;//是否发生异常时退出任务
+    private Map args = new HashMap();//自定义参数
+
+    private String topic;
+
+    private String sender;//发送方
+    private String receiver;//接收方
+    private String appCode;//应用标识
+    private String type;//消息类型标识 被包装报文的类型（xml、ediflat等），这个应该在DBus中备案。
+    private String format;//消息遵循的标准体系标识。例如EDIFLAT，EDIFACT等。这个标识需要在DBus中备案。
+    private String version;//封套消息格式版本(用于标识封套自己的格式版本，非被封装报文和消息的版本。当前为1.0,非必填，默认为1.0。)
+    private String encoding;//需要与报文内容编码一致（留空则默认取msg中encoding）
+    private String mimeType = "text/plain";//报文媒体类型
+
+    private String plogType;//应用消息处理类型
+    private String plogInfo;//应用消息处理说明
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfigDecMsgToDataBus.java

@@ -0,0 +1,37 @@
+package com.easipass.gateway.filter.bean;
+
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName: FilterConfigDecMsgToDataBus
+ * @Description: 报关单传输发送配置
+ * @author: xufeng
+ * @date: 2018/5/30 17:18
+ */
+
+@Data
+public class FilterConfigDecMsgToDataBus implements FilterConfig {
+    private String serviceName = "filterDecMsgToDataBus";//对应服务名称
+    private String id;//如果留空则系统自动分配
+    private boolean enable = true;//是否开启
+    private boolean async = false;//是否异步执行
+    private boolean exceptionExit = true;//是否发生异常时退出任务
+    private Map args = new HashMap();//自定义参数
+
+    private String topic;
+
+    private String sender;//发送方
+    private String receiver;//接收方
+    private String appCode;//应用标识
+    private String type;//消息类型标识 被包装报文的类型（xml、ediflat等），这个应该在DBus中备案。
+    private String format;//消息遵循的标准体系标识。例如EDIFLAT，EDIFACT等。这个标识需要在DBus中备案。
+    private String version;//封套消息格式版本(用于标识封套自己的格式版本，非被封装报文和消息的版本。当前为1.0,非必填，默认为1.0。)
+    private String encoding;//需要与报文内容编码一致（留空则默认取msg中encoding）
+    private String mimeType = "text/plain";//报文媒体类型
+
+    private String plogType;//应用消息处理类型
+    private String plogInfo;//应用消息处理说明
+}

src/main/java/com/easipass/gateway/filter/bean/FilterConfigDecompress.java

@@ -0,0 +1,25 @@
+package com.easipass.gateway.filter.bean;
+
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName: FilterConfigDecompress
+ * @Description: 消息解压操作配置
+ * @author: xufeng
+ * @date: 2018/5/29 16:38
+ */
+@Data
+public class FilterConfigDecompress implements FilterConfig {
+    private String serviceName = "filterDecompress";//对应服务名称
+    private String id;//如果留空则系统自动分配
+    private boolean enable = true;//是否开启
+    private boolean async = false;//是否异步执行
+    private boolean exceptionExit = false;//是否发生异常时退出任务
+
+    private String method = "zip";//解压类型
+    private String encoding;      //文件编码
+    private Map args = new HashMap();
+}