package role import ( "context" "time" "perms-system-server/internal/consts" authHelper "perms-system-server/internal/logic/auth" "perms-system-server/internal/middleware" roleModel "perms-system-server/internal/model/role" "perms-system-server/internal/response" "perms-system-server/internal/svc" "perms-system-server/internal/types" "perms-system-server/internal/util" "github.com/zeromicro/go-zero/core/logx" ) type CreateRoleLogic struct { logx.Logger ctx context.Context svcCtx *svc.ServiceContext } func NewCreateRoleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateRoleLogic { return &CreateRoleLogic{ Logger: logx.WithContext(ctx), ctx: ctx, svcCtx: svcCtx, } } // CreateRole 创建角色。在指定产品下新建角色并设置权限级别,需产品 ADMIN 或超管权限。产品必须存在且已启用。 func (l *CreateRoleLogic) CreateRole(req *types.CreateRoleReq) (resp *types.IdResp, err error) { if err := authHelper.RequireProductAdminFor(l.ctx, req.ProductCode); err != nil { return nil, err } product, err := l.svcCtx.SysProductModel.FindOneByCode(l.ctx, req.ProductCode) if err != nil { return nil, response.ErrNotFound("产品不存在") } if product.Status != consts.StatusEnabled { return nil, response.ErrBadRequest("产品已被禁用,无法创建角色") } if len(req.Name) > 64 { return nil, response.ErrBadRequest("角色名长度不能超过64个字符") } if len(req.Remark) > 255 { return nil, response.ErrBadRequest("备注长度不能超过255个字符") } if req.PermsLevel < 1 || req.PermsLevel > 999 { return nil, response.ErrBadRequest("权限级别必须在 1-999 之间") } // 审计 H-R17-3:镜像 UpdateRole 的 L-R12-3 防提权("非超管不能提升角色的权限级别"), // 但 CreateRole 的口径比 UpdateRole 更严——UpdateRole 限制的是"已有角色往更高权限挪", // CreateRole 如果不限制,product ADMIN 可以直接造出 permsLevel=1 的顶格角色,再走 BindRoles // 把下属 MEMBER/DEVELOPER 顶到 ADMIN 线(下一次 UD 重建时 MinPermsLevel=1),绕过 BindRoles // 的 GuardRoleLevelAssignable "同级拦截"。GuardCreateRolePermsLevel 把这条短路堵死: // - SuperAdmin 不受限; // - 非超管(含 product ADMIN / DEVELOPER)创建时 permsLevel 必须 >= 2,permsLevel=1 // 作为"顶格语义"只允许 SuperAdmin 所生。 caller := middleware.GetUserDetails(l.ctx) if err := authHelper.GuardCreateRolePermsLevel(l.ctx, l.svcCtx, caller, req.PermsLevel); err != nil { return nil, err } now := time.Now().Unix() result, err := l.svcCtx.SysRoleModel.Insert(l.ctx, &roleModel.SysRole{ ProductCode: req.ProductCode, Name: req.Name, Remark: req.Remark, Status: consts.StatusEnabled, PermsLevel: req.PermsLevel, CreateTime: now, UpdateTime: now, }) if err != nil { if util.IsDuplicateEntryErr(err) { return nil, response.ErrConflict("该产品下角色名已存在") } return nil, err } id, _ := result.LastInsertId() return &types.IdResp{Id: id}, nil }