using Blog.Core.IRepository.Base; using Blog.Core.IServices; using Blog.Core.Model.Models; using Blog.Core.Services.BASE; using System.Linq; using System.Threading.Tasks; namespace Blog.Core.FrameWork.Services { /// /// sysUserInfoServices /// public class SysUserInfoServices : BaseServices, ISysUserInfoServices { private readonly IBaseRepository _userRoleRepository; private readonly IBaseRepository _roleRepository; public SysUserInfoServices(IBaseRepository userRoleRepository, IBaseRepository roleRepository) { _userRoleRepository = userRoleRepository; _roleRepository = roleRepository; } /// /// /// /// /// /// public async Task SaveUserInfo(string loginName, string loginPwd) { SysUserInfo sysUserInfo = new SysUserInfo(loginName, loginPwd); SysUserInfo model = new SysUserInfo(); var userList = await base.Query(a => a.LoginName == sysUserInfo.LoginName && a.LoginPWD == sysUserInfo.LoginPWD); if (userList.Count > 0) { model = userList.FirstOrDefault(); } else { var id = await base.Add(sysUserInfo); model = await base.QueryById(id); } return model; } /// /// /// /// /// /// public async Task GetUserRoleNameStr(string loginName, string loginPwd) { string roleName = ""; var user = (await base.Query(a => a.LoginName == loginName && a.LoginPWD == loginPwd)).FirstOrDefault(); var roleList = await _roleRepository.Query(a => a.IsDeleted == false); if (user != null) { var userRoles = await _userRoleRepository.Query(ur => ur.UserId == user.Id); if (userRoles.Count > 0) { var arr = userRoles.Select(ur => ur.RoleId.ObjToString()).ToList(); var roles = roleList.Where(d => arr.Contains(d.Id.ObjToString())); roleName = string.Join(',', roles.Select(r => r.Name).ToArray()); } } return roleName; } } } //----------sysUserInfo结束----------