| | |
|---|
| | | ardMediaVideoMapper.insertArdMediaVideo(ardMedia); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | // @Scheduled(fixedDelay = 10000) // 每10秒执行一次 |
|---|
| | | // public void syncVideoMediaUrl() { |
|---|
| | | // List<ArdMediaVideo> videos = ardMediaVideoMapper.selectVideosWithNullMedia(); |
|---|
| | | // for (ArdMediaVideo video : videos) { |
|---|
| | | // if (!uploadingVideos.add(video.getId())) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // CompletableFuture.runAsync(() -> { |
|---|
| | | // try { |
|---|
| | | // // 上传视频到 OSS |
|---|
| | | // try (InputStream is = openUrlInputStream(video.getSourceUrl(), 5000, 10000)) { |
|---|
| | | // if (is != null) { |
|---|
| | | // String mediaUrl = ossServiceContext.upload( |
|---|
| | | // "record", |
|---|
| | | // video.getTaskId() + "/" + video.getId() + ".mp4", |
|---|
| | | // is, |
|---|
| | | // MimeTypeUtils.VIDEO_MP4 |
|---|
| | | // ); |
|---|
| | | // log.info("upload mediaUrl={}", mediaUrl); |
|---|
| | | // video.setMediaUrl(mediaUrl); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // // 生成缩略图 |
|---|
| | | // processVideoThumbnail(video); |
|---|
| | | // |
|---|
| | | // // 更新数据库 |
|---|
| | | // video.setUpdateTime(new Date()); |
|---|
| | | // ardMediaVideoMapper.updateArdMediaVideo(video); |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // log.error("生成 mediaUrl/缩略图失败 videoId={}", video.getId(), e); |
|---|
| | | // } finally { |
|---|
| | | // uploadingVideos.remove(video.getId()); |
|---|
| | | // } |
|---|
| | | // }, threadPoolTaskExecutor); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // @Scheduled(fixedDelay = 10000) // 每10秒执行一次 |
|---|
| | | // public void syncPicMediaUrl() { |
|---|
| | | // List<ArdMediaPic> pics = ardMediaPicMapper.selectPicsWithNullMedia(); |
|---|
| | | // for (ArdMediaPic pic : pics) { |
|---|
| | | // if (!uploadingPics.add(pic.getId())) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // CompletableFuture.runAsync(() -> { |
|---|
| | | // try (InputStream inputStream = openUrlInputStream(pic.getSourceUrl(), 5000, 10000)) { |
|---|
| | | // if (inputStream != null) { |
|---|
| | | // String url = ossServiceContext.upload( |
|---|
| | | // "pic", |
|---|
| | | // pic.getTaskId() + "/" + pic.getId() + ".jpg", |
|---|
| | | // inputStream, |
|---|
| | | // MimeTypeUtils.IMAGE_JPG |
|---|
| | | // ); |
|---|
| | | // pic.setMediaUrl(url); |
|---|
| | | // pic.setUpdateTime(new Date()); |
|---|
| | | // ardMediaPicMapper.updatePic(pic); |
|---|
| | | // } |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // log.error("图片上传失败 taskId={}, photoId={}", pic.getTaskId(), pic.getId(), e); |
|---|
| | | // } finally { |
|---|
| | | // uploadingPics.remove(pic.getId()); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // }, threadPoolTaskExecutor); // 使用自定义线程池 |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | |
|---|
| | | } |
|---|
