Ancora update gestione controller queue

This commit is contained in:
Samuele Locatelli
2023-04-19 15:02:25 +02:00
parent a0f30600b4
commit 72a2bc53da
2 changed files with 15 additions and 58 deletions
@@ -21,30 +21,6 @@ namespace WebDoorCreator.API.Controllers
#endregion Public Constructors
#if false
/// <summary>
/// Lunghezza coda in attesa
/// </summary>
/// <returns></returns>
[HttpGet("ActPendingLenght")]
public async Task<long> ActPendingLenght()
{
long numQueue = await QDataServ.NumRequestPending();
return numQueue;
}
/// <summary>
/// Lunghezza coda in fase di processing
/// </summary>
/// <returns></returns>
[HttpGet("ActProcessingLenght")]
public async Task<long> ActProcessingLenght()
{
long numQueue = await QDataServ.NumRequestProcessing();
return numQueue;
}
#endif
#region Public Methods
/// <summary>
@@ -68,37 +44,13 @@ namespace WebDoorCreator.API.Controllers
/// </summary>
/// <param name="calcResults">Risultati elaborazioni in formato CalcResultDTO</param>
/// <returns></returns>
[HttpPost("SaveProcessingResult")]
public async Task<bool> SaveProcessingResult(List<CalcResultDTO> calcResults)
[HttpPost("SaveProcResult")]
public async Task<bool> SaveProcResult(List<CalcResultDTO> calcResults)
{
bool answ = await QDataServ.SaveProcessingResult(calcResults);
return answ;
}
#if false
/// <summary>
/// Elenco richieste in stato pending
/// </summary>
/// <returns></returns>
[HttpGet("ShowPending")]
public async Task<Dictionary<string, string>?> ShowPending()
{
var actQueue = await QDataServ.RequestPending();
return actQueue;
}
/// <summary>
/// Elenco richeiste in stato processing
/// </summary>
/// <returns></returns>
[HttpGet("ShowProcessing")]
public async Task<Dictionary<string, string>> ShowProcessing()
{
var actQueue = await QDataServ.RequestProcessing();
return actQueue;
}
#endif
/// <summary>
/// Elenco richieste raggruppate x stato
/// </summary>
@@ -121,7 +73,7 @@ namespace WebDoorCreator.API.Controllers
/// - verranno messi nella coda FIFO processing
/// </summary>
/// <returns></returns>
[HttpGet("TakeProcessingItems")]
[HttpGet("TakeNextItems")]
public async Task<Dictionary<string, string>> TakeProcessingItems(int numItems)
{
var actQueue = await QDataServ.TakeProcessingItems(numItems);