feat:开发

sunpengfei

2025-08-14 e1dd123ce54dfd2bb770ba017917be2e1a78b1b8

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
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
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 UserResumeCommandHandler(
            IRepository<User> rep,
            IRepository<EnterpriseUserCollect> repEnterpriseUserCollect
        ) :
        IRequestHandler<SaveUserResumePersonalCommand, Guid>,
        IRequestHandler<SaveUserResumeJobSeekingCommand, Guid>,
        IRequestHandler<SaveUserResumeCredentialCommand, Guid>,
        IRequestHandler<DeleteUserResumeCredentialCommand, int>,
        IRequestHandler<SaveUserResumeWorkExperienceCommand, Guid>,
        IRequestHandler<SaveUserResumeDetailCommand, Guid>,
        IRequestHandler<CollectUserResumeCommand, Guid>,
        IRequestHandler<ContactUserResumeCommand, Guid>
    {
        private readonly IRepository<User> rep = rep;
        private readonly IRepository<EnterpriseUserCollect> repEnterpriseUserCollect = repEnterpriseUserCollect;
 
        /// <summary>
        /// 保存用户简历-个人信息
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<Guid> Handle(SaveUserResumePersonalCommand request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .UpdateData(request, cancellationToken: cancellationToken);
        }
 
        /// <summary>
        /// 保存用户简历-求职意向
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<Guid> Handle(SaveUserResumeJobSeekingCommand request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .Include(it => it.UserExpectJobs)
                .UpdateData(
                    request,
                    null,
                    cancellationToken: cancellationToken);
        }
 
        /// <summary>
        /// 保存用户简历-资格证书
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<Guid> Handle(SaveUserResumeCredentialCommand request, CancellationToken cancellationToken)
        {
            var logier = JwtUtils.GetCurrentLogier();
            return request.SaveData<UserCredential, SaveUserResumeCredentialCommand>(
                q => rep.GetPersonalQueryable(false).SelectMany(it => it.UserCredentials),
                update: (entity) =>
                {
                    request.Adapt(entity);
                    if (request.Id == null)
                    {
                        entity.UserId = logier.Id;
                    }
                },
                cancellationToken: cancellationToken);
        }
 
        /// <summary>
        /// 删除用户简历-资格证书
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<int> Handle(DeleteUserResumeCredentialCommand request, CancellationToken cancellationToken)
        {
            return request.DeleteData<UserCredential>(
                q => rep.GetPersonalQueryable(false).SelectMany(it => it.UserCredentials),
                cancellationToken);
        }
 
        /// <summary>
        /// 保存用户简历-工作经验
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<Guid> Handle(SaveUserResumeWorkExperienceCommand request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .UpdateData(request, cancellationToken: cancellationToken);
        }
 
        /// <summary>
        /// 保存用户简历-详细信息
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public Task<Guid> Handle(SaveUserResumeDetailCommand request, CancellationToken cancellationToken)
        {
            return rep.GetPersonalQueryable(false)
                .Include(it => it.Photos)
                .UpdateData(request, cancellationToken: cancellationToken);
        }
 
        /// <summary>
        /// 收藏灵工
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<Guid> Handle(CollectUserResumeCommand request, CancellationToken cancellationToken)
        {
            var logier = JwtUtils.GetCurrentLogier();
            if (logier.Type != EnumUserType.Enterprise) throw Oops.Oh(EnumErrorCodeType.s400, "需企业用户方可联系");
            var entity = await repEnterpriseUserCollect.AsQueryable()
                .FirstOrDefaultAsync(it => it.EnterpriseId == logier.EnterpriseId && it.UserId == request.Id);
            if (entity == null)
            {
                entity = new EnterpriseUserCollect
                {
                    EnterpriseId = logier.EnterpriseId!.Value,
                    UserId = request.Id,
                    IsCollected = true,
                    CollectedTime = request.IsCollected
                        ? DateTime.Now
                        : null
                };
                await repEnterpriseUserCollect.InsertAsync(entity);
            }
            else if (entity.IsCollected != request.IsCollected)
            {
                entity.IsCollected = request.IsCollected;
                entity.CollectedTime = request.IsCollected
                        ? DateTime.Now
                        : null;
                await repEnterpriseUserCollect.UpdateAsync(entity);
            }
            return entity.Id;
        }
 
        /// <summary>
        /// 联系灵工
        /// </summary>
        /// <param name="request"></param>
        /// <param name="cancellationToken"></param>
        /// <returns></returns>
        public async Task<Guid> Handle(ContactUserResumeCommand request, CancellationToken cancellationToken)
        {
            var logier = JwtUtils.GetCurrentLogier();
            if (logier.Type != EnumUserType.Enterprise) throw Oops.Oh(EnumErrorCodeType.s400, "需企业用户方可联系");
            var entity = await repEnterpriseUserCollect.AsQueryable()
                .FirstOrDefaultAsync(it => it.EnterpriseId == logier.EnterpriseId && it.UserId == request.Id);
            if (entity == null)
            {
                entity = new EnterpriseUserCollect
                {
                    EnterpriseId = logier.EnterpriseId!.Value,
                    UserId = request.Id,
                    IsContacted = true,
                    ContactedTime = DateTime.Now
                };
                await repEnterpriseUserCollect.InsertAsync(entity);
            }
            else if (entity.IsContacted == false)
            {
                entity.IsContacted = true;
                entity.ContactedTime = DateTime.Now;
                await repEnterpriseUserCollect.UpdateAsync(entity);
            }
            return entity.Id;
        }
    }
}