cygx_yanxuan_special_user.go 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. package cygx
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "time"
  6. )
  7. type CygxYanxuanSpecialAuthor struct {
  8. Id int `orm:"column(id);pk"`
  9. UserId int // 用户ID
  10. SpecialName string // 专栏名称
  11. Introduction string // 介绍
  12. Label string // 标签
  13. NickName string // 昵称
  14. RealName string // 姓名
  15. Mobile string // 手机号
  16. MobileInit string // 初始化手机号(没有脱敏的)
  17. CreateTime time.Time // 创建时间
  18. ModifyTime time.Time // 修改时间
  19. HeadImg string // 头像
  20. BgImg string // 背景图上部分
  21. BgImgDown string // 背景图下部分
  22. BgImgPc string // pc背景图
  23. Status int // 1启用2禁用
  24. CompanyId int `description:"公司id"`
  25. CompanyName string `description:"公司名称"`
  26. InviteName string //引荐人
  27. Remark string //备注
  28. }
  29. type CygxYanxuanSpecialAuthorItem struct {
  30. Id int `orm:"column(id);pk"`
  31. UserId int // 用户ID
  32. CompanyName string // 公司名
  33. CompanyId int // 公Id
  34. SpecialName string // 专栏名称
  35. Introduction string // 介绍
  36. Label string // 标签
  37. NickName string // 昵称
  38. RealName string // 姓名
  39. Mobile string // 手机号
  40. MobileInit string // 初始化手机号(没有脱敏的)
  41. CreateTime string // 创建时间
  42. ModifyTime string // 修改时间
  43. HeadImg string // 头像
  44. BgImg string // 背景图
  45. Status int // 1启用2禁用
  46. Pv int // Pv
  47. Uv int // Uv
  48. ArticleNum int // 已发布的文章数量
  49. ArticlePublishTime string // 最近发布文章的时间
  50. FansNum int // 粉丝数量
  51. ArticleCollectNum int // 文章收藏数量
  52. SpecialAuthorId int //cygx_yanxuan_special_author 表主键ID 作者专栏ID
  53. InviteName string //引荐人
  54. Remark string //备注
  55. }
  56. type CygxYanxuanSpecialKeyWordReesp struct {
  57. KeyWord string //引荐人
  58. }
  59. type CygxYanxuanSpecialKeyWordListReesp struct {
  60. List []*CygxYanxuanSpecialKeyWordReesp //引荐人
  61. }
  62. func AddCygxYanxuanSpecialAuthor(item *CygxYanxuanSpecialAuthor) (lastId int64, err error) {
  63. o := orm.NewOrmUsingDB("hz_cygx")
  64. lastId, err = o.Insert(item)
  65. return
  66. }
  67. type AddCygxYanxuanSpecialAuthorReq struct {
  68. UserId int // 用户ID
  69. RealName string // 姓名
  70. Mobile string // 手机号
  71. InviteName string //引荐人
  72. Remark string //备注
  73. }
  74. type EnableCygxYanxuanSpecialAuthorReq struct {
  75. UserId int // 用户ID
  76. Status int // 1启用2禁用
  77. }
  78. // 启用禁用作者
  79. func EnableYanxuanSpecialAuthor(userId, status int) (err error) {
  80. o := orm.NewOrmUsingDB("hz_cygx")
  81. sql := ``
  82. sql = `UPDATE cygx_yanxuan_special_author SET status=? WHERE user_id = ? `
  83. _, err = o.Raw(sql, status, userId).Exec()
  84. return
  85. }
  86. // 获取数量
  87. func GetYanxuanSpecialAuthorCount(condition string, pars []interface{}) (count int, err error) {
  88. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_yanxuan_special_author as art WHERE 1= 1 `
  89. if condition != "" {
  90. sqlCount += condition
  91. }
  92. o := orm.NewOrmUsingDB("hz_cygx")
  93. err = o.Raw(sqlCount, pars).QueryRow(&count)
  94. return
  95. }
  96. type GetCygxYanxuanSpecialAuthorItemResp struct {
  97. Paging *paging.PagingItem `description:"分页数据"`
  98. List []*CygxYanxuanSpecialAuthorItem
  99. }
  100. // 列表
  101. func GetYanxuanSpecialAuthorList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxYanxuanSpecialAuthorItem, err error) {
  102. o := orm.NewOrmUsingDB("hz_cygx")
  103. sql := `SELECT * FROM cygx_yanxuan_special_author as art WHERE 1= 1 `
  104. if condition != "" {
  105. sql += condition
  106. }
  107. sql += ` LIMIT ?,? `
  108. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  109. return
  110. }
  111. // 启用禁用作者
  112. func UpdateSpecialAuthorComapony(userId, CompanyId int, CompanyName string) (err error) {
  113. o := orm.NewOrmUsingDB("hz_cygx")
  114. sql := ``
  115. sql = `UPDATE cygx_yanxuan_special_author SET company_id=?,company_name = ? WHERE user_id = ? `
  116. _, err = o.Raw(sql, CompanyId, CompanyName, userId).Exec()
  117. return
  118. }
  119. // 通过ID获取详情
  120. func GetCygxYanxuanSpecialAuthorItemById(id int) (item *CygxYanxuanSpecialAuthorItem, err error) {
  121. o := orm.NewOrmUsingDB("hz_cygx")
  122. sql := `SELECT * FROM cygx_yanxuan_special_author WHERE id=? `
  123. err = o.Raw(sql, id).QueryRow(&item)
  124. return
  125. }
  126. // 根据用户ID获取专栏详情
  127. func GetCygxYanxuanSpecialAuthorByUserId(userId int) (item *CygxYanxuanSpecialAuthorItem, err error) {
  128. o := orm.NewOrmUsingDB("hz_cygx")
  129. sql := `SELECT * FROM cygx_yanxuan_special_author WHERE user_id = ? `
  130. err = o.Raw(sql, userId).QueryRow(&item)
  131. return
  132. }
  133. type CygxYanxuanSpecialCenterAuthorResp struct {
  134. Id int //研选专栏ID
  135. UserId int // 用户ID
  136. PublishTime string // 提审过审或驳回时间
  137. Title string // 标题
  138. }
  139. // 启用禁用作者
  140. func UpdateSpecialAuthormobile_init(mobile_init string, userId int) (err error) {
  141. o := orm.NewOrmUsingDB("hz_cygx")
  142. sql := ``
  143. sql = `UPDATE cygx_yanxuan_special_author SET mobile_init = ? WHERE user_id = ? `
  144. _, err = o.Raw(sql, mobile_init, userId).Exec()
  145. return
  146. }
  147. // 更新作者引荐人相关信息
  148. func UpdateYanxuanSpecialAuthorInviteName(inviteName, remark string, userId int) (err error) {
  149. o := orm.NewOrmUsingDB("hz_cygx")
  150. sql := ``
  151. sql = `UPDATE cygx_yanxuan_special_author SET invite_name=? , remark = ? WHERE user_id = ? `
  152. _, err = o.Raw(sql, inviteName, remark, userId).Exec()
  153. return
  154. }