118 lines
4.6 KiB
C#
118 lines
4.6 KiB
C#
using Aliyun.OSS;
|
||
using Aliyun.OSS.Common;
|
||
using Infrastructure;
|
||
using System;
|
||
using System.IO;
|
||
using System.Security.Cryptography;
|
||
|
||
namespace ZR.Common
|
||
{
|
||
public class AliyunOssHelper
|
||
{
|
||
static string accessKeyId = AppSettings.GetConfig("ALIYUN_OSS:KEY");
|
||
static string accessKeySecret = AppSettings.GetConfig("ALIYUN_OSS:SECRET");
|
||
static string endpoint = AppSettings.GetConfig("ALIYUN_OSS:REGIONID");
|
||
static string bucketName1 = AppSettings.GetConfig("ALIYUN_OSS:bucketName");
|
||
|
||
/// <summary>
|
||
/// 上传到阿里云
|
||
/// </summary>
|
||
/// <param name="filestreams"></param>
|
||
/// <param name="dirPath">存储路径 eg： upload/2020/01/01/xxx.png</param>
|
||
/// <param name="bucketName">存储桶 如果为空默认取配置文件</param>
|
||
public static System.Net.HttpStatusCode PutObjectFromFile(Stream filestreams, string dirPath, string bucketName = "")
|
||
{
|
||
OssClient client = new(endpoint, accessKeyId, accessKeySecret);
|
||
if (string.IsNullOrEmpty(bucketName)) { bucketName = bucketName1; }
|
||
try
|
||
{
|
||
dirPath = dirPath.Replace("\\", "/");
|
||
PutObjectResult putObjectResult = client.PutObject(bucketName, dirPath, filestreams);
|
||
// Console.WriteLine("Put object:{0} succeeded", directory);
|
||
|
||
return putObjectResult.HttpStatusCode;
|
||
}
|
||
catch (OssException ex)
|
||
{
|
||
Console.WriteLine("Failed with error code: {0}; Error info: {1}. \nRequestID:{2}\tHostID:{3}",
|
||
ex.ErrorCode, ex.Message, ex.RequestId, ex.HostId);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine("Failed with error info: {0}", ex.Message);
|
||
}
|
||
return System.Net.HttpStatusCode.BadRequest;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 删除资源
|
||
/// </summary>
|
||
/// <param name="dirPath"></param>
|
||
/// <param name="bucketName"></param>
|
||
/// <returns></returns>
|
||
public static System.Net.HttpStatusCode DeleteFile(string dirPath, string bucketName = "")
|
||
{
|
||
if (string.IsNullOrEmpty(bucketName)) { bucketName = bucketName1; }
|
||
try
|
||
{
|
||
OssClient client = new(endpoint, accessKeyId, accessKeySecret);
|
||
dirPath = dirPath.Replace("\\", "/");
|
||
DeleteObjectResult putObjectResult = client.DeleteObject(bucketName, dirPath);
|
||
return putObjectResult.HttpStatusCode;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine(ex.Message);
|
||
}
|
||
return System.Net.HttpStatusCode.BadRequest;
|
||
}
|
||
|
||
public static Stream DownloadFile(string dirPath, string bucketName = "", bool isEncrypted = false)
|
||
{
|
||
if (string.IsNullOrEmpty(bucketName))
|
||
{
|
||
bucketName = bucketName1;
|
||
}
|
||
try
|
||
{
|
||
OssClient client = new(endpoint, accessKeyId, accessKeySecret);
|
||
dirPath = dirPath.Replace("\\", "/");
|
||
var ossObject = client.GetObject(bucketName, dirPath);
|
||
if (isEncrypted)
|
||
{
|
||
try
|
||
{
|
||
var key = new byte[]
|
||
{
|
||
13, 57, 174, 2, 102, 26, 253, 192, 141, 38, 175, 244, 32, 86, 163, 25, 237, 134,
|
||
253, 162, 62, 203, 57, 52, 56, 157, 78, 155, 63, 28, 63, 255
|
||
};
|
||
var iv = new byte[]
|
||
{
|
||
137, 221, 84, 122, 104, 162, 48, 60, 108, 130, 170, 238, 186, 190, 111, 176
|
||
};
|
||
var aes = Aes.Create();
|
||
aes.Key = key;
|
||
aes.IV = iv;
|
||
var decryptor = aes.CreateDecryptor();
|
||
var cryptoStream = new CryptoStream(ossObject.Content, decryptor, CryptoStreamMode.Read);
|
||
return cryptoStream;
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
// 处理异常，例如记录日志或抛出自定义异常
|
||
Console.WriteLine($"解密文件时发生异常: {e.Message}");
|
||
throw;
|
||
}
|
||
}
|
||
return ossObject.Content;
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
Console.WriteLine(e);
|
||
throw;
|
||
}
|
||
}
|
||
}
|
||
}
|