system_service.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656
  1. package backend
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "kpt-pasture/model"
  7. "kpt-pasture/util"
  8. "net/http"
  9. "time"
  10. "gitee.com/xuyiping_admin/pkg/logger/zaplog"
  11. "go.uber.org/zap"
  12. pasturePb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/cow"
  13. operationPb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/operation"
  14. "gitee.com/xuyiping_admin/pkg/jwt"
  15. "gitee.com/xuyiping_admin/pkg/xerr"
  16. "gorm.io/gorm"
  17. )
  18. const CurrentUserName = "userName"
  19. // Login 用户登录
  20. func (s *StoreEntry) Login(ctx context.Context, req *pasturePb.SearchUserRequest) (*pasturePb.SystemUserResponse, error) {
  21. systemUser := &model.SystemUser{}
  22. if err := s.DB.Where("name = ?", req.Name).
  23. Where("is_delete = ?", pasturePb.IsShow_Ok).
  24. Where("is_show = ?", pasturePb.IsShow_Ok).
  25. Find(systemUser).Error; err != nil {
  26. return nil, xerr.WithStack(err)
  27. }
  28. if systemUser.Password != req.Password {
  29. return nil, xerr.Customf("密码错误,来自用户:%s", req.Name)
  30. }
  31. if systemUser.IsShow == pasturePb.IsShow_No {
  32. return nil, xerr.Customf("该账号已被禁用,请联系管理员")
  33. }
  34. systemRole := &model.SystemRole{Id: systemUser.RoleId}
  35. if err := s.DB.Where("is_show = ? and is_delete = ?", pasturePb.IsShow_Ok, pasturePb.IsShow_Ok).
  36. First(systemRole).Error; err != nil {
  37. zaplog.Error("Login", zap.Any("systemRole", err))
  38. }
  39. jwtToken := jwt.NewJWTTokenGen(s.Cfg.AppName, s.Cfg.JwtTokenKeyConfig.PrivateKey)
  40. token, err := jwtToken.GenerateToken(systemUser.Name, s.Cfg.JwtExpireTime)
  41. if err != nil {
  42. return nil, xerr.WithStack(err)
  43. }
  44. if token == "" {
  45. return nil, xerr.Custom("获取token错误")
  46. }
  47. expires := time.Now().Add(time.Duration(s.Cfg.JwtExpireTime) * time.Second).Format(util.LayoutTime)
  48. return &pasturePb.SystemUserResponse{
  49. Code: http.StatusOK,
  50. Message: "ok",
  51. Data: &pasturePb.SystemUserData{
  52. AccessToken: token,
  53. Expires: expires,
  54. RefreshToken: token,
  55. Username: systemUser.Name,
  56. Roles: []string{systemRole.Name},
  57. Avatar: systemUser.Avatar,
  58. },
  59. }, nil
  60. }
  61. // SearchSystemUserList 查询系统用户
  62. func (s *StoreEntry) SearchSystemUserList(ctx context.Context, req *pasturePb.SearchUserRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchUserResponse, error) {
  63. systemUserList := make([]*model.SystemUser, 0)
  64. var count int64 = 0
  65. pref := s.DB.Model(new(model.SystemUser)).Where("is_delete = ?", operationPb.IsShow_OK)
  66. if req.Name != "" {
  67. pref.Where("name like ?", fmt.Sprintf("%s%s%s", "%", req.Name, "%"))
  68. }
  69. if req.Mobile != "" {
  70. pref.Where("mobile = ?", req.Mobile)
  71. }
  72. if req.DeptId > 0 {
  73. pref.Where("dept_id = ?", req.DeptId)
  74. }
  75. if req.IsShow > 0 {
  76. pref.Where("is_show = ?", req.IsShow)
  77. }
  78. if err := pref.Order("id desc").Count(&count).Limit(int(pagination.PageSize)).Offset(int(pagination.PageOffset)).
  79. Find(&systemUserList).Debug().Error; err != nil {
  80. return nil, xerr.WithStack(err)
  81. }
  82. roleList, err := s.SearchSystemRoleListByIds(ctx, []int64{})
  83. if err != nil {
  84. return nil, xerr.WithStack(err)
  85. }
  86. deptList, err := s.SearchSystemDeptListByIds(ctx, []int64{})
  87. if err != nil {
  88. return nil, xerr.WithStack(err)
  89. }
  90. return &pasturePb.SearchUserResponse{
  91. Code: http.StatusOK,
  92. Message: "ok",
  93. Data: &pasturePb.SearchUserData{
  94. List: model.SystemUserSlice(systemUserList).ToPB(deptList, roleList),
  95. Total: int32(count),
  96. PageSize: pagination.PageSize,
  97. Page: pagination.Page,
  98. },
  99. }, nil
  100. }
  101. // DeleteSystemUser 删除系统用户
  102. func (s *StoreEntry) DeleteSystemUser(ctx context.Context, userId int64) error {
  103. systemUser := &model.SystemUser{
  104. Id: userId,
  105. }
  106. if err := s.DB.First(systemUser).Error; err != nil {
  107. if errors.Is(err, gorm.ErrRecordNotFound) {
  108. return xerr.Custom("该用户不存在")
  109. }
  110. return xerr.WithStack(err)
  111. }
  112. if err := s.DB.Model(systemUser).Update("is_delete", operationPb.IsShow_NO).Error; err != nil {
  113. return xerr.WithStack(err)
  114. }
  115. return nil
  116. }
  117. // IsShowSystemUser 用户是否启用
  118. func (s *StoreEntry) IsShowSystemUser(ctx context.Context, userId int64) error {
  119. systemUser := &model.SystemUser{
  120. Id: userId,
  121. }
  122. if err := s.DB.First(systemUser).Error; err != nil {
  123. if errors.Is(err, gorm.ErrRecordNotFound) {
  124. return xerr.Custom("该用户不存在")
  125. }
  126. return xerr.WithStack(err)
  127. }
  128. isShow := pasturePb.IsShow_No
  129. if systemUser.IsShow == pasturePb.IsShow_No {
  130. isShow = pasturePb.IsShow_Ok
  131. }
  132. if err := s.DB.Model(systemUser).Update("is_show", isShow).Error; err != nil {
  133. return xerr.WithStack(err)
  134. }
  135. return nil
  136. }
  137. // SystemUserCreateOrUpdate 创建或者更新系统用户
  138. func (s *StoreEntry) SystemUserCreateOrUpdate(ctx context.Context, req *pasturePb.SearchUserRequest) error {
  139. systemUser := &model.SystemUser{}
  140. if req.Id > 0 {
  141. systemUser.Id = int64(req.Id)
  142. if err := s.DB.First(systemUser).Error; err != nil {
  143. return xerr.WithStack(err)
  144. }
  145. req.Password = systemUser.Password
  146. } else {
  147. if err := s.DB.Where("name = ?", req.Name).First(systemUser).Error; err != nil {
  148. if !errors.Is(err, gorm.ErrRecordNotFound) {
  149. return xerr.WithStack(err)
  150. }
  151. } else if systemUser.Id > 0 {
  152. return xerr.Custom("该用户名称已经存在")
  153. }
  154. }
  155. if err := s.DB.Model(&model.SystemUser{}).Where(map[string]interface{}{
  156. "id": req.Id,
  157. }).Assign(map[string]interface{}{
  158. "name": req.Name,
  159. "nick_name": req.NickName,
  160. "mobile": req.Mobile,
  161. "gender": req.Gender,
  162. "password": req.Password,
  163. "dept_id": req.DeptId,
  164. "remarks": req.Remarks,
  165. "is_delete": operationPb.IsShow_OK,
  166. "is_show": req.IsShow,
  167. }).FirstOrCreate(&model.SystemUser{}).Error; err != nil {
  168. return xerr.WithStack(err)
  169. }
  170. return nil
  171. }
  172. // ResetPasswordSystemUser 重置系统用户密码
  173. func (s *StoreEntry) ResetPasswordSystemUser(ctx context.Context, req *pasturePb.ResetUserPasswordRequest) error {
  174. systemUser := &model.SystemUser{
  175. Id: int64(req.Id),
  176. }
  177. if err := s.DB.First(systemUser).Error; err != nil {
  178. if errors.Is(err, gorm.ErrRecordNotFound) {
  179. return xerr.Custom("该用户不存在")
  180. }
  181. return xerr.WithStack(err)
  182. }
  183. if err := s.DB.Model(systemUser).Update("password", req.Password).Error; err != nil {
  184. return xerr.WithStack(err)
  185. }
  186. return nil
  187. }
  188. func (s *StoreEntry) SystemUserRole(ctx context.Context, userId int64) (*pasturePb.SystemUserRoleResponse, error) {
  189. systemUser := &model.SystemUser{Id: userId}
  190. if err := s.DB.First(systemUser).Error; err != nil {
  191. if errors.Is(err, gorm.ErrRecordNotFound) {
  192. return nil, xerr.Custom("该用户不存在")
  193. }
  194. return nil, xerr.WithStack(err)
  195. }
  196. return &pasturePb.SystemUserRoleResponse{
  197. Code: http.StatusOK,
  198. Message: "ok",
  199. Data: int32(systemUser.RoleId),
  200. }, nil
  201. }
  202. func (s *StoreEntry) SystemUserRoleSave(ctx context.Context, req *pasturePb.SystemUserRoleRequest) error {
  203. systemUser := &model.SystemUser{Id: int64(req.UserId)}
  204. if err := s.DB.First(systemUser).Error; err != nil {
  205. if errors.Is(err, gorm.ErrRecordNotFound) {
  206. return xerr.Custom("该用户不存在")
  207. }
  208. return xerr.WithStack(err)
  209. }
  210. systemRole := &model.SystemRole{Id: int64(req.RoleId)}
  211. if err := s.DB.First(systemRole).Error; err != nil {
  212. if errors.Is(err, gorm.ErrRecordNotFound) {
  213. return xerr.Custom("该角色不存在")
  214. }
  215. return xerr.WithStack(err)
  216. }
  217. if err := s.DB.Model(systemUser).Update("role_id", systemRole.Id).Error; err != nil {
  218. return xerr.WithStack(err)
  219. }
  220. return nil
  221. }
  222. // GetCurrentUserName 获取当前用户名
  223. func (s *StoreEntry) GetCurrentUserName(ctx context.Context) (string, error) {
  224. userNameInter := ctx.Value(CurrentUserName)
  225. if userNameInter == nil {
  226. return "", xerr.Customf("cannot userName")
  227. }
  228. if userName, ok := userNameInter.(string); ok {
  229. return userName, nil
  230. } else {
  231. return "", xerr.Customf("waring userName")
  232. }
  233. }
  234. // GetSystemUserMenu 返回系统用户相关菜单权限
  235. func (s *StoreEntry) GetSystemUserMenu(ctx context.Context) (*pasturePb.SystemUserMenuTreeResponse, error) {
  236. // 解析token
  237. userName, err := s.GetCurrentUserName(ctx)
  238. if err != nil {
  239. return nil, xerr.WithStack(err)
  240. }
  241. // 根据用户token获取用户数据
  242. systemUser := &model.SystemUser{Name: userName}
  243. if err = s.DB.Where("name = ?", userName).
  244. Where("is_show = ? and is_delete = ?", pasturePb.IsShow_Ok, pasturePb.IsShow_Ok).
  245. First(systemUser).Error; err != nil {
  246. if errors.Is(err, gorm.ErrRecordNotFound) {
  247. return nil, xerr.Custom("该用户数据不存在")
  248. }
  249. return nil, xerr.WithStack(err)
  250. }
  251. if systemUser.RoleId <= 0 {
  252. return nil, xerr.Custom("该用户没有角色")
  253. }
  254. // 获取用户角色数据
  255. systemRole := &model.SystemRole{}
  256. if err = s.DB.Where("id = ?", systemUser.RoleId).First(systemRole).Error; err != nil {
  257. if errors.Is(err, gorm.ErrRecordNotFound) {
  258. return nil, xerr.Custom("该用户角色不存在")
  259. }
  260. return nil, xerr.WithStack(err)
  261. }
  262. // 获取用户菜单
  263. systemMenuList := make([]*model.SystemMenu, 0)
  264. if err = s.DB.Table(fmt.Sprintf("%s as a", new(model.SystemRoleMenu).TableName())).
  265. Select("b.*").
  266. Joins("LEFT JOIN system_menu AS b ON a.menu_id = b.id").
  267. Where("a.role_id = ? and b.is_delete = ?", systemRole.Id, pasturePb.IsShow_Ok).
  268. Find(&systemMenuList).Error; err != nil {
  269. return nil, xerr.WithStack(err)
  270. }
  271. // 获取菜单权限
  272. return &pasturePb.SystemUserMenuTreeResponse{
  273. Code: http.StatusOK,
  274. Message: "ok",
  275. Data: model.SystemMenuSlice(systemMenuList).ToTree(),
  276. }, nil
  277. }
  278. // SystemRoleCreateOrUpdate 添加角色
  279. func (s *StoreEntry) SystemRoleCreateOrUpdate(ctx context.Context, req *pasturePb.SearchRoleRequest) error {
  280. isShow := pasturePb.IsShow_Ok
  281. if req.Id > 0 {
  282. isShow = req.IsShow
  283. }
  284. if err := s.DB.Model(&model.SystemRole{}).Where(map[string]interface{}{
  285. "id": req.Id,
  286. }).Assign(map[string]interface{}{
  287. "name": req.Name,
  288. "remarks": req.Remarks,
  289. "is_delete": operationPb.IsShow_OK,
  290. "is_show": isShow,
  291. }).FirstOrCreate(&model.SystemRole{}).Error; err != nil {
  292. return xerr.WithStack(err)
  293. }
  294. return nil
  295. }
  296. // DeleteSystemRole 删除系统角色
  297. func (s *StoreEntry) DeleteSystemRole(ctx context.Context, roleId int64) error {
  298. systemRole := &model.SystemRole{
  299. Id: roleId,
  300. }
  301. if err := s.DB.First(systemRole).Error; err != nil {
  302. if errors.Is(err, gorm.ErrRecordNotFound) {
  303. return xerr.Custom("该数据不存在")
  304. }
  305. return xerr.WithStack(err)
  306. }
  307. if err := s.DB.Model(systemRole).Update("is_delete", pasturePb.IsShow_No).Error; err != nil {
  308. return xerr.WithStack(err)
  309. }
  310. return nil
  311. }
  312. // IsShowSystemRole 角色是否启用
  313. func (s *StoreEntry) IsShowSystemRole(ctx context.Context, roleId int64) error {
  314. systemRole := &model.SystemRole{
  315. Id: roleId,
  316. }
  317. if err := s.DB.First(systemRole).Error; err != nil {
  318. if errors.Is(err, gorm.ErrRecordNotFound) {
  319. return xerr.Custom("该角色不存在")
  320. }
  321. return xerr.WithStack(err)
  322. }
  323. isShow := pasturePb.IsShow_No
  324. if systemRole.IsShow == pasturePb.IsShow_No {
  325. isShow = pasturePb.IsShow_Ok
  326. }
  327. if err := s.DB.Model(systemRole).Update("is_show", isShow).Error; err != nil {
  328. return xerr.WithStack(err)
  329. }
  330. return nil
  331. }
  332. // SearchSystemRoleList 查询系统角色
  333. func (s *StoreEntry) SearchSystemRoleList(ctx context.Context, req *pasturePb.SearchRoleRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchRoleResponse, error) {
  334. systemRoleList := make([]*model.SystemRole, 0)
  335. var count int64 = 0
  336. pref := s.DB.Model(new(model.SystemRole)).Where("is_delete = ?", operationPb.IsShow_OK)
  337. if req.Name != "" {
  338. pref.Where("name like ?", fmt.Sprintf("%s%s%s", "%", req.Name, "%"))
  339. }
  340. if req.IsShow > 0 {
  341. pref.Where("is_show = ?", req.IsShow)
  342. }
  343. if err := pref.Order("id desc").Count(&count).Limit(int(pagination.PageSize)).
  344. Offset(int(pagination.PageOffset)).Find(&systemRoleList).Error; err != nil {
  345. return nil, xerr.WithStack(err)
  346. }
  347. return &pasturePb.SearchRoleResponse{
  348. Code: http.StatusOK,
  349. Message: "ok",
  350. Data: &pasturePb.SearchRoleData{
  351. Page: pagination.Page,
  352. Total: int32(count),
  353. PageSize: pagination.PageSize,
  354. List: model.SystemRoleSlice(systemRoleList).ToPB(),
  355. },
  356. }, nil
  357. }
  358. // SearchSystemRoleListByIds 根据id查询角色列表
  359. func (s *StoreEntry) SearchSystemRoleListByIds(ctx context.Context, ids []int64) ([]*model.SystemRole, error) {
  360. systemRoleList := make([]*model.SystemRole, 0)
  361. if err := s.DB.Model(new(model.SystemRole)).
  362. Where("is_show = ?", operationPb.IsShow_OK).
  363. Find(&systemRoleList, ids).Error; err != nil {
  364. return nil, xerr.WithStack(err)
  365. }
  366. return systemRoleList, nil
  367. }
  368. // GetRoleMenuList 查询系统角色对应的菜单数据
  369. func (s *StoreEntry) GetRoleMenuList(ctx context.Context, roleId int64) (*pasturePb.SystemRoleMenuResponse, error) {
  370. systemRole := &model.SystemRole{
  371. Id: roleId,
  372. }
  373. if err := s.DB.First(systemRole).Error; err != nil {
  374. if errors.Is(err, gorm.ErrRecordNotFound) {
  375. return nil, xerr.Custom("该数据不存在")
  376. }
  377. return nil, xerr.WithStack(err)
  378. }
  379. if systemRole.IsDelete == pasturePb.IsShow_No {
  380. return nil, xerr.Custom("该数据已被删除")
  381. }
  382. menuList := make([]*model.SystemRoleMenu, 0)
  383. if err := s.DB.Where("role_id = ?", systemRole.Id).Find(&menuList).Error; err != nil {
  384. zaplog.Error("GetSystemRoleMenuList", zap.Any("Err", err))
  385. }
  386. return &pasturePb.SystemRoleMenuResponse{
  387. Code: http.StatusOK,
  388. Message: "ok",
  389. Data: model.SystemRoleMenuSlice(menuList).ToPB(),
  390. }, nil
  391. }
  392. // RoleMenuSave 保存系统角色对应的菜单数据
  393. func (s *StoreEntry) RoleMenuSave(ctx context.Context, res *pasturePb.SystemRoleMenuRequest) error {
  394. if len(res.MenuIds) <= 0 {
  395. return xerr.Custom("请选择菜单")
  396. }
  397. systemRole := &model.SystemRole{
  398. Id: int64(res.RoleId),
  399. }
  400. if err := s.DB.First(systemRole).Error; err != nil {
  401. if errors.Is(err, gorm.ErrRecordNotFound) {
  402. return xerr.Custom("该数据不存在")
  403. }
  404. return xerr.WithStack(err)
  405. }
  406. if err := s.DB.Transaction(func(tx *gorm.DB) error {
  407. if err := tx.Model(new(model.SystemRoleMenu)).Where("role_id = ?", systemRole.Id).Delete(&model.SystemRoleMenu{}).Error; err != nil {
  408. return xerr.WithStack(err)
  409. }
  410. for _, menuId := range res.MenuIds {
  411. if err := tx.Create(&model.SystemRoleMenu{
  412. RoleId: systemRole.Id,
  413. MenuId: int64(menuId),
  414. }).Error; err != nil {
  415. return xerr.WithStack(err)
  416. }
  417. }
  418. return nil
  419. }); err != nil {
  420. return xerr.WithStack(err)
  421. }
  422. return nil
  423. }
  424. func (s *StoreEntry) SystemRoleList(ctx context.Context) (*pasturePb.GetRoleListResponse, error) {
  425. systemRoleList := make([]*model.SystemRole, 0)
  426. if err := s.DB.Model(new(model.SystemRole)).
  427. Where("is_delete = ? and is_show = ?", pasturePb.IsShow_Ok, pasturePb.IsShow_Ok).
  428. Find(&systemRoleList).Error; err != nil {
  429. return nil, xerr.WithStack(err)
  430. }
  431. return &pasturePb.GetRoleListResponse{
  432. Code: http.StatusOK,
  433. Message: "ok",
  434. Data: model.SystemRoleSlice(systemRoleList).ToPB(),
  435. }, nil
  436. }
  437. // CreateOrUpdateSystemMenu 添加或者更新系统菜单权限
  438. func (s *StoreEntry) CreateOrUpdateSystemMenu(ctx context.Context, req *pasturePb.SearchMenuRequest) error {
  439. if req.Id > 0 {
  440. systemMenu := &model.SystemMenu{Id: int64(req.Id)}
  441. if err := s.DB.Model(&model.SystemMenu{}).First(systemMenu).Error; err != nil {
  442. if !errors.Is(err, gorm.ErrRecordNotFound) {
  443. return xerr.WithStack(err)
  444. }
  445. }
  446. }
  447. if err := s.DB.Model(&model.SystemMenu{}).Where(map[string]interface{}{
  448. "id": req.Id,
  449. }).Assign(map[string]interface{}{
  450. "name": req.Name,
  451. "path": req.Path,
  452. "title": req.Title,
  453. "menu_type": req.MenuType,
  454. "parent_id": req.ParentId,
  455. "frame_src": req.FrameSrc,
  456. "frame_loading": model.BooleanToIsShow(req.FrameLoading),
  457. "keepalive": model.BooleanToIsShow(req.Keepalive),
  458. "hidden_tag": model.BooleanToIsShow(req.HiddenTag),
  459. "show_link": model.BooleanToIsShow(req.ShowLink),
  460. "show_parent": model.BooleanToIsShow(req.ShowParent),
  461. "icon": req.Icon,
  462. "component": req.Component,
  463. "redirect": req.Redirect,
  464. "auths": req.Auths,
  465. "rank": req.Rank,
  466. "extra_icon": req.ExtraIcon,
  467. "enter_transition": req.EnterTransition,
  468. "leave_transition": req.LeaveTransition,
  469. "active_path": req.ActivePath,
  470. "is_delete": pasturePb.IsShow_Ok,
  471. "is_show": pasturePb.IsShow_Ok,
  472. }).FirstOrCreate(&model.SystemMenu{}).Error; err != nil {
  473. return xerr.WithStack(err)
  474. }
  475. return nil
  476. }
  477. func (s *StoreEntry) SystemMenuTree(ctx context.Context) (*pasturePb.SystemMenuTreeResponse, error) {
  478. systemMenuList := make([]*model.SystemMenu, 0)
  479. if err := s.DB.Model(new(model.SystemMenu)).Where("is_delete = ?", pasturePb.IsShow_Ok).
  480. Where("is_show = ?", pasturePb.IsShow_Ok).Find(&systemMenuList).Error; err != nil {
  481. return nil, xerr.WithStack(err)
  482. }
  483. return &pasturePb.SystemMenuTreeResponse{
  484. Code: http.StatusOK,
  485. Message: "ok",
  486. Data: model.SystemMenuSlice(systemMenuList).ToPB(),
  487. }, nil
  488. }
  489. // SearchSystemMenuList 菜单列表查询
  490. func (s *StoreEntry) SearchSystemMenuList(ctx context.Context, req *pasturePb.SearchMenuRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchMenuResponse, error) {
  491. systemMenuList := make([]*model.SystemMenu, 0)
  492. var count int64 = 0
  493. if err := s.DB.Model(new(model.SystemMenu)).
  494. Where("is_delete = ? ", operationPb.IsShow_OK).
  495. Order("parent_id").Count(&count).
  496. Find(&systemMenuList).Error; err != nil {
  497. return nil, xerr.WithStack(err)
  498. }
  499. return &pasturePb.SearchMenuResponse{
  500. Code: http.StatusOK,
  501. Message: "ok",
  502. Data: &pasturePb.SearchMenuData{
  503. Page: pagination.Page,
  504. Total: int32(count),
  505. PageSize: pagination.PageSize,
  506. List: model.SystemMenuSlice(systemMenuList).ToPB(),
  507. },
  508. }, nil
  509. }
  510. // DeleteSystemMenu 删除系统菜单
  511. func (s *StoreEntry) DeleteSystemMenu(ctx context.Context, menuId int64) error {
  512. systemMenu := &model.SystemMenu{Id: menuId}
  513. if err := s.DB.First(systemMenu).Error; err != nil {
  514. if errors.Is(err, gorm.ErrRecordNotFound) {
  515. return xerr.Custom("该数据不存在")
  516. }
  517. return xerr.WithStack(err)
  518. }
  519. if err := s.DB.Model(systemMenu).Update("is_delete", pasturePb.IsShow_No).Error; err != nil {
  520. return xerr.WithStack(err)
  521. }
  522. return nil
  523. }
  524. func (s *StoreEntry) SearchSystemDeptList(ctx context.Context, req *pasturePb.SearchDeptRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDeptResponse, error) {
  525. deptList := make([]*model.SystemDept, 0)
  526. var count int64 = 0
  527. pref := s.DB.Model(new(model.SystemDept)).Where("is_delete = ?", operationPb.IsShow_OK)
  528. if req.Name != "" {
  529. pref.Where("name like ?", fmt.Sprintf("%s%s%s", "%", req.Name, "%"))
  530. }
  531. if req.IsShow > 0 {
  532. pref.Where("is_show = ?", req.IsShow)
  533. }
  534. if err := pref.Order("sort desc").Count(&count).Limit(int(pagination.PageSize)).Offset(int(pagination.PageOffset)).
  535. Find(&deptList).Error; err != nil {
  536. return nil, xerr.WithStack(err)
  537. }
  538. return &pasturePb.SearchDeptResponse{
  539. Code: http.StatusOK,
  540. Message: "ok",
  541. Data: model.SystemDeptSlice(deptList).ToPB(),
  542. }, nil
  543. }
  544. func (s *StoreEntry) SystemDepDelete(ctx context.Context, id int64) error {
  545. dept := &model.SystemDept{Id: id}
  546. if err := s.DB.First(dept).Error; err != nil {
  547. return xerr.WithStack(err)
  548. }
  549. if dept.IsShow == pasturePb.IsShow_No {
  550. return nil
  551. }
  552. if err := s.DB.Model(dept).Update("is_delete", operationPb.IsShow_NO).Error; err != nil {
  553. return xerr.WithStack(err)
  554. }
  555. return nil
  556. }
  557. func (s *StoreEntry) SystemDeptCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDeptRequest) error {
  558. if err := s.DB.Model(&model.SystemDept{}).Where(map[string]interface{}{
  559. "id": req.Id,
  560. }).Assign(map[string]interface{}{
  561. "name": req.Name,
  562. "sort": req.Sort,
  563. "parent_id": req.ParentId,
  564. "remarks": req.Remarks,
  565. "is_delete": operationPb.IsShow_OK,
  566. "is_show": req.IsShow,
  567. "dept_type": pasturePb.Depth_Department,
  568. "leader_id": req.LeaderId,
  569. }).FirstOrCreate(&model.SystemDept{}).Error; err != nil {
  570. return xerr.WithStack(err)
  571. }
  572. return nil
  573. }
  574. // SearchSystemDeptListByIds 根据id查询部门列表
  575. func (s *StoreEntry) SearchSystemDeptListByIds(ctx context.Context, ids []int64) ([]*model.SystemDept, error) {
  576. systemDeptList := make([]*model.SystemDept, 0)
  577. if err := s.DB.Model(new(model.SystemDept)).
  578. Where("is_show = ?", operationPb.IsShow_OK).
  579. Find(&systemDeptList, ids).Error; err != nil {
  580. return nil, xerr.WithStack(err)
  581. }
  582. return systemDeptList, nil
  583. }