sys_department.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. package system
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "time"
  6. )
  7. type SysDepartmentAddReq struct {
  8. DepartmentName string `description:"部门名称"`
  9. }
  10. type SysDepartment struct {
  11. DepartmentId int `orm:"column(department_id);pk" gorm:"primaryKey" description:"部门Id"`
  12. DepartmentName string `description:"部门名称"`
  13. Sort int `description:"排序"`
  14. CreateTime time.Time `description:"创建时间"`
  15. }
  16. func GetSysDepartmentCount(departmentName string) (count int, err error) {
  17. sql := `SELECT COUNT(1) AS count FROM sys_department WHERE department_name=? `
  18. o := global.DbMap[utils.DbNameMaster]
  19. err = o.Raw(sql, departmentName).Scan(&count).Error
  20. return
  21. }
  22. func AddSysDepartment(item *SysDepartment) (lastId int64, err error) {
  23. o := global.DbMap[utils.DbNameMaster]
  24. err = o.Create(item).Error
  25. if err != nil {
  26. return
  27. }
  28. lastId = int64(item.DepartmentId)
  29. return
  30. }
  31. type SysDepartmentEditReq struct {
  32. DepartmentId int `description:"部门Id"`
  33. DepartmentName string `description:"部门名称"`
  34. }
  35. func GetSysDepartmentById(departmentId int) (item *SysDepartment, err error) {
  36. sql := `SELECT * FROM sys_department WHERE department_id=? `
  37. o := global.DbMap[utils.DbNameMaster]
  38. err = o.Raw(sql, departmentId).First(&item).Error
  39. return
  40. }
  41. func GetSysDepartmentByName(departmentName string) (item *SysDepartment, err error) {
  42. sql := `SELECT * FROM sys_department WHERE department_name=? `
  43. o := global.DbMap[utils.DbNameMaster]
  44. err = o.Raw(sql, departmentName).First(&item).Error
  45. return
  46. }
  47. func ModifySysDepartment(departmentName string, departmentId int) (err error) {
  48. o := global.DbMap[utils.DbNameMaster]
  49. to := o.Begin()
  50. defer func() {
  51. if err != nil {
  52. _ = to.Rollback()
  53. } else {
  54. _ = to.Commit()
  55. }
  56. }()
  57. sql := `UPDATE sys_department SET department_name=? WHERE department_id=? `
  58. err = to.Exec(sql, departmentName, departmentId).Error
  59. if err != nil {
  60. return
  61. }
  62. sql = `UPDATE "admin" SET department_name=? WHERE department_id=? `
  63. err = to.Exec(sql, departmentName, departmentId).Error
  64. return
  65. }
  66. type SysDepartmentDeleteReq struct {
  67. DepartmentId int `description:"部门Id"`
  68. }
  69. func DeleteSysDepartment(departmentId int) (err error) {
  70. sql := `DELETE FROM sys_department WHERE department_id=? `
  71. o := global.DbMap[utils.DbNameMaster]
  72. err = o.Exec(sql, departmentId).Error
  73. return
  74. }
  75. type SysDepartmentList struct {
  76. DepartmentId int `orm:"column(department_id);pk" gorm:"primaryKey" description:"部门Id"`
  77. DepartmentName string `description:"部门名称"`
  78. CreateTime time.Time `description:"创建时间"`
  79. Child []*SysGroupList `description:"分组" gorm:"-"`
  80. IsDepartment bool `description:"true:部门,false:分组"`
  81. }
  82. func GetDepartmentList() (items []*SysDepartmentList, err error) {
  83. o := global.DbMap[utils.DbNameMaster]
  84. sql := `SELECT * FROM sys_department ORDER BY sort ASC, create_time ASC `
  85. err = o.Raw(sql).Find(&items).Error
  86. return
  87. }
  88. // GetDepartmentListByIds 根据部门id集合获取部门列表信息
  89. func GetDepartmentListByIds(departmentIds string) (items []*SysDepartmentList, err error) {
  90. o := global.DbMap[utils.DbNameMaster]
  91. sql := `SELECT * FROM sys_department where 1 = 1 `
  92. if departmentIds != "" {
  93. sql += `and department_id in(` + departmentIds + `) `
  94. }
  95. sql += ` ORDER BY sort ASC, create_time ASC `
  96. err = o.Raw(sql).Find(&items).Error
  97. return
  98. }
  99. type SysDepartmentListResp struct {
  100. List []*SysDepartmentList
  101. }
  102. func GetSysDepartmentAll() (item []*SysDepartment, err error) {
  103. sql := `SELECT * FROM sys_department ORDER BY sort ASC, department_id ASC `
  104. o := global.DbMap[utils.DbNameMaster]
  105. err = o.Raw(sql).Find(&item).Error
  106. return
  107. }
  108. type DepartmentSort struct {
  109. DepartmentId int
  110. Sort int
  111. }
  112. func MultiUpdateDepartmentSort(items []*DepartmentSort) (err error) {
  113. if len(items) == 0 {
  114. return
  115. }
  116. o := global.DbMap[utils.DbNameMaster]
  117. sql := "UPDATE sys_department SET sort = ? WHERE department_id = ?"
  118. for _, v := range items {
  119. err = o.Exec(sql, v.Sort, v.DepartmentId).Error
  120. if err != nil {
  121. return
  122. }
  123. }
  124. return
  125. }
  126. // DepartmentUserTree 部门用户树
  127. type DepartmentUserTree struct {
  128. NodeId int `description:"节点ID"`
  129. NodeType int `description:"节点类型:1-部门;2-分组;3-用户"`
  130. NodeName string `description:"节点名称"`
  131. Children []*DepartmentUserTree `description:"子节点" gorm:"-"`
  132. }