using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Furion.DataEncryption;
|
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.User.Application
|
{
|
/// <summary>
|
/// 企业命令处理器
|
/// </summary>
|
public class EnterpriseCommandHandler(
|
IRepository<Enterprise> rep,
|
IRepository<UserInfo> repUserInfo
|
)
|
: IRequestHandler<SaveEnterpriseCommand, Guid>
|
{
|
private readonly IRepository<Enterprise> rep = rep;
|
private readonly IRepository<UserInfo> repUserInfo = repUserInfo;
|
|
/// <summary>
|
/// 保存企业
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<Guid> Handle(SaveEnterpriseCommand request, CancellationToken cancellationToken)
|
{
|
var entity = await rep.AsQueryable()
|
.FirstOrDefaultAsync(it => it.SocietyCreditCode == request.SocietyCreditCode);
|
if (entity == null)
|
{
|
entity = new Enterprise();
|
request.Adapt(entity);
|
await rep.InsertAsync(entity);
|
}
|
else
|
{
|
request.Adapt(entity);
|
await rep.UpdateAsync(entity);
|
}
|
|
var userInfo = await repUserInfo.AsQueryable()
|
.Include(it => it.UserAuth)
|
.FirstOrDefaultAsync(it =>
|
it.Type == EnumUserType.Enterprise
|
&& it.UserAuth.UserName == request.UserName);
|
if (userInfo == null)
|
{
|
userInfo = new UserInfo
|
{
|
EnterpriseId = entity.Id,
|
Type = EnumUserType.Enterprise,
|
Status = EnumUserInfoStatus.Normal,
|
UserAuth = new UserAuth
|
{
|
UserName = request.UserName,
|
PhoneNumber = request.ContactPhoneNumber,
|
Password = PBKDF2Encryption.Encrypt(request.Password)
|
}
|
};
|
await repUserInfo.InsertAsync(userInfo);
|
}
|
else
|
{
|
if (userInfo.EnterpriseId != entity.Id) throw Oops.Oh(EnumErrorCodeType.s405, "该账号");
|
userInfo.UserAuth.PhoneNumber = request.ContactPhoneNumber;
|
await repUserInfo.UpdateAsync(userInfo);
|
}
|
|
return entity.Id;
|
}
|
}
|
}
|
