yanpeng200212
a8890c81e9
质量模块： - 11 张工艺执行书表：封面、试产、选剥茧（含混茧明细）、试缫与大样、煮茧（含分车间配温、副煮车间）、自动缫（含大样）、后缫 - 10 张样茧试缫表：原料小样/综合样主表 + 选茧、解舒、茧幅、切剖、清洁洁净、茧丝百回纤度 - 服务与接口、主控指针回写（列表 √ 标记）、封面编号自增、报表数据包 - 前端 8 张报表打印版式、7 类工艺单据与 6 类调查录入弹窗、字段驱动表单/表格组件 - 菜单种子新增「质量」目录，样茧子表增加 YjssType 判别列，避免原料小样与综合样自增 Id 重号串数据 报表中心： - 报表模板管理、锐浪 grhtml5 加载与预览、全屏设计面板、数据源 Provider（落丝记录、职工花名册） 其他：同步工作进度 1-11 文档、开发数据库快照、.gitignore 忽略运行日志目录
92 lines
4.2 KiB
C#
92 lines
4.2 KiB
C#
using F9WebAiTest.Application.Common.Exceptions;
|
|
using F9WebAiTest.Application.Interfaces.SnowflakeID;
|
|
using F9WebAiTest.Application.Interfaces.UOW;
|
|
using F9WebAiTest.Domain.Common;
|
|
using F9WebAiTest.Domain.Entities.SYS.RBAC;
|
|
using F9WebAiTest.Domain.Enums.SYS.RBAC;
|
|
using NotificationTypeEntity = F9WebAiTest.Domain.Entities.Notice.NotificationType;
|
|
using MenuEntity = F9WebAiTest.Domain.Entities.SYS.RBAC.Menu;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.RBAC.Permissions;
|
|
using F9WebAiTest.Domain.Interfaces.SYS.RBAC.Roles;
|
|
using MediatR;
|
|
|
|
namespace F9WebAiTest.Application.CQRS.SYS.RBAC.Roles.Commands;
|
|
|
|
/// <summary>命令定义</summary>
|
|
public record RolePermission_AssignCommand(long RoleId, Permission_Type_Enum PermissionType, Resource_Type_Enum ResourceType, string ResourceIdentity, long ResourceId) : IRequest<long>;
|
|
|
|
/// <summary>命令处理器</summary>
|
|
public class AssignRolePermissionCommandHandler(
|
|
IRoleWriteRepository roleRepository,
|
|
IUnitOfWork_F9 unitOfWork,
|
|
IRolePermissionWriteRepository rolePermissionRep,
|
|
IPermissionWriteRepository permissionWriteRepository,
|
|
IRepository<NotificationTypeEntity> notificationTypeRepository,
|
|
IRepository<MenuEntity> menuRepository,
|
|
ISnowflakeIdGenerator snowflakeIdGenerator,
|
|
IPublisher eventBus) : IRequestHandler<RolePermission_AssignCommand, long>
|
|
{
|
|
public async Task<long> Handle(RolePermission_AssignCommand command, CancellationToken cancellationToken)
|
|
{
|
|
if (command.RoleId <= 0) throw new F9OperationException("角色ID不能为空");
|
|
if (command.ResourceId <= 0) throw new F9OperationException("资源ID不能为空");
|
|
if (string.IsNullOrWhiteSpace(command.ResourceIdentity)) throw new F9OperationException("资源标识不能为空");
|
|
|
|
Role role = null;
|
|
long rolePermissionId = 0;
|
|
|
|
var ok = await unitOfWork.ExecuteWithUow(async () =>
|
|
{
|
|
// 查或创建权限
|
|
var dbPermission = await permissionWriteRepository.GetByIdAsync(command.PermissionType, command.ResourceType, command.ResourceId);
|
|
if (dbPermission == null)
|
|
{
|
|
dbPermission = new Permission(
|
|
snowflakeIdGenerator.CreateId(),
|
|
command.PermissionType,
|
|
command.ResourceType,
|
|
command.ResourceIdentity,
|
|
command.ResourceId);
|
|
|
|
// 菜单/操作权限：Code 对齐菜单上声明的权限标识（如 sys:user:add），
|
|
// 否则 v-permission 之类按业务权限码判断的地方永远匹配不上
|
|
if (command.ResourceType is Resource_Type_Enum.菜单 or Resource_Type_Enum.操作)
|
|
{
|
|
var menu = await menuRepository.GetByIdAsync(command.ResourceId);
|
|
if (menu != null && !string.IsNullOrEmpty(menu.Permission))
|
|
dbPermission.SetCode(menu.Permission);
|
|
}
|
|
|
|
// 消息订阅权限：Code 对齐消息类型的 RequiredPermission（业务权限码），保证订阅校验一致
|
|
if (command.ResourceType == Resource_Type_Enum.消息订阅)
|
|
{
|
|
var type = await notificationTypeRepository.GetByIdAsync(command.ResourceId);
|
|
if (type != null && !string.IsNullOrEmpty(type.RequiredPermission))
|
|
dbPermission.SetCode(type.RequiredPermission);
|
|
}
|
|
|
|
await permissionWriteRepository.AddRangeAsync(new[] { dbPermission });
|
|
}
|
|
|
|
// 绑定角色权限
|
|
var rolePermission = new RolePermission(snowflakeIdGenerator.CreateId(), command.RoleId, dbPermission.Id);
|
|
var result = await rolePermissionRep.AssignAsync(rolePermission);
|
|
|
|
role = await roleRepository.GetByIdAsync(command.RoleId);
|
|
role.AddPermission(dbPermission.Id, command.ResourceType);
|
|
|
|
rolePermissionId = rolePermission.Id;
|
|
return result;
|
|
});
|
|
|
|
if (!ok) throw new F9OperationException("权限", "绑定");
|
|
|
|
// 发布领域事件
|
|
foreach (var domainEvent in role.DomainEvents)
|
|
await eventBus.Publish(domainEvent, cancellationToken);
|
|
role.ClearDomainEvents();
|
|
|
|
return rolePermissionId;
|
|
}
|
|
}
|