using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Mapster;
|
using MediatR;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.Application
|
{
|
/// <summary>
|
/// 数据字典命令处理器
|
/// </summary>
|
public class DictionaryDataCommandHandler :
|
IRequestHandler<SaveDictionaryDataCommand, Guid>,
|
IRequestHandler<SetDictionaryDataIsDisabledCommand, int>
|
|
{
|
/// <summary>
|
/// 保存数据字典
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public Task<Guid> Handle(SaveDictionaryDataCommand request, CancellationToken cancellationToken)
|
{
|
return request.SaveData<DictionaryData, SaveDictionaryDataCommand>(
|
null,
|
it =>
|
it.CategoryId == request.CategoryId
|
&& it.ParentId == request.ParentId
|
&& it.Code == request.Code
|
&& it.Content == request.Content
|
&& it.Id != request.Id,
|
(entity) =>
|
{
|
entity.Path = DbUtils.GetTreeDataPath<DictionaryData>(request.ParentId, cancellationToken).Result;
|
if (request.Id.HasValue)
|
{
|
DbUtils.UpdateTreeDataChildrenPath<DictionaryData>(
|
$"{entity.Path}/{entity.Code}/",
|
$"{entity.Path}/{request.Code}/",
|
cancellationToken).Wait();
|
}
|
request.Adapt(entity);
|
},
|
cancellationToken);
|
}
|
|
/// <summary>
|
/// 设置数据字典是否禁用
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public Task<int> Handle(SetDictionaryDataIsDisabledCommand request, CancellationToken cancellationToken)
|
{
|
return request.SetIsDisabled<DictionaryData>(cancellationToken: cancellationToken);
|
}
|
}
|
}
|