| | |
| | | redisCache.setCacheSet(Constants.LIVE_APPOINTMENT_PUSH + id, appointmentPush); |
| | | |
| | | TSysLive sysLive = sysLiveService.getById(id); |
| | | Map<String, ? extends Object> maps = |
| | | new ImmutableMap.Builder<String, String>(). |
| | | put("id", sysLive.getId()) |
| | | .build(); |
| | | QuartzManager.addJob( |
| | | LivePushJob.class, |
| | | (LivePushJob.name+sysLive.getId()).toUpperCase(), |
| | | TimeJobType.LIVE_PUSH, |
| | | DateUtils.localDateTimeToDate(sysLive.getStartTime().minusHours(1)), |
| | | maps |
| | | ); |
| | | // 录播视频等没有开始时间的内容无法推算提醒时间,只记录预约、不排定时任务 |
| | | if (Objects.nonNull(sysLive) && Objects.nonNull(sysLive.getStartTime())) { |
| | | Map<String, ? extends Object> maps = |
| | | new ImmutableMap.Builder<String, String>(). |
| | | put("id", sysLive.getId()) |
| | | .build(); |
| | | QuartzManager.addJob( |
| | | LivePushJob.class, |
| | | (LivePushJob.name + sysLive.getId()).toUpperCase(), |
| | | TimeJobType.LIVE_PUSH, |
| | | DateUtils.localDateTimeToDate(sysLive.getStartTime().minusHours(1)), |
| | | maps |
| | | ); |
| | | } |
| | | |
| | | return R.ok(); |
| | | } |