using k8s.Models;
using MagMan.Core;
using MagMan.Core.DTO;
using MagMan.Data.Admin.DbModels;
using MagMan.Data.Admin.Services;
using MagMan.Data.Tenant.DbModels;
using MagMan.Data.Tenant.Services;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using NLog;
using Org.BouncyCastle.Asn1.Pkcs;
using System.Diagnostics;
namespace MagMan.UI.Controllers
{
[Route("api/[controller]")]
[ApiController]
public class ProjectsController : ControllerBase
{
#region Public Constructors
public ProjectsController(MTAdminService MTDataService, TenantService TDataService)
{
MTAdmService = MTDataService;
TService = TDataService;
// json serializer... FIX errore loop circolare https://www.ryadel.com/en/jsonserializationexception-self-referencing-loop-detected-error-fix-entity-framework-asp-net-core/
JSSettings = new JsonSerializerSettings()
{
ReferenceLoopHandling = ReferenceLoopHandling.Ignore
};
Log.Info("Avviata classe ProjectsController");
}
#endregion Public Constructors
#region Public Methods
///
/// Controllo status Alive
/// GET: api/Machines/alive
///
///
[HttpGet("alive")]
public string alive()
{
//Log.Debug("Chiamata alive");
return $"OK";
}
// GET api/Machines/5
[HttpGet]
public async Task> Get()
{
// se non ho chaive --> vuoto!
List ListRecords = new List();
await Task.Delay(100);
return ListRecords;
}
///
/// Elenco Progetti dato RestToken
///
/// Rest Token cliente
/// Chiave associata ai progetti
///
// GET api/Machines/2cba60c7-7be4-40b1-aa0d-52e7c71fc1a7
[HttpGet("{id}")]
public async Task> Get(string id, int KeyNum)
{
List ListRecords = new List();
if (!string.IsNullOrEmpty(id))
{
// in primis recupero codice chiave da token...
int nKey = await MTAdmService.MainKeyByToken(id);
var rawList = await TService.ProjectGetAll(nKey);
ListRecords = rawList.Select(x => TService.ProjectToDto(x)).ToList();
}
return ListRecords;
}
///
/// Elenco Progetti dato RestToken
///
/// Rest Token cliente
/// Chiave associata ai progetti
/// Key del proj
///
// GET api/Machines/2cba60c7-7be4-40b1-aa0d-52e7c71fc1a7
[HttpGet("single/{id}")]
public async Task GetSingle(string id, int ProjCloudId)
{
ProjectDTO CurrRec = new ProjectDTO();
if (!string.IsNullOrEmpty(id))
{
// in primis recupero codice chiave da token...
int nKey = await MTAdmService.MainKeyByToken(id);
var rawResult = await TService.ProjectGetById(nKey, ProjCloudId);
CurrRec = rawResult != null ? TService.ProjectToDto(rawResult) : new ProjectDTO();
}
return CurrRec;
}
///
/// Processa una chiamata POST per l'invio di un oggetto di upsert progetto
/// PUT: api/Inventory/upsert/00000000-0000-0000-0000-000000000000
///
/// token comunicazione
/// ID del progetto creato da usare come CloudId
[HttpPost("upsert/{id}")]
public async Task upsert(string id, [FromBody] RestPayload.Projects rawData)
{
int answ = 0;
// verifico ci sia valore
if (!string.IsNullOrEmpty(id) && rawData != null && rawData.Project != null)
{
// in primis recupero codice chiave da token...
int nKey = await MTAdmService.MainKeyByToken(id);
if (nKey > 0)
{
// converto ProjDto --> DB
var currRec = TService.ProjectFromDto(rawData.Project);
try
{
answ = await TService.ProjectUpsert(nKey, currRec);
}
catch (Exception exc)
{
Log.Error($"ProjectsController.upsert | Errore in fase salvataggio ProjectDTO{Environment.NewLine}{exc}");
}
// resetto cache redis
await MTAdmService.FlushRedisCache();
}
}
return answ;
}
#endregion Public Methods
#region Private Fields
private static JsonSerializerSettings? JSSettings;
///
/// Classe per logging
///
private static NLog.Logger Log = LogManager.GetCurrentClassLogger();
#endregion Private Fields
#region Private Properties
private MTAdminService MTAdmService { get; set; } = null!;
private TenantService TService { get; set; } = null!;
#endregion Private Properties
}
}