|
@@ -4,8 +4,10 @@ import cn.reghao.jutil.jdk.result.WebResult;
|
|
|
import cn.reghao.jutil.jdk.serializer.JsonConverter;
|
|
import cn.reghao.jutil.jdk.serializer.JsonConverter;
|
|
|
import cn.reghao.oss.store.api.dto.*;
|
|
import cn.reghao.oss.store.api.dto.*;
|
|
|
import cn.reghao.oss.store.api.dto.media.*;
|
|
import cn.reghao.oss.store.api.dto.media.*;
|
|
|
|
|
+import cn.reghao.oss.store.api.rest.UploadFileRet;
|
|
|
import com.google.gson.reflect.TypeToken;
|
|
import com.google.gson.reflect.TypeToken;
|
|
|
|
|
|
|
|
|
|
+import java.io.File;
|
|
|
import java.lang.reflect.Type;
|
|
import java.lang.reflect.Type;
|
|
|
import java.net.URI;
|
|
import java.net.URI;
|
|
|
import java.net.URLEncoder;
|
|
import java.net.URLEncoder;
|
|
@@ -498,4 +500,17 @@ public class OssConsoleClient {
|
|
|
throw new Exception(errMsg);
|
|
throw new Exception(errMsg);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ public UploadFileRet uploadFile(int channelId, File file) throws Exception {
|
|
|
|
|
+ ServerInfo serverInfo = getServerInfo(channelId);
|
|
|
|
|
+ if (serverInfo == null) {
|
|
|
|
|
+ throw new Exception("获取 server_info 失败");
|
|
|
|
|
+ }
|
|
|
|
|
+ String ossUrl = serverInfo.getOssUrl();
|
|
|
|
|
+ String token = serverInfo.getToken();
|
|
|
|
|
+
|
|
|
|
|
+ OssStoreClient ossStoreClient = new OssStoreClient(ossUrl);
|
|
|
|
|
+ UploadFileRet uploadFileRet = ossStoreClient.postObjectWithJdkHttp(file, channelId, token);
|
|
|
|
|
+ return uploadFileRet;
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|