From b2379f0a27da604de31869137f892629ce99a1da Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期三, 06 八月 2025 16:58:51 +0800
Subject: [PATCH] feat:字典开发
---
FlexJobApi.User.Application/Menus/Commands/SaveMenuCommandHandler.cs | 132 +++++++++----------------------------------
1 files changed, 29 insertions(+), 103 deletions(-)
diff --git a/FlexJobApi.User.Application/Menus/Commands/SaveMenuCommandHandler.cs b/FlexJobApi.User.Application/Menus/Commands/SaveMenuCommandHandler.cs
index 59550fc..925775d 100644
--- a/FlexJobApi.User.Application/Menus/Commands/SaveMenuCommandHandler.cs
+++ b/FlexJobApi.User.Application/Menus/Commands/SaveMenuCommandHandler.cs
@@ -1,4 +1,5 @@
-锘縰sing FlexJobApi.Core;
+锘縰sing Consul;
+using FlexJobApi.Core;
using Furion.DatabaseAccessor;
using Furion.DataValidation;
using Furion.FriendlyException;
@@ -29,35 +30,29 @@
/// <inheritdoc/>
public async Task<Guid> Handle(SaveMenuCommand request, CancellationToken cancellationToken)
{
- if (request.Id.HasValue)
- {
- var entity = await rep.AsQueryable()
- .Include(it => it.Children)
- .FirstOrDefaultAsync(it => it.Id == request.Id, cancellationToken);
- if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "鑿滃崟");
- if (entity.UserType != request.UserType) throw Oops.Oh(EnumErrorCodeType.s410, "鐢ㄦ埛绫诲瀷");
- if (entity.ClientType != request.ClientType) throw Oops.Oh(EnumErrorCodeType.s410, "瀹㈡埛绔被鍨�");
-
- var path = await GetPathAsync(request.ParentId, request.Code, cancellationToken);
- if (await CheckExist(entity, request.ParentId, request.Code)) throw Oops.Oh(EnumErrorCodeType.s405, "鑿滃崟缂栧彿");
- await UpdateChildrensPath($"{entity.Path}/{entity.Code}", $"{path}/{request.Code}", cancellationToken);
- request.Adapt(entity);
- SaveChildrens(entity, request);
- await rep.UpdateAsync(entity);
-
- return entity.Id;
- }
- else
- {
- var entity = new Menu();
- request.Adapt(entity);
- entity.Path = await GetPathAsync(entity.ParentId, entity.Code, cancellationToken);
- if (await CheckExist(entity, request.ParentId, request.Code)) throw Oops.Oh(EnumErrorCodeType.s405, "鑿滃崟缂栧彿");
- SaveChildrens(entity, request);
- await rep.InsertAsync(entity);
-
- return entity.Id;
- }
+ return await request.SaveData<Menu, SaveMenuCommand>(
+ it =>
+ it.UserType == request.UserType
+ && it.ClientType == request.ClientType
+ && it.ParentId == request.ParentId
+ && it.Code == request.Code
+ && it.Id != request.Id,
+ (entity) =>
+ {
+ entity.Path = DbUtils.GetTreeDataPath<DictionaryData>(request.ParentId, cancellationToken).Result;
+ if (request.Id.HasValue)
+ {
+ if (entity.UserType != request.UserType) throw Oops.Oh(EnumErrorCodeType.s410, "鐢ㄦ埛绫诲瀷");
+ if (entity.ClientType != request.ClientType) throw Oops.Oh(EnumErrorCodeType.s410, "瀹㈡埛绔被鍨�");
+ DbUtils.UpdateTreeDataChildrenPath<DictionaryData>(
+ $"{entity.Path}/{entity.Code}/",
+ $"{entity.Path}/{request.Code}/",
+ cancellationToken).Wait();
+ }
+ request.Adapt(entity);
+ SaveChildrens(entity, request);
+ },
+ cancellationToken);
}
/// <summary>
@@ -72,10 +67,10 @@
var childrenIds = GetRequestChildrenIds(request);
// 鍒犻櫎瀛愮骇
entity.Children = entity.Children
- .Where(it =>
- it.Type == EnumMenuType.Menu
- || it.Type == EnumMenuType.Page
- || it.Type == EnumMenuType.Modal
+ .Where(it =>
+ it.Type == EnumMenuType.Menu
+ || it.Type == EnumMenuType.Page
+ || it.Type == EnumMenuType.Modal
|| childrenIds.Contains(it.Id))
.ToList();
@@ -172,75 +167,6 @@
g.Fields.Where(f => f.Id.HasValue).Select(f => f.Id!.Value)))
.SelectMany(it => it)
.ToList();
- }
-
- /// <summary>
- /// 鏍￠獙鑿滃崟鏄惁閲嶅
- /// </summary>
- /// <param name="entity"></param>
- /// <param name="parentId"></param>
- /// <param name="code"></param>
- /// <returns></returns>
- private async Task<bool> CheckExist(Menu entity, Guid? parentId, string code)
- {
- return await rep.AsQueryable().AsNoTracking()
- .AnyAsync(it =>
- it.UserType == entity.UserType
- && it.ClientType == entity.ClientType
- && it.ParentId == parentId
- && it.Code == code
- && it.Id != entity.Id);
- }
-
- /// <summary>
- /// 鑾峰彇鍦板潃
- /// </summary>
- /// <param name="parentId"></param>
- /// <param name="code"></param>
- /// <param name="cancellationToken"></param>
- /// <returns></returns>
- private async Task<string> GetPathAsync(Guid? parentId, string code, CancellationToken cancellationToken)
- {
- if (parentId.HasValue)
- {
- var parent = await rep.AsQueryable().AsNoTracking()
- .Where(it => it.Id == parentId)
- .Select(it => new
- {
- it.Path,
- it.Code
- })
- .FirstOrDefaultAsync(cancellationToken);
- if (parent == null) throw Oops.Oh(EnumErrorCodeType.s404, "涓婄骇鑿滃崟");
- return $"{parent.Path}{parent.Code}/";
- }
- else
- {
- return "/";
- }
- }
-
- /// <summary>
- /// 鏇存柊涓嬬骇鑿滃崟璺緞
- /// </summary>
- /// <param name="oldPath"></param>
- /// <param name="newPath"></param>
- /// <param name="cancellationToken"></param>
- /// <returns></returns>
- private async Task UpdateChildrensPath(string oldPath, string newPath, CancellationToken cancellationToken)
- {
- var models = await rep.AsQueryable()
- .Where(it => it.Path.StartsWith(oldPath))
- .Where(it => it.Type == EnumMenuType.Menu || it.Type == EnumMenuType.Page || it.Type == EnumMenuType.Modal)
- .ToListAsync(cancellationToken);
- if (models.IsNotNull())
- {
- foreach (var model in models)
- {
- model.Path = model.Path.Replace(oldPath, newPath);
- }
- await rep.UpdateAsync(models);
- }
}
}
}
--
Gitblit v1.9.1