using iWareCommon.Common.Entity;
using iWareCommon.Common.EnumType;
using iWareCommon.Common.Service;
using iWareCommon.Utils;
using iWareDataCore.ORM;
using iWareDataCore.Properties;
using iWareDataCore.RBAC.Dao;
using iWareDataCore.RBAC.Entity;
using iWareDataCore.RBAC.EnumType;
using System;
using System.Collections.Generic;
using System.Data.Entity.Validation;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace iWareDataCore.RBAC.Service
{
   public class UserService : CommonService<UserEntity, RBACUser, DbModelCore>
    {

        private static object Lock = new object();

        private UserService() : base(UserDao.GetInstance()) { }

        private static UserService Instance = null;

        /// <summary>
        /// 获取单例的方法
        /// </summary>
        /// <returns>用户服务的单例实体</returns>
        public static UserService GetInstance()
        {

            if (Instance == null)
            {
                lock (Lock)
                {
                    if (Instance == null)
                    {
                        Instance = new UserService();
                    }
                }
            }
            return Instance;
        }

        /// <summary>
        /// 批量修改用户状态
        /// </summary>
        /// <param name="ids">需要修改的用户id列表</param>
        /// <param name="status">状态:1为启用，0为锁定</param>
        /// <param name="msg">异常错误消息</param>
        /// <returns>修改的用户数量</returns>
        public int ChangeStatus(List<int> ids, int status, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var ones = dbModel.RBACUsers.Where(x => ids.Contains(x.id)).ToList();

                    foreach (var one in ones)
                    {
                        one.status = status;
                    }

                    dbModel.SaveChanges();
                    return ones.Count;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ChangeStatus", ex.Message);
                    return -1;
                }
            }
        }


        /// <summary>
        /// 用户自己修改用户密码
        /// </summary>
        /// <param name="id">用户Id</param>
        /// <param name="oldPassword">原密码</param>
        /// <param name="newPassword">新密码</param>
        /// <param name="msg">异常错误消息</param>
        /// <returns>修改用户的Id，发生错误是返回-1</returns>
        public int ChangePassword(int id, string oldPassword, string newPassword, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var oPass = MD5Helper.ParseMd5(oldPassword);

                    var users = dbModel.RBACUsers.Where(x => x.id == id && x.password == oPass).ToList();

                    if (users.Count <= 0)
                    {
                        msg = "您输入的原始密码错误！";
                        return -1;
                    }

                    users[0].password = MD5Helper.ParseMd5(newPassword);
                    dbModel.SaveChanges();
                    return id;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ChangePassword", ex.Message);
                    return -1;
                }
            }
        }

        /// <summary>
        /// 将密码重置为111111
        /// </summary>
        /// <param name="id">用户Id</param>
        /// <param name="msg">异常错误消息</param>
        /// <returns>修改用户的Id，发生错误是返回-1</returns>
        public int ResetPassword(int id, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var users = dbModel.RBACUsers.Where(x => x.id == id).ToList();

                    if (users.Count <= 0)
                    {
                        msg = "未找到指定用户！";
                        return -1;
                    }

                    users[0].password = MD5Helper.ParseMd5(Resources.InitPassword);
                    dbModel.SaveChanges();
                    return id;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ResetPassword", ex.Message);
                    return -1;
                }
            }
        }

        public override List<UserEntity> QueryByParam(QueryParam param, out string msg)
        {
            msg = "";

            using (var dbModel = new DbModelCore())
            {
                var users = UserDao.GetInstance().QueryByParam(param, dbModel);
                var roles = RoleDao.GetInstance().QueryByParam(new QueryParam(), dbModel);
                //以角色Id为键，角色实体为值的字典
                var roleDictionary = new Dictionary<int, RoleEntity>();

                foreach (var role in roles)
                {
                    roleDictionary.Add(role.Id, role);
                }

                //以用户id为键，角色id列表为值的字典
                var userIdRoleIdsDictionary = new Dictionary<int, List<int>>();

                foreach (var user in users)
                {
                    userIdRoleIdsDictionary.Add(user.Id, new List<int>());
                }

                var roleUsers = RoleUserDao.GetInstance().QueryByParam(new QueryParam(), dbModel);

                foreach (var one in roleUsers)
                {
                    if (userIdRoleIdsDictionary.ContainsKey(one.UserId))
                    {
                        userIdRoleIdsDictionary[one.UserId].Add(one.RoleId);
                    }
                }

                foreach (var user in users)
                {
                    foreach (var roleId in userIdRoleIdsDictionary[user.Id])
                    {
                        user.Roles.Add(roleDictionary[roleId]);
                        user.DisplayRoleNames += roleDictionary[roleId].RoleName + ",";
                    }

                    if (user.DisplayRoleNames.EndsWith(","))
                    {
                        user.DisplayRoleNames = user.DisplayRoleNames.Substring(0, user.DisplayRoleNames.Length - 1);
                    }
                }
                return users;
            }
        }

        public override List<UserEntity> QueryByParam(QueryParam param, out string msg, out int totalNum, out int currentPage)
        {
            msg = "";
            totalNum = 0;
            currentPage = 1;
            using (var dbModel = new DbModelCore())
            {
                var users = UserDao.GetInstance().QueryByParam(param, dbModel, out totalNum, out currentPage);
                var roles = RoleDao.GetInstance().QueryByParam(new QueryParam(), dbModel);
                //以角色Id为键，角色实体为值的字典
                var roleDictionary = new Dictionary<int, RoleEntity>();

                foreach (var role in roles)
                {
                    roleDictionary.Add(role.Id, role);
                }

                //以用户id为键，角色id列表为值的字典
                var userIdRoleIdsDictionary = new Dictionary<int, List<int>>();

                foreach (var user in users)
                {
                    userIdRoleIdsDictionary.Add(user.Id, new List<int>());
                }

                var roleUsers = RoleUserDao.GetInstance().QueryByParam(new QueryParam(), dbModel);

                foreach (var one in roleUsers)
                {
                    if (userIdRoleIdsDictionary.ContainsKey(one.UserId))
                    {
                        userIdRoleIdsDictionary[one.UserId].Add(one.RoleId);
                    }
                }

                foreach (var user in users)
                {
                    foreach (var roleId in userIdRoleIdsDictionary[user.Id])
                    {
                        user.Roles.Add(roleDictionary[roleId]);
                        user.DisplayRoleNames += roleDictionary[roleId].RoleName + ",";
                    }

                    if (user.DisplayRoleNames.EndsWith(","))
                    {
                        user.DisplayRoleNames = user.DisplayRoleNames.Substring(0, user.DisplayRoleNames.Length - 1);
                    }
                }
                return users;
            }

        }

        public override int Delete(int id, out string msg)
        {
            Delete(new List<int> { id }, out msg);
            return string.IsNullOrEmpty(msg) ? id : -1;
        }

        public override int Delete(List<int> ids, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var roleUsers = dbModel.RBACRoleUsers.Where(x => ids.Contains(x.userid)).ToList();
                    roleUsers.ForEach(x => dbModel.RBACRoleUsers.Remove(x));


                    var ones = dbModel.RBACUsers.Where(x => ids.Contains(x.id)).ToList();
                    ones.ForEach(x => x.label = (int)ELabelStatus.已删除);

                    dbModel.SaveChanges();
                    return ones.Count;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "DeleteBatch", ex.Message);
                    return 0;
                }
            }
        }

        public override int Save(UserEntity user, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var one = user.ToOrm();
                    if (string.IsNullOrEmpty(one.password))
                    {
                        one.password = MD5Helper.ParseMd5(Resources.InitPassword);
                    }
                    else 
                    {
                        one.password = MD5Helper.ParseMd5(one.password);
                    }

                    if (user.Roles != null)
                    {
                        foreach (var role in user.Roles)
                        {
                            one.RBACRoleUsers.Add(new RBACRoleUser
                            {
                                roleid = role.Id
                            });
                        }
                    }
                    dbModel.RBACUsers.Add(one);
                    dbModel.SaveChanges();
                    return one.id;
                }
                catch (DbEntityValidationException ex)
                {
                    var errs = ex.EntityValidationErrors.SelectMany(validationResult => validationResult.ValidationErrors).Select(m => m.ErrorMessage);
                    msg = string.Join(", ", errs);
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Save", msg);
                    return -1;
                }


                catch (Exception ex)
                {
                    msg = ex.HResult == (int)EDbError.记录已存在 ? EDbError.记录已存在.ToString() : ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Save", msg);
                    return -1;
                }
            }
        }

        public override int Update(UserEntity user, out string msg)
        {
            msg = "";
            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var one = dbModel.RBACUsers.First(x => x.id == user.Id);

                    EntityPropHelper<UserEntity, RBACUser>.CopyProp(user, one, UserEntity.GetColumnMap());


                    var ones = dbModel.RBACRoleUsers.Where(x => x.userid == user.Id).ToList();

                    foreach (var ur in ones)
                    {
                        dbModel.RBACRoleUsers.Remove(ur);
                    }


                    if (user.Roles != null)
                    {
                        foreach (var role in user.Roles)
                        {
                            one.RBACRoleUsers.Add(new RBACRoleUser
                            {

                                roleid = role.Id
                            });
                        }
                    }


                    dbModel.SaveChanges();
                    return one.id;
                }

                catch (DbEntityValidationException ex)
                {
                    var errs = ex.EntityValidationErrors.SelectMany(validationResult => validationResult.ValidationErrors).Select(m => m.ErrorMessage);
                    msg = string.Join(", ", errs);
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Save", msg);
                    return -1;
                }

                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Update", ex.Message);
                    return -1;
                }
            }
        }


        /// <summary>
        /// 用户登录验证
        /// </summary>
        /// <param name="username">用户名</param>
        /// <param name="password">密码</param>
        /// <param name="msg">异常错误信息</param>
        /// <returns>登录成功后的用户信息,登录失败时返回null</returns>
        public UserEntity Login(string username, string password, out string msg)
        {
            msg = "";

            if (string.IsNullOrEmpty(username))
            {
                msg = "用户名不能为空";
                return null;
            }

            if (string.IsNullOrEmpty(password))
            {
                msg = "密码不能为空";
                return null;
            }

            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var pass = MD5Helper.ParseMd5(password);

                    var users = dbModel.RBACUsers.Where(x => x.username == username && x.password == pass && x.status == (int)EStatus.启用 && x.label == (int)ELabelStatus.未删除).ToList();

                    if (users.Count <= 0)
                    {
                        msg = "用户名或密码错误！";
                        return null;
                    }

                    var user = new UserEntity(users[0]);

                    //拼装用户角色
                    var roleUsers = dbModel.RBACRoleUsers.Where(x => x.userid == user.Id).ToList();

                    var roleIds = new List<int>();

                    foreach (var one in roleUsers)
                    {
                        roleIds.Add(one.roleid);
                    }

                    var roles = dbModel.RBACRoles.Where(x => roleIds.Contains(x.id)).ToList();

                    foreach (var role in roles)
                    {
                        user.Roles.Add(new RoleEntity(role));
                    }

                    //拼装用户菜单
                    var roleContents = dbModel.RBACRoleContents.Where(x => roleIds.Contains(x.roleid)).ToList();

                    var contentIds = new List<int>();

                    var valueDictionary = new Dictionary<int, int>();

                    foreach (var roleContent in roleContents)
                    {
                        if (!contentIds.Contains(roleContent.contentid))
                        {
                            contentIds.Add(roleContent.contentid);
                            valueDictionary.Add(roleContent.contentid, roleContent.value);
                        }
                        else
                        {
                            if (valueDictionary[roleContent.contentid] < roleContent.value)
                            {
                                valueDictionary[roleContent.contentid] = roleContent.value;
                            }
                        }
                    }

                    var contents = dbModel.RBACContents.Where(x => contentIds.Contains(x.id)).OrderBy(x => x.contentindex).ToList();

                    var planContents = new List<ContentValueEntity>();

                    foreach (var content in contents)
                    {
                        planContents.Add(new ContentValueEntity(content, valueDictionary[content.id]));
                    }

                    var childrenDictionary = TreeHelper<ContentValueEntity>.GetChildrenDictionary(planContents);

                    var userContents = childrenDictionary.ContainsKey(-1) ? childrenDictionary[-1] : new List<ContentValueEntity>();

                    foreach (var content in userContents)
                    {
                        if (((int)EContentType.用于BS端的菜单).Equals(content.Type))
                        {
                            user.Contents.Add(content);
                        }
                        else if (((int)EContentType.用于CS端的菜单).Equals(content.Type))
                        {
                            user.CsContents.Add(content);
                        }
                    }



                    if (user.Roles.Count > 0)
                    {
                        for (var i = 0; i < user.Roles.Count; i++)
                        {
                            user.DisplayRoleNames += user.Roles[i].RoleName + ",";
                        }
                        if (user.DisplayRoleNames.EndsWith(","))
                        {
                            user.DisplayRoleNames = user.DisplayRoleNames.Substring(0, user.DisplayRoleNames.Length - 1);
                        }
                    }

                    return user;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Login", ex.Message);
                    return null;
                }
            }
        }

        /// <summary>
        /// 用户登录验证
        /// </summary>
        /// <param name="username">用户名</param>
        /// <param name="password">密码</param>
        /// <param name="msg">异常错误信息</param>
        /// <returns>登录成功后的用户信息,登录失败时返回null</returns>
        public UserEntity Login(string username, string password, string cellName, out string msg)
        {
            msg = "";

            if (string.IsNullOrEmpty(username))
            {
                msg = "用户名不能为空";
                return null;
            }

            if (string.IsNullOrEmpty(password))
            {
                msg = "密码不能为空";
                return null;
            }

            using (var dbModel = new DbModelCore())
            {
                try
                {
                    var pass = MD5Helper.ParseMd5(password);

                    var users = dbModel.RBACUsers.Where(x => x.username == username && x.password == pass && x.status == (int)EStatus.启用 && x.label == (int)ELabelStatus.未删除).ToList();

                    if (users.Count <= 0)
                    {
                        msg = "用户名或密码错误！";
                        return null;
                    }

                    var user = new UserEntity(users[0]);
                    var roleIds = new List<int>();

                    var roles = dbModel.RBACRoles.Where(x => x.rolename == cellName).ToList();

                    foreach (var role in roles)
                    {
                        roleIds.Add(role.id);
                        user.Roles.Add(new RoleEntity(role));
                    }

                    //拼装用户菜单
                    var roleContents = dbModel.RBACRoleContents.Where(x => roleIds.Contains(x.roleid)).ToList();

                    var contentIds = new List<int>();

                    var valueDictionary = new Dictionary<int, int>();

                    foreach (var roleContent in roleContents)
                    {
                        if (!contentIds.Contains(roleContent.contentid))
                        {
                            contentIds.Add(roleContent.contentid);
                            valueDictionary.Add(roleContent.contentid, roleContent.value);
                        }
                        else
                        {
                            if (valueDictionary[roleContent.contentid] < roleContent.value)
                            {
                                valueDictionary[roleContent.contentid] = roleContent.value;
                            }
                        }
                    }

                    var contents = dbModel.RBACContents.Where(x => contentIds.Contains(x.id)).OrderBy(x => x.contentindex).ToList();

                    var planContents = new List<ContentValueEntity>();

                    foreach (var content in contents)
                    {
                        planContents.Add(new ContentValueEntity(content, valueDictionary[content.id]));
                    }

                    var childrenDictionary = TreeHelper<ContentValueEntity>.GetChildrenDictionary(planContents);

                    var userContents = childrenDictionary.ContainsKey(-1) ? childrenDictionary[-1] : new List<ContentValueEntity>();

                    foreach (var content in userContents)
                    {
                        if (((int)EContentType.用于BS端的菜单).Equals(content.Type))
                        {
                            user.Contents.Add(content);
                        }
                        else if (((int)EContentType.用于CS端的菜单).Equals(content.Type))
                        {
                            user.CsContents.Add(content);
                        }
                    }



                    if (user.Roles.Count > 0)
                    {
                        for (var i = 0; i < user.Roles.Count; i++)
                        {
                            user.DisplayRoleNames += user.Roles[i].RoleName + ",";
                        }
                        if (user.DisplayRoleNames.EndsWith(","))
                        {
                            user.DisplayRoleNames = user.DisplayRoleNames.Substring(0, user.DisplayRoleNames.Length - 1);
                        }
                    }

                    return user;
                }
                catch (Exception ex)
                {
                    msg = ex.Message;
                    LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Login", ex.Message);
                    return null;
                }
            }
        }

    }
}