updateRoleLogic.go 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. package role
  2. import (
  3. "context"
  4. "time"
  5. "perms-system-server/internal/consts"
  6. authHelper "perms-system-server/internal/logic/auth"
  7. "perms-system-server/internal/middleware"
  8. "perms-system-server/internal/response"
  9. "perms-system-server/internal/svc"
  10. "perms-system-server/internal/types"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. )
  13. type UpdateRoleLogic struct {
  14. logx.Logger
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. }
  18. func NewUpdateRoleLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateRoleLogic {
  19. return &UpdateRoleLogic{
  20. Logger: logx.WithContext(ctx),
  21. ctx: ctx,
  22. svcCtx: svcCtx,
  23. }
  24. }
  25. // UpdateRole 更新角色。修改角色名称、备注、权限级别和启用/禁用状态。非超管不能降低权限级别。变更后自动清理绑定该角色的用户缓存。
  26. func (l *UpdateRoleLogic) UpdateRole(req *types.UpdateRoleReq) error {
  27. role, err := l.svcCtx.SysRoleModel.FindOne(l.ctx, req.Id)
  28. if err != nil {
  29. return response.ErrNotFound("角色不存在")
  30. }
  31. if err := authHelper.RequireProductAdminFor(l.ctx, role.ProductCode); err != nil {
  32. return err
  33. }
  34. if len(req.Name) > 64 {
  35. return response.ErrBadRequest("角色名长度不能超过64个字符")
  36. }
  37. if len(req.Remark) > 255 {
  38. return response.ErrBadRequest("备注长度不能超过255个字符")
  39. }
  40. if req.PermsLevel < 1 || req.PermsLevel > 999 {
  41. return response.ErrBadRequest("权限级别必须在 1-999 之间")
  42. }
  43. caller := middleware.GetUserDetails(l.ctx)
  44. if caller != nil && !caller.IsSuperAdmin && req.PermsLevel < role.PermsLevel {
  45. return response.ErrForbidden("非超管不能降低角色的权限级别")
  46. }
  47. role.Name = req.Name
  48. role.Remark = req.Remark
  49. role.PermsLevel = req.PermsLevel
  50. if req.Status != 0 {
  51. if req.Status != consts.StatusEnabled && req.Status != consts.StatusDisabled {
  52. return response.ErrBadRequest("状态值无效,仅支持 1(启用) 和 2(禁用)")
  53. }
  54. role.Status = req.Status
  55. }
  56. role.UpdateTime = time.Now().Unix()
  57. if err := l.svcCtx.SysRoleModel.Update(l.ctx, role); err != nil {
  58. return err
  59. }
  60. affectedUserIds, _ := l.svcCtx.SysUserRoleModel.FindUserIdsByRoleId(l.ctx, req.Id)
  61. l.svcCtx.UserDetailsLoader.BatchDel(l.ctx, affectedUserIds, role.ProductCode)
  62. return nil
  63. }