Merge branch 'SZDAS_V2.0' into 'SZDAS_V2.1'

.project

 <?xml version="1.0" encoding="UTF-8"?>
 <projectDescription>
-    <name>aserver</name>
+	<name>aserver-szdas</name>
 	<comment></comment>
 	<projects>
 	</projects>

src/main/java/com/archser/aserver/common/config/MainConfig.java

 package com.archser.aserver.common.config;
 
 import com.alibaba.druid.filter.stat.StatFilter;
+import com.archser.aserver.common.config.plugins.RedisConfig;
 import com.archser.aserver.controller.*;
 import com.archser.aserver.interceptor.JwtInterceptor;
 import com.archser.aserver.itask.GoodSync;
 import com.archser.aserver.model._MappingKit;
 import com.archser.aserver.service.DBService;
+import com.archser.aserver.util.SharedDisk;
 import com.archser.aserver.websocket.MessageWebSocket;
 import com.jfinal.config.*;
 import com.jfinal.ext.handler.UrlSkipHandler;
@@ -19,7 +21,6 @@ import com.jfinal.plugin.activerecord.CaseInsensitiveContainerFactory;
 import com.jfinal.plugin.activerecord.dialect.*;
 import com.jfinal.plugin.cron4j.Cron4jPlugin;
 import com.jfinal.plugin.druid.DruidPlugin;
-import com.jfinal.plugin.redis.RedisPlugin;
 import com.jfinal.render.ViewType;
 import com.jfinal.server.undertow.UndertowServer;
 import com.jfinal.server.undertow.WebBuilder;
@@ -110,19 +111,21 @@ public class MainConfig extends JFinalConfig {
       p = PropKit.use("AppConfig.properties").appendIfExists("AppConfig-pro.properties");
       ClassLoader path = Thread.currentThread().getContextClassLoader();
       try {
-        String resources = path.getResource("AppConfig.properties").toURI().getPath().replace("AppConfig.properties","");
+        String resources = path.getResource("AppConfig.properties").toURI().getPath()
+            .replace("AppConfig.properties", "");
         p.getProperties().put("resources", resources);
       } catch (Exception e) {
         e.printStackTrace();
       }
       ConfirmMiddlewareType(p);
+      new SharedDisk(p);
     }
   }
 
   /**
+   * @return void
    * @Description: 确认中间件类型获取打包后的resource
    * @authorAndDate: ChengYaqing create on 2021/1/14 9:23
-   * @return void
    */
   public static void ConfirmMiddlewareType(Prop p) {
     String basePath;
@@ -167,15 +170,12 @@ public class MainConfig extends JFinalConfig {
     /******** 在此添加数据库 表-Model 映射 *********/
     // 如果使用了JFinal Model 生成器 生成了BaseModel 把下面注释解开即可
     _MappingKit.mapping(arp);
-
     // 添加到插件列表中
     me.add(dbPlugin);
     me.add(arp);
 
-//   添加Redis 配置
-    RedisPlugin redis = new RedisPlugin("redis", PropKit.get("redis.url"),PropKit.getInt("redis.port"),
-        PropKit.get("redis.password"));
-    me.add(redis);
+//    配置Redis信息，自动判断单实例和集群并加入JFinal插件列表
+    new RedisConfig(me, p);
 
 //  添加定时任务
     me.add(new Cron4jPlugin(PropKit.append("task.properties")));
@@ -243,7 +243,6 @@ public class MainConfig extends JFinalConfig {
 
   /**
    * 添加websocket
-   *
    * @param builder
    */
   public static void addWebSocket(WebBuilder builder) {
@@ -254,7 +253,6 @@ public class MainConfig extends JFinalConfig {
 
   /**
    * 添加消息中心的websocket
-   *
    * @param builder
    */
   public static void addMessageWebSocket(WebBuilder builder) {

src/main/java/com/archser/aserver/common/config/plugins/RedisConfig.java

+package com.archser.aserver.common.config.plugins;
+
+import com.archser.aserver.plugin.redis.RedisSentinelPlugin;
+import com.jfinal.config.Plugins;
+import com.jfinal.kit.Prop;
+import com.jfinal.plugin.redis.RedisPlugin;
+import java.util.HashSet;
+import java.util.Set;
+import redis.clients.jedis.HostAndPort;
+
+/**
+ * TODO 自定义Redis配置，提取逻辑判断，避免在主类中掺杂大量代码
+ * @author 李德才
+ * @version V2.0
+ * @date 2021/3/4 9:02
+ */
+
+public class RedisConfig {
+
+
+  public RedisConfig(Plugins plugins, Prop prop) {
+    String redisUrl = prop.get("redis.url");
+    //    哨兵配置
+    if (redisUrl.contains(",")) {
+      Set<HostAndPort> sentinels = new HashSet<HostAndPort>();
+      String[] split = redisUrl.split(",");
+      int port = 26379;
+      for (String item : split) {
+        if (item.contains(":")) {
+          port = Integer.parseInt(item.split(":")[1]);
+        }
+        sentinels.add(new HostAndPort(item.split(":")[0], port));
+      }
+      RedisSentinelPlugin redisSentinelPlugin = new RedisSentinelPlugin(
+          prop.get("redisSentinel.CacheName", "redisSentinel"),
+          prop.get("redisSentinel.masterName", "mymaster"),
+          sentinels, prop.get("redis.password", "archser_redis"));
+      plugins.add(redisSentinelPlugin);
+    } else {
+      //    普通Redis单实例配置
+      RedisPlugin redis = new RedisPlugin("redis", prop.get("redis.url"),
+          prop.getInt("redis.port", 6379),
+          prop.get("redis.password"));
+      plugins.add(redis);
+    }
+  }
+
+
+}

src/main/java/com/archser/aserver/plugin/redis/ICache.java

+package com.archser.aserver.plugin.redis;
+
+/**
+ * TODO
+ * @author 李德才
+ * @version V2.0
+ * @date 2021/3/3 14:52
+ */
+
+import com.jfinal.plugin.redis.Cache;
+import com.jfinal.plugin.redis.IKeyNamingPolicy;
+import com.jfinal.plugin.redis.serializer.ISerializer;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisSentinelPool;
+
+
+public class ICache extends Cache {
+
+  private JedisSentinelPool jedisSentinelPool;
+
+  /**
+   * TODO JFinal 自带的 Cache要求传入 JedisPool，无法满足哨兵需求，重写连接属性和获取Jedis对象方法
+   * @author 李德才
+   * @date 2021/3/3 16:41
+   * @return
+   */
+
+  public ICache(String name, JedisSentinelPool jedisSentinelPool, ISerializer serializer,
+      IKeyNamingPolicy keyNamingPolicy) {
+    try {
+      super.name = name;
+      super.serializer = serializer;
+      super.keyNamingPolicy = keyNamingPolicy;
+      super.threadLocalJedis.set(jedisSentinelPool.getResource());
+      this.jedisSentinelPool = jedisSentinelPool;
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+  }
+
+  @Override
+  public Jedis getJedis() {
+    Jedis jedis = threadLocalJedis.get();
+    return jedis != null ? jedis : jedisSentinelPool.getResource();
+  }
+}

src/main/java/com/archser/aserver/plugin/redis/RedisSentinelPlugin.java

+package com.archser.aserver.plugin.redis;
+
+import com.jfinal.kit.StrKit;
+import com.jfinal.plugin.IPlugin;
+import com.jfinal.plugin.redis.IKeyNamingPolicy;
+import com.jfinal.plugin.redis.Redis;
+import com.jfinal.plugin.redis.serializer.FstSerializer;
+import com.jfinal.plugin.redis.serializer.ISerializer;
+import java.util.HashSet;
+import java.util.Set;
+import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
+import redis.clients.jedis.HostAndPort;
+import redis.clients.jedis.JedisSentinelPool;
+import redis.clients.jedis.Protocol;
+
+/**
+ * TODO 自定义JFinal sentinel 集群下的 Redis 插件
+ * @author 李德才
+ * @version V2.0
+ * @date 2021/3/2 17:14
+ */
+
+public class RedisSentinelPlugin implements IPlugin {
+
+  private String cacheName;
+
+  private String masterName = null;
+  private int connectionTimeout = Protocol.DEFAULT_TIMEOUT;
+  private String password = null;
+  private int database = Protocol.DEFAULT_DATABASE;
+  private Set<String> sentinels = new HashSet<String>();
+  private ISerializer serializer;
+  private IKeyNamingPolicy keyNamingPolicy;
+  private GenericObjectPoolConfig poolConfig;
+
+  ICache iCache;
+
+
+  public RedisSentinelPlugin(String cacheName, String masterName, Set<HostAndPort> sentinels,
+      String password) {
+    this(cacheName, masterName, sentinels, new GenericObjectPoolConfig(), Protocol.DEFAULT_TIMEOUT,
+        password);
+  }
+
+  public RedisSentinelPlugin(String cacheName, String masterName, Set<HostAndPort> sentinels,
+      final GenericObjectPoolConfig poolConfig, int timeout, final String password) {
+    this(cacheName, masterName, sentinels, poolConfig, timeout, password,
+        Protocol.DEFAULT_DATABASE);
+  }
+
+  public RedisSentinelPlugin(String cacheName, String masterName, Set<HostAndPort> sentinels,
+      final GenericObjectPoolConfig poolConfig, int timeout, final String password,
+      final int database) {
+    this(cacheName, masterName, sentinels, poolConfig, timeout, timeout, password, database);
+  }
+
+  public RedisSentinelPlugin(String cacheName, String masterName, Set<HostAndPort> sentinels,
+      final GenericObjectPoolConfig poolConfig,
+      final int timeout, final int soTimeout, final String password,
+      final int database) {
+    this(cacheName, masterName, sentinels, poolConfig, timeout, soTimeout,
+        password, database, null);
+  }
+
+  public RedisSentinelPlugin(String cacheName, String masterName,
+      Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
+      final int connectionTimeout, final int soTimeout,
+      final String password, final int database, final String clientName) {
+    if (StrKit.isBlank(cacheName)) {
+      throw new IllegalArgumentException("cacheName can not be blank.");
+    }
+    if (StrKit.isBlank(masterName)) {
+      throw new IllegalArgumentException("masterName can not be blank.");
+    }
+    if (null == sentinels || sentinels.isEmpty()) {
+      throw new IllegalArgumentException("sentinels can not be blank.");
+    }
+    if (null == poolConfig) {
+      throw new IllegalArgumentException("poolConfig can not be null.");
+    }
+    for (HostAndPort hp : sentinels) {
+      this.sentinels.add(hp.toString());
+    }
+    this.cacheName = cacheName.trim();
+    this.masterName = masterName.trim();
+    this.poolConfig = poolConfig;
+    this.connectionTimeout = connectionTimeout;
+    this.password = password;
+    this.database = database;
+
+  }
+
+  public boolean start() {
+    JedisSentinelPool jedisSentinelPool = new JedisSentinelPool(masterName, sentinels, poolConfig,
+        connectionTimeout, password, database);
+    if (serializer == null) {
+      serializer = FstSerializer.me;
+    }
+    if (keyNamingPolicy == null) {
+      keyNamingPolicy = IKeyNamingPolicy.defaultKeyNamingPolicy;
+    }
+    iCache = new ICache(cacheName, jedisSentinelPool, serializer, keyNamingPolicy);
+    Redis.addCache(iCache);
+    return true;
+  }
+
+  public boolean stop() {
+    try {
+      iCache.getJedis().close();
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+    return true;
+  }
+
+}
+
+

src/main/java/com/archser/aserver/util/SharedDisk.java

+package com.archser.aserver.util;
+
+
+import com.jfinal.kit.Prop;
+import com.jfinal.kit.PropKit;
+import com.jfinal.kit.StrKit;
+import java.io.File;
+
+/**
+ * TODO 根据项目配置文件确定临时文件存放位置
+ * @author 李德才
+ * @version V2.0
+ * @date 2021/3/8 9:40
+ */
+
+public class SharedDisk {
+
+  protected static String sharedDiskPath = null;
+
+  public static String getSharedDiskPath() {
+    return sharedDiskPath;
+  }
+
+  public static void setSharedDiskPath(String sharedDiskPath) {
+    SharedDisk.sharedDiskPath = sharedDiskPath;
+  }
+
+
+  public SharedDisk(Prop p) {
+    String sharedDisk = PropKit.get("SharedDisk");
+//    确定存在临时文件共享磁盘
+    if (StrKit.notBlank(sharedDisk) && new File(sharedDisk).isDirectory()) {
+      sharedDiskPath = sharedDisk + File.separator + PropKit.get("serverType");
+      if (!new File(sharedDiskPath).exists()) {
+        new File(sharedDiskPath).mkdirs();
+      }
+    }
+//    不存在临时文件共享磁盘或磁盘地址不可用，
+    if (StrKit.isBlank(sharedDisk) || !new File(sharedDisk).isDirectory()) {
+      sharedDiskPath = p.getProperties().get("resourcesPath").toString();
+    }
+  }
+
+
+}

src/main/resources/AppConfig-pro.properties

@@ -2,6 +2,7 @@
 
 # \u6570\u636E\u5E93
 
+serverType=aserver
 
 #oracle\u6570\u636E\u5E93
 #dbType=ORACLE
@@ -38,20 +39,31 @@ jdbc.password=archser_hywdtest
 #\u4E2D\u95F4\u4EF6\u7C7B\u578B \u6C49\u8BED\u62FC\u97F3 zhongchaung\u3001dongfangtong\u3001baolande\u3001jindie\u3001dev
 MiddlewareType=dev
 
-# redis\u914D\u7F6E
-redis.url=127.0.0.1
-redis.port=6379
-redis.password=archser_redis
+
+### don't open redis and redisSentinel At the same time
+### \u4E0D\u8981\u540C\u65F6\u6253\u5F00 redis  \u5355\u5B9E\u4F8B \u548C redisSentinel \u54E8\u5175\u96C6\u7FA4
+
+# redis  \u5355\u5B9E\u4F8B
+#redis.url=192.168.31.151:26379,192.168.31.154:26379,192.168.31.157:26379
+redis.url=39.104.21.218
+redis.port=6380
+redis.password=archser_redis218_6380
+redisSentinel.CacheName=redisSentinel
+redisSentinel.masterName=mymaster
 
 #\u5355\u70B9\u767B\u9646\u5730\u5740
 basic.url=http://39.104.21.218:11038
 ## \u662F\u5426\u540C\u6B65Redis\u4E2D\u7684\u6570\u636E
 updateRedis=true
 
+## \u4E34\u65F6\u6587\u4EF6\u5171\u4EAB\u78C1\u76D8\u8DEF\u5F84
+SharedDisk=D:\\workspace\\fserver_folder\\SharedDisk
+
 #ip\u767D\u540D\u5355\uFF0C\u914D\u7F6E\u672C\u673A\u5730\u5740
 MyIpAddress=127.0.0.1,0:0:0:0:0:0:0:1
 
 #activemq
+#activemq.brokerURL=failover://(tcp://192.168.31.151:61616,tcp://192.168.31.154:61616,tcp://192.168.31.157:61616)
 activemq.brokerURL=tcp://39.104.21.218:61616
 
 authUrl=http://125.77.26.133:7001/auth/token
@@ -163,8 +175,10 @@ FserverName=fserver
 #================sserver=================================
 
 #Elasticsearch\u670D\u52A1\u5668\u8BBE\u7F6E
+#es.host=192.168.31.151:9200,192.168.31.154:9200,192.168.31.157:9200
 es.host=39.104.21.218
 es.port=9200
+es.http=http
 es.user=es
 es.password=Admin@123456
 

src/main/resources/DBUpdate/DM_UpdateSQL.xml

@@ -2493,7 +2493,7 @@
 	<version edition="105" description="218AS_LIBRARY_FILE表添加宽度">
 		<sql creator="yangrifei" createDate="20201204"
 			note="218AS_LIBRARY_FILE表添加宽度">
-			alter table AS_LIBRARY_FILE add WIDTH varchar(9);
+			alter table AS_LIBRARY_FILE add WIDTH NUMBER(9,0);
 		</sql>
 	</version>
 
@@ -2962,7 +2962,40 @@
 			alter table AS_FILE_RECYLE add "ecert_sign" VARCHAR2(50);
 		</sql>
 	</version>
-	<!-- <version edition="137" description="帮助中心">
+	<version edition="137" description="编研管理添加名称简述字段">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加名称简述字段">
+			alter table AS_COMPILATION_CKEDITOR add "NAME" varchar2(100);
+      		alter table AS_COMPILATION_CKEDITOR add "SKETCH" varchar2(500);
+		</sql>
+	</version>
+	<version edition="138" description="编研管理添加序列">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加序列">
+			create sequence SEQ_COMPILATION_CKEDITOR
+			minvalue 1
+			maxvalue 999999999 
+			start with 1
+			increment by 1 
+			nocycle
+			nocache;
+		</sql>
+	</version>
+	<version edition="139" description="统计服务方案表">
+		<sql creator="ChengYaqing" createDate="20210315" note="方案表">CREATE TABLE "AS_PROGRAMME" (
+			ID NUMBER(9,0) NOT NULL,
+			NAME VARCHAR2(500),
+			CREATE_USER VARCHAR2(100),
+			CREATE_TIME VARCHAR2(100),
+			DESCRIPTION VARCHAR2(500),
+			FONDS_NUMBER VARCHAR2(100),
+			PRIMARY KEY("ID")
+			)</sql>
+		<sql creator="ChengYaqing" createDate="20210315" note="序列">
+			CREATE SEQUENCE
+			"SEQ_AS_PROGRAMME" INCREMENT BY 1 START WITH 1 MAXVALUE
+			9999999999999999 MINVALUE 1 CACHE 20;
+		</sql>
+	</version>
+	<version edition="140" description="帮助中心">
         <sql creator="liukexin" createDate="20210301" note="帮助中心">
             CREATE TABLE "AS_HELPER"
             (
@@ -2975,7 +3008,7 @@
             create sequence AS_HELPER_SEQ  start with 1 increment by 1 maxvalue 99999999999
         </sql>
     </version>
-	<version edition="138" description="帮助中心菜单">
+	<version edition="141" description="帮助中心菜单">
 	    <sql creator="liukexin" createDate="20210301" note="帮助中心">
 			insert into
 			AS_MENU(ID,NAME,TITLE,DESCRIPTION,PATH,SYSTEM_ID,FIRST_LEVEL_NAME,SECOND_LEVEL_NAME,GROUP_ORDER)
@@ -2985,7 +3018,7 @@
 			values(SEQ_MENU.nextval,'helpCenter','帮助中心管理','帮助中心管理','#/helpManager',9,'后台管理','系统管理',4);
 		</sql>
 	</version>
-	<version edition="139" description="设置首页">
+	<version edition="142" description="设置首页">
         <sql creator="liukexin" createDate="20210309" note="设置首页">
             CREATE TABLE "AS_USER_HOME"
             (
@@ -2995,5 +3028,6 @@
             "SYSTEM" VARCHAR(100),
             CLUSTER PRIMARY KEY("ID")) STORAGE(ON "MAIN", CLUSTERBTR) ;
         </sql>
-    </version>  -->
+    </version>
+
 </update>
\ No newline at end of file

src/main/resources/DBUpdate/KingBase_UpdateSQL.xml

@@ -2490,7 +2490,7 @@
 	<version edition="105" description="218AS_LIBRARY_FILE表添加宽度">
 		<sql creator="yangrifei" createDate="20201204"
 			note="218AS_LIBRARY_FILE表添加宽度">
-			alter table AS_LIBRARY_FILE add WIDTH varchar(9);
+			alter table AS_LIBRARY_FILE add WIDTH NUMBER(9,0);
 		</sql>
 	</version>
 
@@ -2948,4 +2948,18 @@
 		</sql>
 	</version>
 	
+	
+	<version edition="135" description="编研管理添加名称简述字段">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加名称简述字段">
+			alter table AS_COMPILATION_CKEDITOR add "NAME" varchar2(100);
+      		alter table AS_COMPILATION_CKEDITOR add "SKETCH" varchar2(500);
+		</sql>
+	</version>
+	
+	<version edition="136" description="编研管理添加序列">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加序列">
+			CREATE SEQUENCE "SEQ_COMPILATION_CKEDITOR" INCREMENT BY 1 START WITH 1 MAXVALUE 99999999999999 MINVALUE 1 CACHE 20;
+		</sql>
+	</version>
+
 </update>
\ No newline at end of file

src/main/resources/DBUpdate/ST_UpdateSQL.xml

@@ -2492,7 +2492,7 @@
 	<version edition="105" description="218AS_LIBRARY_FILE表添加宽度">
 		<sql creator="yangrifei" createDate="20201204"
 			note="218AS_LIBRARY_FILE表添加宽度">
-			alter table AS_LIBRARY_FILE add WIDTH varchar(9);
+			alter table AS_LIBRARY_FILE add WIDTH NUMBER(9,0);
 		</sql>
 	</version>
 
@@ -2951,4 +2951,24 @@
 		</sql>
 	</version>
 	
+	<version edition="135" description="编研管理添加名称简述字段">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加名称简述字段">
+			alter table AS_COMPILATION_CKEDITOR add "NAME" varchar2(100);
+      		alter table AS_COMPILATION_CKEDITOR add "SKETCH" varchar2(500);
+		</sql>
+	</version>
+	
+	
+	<version edition="136" description="编研管理添加序列">
+		<sql creator="zhanglongfa" createDate="20210302" note="编研管理添加序列">
+			create sequence SEQ_COMPILATION_CKEDITOR
+			minvalue 1
+			maxvalue 999999999 
+			start with 1
+			increment by 1 
+			nocycle
+			nocache;
+		</sql>
+	</version>
+
 </update>
\ No newline at end of file