COmpletata validazione SRV API UI + test da console
This commit is contained in:
@@ -6,6 +6,7 @@ using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using static System.Data.Entity.Infrastructure.Design.Executor;
|
||||
|
||||
namespace EgwProxy.DataLayer.Controllers
|
||||
{
|
||||
@@ -71,6 +72,41 @@ namespace EgwProxy.DataLayer.Controllers
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// Aggiorna i record indicati inserendo dataora corrente x DtSent
|
||||
/// </summary>
|
||||
/// <param name="rec2upd"></param>
|
||||
/// <returns></returns>
|
||||
public bool SetDtSent(List<LogMachineModel> rec2upd)
|
||||
{
|
||||
bool done = false;
|
||||
using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
|
||||
{
|
||||
DateTime adesso = DateTime.Now;
|
||||
foreach (var item in rec2upd)
|
||||
{
|
||||
var currRec = localDbCtx
|
||||
.DbSetLogMac
|
||||
.Where(x => x.DtSent == null && x.LogDbId == item.LogDbId)
|
||||
.FirstOrDefault();
|
||||
if (currRec != null)
|
||||
{
|
||||
currRec.DtSent = adesso;
|
||||
}
|
||||
|
||||
|
||||
// indico modificato
|
||||
localDbCtx.Entry(currRec).State = System.Data.Entity.EntityState.Modified;
|
||||
|
||||
}
|
||||
// Salvataggio finale
|
||||
localDbCtx.SaveChanges();
|
||||
}
|
||||
|
||||
return done;
|
||||
}
|
||||
|
||||
#endregion Public Methods
|
||||
|
||||
#region Private Fields
|
||||
|
||||
@@ -553,12 +553,6 @@ namespace MagMan.Data.Tenant.Controllers
|
||||
{
|
||||
try
|
||||
{
|
||||
#if false
|
||||
// aggiungo records
|
||||
dbCtx
|
||||
.DbSetLogMac
|
||||
.AddRange(recList);
|
||||
#endif
|
||||
// verifico record x data/progetto...
|
||||
foreach (var item in recList)
|
||||
{
|
||||
|
||||
@@ -197,7 +197,7 @@ namespace DemoApp
|
||||
|
||||
// carico dal DB primi 50 rec e li invio 10 alla volta...
|
||||
LogMachineController lmc = new LogMachineController();
|
||||
int num2send = 50;
|
||||
int num2send = 20;
|
||||
int batchSize = 10;
|
||||
int numSent = 0;
|
||||
var recList = lmc.GetUnsentAsc(num2send);
|
||||
@@ -216,6 +216,8 @@ namespace DemoApp
|
||||
var res = commLib.LogMachineSend(listDto);
|
||||
if (res)
|
||||
{
|
||||
// registro dati inviati...
|
||||
lmc.SetDtSent(currList);
|
||||
Console.WriteLine($"Inviati {batchSize}rec | {numSent} --> {numSent + batchSize}");
|
||||
numSent += batchSize;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user