fede/AlquilaFacil
Public Access
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

tengo que arreglar el tema de los streams

Browse Source
This commit is contained in:
fedpo
2025-01-12 04:19:39 -03:00
parent c362949bdc
commit db7c66e15b
6 changed files with 263 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

112
Aspnet/Controllers/ContratoController.cs
View File

@@ -1,4 +1,7 @@
using System.Net;
using System.Text.Json;
using AlquilaFacil.Builder;
using AlquilaFacil.Config;
using Entidades;
using Entidades.Dto;
using Microsoft.AspNetCore.Mvc;
@@ -210,12 +213,21 @@ public class ContratoController: ControllerBase {
}
private readonly IMinioClient mc;
public ContratoController(IMinioClient mcc){
mc = mcc;
public ContratoController(IMinioClient minioClient) {
mc = minioClient;
if (mc == null){
MinioConfigcus? mcon = JsonSerializer.Deserialize<MinioConfigcus>(System.IO.File.ReadAllText("./settings.json"))?? null;
if (mcon == null) throw new Exception();
mc = new MinioClient().WithCredentials(mcon.usr, mcon.scrt)
.WithEndpoint("192.168.1.11:9000")
.WithSSL(false)
.Build();
}
}
[HttpPost("api/contratos/subirContrato")]
public IActionResult subirContrato([FromHeader(Name = "Auth")]string Auth, [FromForm]long idcontrato, IFormFile contrato) {
public async Task<IActionResult> subirContrato([FromHeader(Name = "Auth")]string Auth, [FromForm]long idcontrato, [FromForm]DateTime ubicarnotificacion, IFormFile contrato) {
if (String.IsNullOrWhiteSpace(Auth)) return BadRequest("");
var validacion1 = RepositorioGrupos.Singleton.CheckGrupos(Auth, "Propietario");
if (validacion1 == false) return Unauthorized();
@@ -223,49 +235,117 @@ public class ContratoController: ControllerBase {
if (idcontrato<=0) return BadRequest(new {message = "No puede tener un id contrato menor o igual a 0"});
Contrato? contr = RepositorioContratos.Singleton.ObtenerPreContratoPorId(idcontrato);
if (contr == null) return BadRequest(new { message = "No hay precontrato por esa id"});
if (contr.Dniinquilino == 0 || contr.Dnipropietario == 0 || contr.Idpropiedad == 0 ||
contr.Dniinquilino == null || contr.Dnipropietario == null || contr.Idpropiedad == null) {
return BadRequest(new { message = "Estan mal cargados los datos del precontrato comunicate con un administrador"});
}
Cliente? cli = RepositorioUsuarios.Singleton.ObtenerClientePorToken(Auth);
if (cli == null || contr.DnipropietarioNavigation == null) return BadRequest(new { message ="No se pudo checkear que el token corresponda al propietario"});
if (cli.Dni != contr.DnipropietarioNavigation.Dni) return BadRequest(new { message = "el token de usuario no coinside con el usuario propietario"});
if (contrato == null) return BadRequest(new { message = "Debe subir un archivo." });
if (contrato.ContentType != "application/pdf") return BadRequest(new { message = "El archivo debe ser un documento PDF." });
if (!Path.GetExtension(contrato.FileName).Equals(".pdf", StringComparison.OrdinalIgnoreCase)) return BadRequest(new { message = "El archivo debe tener la extensión .pdf." });
string nuevoNombreArchivo = $"id:{contr.Id}-inq:{contr.Dniinquilino}-propi:{contr.Dnipropietario}-idprop:{contr.Idpropiedad}.pdf";
var ret = subirContrato(contrato, mc, nuevoNombreArchivo).Wait();
bool ret = await subirContrato(contrato, nuevoNombreArchivo);
if(ret == false) return BadRequest(new {message = "No se pudo subir el archivo"});
ret = RepositorioContratos.Singleton.AddUrl(contr.Id, nuevoNombreArchivo);
if (ret == false) return BadRequest(new { message = "No se pudo guardar la url del contrato" });
var noti = new NotificacioneBuilder()
.SetDniremitente(contr.Dnipropietario??0)
.SetIdpropiedad(contr.Idpropiedad??0)
.SetDnicliente(contr.Dniinquilino??0)
.SetAccion("Aceptar Contrato")
.SetMensaje($"El propietario: {contr.Dnipropietario}, hizo un documento de contrato: {contr.Id}")
.SetFecha(DateTime.Now)
.SetLeido(false)
.Build();
RepositorioNotificaciones.Singleton.MarcarComoLeido(cli.Dni, ubicarnotificacion);
ret = RepositorioNotificaciones.Singleton.AltaNotificacion(noti);
return (ret)?
Ok(new { message = "se notifico al futuro inquilino"}): BadRequest(new { message = "No se pudo enviar la notificacion"});
}
[HttpGet("api/contrato/getdocumento")]
public async Task<IActionResult> ObtenerContrato([FromHeader(Name = "Auth")]string Auth, [FromQuery]long idcontrato) {
if (String.IsNullOrWhiteSpace(Auth)) return BadRequest("");
var validacion1 = RepositorioGrupos.Singleton.CheckGrupos(Auth, "Inquilino");
if (validacion1 == false) return Unauthorized();
if (idcontrato <= 0) return BadRequest(new {message = "La id no puede ser igual o menor a 0"});
Contrato? contr = RepositorioContratos.Singleton.ObtenerPreContratoPorId(idcontrato);
if (contr == null || contr.Dniinquilino == 0) return BadRequest(new { message = "No hay un precontrato por esa id"});
Cliente? cli = RepositorioUsuarios.Singleton.ObtenerClientePorToken(Auth);
if (cli == null) return BadRequest(new { message = "No hay un cliente por ese token"});
if (cli.Dni != contr.Dniinquilino) return BadRequest(new { message = "El token no corresponde con el del inquilino"});
string nuevoNombreArchivo = $"id:{contr.Id}-inq:{contr.Dniinquilino}-propi:{contr.Dnipropietario}-idprop:{contr.Idpropiedad}.pdf";
try{
using( var memstream = new MemoryStream()){
var goa = new GetObjectArgs()
.WithBucket("alquilafacil")
.WithObject(nuevoNombreArchivo)
.WithCallbackStream(async stream => {
memstream.Position=0;
await stream.CopyToAsync(memstream);
});
await mc.GetObjectAsync(goa);
memstream.Position = 0;
if (memstream.Length == 0) return BadRequest(new { message = "El archivo está vacío" });
return File(memstream.ToArray(), "application/pdf", nuevoNombreArchivo);
}
} catch (Exception e){
Console.Error.WriteLine(e);
return BadRequest(new { message = "Fallo al intentar obtener el archivo del almacenamiento o este no existe"});
}
return Ok();
}
[HttpPost("api/contratos/aceptarContrato")]
public IActionResult AceptarContrato([FromHeader(Name = "Auth")]string Auth){
if (String.IsNullOrWhiteSpace(Auth)) return BadRequest("");
if (String.IsNullOrWhiteSpace(Auth)) return BadRequest();
var validacion1 = RepositorioGrupos.Singleton.CheckGrupos(Auth, "Inquilino");
if (validacion1 == false) return Unauthorized();
return Ok();
}
private async Task<bool> subirContrato(IFormFile f, IMinioClient m, string flname) {
private async Task<bool> subirContrato(IFormFile f, string flname) {
try {
var buck = new BucketExistsArgs().WithBucket("alquilafacil");
bool encontrado = await m.BucketExistsAsync(buck).ConfigureAwait(false);
bool encontrado = await mc.BucketExistsAsync(buck).ConfigureAwait(false);
if(!encontrado){
var mb = new MakeBucketArgs().WithBucket("alquilafacil");
await m.MakeBucketAsync(mb).ConfigureAwait(false);
await mc.MakeBucketAsync(mb).ConfigureAwait(false);
}
using (var stream = f.OpenReadStream()){
var putbj = new PutObjectArgs()
using (var stream = new MemoryStream()){
await f.CopyToAsync(stream);
stream.Position=0;
PutObjectArgs putbj = new PutObjectArgs()
.WithBucket("alquilafacil")
.WithObject(flname)
.WithStreamData(stream)
.WithContentType("application/pdf")
.WithObjectSize(f.Length);
await m.PutObjectAsync(putbj).ConfigureAwait(false);
.WithObjectSize(stream.Length);
await mc.PutObjectAsync(putbj);
}
return true;
} catch (MinioException e ) {
} catch (Exception e ) {
Console.Error.WriteLine(e.Message);
return false;
}