forked from MDCPS/DamageAssessment_Backend
Added Document api solution
This commit is contained in:
uppuv
@ -0,0 +1,44 @@
|
||||
|
||||
using Azure.Storage.Blobs;
|
||||
using Azure.Storage.Blobs.Models;
|
||||
using Azure.Storage.Blobs.Specialized;
|
||||
using DamageAssesment.Api.Documents.Interfaces;
|
||||
|
||||
namespace DamageAssesment.Api.Documents.Providers
|
||||
{
|
||||
public class AzureBlobService: IAzureBlobService
|
||||
{
|
||||
BlobServiceClient _blobClient;
|
||||
BlobContainerClient _containerClient;
|
||||
string azureConnectionString = "<Primary Connection String>";
|
||||
public AzureBlobService()
|
||||
{
|
||||
_blobClient = new BlobServiceClient(azureConnectionString);
|
||||
_containerClient = _blobClient.GetBlobContainerClient("apiimages");
|
||||
}
|
||||
|
||||
public async Task<List<Azure.Response<BlobContentInfo>>> UploadFiles(List<IFormFile> files)
|
||||
{
|
||||
|
||||
var azureResponse = new List<Azure.Response<BlobContentInfo>>();
|
||||
foreach (var file in files)
|
||||
{
|
||||
string fileName = file.FileName;
|
||||
using (var memoryStream = new MemoryStream())
|
||||
{
|
||||
file.CopyTo(memoryStream);
|
||||
memoryStream.Position = 0;
|
||||
var client = await _containerClient.UploadBlobAsync(fileName, memoryStream, default);
|
||||
azureResponse.Add(client);
|
||||
}
|
||||
};
|
||||
|
||||
return azureResponse;
|
||||
}
|
||||
public void DeleteFile(string url)
|
||||
{
|
||||
var blob = _containerClient.GetBlockBlobClient(url);
|
||||
blob.DeleteIfExists();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,363 @@
|
||||
using AutoMapper;
|
||||
using DamageAssesment.Api.Documents.Db;
|
||||
using DamageAssesment.Api.Documents.Interfaces;
|
||||
using DamageAssesment.Api.Documents.Models;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.EntityFrameworkCore.Metadata.Internal;
|
||||
using System;
|
||||
using System.Diagnostics.Eventing.Reader;
|
||||
|
||||
namespace DamageAssesment.Api.Documents.Providers
|
||||
{
|
||||
|
||||
|
||||
public class documentsProvider : IDocumentsProvider
|
||||
{
|
||||
private DocumentDbContext DocumentDbContext;
|
||||
private ILogger<documentsProvider> logger;
|
||||
private IUploadService uploadservice;
|
||||
private IMapper mapper;
|
||||
|
||||
public documentsProvider(DocumentDbContext DocumentDbContext, ILogger<documentsProvider> logger, IMapper mapper, IUploadService uploadservice)
|
||||
{
|
||||
this.DocumentDbContext = DocumentDbContext;
|
||||
this.logger = logger;
|
||||
this.mapper = mapper;
|
||||
this.uploadservice = uploadservice;
|
||||
SeedData();
|
||||
}
|
||||
|
||||
|
||||
|
||||
private void SeedData()
|
||||
{
|
||||
if (!DocumentDbContext.LinkTypes.Any())
|
||||
{
|
||||
DocumentDbContext.LinkTypes.Add(new Db.LinkType() {TypeText = "Forms",IsActive=true, IsAttachment=true });
|
||||
DocumentDbContext.LinkTypes.Add(new Db.LinkType() {TypeText = "Communiques",IsActive = true,IsAttachment=false });
|
||||
DocumentDbContext.LinkTypes.Add(new Db.LinkType() {TypeText = "Memos",IsActive = true,IsAttachment=true });
|
||||
DocumentDbContext.SaveChanges();
|
||||
}
|
||||
if (!DocumentDbContext.Documents.Any())
|
||||
{
|
||||
FileModel fileModel = new FileModel() { FileName = "Sample", FileContent = "c2FtcGxl", FileExtension = ".txt" };
|
||||
DocumentInfo documentInfo = new DocumentInfo() { linkTypeId = 1, url = "Sample", File = fileModel };
|
||||
Models.Document document = uploadservice.UploadDocument(0, documentInfo);
|
||||
DocumentDbContext.Documents.Add(mapper.Map<Models.Document, Db.Document>(document));
|
||||
DocumentDbContext.SaveChanges();
|
||||
}
|
||||
if (!DocumentDbContext.DocumentsTranslations.Any())
|
||||
{
|
||||
Db.DocumentsTranslation documents = new Db.DocumentsTranslation { Id = 0, DocumentId = 1, title = "Test", description = "ss", Language = "en" };
|
||||
DocumentDbContext.DocumentsTranslations.Add(documents);
|
||||
DocumentDbContext.SaveChanges();
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, IEnumerable<Models.Document> documents, string ErrorMessage)> GetDocumnetsByLinkAsync(string Language, string LinkType)
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query Question");
|
||||
var documents=new List<Db.Document>();
|
||||
if(String.IsNullOrEmpty(LinkType))
|
||||
documents = await DocumentDbContext.Documents.AsNoTracking().Where(q => q.IsActive).ToListAsync();
|
||||
else
|
||||
documents = await DocumentDbContext.Documents.AsNoTracking().Where(q => q.IsActive &&
|
||||
q.linkTypeId == (DocumentDbContext.LinkTypes.AsNoTracking().Where(a => a.TypeText.ToLower() == LinkType.ToLower()).Select(a => a.Id).FirstOrDefault())).ToListAsync();
|
||||
if (documents != null)
|
||||
{
|
||||
var result = mapper.Map<IEnumerable<Db.Document>, IEnumerable<Models.Document>>(documents);
|
||||
foreach (var item in result)
|
||||
{
|
||||
if(!String.IsNullOrEmpty(Language))
|
||||
item.documentsTranslations = mapper.Map<List<Db.DocumentsTranslation>, List<Models.DocumentsTranslation>>(
|
||||
DocumentDbContext.DocumentsTranslations.Where(a => a.DocumentId == item.Id && (a.Language.ToLower() == Language.ToLower())).ToList());
|
||||
else
|
||||
item.documentsTranslations = mapper.Map<List<Db.DocumentsTranslation>, List<Models.DocumentsTranslation>>(
|
||||
DocumentDbContext.DocumentsTranslations.Where(a => a.DocumentId == item.Id).ToList());
|
||||
}
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "Not found");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
|
||||
}
|
||||
public async Task<(bool IsSuccess, IEnumerable<Models.Document> documents, string ErrorMessage)> GetDocumnetsAsync()
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query Question");
|
||||
var documents = await DocumentDbContext.Documents.AsNoTracking().Where(q => q.IsActive).ToListAsync();
|
||||
if (documents != null)
|
||||
{
|
||||
logger?.LogInformation($"{documents.Count} Document(s) found");
|
||||
var result = mapper.Map<IEnumerable<Db.Document>, IEnumerable<Models.Document>>(documents);
|
||||
foreach (var item in result)
|
||||
{
|
||||
item.documentsTranslations = mapper.Map<List<Db.DocumentsTranslation>, List<Models.DocumentsTranslation>>(
|
||||
DocumentDbContext.DocumentsTranslations.Where(a => a.DocumentId == item.Id).ToList());
|
||||
}
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "Not found");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.Document Document, string ErrorMessage)> GetDocumentAsync(int Id)
|
||||
{
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query LinkType");
|
||||
var Document = await DocumentDbContext.Documents.AsNoTracking().FirstOrDefaultAsync(q => q.Id == Id && q.IsActive);
|
||||
if (Document != null)
|
||||
{
|
||||
logger?.LogInformation($"{Document} customer(s) found");
|
||||
var result = mapper.Map<Db.Document, Models.Document>(Document);
|
||||
result.documentsTranslations = mapper.Map<List<Db.DocumentsTranslation>, List<Models.DocumentsTranslation>>(
|
||||
DocumentDbContext.DocumentsTranslations.Where(a => a.DocumentId == result.Id).ToList());
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "Not found");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.Document Document, string ErrorMessage)> PostDocumentAsync(Models.Document Document)
|
||||
{
|
||||
try
|
||||
{
|
||||
var document = mapper.Map<Models.Document, Db.Document>(Document);
|
||||
DocumentDbContext.Documents.Add(document);
|
||||
DocumentDbContext.SaveChanges();
|
||||
var dbtranslation = mapper.Map<List<Models.DocumentsTranslation>, List<Db.DocumentsTranslation>>(Document.documentsTranslations);
|
||||
dbtranslation.ForEach(i => i.DocumentId = document.Id);
|
||||
DocumentDbContext.DocumentsTranslations.AddRange(dbtranslation);
|
||||
DocumentDbContext.SaveChanges();
|
||||
Document.Id = document.Id;
|
||||
return (true, Document, null);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
|
||||
public async Task<(bool IsSuccess, Models.Document Document, string ErrorMessage)> UpdateDocumentAsync(Models.Document Document)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (Document != null)
|
||||
{
|
||||
var existing = DocumentDbContext.Documents.AsNoTracking().FirstOrDefault(x => x.Id == Document.Id);
|
||||
if (existing != null)
|
||||
{
|
||||
var document = mapper.Map<Models.Document, Db.Document>(Document);
|
||||
DocumentDbContext.Documents.Update(document);
|
||||
DocumentDbContext.SaveChanges();
|
||||
var oldtranslations = DocumentDbContext.DocumentsTranslations.Where(a => a.DocumentId == Document.Id).ToList();
|
||||
if (oldtranslations != null)
|
||||
DocumentDbContext.DocumentsTranslations.RemoveRange(oldtranslations);
|
||||
var dbtranslation = mapper.Map<List<Models.DocumentsTranslation>, List<Db.DocumentsTranslation>>(Document.documentsTranslations);
|
||||
dbtranslation.ForEach(i => i.DocumentId = Document.Id);
|
||||
return (true, Document, "Successful");
|
||||
}
|
||||
else
|
||||
{
|
||||
logger?.LogInformation($"{Document} Not found");
|
||||
return (false, null, "Not Found");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
logger?.LogInformation($"{Document} Bad Request");
|
||||
return (false, null, "Bad request");
|
||||
}
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.Document Document, string ErrorMessage)> DeleteDocumentAsync(int Id)
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
Db.Document Document = DocumentDbContext.Documents.AsNoTracking().Where(a => a.Id == Id).FirstOrDefault();
|
||||
if (Document == null)
|
||||
{
|
||||
return (false, null, "Not Found");
|
||||
}
|
||||
Document.IsActive = false;
|
||||
DocumentDbContext.Documents.Update(Document);
|
||||
DocumentDbContext.SaveChanges();
|
||||
return (true, mapper.Map<Db.Document, Models.Document>(Document), $"DocumentId {Id} deleted Successfuly");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
|
||||
public async Task<(bool IsSuccess, int counter, string message)> GetDocumentCounter()
|
||||
{
|
||||
try
|
||||
{
|
||||
int AttachmentId = DocumentDbContext.Documents.Max(a => a.Id);
|
||||
return (true, AttachmentId, "");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
return (false, 0, ex.Message);
|
||||
}
|
||||
}
|
||||
|
||||
//Link Type methods
|
||||
public async Task<(bool IsSuccess, IEnumerable<Models.LinkType> LinkTypes, string ErrorMessage)> GetLinkTypesAsync()
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query Question");
|
||||
var LinkType = await DocumentDbContext.LinkTypes.AsNoTracking().Where(q=>q.IsActive).ToListAsync();
|
||||
if (LinkType != null)
|
||||
{
|
||||
logger?.LogInformation($"{LinkType.Count} LinkTypes(s) found");
|
||||
var result = mapper.Map<IEnumerable<Db.LinkType>, IEnumerable<Models.LinkType>>(LinkType);
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "Not found");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public async Task<(bool IsSuccess, Models.LinkType LinkType, string ErrorMessage)> GetLinkTypeAsync(int Id)
|
||||
{
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query LinkType");
|
||||
var LinkType = await DocumentDbContext.LinkTypes.AsNoTracking().FirstOrDefaultAsync(q => q.Id == Id&&q.IsActive);
|
||||
if (LinkType != null)
|
||||
{
|
||||
logger?.LogInformation($"{LinkType} customer(s) found");
|
||||
var result = mapper.Map<Db.LinkType, Models.LinkType>(LinkType);
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "Not found");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.LinkType LinkType, string ErrorMessage)> PostLinkTypeAsync(Models.LinkType LinkType)
|
||||
{
|
||||
try
|
||||
{
|
||||
logger?.LogInformation("Query LinkType");
|
||||
if (!LinkTypeExists(LinkType.Id))
|
||||
{
|
||||
var dbLink = mapper.Map<Models.LinkType, Db.LinkType>(LinkType);
|
||||
DocumentDbContext.LinkTypes.Add(dbLink);
|
||||
DocumentDbContext.SaveChanges();
|
||||
var result = mapper.Map<Db.LinkType, Models.LinkType>(dbLink);
|
||||
return (true, result, null);
|
||||
}
|
||||
return (false, null, "LinkType is already exits");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.LinkType LinkType, string ErrorMessage)> UpdateLinkTypeAsync(Models.LinkType LinkType)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (LinkType != null)
|
||||
{
|
||||
var existing = DocumentDbContext.LinkTypes.AsNoTracking().FirstOrDefault(x => x.Id == LinkType.Id);
|
||||
if (existing != null)
|
||||
{
|
||||
var dbLink = mapper.Map<Models.LinkType, Db.LinkType>(LinkType);
|
||||
DocumentDbContext.LinkTypes.Update(dbLink);
|
||||
DocumentDbContext.SaveChanges();
|
||||
return (true, mapper.Map<Db.LinkType, Models.LinkType>(dbLink), "Successful");
|
||||
}
|
||||
else
|
||||
{
|
||||
logger?.LogInformation($"{LinkType} Not found");
|
||||
return (false, null, "Not Found");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
logger?.LogInformation($"{LinkType} Bad Request");
|
||||
return (false, null, "Bad request");
|
||||
}
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
public async Task<(bool IsSuccess, Models.LinkType LinkType, string ErrorMessage)> DeleteLinkTypeAsync(int Id)
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
Db.LinkType LinkType = DocumentDbContext.LinkTypes.AsNoTracking().Where(a => a.Id == Id).FirstOrDefault();
|
||||
if (LinkType == null)
|
||||
{
|
||||
return (false, null, "Not Found");
|
||||
}
|
||||
LinkType.IsActive = false;
|
||||
DocumentDbContext.LinkTypes.Update(LinkType);
|
||||
DocumentDbContext.SaveChanges();
|
||||
return (true, mapper.Map<Db.LinkType, Models.LinkType>(LinkType), $"LinkTypeId {Id} deleted Successfuly");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
logger?.LogError(ex.ToString());
|
||||
return (false, null, ex.Message);
|
||||
}
|
||||
}
|
||||
private bool LinkTypeExists(int id)
|
||||
{
|
||||
return DocumentDbContext.LinkTypes.AsNoTracking().Count(e => e.Id == id) > 0;
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,123 @@
|
||||
using AutoMapper;
|
||||
using Azure;
|
||||
using DamageAssesment.Api.Documents.Db;
|
||||
using DamageAssesment.Api.Documents.Interfaces;
|
||||
using DamageAssesment.Api.Documents.Models;
|
||||
using Microsoft.AspNetCore.Http;
|
||||
using Microsoft.EntityFrameworkCore.Metadata.Internal;
|
||||
using System.Diagnostics.Metrics;
|
||||
using System.Net.Http;
|
||||
using System.Security.AccessControl;
|
||||
using System.Security.Principal;
|
||||
|
||||
namespace DamageAssesment.Api.Documents.Providers
|
||||
{
|
||||
public class UploadService : IUploadService
|
||||
{
|
||||
private ILogger<UploadService> logger;
|
||||
private IMapper mapper;
|
||||
private string uploadpath = "";
|
||||
private string Deletepath = "";
|
||||
public UploadService(IConfiguration configuration, ILogger<UploadService> logger, IMapper mapper)
|
||||
{
|
||||
this.logger = logger;
|
||||
this.mapper = mapper;
|
||||
uploadpath = configuration.GetValue<string>("Fileupload:folderpath");
|
||||
Deletepath = configuration.GetValue<string>("Fileupload:Deletepath");
|
||||
}
|
||||
|
||||
public Models.Document UploadDocument(int counter, DocumentInfo documentInfo)
|
||||
{
|
||||
Models.Document Documents = new Models.Document();
|
||||
try
|
||||
{
|
||||
string path = "", UserfileName="";
|
||||
if (documentInfo.File != null)
|
||||
{
|
||||
counter++;
|
||||
var fullDirectoryPath = Path.Combine(Directory.GetCurrentDirectory(), uploadpath);
|
||||
if (!Directory.Exists(fullDirectoryPath)) //Create deirectory if does not exist
|
||||
Directory.CreateDirectory(fullDirectoryPath);
|
||||
UserfileName = Path.GetFileName(documentInfo.File.FileName);
|
||||
var fileName = String.Format("Document_{0}{1}", counter, documentInfo.File.FileExtension);
|
||||
path = Path.Combine(fullDirectoryPath, fileName);
|
||||
File.WriteAllBytes(path, Convert.FromBase64String(documentInfo.File.FileContent));
|
||||
}
|
||||
Documents=new Models.Document (){ linkTypeId = documentInfo.linkTypeId,
|
||||
documentsTranslations = documentInfo.documentsTranslations,
|
||||
docName = UserfileName,
|
||||
url = documentInfo.url, Path = path,IsActive =true,dateCreated=DateTime.Now,dateUpdated=DateTime.Now};
|
||||
|
||||
return Documents;
|
||||
}
|
||||
catch (Exception ex) {
|
||||
return new Models.Document();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
public Models.Document UpdateDocuments(Models.Document document, DocumentInfo documentInfo)
|
||||
{
|
||||
try
|
||||
{
|
||||
Deletefile(document.Path);
|
||||
var fullDirectoryPath = Path.Combine(Directory.GetCurrentDirectory(), uploadpath);
|
||||
if (!Directory.Exists(fullDirectoryPath)) //Create deirectory if does not exist
|
||||
Directory.CreateDirectory(fullDirectoryPath);
|
||||
|
||||
string path = "", UserfileName = "";
|
||||
if (documentInfo.File != null)
|
||||
{
|
||||
UserfileName = Path.GetFileName(documentInfo.File.FileName);
|
||||
var fileName = String.Format("Document_{0}{1}", documentInfo.Id, documentInfo.File.FileExtension);
|
||||
path = Path.Combine(fullDirectoryPath, fileName);
|
||||
File.WriteAllBytes(path, Convert.FromBase64String(documentInfo.File.FileContent));
|
||||
}
|
||||
Models.Document Documents = new Models.Document()
|
||||
{
|
||||
Id = documentInfo.Id,
|
||||
linkTypeId = documentInfo.linkTypeId,
|
||||
documentsTranslations=documentInfo.documentsTranslations,
|
||||
docName = UserfileName,
|
||||
url = documentInfo.url,
|
||||
Path = path,
|
||||
IsActive = true,
|
||||
dateCreated = document.dateCreated,
|
||||
dateUpdated = DateTime.Now
|
||||
};
|
||||
|
||||
return Documents;
|
||||
}
|
||||
|
||||
catch (Exception ex) {
|
||||
return new Models.Document();
|
||||
}
|
||||
}
|
||||
public void Deletefile(string path)
|
||||
{
|
||||
if (path != "")
|
||||
{
|
||||
FileInfo file = new FileInfo(path);
|
||||
if (file?.Exists??false)//check file exsit or not
|
||||
{
|
||||
file.Delete();
|
||||
}
|
||||
}
|
||||
}
|
||||
public void Movefile(string path)
|
||||
{
|
||||
if (path != "")
|
||||
{
|
||||
var pathToSave = Path.Combine(Directory.GetCurrentDirectory(), Deletepath);
|
||||
if (!Directory.Exists(pathToSave)) //Create deirectory if does not exist
|
||||
Directory.CreateDirectory(pathToSave);
|
||||
FileInfo file = new FileInfo(path);
|
||||
if (file?.Exists ?? false)//check file exsit or not
|
||||
{
|
||||
string filename = file.Name.Replace(file.Extension, " ") + DateTime.Now.ToShortDateString().Replace("/","_") + file.Extension;
|
||||
file.MoveTo(pathToSave+"\\"+ filename);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user