|
|
@@ -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()) { |
|
|
|