yanxuan_special.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "hongze/hongze_cygx/models"
  5. "hongze/hongze_cygx/utils"
  6. "time"
  7. )
  8. type YanxuanSpecialController struct {
  9. BaseAuthController
  10. }
  11. // @Title 专栏列表
  12. // @Description 专栏列表
  13. // @Param request body help_doc.AddHelpDocReq true "type json string"
  14. // @Success 200 {object} models.AddEnglishReportResp
  15. // @router /list [get]
  16. func (this *YanxuanSpecialController) List() {
  17. br := new(models.BaseResponse).Init()
  18. defer func() {
  19. this.Data["json"] = br
  20. this.ServeJSON()
  21. }()
  22. sysUser := this.User
  23. if sysUser == nil {
  24. br.Msg = "请登录"
  25. br.ErrMsg = "请登录,SysUser Is Empty"
  26. br.Ret = 408
  27. return
  28. }
  29. userId, _ := this.GetInt("UserId", 0)
  30. var condition string
  31. var pars []interface{}
  32. var specialUser *models.CygxYanxuanSpecialAuthorItem
  33. var err error
  34. if userId > 0 {
  35. condition += ` AND a.user_id = ? `
  36. pars = append(pars, userId)
  37. }
  38. specialUser, err = models.GetYanxuanSpecialAuthor(sysUser.UserId, sysUser.UserId)
  39. if err != nil && err.Error() != utils.ErrNoRow() {
  40. br.Msg = "获取失败"
  41. br.ErrMsg = "获取失败, Err:" + err.Error()
  42. return
  43. }
  44. condition += ` AND a.status = 3 `
  45. list, tmpErr := models.GetYanxuanSpecialList(sysUser.UserId, condition, pars)
  46. if tmpErr != nil {
  47. br.Msg = "获取失败"
  48. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  49. return
  50. }
  51. for _, v := range list {
  52. hasImg, err := utils.ArticleHasImgUrl(v.Content)
  53. if err != nil {
  54. return
  55. }
  56. if hasImg {
  57. v.ContentHasImg = 1
  58. }
  59. if v.DocUrl != "" {
  60. var docs []models.Doc
  61. err := json.Unmarshal([]byte(v.DocUrl), &docs)
  62. if err != nil {
  63. br.Msg = "参数解析异常!"
  64. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  65. return
  66. }
  67. v.Docs = docs
  68. }
  69. if v.Type == 1 {
  70. v.Title = "【笔记】"+v.Title
  71. } else if v.Type == 2 {
  72. v.Title = "【观点】"+v.Title
  73. }
  74. if v.MyCollectNum > 0 {
  75. v.IsCollect = 1
  76. }
  77. }
  78. resp := new(models.SpecialListResp)
  79. if specialUser != nil {
  80. resp.IsAuthor = true
  81. }
  82. resp.List = list
  83. br.Data = resp
  84. br.Ret = 200
  85. br.Success = true
  86. br.Msg = "获取成功"
  87. }
  88. // @Title 专栏详情
  89. // @Description 专栏详情
  90. // @Param request body help_doc.AddHelpDocReq true "type json string"
  91. // @Success 200 {object} models.AddEnglishReportResp
  92. // @router /detail [get]
  93. func (this *YanxuanSpecialController) Detail() {
  94. br := new(models.BaseResponse).Init()
  95. defer func() {
  96. this.Data["json"] = br
  97. this.ServeJSON()
  98. }()
  99. sysUser := this.User
  100. if sysUser == nil {
  101. br.Msg = "请登录"
  102. br.ErrMsg = "请登录,SysUser Is Empty"
  103. br.Ret = 408
  104. return
  105. }
  106. specialId, _ := this.GetInt("Id", 0)
  107. if specialId <= 0 {
  108. br.Msg = "参数错误"
  109. br.ErrMsg = "参数错误"
  110. return
  111. }
  112. item, tmpErr := models.GetYanxuanSpecialById(specialId, sysUser.UserId)
  113. if tmpErr != nil {
  114. br.Msg = "获取失败"
  115. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  116. return
  117. }
  118. if item.MyCollectNum > 0 {
  119. item.IsCollect = 1
  120. }
  121. var resp models.CygxYanxuanSpecialResp
  122. resp.CygxYanxuanSpecialItem = *item
  123. if item.DocUrl != "" {
  124. var docs []models.Doc
  125. err := json.Unmarshal([]byte(item.DocUrl), &docs)
  126. if err != nil {
  127. br.Msg = "参数解析异常!"
  128. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  129. return
  130. }
  131. resp.Docs = docs
  132. }
  133. br.Data = resp
  134. br.Ret = 200
  135. br.Success = true
  136. br.Msg = "获取成功"
  137. }
  138. // @Title 新增保存专栏作者详情
  139. // @Description 新增保存专栏作者详情
  140. // @Param request body help_doc.AddHelpDocReq true "type json string"
  141. // @Success 200 {object} models.AddEnglishReportResp
  142. // @router /author/save [post]
  143. func (this *YanxuanSpecialController) AuthorSave() {
  144. br := new(models.BaseResponse).Init()
  145. defer func() {
  146. this.Data["json"] = br
  147. this.ServeJSON()
  148. }()
  149. sysUser := this.User
  150. if sysUser == nil {
  151. br.Msg = "请登录"
  152. br.ErrMsg = "请登录,SysUser Is Empty"
  153. br.Ret = 408
  154. return
  155. }
  156. var req models.SaveCygxYanxuanSpecialAuthorReq
  157. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  158. if err != nil {
  159. br.Msg = "参数解析异常!"
  160. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  161. return
  162. }
  163. if req.UserId <= 0 {
  164. br.Msg = "用户id有误"
  165. return
  166. }
  167. if req.SpecialName == "" {
  168. br.Msg = "请输入专栏名称"
  169. return
  170. }
  171. if req.NickName == "" {
  172. br.Msg = "请输入昵称"
  173. return
  174. }
  175. item := models.CygxYanxuanSpecialAuthor{
  176. UserId: req.UserId,
  177. SpecialName: req.SpecialName,
  178. Introduction: req.Introduction,
  179. Label: req.Label,
  180. NickName: req.NickName,
  181. CreateTime: time.Now(),
  182. ModifyTime: time.Now(),
  183. BgImg: "",
  184. Status: 1,
  185. }
  186. //if req.Id == 0{
  187. // _, err = models.AddCygxYanxuanSpecialAuthor(&item)
  188. // if err != nil {
  189. // br.Msg = "新增失败"
  190. // br.ErrMsg = "新增失败,Err:" + err.Error()
  191. // return
  192. // }
  193. //} else {
  194. // err = models.UpdateYanxuanSpecialAuthor(&item)
  195. // if err != nil {
  196. // br.Msg = "保存失败"
  197. // br.ErrMsg = "保存失败,Err:" + err.Error()
  198. // return
  199. // }
  200. //}
  201. err = models.UpdateYanxuanSpecialAuthor(&item)
  202. if err != nil {
  203. br.Msg = "保存失败"
  204. br.ErrMsg = "保存失败,Err:" + err.Error()
  205. return
  206. }
  207. br.Ret = 200
  208. br.Success = true
  209. br.Msg = "保存成功"
  210. }
  211. // @Title 新增保存专栏
  212. // @Description 新增保存专栏
  213. // @Param request body help_doc.AddHelpDocReq true "type json string"
  214. // @Success 200 {object} models.AddEnglishReportResp
  215. // @router /save [post]
  216. func (this *YanxuanSpecialController) Save() {
  217. br := new(models.BaseResponse).Init()
  218. defer func() {
  219. this.Data["json"] = br
  220. this.ServeJSON()
  221. }()
  222. sysUser := this.User
  223. if sysUser == nil {
  224. br.Msg = "请登录"
  225. br.ErrMsg = "请登录,SysUser Is Empty"
  226. br.Ret = 408
  227. return
  228. }
  229. var req models.CygxYanxuanSpecialReq
  230. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  231. if err != nil {
  232. br.Msg = "参数解析异常!"
  233. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  234. return
  235. }
  236. if req.Content == "" {
  237. br.Msg = "请输入内容"
  238. return
  239. }
  240. if req.Tags == "" {
  241. br.Msg = "请至少输入一个标签"
  242. return
  243. }
  244. item := models.CygxYanxuanSpecial{
  245. Id: req.Id,
  246. UserId: sysUser.UserId,
  247. CreateTime: time.Now(),
  248. ModifyTime: time.Now(),
  249. PublishTime: time.Now(),
  250. Content: req.Content,
  251. Tags: req.Tags,
  252. ImgUrl: req.ImgUrl,
  253. DocUrl: req.DocUrl,
  254. Title: req.Title,
  255. Type: req.Type,
  256. }
  257. if req.DoType == 1 {
  258. item.Status = 1
  259. } else {
  260. item.Status = 2
  261. }
  262. errCode := models.WxCheckContent(req.Content)
  263. if errCode != 0 {
  264. br.Msg = "文章内容含有违法违规内容"
  265. br.ErrMsg = "文章内容含有违法违规内容"
  266. return
  267. }
  268. if req.Id == 0 {
  269. _, err = models.AddCygxYanxuanSpecial(&item)
  270. if err != nil {
  271. br.Msg = "新增失败"
  272. br.ErrMsg = "新增失败,Err:" + err.Error()
  273. return
  274. }
  275. } else {
  276. err = models.UpdateYanxuanSpecial(&item)
  277. if err != nil {
  278. br.Msg = "保存失败"
  279. br.ErrMsg = "保存失败,Err:" + err.Error()
  280. return
  281. }
  282. }
  283. br.Ret = 200
  284. br.Success = true
  285. br.Msg = "保存成功"
  286. }
  287. // @Title 专栏作者详情
  288. // @Description 专栏作者详情
  289. // @Param request body help_doc.AddHelpDocReq true "type json string"
  290. // @Success 200 {object} models.AddEnglishReportResp
  291. // @router /author/detail [get]
  292. func (this *YanxuanSpecialController) AuthorDetail() {
  293. br := new(models.BaseResponse).Init()
  294. defer func() {
  295. this.Data["json"] = br
  296. this.ServeJSON()
  297. }()
  298. sysUser := this.User
  299. if sysUser == nil {
  300. br.Msg = "请登录"
  301. br.ErrMsg = "请登录,SysUser Is Empty"
  302. br.Ret = 408
  303. return
  304. }
  305. userId, _ := this.GetInt("UserId", 0)
  306. if userId == 0 {
  307. userId = sysUser.UserId
  308. }
  309. item, tmpErr := models.GetYanxuanSpecialAuthor(userId, sysUser.UserId)
  310. if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
  311. br.Msg = "获取失败"
  312. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  313. return
  314. }
  315. br.Data = item
  316. br.Ret = 200
  317. br.Success = true
  318. br.Msg = "获取成功"
  319. }
  320. // @Title 审批研选专栏
  321. // @Description 审批研选专栏
  322. // @Param request body help_doc.AddHelpDocReq true "type json string"
  323. // @Success 200 {object} models.AddEnglishReportResp
  324. // @router /enable [post]
  325. func (this *YanxuanSpecialController) Enable() {
  326. br := new(models.BaseResponse).Init()
  327. defer func() {
  328. this.Data["json"] = br
  329. this.ServeJSON()
  330. }()
  331. sysUser := this.User
  332. if sysUser == nil {
  333. br.Msg = "请登录"
  334. br.ErrMsg = "请登录,SysUser Is Empty"
  335. br.Ret = 408
  336. return
  337. }
  338. var req models.EnableCygxYanxuanSpecialReq
  339. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  340. if err != nil {
  341. br.Msg = "参数解析异常!"
  342. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  343. return
  344. }
  345. if req.Id <= 0 {
  346. br.Msg = "文章id错误"
  347. return
  348. }
  349. if req.Status <= 0 {
  350. br.Msg = "参数错误"
  351. return
  352. }
  353. status := 0
  354. if req.Status == 1 {
  355. status = 3
  356. } else {
  357. status = 4
  358. }
  359. if tmpErr := models.EnableYanxuanSpecial(req.Id, status, req.Reason); tmpErr != nil {
  360. br.Msg = "审批失败"
  361. br.ErrMsg = "审批失败, Err:" + tmpErr.Error()
  362. return
  363. }
  364. br.Msg = "审批成功"
  365. br.Ret = 200
  366. br.Success = true
  367. }
  368. // @Title 研选专栏收藏
  369. // @Description 研选专栏收藏
  370. // @Param request body help_doc.AddHelpDocReq true "type json string"
  371. // @Success 200 {object} models.AddEnglishReportResp
  372. // @router /collect [post]
  373. func (this *YanxuanSpecialController) Collect() {
  374. br := new(models.BaseResponse).Init()
  375. defer func() {
  376. this.Data["json"] = br
  377. this.ServeJSON()
  378. }()
  379. sysUser := this.User
  380. if sysUser == nil {
  381. br.Msg = "请登录"
  382. br.ErrMsg = "请登录,SysUser Is Empty"
  383. br.Ret = 408
  384. return
  385. }
  386. var req models.CollectCygxYanxuanSpecialReq
  387. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  388. if err != nil {
  389. br.Msg = "参数解析异常!"
  390. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  391. return
  392. }
  393. if req.Id <= 0 {
  394. br.Msg = "文章id错误"
  395. return
  396. }
  397. if req.Status <= 0 {
  398. br.Msg = "参数错误"
  399. return
  400. }
  401. var sellerName string
  402. sellerName, err = models.GetCompanySellerName(sysUser.CompanyId)
  403. if err != nil {
  404. br.Msg = "报名失败!"
  405. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  406. return
  407. }
  408. if req.Status == 1 {
  409. item := models.CygxYanxuanSpecialCollect{
  410. UserId: sysUser.UserId,
  411. Mobile: sysUser.Mobile,
  412. Email: sysUser.Email,
  413. CompanyId: sysUser.CompanyId,
  414. CompanyName: sysUser.CompanyName,
  415. RealName: sysUser.RealName,
  416. SellerName: sellerName,
  417. CreateTime: time.Now(),
  418. ModifyTime: time.Now(),
  419. RegisterPlatform: utils.REGISTER_PLATFORM,
  420. YanxuanSpecialId: req.Id,
  421. }
  422. _, err = models.AddCygxYanxuanSpecialCollect(&item)
  423. if err != nil {
  424. br.Msg = "新增失败"
  425. br.ErrMsg = "新增失败,Err:" + err.Error()
  426. return
  427. }
  428. br.Msg = "收藏成功"
  429. } else {
  430. err = models.DelCygxYanxuanSpecialCollect(sysUser.UserId, req.Id)
  431. if err != nil {
  432. br.Msg = "删除失败"
  433. br.ErrMsg = "删除失败,Err:" + err.Error()
  434. return
  435. }
  436. br.Msg = "取消收藏成功"
  437. }
  438. br.Ret = 200
  439. br.Success = true
  440. }
  441. // @Title 专栏内容中心
  442. // @Description 专栏内容中心
  443. // @Param request body help_doc.AddHelpDocReq true "type json string"
  444. // @Success 200 {object} models.AddEnglishReportResp
  445. // @router /center [get]
  446. func (this *YanxuanSpecialController) Center() {
  447. br := new(models.BaseResponse).Init()
  448. defer func() {
  449. this.Data["json"] = br
  450. this.ServeJSON()
  451. }()
  452. sysUser := this.User
  453. if sysUser == nil {
  454. br.Msg = "请登录"
  455. br.ErrMsg = "请登录,SysUser Is Empty"
  456. br.Ret = 408
  457. return
  458. }
  459. // 1:未发布,2:审核中 3:已发布 4:驳回
  460. status, _ := this.GetInt("Status", 0)
  461. if status <= 0 {
  462. br.Msg = "参数错误"
  463. br.ErrMsg = "参数错误"
  464. return
  465. }
  466. var condition string
  467. var pars []interface{}
  468. condition += ` AND a.user_id = ? `
  469. pars = append(pars, sysUser.UserId)
  470. condition += ` AND a.status = ? `
  471. pars = append(pars, status)
  472. list, tmpErr := models.GetYanxuanSpecialList(sysUser.UserId, condition, pars)
  473. if tmpErr != nil {
  474. br.Msg = "获取失败"
  475. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  476. return
  477. }
  478. br.Data = list
  479. br.Ret = 200
  480. br.Success = true
  481. br.Msg = "获取成功"
  482. }
  483. // @Title 专栏点击记录
  484. // @Description 专栏点击记录
  485. // @Param request body models.AddCygxReportSelectionSubjectHistoryReq true "type json string"
  486. // @router /record [post]
  487. func (this *YanxuanSpecialController) Record() {
  488. br := new(models.BaseResponse).Init()
  489. defer func() {
  490. this.Data["json"] = br
  491. this.ServeJSON()
  492. }()
  493. user := this.User
  494. if user == nil {
  495. br.Msg = "请重新登录"
  496. br.Ret = 408
  497. return
  498. }
  499. var req models.AddCygxYanxuanSpecialRecordReq
  500. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  501. if err != nil {
  502. br.Msg = "参数解析异常!"
  503. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  504. return
  505. }
  506. if req.SpecialId <= 0 {
  507. br.Msg = "文章不存在"
  508. br.ErrMsg = "文章不存在,文章ID错误"
  509. return
  510. }
  511. var sellerName string
  512. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  513. if err != nil {
  514. br.Msg = "报名失败!"
  515. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  516. return
  517. }
  518. item := models.CygxYanxuanSpecialRecord{
  519. UserId: user.UserId,
  520. Mobile: user.Mobile,
  521. Email: user.Email,
  522. CompanyId: user.CompanyId,
  523. CompanyName: user.CompanyName,
  524. RealName: user.RealName,
  525. SellerName: sellerName,
  526. CreateTime: time.Now(),
  527. ModifyTime: time.Now(),
  528. RegisterPlatform: utils.REGISTER_PLATFORM,
  529. YanxuanSpecialId: req.SpecialId,
  530. }
  531. _, err = models.AddCygxYanxuanSpecialRecord(&item)
  532. if err != nil {
  533. br.Msg = "记录失败"
  534. br.ErrMsg = "记录失败,Err:" + err.Error()
  535. return
  536. }
  537. br.Ret = 200
  538. br.Success = true
  539. br.Msg = "记录成功"
  540. }
  541. // @Title 研选专栏关注
  542. // @Description 研选专栏关注
  543. // @Param request body help_doc.AddHelpDocReq true "type json string"
  544. // @Success 200 {object} models.AddEnglishReportResp
  545. // @router /follow [post]
  546. func (this *YanxuanSpecialController) Follow() {
  547. br := new(models.BaseResponse).Init()
  548. defer func() {
  549. this.Data["json"] = br
  550. this.ServeJSON()
  551. }()
  552. sysUser := this.User
  553. if sysUser == nil {
  554. br.Msg = "请登录"
  555. br.ErrMsg = "请登录,SysUser Is Empty"
  556. br.Ret = 408
  557. return
  558. }
  559. var req models.FollowCygxYanxuanSpecialReq
  560. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  561. if err != nil {
  562. br.Msg = "参数解析异常!"
  563. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  564. return
  565. }
  566. if req.FollowUserId <= 0 {
  567. br.Msg = "被关注的用户id"
  568. return
  569. }
  570. if req.Status <= 0 {
  571. br.Msg = "参数错误"
  572. return
  573. }
  574. var sellerName string
  575. sellerName, err = models.GetCompanySellerName(sysUser.CompanyId)
  576. if err != nil {
  577. br.Msg = "报名失败!"
  578. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  579. return
  580. }
  581. if req.Status == 1 {
  582. item := models.CygxYanxuanSpecialFollow{
  583. UserId: sysUser.UserId,
  584. FollowUserId: req.FollowUserId,
  585. Mobile: sysUser.Mobile,
  586. Email: sysUser.Email,
  587. CompanyId: sysUser.CompanyId,
  588. CompanyName: sysUser.CompanyName,
  589. RealName: sysUser.RealName,
  590. SellerName: sellerName,
  591. CreateTime: time.Now(),
  592. ModifyTime: time.Now(),
  593. RegisterPlatform: utils.REGISTER_PLATFORM,
  594. YanxuanSpecialId: req.SpecialId,
  595. }
  596. err = models.AddCygxYanxuanSpecialFollow(&item)
  597. if err != nil {
  598. br.Msg = "新增失败"
  599. br.ErrMsg = "新增失败,Err:" + err.Error()
  600. return
  601. }
  602. br.Msg = "关注成功"
  603. } else {
  604. err = models.DelCygxYanxuanSpecialFollow(sysUser.UserId, req.FollowUserId)
  605. if err != nil {
  606. br.Msg = "删除失败"
  607. br.ErrMsg = "删除失败,Err:" + err.Error()
  608. return
  609. }
  610. br.Msg = "取消关注成功"
  611. }
  612. br.Ret = 200
  613. br.Success = true
  614. }
  615. // @Title 行业标签搜索
  616. // @Description 行业标签搜索
  617. // @Param request body help_doc.AddHelpDocReq true "type json string"
  618. // @Success 200 {object} models.AddEnglishReportResp
  619. // @router /industrySearch [get]
  620. func (this *YanxuanSpecialController) IndustrySearch() {
  621. br := new(models.BaseResponse).Init()
  622. defer func() {
  623. this.Data["json"] = br
  624. this.ServeJSON()
  625. }()
  626. sysUser := this.User
  627. if sysUser == nil {
  628. br.Msg = "请登录"
  629. br.ErrMsg = "请登录,SysUser Is Empty"
  630. br.Ret = 408
  631. return
  632. }
  633. keyword := this.GetString("Keyword")
  634. list, tmpErr := models.GetYanxuanSpecialIndustry(keyword)
  635. if tmpErr != nil {
  636. br.Msg = "获取失败"
  637. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  638. return
  639. }
  640. br.Data = list
  641. br.Ret = 200
  642. br.Success = true
  643. br.Msg = "获取成功"
  644. }
  645. // @Title 公司标签搜索
  646. // @Description 公司标签搜索
  647. // @Param request body help_doc.AddHelpDocReq true "type json string"
  648. // @Success 200 {object} models.AddEnglishReportResp
  649. // @router /companySearch [get]
  650. func (this *YanxuanSpecialController) CompanySearch() {
  651. br := new(models.BaseResponse).Init()
  652. defer func() {
  653. this.Data["json"] = br
  654. this.ServeJSON()
  655. }()
  656. sysUser := this.User
  657. if sysUser == nil {
  658. br.Msg = "请登录"
  659. br.ErrMsg = "请登录,SysUser Is Empty"
  660. br.Ret = 408
  661. return
  662. }
  663. keyword := this.GetString("Keyword")
  664. if keyword == "" {
  665. br.Ret = 200
  666. return
  667. }
  668. list, tmpErr := models.GetYanxuanSpecialCompany(keyword)
  669. if tmpErr != nil {
  670. br.Msg = "获取失败"
  671. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  672. return
  673. }
  674. br.Data = list
  675. br.Ret = 200
  676. br.Success = true
  677. br.Msg = "获取成功"
  678. }
  679. // @Title 专栏取消发布
  680. // @Description 专栏取消发布
  681. // @Param request body help_doc.AddHelpDocReq true "type json string"
  682. // @Success 200 {object} models.AddEnglishReportResp
  683. // @router /cancel [post]
  684. func (this *YanxuanSpecialController) Cancel() {
  685. br := new(models.BaseResponse).Init()
  686. defer func() {
  687. this.Data["json"] = br
  688. this.ServeJSON()
  689. }()
  690. sysUser := this.User
  691. if sysUser == nil {
  692. br.Msg = "请登录"
  693. br.ErrMsg = "请登录,SysUser Is Empty"
  694. br.Ret = 408
  695. return
  696. }
  697. var req models.CancelPublishCygxYanxuanSpecialReq
  698. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  699. if err != nil {
  700. br.Msg = "参数解析异常!"
  701. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  702. return
  703. }
  704. if req.Id <= 0 {
  705. br.Msg = "文章id错误"
  706. return
  707. }
  708. if tmpErr := models.CancelPublishYanxuanSpecial(req.Id); tmpErr != nil {
  709. br.Msg = "取消发布失败"
  710. br.ErrMsg = "取消发布失败, Err:" + tmpErr.Error()
  711. return
  712. }
  713. br.Msg = "取消发布成功"
  714. br.Ret = 200
  715. br.Success = true
  716. }
  717. // @Title 作者列表
  718. // @Description 作者列表
  719. // @Param request body help_doc.AddHelpDocReq true "type json string"
  720. // @Success 200 {object} models.AddEnglishReportResp
  721. // @router /author/list [get]
  722. func (this *YanxuanSpecialController) AuthorList() {
  723. br := new(models.BaseResponse).Init()
  724. defer func() {
  725. this.Data["json"] = br
  726. this.ServeJSON()
  727. }()
  728. sysUser := this.User
  729. if sysUser == nil {
  730. br.Msg = "请登录"
  731. br.ErrMsg = "请登录,SysUser Is Empty"
  732. br.Ret = 408
  733. return
  734. }
  735. var specialUser *models.CygxYanxuanSpecialAuthorItem
  736. var err error
  737. specialUser, err = models.GetYanxuanSpecialAuthor(sysUser.UserId, sysUser.UserId)
  738. if err != nil && err.Error() != utils.ErrNoRow() {
  739. br.Msg = "获取失败"
  740. br.ErrMsg = "获取失败, Err:" + err.Error()
  741. return
  742. }
  743. list, tmpErr := models.GetYanxuanSpecialAuthorList()
  744. if tmpErr != nil {
  745. br.Msg = "获取失败"
  746. br.ErrMsg = "获取失败, Err:" + tmpErr.Error()
  747. return
  748. }
  749. resp := new(models.SpecialAuthorListResp)
  750. if specialUser != nil {
  751. resp.IsAuthor = true
  752. }
  753. resp.List = list
  754. br.Data = resp
  755. br.Ret = 200
  756. br.Success = true
  757. br.Msg = "获取成功"
  758. }
  759. // @Title 更新作者头像
  760. // @Description 更新作者头像
  761. // @Param request body help_doc.AddHelpDocReq true "type json string"
  762. // @Success 200 {object} models.AddEnglishReportResp
  763. // @router /author/head_img [post]
  764. func (this *YanxuanSpecialController) AuthorHeadImg() {
  765. br := new(models.BaseResponse).Init()
  766. defer func() {
  767. this.Data["json"] = br
  768. this.ServeJSON()
  769. }()
  770. sysUser := this.User
  771. if sysUser == nil {
  772. br.Msg = "请登录"
  773. br.ErrMsg = "请登录,SysUser Is Empty"
  774. br.Ret = 408
  775. return
  776. }
  777. var req models.SaveCygxYanxuanSpecialAuthoHeadImgrReq
  778. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  779. if err != nil {
  780. br.Msg = "参数解析异常!"
  781. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  782. return
  783. }
  784. if req.UserId <= 0 {
  785. br.Msg = "用户id有误"
  786. return
  787. }
  788. if req.HeadImg == "" {
  789. br.Msg = "头像图片错误"
  790. return
  791. }
  792. item := models.CygxYanxuanSpecialAuthor{
  793. UserId: req.UserId,
  794. HeadImg: req.HeadImg,
  795. }
  796. err = models.UpdateYanxuanSpecialAuthorHeadImg(&item)
  797. if err != nil {
  798. br.Msg = "保存失败"
  799. br.ErrMsg = "保存失败,Err:" + err.Error()
  800. return
  801. }
  802. br.Ret = 200
  803. br.Success = true
  804. br.Msg = "保存成功"
  805. }
  806. // @Title 删除专栏
  807. // @Description 删除专栏
  808. // @Param request body help_doc.AddHelpDocReq true "type json string"
  809. // @Success 200 {object} models.AddEnglishReportResp
  810. // @router /del [post]
  811. func (this *YanxuanSpecialController) Delete() {
  812. br := new(models.BaseResponse).Init()
  813. defer func() {
  814. this.Data["json"] = br
  815. this.ServeJSON()
  816. }()
  817. sysUser := this.User
  818. if sysUser == nil {
  819. br.Msg = "请登录"
  820. br.ErrMsg = "请登录,SysUser Is Empty"
  821. br.Ret = 408
  822. return
  823. }
  824. var req models.EnableCygxYanxuanSpecialReq
  825. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  826. if err != nil {
  827. br.Msg = "参数解析异常!"
  828. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  829. return
  830. }
  831. if req.Id <= 0 {
  832. br.Msg = "文章id错误"
  833. return
  834. }
  835. if tmpErr := models.DelYanxuanSpecial(req.Id); tmpErr != nil {
  836. br.Msg = "删除失败"
  837. br.ErrMsg = "删除失败, Err:" + tmpErr.Error()
  838. return
  839. }
  840. br.Msg = "删除成功"
  841. br.Ret = 200
  842. br.Success = true
  843. }