AzureBlobDBRepository.cs 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. using TEAMModelOS.SDK.Module.AzureBlob.Configuration;
  2. using TEAMModelOS.SDK.Module.AzureBlob.Container;
  3. using TEAMModelOS.SDK.Module.AzureBlob.Interfaces;
  4. using Microsoft.WindowsAzure.Storage;
  5. using Microsoft.WindowsAzure.Storage.Blob;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.IO;
  9. using System.Net.Http.Headers;
  10. using System.Threading.Tasks;
  11. using Microsoft.AspNetCore.Http.Internal;
  12. using TEAMModelOS.SDK.Helper.Security.AESCrypt;
  13. using TEAMModelOS.SDK.Context.Exception;
  14. using Microsoft.AspNetCore.Http;
  15. namespace TEAMModelOS.SDK.Module.AzureBlob.Implements
  16. {
  17. public class AzureBlobDBRepository : IAzureBlobDBRepository
  18. {
  19. private readonly string china = "417A7572654368696E612020202020202020202020202020202020202020202097EB27FCC1F03349787DCD35F4DE22BBDFEDC90F24738B1D7FB9167A2C191BE671B512E17D48B73A002FC98867345CD59D3250AF59FD5FDFFC67976108F9E3BC9E9F75EDE605B058C1821D16BD9EB753B8E7D39FF48163430C1B5F3B6150195B880C3FCB87D35BF3540432734B768EC28C77B4CF0D556E794DE57979C1E01C429E66F7B2794D9940CF287F2B22A22E5F266B949D5E523E709FF37229E45D1A8FC8C4341E0A8346BB976CCB3D91802FFE5A4A28577898B4E942B5BA3A4A7B796FA673782D405060E7F2CBA4F67DF59F47";
  20. private readonly string global = "417A757265476C6F62616C2020202020202020202020202020202020202020206956019D195ED330AFA660D369B9464FC5E90AB3A106FDDD7978A2772DB186CDAE21C6CBFDE2B6739F089E853B3171A27841026E61C51666347F63FDF63E4377448D493B05CF6CDB3791946B9145825DD7756392EB8EA36DBF42E5C1C0021CEC2CDB5F4EA57EBCFA98B17D7236FA2CDCA6E7FCBE1DDC45BEAF691A2462A8BC3C429CBC4BCCA3192E554D23758AA8EA5937F988C927534C70A4769ED33878BEC10E2550F121E4AEB5A2DA213F2902D602A758C7D93D5DED368544F8A86D2A0CAA7813D1D950EC81D544EE41A8EDC84173";
  21. public CloudBlobClient blobClient;
  22. public CloudBlobContainer blobContainer;
  23. public AzureBlobOptions _options;
  24. public AzureBlobDBRepository(AzureBlobOptions options)
  25. {
  26. _options = options;
  27. if (!string.IsNullOrEmpty(options.ConnectionString))
  28. {
  29. blobClient = BlobClientSingleton.getInstance(options.ConnectionString).GetBlobClient();
  30. }
  31. else if (AzureBlobConfig.AZURE_CHINA.Equals(options.AzureTableDialect))
  32. {
  33. AESCrypt crypt = new AESCrypt();
  34. blobClient = BlobClientSingleton.getInstance(crypt.Decrypt(china, options.AzureTableDialect)).GetBlobClient();
  35. }
  36. else if (AzureBlobConfig.AZURE_GLOBAL.Equals(options.AzureTableDialect))
  37. {
  38. AESCrypt crypt = new AESCrypt();
  39. blobClient = BlobClientSingleton.getInstance(crypt.Decrypt(global, options.AzureTableDialect)).GetBlobClient();
  40. }
  41. else { throw new BizException("请设置正确的AzureBlob文件存储配置信息!"); }
  42. }
  43. public AzureBlobDBRepository()
  44. {
  45. // _connectionString = BaseConfigModel.Configuration["AppSettings:Azure:TableStorageConnection"];
  46. }
  47. //private async Task InitializeBlob(string container)
  48. //{
  49. ////https://teammodelstorage.blob.core.chinacloudapi.cn/wechatfilescontainer
  50. // if (blobContainer == null)
  51. // {
  52. // // Type t = typeof(T);
  53. // //若要将权限设置为仅针对 blob 的公共读取访问,请将 PublicAccess 属性设置为 BlobContainerPublicAccessType.Blob。
  54. // //要删除匿名用户的所有权限,请将该属性设置为 BlobContainerPublicAccessType.Off。
  55. // blobContainer = blobClient.GetContainerReference("wechatfilescontainer");
  56. // // await blobContainer.CreateIfNotExistsAsync();
  57. // // BlobContainerPermissions permissions = await blobContainer.GetPermissionsAsync();
  58. // // permissions.PublicAccess = BlobContainerPublicAccessType.Blob;
  59. // // await blobContainer.SetPermissionsAsync(permissions);
  60. // }
  61. // //await UploadFiles(null, new FileContainer() );
  62. //}
  63. public async Task<List<AzureBlobModel>> UploadFiles(IFormFile[] file)
  64. {
  65. string groupName = DateTime.Now.ToString("yyyyMMdd");
  66. string newFileName = DateTime.Now.ToString("yyyyMMddHHmmss");
  67. // await InitializeBlob(DateTime.Now.ToString("yyyyMMdd"));
  68. blobContainer = blobClient.GetContainerReference(groupName);
  69. StorageUri url = blobContainer.StorageUri;
  70. List<AzureBlobModel> list = new List<AzureBlobModel>();
  71. foreach (FormFile f in file)
  72. {
  73. string[] names = f.FileName.Split(".");
  74. string name = "";
  75. for (int i = 0; i < names.Length-1; i++) {
  76. name = name + names[i];
  77. }
  78. if (names.Length <= 1)
  79. {
  80. name = name + "_" + newFileName;
  81. }
  82. else {
  83. name = name + "_" + newFileName + "." + names[names.Length - 1];
  84. }
  85. var parsedContentDisposition = ContentDispositionHeaderValue.Parse(f.ContentDisposition);
  86. var filename = Path.Combine(parsedContentDisposition.FileName.Trim('"'));
  87. var blockBlob = blobContainer.GetBlockBlobReference(name);
  88. await blockBlob.UploadFromStreamAsync(f.OpenReadStream());
  89. AzureBlobModel model = new AzureBlobModel(f, _options.Container, groupName, name)
  90. {
  91. BlobUrl = url.PrimaryUri.ToString().Split("?")[0] + "/" + name
  92. };
  93. list.Add(model);
  94. }
  95. return list;
  96. }
  97. }
  98. }