using OpenAuth.Domain.Interface;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Text;
using System.Transactions;
using EntityFramework.Extensions;
using OpenAuth.Domain;

namespace OpenAuth.Repository
{
    public class UserRepository :BaseRepository<User>, IUserRepository
    {
        public IEnumerable<User> LoadUsers(int pageindex, int pagesize)
        {
            return Context.Users.OrderBy(u => u.Id).Skip((pageindex - 1) * pagesize).Take(pagesize);
        }

        public IEnumerable<User> LoadInOrgs(params int[] orgId)
        {
            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;

        }

        public int GetUserCntInOrgs(params int[] orgIds)
        {
            return LoadInOrgs(orgIds).Count();
        }

        public IEnumerable<User> LoadInOrgs(int pageindex, int pagesize, params int[] orgIds)
        {
            return LoadInOrgs(orgIds).OrderBy(u =>u.Id).Skip((pageindex -1)*pagesize).Take(pagesize);
        }

        /// <summary>
        /// 设置用户的机构
        /// </summary>
        public void SetOrg(int userId, params int[] orgIds)
        {
            using (TransactionScope ts = new TransactionScope())
            {
                Context.UserOrgs.Where(u => u.UserId == userId).Delete();

                foreach (var orgId in orgIds)
                {
                    Context.UserOrgs.Add(new UserOrg{OrgId = orgId,UserId = userId});
                }
                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();
            }
        }
    }
}