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();
//}
}
}