using Aliyun.OSS;
using Aliyun.OSS.Common;
using System;
using System.IO;
using System.Net;
namespace Magic.Core;
///
/// 阿里云oss文件上传工具类
///
public class OSSClientUtil
{
private static readonly string _accessKeyId = "accessKeyId";
private static readonly string _accessKeySecret = "accessKeySecret";
//const string endpoint = "oss-cn-huhehaote-internal.aliyuncs.com";
private static readonly string _internalEndpoint = "internalEndpoint"; //内网传输连接
private const string _endpoint = "oss-cn-beijing.aliyuncs.com"; //"oss-cn-beijing.aliyuncs.com";// "oss-cn-huhehaote-internal.aliyuncs.com";//"oss-cn-huhehaote.aliyuncs.com" ;
private static readonly string _bucketName = "bucketName";
public static OssClient GetClient()
{
return new OssClient(_endpoint, _accessKeyId, _accessKeySecret);
}
public static OssClient GetClient_CND()
{
var conf = new ClientConfiguration
{
IsCname = true
};
return new OssClient("cdnmedia.aliyuncs.com", _accessKeyId, _accessKeySecret, conf);
}
public static OssClient GetClient_internal()
{
return new OssClient(_internalEndpoint, _accessKeyId, _accessKeySecret);
}
///
/// 上传本地文件(走阿里云内网传输)
///
///
///
///
public static bool PushMedia_internal(string objectName, string localFilename)
{
var client = GetClient_internal();
return client.PutObject(_bucketName, objectName, localFilename).HttpStatusCode == System.Net.HttpStatusCode.OK;
}
///
/// 上传一个图片
///
/// 图片经过base64加密后的结果
/// 文件名,例如:Emplyoee/dzzBack.jpg
public static bool PushImg(string base64Code, string fileName)
{
var client = GetClient();
var stream = new MemoryStream(Convert.FromBase64String(base64Code));
return client.PutObject(_bucketName, fileName, stream).HttpStatusCode == System.Net.HttpStatusCode.OK;
}
public static bool PushMedia(Stream stream, string fileName)
{
var client = GetClient();
return client.PutObject(_bucketName, fileName, stream).HttpStatusCode == System.Net.HttpStatusCode.OK;
}
///
/// 上传本地文件
///
///
///
/// 返回参数说明 1.本地文件不存在 2.文件oss上已存在 3.上传失败 4.上传成功
///
public static int PushMedia(string objectName, string localFilename)
{
if (!File.Exists(localFilename)) return 1;
if (DoesObjectExist(objectName)) return 2; // 存在文件
try
{
var client = GetClient();
//MemoryStream stream = new MemoryStream(Convert.FromBase64String(base64Code));
//var metadata = new ObjectMetadata();
//metadata.ContentType = TypeTo(contentType);
if (localFilename.Contains("http"))
{
var webClient = new WebClient { Credentials = CredentialCache.DefaultCredentials };
var stream = webClient.DownloadData(localFilename);
var ms = new MemoryStream(stream);
var c = client.PutObject(_bucketName, objectName, ms);
if (c.HttpStatusCode == System.Net.HttpStatusCode.OK) { return 4; } else { return 3; }
}
else
{
var c = client.PutObject(_bucketName, objectName, localFilename);
if (c.HttpStatusCode == System.Net.HttpStatusCode.OK) { return 4; } else { return 3; }
}
}
catch
{
return 3;
}
}
///
/// 上传一个图片
///
/// 图片字节
/// 文件名,例如:Emplyoee/dzzBack.jpg
///
public static bool PushImg(byte[] filebyte, string fileName, out string md5)
{
var client = GetClient();
var stream = new MemoryStream(filebyte, 0, filebyte.Length);
var result = client.PutObject(_bucketName, fileName, stream);
md5 = result.ResponseMetadata["Content-MD5"];
return result.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
///
/// 获取鉴权后的URL,URL有效日期默认一小时
///
/// 文件名,例如:Emplyoee/dzzBack.jpg
///
public static string GetImg(string fileName)
{
var client = GetClient();
var key = fileName;
var req = new GeneratePresignedUriRequest(_bucketName, key, SignHttpMethod.Get)
{
Expiration = DateTime.Now.AddHours(1)
};
return client.GeneratePresignedUri(req).ToString();
}
///
/// 获取鉴权后的URL
///
/// 文件名,例如:Emplyoee/dzzBack.jpg
/// URL有效日期,例如:DateTime.Now.AddHours(1)
///
public static string GetImg(string fileName, DateTime expiration)
{
var client = GetClient();
var key = fileName;
var req = new GeneratePresignedUriRequest(_bucketName, key, SignHttpMethod.Get)
{
Expiration = expiration
};
return client.GeneratePresignedUri(req).ToString();
}
///
/// 将文件转换成byte[] 数组
///
/// 文件路径文件名称
/// byte[]
private byte[] AuthGetFileData(string fileUrl)
{
using (var fs = new FileStream(fileUrl, FileMode.OpenOrCreate, FileAccess.ReadWrite))
{
byte[] buffur = new byte[fs.Length];
using (BinaryWriter bw = new BinaryWriter(fs))
{
bw.Write(buffur);
bw.Close();
}
return buffur;
}
}
///
/// 删除文件
///
/// 文件id
/// 文件url
public static bool DeletefileCode(string fileCode)
{
if (string.IsNullOrEmpty(fileCode))
return true;
//检查fileCode磁盘中是否存在此文件
if (File.Exists(fileCode))
{
File.Delete(fileCode);
return true;
}
var client = GetClient();
client.DeleteObject(_bucketName, fileCode);
return true;
}
///
/// 删除文件夹
///
/// 文件id
/// 文件url
public static bool DeleteFolder(string prefix)
{
if (string.IsNullOrEmpty(prefix))
return true;
var client = GetClient();
var listObjectsRequest = new ListObjectsRequest(_bucketName);
listObjectsRequest.Prefix = prefix;
var result = client.ListObjects(listObjectsRequest);
foreach (var summary in result.ObjectSummaries)
{
client.DeleteObject(_bucketName, summary.Key);
}
return false;
}
///
/// 判断文件是否存在
///
///
///
public static bool DoesObjectExist(string fileName)
{
var client = GetClient();
// 判断文件是否存在。
var exist = client.DoesObjectExist(_bucketName, fileName);
return exist;
}
///
/// 类型转换
///
///
public static string TypeTo(string type)
{
type = type switch
{
"mp4" => "video/mp4",
"mp3" => "audio/mp3",
_ => "image/" + type,
};
return type;
}
public static OssObject DownLoad(String fileName)
{
//var client = GetClient();
//DateTime expiration = new DateTime().AddHours(1);
//GeneratePresignedUriRequest request = new GeneratePresignedUriRequest(bucketName, fileName, SignHttpMethod.Get);
//// 设置过期时间。
//request.Expiration=expiration;
//// 生成签名URL（HTTP GET请求）。
//Uri signedUrl = client.GeneratePresignedUri(request);
//// 添加GetObject请求头。
////customHeaders.put("Range", "bytes=100-1000");
//OssObject result = client.GetObject(signedUrl);
var client = GetClient();
var key = fileName;
_ = new GeneratePresignedUriRequest(_bucketName, key, SignHttpMethod.Get)
{
Expiration = DateTime.Now.AddHours(1)
};
return client.GetObject(_bucketName, key);
}
}