去掉相关注释掉的代码

lab-service/lab-system/target/classes/application-dev.yml

@@ -0,0 +1,3 @@
+#服务器端口
+server:
+  port: 8003

lab-service/lab-user/src/main/java/org/springblade/system/user/UserApplication.java

@@ -23,10 +23,5 @@ public class UserApplication {
 	public static void main(String[] args) {
 		BladeApplication.run(AppConstant.APPLICATION_USER_NAME, UserApplication.class, args);
 	}
-//	@Bean
-//	public MessageConverter jsonMessageConverter(){
-//		return new Jackson2JsonMessageConverter();
-//	}
-
 
 }

lab-service/lab-user/src/main/java/org/springblade/system/user/mettinghandler/MettingRemindHandler.java

@@ -35,14 +35,15 @@ public class MettingRemindHandler implements  RedissonDelayQueuHandlle<String>{
         wrapper.eq(TrainPerson::getTrainId, id);
         List<TrainPerson> list = trainPersonService.list(wrapper);
         Train train = trainService.getById(id);
-//        if (list.size() > 0) {
+        //分别为讲师和培训者增加延迟消息提醒
-//            list.forEach(person -> {
+        if (list.size() > 0) {
-//                messageClient.event(SysTypeEnum.INFORM.getValue(), "会议提醒",
+            list.forEach(person -> {
-//                        "您有新的会议将在" + train.getDuration() + "分钟后开始，请准时参加！", 1, 5, person.getPersonName(), "/train/project");
+                messageClient.event(SysTypeEnum.INFORM.getValue(), "会议提醒",
-//            });
+                        "您有新的会议将在" + train.getDuration() + "分钟后开始，请准时参加！", 1, 5, person.getPersonName(), "/train/project");
-//        }
+            });
-//        messageClient.event(SysTypeEnum.INFORM.getValue(), "会议提醒",
+        }
-//                "您有新的会议将在" + train.getDuration() + "分钟后开始，请准时参加！", 1, 5, train.getTeacherName(), "/train/project");
+        messageClient.event(SysTypeEnum.INFORM.getValue(), "会议提醒",
+                "您有新的会议将在" + train.getDuration() + "分钟后开始，请准时参加！", 1, 5, train.getTeacherName(), "/train/project");
         log.info("有会议即将开始，会议id:{}", id);
     }
 }

lab-service/lab-user/src/main/java/org/springblade/system/user/util/RedisDelayQueueRunner.java

@@ -47,7 +47,7 @@ public class RedisDelayQueueRunner implements CommandLineRunner {
                         log.error("延迟队列监控失败");
                     }
                     try {
-                        TimeUnit.MILLISECONDS.sleep(500);
+                        TimeUnit.MILLISECONDS.sleep(1000);
                     } catch (InterruptedException e) {
                         e.printStackTrace();
                     }