添加定时器，每天晚上一点定时更新数据

pom.xml

@@ -76,6 +76,13 @@
 			<version>${jfinalundertow.version}</version>
 		</dependency>
 
+		<!--引入定时器任务 -->
+		<dependency>
+			<groupId>it.sauronsoftware.cron4j</groupId>
+			<artifactId>cron4j</artifactId>
+			<version>2.2.5</version>
+		</dependency>
+
 		<!-- WebSocket 支持 -->
 		<dependency>
 			<groupId>io.undertow</groupId>

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

@@ -11,6 +11,7 @@ import com.archser.aserver.controller.SettingController;
 import com.archser.aserver.controller.SystemController;
 import com.archser.aserver.controller.UserController;
 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.websocket.MessageWebSocket;
@@ -28,6 +29,7 @@ import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
 import com.jfinal.plugin.activerecord.CaseInsensitiveContainerFactory;
 import com.jfinal.plugin.activerecord.dialect.OracleDialect;
+import com.jfinal.plugin.cron4j.Cron4jPlugin;
 import com.jfinal.plugin.druid.DruidPlugin;
 import com.jfinal.plugin.redis.RedisPlugin;
 import com.jfinal.render.ViewType;
@@ -77,8 +79,6 @@ public class MainConfig extends JFinalConfig {
     // 推荐拆分方式 如果需要就解开注释 创建对应的 Routes
 
     // me.add(new WechatRoutes());//配置微信端访问路由
-
-
     // 普通不拆分的方式配置 如下
     // 设置默认访问首页路由 可使用http://localhost:port 直接访问 如果80端口 port可以省略
     me.add("/", IndexController.class);
@@ -135,6 +135,8 @@ public class MainConfig extends JFinalConfig {
     RedisPlugin redis = new RedisPlugin("redis", PropKit.get("redis.url"), PropKit.get("redis.password"));
   me.add(redis);
 
+//  添加定时任务
+    me.add(new Cron4jPlugin(PropKit.use("task.properties")));
 
   }
 
@@ -176,6 +178,7 @@ public class MainConfig extends JFinalConfig {
     String configPath=PathKit.getRootClassPath()+"/DBUpdate/";
     DBService dbService= new DBService();
     dbService.upgrade(configPath, dbType);
+    new GoodSync().run();
   }
 
   /**

src/main/java/com/archser/aserver/itask/GoodSync.java

+package com.archser.aserver.itask;
+
+import com.archser.aserver.model.Organ;
+import com.archser.aserver.model.System;
+import com.archser.aserver.model.User;
+import com.archser.aserver.util.redis.InfoOrgan;
+import com.archser.aserver.util.redis.InfoSystem;
+import com.archser.aserver.util.redis.InfoUser;
+import com.jfinal.plugin.cron4j.ITask;
+
+
+/**
+ * 同步数据
+ */
+public class GoodSync implements ITask {
+
+  @Override
+  public void stop() {
+
+  }
+
+  @Override
+  public void run() {
+//    同步用户数据
+    User.dao.findAll().forEach(InfoUser::saveUser);
+//    同步系统数据
+    System.dao.findAll().forEach(InfoSystem::saveSystem);
+//    同步机构数据
+    Organ.dao.findAll().forEach(InfoOrgan::saveOrgan);
+  }
+}

src/main/resources/config-pro.properties

@@ -13,17 +13,17 @@ authUrl=http://125.77.26.133:7001/auth/token
 userInfoUrl=http://125.77.26.133:7001/api/info/user_info
 redirect_uri=http://192.168.31.17:8080/
 
-redis.url=39.104.174.12
+redis.url=39.104.21.218
 redis.password=archser_redis
 
 # --- 消息中心websocket配置 ---
 ##  定时发送消息的周期   单位毫秒
-messageWsDelay=5000
+messageWsDelay=50000
 ##  延期，第二次发送消息的延期时间，第一次发送在开始连接时就会发送 单位毫秒
-messageWsPeriod=5000
+messageWsPeriod=50000
 ## 消息发送成功后，等待客户端反馈时间，超出此时间表示连接已经断开，会关闭连接 单位毫秒
 messageWsTimeout=30000
 ## 是否开启消息中心的websocket
 openMessageWebSocket=true
 
-MyIpAddress=127.0.0.1,39.104.28.145,39.104.174.12
\ No newline at end of file
+MyIpAddress=127.0.0.1,39.104.28.145,39.104.21.218
\ No newline at end of file