feat:开发

sunpengfei

2025-08-11 2b93d154c57c8456a730361d635a0ff88dc8dfe8

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
using FlexJobApi.Core;
using Furion.DatabaseAccessor;
using Furion.FriendlyException;
using Mapster;
using MediatR;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace FlexJobApi.UserServer.Application
{
    /// <summary>
    /// 用户简历查询处理器
    /// </summary>
    public class UserResumeQueryHandler(
            IRepository<User> rep
        ) :
        IRequestHandler<GetUserResumeQuery, GetUserResumeQueryResult>,
        IRequestHandler<GetUserResumePersonalQuery, GetUserResumePersonalQueryResult>,
        IRequestHandler<GetUserResumeJobSeekingQuery, GetUserResumeJobSeekingQueryResult>,
        IRequestHandler<GetUserResumeCredentialsQuery, List<GetUserResumeCredentialsQueryResultItem>>,
        IRequestHandler<GetUserResumeCredentialQuery, GetUserResumeCredentialQueryResult>,
        IRequestHandler<GetUserResumeWorkExperienceQuery, GetUserResumeWorkExperienceQueryResult>,
        IRequestHandler<GetUserResumeDetailQuery, GetUserResumeDetailQueryResult>
    {
        private readonly IRepository<User> rep = rep;
 
        /// <summary>
        /// 查询用户简历
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<GetUserResumeQueryResult> Handle(GetUserResumeQuery request, CancellationToken cancellationToken)
        {
            var logier = JwtUtils.GetCurrentLogier();
            if (logier.Type == EnumUserType.Personal)
            {
                request.UserId = logier.Id;
            }
            if (request.UserId == null) throw Oops.Oh(EnumErrorCodeType.s400, "请选择用户");
            var model = await request.UserId.Value
                 .GetDetail<User, GetUserResumeQueryResult>(cancellationToken);
            model.TaskCount = await rep.Change<TaskInfoUser>().AsQueryable().AsNoTracking()
                .Where(it => it.UserId == model.Id && it.HireStatus == EnumTaskUserHireStatus.Pass)
                .CountAsync();
            return model;
        }
 
        /// <summary>
        /// 查询用户简历-个人信息
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<GetUserResumePersonalQueryResult> Handle(GetUserResumePersonalQuery request, CancellationToken cancellationToken)
        {
            var model = await rep.GetPersonalQueryable(false)
                .GetDetail<User, GetUserResumePersonalQueryResultModel>(cancellationToken);
            var result = model.Adapt<GetUserResumePersonalQueryResult>();
            if (model.CityCode.IsNotNull())
            {
                result.CompleteRate += 20;
            }
            if (model.JobSeekingStatus.HasValue)
            {
                result.CompleteRate += 20;
            }
            if (model.UserCredentials.IsNotNull())
            {
                result.CompleteRate += 20;
            }
            if (model.WorkExperience.IsNotNull() || model.WorkSeniority.IsNotNull())
            {
                result.CompleteRate += 20;
            }
            if (model.Weight.HasValue || model.Height.HasValue || model.Photos.IsNotNull())
            {
                result.CompleteRate += 20;
            }
            return result;
        }
 
        /// <summary>
        /// 查询用户简历-求职意向
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<GetUserResumeJobSeekingQueryResult> Handle(GetUserResumeJobSeekingQuery request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .GetDetail<User, GetUserResumeJobSeekingQueryResult>(cancellationToken);
        }
 
        /// <summary>
        /// 查询用户简历-资格证书列表
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<List<GetUserResumeCredentialsQueryResultItem>> Handle(GetUserResumeCredentialsQuery request, CancellationToken cancellationToken)
        {
            return await rep.GetPersonalQueryable(false)
                .SelectMany(it => it.UserCredentials)
                .OrderBy(it => it.CreatedTime)
                .ProjectToType<GetUserResumeCredentialsQueryResultItem>()
                .ToListAsync(cancellationToken);
        }
 
        /// <summary>
        /// 查询用户简历-资格证书
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<GetUserResumeCredentialQueryResult> Handle(GetUserResumeCredentialQuery request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .SelectMany(it => it.UserCredentials)
                .Where(it => it.Id == request.Id)
                .GetDetail<UserCredential, GetUserResumeCredentialQueryResult>(cancellationToken);
        }
 
        /// <summary>
        /// 查询用户简历-工作经验
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<GetUserResumeWorkExperienceQueryResult> Handle(GetUserResumeWorkExperienceQuery request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .GetDetail<User, GetUserResumeWorkExperienceQueryResult>(cancellationToken);
        }
 
        /// <summary>
        /// 查询用户简历-详细信息
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<GetUserResumeDetailQueryResult> Handle(GetUserResumeDetailQuery request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .GetDetail<User, GetUserResumeDetailQueryResult>(cancellationToken);
        }
 
    }
}