First Initial
This commit is contained in:
Nakorn Rientrakrunchai
359
EF/_BaseRepository2.cs
Normal file
359
EF/_BaseRepository2.cs
Normal file
@@ -0,0 +1,359 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using System.Transactions;
|
||||
using AutoMapper;
|
||||
using System.Linq.Expressions;
|
||||
using TTSW.Common;
|
||||
using TodoAPI2.Models;
|
||||
using Microsoft.AspNetCore.Http;
|
||||
using IdentityModel;
|
||||
|
||||
namespace TTSW.EF
|
||||
{
|
||||
public class BaseRepository2<T, Key> : IBaseRepository2<T, Key>
|
||||
where T : class, IBaseEntity2<Key>
|
||||
{
|
||||
#region Private Variables
|
||||
private DataContext _context;
|
||||
public DataContext Context
|
||||
{
|
||||
get
|
||||
{
|
||||
return _context;
|
||||
}
|
||||
}
|
||||
|
||||
private IHttpContextAccessor _contextAccessor;
|
||||
private LoginProfile _loginProfile;
|
||||
#endregion
|
||||
|
||||
#region Properties
|
||||
private DbSet<T> _entities;
|
||||
public DbSet<T> Entities {
|
||||
get {
|
||||
return _entities ?? (_entities = _context.Set<T>()); }
|
||||
}
|
||||
#endregion
|
||||
|
||||
public BaseRepository2(DataContext context, IHttpContextAccessor contextAccessor
|
||||
)
|
||||
{
|
||||
_context = context;
|
||||
_contextAccessor = contextAccessor;
|
||||
}
|
||||
|
||||
#region Private Functions
|
||||
private bool SaveToDB()
|
||||
{
|
||||
return (_context.SaveChanges() >= 0);
|
||||
}
|
||||
private T SetCreatorProperties(T entity)
|
||||
{
|
||||
//entity.CreatorId = _userRepository.LoginProfile.Id;
|
||||
entity.created = DateTime.Now;
|
||||
|
||||
return entity;
|
||||
}
|
||||
private T SetUpdatorProperties(T entity)
|
||||
{
|
||||
//entity.UpdatorId = _userRepository.LoginProfile.Id;
|
||||
entity.updated = DateTime.Now;
|
||||
|
||||
return entity;
|
||||
}
|
||||
private T SetActiveProperty(T entity)
|
||||
{
|
||||
entity.isActive = true;
|
||||
return entity;
|
||||
}
|
||||
private T SetInActiveProperty(T entity)
|
||||
{
|
||||
entity.isActive = false;
|
||||
return entity;
|
||||
}
|
||||
#endregion
|
||||
|
||||
#region Public Functions
|
||||
|
||||
public LoginProfile GetLoginProfile()
|
||||
{
|
||||
// Set login profile in the 1st accessing time only
|
||||
// The user has to login to the system too.
|
||||
if (_loginProfile == null && _contextAccessor.HttpContext.User.Identity.IsAuthenticated)
|
||||
{
|
||||
var dict = new Dictionary<string, string>();
|
||||
|
||||
// A list to keep list of all keys for getting user user claims
|
||||
var userProfileClaimsKey = new List<string>();
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.GivenName);
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.FamilyName);
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.Email);
|
||||
userProfileClaimsKey.Add("customer_guid");
|
||||
userProfileClaimsKey.Add("user_guid");
|
||||
userProfileClaimsKey.Add("permission_level");
|
||||
userProfileClaimsKey.Add("base_system");
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.Name);
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.PreferredUserName);
|
||||
userProfileClaimsKey.Add(JwtClaimTypes.PhoneNumber);
|
||||
|
||||
// Fetch only claims related to user profile
|
||||
_contextAccessor.HttpContext.User.Claims
|
||||
.Where(c=> userProfileClaimsKey.Contains(c.Type)).ToList()
|
||||
.ForEach(item => dict.Add(item.Type, item.Value));
|
||||
|
||||
// Map claims to model
|
||||
_loginProfile = new LoginProfile();
|
||||
|
||||
//if (dict.ContainsKey(JwtClaimTypes.Subject))
|
||||
// _loginProfile.Id = dict[JwtClaimTypes.Subject];
|
||||
|
||||
if (dict.ContainsKey(JwtClaimTypes.GivenName) && !string.IsNullOrEmpty(dict[JwtClaimTypes.GivenName]))
|
||||
_loginProfile.FirstName = dict[JwtClaimTypes.GivenName];
|
||||
|
||||
if (dict.ContainsKey(JwtClaimTypes.FamilyName) && !string.IsNullOrEmpty(dict[JwtClaimTypes.FamilyName]))
|
||||
_loginProfile.LastName = dict[JwtClaimTypes.FamilyName];
|
||||
|
||||
if (dict.ContainsKey(JwtClaimTypes.Email) && !string.IsNullOrEmpty(dict[JwtClaimTypes.Email]))
|
||||
_loginProfile.Email = dict[JwtClaimTypes.Email];
|
||||
|
||||
if (dict.ContainsKey("customer_guid") && !string.IsNullOrEmpty(dict["customer_guid"]))
|
||||
_loginProfile.CustomerGUID = new Guid(dict["customer_guid"]);
|
||||
|
||||
if (dict.ContainsKey("user_guid") && !string.IsNullOrEmpty(dict["user_guid"]))
|
||||
_loginProfile.UserGUID = new Guid(dict["user_guid"]);
|
||||
|
||||
if (dict.ContainsKey("permission_level") && !string.IsNullOrEmpty(dict["permission_level"]))
|
||||
_loginProfile.permission_level = dict["permission_level"];
|
||||
|
||||
if (dict.ContainsKey("base_system") && !string.IsNullOrEmpty(dict["base_system"]))
|
||||
_loginProfile.base_system = dict["base_system"];
|
||||
|
||||
if (string.IsNullOrEmpty(_loginProfile.base_system))
|
||||
{
|
||||
_loginProfile.base_system = "";
|
||||
}
|
||||
|
||||
if (dict.ContainsKey(JwtClaimTypes.Name) && !string.IsNullOrEmpty(dict[JwtClaimTypes.Name]))
|
||||
_loginProfile.UserName = dict[JwtClaimTypes.Name];
|
||||
else if (dict.ContainsKey(JwtClaimTypes.PreferredUserName) && !string.IsNullOrEmpty(dict[JwtClaimTypes.PreferredUserName]))
|
||||
_loginProfile.UserName = dict[JwtClaimTypes.PreferredUserName];
|
||||
|
||||
if (dict.ContainsKey(JwtClaimTypes.PhoneNumber) && !string.IsNullOrEmpty(dict[JwtClaimTypes.PhoneNumber]))
|
||||
_loginProfile.PhoneNumber = dict[JwtClaimTypes.PhoneNumber];
|
||||
}
|
||||
|
||||
return _loginProfile;
|
||||
}
|
||||
|
||||
#region Query Functions
|
||||
public T Get(Key id)
|
||||
{
|
||||
return Entities
|
||||
//.Include(c => c.Creator)
|
||||
//.Include(c => c.Updator)
|
||||
.FirstOrDefault(c=>c.id.Equals(id));
|
||||
}
|
||||
public T Get(Key id, params Expression<Func<T, object>>[] includes)
|
||||
{
|
||||
var query = Entities.AsQueryable();
|
||||
|
||||
//Dynamic include columns
|
||||
foreach (var include in includes)
|
||||
query = query.Include(include);
|
||||
|
||||
return query
|
||||
//.Include(c => c.Creator)
|
||||
//.Include(c => c.Updator)
|
||||
.FirstOrDefault(c => c.id.Equals(id));
|
||||
}
|
||||
|
||||
public IQueryable<T> GetQuery()
|
||||
{
|
||||
return Entities.AsNoTracking();
|
||||
}
|
||||
public List<T> GetList(Expression<Func<T, bool>> predicate)
|
||||
{
|
||||
var query = Entities
|
||||
.AsNoTracking()
|
||||
//.Include(c => c.Creator)
|
||||
//.Include(c => c.Updator)
|
||||
.Where(predicate);
|
||||
|
||||
return query.ToList();
|
||||
}
|
||||
public List<T> GetList(Expression<Func<T, bool>> predicate, params Expression<Func<T, object>>[] includes)
|
||||
{
|
||||
var query = Entities.AsQueryable();
|
||||
|
||||
//Dynamic include columns
|
||||
foreach (var include in includes)
|
||||
query = query.Include(include);
|
||||
|
||||
query = query
|
||||
.AsNoTracking()
|
||||
//.Include(c => c.Creator)
|
||||
//.Include(c => c.Updator)
|
||||
.Where(predicate);
|
||||
|
||||
return query.ToList();
|
||||
}
|
||||
#endregion
|
||||
|
||||
#region Manipulation Functions
|
||||
public T Insert(T entity)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
entity = SetCreatorProperties(entity);
|
||||
entity = SetUpdatorProperties(entity);
|
||||
entity = SetActiveProperty(entity);
|
||||
|
||||
var result = Entities.Add(entity);
|
||||
|
||||
if(!SaveToDB())
|
||||
throw new NotificationException($"Unable to add new item to database.");
|
||||
|
||||
return Get(result.Entity.id);
|
||||
}
|
||||
public void Insert(IEnumerable<T> list)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var insertedList = new List<T>();
|
||||
foreach(var entity in list)
|
||||
{
|
||||
var newItem = entity;
|
||||
newItem = SetCreatorProperties(newItem);
|
||||
newItem = SetUpdatorProperties(newItem);
|
||||
newItem = SetActiveProperty(newItem);
|
||||
|
||||
insertedList.Add(newItem);
|
||||
}
|
||||
|
||||
Entities.AddRange(insertedList);
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to insert item to database.");
|
||||
}
|
||||
public T Update(Key id, object model)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if(existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
Mapper.Map(model, existingItem);
|
||||
|
||||
existingItem = SetUpdatorProperties(existingItem);
|
||||
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to save item to database.");
|
||||
|
||||
return existingItem;
|
||||
}
|
||||
public T SetAsInActive(Key id)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if (existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
existingItem = SetUpdatorProperties(existingItem);
|
||||
existingItem = SetInActiveProperty(existingItem);
|
||||
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to set item as inactive to database.");
|
||||
|
||||
return existingItem;
|
||||
}
|
||||
public T SetAsActive(Key id)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if (existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
existingItem = SetUpdatorProperties(existingItem);
|
||||
existingItem = SetActiveProperty(existingItem);
|
||||
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to set item as active to database.");
|
||||
|
||||
return existingItem;
|
||||
}
|
||||
public void Delete(Key id)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if (existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
Entities.Remove(existingItem);
|
||||
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to delete item from database.");
|
||||
|
||||
return;
|
||||
}
|
||||
public void Delete(Expression<Func<T, bool>> predicate)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
Entities.RemoveRange(Entities.Where(predicate));
|
||||
if (!SaveToDB())
|
||||
throw new NotificationException($"Unable to delete items from database.");
|
||||
}
|
||||
|
||||
public void InsertWithoutCommit(T entity)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
entity = SetCreatorProperties(entity);
|
||||
entity = SetUpdatorProperties(entity);
|
||||
entity = SetActiveProperty(entity);
|
||||
|
||||
var result = Entities.Add(entity);
|
||||
}
|
||||
|
||||
public void UpdateWithoutCommit(Key id, object model)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if (existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
Mapper.Map(model, existingItem);
|
||||
|
||||
existingItem = SetUpdatorProperties(existingItem);
|
||||
}
|
||||
|
||||
public void DeleteWithoutCommit(Key id)
|
||||
{
|
||||
var userLogin = GetLoginProfile();
|
||||
|
||||
var existingItem = Get(id);
|
||||
|
||||
if (existingItem == null)
|
||||
throw new NotificationException($"No item in database.");
|
||||
|
||||
Entities.Remove(existingItem);
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
#endregion
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user