|
|
@@ -1,9 +1,13 @@
|
|
|
package cn.reghao.oss.store.rpc;
|
|
|
|
|
|
-import cn.reghao.oss.storeapi.dto.media.*;
|
|
|
-import cn.reghao.oss.storeapi.iface.MediaService;
|
|
|
+import cn.reghao.oss.store.db.repository.ObjectRepository;
|
|
|
+import cn.reghao.oss.store.model.po.FileMeta;
|
|
|
+import cn.reghao.oss.store.service.ObjectNameService;
|
|
|
+import cn.reghao.oss.store.service.SignService;
|
|
|
+import cn.reghao.tnb.file.api.dto.media.*;
|
|
|
import cn.reghao.oss.store.task.MediaFileProcessor;
|
|
|
import cn.reghao.oss.store.util.UserContext;
|
|
|
+import cn.reghao.tnb.file.api.iface.MediaService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.dubbo.config.annotation.DubboService;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -21,11 +25,45 @@ import java.util.List;
|
|
|
public class MediaServiceImpl implements MediaService {
|
|
|
private final LocalDateTime epoch = LocalDateTime.parse("1970-01-01T08:00");
|
|
|
private final MediaFileProcessor mediaFileProcessor;
|
|
|
+ private ObjectRepository objectRepository;
|
|
|
+ private ObjectNameService objectNameService;
|
|
|
+ private SignService signService;
|
|
|
|
|
|
public MediaServiceImpl(MediaFileProcessor mediaFileProcessor) {
|
|
|
this.mediaFileProcessor = mediaFileProcessor;
|
|
|
}
|
|
|
|
|
|
+ public VideoInfo getVideoInfo(int channelId, String objectId) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ public ImageInfo getImageInfo(int channelId, String objectId) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public List<ConvertedImageInfo> getWebpInfo(int channelId, List<String> objectIds) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ public AudioInfo getAudioInfo(int channelId, String objectId) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public String getSignedUrl(int loginUser, String objectId, int expireSecond) {
|
|
|
+ FileMeta fileMeta = objectRepository.getByObjectId(objectId);
|
|
|
+ String objectName = fileMeta.getObjectName();
|
|
|
+ String url = objectNameService.getObjectUrl(objectName);
|
|
|
+ String signedUrl = signService.getSignedUrl(loginUser, url, expireSecond);
|
|
|
+ return signedUrl;
|
|
|
+ }
|
|
|
+
|
|
|
+ public String getSignedUrl(int channelId, String uploadId) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Deprecated
|
|
|
public VideoInfo getVideoInfo(String videoFileId) {
|
|
|
try {
|
|
|
VideoInfo videoInfo = mediaFileProcessor.getVideoInfo(videoFileId);
|
|
|
@@ -37,6 +75,7 @@ public class MediaServiceImpl implements MediaService {
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ @Deprecated
|
|
|
public ImageInfo getImageInfo(String imageFileId) {
|
|
|
try {
|
|
|
ImageInfo imageInfo = mediaFileProcessor.getImageInfo(imageFileId);
|
|
|
@@ -49,16 +88,18 @@ public class MediaServiceImpl implements MediaService {
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ @Deprecated
|
|
|
public List<ImageInfo> getImagesInfo(List<String> imageFileIds) {
|
|
|
return mediaFileProcessor.getImagesInfo(imageFileIds);
|
|
|
}
|
|
|
|
|
|
- public List<ConvertedImageInfo> getWebpInfo(int loginUser, List<String> imageFileIds) {
|
|
|
+ @Deprecated
|
|
|
+ public List<ConvertedImageInfo> getWebpInfo1(int loginUser, List<String> imageFileIds) {
|
|
|
UserContext userContext = new UserContext(loginUser);
|
|
|
return mediaFileProcessor.getWebpInfos(imageFileIds);
|
|
|
}
|
|
|
|
|
|
- @Override
|
|
|
+ @Deprecated
|
|
|
public AudioInfo getAudioInfo(String audioFileId) {
|
|
|
try {
|
|
|
AudioInfo audioInfo = mediaFileProcessor.getAudioInfo(audioFileId);
|