Обновить IformFile - PullRequest
Новая
       51

Обновить IformFile

0 голосов
/ 24 апреля 2019

У меня есть требование прочитать файл Excel из системы и изменить этот файл (например, удалить дубликаты) и перенести его в другое место.Я использую IFormFile.

Может кто-нибудь помочь мне удалить дубликаты из файла, обновить тот же файл и создать новый файл с дублированными значениями.

Вот что мне нужно, чтобы прочитать файл 

var result = new StringBuilder();
using (var reader = new StreamReader(iFormFile.OpenReadStream()))
{
  //read till EOF
  while (reader.Peek() >= 0) 
  {
      result.AppendLine(await reader.ReadLineAsync());
  }
}


 public async Task<Stream> ValidateDataFileAsync(Stream stream, CancellationToken token)
    {
        List<string> result = new List<string>();
        using (var reader = new StreamReader(stream))
        {
            while (reader.Peek() >= 0)
           result.Add(await reader.ReadLineAsync());
        }

        HashSet<string> hSet = new HashSet<string>(result);
       return hSet;

// Как мне преобразовать хешсет в поток. 

    }

1 Ответ

0 голосов
/ 25 апреля 2019

Сначала установите Nuget: 

Install-Package WindowsAzure.Storage -Version 9.3.3

и 

Install-Package EPPlus -Version 4.5.2.1

Создайте интерфейс IBlobManager.cs, в котором будут храниться все ваши операции BLOB-объектов: 

using System;
using System.IO;
using System.Threading.Tasks;

namespace UploadAzureBlob.Services
{
    public interface IBlobManager
    {
        Task<string> UploadFileToBlobAsync(string fileName, Stream stream);
    }
}

Реализуйте вышеуказанный интерфейс в классе BlobManager.cs: 

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
using System.Threading.Tasks;

namespace UploadAzureBlob.Services
{
    public class BlobManager : IBlobManager
    {
        private CloudBlobClient cloudBlobClient;
        public BlobManager()
        {
            // Retrieve the connection string for blob storage
            string storageConnectionString = "";

            CloudStorageAccount.TryParse(storageConnectionString, out CloudStorageAccount storageAccount);

            // Create the CloudBlobClient that represents the Blob storage endpoint for the storage account.
            cloudBlobClient = storageAccount.CreateCloudBlobClient();
        }

        /// <summary>
        /// Uploads a file to blob storage.
        /// </summary>
        /// <param name="fileName"></param>
        /// <param name="file"></param>
        /// <returns></returns>
        public async Task<string> UploadFileToBlobAsync(string fileName, Stream stream)
        {
            try
            {
                // Create a container.
                CloudBlobContainer blobContainer = cloudBlobClient.GetContainerReference("test");
                await blobContainer.CreateAsync();

                BlobContainerPermissions perm = await blobContainer.GetPermissionsAsync();
                perm.PublicAccess = BlobContainerPublicAccessType.Container;
                await blobContainer.SetPermissionsAsync(perm);

                // Get a reference to the blob address, then upload the file to the blob.
                var cloudBlockBlob = blobContainer.GetBlockBlobReference(fileName);
                await cloudBlockBlob.UploadFromStreamAsync(stream);

                // Returning the URI of the freshly created resource
                return cloudBlockBlob.Uri.ToString();
            }
            catch (StorageException ex)
            {
                throw;
            }
        }
    }
}

Теперь, наконец, в вашем контроллере: 

public async Task<string> ValidateDataFileAsync(IFormFile formFile)
{
        List<string> result = new List<string>();

        using (var reader = new StreamReader(formFile.OpenReadStream()))
        {
            //read till EOF
            while (reader.Peek() >= 0)
                result.Add(reader.ReadLineAsync().Result);
        }

        // Filter by repeated items
        result = result.GroupBy(x => x).Where(x => x.Count() > 1).Select(x => x.Key).ToList();

        // Write the List<string> into the MemoryStream using the EPPlus package

        MemoryStream memoryStream = new MemoryStream();
        using (var package = new ExcelPackage())
        {
            var worksheet = package.Workbook.Worksheets.Add("Worksheet 1");
            worksheet.Cells["A1"].LoadFromCollection(result);
            memoryStream = new MemoryStream(package.GetAsByteArray());
        }

        IBlobManager blobManager = new BlobManager();
        string newResourceUri = await blobManager.UploadFileToBlobAsync(formFile.FileName, memoryStream);
        return newResourceUri;
}
...