2025-05-28 13:34:48 -07:00

583 lines
18 KiB
C#

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using Dapper;
using Fab2ApprovalSystem.Misc;
using Fab2ApprovalSystem.Models;
namespace Fab2ApprovalSystem.DMO;
public class TrainingDMO {
private readonly IDbConnection db = new SqlConnection(GlobalVars.DB_CONNECTION_STRING);
#if !NET8
private static FabApprovalTrainingEntities FabApprovalDB = new FabApprovalTrainingEntities();
#endif
public int Create(int issueId) {
DynamicParameters parameters = new();
parameters.Add("@TrainingId", dbType: DbType.Int32, direction: ParameterDirection.InputOutput);
parameters.Add("@ECNNumber", issueId);
db.Execute("InsertTrainingItem", parameters, commandType: CommandType.StoredProcedure);
int trainingId = parameters.Get<int>("@TrainingId");
return trainingId;
}
public int CreateAssignment(int trainingId, int userId) {
DynamicParameters parameters = new();
parameters.Add("@TrainingID", trainingId);
parameters.Add("@UserID", userId);
parameters.Add("@AssignmentID", dbType: DbType.Int32, direction: ParameterDirection.InputOutput);
db.Execute("InsertTrainingAssignment", parameters, commandType: CommandType.StoredProcedure);
int assignmentId = parameters.Get<int>("@AssignmentID");
return assignmentId;
}
public IEnumerable<Training> GetAllTrainings() {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
IEnumerable<Training> allTrainings = (from a in db.Trainings select a).ToList();
return allTrainings;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public Training GetTraining(int trainingId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
Training trainingRecord = new Training();
trainingRecord = (from a in db.Trainings where a.TrainingID == trainingId select a).FirstOrDefault();
return trainingRecord;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public TrainingAssignment GetAssignment(int assignmentId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
TrainingAssignment assignmentRecord = (from a in db.TrainingAssignments where a.ID == assignmentId select a).FirstOrDefault();
return assignmentRecord;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public int GetTrainingId(int issueId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
int ECNId = issueId;
int trainingId = (from a in db.Trainings where a.ECN == ECNId select a.TrainingID).FirstOrDefault();
return trainingId;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<int> GetTrainees(int groupId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var users = (from a in db.TrainingGroupMembers where a.TrainingGroupID == groupId select a.UserID).ToList();
return users;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public bool isUserTrainingMember(int groupId, int userId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var users = (from a in db.TrainingGroupMembers where a.TrainingGroupID == groupId && a.UserID == userId select a).FirstOrDefault();
if (users == null) {
return false;
} else {
return true;
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingGroup> GetTrainingGroups() {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
return (from a in db.TrainingGroups select a).ToList();
#endif
#if NET8
System.Text.StringBuilder query = new("SELECT TrainingGroupID, TrainingGroupName FROM TrainingGroups ORDER BY TrainingGroupID");
return db.Query<TrainingGroup>(query.ToString()).ToList();
#endif
}
public TrainingGroup GetTrainingGroupByID(int groupId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
TrainingGroup groups = (from a in db.TrainingGroups where a.TrainingGroupID == groupId select a).FirstOrDefault();
return groups;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<int> GetECNAssignedTrainingGroups(int ECNNumber) {
#if !NET8
List<int> trainingGroups = (from a in FabApprovalDB.ECNTrainingBies where a.ECNNumber == ECNNumber select a.AcknowledgementTrainingByID).ToList();
return trainingGroups;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void AddTrainingGroupToECN(int ECNNumber, int groupId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var parameters = new DynamicParameters();
parameters.Add("@ECNNumber", ECNNumber);
parameters.Add("@TrainingByID", groupId);
this.db.Execute("ECNInsertTrainingBy", parameters, commandType: CommandType.StoredProcedure);
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void SetTrainingFlag(int ECNNumber) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var parameters = new DynamicParameters();
parameters.Add("@ECNNumber", ECNNumber);
this.db.Execute("ECNSetTrainingFlag", parameters, commandType: CommandType.StoredProcedure);
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingAssignment> GetAllTrainingAssignments(int TrainingID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var TrainingData = from a in db.TrainingAssignments where a.TrainingID == TrainingID select a;
RefreshTrainingData(TrainingID, TrainingData);
TrainingData = from a in db.TrainingAssignments where a.TrainingID == TrainingID select a;
return TrainingData.ToList();
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingAssignment> GetTrainingAssignments(int TrainingID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var TrainingData = from a in db.TrainingAssignments where a.TrainingID == TrainingID && a.Deleted != true select a;
RefreshTrainingData(TrainingID, TrainingData);
TrainingData = from a in db.TrainingAssignments where a.TrainingID == TrainingID select a;
return TrainingData.ToList();
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingAssignment> GetTrainingAssignmentsByUser(int TrainingID, int userID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var TrainingData = from a in db.TrainingAssignments where a.TrainingID == TrainingID && a.UserID == userID select a;
return TrainingData.ToList();
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingDocAck> GetAssignedDocs(int trainingAssignmentId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var docs = (from a in db.TrainingDocAcks where a.TrainingAssignmentID == trainingAssignmentId && a.Deleted != true select a).ToList();
return docs;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void AcknowledgeDocument(int trainingDocAckID) {
DynamicParameters parameters = new();
parameters.Add("@TrainingDocAckID", trainingDocAckID);
db.Execute("TrainingAcknowledgeDocument", parameters, commandType: CommandType.StoredProcedure);
}
public void UpdateAssignmentStatus(int trainingAssignmentID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var RecordToUpdate = (from a in db.TrainingAssignments where a.ID == trainingAssignmentID select a).SingleOrDefault();
if (RecordToUpdate.status != true) {
RecordToUpdate.DateCompleted = DateTime.Now;
RecordToUpdate.status = true;
try {
db.SaveChanges();
} catch (InvalidOperationException e) {
string exception = e.ToString();
Console.WriteLine(e);
}
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public int GetTrainingIdByAssignment(int trainingAssignmentID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
int trainingID = (from a in db.TrainingAssignments where a.ID == trainingAssignmentID select a.TrainingID).SingleOrDefault();
return trainingID;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void UpdateTrainingStatus(int trainingId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
Training training = (from a in db.Trainings where a.TrainingID == trainingId select a).SingleOrDefault();
if (training != null) {
training.CompletedDate = DateTime.Now;
training.Status = true;
try {
db.SaveChanges();
} catch (InvalidOperationException e) {
string exception = e.ToString();
Console.WriteLine(e);
}
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void reOpenTraining(int trainingId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
Training training = (from a in db.Trainings where a.TrainingID == trainingId select a).SingleOrDefault();
if (training != null) {
training.CompletedDate = null;
training.Status = false;
try {
db.SaveChanges();
} catch (InvalidOperationException e) {
string exception = e.ToString();
Console.WriteLine(e);
}
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public bool CheckTrainingStatus(int trainingAssignmentID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
bool isFinished = true;
int trainingID = (from a in db.TrainingAssignments where a.ID == trainingAssignmentID select a.TrainingID).SingleOrDefault();
var trainingAssignments = from a in db.TrainingAssignments where a.TrainingID == trainingID && a.Deleted != true select a;
foreach (var training in trainingAssignments) {
if (training.status == false) {
isFinished = false;
}
}
return isFinished;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public bool CheckTrainingAssignmentStatus(int trainingAssignmentID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
bool isFinished = true;
// TrainingDocAck docsAssigned = null;
var docsAssigned = from a in db.TrainingDocAcks where a.TrainingAssignmentID == trainingAssignmentID && a.Deleted != true select a;
foreach (var doc in docsAssigned) {
if (doc.Reviewed == false) {
isFinished = false;
}
}
return isFinished;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public bool IsUserAssigned(int userId, int trainingId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
bool userHasAssignment = false;
var assignments = (from a in db.TrainingAssignments where a.TrainingID == trainingId && a.UserID == userId && a.Deleted != true select a).ToList();
if (assignments.Count() > 0) {
userHasAssignment = true;
}
return userHasAssignment;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<Training> GetTrainings() {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var trainings = from a in db.Trainings select a;
return trainings.ToList();
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingAssignment> GetTrainingAssignmentsByUserID(int userID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var trainingAssignments = from a in db.TrainingAssignments where a.UserID == userID && a.Deleted != true select a;
return trainingAssignments.ToList();
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void DeleteTrainingAssignment(int trainingAssignmentId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var trainingAssignments = from a in db.TrainingAssignments where a.ID == trainingAssignmentId select a;
foreach (var item in trainingAssignments) {
item.Deleted = true;
item.DeletedDate = DateTime.Now;
}
try {
db.SaveChanges();
} catch (InvalidOperationException e) {
string exception = e.ToString();
Console.WriteLine(e);
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void DeleteTrainingDocAck(int trainingAssignmentId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var trainingDocAcks = from a in db.TrainingDocAcks where a.TrainingAssignmentID == trainingAssignmentId select a;
foreach (var item in trainingDocAcks) {
item.Deleted = true;
item.DeletedDate = DateTime.Now;
}
try {
db.SaveChanges();
} catch (InvalidOperationException e) {
string exception = e.ToString();
Console.WriteLine(e);
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void DeleteTraining(int trainingId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
Training training = (from a in db.Trainings where a.TrainingID == trainingId select a).FirstOrDefault();
if (training != null) {
training.Deleted = true;
training.DeletedDate = DateTime.Now;
}
List<TrainingAssignment> trainingAssignments = (from a in db.TrainingAssignments where a.TrainingID == trainingId select a).ToList();
db.SaveChanges();
foreach (TrainingAssignment trainingAssignment in trainingAssignments) {
DeleteTrainingAssignment(trainingAssignment.ID);
DeleteTrainingDocAck(trainingAssignment.ID);
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public void DeleteAssignmentByUserId(int userId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
var userAssignments = (from a in db.TrainingAssignments where a.UserID == userId select a).ToList();
foreach (var item in userAssignments) {
// get document assignments
var docAssignments = (from a in db.TrainingDocAcks where a.TrainingAssignmentID == item.TrainingID select a).ToList();
// delete each docAssignment
foreach (var docAssignment in docAssignments) {
DeleteTrainingDocAck(docAssignment.ID);
}
DeleteTrainingAssignment(item.ID);
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public bool CheckValidDocAck(int docAckId) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
TrainingDocAck ack = (from a in db.TrainingDocAcks where a.ID == docAckId select a).FirstOrDefault();
// TODO Check the user is valid
// Check that the assignment exists
if (ack != null) {
// Check that the assignment isn't deleted
if (ack.Deleted == true) {
return false;
}
// Check that the assignment isn't completed
else if (ack.Reviewed == true) {
return false;
} else {
return true;
}
} else {
return false;
}
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<Training> GetAllOpenTrainings() {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
List<Training> openTrainings = (from a in db.Trainings where a.Status != true && a.Deleted != true select a).ToList();
return openTrainings;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
public List<TrainingAssignment> GetOpenAssignmentsByTrainingID(int trainingID) {
#if !NET8
FabApprovalTrainingEntities db = new FabApprovalTrainingEntities();
List<TrainingAssignment> openAssignments = (from a in FabApprovalDB.TrainingAssignments where a.TrainingID == trainingID && a.status != true && a.Deleted != true select a).ToList();
return openAssignments;
#endif
#if NET8
throw new NotImplementedException();
#endif
}
private void RefreshTrainingData(int TrainingID, IQueryable<TrainingAssignment> TrainingData) {
bool assignmentIsIncomplete = false;
UserAccountDMO userAccountDMO = new();
foreach (TrainingAssignment assignment in TrainingData) {
LoginModel userModel = userAccountDMO.GetUserByID(assignment.UserID);
if (!userModel.IsActive)
UpdateAssignmentStatus(assignment.ID);
if (assignment.Deleted != true && (assignment.DateCompleted is null || assignment.DateCompleted > DateTime.Now))
assignmentIsIncomplete = true;
}
if (!assignmentIsIncomplete)
UpdateTrainingStatus(TrainingID);
}
}