createRoleLogic.go 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. package role
  2. import (
  3. "context"
  4. "strings"
  5. "time"
  6. "perms-system-server/internal/consts"
  7. authHelper "perms-system-server/internal/logic/auth"
  8. roleModel "perms-system-server/internal/model/role"
  9. "perms-system-server/internal/response"
  10. "perms-system-server/internal/svc"
  11. "perms-system-server/internal/types"
  12. "github.com/zeromicro/go-zero/core/logx"
  13. )
  14. type CreateRoleLogic struct {
  15. logx.Logger
  16. ctx context.Context
  17. svcCtx *svc.ServiceContext
  18. }
  19. func NewCreateRoleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateRoleLogic {
  20. return &CreateRoleLogic{
  21. Logger: logx.WithContext(ctx),
  22. ctx: ctx,
  23. svcCtx: svcCtx,
  24. }
  25. }
  26. // CreateRole 创建角色。在指定产品下新建角色并设置权限级别,需产品 ADMIN 或超管权限。产品必须存在且已启用。
  27. func (l *CreateRoleLogic) CreateRole(req *types.CreateRoleReq) (resp *types.IdResp, err error) {
  28. if err := authHelper.RequireProductAdminFor(l.ctx, req.ProductCode); err != nil {
  29. return nil, err
  30. }
  31. product, err := l.svcCtx.SysProductModel.FindOneByCode(l.ctx, req.ProductCode)
  32. if err != nil {
  33. return nil, response.ErrNotFound("产品不存在")
  34. }
  35. if product.Status != consts.StatusEnabled {
  36. return nil, response.ErrBadRequest("产品已被禁用,无法创建角色")
  37. }
  38. if len(req.Name) > 64 {
  39. return nil, response.ErrBadRequest("角色名长度不能超过64个字符")
  40. }
  41. if len(req.Remark) > 255 {
  42. return nil, response.ErrBadRequest("备注长度不能超过255个字符")
  43. }
  44. if req.PermsLevel < 1 || req.PermsLevel > 999 {
  45. return nil, response.ErrBadRequest("权限级别必须在 1-999 之间")
  46. }
  47. now := time.Now().Unix()
  48. result, err := l.svcCtx.SysRoleModel.Insert(l.ctx, &roleModel.SysRole{
  49. ProductCode: req.ProductCode,
  50. Name: req.Name,
  51. Remark: req.Remark,
  52. Status: consts.StatusEnabled,
  53. PermsLevel: req.PermsLevel,
  54. CreateTime: now,
  55. UpdateTime: now,
  56. })
  57. if err != nil {
  58. if strings.Contains(err.Error(), "1062") || strings.Contains(err.Error(), "Duplicate entry") {
  59. return nil, response.ErrConflict("该产品下角色名已存在")
  60. }
  61. return nil, err
  62. }
  63. id, _ := result.LastInsertId()
  64. return &types.IdResp{Id: id}, nil
  65. }