Review namespace Task --> Job + fix JobStep/JobTask

2026-03-17 14:54:16 +01:00
parent 7c5adc9012
commit 9989c7767e
39 changed files with 716 additions and 68 deletions
@@ -0,0 +1,156 @@
+using EgwCoreLib.Lux.Data.DbModel.Job;
+using Microsoft.EntityFrameworkCore;
+
+namespace EgwCoreLib.Lux.Data.Repository.Job
+{
+    public class JobTaskRepository : BaseRepository, IJobTaskRepository
+    {
+        #region Public Constructors
+
+        public JobTaskRepository(IDbContextFactory<DataLayerContext> ctxFactory) : base(ctxFactory)
+        {
+        }
+
+        #endregion Public Constructors
+
+        #region Public Methods
+
+        public async Task<bool> AddAsync(JobTaskModel entity)
+        {
+            await using var dbCtx = await CreateContextAsync();
+            await dbCtx.DbSetJobTask.AddAsync(entity);
+            return await dbCtx.SaveChangesAsync() > 0;
+        }
+
+        public async Task<bool> DeleteAsync(JobTaskModel rec2del)
+        {
+            await using var dbCtx = await CreateContextAsync();
+
+            var dbResult = await dbCtx.DbSetJobTask
+                .FirstOrDefaultAsync(x => x.JobID == rec2del.JobID);
+
+            if (dbResult == null)
+                return false;
+
+            var list2Move = await dbCtx.DbSetJobTask
+                                            .Where(x => x.JobID == rec2del.JobID && x.Index > dbResult.Index)
+                                            .ToListAsync();
+
+            foreach (var item in list2Move)
+            {
+                item.Index--;
+                dbCtx.Entry(item).State = EntityState.Modified;
+            }
+
+            dbCtx.DbSetJobTask.Remove(dbResult);
+
+            return await dbCtx.SaveChangesAsync() > 0;
+        }
+
+        public async Task<List<JobTaskModel>> GetAllAsync()
+        {
+            await using var dbCtx = await CreateContextAsync();
+            return await dbCtx.DbSetJobTask
+                            .Include(c => c.TagNav)
+                            .Include(c => c.JobStepNav)
+                            .AsNoTracking()
+                            .ToListAsync();
+        }
+
+        public async Task<JobTaskModel?> GetByIdAsync(int recId)
+        {
+            await using var dbCtx = await CreateContextAsync();
+            return await dbCtx.DbSetJobTask.FirstOrDefaultAsync(x => x.JobID == recId);
+        }
+
+        public async Task<bool> MergeTagsAsync(int JobID, List<string> reqTagList)
+        {
+            await using var dbCtx = await CreateContextAsync();
+            var currRec = await dbCtx.DbSetJobTask
+                                    .Where(x => x.JobID == JobID)
+                                    .Include(t => t.TagNav)
+                                    .FirstOrDefaultAsync();
+
+            if (currRec == null)
+                return false;
+
+            var currentTags = currRec.TagNav.Select(t => t.CodTag).ToList();
+
+            // calcolo modifiche
+            var toAdd = reqTagList.Except(currentTags).ToList();
+            var toRemove = currentTags.Except(reqTagList).ToList();
+
+            // aggiunte
+            foreach (var tag in toAdd)
+            {
+                currRec.TagNav.Add(new JobTaskTagModel
+                {
+                    JobID = JobID,
+                    CodTag = tag
+                });
+            }
+            // rimozioni
+            foreach (var tag in toRemove)
+            {
+                var entity = currRec.TagNav.FirstOrDefault(t => t.CodTag == tag);
+                if (entity != null)
+                    dbCtx.Remove(entity);
+            }
+
+            dbCtx.Entry(currRec).State = EntityState.Modified;
+
+            return await dbCtx.SaveChangesAsync() > 0;
+        }
+
+        public async Task<bool> MoveAsync(JobTaskModel selRec, bool moveUp)
+        {
+            await using var dbCtx = await CreateContextAsync();
+            var currRec = await dbCtx.DbSetJobTask
+                .FirstOrDefaultAsync(x => x.JobID == selRec.JobID);
+
+            if (currRec == null)
+                return false;
+
+            int numRec = await dbCtx.DbSetJobTask
+                                    .CountAsync();
+
+            int newPos = moveUp ? currRec.Index - 1 : currRec.Index + 1;
+
+            bool canMove = moveUp ? newPos > 0 : newPos <= numRec;
+            if (!canMove)
+                return false;
+
+            var otherRec = await dbCtx.DbSetJobTask
+                .FirstOrDefaultAsync(x => x.Index == newPos);
+
+            if (otherRec == null)
+                return false;
+
+            otherRec.Index = currRec.Index;
+            currRec.Index = newPos;
+
+            dbCtx.Entry(otherRec).State = EntityState.Modified;
+            dbCtx.Entry(currRec).State = EntityState.Modified;
+
+            return await dbCtx.SaveChangesAsync() > 0;
+        }
+
+        public async Task<bool> UpdateAsync(JobTaskModel entity)
+        {
+            await using var dbCtx = await CreateContextAsync();
+            var trackedEntity = dbCtx.DbSetJobTask.Local.FirstOrDefault(x => x.JobID == entity.JobID);
+
+            if (trackedEntity != null)
+            {
+                dbCtx.Entry(trackedEntity).CurrentValues.SetValues(entity);
+            }
+            else
+            {
+                dbCtx.DbSetJobTask.Update(entity);
+            }
+            return await dbCtx.SaveChangesAsync() > 0;
+        }
+
+        #endregion Public Methods
+    }
+}