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(user); return userDto; } public TsysUserDetailViewModel GetUserDetail(LoginModel loginModel) { var user = _repository.GetUserDetail(loginModel); return user; } public async Task GetByIdAsync(Guid id) { var user = await _repository.GetByIdAsync(id); var userDto = _mapper.Map(user); if (null == userDto) { return null; } var predicate = PredicateBuilder.New(true); predicate = predicate.And(i => i.C_UserCode.Equals(id)); IEnumerable 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 GetByMobileAsync(string mobile) { var usermodel = await _repository.GetByConditionAsync(t=>t.C_Mobile==mobile); var user = usermodel?.FirstOrDefault(); var userDto = _mapper.Map(user); if (null == userDto) { return null; } var predicate = PredicateBuilder.New(true); predicate = predicate.And(i => i.C_UserCode.Equals(user.C_UserID)); IEnumerable 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 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(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> GetAllAsync() { var pagedList = await _repository.GetAllAsync(); var userDtoList = _mapper.Map>(pagedList); return userDtoList.ToList(); } public Task> GetByConditionAsync(Expression> expression) { throw new NotImplementedException(); } public Task UpdateOneAsync(TsysUserViewModel viewModel, params string[] fields) { throw new NotImplementedException(); } public Task IsExistAsync(Guid id) { throw new NotImplementedException(); } public async Task 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 = @"

时间: " + DateTime.Now + "

" + "

修改人: " + user.C_Name + "

" + "

修改手机号: " + user.C_Mobile + "

" ; 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> GetByAsync(TsysUserSearchModel searchModel) { //使用PredicateBuilder获取分页数据方式支持筛选 var predicate = PredicateBuilder.New(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>(list.Rows); return userDtoList; //return PagedList.Create(userDtoList,searchModel.PageIndex,searchModel.PageSize); } public async Task> GetByNameAsync(TsysUserSearchByNameModel searchModel) { var pagedList = await _repository.GetByNameAsync(searchModel); searchModel.TotalCount = pagedList == null ? 0 : pagedList.Totals; return pagedList?.Rows; } public async Task> GetByStoreCodeAsync(string storeCode) { var users = await _repository.GetByStoreCodeAsync(storeCode); var userDtos = _mapper.Map>(users); return userDtos; } public async Task LoginByAsync(LoginModel loginModel) { var user = await _repository.LoginByAsync(loginModel); var userDto = _mapper.Map(user); return userDto; } public async Task 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 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 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 FindAll() //{ // var pagedList = _repository.GetAll(); // var userDtoList = _mapper.Map>(pagedList); // return userDtoList.ToList(); //} //public async Task InsertOneAsync(TsysUserViewModel viewModel) //{ // var model = _mapper.Map(viewModel); // await _repository.CreateOneAsync(model); //} //public Task UpdateOneAsync(TsysUserViewModel viewModel, params string[] fields) //{ // throw new NotImplementedException(); //} } }