OpenAuth.Net/OpenAuth.Repository/UserRepository.cs

71 lines
2.0 KiB
C#
Raw Normal View History

2015-10-26 21:58:12 +08:00
using OpenAuth.Domain.Interface;
using System;
using System.Collections.Generic;
2015-11-13 21:33:53 +08:00
using System.Globalization;
2015-10-26 21:58:12 +08:00
using System.Linq;
using System.Text;
2015-11-13 21:33:53 +08:00
using System.Transactions;
using EntityFramework.Extensions;
2015-10-26 21:58:12 +08:00
using OpenAuth.Domain;
namespace OpenAuth.Repository
{
public class UserRepository :BaseRepository<User>, IUserRepository
{
2015-11-13 21:33:53 +08:00
public IEnumerable<User> LoadUsers()
2015-10-26 21:58:12 +08:00
{
2015-11-13 21:33:53 +08:00
return Context.Users.ToList();
2015-10-26 21:58:12 +08:00
}
2015-11-13 21:33:53 +08:00
public IEnumerable<User> LoadInOrgs(params int[] orgId)
2015-10-26 21:58:12 +08:00
{
2015-11-13 21:33:53 +08:00
var result = from user in Context.Users
where (
Context.UserOrgs.Where(uo => orgId.Contains(uo.OrgId))
.Select(u => u.UserId)
.Distinct()
)
.Contains(user.Id)
select user;
return result;
2015-10-26 21:58:12 +08:00
}
2015-11-13 21:33:53 +08:00
public int GetUserCount(params int[] orgIds)
2015-10-26 21:58:12 +08:00
{
2015-11-13 21:33:53 +08:00
return LoadInOrgs(orgIds).Count();
}
public IEnumerable<User> LoadInOrgs(int pageindex, int pagesize, params int[] orgIds)
{
return LoadInOrgs(orgIds).OrderBy(u =>u.Name).Skip((pageindex -1)*pagesize).Take(pagesize);
}
public void AddWithOrg(User user, params int[] orgIds)
{
using (TransactionScope ts = new TransactionScope())
{
Add(user);
Save();
foreach (var orgId in orgIds)
{
Context.UserOrgs.Add(new UserOrg{OrgId = orgId,UserId = user.Id});
}
Save();
ts.Complete();
}
}
public void Delete(int id)
{
using (TransactionScope ts = new TransactionScope())
{
Context.UserOrgs.Where(u => u.UserId == id).Delete();
Delete(u =>u.Id == id);
ts.Complete();
}
2015-10-26 21:58:12 +08:00
}
}
}