| | |
| | | resVideo.setStatus(ResItemVideo.STATUS_LINEUP); |
| | | save(resVideo); |
| | | |
| | | // 将mediaVideoId放进缓存 |
| | | // 将mediaVideoId放进缓存 |
| | | cacheService.lstRightPush(RES_VIDEO_CONVER_LST, mediaVideoId); |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | |
| | | } |
| | | |
| | | /** |
| | | * 定时器转码成功后 同步更新ResItemVideo的状态 |
| | | * 定时器转码成功后 同步更新ResItemVideo的状态 |
| | | */ |
| | | @Scheduled(cron = "0/2 * * * * ?") // 每2秒执行一次 |
| | | @Scheduled(cron = "0/2 * * * * ?") // 每2秒执行一次 |
| | | public void doTimer() { |
| | | |
| | | String mediaVideoId = cacheService.lstLeftPop(RES_VIDEO_CONVER_LST); |
| | |
| | | resItemVideo.setVideoSeconds(mediaVideo.getPlayTime()); |
| | | save(resItemVideo); |
| | | |
| | | cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemVideo.getVideoId());// 将转码完成后的文件id放入缓存。 |
| | | cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemVideo.getVideoId());// 将转码完成后的文件id放入缓存。 |
| | | return; |
| | | } else if (mediaVideo.getType().equals("audio")) { |
| | | ResItemAudio resItemAudio = findUnique( |
| | |
| | | resItemAudio.setSeconds(mediaVideo.getPlayTime()); |
| | | save(resItemAudio); |
| | | |
| | | cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemAudio.getAudioId());// 将转码完成后的文件id放入缓存。 |
| | | cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemAudio.getAudioId());// 将转码完成后的文件id放入缓存。 |
| | | return; |
| | | } |
| | | |