yanxuan_special.go 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "hongze/hz_crm_api/controllers"
  5. "hongze/hz_crm_api/models"
  6. "hongze/hz_crm_api/models/cygx"
  7. "hongze/hz_crm_api/utils"
  8. "time"
  9. )
  10. // YanxuanSpecialController 研选专栏
  11. type YanxuanSpecialController struct {
  12. controllers.BaseAuthController
  13. }
  14. // @Title 新增研选专栏作者
  15. // @Description 新增研选专栏作者
  16. // @Param request body help_doc.AddHelpDocReq true "type json string"
  17. // @Success 200 {object} models.AddEnglishReportResp
  18. // @router /yanxuan_special/author/add [post]
  19. func (this *YanxuanSpecialController) Add() {
  20. br := new(models.BaseResponse).Init()
  21. defer func() {
  22. this.Data["json"] = br
  23. this.ServeJSON()
  24. }()
  25. sysUser := this.SysUser
  26. if sysUser == nil {
  27. br.Msg = "请登录"
  28. br.ErrMsg = "请登录,SysUser Is Empty"
  29. br.Ret = 408
  30. return
  31. }
  32. var req cygx.AddCygxYanxuanSpecialAuthorReq
  33. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  34. if err != nil {
  35. br.Msg = "参数解析异常!"
  36. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  37. return
  38. }
  39. if req.UserId <= 0 {
  40. br.Msg = "请输入内容"
  41. return
  42. }
  43. if req.RealName == "" {
  44. br.Msg = "请输入内容"
  45. return
  46. }
  47. if req.Mobile == "" {
  48. br.Msg = "请输入内容"
  49. return
  50. }
  51. item := cygx.CygxYanxuanSpecialAuthor{
  52. UserId: req.UserId,
  53. RealName: req.RealName,
  54. Mobile: req.Mobile,
  55. CreateTime: time.Now(),
  56. ModifyTime: time.Now(),
  57. HeadImg: "",
  58. BgImg: "",
  59. Status: 1,
  60. }
  61. _, err = cygx.AddCygxYanxuanSpecialAuthor(&item)
  62. if err != nil {
  63. br.Msg = "新增失败"
  64. br.ErrMsg = "新增失败,Err:" + err.Error()
  65. return
  66. }
  67. br.Ret = 200
  68. br.Success = true
  69. br.Msg = "新增成功"
  70. }
  71. // @Title 禁用/启用研选专栏作者
  72. // @Description 禁用/启用研选专栏作者
  73. // @Param request body help_doc.AddHelpDocReq true "type json string"
  74. // @Success 200 {object} models.AddEnglishReportResp
  75. // @router /yanxuan_special/author/enable [post]
  76. func (this *YanxuanSpecialController) AuthorEnable() {
  77. br := new(models.BaseResponse).Init()
  78. defer func() {
  79. this.Data["json"] = br
  80. this.ServeJSON()
  81. }()
  82. sysUser := this.SysUser
  83. if sysUser == nil {
  84. br.Msg = "请登录"
  85. br.ErrMsg = "请登录,SysUser Is Empty"
  86. br.Ret = 408
  87. return
  88. }
  89. var req cygx.EnableCygxYanxuanSpecialAuthorReq
  90. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  91. if err != nil {
  92. br.Msg = "参数解析异常!"
  93. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  94. return
  95. }
  96. if req.UserId <= 0 {
  97. br.Msg = "用户id错误"
  98. return
  99. }
  100. if req.Status <= 0 {
  101. br.Msg = "参数错误"
  102. return
  103. }
  104. if tmpErr := cygx.EnableYanxuanSpecialAuthor(req.UserId, req.Status); tmpErr != nil {
  105. br.Msg = "启用/禁用作者失败"
  106. br.ErrMsg = "启用/禁用作者失败, Err:" + tmpErr.Error()
  107. return
  108. }
  109. if req.Status == 1 {
  110. br.Msg = "启用成功"
  111. } else {
  112. br.Msg = "禁用成功"
  113. }
  114. br.Ret = 200
  115. br.Success = true
  116. }
  117. // @Title 作者列表
  118. // @Description 作者列表
  119. // @Param request body help_doc.AddHelpDocReq true "type json string"
  120. // @Success 200 {object} models.AddEnglishReportResp
  121. // @router /yanxuan_special/author/list [get]
  122. func (this *YanxuanSpecialController) AuthorList() {
  123. br := new(models.BaseResponse).Init()
  124. defer func() {
  125. this.Data["json"] = br
  126. this.ServeJSON()
  127. }()
  128. sysUser := this.SysUser
  129. if sysUser == nil {
  130. br.Msg = "请登录"
  131. br.ErrMsg = "请登录,SysUser Is Empty"
  132. br.Ret = 408
  133. return
  134. }
  135. list, tmpErr := cygx.GetYanxuanSpecialAuthorList()
  136. if tmpErr != nil {
  137. br.Msg = "获取失败"
  138. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  139. return
  140. }
  141. br.Data = list
  142. br.Ret = 200
  143. br.Success = true
  144. br.Msg = "获取成功"
  145. }
  146. // @Title 审核列表
  147. // @Description 审核列表
  148. // @Param request body help_doc.AddHelpDocReq true "type json string"
  149. // @Success 200 {object} models.AddEnglishReportResp
  150. // @router /yanxuan_special/list [get]
  151. func (this *YanxuanSpecialController) List() {
  152. br := new(models.BaseResponse).Init()
  153. defer func() {
  154. this.Data["json"] = br
  155. this.ServeJSON()
  156. }()
  157. sysUser := this.SysUser
  158. if sysUser == nil {
  159. br.Msg = "请登录"
  160. br.ErrMsg = "请登录,SysUser Is Empty"
  161. br.Ret = 408
  162. return
  163. }
  164. userId, _ := this.GetInt("UserId", 0)
  165. var condition string
  166. var pars []interface{}
  167. if userId > 0 {
  168. condition += ` AND a.user_id = ? `
  169. pars = append(pars, userId)
  170. }
  171. condition += ` AND a.status = 2 `
  172. list, tmpErr := cygx.GetYanxuanSpecialList(condition, pars)
  173. if tmpErr != nil {
  174. br.Msg = "获取失败"
  175. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  176. return
  177. }
  178. for _, v := range list {
  179. hasImg, err := utils.ArticleHasImgUrl(v.Content)
  180. if err != nil {
  181. return
  182. }
  183. if !hasImg{
  184. v.ContentHasImg = 1
  185. }
  186. }
  187. br.Data = list
  188. br.Ret = 200
  189. br.Success = true
  190. br.Msg = "获取成功"
  191. }
  192. // @Title 审批研选专栏
  193. // @Description 审批研选专栏
  194. // @Param request body help_doc.AddHelpDocReq true "type json string"
  195. // @Success 200 {object} models.AddEnglishReportResp
  196. // @router /yanxuan_special/enable [post]
  197. func (this *YanxuanSpecialController) Enable() {
  198. br := new(models.BaseResponse).Init()
  199. defer func() {
  200. this.Data["json"] = br
  201. this.ServeJSON()
  202. }()
  203. sysUser := this.SysUser
  204. if sysUser == nil {
  205. br.Msg = "请登录"
  206. br.ErrMsg = "请登录,SysUser Is Empty"
  207. br.Ret = 408
  208. return
  209. }
  210. var req cygx.EnableCygxYanxuanSpecialReq
  211. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  212. if err != nil {
  213. br.Msg = "参数解析异常!"
  214. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  215. return
  216. }
  217. if req.Id <= 0 {
  218. br.Msg = "文章id错误"
  219. return
  220. }
  221. if req.Status <= 0 {
  222. br.Msg = "参数错误"
  223. return
  224. }
  225. status := 0
  226. if req.Status == 1 {
  227. status = 3
  228. } else {
  229. status = 4
  230. }
  231. if tmpErr := cygx.EnableYanxuanSpecial(req.Id, status, req.Reason); tmpErr != nil {
  232. br.Msg = "审批失败"
  233. br.ErrMsg = "审批失败, Err:" + tmpErr.Error()
  234. return
  235. }
  236. br.Msg = "审批成功"
  237. br.Ret = 200
  238. br.Success = true
  239. }