sys_user.go 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211
  1. package system
  2. import (
  3. "eta_gn/eta_api/global"
  4. "eta_gn/eta_api/utils"
  5. "fmt"
  6. "strings"
  7. "time"
  8. )
  9. type LoginReq struct {
  10. Username string `description:"账号"`
  11. Password string `description:"密码"`
  12. IsRemember bool `description:"是否属于受信设备"`
  13. }
  14. type LoginResp struct {
  15. Authorization string
  16. AdminName string `description:"系统用户名称"`
  17. RealName string `description:"系统用户姓名"`
  18. RoleName string `description:"角色名称"`
  19. RoleTypeCode string `description:"角色类型编码"`
  20. SysRoleTypeCode string `description:"角色类型编码"`
  21. AdminId int `description:"系统用户id"`
  22. ProductName string `description:"产品名称:admin,ficc,权益"`
  23. Authority int `description:"管理权限,0:无,1:部门负责人,2:小组负责人,或者ficc销售主管,4:ficc销售组长"`
  24. }
  25. type Admin struct {
  26. //AdminId int `grm:"column:admin_id;identity:true" description:"系统用户id"`
  27. AdminId int `gorm:"primaryKey;autoIncrement;column:admin_id"`
  28. AdminName string `description:"系统用户名称"`
  29. AdminAvatar string `description:"用户头像"`
  30. RealName string `description:"系统用户姓名"`
  31. Password string `json:"-"`
  32. LastUpdatedPasswordTime string `json:"-"`
  33. Enabled int
  34. Email string `description:"系统用户邮箱"`
  35. LastLoginTime string
  36. CreatedTime time.Time
  37. LastUpdatedTime string
  38. Role string `description:"系统用户角色"`
  39. Mobile string `description:"手机号"`
  40. RoleType int `description:"角色类型:1需要录入指标,0:不需要"`
  41. RoleId int `description:"角色ID"`
  42. RoleName string `description:"角色名称"`
  43. RoleTypeCode string `description:"角色类型编码"`
  44. DepartmentId int `description:"部门id"`
  45. DepartmentName string `description:"部门名称"`
  46. GroupId int `description:"分组id"`
  47. GroupName string `description:"分组名称"`
  48. Authority int `description:"管理权限,0:无,1:部门负责人,2:小组负责人,或者ficc销售主管,3:超级管理员,4:ficc销售组长"`
  49. Position string `description:"职位"`
  50. DisableTime time.Time `description:"禁用时间"`
  51. ChartPermission int8 `description:"图表权限id"`
  52. OpenId string `description:"弘则部门公众号的openid"`
  53. UnionId string `description:"微信公众平台唯一标识"`
  54. EdbPermission int8 `description:"指标库操作权限,0:只能操作 自己的,1:所有指标可操作"`
  55. MysteelChemicalPermission int8 `description:"钢联化工指标操作权限,0:只能操作 自己的,1:所有指标可操作"`
  56. PredictEdbPermission int8 `description:"预测指标库操作权限,0:只能操作 自己的,1:所有预测指标可操作"`
  57. Province string `description:"省"`
  58. ProvinceCode string `description:"省编码"`
  59. City string `description:"市"`
  60. CityCode string `description:"市编码"`
  61. EmployeeId string `description:"员工工号(钉钉/每刻报销)"`
  62. TelAreaCode string `description:"手机区号"`
  63. IsLdap int `description:"是否为域用户:0-系统账户;1-域用户"`
  64. }
  65. // Update 更新用户基础信息
  66. func (item *Admin) Update(cols []string) (err error) {
  67. //o := global.DEFAULT_DmSQL
  68. err = global.DEFAULT_DmSQL.Select(cols).Updates(*item).Error
  69. return
  70. }
  71. func CheckSysUser(userName, password string) (item *Admin, err error) {
  72. sql := ` SELECT a.*,b.role_type_code FROM "admin" AS a
  73. INNER JOIN sys_role AS b ON a.role_id=b.role_id WHERE a.admin_name=? AND a.password=? LIMIT 1`
  74. //o := orm.NewOrm()
  75. //err = o.Raw(sql, userName, password).QueryRow(&item)
  76. err = global.DEFAULT_DmSQL.Raw(sql, userName, password).First(&item).Error
  77. return
  78. }
  79. func GetSysUserById(sysUserId int) (item *Admin, err error) {
  80. sql := `SELECT * FROM "admin" WHERE admin_id=? LIMIT 1`
  81. err = global.DEFAULT_DmSQL.Raw(sql, sysUserId).First(&item).Error
  82. return
  83. }
  84. func ModifyPwd(sysUserId int, newPwd string) (err error) {
  85. sql := `UPDATE "admin" SET password=?,last_updated_time=NOW() WHERE admin_id=? `
  86. //o := orm.NewOrm()
  87. //_, err = o.Raw(sql, newPwd, sysUserId).Exec()
  88. err = global.DEFAULT_DmSQL.Exec(sql, newPwd, sysUserId).Error
  89. return
  90. }
  91. type ModifyPwdReq struct {
  92. OldPwd string `description:"旧密码"`
  93. NewPwd string `description:"新密码"`
  94. }
  95. // AdminWxUserRelation 管理员-微信用户关联
  96. type AdminWxUserRelation struct {
  97. AdminId int `json:"admin_id"`
  98. AdminName string `json:"admin_name"`
  99. RealName string `json:"real_name"`
  100. UserId int `json:"user_id"`
  101. }
  102. // GetAdminListByIdList 根据用户id列表获取系统用户列表
  103. func GetAdminListByIdList(idList []int) (items []*Admin, err error) {
  104. lenNum := len(idList)
  105. if lenNum <= 0 {
  106. return
  107. }
  108. sql := `SELECT * FROM "admin" WHERE admin_id in (` + utils.GetOrmInReplace(lenNum) + `) and enabled=1 `
  109. //o := orm.NewOrm()
  110. //_, err = o.Raw(sql, idList).QueryRows(&items)
  111. err = global.DEFAULT_DmSQL.Raw(sql, idList).Find(&items).Error
  112. return
  113. }
  114. // GetAdminListByIdListWithoutEnable 根据用户id列表获取系统用户列表
  115. func GetAdminListByIdListWithoutEnable(idList []int) (items []*Admin, err error) {
  116. lenNum := len(idList)
  117. if lenNum <= 0 {
  118. return
  119. }
  120. sql := `SELECT * FROM "admin" WHERE admin_id in (` + utils.GetOrmInReplace(lenNum) + `) `
  121. //o := orm.NewOrm()
  122. //_, err = o.Raw(sql, idList).QueryRows(&items)
  123. err = global.DEFAULT_DmSQL.Raw(sql, idList).Find(&items).Error
  124. return
  125. }
  126. func (item *Admin) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
  127. //o := orm.NewOrm()
  128. sql := fmt.Sprintf(`SELECT COUNT(1) FROM "admin" WHERE 1=1 %s`, condition)
  129. //err = o.Raw(sql, pars).QueryRow(&count)
  130. err = global.DEFAULT_DmSQL.Raw(sql, pars...).Scan(&count).Error
  131. return
  132. }
  133. func (item *Admin) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*Admin, err error) {
  134. //o := orm.NewOrm()
  135. fields := strings.Join(fieldArr, ",")
  136. if len(fieldArr) == 0 {
  137. fields = `*`
  138. }
  139. order := `ORDER BY created_time DESC`
  140. if orderRule != "" {
  141. order = ` ORDER BY ` + orderRule
  142. }
  143. sql := fmt.Sprintf(`SELECT %s FROM "admin" WHERE 1=1 %s %s`, fields, condition, order)
  144. //_, err = o.Raw(sql, pars).QueryRows(&items)
  145. err = global.DEFAULT_DmSQL.Raw(sql, pars...).Find(&items).Error
  146. return
  147. }
  148. // GetSysUserByMobile 手机号获取用户
  149. func GetSysUserByMobile(mobile string) (item *Admin, err error) {
  150. //o := global.DEFAULT_DmSQL
  151. sql := `SELECT
  152. a.*, b.role_type_code
  153. FROM
  154. admin AS a
  155. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  156. WHERE
  157. a.mobile = ?
  158. LIMIT 1`
  159. //err = o.Raw(sql, mobile).Find(&item).Error
  160. err = global.DEFAULT_DmSQL.Raw(sql, mobile).First(&item).Error
  161. return
  162. }
  163. // GetSysUserByEmail 邮箱获取用户
  164. func GetSysUserByEmail(email string) (item *Admin, err error) {
  165. //o := global.DEFAULT_DmSQL
  166. sql := `SELECT
  167. a.*, b.role_type_code
  168. FROM
  169. admin AS a
  170. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  171. WHERE
  172. a.email = ?
  173. LIMIT 1`
  174. //err = o.Raw(sql, email).Find(&item).Error
  175. err = global.DEFAULT_DmSQL.Raw(sql, email).First(&item).Error
  176. return
  177. }
  178. // GetSysUserByAdminName 账号获取用户
  179. func GetSysUserByAdminName(adminName string) (item *Admin, err error) {
  180. o := global.DEFAULT_DmSQL
  181. sql := `SELECT
  182. a.*, b.role_type_code
  183. FROM
  184. "admin" AS a
  185. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  186. WHERE
  187. a.admin_name = ?
  188. LIMIT 1`
  189. err = o.Raw(sql, adminName).Find(&item).Error
  190. return
  191. }