using AutoMapper;
using LinqKit;
using Ropin.Inspection.Common.Accessor.Interface;
using Ropin.Inspection.Common.Helper;
using Ropin.Inspection.Model;
using Ropin.Inspection.Model.Common;
using Ropin.Inspection.Model.Entities;
using Ropin.Inspection.Model.SearchModel;
using Ropin.Inspection.Model.ViewModel;
using Ropin.Inspection.Repository;
using Ropin.Inspection.Repository.Interface;
using Ropin.Inspection.Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace Ropin.Inspection.Service
{
    public class TsysUserService : ITsysUserService
    {
        private readonly ITsysUserRepository _repository;
        private readonly ITsysRoleRepository _tsysRoleRepository;
        private readonly ITsysUserRoleRepository _tsysUserRoleRepository;
        private readonly IMapper _mapper;
        private readonly IClaimsAccessor _claims;
        public TsysUserService(IClaimsAccessor claims, ITsysUserRepository repository, ITsysRoleRepository tsysRoleRepository, ITsysUserRoleRepository tsysUserRoleRepository, IMapper mapper)
        {
            _repository = repository;
            _tsysRoleRepository = tsysRoleRepository;
            _tsysUserRoleRepository = tsysUserRoleRepository;
            _mapper = mapper;
            _claims = claims;
        }
        public TsysUserViewModel GetUser(TsysUserSearchModel searchUser)
        {
            var user = _repository.GetUser(searchUser);
            var userDto = _mapper.Map<TsysUserViewModel>(user);
            return userDto;
        }
        public TsysUserDetailViewModel GetUserDetail(LoginModel loginModel)
        {
            var user = _repository.GetUserDetail(loginModel);
            return user;
        }
        public async Task<TsysUserViewModel> GetByIdAsync(Guid id)
        {
            var user = await _repository.GetByIdAsync(id);
            var userDto = _mapper.Map<TsysUserViewModel>(user);
            if (null == userDto)
            {
                return null;
            }
            var predicate = PredicateBuilder.New<TSYS_UserRole>(true);
            predicate = predicate.And(i => i.C_UserCode.Equals(id));
            IEnumerable<TSYS_UserRole> userRoles = await _tsysUserRoleRepository.GetByConditionAsync(predicate);
            if (userRoles.FirstOrDefault() == null)
            {
               // userDto.UserRole = Guid.Empty;
            }
            else
            {
                userDto.UserRole =userRoles.FirstOrDefault().C_RoleCode;
            }
            
            return userDto;
        }

        public async Task<TsysUserViewModel> GetByMobileAsync(string mobile)
        {
            var usermodel = await _repository.GetByConditionAsync(t=>t.C_Mobile==mobile);
            var user = usermodel?.FirstOrDefault();
            var userDto = _mapper.Map<TsysUserViewModel>(user);
            if (null == userDto)
            {
                return null;
            }
            var predicate = PredicateBuilder.New<TSYS_UserRole>(true);
            predicate = predicate.And(i => i.C_UserCode.Equals(user.C_UserID));
            IEnumerable<TSYS_UserRole> userRoles = await _tsysUserRoleRepository.GetByConditionAsync(predicate);
            if (userRoles.FirstOrDefault() == null)
            {
                // userDto.UserRole = Guid.Empty;
            }
            else
            {
                userDto.UserRole = userRoles.FirstOrDefault().C_RoleCode;
            }

            return userDto;
        }
        public async Task<TsysUserDetailWithOrgRoleViewModel> GetByUserIdAsync(Guid userId)
        {
            var pagedList = await _repository.GetByNameAsync(new TsysUserSearchByNameModel {G_UserId = userId,IsPagination = false });
            return pagedList?.Rows.FirstOrDefault();
        }
        public async Task CreateOneAsync(TsysUserCreateViewModel viewModel)
        {
            _repository.CheckUser(viewModel);
            var user = _mapper.Map<TSYS_User>(viewModel);
            user.C_UserID = Guid.NewGuid();
            user.C_UserName = user.C_UserID.ToString();
            user.C_IDNum = GenerateHelper.generate(); //string.IsNullOrWhiteSpace(user.C_IDNum) ? 
            user.C_LicenseCode = user.C_LicenseCode ??  _claims.Linsence;
            user.C_Password = EncryptUtil.Encrypt("123456").ToLower();
            user.C_CreateBy = _claims.ApiUserId;
            user.D_CreateOn = DateTime.Now;
            user.C_Status = "1";
            _repository.Create(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("创建用户失败");
            }
            await _tsysUserRoleRepository.DeleteByUserIdAsync(user.C_UserID);
            foreach (Guid roleId in viewModel.RoleCodeList)
            {
                TSYS_UserRole userRole = new TSYS_UserRole()
                {
                    C_UserCode = user.C_UserID,
                    C_RoleCode = roleId,
                    C_CreateBy = _claims.ApiUserId,
                    D_CreateOn = DateTime.Now,
                };
                _tsysUserRoleRepository.Create(userRole);
            }

            result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("创建用户角色失败");
            }
        }

        public async Task<IEnumerable<TsysUserViewModel>> GetAllAsync()
        {
            var pagedList = await _repository.GetAllAsync();
            var userDtoList = _mapper.Map<IEnumerable<TsysUserViewModel>>(pagedList);
            return userDtoList.ToList();
        }

        public Task<IEnumerable<TsysUserViewModel>> GetByConditionAsync(Expression<Func<TsysUserViewModel, bool>> expression)
        {
            throw new NotImplementedException();
        }

        public Task<int> UpdateOneAsync(TsysUserViewModel viewModel, params string[] fields)
        {
            throw new NotImplementedException();
        }

        public Task<bool> IsExistAsync(Guid id)
        {
            throw new NotImplementedException();
        }
        public async Task<bool> IsExistByMobileAsync(string mobile)
        {
            var usermodel = await _repository.GetByConditionAsync(t => t.C_Mobile == mobile);
            if (usermodel != null&& usermodel.Count()>0)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
        public async Task DeleteAsync(Guid id)
        {
            var user = await _repository.GetByIdAsync(id);
            if (user == null)
            {
                throw new Exception("没有此用户");
            }
            user.C_Status = "0";
            user.C_LastUpdatedBy = _claims.ApiUserId;
            user.D_LastUpdatedOn = DateTime.Now;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("删除用户失败");
            }
        }
        public async Task UpdateUserOpenIdAsync(Guid id,string openId)
        {
            var user = await _repository.GetByIdAsync(id);
            if (user == null)
            {
                throw new Exception("没有此用户");
            }
            user.C_WechatID = openId;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新失败");
            }
           
        }
        public async Task UpdateUserAsync(Guid id, TsysUserUpdateViewModel updateUser)
        {
            var user = await _repository.GetByIdAsync(id);
            if (user == null)
            {
                throw new Exception("没有此用户");
            }
            user.C_LastUpdatedBy = _claims.ApiUserId;
            user.D_LastUpdatedOn = DateTime.Now;
            _mapper.Map(updateUser, user, typeof(TsysUserUpdateViewModel), typeof(TSYS_User));
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户失败");
            }
           

            await _tsysUserRoleRepository.DeleteByUserIdAsync(user.C_UserID);
            foreach (Guid roleId in updateUser.RoleCodeList)
            {
                TSYS_UserRole userRole = new TSYS_UserRole()
                {
                    C_UserCode = user.C_UserID,
                    C_RoleCode = roleId,
                    C_CreateBy = _claims.ApiUserId,
                    D_CreateOn = DateTime.Now,
                };
                _tsysUserRoleRepository.Create(userRole);
            }

            result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户角色失败");
            }
        }

        public async Task ChangePasswordAsync(Guid id, ChangePasswordModel passwordModel)
        {
            if (passwordModel.NewPassWordFrist != passwordModel.NewPassWordTwo)
            {
                throw new Exception("两次输入新密码不一致");
            }
            
            var user = await _repository.GetByIdAsync(id);
            if (user == null)
            {
                throw new Exception("没有此用户");
            }
            if (passwordModel.OldPassWord.ToLower() != user.C_Password)
            {
                throw new Exception("旧密码不正确");
            }
            user.C_LastUpdatedBy = id;
            user.D_LastUpdatedOn = DateTime.Now;
            user.C_Password = passwordModel.NewPassWordFrist;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户失败");
            }

            if (passwordModel.OldPassWord.ToLower() == "e10adc3949ba59abbe56e057f20f883e")
            {
                string msg = @"<p><td> 时间:</td> " + DateTime.Now + "</p>" +
                    "<p><td> 修改人:</td> " + user.C_Name + "</p>" +
                     "<p><td> 修改手机号:</td> " + user.C_Mobile + "</p>"
                         ;

               bool bols= EmailHelper.SendEmail("yuweichun@126.com", "用户", "用户修改密码", msg);
                if (!bols)
                {
                    throw new Exception("用户密码修改成功，邮件发送失败");
                }
            }

        }

        public async Task ResetPasswordAsync(Guid id)
        {
            var user = await _repository.GetByIdAsync(id);
            if (user == null)
            {
                throw new Exception("没有此用户");
            }
            user.C_LastUpdatedBy = _claims.ApiUserId;
            user.D_LastUpdatedOn = DateTime.Now;
            user.C_Password = EncryptUtil.Encrypt("123456").ToLower();
            user.C_WechatID = String.Empty;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户失败");
            }
        }

        public async Task<List<TsysUserViewModel>> GetByAsync(TsysUserSearchModel searchModel)
        {
            //使用PredicateBuilder获取分页数据方式支持筛选
            var predicate = PredicateBuilder.New<TSYS_User>(true);//查询条件,推荐后台使用这种方式灵活筛选
            #region 添加条件查询
            predicate = predicate.And(i => i.C_Status.Equals("1"));
            if (!string.IsNullOrEmpty(searchModel.C_Name))
            {
                predicate = predicate.And(i => i.C_Name.Contains(searchModel.C_Name));
            }
            //if (searchModel. != null)
            //{
            //    predicate = predicate.And(i => i.Status.Equals(Status));
            //}
            if (!string.IsNullOrEmpty(searchModel.C_Mobile))
            {
                predicate = predicate.And(i => i.C_Mobile.Equals(searchModel.C_Mobile));
            }
            if (!searchModel.G_OrganizeCode.Equals(Guid.Empty))
            {
                predicate = predicate.And(i => i.C_OrgCode.Equals(searchModel.G_OrganizeCode));
            }
            #endregion
            var list = await _repository.GetPageAsync(predicate, "C_Name,-D_CreateOn", searchModel.IsPagination, searchModel.PageIndex, searchModel.PageSize);
            searchModel.TotalCount = list.Totals;
            var userDtoList = _mapper.Map<List<TSYS_User>, List<TsysUserViewModel>>(list.Rows);
            return userDtoList;
            //return PagedList<TsysUserViewModel>.Create(userDtoList,searchModel.PageIndex,searchModel.PageSize);
        }

        public async Task<List<TsysUserDetailWithOrgRoleViewModel>> GetByNameAsync(TsysUserSearchByNameModel searchModel)
        {

            var pagedList = await _repository.GetByNameAsync(searchModel);
            searchModel.TotalCount = pagedList == null ? 0 : pagedList.Totals;
            return pagedList?.Rows;
        }
        public async Task<IEnumerable<TsysUserViewModel>> GetByStoreCodeAsync(string storeCode)
        {
            var users = await _repository.GetByStoreCodeAsync(storeCode);
            var userDtos = _mapper.Map<IEnumerable<TsysUserViewModel>>(users);
            return userDtos;
        }

        public async Task<TsysUserViewModel> LoginByAsync(LoginModel loginModel)
        {
            var user = await _repository.LoginByAsync(loginModel);
            var userDto = _mapper.Map<TsysUserViewModel>(user);
            return userDto;
        }

        public async Task<TsysUserDetailViewModel> GetUserDetailByAsync(LoginModel loginModel)
        {
            var user = await _repository.GetUserDetailByAsync(loginModel);
            return user;
        }

        public async Task LogOutByAsync()
        {
            var user = await _repository.GetByIdAsync(_claims.ApiUserId);
            if (user == null)
                throw new Exception("退出失败");
            user.C_WechatID = null;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户失败");
            }
        }

        public async Task<bool> IsNeedAuth()
        {
            var user = await _repository.GetByIdAsync(_claims.ApiUserId);
            if (user == null)
                throw new Exception("获取用户失败");
            if (string.IsNullOrEmpty(user.C_WxopenID))
                return true;
            return false;
        }

        public async Task<bool> SetOpenId(string openId)
        {
            var user = await _repository.GetByIdAsync(_claims.ApiUserId);
            if (user == null)
                throw new Exception("获取用户失败");
            user.C_WxopenID = openId;
            _repository.Update(user);
            var result = await _repository.SaveAsync();
            if (!result)
            {
                throw new Exception("更新用户失败");
            }
            return result;
        }

        public Task CreateOneAsync(TsysUserViewModel viewModel)
        {
            throw new NotImplementedException();
        }

        //public List<TsysUserViewModel> FindAll()
        //{
        //    var pagedList = _repository.GetAll();
        //    var userDtoList = _mapper.Map<IEnumerable<TsysUserViewModel>>(pagedList);
        //    return userDtoList.ToList();
        //}

        //public async Task InsertOneAsync(TsysUserViewModel viewModel)
        //{
        //    var model = _mapper.Map<TSYS_User>(viewModel);
        //    await _repository.CreateOneAsync(model);
        //}

        //public Task<int> UpdateOneAsync(TsysUserViewModel viewModel, params string[] fields)
        //{
        //    throw new NotImplementedException();
        //}
    }
}