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(); }