OK esecuzione registrazione ODL Energy

2024-04-02 19:24:11 +02:00
parent 5240ffe2f6
commit 8be883256e
13 changed files with 224 additions and 43 deletions
@@ -1,4 +1,5 @@
-using Microsoft.Data.SqlClient;
+using DnsClient.Protocol;
+using Microsoft.Data.SqlClient;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using MP.Data.DatabaseModels;
@@ -371,6 +372,118 @@ namespace MP.Data.Controllers
            return dbResult;
        }

+        public DateTime CalcNextExe(TaskListModel taskRec)
+        {
+            DateTime dtNext = DateTime.Today;
+            try
+            {
+                // calcolo next exec da tipo...
+                switch (taskRec.Freq)
+                {
+                    case TaskFreqType.ND:
+                        dtNext = taskRec.DtLastExec.AddDays(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Sec:
+                        dtNext = taskRec.DtLastExec.AddSeconds(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Min:
+                        dtNext = taskRec.DtLastExec.AddMinutes(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Hour:
+                        dtNext = taskRec.DtLastExec.AddHours(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Day:
+                        dtNext = taskRec.DtLastExec.AddDays(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Week:
+                        dtNext = taskRec.DtLastExec.AddDays(7 * taskRec.Cad);
+                        break;
+                    case TaskFreqType.Month:
+                        dtNext = taskRec.DtLastExec.AddMonths(taskRec.Cad);
+                        break;
+                    case TaskFreqType.Year:
+                        dtNext = taskRec.DtLastExec.AddYears(taskRec.Cad);
+                        break;
+                    default:
+                        dtNext = taskRec.DtLastExec.AddDays(taskRec.Cad);
+                        break;
+                }
+            }
+            catch (Exception exc)
+            {
+                Log.Error($"Eccezione in CalcNextExe{Environment.NewLine}{exc}");
+            }
+            return dtNext;
+        }
+
+        /// <summary>
+        /// Chiamata esecuzione di un singolo task programmato
+        /// </summary>
+        /// <param name="TaskId"></param>
+        /// <returns></returns>
+        public TaskResultModel ExecuteTask(int TaskId)
+        {
+            TaskResultModel callRes = new TaskResultModel();
+            using (var dbCtx = new MoonPro_STATSContext(_configuration))
+            {
+                // imposto timeout a 5 min
+                dbCtx.Database.SetCommandTimeout(TimeSpan.FromMinutes(5));
+                try
+                {
+                    DateTime dtStart = DateTime.Now;
+                    // recupero i dati da richiamare...
+                    var currRec = dbCtx
+                                .DbSetTaskList
+                                .Where(x => x.TaskId == TaskId)
+                                .FirstOrDefault();
+                    if (currRec != null)
+                    {
+                        // recupero comando
+                        string sqlCommand = currRec.Command;
+                        string rawParams = currRec.Args;
+                        callRes = dbCtx
+                                    .DbSetTaskResult
+                                    .FromSqlRaw($"EXEC {sqlCommand} {rawParams}")
+                                    .AsNoTracking()
+                                    .AsEnumerable()
+                                    .FirstOrDefault();
+                        DateTime dtEnd = DateTime.Now;
+
+                        // preparo record esecuzione...
+                        TaskExecModel resRec = new TaskExecModel()
+                        {
+                            TaskId = TaskId,
+                            DtStart = dtStart,
+                            DtEnd = dtEnd,
+                            IsError = callRes.ExecResult < 0,
+                            Result = callRes.TextResult
+                        };
+                        dbCtx
+                            .DbSetTaskExe
+                            .Add(resRec);
+
+                        // aggiorno record chiamata...
+                        currRec.DtLastExec = dtStart;
+                        currRec.LastResult = resRec.Result;
+                        currRec.LastDuration = dtEnd.Subtract(dtStart).TotalSeconds;
+                        // calcolo prossima esecuzione...
+                        currRec.DtNextExec = CalcNextExe(currRec);
+                        // segno modificato
+                        dbCtx.Entry(currRec).State = EntityState.Modified;
+
+                        // salvo modifiche!
+                        dbCtx.SaveChanges();
+                    }
+
+                }
+                catch (Exception exc)
+                {
+                    Log.Error($"Eccezione in ExecuteSqlCommand{Environment.NewLine}{exc}");
+                }
+            }
+            return callRes;
+        }
+
        /// <summary>
        /// Upsert record TaskExec
        /// </summary>