sys_user.go 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250
  1. package system
  2. import (
  3. "eta/eta_mobile/utils"
  4. "github.com/beego/beego/v2/client/orm"
  5. "time"
  6. )
  7. type LoginReq struct {
  8. Username string `description:"账号"`
  9. Password string `description:"密码"`
  10. IsRemember bool `description:"是否属于受信设备"`
  11. }
  12. type LoginResp struct {
  13. Authorization string
  14. AdminName string `description:"系统用户名称"`
  15. RealName string `description:"系统用户姓名"`
  16. RoleName string `description:"角色名称"`
  17. RoleTypeCode string `description:"角色类型编码"`
  18. SysRoleTypeCode string `description:"角色类型编码"`
  19. AdminId int `description:"系统用户id"`
  20. ProductName string `description:"产品名称:admin,ficc,权益"`
  21. DepartmentName string `description:"部门名称"`
  22. Authority int `description:"管理权限,0:无,1:部门负责人,2:小组负责人,或者ficc销售主管,4:ficc销售组长"`
  23. }
  24. type Admin struct {
  25. AdminId int `orm:"column(admin_id);pk" description:"系统用户id"`
  26. AdminName string `description:"系统用户名称"`
  27. AdminAvatar string `description:"用户头像"`
  28. RealName string `description:"系统用户姓名"`
  29. Password string `json:"-"`
  30. LastUpdatedPasswordTime string `json:"-"`
  31. Enabled int
  32. Email string `description:"系统用户邮箱"`
  33. LastLoginTime string
  34. CreatedTime time.Time
  35. LastUpdatedTime string
  36. Role string `description:"系统用户角色"`
  37. Mobile string `description:"手机号"`
  38. RoleType int `description:"角色类型:1需要录入指标,0:不需要"`
  39. RoleId int `description:"角色ID"`
  40. RoleName string `description:"角色名称"`
  41. RoleTypeCode string `description:"角色类型编码"`
  42. DepartmentId int `description:"部门id"`
  43. DepartmentName string `description:"部门名称"`
  44. GroupId int `description:"分组id"`
  45. GroupName string `description:"分组名称"`
  46. Authority int `description:"管理权限,0:无,1:部门负责人,2:小组负责人,或者ficc销售主管,3:超级管理员,4:ficc销售组长"`
  47. Position string `description:"职位"`
  48. DisableTime time.Time `description:"禁用时间"`
  49. ChartPermission int8 `description:"图表权限id"`
  50. OpenId string `description:"弘则部门公众号的openid"`
  51. UnionId string `description:"微信公众平台唯一标识"`
  52. EdbPermission int8 `description:"指标库操作权限,0:只能操作 自己的,1:所有指标可操作"`
  53. MysteelChemicalPermission int8 `description:"钢联化工指标操作权限,0:只能操作 自己的,1:所有指标可操作"`
  54. PredictEdbPermission int8 `description:"预测指标库操作权限,0:只能操作 自己的,1:所有预测指标可操作"`
  55. Province string `description:"省"`
  56. ProvinceCode string `description:"省编码"`
  57. City string `description:"市"`
  58. CityCode string `description:"市编码"`
  59. EmployeeId string `description:"员工工号(钉钉/每刻报销)"`
  60. TelAreaCode string `description:"手机区号"`
  61. }
  62. // Update 更新用户基础信息
  63. func (item *Admin) Update(cols []string) (err error) {
  64. o := orm.NewOrm()
  65. _, err = o.Update(item, cols...)
  66. return
  67. }
  68. func CheckSysUser(userName, password string) (item *Admin, err error) {
  69. sql := ` SELECT a.*,b.role_type_code FROM admin AS a
  70. INNER JOIN sys_role AS b ON a.role_id=b.role_id WHERE a.admin_name=? AND a.password=? LIMIT 1`
  71. o := orm.NewOrm()
  72. err = o.Raw(sql, userName, password).QueryRow(&item)
  73. return
  74. }
  75. func GetSysUserById(sysUserId int) (item *Admin, err error) {
  76. sql := `SELECT * FROM admin WHERE admin_id=? LIMIT 1`
  77. o := orm.NewOrm()
  78. err = o.Raw(sql, sysUserId).QueryRow(&item)
  79. return
  80. }
  81. // 根据权限code获取系统用户列表
  82. func GetAdminListByRoleCode(roleTypeCode string) (items []*Admin, err error) {
  83. sql := `SELECT * FROM admin WHERE role_type_code=? and enabled=1 `
  84. o := orm.NewOrm()
  85. _, err = o.Raw(sql, roleTypeCode).QueryRows(&items)
  86. return
  87. }
  88. // 根据权限id获取系统用户列表
  89. func GetAdminListByRoleId(roleId string) (items []*Admin, err error) {
  90. sql := `SELECT * FROM admin WHERE role_id=? and enabled=1 `
  91. o := orm.NewOrm()
  92. _, err = o.Raw(sql, roleId).QueryRows(&items)
  93. return
  94. }
  95. // GetAdminListByIds 根据用户id字符串获取系统用户列表
  96. func GetAdminListByIds(ids string) (items []*Admin, err error) {
  97. sql := `SELECT * FROM admin WHERE admin_id in (` + ids + `) and enabled=1 `
  98. o := orm.NewOrm()
  99. _, err = o.Raw(sql).QueryRows(&items)
  100. return
  101. }
  102. func ModifyPwd(sysUserId int, newPwd string) (err error) {
  103. sql := `UPDATE admin SET password=?,last_updated_time=NOW() WHERE admin_id=? `
  104. o := orm.NewOrm()
  105. _, err = o.Raw(sql, newPwd, sysUserId).Exec()
  106. return
  107. }
  108. type ModifyPwdReq struct {
  109. OldPwd string `description:"旧密码"`
  110. NewPwd string `description:"新密码"`
  111. }
  112. func GetAdminList() (items []*Admin, err error) {
  113. sql := `SELECT * FROM admin`
  114. o := orm.NewOrm()
  115. _, err = o.Raw(sql).QueryRows(&items)
  116. return
  117. }
  118. // GetSysUserByMobile 根据手机号获取管理信息
  119. //func GetSysUserByMobile(mobile string) (item *Admin, err error) {
  120. // sql := `SELECT * FROM admin WHERE mobile = ? LIMIT 1`
  121. // o := orm.NewOrm()
  122. // err = o.Raw(sql, mobile).QueryRow(&item)
  123. // return
  124. //}
  125. // 通过用户姓名跟身份获取管理员信息
  126. func CheckSysUserByName(userName, roleTypeCode string) (item *Admin, err error) {
  127. sql := ` SELECT a.* FROM admin AS a WHERE a.real_name=? AND a.role_type_code=? LIMIT 1`
  128. o := orm.NewOrm()
  129. err = o.Raw(sql, userName, roleTypeCode).QueryRow(&item)
  130. return
  131. }
  132. // GetAdminListByGroupId 根据分组id获取系统用户列表
  133. func GetAdminListByGroupId(groupId int) (items []*Admin, err error) {
  134. sql := `SELECT * FROM admin WHERE group_id=? and enabled=1 `
  135. o := orm.NewOrm()
  136. _, err = o.Raw(sql, groupId).QueryRows(&items)
  137. return
  138. }
  139. // AdminWxUserRelation 管理员-微信用户关联
  140. type AdminWxUserRelation struct {
  141. AdminId int `json:"admin_id"`
  142. AdminName string `json:"admin_name"`
  143. RealName string `json:"real_name"`
  144. UserId int `json:"user_id"`
  145. }
  146. // GetAdminWxUserRelationByWxUserIds 通过微信用户及平台获取后台关联信息
  147. func GetAdminWxUserRelationByWxUserIds(platform int, userIds []int) (list []*AdminWxUserRelation, err error) {
  148. userLen := len(userIds)
  149. if userLen == 0 {
  150. return
  151. }
  152. o := orm.NewOrm()
  153. sql := `SELECT
  154. ad.admin_id, ad.admin_name, ad.real_name, wu.user_id
  155. FROM
  156. admin AS ad
  157. JOIN wx_user AS wu ON ad.mobile = wu.mobile
  158. JOIN user_record AS ur ON wu.user_id = ur.user_id AND ur.create_platform = ?
  159. WHERE
  160. wu.user_id IN (` + utils.GetOrmInReplace(userLen) + `)`
  161. _, err = o.Raw(sql, platform, userIds).QueryRows(&list)
  162. return
  163. }
  164. // GetAdminListByIdList 根据用户id列表获取系统用户列表
  165. func GetAdminListByIdList(idList []int) (items []*Admin, err error) {
  166. lenNum := len(idList)
  167. if lenNum <= 0 {
  168. return
  169. }
  170. sql := `SELECT * FROM admin WHERE admin_id in (` + utils.GetOrmInReplace(lenNum) + `) and enabled=1 `
  171. o := orm.NewOrm()
  172. _, err = o.Raw(sql, idList).QueryRows(&items)
  173. return
  174. }
  175. // GetAdminListByIdList 根据用户id列表获取系统用户列表
  176. func GetAdminListByIdListWithoutEnable(idList []int) (items []*Admin, err error) {
  177. lenNum := len(idList)
  178. if lenNum <= 0 {
  179. return
  180. }
  181. sql := `SELECT * FROM admin WHERE admin_id in (` + utils.GetOrmInReplace(lenNum) + `) `
  182. o := orm.NewOrm()
  183. _, err = o.Raw(sql, idList).QueryRows(&items)
  184. return
  185. }
  186. // GetSysUserByMobile 手机号获取用户
  187. func GetSysUserByMobile(mobile string) (item *Admin, err error) {
  188. o := orm.NewOrm()
  189. sql := `SELECT
  190. a.*, b.role_type_code
  191. FROM
  192. admin AS a
  193. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  194. WHERE
  195. a.mobile = ?
  196. LIMIT 1`
  197. err = o.Raw(sql, mobile).QueryRow(&item)
  198. return
  199. }
  200. // GetSysUserByEmail 邮箱获取用户
  201. func GetSysUserByEmail(email string) (item *Admin, err error) {
  202. o := orm.NewOrm()
  203. sql := `SELECT
  204. a.*, b.role_type_code
  205. FROM
  206. admin AS a
  207. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  208. WHERE
  209. a.email = ?
  210. LIMIT 1`
  211. err = o.Raw(sql, email).QueryRow(&item)
  212. return
  213. }
  214. // GetSysUserByAdminName 账号获取用户
  215. func GetSysUserByAdminName(adminName string) (item *Admin, err error) {
  216. o := orm.NewOrm()
  217. sql := `SELECT
  218. a.*, b.role_type_code
  219. FROM
  220. admin AS a
  221. INNER JOIN sys_role AS b ON a.role_id = b.role_id
  222. WHERE
  223. a.admin_name = ?
  224. LIMIT 1`
  225. err = o.Raw(sql, adminName).QueryRow(&item)
  226. return
  227. }