TD-5286 prep work for self assessments

DigitalLearningSolutions.Data.Migrations/202501280929_CreateCompetencyAssessmentTables.cs

@@ -0,0 +1,56 @@
+namespace DigitalLearningSolutions.Data.Migrations
+{
+    using FluentMigrator;
+    using FluentMigrator.SqlServer;
+    [Migration(202501280929)]
+    public class CreateCompetencyAssessmentTables : Migration
+    {
+        public override void Up()
+        {
+            Create.Table("SelfAssessmentFrameworks")
+               .WithColumn("ID").AsInt32().NotNullable().PrimaryKey().Identity()
+               .WithColumn("SelfAssessmentId").AsInt32().NotNullable().ForeignKey("SelfAssessments", "ID")
+               .WithColumn("FrameworkId").AsInt32().NotNullable().ForeignKey("Frameworks", "ID")
+               .WithColumn("CreatedDate").AsDateTime().NotNullable().WithDefault(SystemMethods.CurrentDateTime)
+               .WithColumn("CreatedByUserId").AsInt32().NotNullable().ForeignKey("Users", "ID")
+               .WithColumn("RemovedDate").AsDateTime().Nullable()
+               .WithColumn("RemovedByUserId").AsInt32().Nullable().ForeignKey("Users", "ID")
+               .WithColumn("AmendedDate").AsDateTime().Nullable()
+               .WithColumn("AmendedByUserId").AsInt32().Nullable().ForeignKey("Users", "ID");
+            Create.Table("SelfAssessmentTaskStatus")
+               .WithColumn("ID").AsInt32().NotNullable().PrimaryKey().Identity()
+               .WithColumn("SelfAssessmentId").AsInt32().NotNullable().ForeignKey("SelfAssessments", "ID").Unique()
+               .WithColumn("IntroductoryTextTaskStatus").AsBoolean().Nullable()
+               .WithColumn("BrandingTaskStatus").AsBoolean().Nullable()
+               .WithColumn("VocabularyTaskStatus").AsBoolean().Nullable()
+               .WithColumn("WorkingGroupTaskStatus").AsBoolean().Nullable()
+               .WithColumn("NationalRoleProfileTaskStatus").AsBoolean().Nullable()
+               .WithColumn("FrameworkLinksTaskStatus").AsBoolean().Nullable()
+               .WithColumn("SelectCompetenciesTaskStatus").AsBoolean().Nullable()
+               .WithColumn("OptionalCompetenciesTaskStatus").AsBoolean().Nullable()
+               .WithColumn("RoleRequirementsTaskStatus").AsBoolean().Nullable()
+               .WithColumn("SupervisorRolesTaskStatus").AsBoolean().Nullable()
+               .WithColumn("SelfAssessmentOptionsTaskStatus").AsBoolean().Nullable()
+               .WithColumn("ReviewTaskStatus").AsBoolean().Nullable();
+            Execute.Sql($@"INSERT INTO SelfAssessmentFrameworks (SelfAssessmentId, FrameworkId, CreatedByUserId)
+                            SELECT sa.ID, fc.FrameworkID, aa.UserID
+                            FROM   SelfAssessments AS sa INNER JOIN
+                                         SelfAssessmentStructure AS sas ON sa.ID = sas.SelfAssessmentID INNER JOIN
+                                         FrameworkCompetencies AS fc ON sas.CompetencyID = fc.CompetencyID INNER JOIN
+                                         AdminAccounts AS aa ON sa.CreatedByAdminID = aa.ID
+                            GROUP BY sa.ID, fc.FrameworkID, aa.UserID
+                            ");
+            Execute.Sql($@"INSERT INTO SelfAssessmentTaskStatus (SelfAssessmentId, IntroductoryTextTaskStatus, BrandingTaskStatus, VocabularyTaskStatus, WorkingGroupTaskStatus, NationalRoleProfileTaskStatus, FrameworkLinksTaskStatus, SelectCompetenciesTaskStatus, OptionalCompetenciesTaskStatus, RoleRequirementsTaskStatus, SupervisorRolesTaskStatus, SelfAssessmentOptionsTaskStatus)
+                            SELECT ID, 1,1,1,1,1,1,1,1,1,1,1
+                            FROM   SelfAssessments AS sa
+                            ");
+        }
+
+        public override void Down()
+        {
+            Delete.Table("SelfAssessmentFrameworks");
+            Delete.Table("SelfAssessmentTaskStatus");
+        }
+
+    }
+}

DigitalLearningSolutions.Data/DataServices/CompetencyAssessmentDataService.cs

@@ -0,0 +1,197 @@
+namespace DigitalLearningSolutions.Data.DataServices
+{
+    using System.Collections.Generic;
+    using System.Data;
+    using System.Linq;
+    using Dapper;
+    using DigitalLearningSolutions.Data.Models.CompetencyAssessments;
+    using Microsoft.Extensions.Logging;
+
+    public interface ICompetencyAssessmentDataService
+    {
+        //GET DATA
+        IEnumerable<CompetencyAssessment> GetAllCompetencyAssessments(int adminId);
+
+        IEnumerable<CompetencyAssessment> GetCompetencyAssessmentsForAdminId(int adminId);
+
+        CompetencyAssessmentBase? GetCompetencyAssessmentBaseById(int competencyAssessmentId, int adminId);
+
+        CompetencyAssessmentBase? GetCompetencyAssessmentByName(string competencyAssessmentName, int adminId);
+
+        IEnumerable<NRPProfessionalGroups> GetNRPProfessionalGroups();
+
+        //UPDATE DATA
+        bool UpdateCompetencyAssessmentName(int competencyAssessmentId, int adminId, string competencyAssessmentName);
+
+        bool UpdateCompetencyAssessmentProfessionalGroup(int competencyAssessmentId, int adminId, int? nrpProfessionalGroupID);
+        //INSERT DATA
+
+        //DELETE DATA
+    }
+
+    public class CompetencyAssessmentDataService : ICompetencyAssessmentDataService
+    {
+        private const string SelfAssessmentBaseFields = @"sa.ID, sa.Name AS CompetencyAssessmentName, sa.Description, sa.BrandID,
+                sa.ParentSelfAssessmentID,
+                sa.[National], sa.[Public], sa.CreatedByAdminID AS OwnerAdminID,
+                sa.NRPProfessionalGroupID,
+                 sa.NRPSubGroupID,
+                 sa.NRPRoleID,
+                 sa.PublishStatusID, CASE WHEN sa.CreatedByAdminID = @adminId THEN 3 WHEN sac.CanModify = 1 THEN 2 WHEN sac.CanModify = 0 THEN 1 ELSE 0 END AS UserRole";
+
+        private const string SelfAssessmentFields =
+            @", sa.CreatedDate,
+                 (SELECT BrandName
+                 FROM    Brands
+                 WHERE (BrandID = sa.BrandID)) AS Brand,
+                 (SELECT [Name]
+                 FROM    SelfAssessments AS sa2
+                 WHERE (ID = sa.ParentSelfAssessmentID)) AS ParentSelfAssessment,
+                 (SELECT Forename + ' ' + Surname + (CASE WHEN Active = 1 THEN '' ELSE ' (Inactive)' END) AS Expr1
+                 FROM  AdminUsers
+                 WHERE (AdminID = sa.CreatedByAdminID)) AS Owner,
+                 sa.Archived,
+                 sa.LastEdit,
+                 (SELECT ProfessionalGroup
+                 FROM    NRPProfessionalGroups
+                 WHERE (ID = sa.NRPProfessionalGroupID)) AS NRPProfessionalGroup,
+                 (SELECT SubGroup
+                 FROM    NRPSubGroups
+                 WHERE (ID = sa.NRPSubGroupID)) AS NRPSubGroup,
+                 (SELECT RoleProfile
+                 FROM    NRPRoles
+                 WHERE (ID = sa.NRPRoleID)) AS NRPRole, sar.ID AS SelfAssessmentReviewID";
+
+        private const string SelfAssessmentBaseTables =
+            @"SelfAssessments AS sa LEFT OUTER JOIN
+             SelfAssessmentCollaborators AS sac ON sac.SelfAssessmentID = sa.ID AND sac.AdminID = @adminId";
+
+        private const string SelfAssessmentTables =
+            @" LEFT OUTER JOIN
+             SelfAssessmentReviews AS sar ON sac.ID = sar.SelfAssessmentCollaboratorID AND sar.Archived IS NULL AND sar.ReviewComplete IS NULL";
+
+        private readonly IDbConnection connection;
+        private readonly ILogger<CompetencyAssessmentDataService> logger;
+
+        public CompetencyAssessmentDataService(IDbConnection connection, ILogger<CompetencyAssessmentDataService> logger)
+        {
+            this.connection = connection;
+            this.logger = logger;
+        }
+
+        public IEnumerable<CompetencyAssessment> GetAllCompetencyAssessments(int adminId)
+        {
+            return connection.Query<CompetencyAssessment>(
+                $@"SELECT {SelfAssessmentBaseFields} {SelfAssessmentFields}
+                      FROM {SelfAssessmentBaseTables} {SelfAssessmentTables}",
+                new { adminId }
+            );
+        }
+
+        public IEnumerable<CompetencyAssessment> GetCompetencyAssessmentsForAdminId(int adminId)
+        {
+            return connection.Query<CompetencyAssessment>(
+                $@"SELECT {SelfAssessmentBaseFields} {SelfAssessmentFields}
+                      FROM {SelfAssessmentBaseTables} {SelfAssessmentTables}
+                      WHERE (sa.CreatedByAdminID = @adminId) OR
+             (@adminId IN
+                 (SELECT AdminID
+                 FROM    SelfAssessmentCollaborators
+                 WHERE (SelfAssessmentID = sa.ID)))",
+                new { adminId }
+            );
+        }
+
+        public CompetencyAssessmentBase? GetCompetencyAssessmentBaseById(int competencyAssessmentId, int adminId)
+        {
+            return connection.Query<CompetencyAssessmentBase>(
+                $@"SELECT {SelfAssessmentBaseFields}
+                      FROM {SelfAssessmentBaseTables}
+                      WHERE (sa.ID = @competencyAssessmentId)",
+                new { competencyAssessmentId, adminId }
+            ).FirstOrDefault();
+        }
+
+        public bool UpdateCompetencyAssessmentName(int competencyAssessmentId, int adminId, string competencyAssessmentName)
+        {
+            if ((competencyAssessmentName.Length == 0) | (adminId < 1) | (competencyAssessmentId < 1))
+            {
+                logger.LogWarning(
+                    $"Not updating role profile name as it failed server side validation. AdminId: {adminId}, competencyAssessmentName: {competencyAssessmentName}, competencyAssessmentId: {competencyAssessmentId}"
+                );
+                return false;
+            }
+
+            var existingSelfAssessments = (int)connection.ExecuteScalar(
+                @"SELECT COUNT(*) FROM SelfAssessments WHERE [Name] = @competencyAssessmentName AND ID <> @competencyAssessmentId",
+                new { competencyAssessmentName, competencyAssessmentId }
+            );
+            if (existingSelfAssessments > 0)
+            {
+                return false;
+            }
+
+            var numberOfAffectedRows = connection.Execute(
+                @"UPDATE SelfAssessments SET [Name] = @competencyAssessmentName, UpdatedByAdminID = @adminId
+                    WHERE ID = @competencyAssessmentId",
+                new { competencyAssessmentName, adminId, competencyAssessmentId }
+            );
+            if (numberOfAffectedRows < 1)
+            {
+                logger.LogWarning(
+                    "Not updating role profile name as db update failed. " +
+                    $"SelfAssessmentName: {competencyAssessmentName}, admin id: {adminId}, competencyAssessmentId: {competencyAssessmentId}"
+                );
+                return false;
+            }
+
+            return true;
+        }
+
+        public IEnumerable<NRPProfessionalGroups> GetNRPProfessionalGroups()
+        {
+            return connection.Query<NRPProfessionalGroups>(
+                @"SELECT ID, ProfessionalGroup, Active
+                    FROM   NRPProfessionalGroups
+                    WHERE (Active = 1)
+                    ORDER BY ProfessionalGroup"
+            );
+        }
+
+        public CompetencyAssessmentBase? GetCompetencyAssessmentByName(string competencyAssessmentName, int adminId)
+        {
+            return connection.Query<CompetencyAssessmentBase>(
+                $@"SELECT {SelfAssessmentBaseFields}
+                      FROM {SelfAssessmentBaseTables}
+                      WHERE (sa.Name = @competencyAssessmentName)",
+                new { competencyAssessmentName, adminId }
+            ).FirstOrDefault();
+        }
+
+        public bool UpdateCompetencyAssessmentProfessionalGroup(int competencyAssessmentId, int adminId, int? nrpProfessionalGroupID)
+        {
+            var sameCount = (int)connection.ExecuteScalar(
+                @"SELECT COUNT(*) FROM CompetencyAssessments WHERE ID = @competencyAssessmentId AND NRPProfessionalGroupID = @nrpProfessionalGroupID",
+                new { competencyAssessmentId, nrpProfessionalGroupID }
+            );
+            if (sameCount > 0)
+            {
+                //same so don't update:
+                return false;
+            }
+
+            //needs updating:
+            var numberOfAffectedRows = connection.Execute(
+                @"UPDATE SelfAssessments SET NRPProfessionalGroupID = @nrpProfessionalGroupID, NRPSubGroupID = NULL, NRPRoleID = NULL, UpdatedByAdminID = @adminId
+                    WHERE ID = @competencyAssessmentId",
+                new { nrpProfessionalGroupID, adminId, competencyAssessmentId }
+            );
+            if (numberOfAffectedRows > 0)
+            {
+                return true;
+            }
+
+            return false;
+        }
+    }
+}

DigitalLearningSolutions.Data/DataServices/FrameworkDataService.cs

@@ -2203,15 +2203,15 @@ public void ArchiveReviewRequest(int reviewId)
                  FROM    FrameworkCollaborators
                  WHERE (FrameworkID = FW.ID) AND (IsDeleted=0)))) AS MyFrameworksCount,
 
-                 (SELECT COUNT(*) FROM SelfAssessments) AS RoleProfileCount,
+                 (SELECT COUNT(*) FROM SelfAssessments) AS CompetencyAssessmentCount,
 
                  (SELECT COUNT(*) FROM SelfAssessments AS RP LEFT OUTER JOIN
              SelfAssessmentCollaborators AS RPC ON RPC.SelfAssessmentID = RP.ID AND RPC.AdminID = @adminId
 WHERE (RP.CreatedByAdminID = @adminId) OR
              (@adminId IN
                  (SELECT AdminID
                  FROM    SelfAssessmentCollaborators
-                 WHERE (SelfAssessmentID = RP.ID)))) AS MyRoleProfileCount",
+                 WHERE (SelfAssessmentID = RP.ID)))) AS MyCompetencyAssessmentCount",
                 new { adminId }
             ).FirstOrDefault();
         }
@@ -2221,7 +2221,7 @@ public IEnumerable<DashboardToDoItem> GetDashboardToDoItems(int adminId)
             return connection.Query<DashboardToDoItem>(
                 @"SELECT
                         FW.ID AS FrameworkID,
-                        0 AS RoleProfileID,
+                        0 AS CompetencyAssessmentID,
                         FW.FrameworkName AS ItemName,
                         AU.Forename + ' ' + AU.Surname + (CASE WHEN AU.Active = 1 THEN '' ELSE ' (Inactive)' END) AS RequestorName,
                         FWR.SignOffRequired,