From e02f33380ffd0ba16f594ba6460368f20b56ba0c Mon Sep 17 00:00:00 2001 From: "a15234804788@163.com" Date: Fri, 14 Oct 2022 08:57:02 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E7=9B=B8=E5=85=B3=E6=B3=A8?= =?UTF-8?q?=E9=87=8A=E6=8E=89=E7=9A=84=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../target/classes/application-dev.yml | 3 +++ .../system/user/UserApplication.java | 5 ----- .../mettinghandler/MettingRemindHandler.java | 17 +++++++++-------- .../system/user/util/RedisDelayQueueRunner.java | 2 +- 4 files changed, 13 insertions(+), 14 deletions(-) create mode 100644 lab-service/lab-system/target/classes/application-dev.yml diff --git a/lab-service/lab-system/target/classes/application-dev.yml b/lab-service/lab-system/target/classes/application-dev.yml new file mode 100644 index 0000000..284d40c --- /dev/null +++ b/lab-service/lab-system/target/classes/application-dev.yml @@ -0,0 +1,3 @@ +#服务器端口 +server: + port: 8003 \ No newline at end of file diff --git a/lab-service/lab-user/src/main/java/org/springblade/system/user/UserApplication.java b/lab-service/lab-user/src/main/java/org/springblade/system/user/UserApplication.java index 198aefd..423f541 100644 --- a/lab-service/lab-user/src/main/java/org/springblade/system/user/UserApplication.java +++ b/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(); -// } - } diff --git a/lab-service/lab-user/src/main/java/org/springblade/system/user/mettinghandler/MettingRemindHandler.java b/lab-service/lab-user/src/main/java/org/springblade/system/user/mettinghandler/MettingRemindHandler.java index 856d414..1c3c467 100644 --- a/lab-service/lab-user/src/main/java/org/springblade/system/user/mettinghandler/MettingRemindHandler.java +++ b/lab-service/lab-user/src/main/java/org/springblade/system/user/mettinghandler/MettingRemindHandler.java @@ -35,14 +35,15 @@ public class MettingRemindHandler implements RedissonDelayQueuHandlle{ wrapper.eq(TrainPerson::getTrainId, id); List list = trainPersonService.list(wrapper); Train train = trainService.getById(id); -// if (list.size() > 0) { -// list.forEach(person -> { -// 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"); + //分别为讲师和培训者增加延迟消息提醒 + if (list.size() > 0) { + list.forEach(person -> { + 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"); log.info("有会议即将开始，会议id:{}", id); } } diff --git a/lab-service/lab-user/src/main/java/org/springblade/system/user/util/RedisDelayQueueRunner.java b/lab-service/lab-user/src/main/java/org/springblade/system/user/util/RedisDelayQueueRunner.java index 72a8355..f5676ca 100644 --- a/lab-service/lab-user/src/main/java/org/springblade/system/user/util/RedisDelayQueueRunner.java +++ b/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(); }