From 1b84c97dd1cf5a746c5bbb185a0b7400b7f5ca24 Mon Sep 17 00:00:00 2001 From: sunpengfei <i@angelzzz.com> Date: 星期五, 15 八月 2025 10:08:40 +0800 Subject: [PATCH] pref:优化 --- FlexJobApi.UserServer.Application/Auths/Commands/LoginCommandHandler.cs | 41 ++++++++++++++++++++++++++++++++++++----- 1 files changed, 36 insertions(+), 5 deletions(-) diff --git a/FlexJobApi.UserServer.Application/Auths/Commands/LoginCommandHandler.cs b/FlexJobApi.UserServer.Application/Auths/Commands/LoginCommandHandler.cs index 6f0e55f..aeceebb 100644 --- a/FlexJobApi.UserServer.Application/Auths/Commands/LoginCommandHandler.cs +++ b/FlexJobApi.UserServer.Application/Auths/Commands/LoginCommandHandler.cs @@ -29,7 +29,8 @@ IRequestHandler<BindWxmpUserInfoCommand, LoginCommandCallback>, IRequestHandler<ChangePhoneNumberCommand, bool>, IRequestHandler<RegisterPersonalUserCommand, bool>, - IRequestHandler<GetPersonalLoginInfoQuery, GetPersonalLoginInfoQueryResult> + IRequestHandler<GetPersonalLoginInfoQuery, GetPersonalLoginInfoQueryResult>, + IRequestHandler<GetEnterpriseLoginInfoQuery, GetEnterpriseLoginInfoQueryResult> { private readonly IRepository<User> rep = rep; private readonly SmsUtils smsUtils = smsUtils; @@ -88,7 +89,7 @@ { if (request.Type == EnumUserType.Operation) { - throw Oops.Oh(EnumErrorCodeType.s400, "涓嶆敮鎸佽绫诲瀷璐﹀彿鐧诲綍"); + throw Oops.Oh(EnumErrorCodeType.s400, "涓嶆敮鎸佹绫诲瀷璐﹀彿鐧诲綍"); } var snsJscode2session = await wxmpUtils.SnsJscode2sessionAsync(request.Type, request.Code, cancellationToken); var user = await rep.AsQueryable().AsNoTracking() @@ -200,7 +201,7 @@ { if (type == EnumUserType.Enterprise) { - throw Oops.Oh(EnumErrorCodeType.s404, "璇ヨ处鍙�"); + throw Oops.Oh(EnumErrorCodeType.s404, "璐﹀彿"); } user.PhoneNumber = info.PhoneNumber; user.ContactPhoneNumber = info.PhoneNumber; @@ -272,18 +273,48 @@ var taskUserQueryable = rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking() .Where(it => it.EnterpriseEmployee.UserId == model.Id); model.TaskCount = await taskUserQueryable.CountAsync(tu => - tu.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Wait + tu.HireStatus == EnumTaskUserHireStatus.Wait || tu.EnterpriseEmployee.UserSignContractStatus == EnumTaskUserSignContractStatus.Wait); model.HirePassTaskCount = await taskUserQueryable.CountAsync(tu => tu.ArrangeStatus == EnumTaskUserArrangeStatus.Complete); model.HireRefuseTaskCount = await taskUserQueryable.CountAsync(tu => - tu.EnterpriseEmployee.HireStatus == EnumTaskUserHireStatus.Refuse + tu.HireStatus == EnumTaskUserHireStatus.Refuse || tu.EnterpriseEmployee.UserSignContractStatus == EnumTaskUserSignContractStatus.Refuse || tu.EnterpriseEmployee.EnterpriseSignContractStatus == EnumTaskUserSignContractStatus.Refuse); return model; } /// <summary> + /// 鏌ヨ浼佷笟鐢ㄦ埛鐧诲綍淇℃伅 + /// </summary> + /// <param name="request"></param> + /// <param name="cancellationToken"></param> + /// <returns></returns> + public async Task<GetEnterpriseLoginInfoQueryResult> Handle(GetEnterpriseLoginInfoQuery request, CancellationToken cancellationToken) + { + var logier = JwtUtils.GetCurrentLogier(); + var model = await rep.AsQueryable().AsNoTracking() + .Where(it => it.Id == logier.Id) + .GetDetail<User, GetEnterpriseLoginInfoQueryResult>(cancellationToken); + model.Roles = await rep.Change<Role>().AsQueryable().AsNoTracking() + .Where(it => it.UserRoles.Any(ur => ur.UserId == logier.Id)) + .Select(it => it.Name) + .ToListAsync(); + var collects = await rep.Change<EnterpriseUserCollect>().AsQueryable().AsNoTracking() + .Where(it => it.EnterpriseId == logier.EnterpriseId) + .Select(it => new + { + it.UserId, + it.IsCollected, + it.IsContacted + }) + .ToListAsync(); + model.CollectedUserCount = collects.Count(it => it.IsCollected); + model.ContactedRecordCount = collects.Count(it => it.IsContacted); + return model; + } + + /// <summary> /// 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛 /// </summary> /// <param name="user"></param> -- Gitblit v1.9.1