sys_team.go 3.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. package system
  2. import (
  3. "eta_gn/eta_api/global"
  4. "time"
  5. )
  6. type SysTeamAddReq struct {
  7. GroupId int `description:"大组id"`
  8. DepartmentId int `description:"部门id"`
  9. TeamName string `description:"分组名称,多个用英文逗号隔开"`
  10. }
  11. type SysTeam struct {
  12. GroupId int `orm:"column(group_id);pk" description:"分组ID"`
  13. ParentId int `description:"父级Id"`
  14. DepartmentId int `description:"部门id"`
  15. GroupName string `description:"分组名称"`
  16. CreateTime time.Time `description:"创建时间"`
  17. }
  18. func GetSysTeamCount(groupId int, teamName string) (count int, err error) {
  19. sql := `SELECT COUNT(1) AS count FROM sys_group WHERE parent_id=? AND group_name=? `
  20. //o := orm.NewOrm()
  21. //err = o.Raw(sql, groupId, teamName).QueryRow(&count)
  22. err = global.DEFAULT_DmSQL.Raw(sql, groupId, teamName).Scan(&count).Error
  23. return
  24. }
  25. type SysTeamEditReq struct {
  26. TeamId int `description:"分组ID"`
  27. TeamName string `description:"分组名称"`
  28. }
  29. func GetSysTeamByName(teamName string) (item *SysGroup, err error) {
  30. sql := `SELECT * FROM sys_group WHERE group_name=? `
  31. //o := orm.NewOrm()
  32. //err = o.Raw(sql, teamName).QueryRow(&item)
  33. err = global.DEFAULT_DmSQL.Raw(sql, teamName).First(&item).Error
  34. return
  35. }
  36. func ModifySysTeam(teamName string, teamId int) (err error) {
  37. //o := orm.NewOrm()
  38. //to, err := o.Begin()
  39. //if err != nil {
  40. // return
  41. //}
  42. //defer func() {
  43. // if err != nil {
  44. // _ = to.Rollback()
  45. // } else {
  46. // _ = to.Commit()
  47. // }
  48. //}()
  49. //sql := `UPDATE sys_group SET group_name=? WHERE group_id=? `
  50. //_, err = to.Raw(sql, teamName, teamId).Exec()
  51. //sql = `UPDATE admin SET group_name=? WHERE group_id=? `
  52. //_, err = to.Raw(sql, teamName, teamId).Exec()
  53. tx := global.DEFAULT_DmSQL.Begin()
  54. defer func() {
  55. if err != nil {
  56. _ = tx.Rollback()
  57. return
  58. }
  59. _ = tx.Commit()
  60. }()
  61. sql := `UPDATE sys_group SET group_name=? WHERE group_id=? `
  62. //_, err = to.Raw(sql, teamName, teamId).Exec()
  63. err = tx.Exec(sql, teamName, teamId).Error
  64. if err != nil {
  65. return
  66. }
  67. sql = `UPDATE "admin" SET group_name=? WHERE group_id=? `
  68. //_, err = to.Raw(sql, teamName, teamId).Exec()
  69. err = tx.Exec(sql, teamName, teamId).Error
  70. return
  71. }
  72. type SysTeamDeleteReq struct {
  73. TeamId int `description:"小组ID"`
  74. }
  75. type SysTeamList struct {
  76. GroupId int `orm:"column(group_id);pk" json:"DepartmentId" description:"小组ID"`
  77. ParentId int `json:"GroupId" description:"小组Id"`
  78. GroupName string `json:"DepartmentName" description:"分组名称"`
  79. CreateTime time.Time `description:"创建时间"`
  80. }
  81. func GetSysTeamByDepartmentId(groupId int) (items []*SysTeamList, err error) {
  82. sql := `SELECT * FROM sys_group WHERE parent_id=? ORDER BY sort ASC, create_time ASC`
  83. //o := orm.NewOrm()
  84. //_, err = o.Raw(sql, groupId).QueryRows(&items)
  85. err = global.DEFAULT_DmSQL.Raw(sql, groupId).Find(&items).Error
  86. return
  87. }
  88. func ClearSysUserTeam(groupId int) (err error) {
  89. sql := `UPDATE "admin" SET group_id=0,group_name='' WHERE group_id=? `
  90. //o := orm.NewOrm()
  91. //_, err = o.Raw(sql, groupId).Exec()
  92. err = global.DEFAULT_DmSQL.Exec(sql, groupId).Error
  93. return
  94. }