From 6584403ca208735e242460f83918737a9892b57e Mon Sep 17 00:00:00 2001 From: WendyYang Date: Fri, 18 Aug 2023 15:17:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BC=9A=E8=AE=AE=E8=AF=A6?= =?UTF-8?q?=E6=83=85=E4=B8=93=E5=AE=B6=E5=B1=82=E7=BA=A7=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ningdatech/pmapi/meeting/manage/MeetingManage.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/meeting/manage/MeetingManage.java b/pmapi/src/main/java/com/ningdatech/pmapi/meeting/manage/MeetingManage.java index b43e8b8..2d3785e 100644 --- a/pmapi/src/main/java/com/ningdatech/pmapi/meeting/manage/MeetingManage.java +++ b/pmapi/src/main/java/com/ningdatech/pmapi/meeting/manage/MeetingManage.java @@ -199,7 +199,7 @@ public class MeetingManage { if (!MeetingStatusEnum.NORMAL.eq(meeting.getStatus())) { throw BizException.wrap("转换失败，请刷新后重试"); } - expertRandomInviteTask.cancelByMeetingId(meetingId); + expertRandomInviteTask.cancelByMeetingIdAndKillTask(meetingId); LambdaUpdateWrapper meetingUpdate = Wrappers.lambdaUpdate(Meeting.class) .set(Meeting::getInviteType, APPOINT.getCode()) .eq(Meeting::getId, meetingId); @@ -654,7 +654,7 @@ public class MeetingManage { } public void stopRandomInvite(Long meetingId) { - expertRandomInviteTask.cancelByMeetingId(meetingId); + expertRandomInviteTask.cancelByMeetingIdAndKillTask(meetingId); } @Transactional(rollbackFor = Exception.class) @@ -676,7 +676,7 @@ public class MeetingManage { .set(Meeting::getStatus, MeetingStatusEnum.CANCELED.getCode()) .eq(Meeting::getId, meetingId); meetingService.update(meetingUpdate); - expertRandomInviteTask.cancelByMeetingId(meetingId); + expertRandomInviteTask.cancelByMeetingIdAndKillTask(meetingId); // 发送通知给专家 List experts = meetingExpertService.listAgreedExperts(meetingId); if (!experts.isEmpty()) {