using WIDESEA_Core.Authorization; using WIDESEA_Core; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Const; using WIDESEA_Core.Helper; using WIDESEA_Core.HttpContextUser; using WIDESEA_ISystemService; using WIDESEA_Model; using WIDESEA_Model.Models; using WIDESEA_ISystemRepository; using WIDESEA_Core.BaseRepository; using System.Net; using WIDESEA_Core.Caches; using SqlSugar; using ICacheService = WIDESEA_Core.Caches.ICacheService; using HslCommunication.WebSocket; using System.Drawing.Drawing2D; using System.Linq; using MailKit.Search; using OrderByType = SqlSugar.OrderByType; using System.Drawing.Printing; namespace WIDESEA_SystemService { public class Sys_UserService : ServiceBase, ISys_UserService { private readonly IUnitOfWorkManage _unitOfWorkManage; private readonly ICacheService _cacheService; private readonly ISys_MenuService _menuService; private readonly ISys_RoleService _roleService; public ISys_UserRepository Repository => BaseDal; public Sys_UserService(ISys_UserRepository repository, IUnitOfWorkManage unitOfWorkManage, ICacheService cacheService, ISys_MenuService menuService, ISys_RoleService roleService) : base(repository) { _unitOfWorkManage = unitOfWorkManage; _cacheService = cacheService; _menuService = menuService; _roleService = roleService; } public WebResponseContent Login(LoginInfo loginInfo) { WebResponseContent content = new WebResponseContent(); try { //BaseDal.QueryFirst(x => x.UserName == loginInfo.UserName); string msg = string.Empty; #region 临时使用 try { loginInfo.Password = loginInfo.Password.EncryptDES(AppSecret.User); } catch { } #endregion UserInfo user = BaseDal.GetUserInfo(loginInfo.UserName, loginInfo.Password); if (user != null) { object obj = _menuService.GetMenuActionList(user.RoleId); if (obj is not IEnumerable list) { return WebResponseContent.Instance.Error("无登录权限"); } if (!list.Any()) { return WebResponseContent.Instance.Error("无登录权限"); } string token = JwtHelper.IssueJwt(new TokenModelJwt() { UserId = user.UserId, RoleId = user.RoleId, UserName = user.UserName, TenantId = user.TenantId, }); _cacheService.AddOrUpdate(user.UserId.ToString(), token); if (PermissionDataHostService.UserRoles.FirstOrDefault(x => x.UserId == user.UserId) == null) PermissionDataHostService.UserRoles.AddRange(PermissionDataHostService.GetUserRoles(Db, user.UserId)); content = WebResponseContent.Instance.OK(data: new { token, userName = user.UserName, img = user.HeadImageUrl, user.UserTrueName }); } else { content = WebResponseContent.Instance.Error("账号或密码错误"); } } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } public override WebResponseContent UpdateData(SaveModel saveModel) { UpdateIgnoreColOnExecute = x => { return new List { nameof(Sys_User.UserPwd), nameof(Sys_User.TenantId) }; }; return base.UpdateData(saveModel); } public override PageGridData GetPageData(PageDataOptions options) { int roleId = -1; //树形菜单传查询角色下所有用户 if (options.Value != null) { roleId = options.Value.ObjToInt(); } if (roleId <= 0) { if (App.User.IsHighestRole) return base.GetPageData(options); roleId = App.User.RoleId; } int totalCount = 0; List roleIds = _roleService.GetAllChildrenRoleId(roleId).Where(x => x != roleId).ToList(); ISugarQueryable sugarQueryable = Db.Queryable(); ValidatePageOptions(options, TProperties, ref sugarQueryable); Dictionary orderbyDic = options.GetPageDataSort(TProperties); List orderByModels = new List(); foreach (var item in orderbyDic) { OrderByModel orderByModel = new OrderByModel() { FieldName = item.Key, OrderByType = item.Value }; orderByModels.Add(orderByModel); } List users = sugarQueryable.Where(x => roleIds.Contains(x.RoleId) || x.UserId == App.User.UserId).OrderBy(orderByModels).ToPageList(options.Page, options.Rows, ref totalCount); return new PageGridData { Rows = users, Total = totalCount }; } public override WebResponseContent AddData(SaveModel saveModel) { string pwd = "123456"; string uesrName = saveModel.MainData[nameof(Sys_User.UserName).FirstLetterToLower()].ToString(); saveModel.MainData[nameof(Sys_User.UserPwd).FirstLetterToLower()] = pwd.EncryptDES(AppSecret.User); WebResponseContent content = base.AddData(saveModel); if (content.Status) { return WebResponseContent.Instance.OK($"用户新建成功.帐号{uesrName}密码{pwd}"); } else { return content; } } /// /// 个人中心获取当前用户信息 /// /// public WebResponseContent GetCurrentUserInfo() { var data = BaseDal.QueryFirst(x => x.UserId == App.User.UserId, s => new { s.UserName, s.UserTrueName, s.Address, s.PhoneNo, s.Email, s.Remark, s.Gender, s.RoleName, s.HeadImageUrl, s.CreateDate }); return WebResponseContent.Instance.OK(null, data); } /// /// 修改密码 /// /// /// public WebResponseContent ModifyPwd(string oldPwd, string newPwd) { WebResponseContent content = WebResponseContent.Instance; oldPwd = oldPwd?.Trim(); newPwd = newPwd?.Trim(); string message = ""; try { if (string.IsNullOrEmpty(oldPwd)) return WebResponseContent.Instance.Error("旧密码不能为空"); if (string.IsNullOrEmpty(newPwd)) return WebResponseContent.Instance.Error("新密码不能为空"); if (newPwd.Length < 6) return WebResponseContent.Instance.Error("密码不能少于6位"); int userId = App.User.UserId; string userCurrentPwd = BaseDal.QueryFirst(x => x.UserId == userId, s => s.UserPwd); string _oldPwd = oldPwd.EncryptDES(AppSecret.User); if (_oldPwd != userCurrentPwd) return WebResponseContent.Instance.Error("旧密码不正确"); string _newPwd = newPwd.EncryptDES(AppSecret.User); if (userCurrentPwd == _newPwd) return WebResponseContent.Instance.Error("新密码不能与旧密码相同"); BaseDal.UpdateData(new Sys_User { UserId = userId, UserPwd = _newPwd, LastModifyPwdDate = DateTime.Now }, new List { nameof(Sys_User.LastModifyPwdDate), nameof(Sys_User.UserPwd) }); content = WebResponseContent.Instance.OK("密码修改成功"); } catch (Exception ex) { message = ex.Message; content = WebResponseContent.Instance.Error("服务器了点问题,请稍后再试"); } return content; } } }