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<Meeting> 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<MeetingExpert> experts = meetingExpertService.listAgreedExperts(meetingId);
             if (!experts.isEmpty()) {