prtsie/schengen-visa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Excel export

Browse Source
This commit is contained in:
prtsie
2024-09-29 21:01:35 +03:00
parent e8fd8523aa
commit 188a5a14d3
16 changed files with 411 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
SchengenVisaApi/ApplicationLayer/Services/Applicants/Models/ApplicantModel.cs
View File

@@ -61,4 +61,6 @@ public class ApplicantModel
/// <inheritdoc cref="Applicant.IsNonResident" />
[Required]
public bool IsNonResident { get; set; }
public override string ToString() => Name.ToString();
}

2
SchengenVisaApi/ApplicationLayer/Services/Applicants/Models/NameModel.cs
View File

@@ -16,4 +16,6 @@ public class NameModel
[MaxLength(ConfigurationConstraints.NameLength)]
public string? Patronymic { get; set; }
public override string ToString() => $"{FirstName} {Surname} {Patronymic}".TrimEnd();
}

4
SchengenVisaApi/ApplicationLayer/Services/VisaApplications/Handlers/IVisaApplicationRequestsHandler.cs
View File

@@ -23,5 +23,9 @@ public interface IVisaApplicationRequestsHandler
/// Sets application status to closed
Task HandleCloseRequestAsync(Guid applicationId, CancellationToken cancellationToken);
/// Sets application status to approved or rejected
Task SetApplicationStatusFromAuthorityAsync(Guid applicationId, AuthorityRequestStatuses status, CancellationToken cancellationToken);
/// Returns stream with file with formatted application data to download
Task<Stream> ApplicationToStreamAsync(Guid applicationId, CancellationToken cancellationToken);
}

12
SchengenVisaApi/ApplicationLayer/Services/VisaApplications/Handlers/VisaApplicationRequestsHandler.cs
View File

@@ -17,7 +17,8 @@ public class VisaApplicationRequestsHandler(
IUnitOfWork unitOfWork,
IMapper mapper,
IDateTimeProvider dateTimeProvider,
IUserIdProvider userIdProvider) : IVisaApplicationRequestsHandler
IUserIdProvider userIdProvider,
IEntityWriter entityWriter) : IVisaApplicationRequestsHandler
{
async Task<List<VisaApplicationPreview>> IVisaApplicationRequestsHandler.GetPendingAsync(CancellationToken cancellationToken)
{
@@ -34,7 +35,8 @@ public class VisaApplicationRequestsHandler(
return mapper.Map<List<VisaApplicationPreview>>(visaApplications);
}
async Task<VisaApplicationModel> IVisaApplicationRequestsHandler.GetApplicationForApplicantAsync(Guid id, CancellationToken cancellationToken)
/// <summary> <inheritdoc cref="IVisaApplicationRequestsHandler.GetApplicationForApplicantAsync"/> </summary>
public async Task<VisaApplicationModel> GetApplicationForApplicantAsync(Guid id, CancellationToken cancellationToken)
{
var applicant = await applicants.FindByUserIdAsync(userIdProvider.GetUserId(), cancellationToken);
var application = await applications.GetByApplicantAndApplicationIdAsync(applicant.Id, id, cancellationToken);
@@ -104,4 +106,10 @@ public class VisaApplicationRequestsHandler(
await unitOfWork.SaveAsync(cancellationToken);
}
async Task<Stream> IVisaApplicationRequestsHandler.ApplicationToStreamAsync(Guid applicationId, CancellationToken cancellationToken)
{
var application = await GetApplicationForApplicantAsync(applicationId, cancellationToken);
return await entityWriter.WriteEntityToStream(application, cancellationToken);
}
}

35
SchengenVisaApi/ApplicationLayer/Services/VisaApplications/Models/VisaApplicationModel.cs
View File

@@ -1,4 +1,5 @@
using System.ComponentModel.DataAnnotations;
using System.Text;
using ApplicationLayer.Services.Applicants.Models;
using Domains.VisaApplicationDomain;
@@ -33,8 +34,7 @@ public class VisaApplicationModel
/// <inheritdoc cref="VisaApplication.PermissionToDestCountry" />
public PermissionToDestCountryModel? PermissionToDestCountry { get; set; }
[Required]
public List<PastVisitModel> PastVisits { get; set; } = null!;
[Required] public List<PastVisitModel> PastVisits { get; set; } = null!;
/// <inheritdoc cref="VisaApplication.VisaCategory" />
[Required]
@@ -55,4 +55,35 @@ public class VisaApplicationModel
/// <inheritdoc cref="VisaApplication.ValidDaysRequested" />
[Required]
public int ValidDaysRequested { get; set; }
public string ForGroupToString() => ForGroup ? "For group" : "Individual";
public string PastVisasToString()
{
var stringBuilder = new StringBuilder();
foreach (var visa in PastVisas)
{
stringBuilder.AppendLine($"{visa.Name} issued at {visa.IssueDate.ToShortDateString()} and valid for {visa.ExpirationDate.ToShortDateString()}");
}
return stringBuilder.ToString();
}
public string PastVisitsToString()
{
var stringBuilder = new StringBuilder();
foreach (var visit in PastVisits)
{
stringBuilder.AppendLine($"Visit to {visit.DestinationCountry} started at {visit.StartDate.ToShortDateString()} and ends {visit.EndDate.ToShortDateString()}");
}
return stringBuilder.ToString();
}
public string PermissionToDestCountryToString()
{
return VisaCategory is VisaCategory.Transit
? $"Issued by{PermissionToDestCountry!.Issuer}, expires at {PermissionToDestCountry.ExpirationDate.ToShortDateString()}"
: "Non-transit";
}
}

7
SchengenVisaApi/ApplicationLayer/Services/VisaApplications/NeededServices/IEntityWriter.cs Normal file
View File

@@ -0,0 +1,7 @@
namespace ApplicationLayer.Services.VisaApplications.NeededServices
{
public interface IEntityWriter
{
Task<Stream> WriteEntityToStream(object entity, CancellationToken cancellationToken);
}
}

4
SchengenVisaApi/BlazorWebAssemblyVisaApiClient/Pages/Application.razor
View File

@@ -26,7 +26,7 @@
<tr>
<td colspan="3">
Country and city of birth:<br/>
<em>@application.Applicant.Passport.Number</em>
<em>@application.Applicant.CountryOfBirth, @application.Applicant.CityOfBirth</em>
</td>
</tr>
<tr>
@@ -34,7 +34,7 @@
Citizenship:<br/>
<em>@application.Applicant.Citizenship</em>
</td>
<td >
<td>
Citizenship by birth:<br/>
<em>@application.Applicant.CitizenshipByBirth</em>
</td>

43
SchengenVisaApi/BlazorWebAssemblyVisaApiClient/Pages/Applications.razor
View File

@@ -40,12 +40,17 @@
<td>@application.Status.GetDisplayName()</td>
<td>
<NavLink href="@($"/applications/{application.Id}")">
<button class="btn-outline-primary">See</button>
<button class="btn-primary">See</button>
</NavLink>
@if (currentRole == Constants.ApplicantRole && application.Status is ApplicationStatus.Pending)
@if (currentRole == Constants.ApplicantRole)
{
<span> | </span>
<input type="button" class="border-danger" @onclick="() => CloseApplication(application)" value="Close"/>
<input type="button" class="btn-outline-primary" @onclick="() => DownloadApplication(application)" value="Download"/>
if (application.Status is ApplicationStatus.Pending)
{
<span> | </span>
<input type="button" class="border-danger" @onclick="() => CloseApplication(application)" value="Close"/>
}
}
</td>
</tr>
@@ -53,12 +58,28 @@
</tbody>
</table >
<script>
window.downloadFileFromStream = async (contentStreamReference) => {
const arrayBuffer = await contentStreamReference.arrayBuffer();
const blob = new Blob([arrayBuffer]);
const url = URL.createObjectURL(blob);
const anchorElement = document.createElement('a');
anchorElement.href = url;
anchorElement.download = 'Application.xlsx';
anchorElement.click();
anchorElement.remove();
URL.revokeObjectURL(url);
}
</script>
@code {
private string currentRole = null!;
private List<VisaApplicationPreview> applications = [];
[Inject] private IUserDataProvider UserDataProvider { get; set; } = null!;
[Inject] private IJSRuntime JavaScriptInterop { get; set; } = null!;
protected override async Task OnInitializedAsync()
{
try
@@ -69,6 +90,7 @@
{
ErrorHandler.Handle(e);
}
await Fetch();
}
@@ -103,4 +125,19 @@
}
}
private async Task DownloadApplication(VisaApplicationPreview application)
{
try
{
var response = await Client.DownloadApplicationForApplicantAsync(application.Id);
using var streamRef = new DotNetStreamReference(stream: response.Stream);
await JavaScriptInterop.InvokeVoidAsync("downloadFileFromStream", streamRef);
}
catch (Exception e)
{
ErrorHandler.Handle(e);
}
}
}

2
SchengenVisaApi/Infrastructure/DependencyInjection.cs
View File

@@ -8,6 +8,7 @@ using Infrastructure.Database.Applicants.Repositories;
using Infrastructure.Database.Generic;
using Infrastructure.Database.Users.Repositories;
using Infrastructure.Database.VisaApplications.Repositories;
using Infrastructure.EntityToExcelTemplateWriter;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
@@ -37,6 +38,7 @@ public static class DependencyInjection
services.AddScoped<IUsersRepository, UsersRepository>();
services.AddSingleton<IDateTimeProvider, DateTimeProvider>();
services.AddSingleton<IEntityWriter, ExcelWriter>();
services.AddHttpContextAccessor();
services.AddScoped<IUserIdProvider, UserIdProvider>();

131
SchengenVisaApi/Infrastructure/EntityToExcelTemplateWriter/ExcelWriter.cs Normal file
View File

@@ -0,0 +1,131 @@
using System.Reflection;
using System.Text;
using ApplicationLayer.Services.VisaApplications.NeededServices;
using DocumentFormat.OpenXml.Packaging;
using DocumentFormat.OpenXml.Spreadsheet;
using Microsoft.Extensions.Primitives;
namespace Infrastructure.EntityToExcelTemplateWriter
{
/// <summary>
/// Writes object to excel using template.xlsx file and reflections
/// </summary>
public class ExcelWriter : IEntityWriter
{
private const char InsertionSymbol = '$';
private readonly char[] endChars = [',', ';'];
/// <summary>
/// Write object to stream in Excel table format
/// </summary>
/// <param name="entity"> object to write </param>
/// <param name="cancellationToken"> cancellation token </param>
/// <returns> Stream with template.xlsx file with replaced entries like '$EntityPropName.AnotherProp' </returns>
/// <exception cref="NullReferenceException"> thrown when template file is incorrect </exception>
/// <exception cref="InvalidOperationException"> thrown if any property path in template is incorrect</exception>
public async Task<Stream> WriteEntityToStream(object entity, CancellationToken cancellationToken)
{
var outStream = new MemoryStream();
await using (var stream = File.Open("template.xlsx", FileMode.Open, FileAccess.Read))
{
await stream.CopyToAsync(outStream, cancellationToken);
}
using var spreadsheetDocument = SpreadsheetDocument.Open(outStream, true);
var workbookPart = spreadsheetDocument.WorkbookPart
?? throw new NullReferenceException("There is no workbook part in document");
var shareStringTable = workbookPart.SharedStringTablePart?.SharedStringTable ??
throw new NullReferenceException("There is no data in document");
var shareStringTableItems = shareStringTable.Elements<SharedStringItem>().ToArray();
foreach (var item in shareStringTableItems)
{
if (string.IsNullOrEmpty(item.InnerText))
{
continue;
}
var entries = item.InnerText.Split();
for (var i = 0; i < entries.Length; i++)
{
var entry = entries[i];
if (entry.FirstOrDefault() is not InsertionSymbol || entry.Length <= 1)
{
continue;
}
entry = entry[1..];
var trimmedCount = entry.Length - entry.TrimEnd(endChars).Length;
var trimmed = entry[^trimmedCount..];
entry = entry.TrimEnd(endChars);
var memberPath = entry.Split('.');
var value = GetValueFor(entity, memberPath.First());
var stringToInsert = "None";
foreach (var memberName in memberPath.Skip(1))
{
if (value is null)
{
break;
}
value = GetValueFor(value, memberName);
}
if (value is not null)
{
switch (value)
{
case DateTime date:
stringToInsert = date.ToShortDateString();
break;
case Enum val:
var enumString = val.ToString();
var stringBuilder = new StringBuilder();
for (var charIndex = 0; charIndex < enumString.Length - 1; charIndex++)
{
stringBuilder.Append(enumString[charIndex]);
if (char.IsUpper(enumString[charIndex + 1]))
{
stringBuilder.Append(' ');
}
}
stringBuilder.Append(enumString.Last());
stringToInsert = stringBuilder.ToString();
break;
default:
stringToInsert = value.ToString();
break;
}
}
entries[i] = stringToInsert! + trimmed;
}
item.Text!.Text = string.Join(' ', entries);
}
spreadsheetDocument.Save();
return outStream;
}
private static object? GetValueFor(object entity, string member)
{
var memberInfo = entity.GetType()
.GetMembers()
.FirstOrDefault(p => p.Name == member)
?? throw new InvalidOperationException(
$"Invalid member path in document. Not found: {member}");
return memberInfo switch
{
PropertyInfo propertyInfo => propertyInfo.GetValue(entity),
MethodInfo methodInfo => methodInfo.Invoke(entity, []),
_ => throw new InvalidOperationException("Only properties and methods allowed.")
};
}
}
}

1
SchengenVisaApi/Infrastructure/Infrastructure.csproj
View File

@@ -11,6 +11,7 @@
</ItemGroup>
<ItemGroup>
<PackageReference Include="DocumentFormat.OpenXml" Version="3.1.0" />
<PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.8" />
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0-preview.7.24405.3" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="9.0.0-preview.7.24405.3" />

16
SchengenVisaApi/SchengenVisaApi/Controllers/VisaApplicationController.cs
View File

@@ -119,4 +119,20 @@ public class VisaApplicationController(
await visaApplicationRequestsHandler.SetApplicationStatusFromAuthorityAsync(applicationId, status, cancellationToken);
return Ok();
}
/// <summary> Returns application </summary>
/// <remarks> Accessible only for applicant </remarks>
[HttpGet("/forApplicant/{applicationId:guid}/download")]
[Produces("application/octet-stream")]
[ProducesResponseType<object>(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status403Forbidden)]
[ProducesResponseType(StatusCodes.Status404NotFound)]
[Authorize(policy: PolicyConstants.ApplicantPolicy)]
public async Task<IActionResult> DownloadApplicationForApplicant(Guid applicationId, CancellationToken cancellationToken)
{
var result = await visaApplicationRequestsHandler.ApplicationToStreamAsync(applicationId, cancellationToken);
result.Position = 0;
return File(result, "application/octet-stream", "Application.xlsx");
}
}

2
SchengenVisaApi/SchengenVisaApi/ExceptionFilters/GlobalExceptionsFilter.cs
View File

@@ -61,6 +61,8 @@ public class GlobalExceptionsFilter : IAsyncExceptionFilter
problemDetails.Status = StatusCodes.Status500InternalServerError;
problemDetails.Title = "An unhandled error occured";
problemDetails.Type = "https://datatracker.ietf.org/doc/html/rfc7231#section-6.6.1";
Console.WriteLine($"Error!!!: {exception.Message}");
break;
}

BIN
SchengenVisaApi/SchengenVisaApi/template.xlsx Normal file
View File

Binary file not shown.

158
SchengenVisaApi/VisaApiClient/Client.cs
View File

@@ -1722,6 +1722,129 @@ namespace VisaApiClient
}
}
/// <summary>
/// Returns application
/// </summary>
/// <remarks>
/// Accessible only for applicant
/// </remarks>
/// <returns>Success</returns>
/// <exception cref="ApiException">A server side error occurred.</exception>
public virtual System.Threading.Tasks.Task<FileResponse> DownloadApplicationForApplicantAsync(System.Guid applicationId)
{
return DownloadApplicationForApplicantAsync(applicationId, System.Threading.CancellationToken.None);
}
/// <param name="cancellationToken">A cancellation token that can be used by other objects or threads to receive notice of cancellation.</param>
/// <summary>
/// Returns application
/// </summary>
/// <remarks>
/// Accessible only for applicant
/// </remarks>
/// <returns>Success</returns>
/// <exception cref="ApiException">A server side error occurred.</exception>
public virtual async System.Threading.Tasks.Task<FileResponse> DownloadApplicationForApplicantAsync(System.Guid applicationId, System.Threading.CancellationToken cancellationToken)
{
if (applicationId == null)
throw new System.ArgumentNullException("applicationId");
var client_ = _httpClient;
var disposeClient_ = false;
try
{
using (var request_ = await CreateHttpRequestMessageAsync(cancellationToken).ConfigureAwait(false))
{
request_.Method = new System.Net.Http.HttpMethod("GET");
request_.Headers.Accept.Add(System.Net.Http.Headers.MediaTypeWithQualityHeaderValue.Parse("application/octet-stream"));
var urlBuilder_ = new System.Text.StringBuilder();
if (!string.IsNullOrEmpty(_baseUrl)) urlBuilder_.Append(_baseUrl);
// Operation Path: "forApplicant/{applicationId}/download"
urlBuilder_.Append("forApplicant/");
urlBuilder_.Append(System.Uri.EscapeDataString(ConvertToString(applicationId, System.Globalization.CultureInfo.InvariantCulture)));
urlBuilder_.Append("/download");
await PrepareRequestAsync(client_, request_, urlBuilder_, cancellationToken).ConfigureAwait(false);
var url_ = urlBuilder_.ToString();
request_.RequestUri = new System.Uri(url_, System.UriKind.RelativeOrAbsolute);
await PrepareRequestAsync(client_, request_, url_, cancellationToken).ConfigureAwait(false);
var response_ = await client_.SendAsync(request_, System.Net.Http.HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false);
var disposeResponse_ = true;
try
{
var headers_ = new System.Collections.Generic.Dictionary<string, System.Collections.Generic.IEnumerable<string>>();
foreach (var item_ in response_.Headers)
headers_[item_.Key] = item_.Value;
if (response_.Content != null && response_.Content.Headers != null)
{
foreach (var item_ in response_.Content.Headers)
headers_[item_.Key] = item_.Value;
}
await ProcessResponseAsync(client_, response_, cancellationToken).ConfigureAwait(false);
var status_ = (int)response_.StatusCode;
if (status_ == 200 || status_ == 206)
{
var responseStream_ = response_.Content == null ? System.IO.Stream.Null : await response_.Content.ReadAsStreamAsync().ConfigureAwait(false);
var fileResponse_ = new FileResponse(status_, headers_, responseStream_, null, response_);
disposeClient_ = false; disposeResponse_ = false; // response and client are disposed by FileResponse
return fileResponse_;
}
else
if (status_ == 401)
{
var objectResponse_ = await ReadObjectResponseAsync<ProblemDetails>(response_, headers_, cancellationToken).ConfigureAwait(false);
if (objectResponse_.Object == null)
{
throw new ApiException("Response was null which was not expected.", status_, objectResponse_.Text, headers_, null);
}
throw new ApiException<ProblemDetails>("Unauthorized", status_, objectResponse_.Text, headers_, objectResponse_.Object, null);
}
else
if (status_ == 403)
{
var objectResponse_ = await ReadObjectResponseAsync<ProblemDetails>(response_, headers_, cancellationToken).ConfigureAwait(false);
if (objectResponse_.Object == null)
{
throw new ApiException("Response was null which was not expected.", status_, objectResponse_.Text, headers_, null);
}
throw new ApiException<ProblemDetails>("Forbidden", status_, objectResponse_.Text, headers_, objectResponse_.Object, null);
}
else
if (status_ == 404)
{
var objectResponse_ = await ReadObjectResponseAsync<ProblemDetails>(response_, headers_, cancellationToken).ConfigureAwait(false);
if (objectResponse_.Object == null)
{
throw new ApiException("Response was null which was not expected.", status_, objectResponse_.Text, headers_, null);
}
throw new ApiException<ProblemDetails>("Not Found", status_, objectResponse_.Text, headers_, objectResponse_.Object, null);
}
else
{
var responseData_ = response_.Content == null ? null : await response_.Content.ReadAsStringAsync().ConfigureAwait(false);
throw new ApiException("The HTTP status code of the response was not expected (" + status_ + ").", status_, responseData_, headers_, null);
}
}
finally
{
if (disposeResponse_)
response_.Dispose();
}
}
}
finally
{
if (disposeClient_)
client_.Dispose();
}
}
protected struct ObjectResponseResult<T>
{
public ObjectResponseResult(T responseObject, string responseText)
@@ -2443,6 +2566,41 @@ namespace VisaApiClient
}
[System.CodeDom.Compiler.GeneratedCode("NSwag", "14.1.0.0 (NJsonSchema v11.0.2.0 (Newtonsoft.Json v13.0.0.0))")]
public partial class FileResponse : System.IDisposable
{
private System.IDisposable? _client;
private System.IDisposable? _response;
public int StatusCode { get; private set; }
public System.Collections.Generic.IReadOnlyDictionary<string, System.Collections.Generic.IEnumerable<string>> Headers { get; private set; }
public System.IO.Stream Stream { get; private set; }
public bool IsPartial
{
get { return StatusCode == 206; }
}
public FileResponse(int statusCode, System.Collections.Generic.IReadOnlyDictionary<string, System.Collections.Generic.IEnumerable<string>> headers, System.IO.Stream stream, System.IDisposable? client, System.IDisposable? response)
{
StatusCode = statusCode;
Headers = headers;
Stream = stream;
_client = client;
_response = response;
}
public void Dispose()
{
Stream.Dispose();
if (_response != null)
_response.Dispose();
if (_client != null)
_client.Dispose();
}
}
[System.CodeDom.Compiler.GeneratedCode("NSwag", "14.1.0.0 (NJsonSchema v11.0.2.0 (Newtonsoft.Json v13.0.0.0))")]

2
SchengenVisaApi/VisaApiClient/clientGeneratorConfig.nswag
View File

File diff suppressed because one or more lines are too long