| | |
|---|
| | | private final LiveSessionMapper liveSessionMapper; |
|---|
| | | private final LiveSessionQuestionMapper liveSessionQuestionMapper; |
|---|
| | | private final LiveReserveMapper liveReserveMapper; |
|---|
| | | private final LiveRemindDispatchService liveRemindDispatchService; |
|---|
| | | |
|---|
| | | public LiveSessionAppService(LiveCourseMapper liveCourseMapper, |
|---|
| | | LiveSessionMapper liveSessionMapper, |
|---|
| | | LiveSessionQuestionMapper liveSessionQuestionMapper, |
|---|
| | | LiveReserveMapper liveReserveMapper) { |
|---|
| | | LiveReserveMapper liveReserveMapper, |
|---|
| | | LiveRemindDispatchService liveRemindDispatchService) { |
|---|
| | | this.liveCourseMapper = liveCourseMapper; |
|---|
| | | this.liveSessionMapper = liveSessionMapper; |
|---|
| | | this.liveSessionQuestionMapper = liveSessionQuestionMapper; |
|---|
| | | this.liveReserveMapper = liveReserveMapper; |
|---|
| | | this.liveRemindDispatchService = liveRemindDispatchService; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public PageResponse<LiveSessionVO> pageSessions(Long courseId, int page, int pageSize, String startTimeFrom, String startTimeTo, Integer liveStatus) { |
|---|
| | |
|---|
| | | .eq(LiveReserve::getLiveCourseId, courseId) |
|---|
| | | .eq(LiveReserve::getSessionId, sessionId) |
|---|
| | | .eq(LiveReserve::getIsCancel, 0)); |
|---|
| | | // 后台手动触发时直接对当前场次预约用户执行一次真正的通知发放。 |
|---|
| | | liveRemindDispatchService.dispatchManualRemind(session); |
|---|
| | | return new LivePushNotificationVO(cnt == null ? 0L : cnt, LocalDateTime.now()); |
|---|
| | | } |
|---|
| | | |
|---|
