research.go 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537
  1. package controllers
  2. import (
  3. "github.com/rdlucklib/rdluck_tools/paging"
  4. "hongze/hongze_cygx/models"
  5. "hongze/hongze_cygx/utils"
  6. "strconv"
  7. )
  8. //研选
  9. type ResearchController struct {
  10. BaseAuthController
  11. }
  12. // @Title 近期更新主题列表
  13. // @Description 近期更新主题列表接口
  14. // @Param ChartPermissionId query int true "分类ID"
  15. // @Success 200 {object} models.IndustrialManagementNewList
  16. // @router /theme/newList [get]
  17. func (this *ResearchController) NewList() {
  18. br := new(models.BaseResponse).Init()
  19. defer func() {
  20. this.Data["json"] = br
  21. this.ServeJSON()
  22. }()
  23. user := this.User
  24. if user == nil {
  25. br.Msg = "请重新登录"
  26. br.Ret = 408
  27. return
  28. }
  29. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  30. if chartPermissionId < 1 {
  31. br.Msg = "请输入分类ID"
  32. return
  33. }
  34. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  35. if err != nil {
  36. br.Msg = "获取信息失败"
  37. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  38. return
  39. }
  40. list, err := models.GetIndustrialManagementNewList(categoryinfo.PermissionName)
  41. if err != nil {
  42. br.Msg = "获取信息失败"
  43. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  44. return
  45. }
  46. mapHot := make(map[string]int)
  47. condition := ` ORDER BY sum_num DESC `
  48. listHot, err := models.GetThemeHeatList(categoryinfo.PermissionName, user.UserId, condition, 0, 3)
  49. if err != nil {
  50. br.Msg = "获取信息失败"
  51. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  52. return
  53. }
  54. for _, v := range listHot {
  55. mapHot[v.IndustryName] = v.IndustrialManagementId
  56. }
  57. for k, v := range list {
  58. if mapHot[v.IndustryName] > 0 {
  59. list[k].IsHot = true
  60. }
  61. }
  62. resp := new(models.IndustrialManagementNewList)
  63. resp.List = list
  64. br.Ret = 200
  65. br.Success = true
  66. br.Msg = "获取成功"
  67. br.Data = resp
  68. }
  69. // @Title 用户收藏列表
  70. // @Description 用户收藏列表接口
  71. // @Param ChartPermissionId query int true "分类ID"
  72. // @Success 200 {object} models.ArticleCollectionLIstResp
  73. // @router /collectionList [get]
  74. func (this *ResearchController) CollectionList() {
  75. br := new(models.BaseResponse).Init()
  76. defer func() {
  77. this.Data["json"] = br
  78. this.ServeJSON()
  79. }()
  80. user := this.User
  81. if user == nil {
  82. br.Msg = "请重新登录"
  83. br.Ret = 408
  84. return
  85. }
  86. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  87. if chartPermissionId < 1 {
  88. br.Msg = "请输入分类ID"
  89. return
  90. }
  91. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  92. if err != nil {
  93. br.Msg = "获取信息失败"
  94. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  95. return
  96. }
  97. var condition string
  98. condition = ` AND a.category_name LIKE '%` + categoryinfo.PermissionName + `%' AND publish_status = 1 GROUP BY a.article_id ORDER BY collect_num_order DESC, publish_date DESC LIMIT 15 `
  99. list, err := models.GetArticleCollectionList(condition, user.UserId)
  100. if err != nil {
  101. br.Msg = "获取信息失败"
  102. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  103. return
  104. }
  105. for k, v := range list {
  106. if v.MyCollectNum > 0 {
  107. list[k].IsCollect = true
  108. }
  109. }
  110. resp := new(models.ArticleCollectionLIstResp)
  111. resp.List = list
  112. br.Ret = 200
  113. br.Success = true
  114. br.Msg = "获取成功"
  115. br.Data = resp
  116. }
  117. // @Title 主题热度/近期更新更多,列表
  118. // @Description 主题热度/近期更新更多,列表接口
  119. // @Param ChartPermissionId query int true "分类ID"
  120. // @Param ThemeType query int true "主题类型,1主题热度、2近期更新 默认1"
  121. // @Param PageSize query int true "每页数据条数"
  122. // @Param CurrentIndex query int true "当前页页码,从1开始"
  123. // @Success 200 {object} models.IndustrialManagementHotListResp
  124. // @router /hotList [get]
  125. func (this *ResearchController) HotList() {
  126. br := new(models.BaseResponse).Init()
  127. defer func() {
  128. this.Data["json"] = br
  129. this.ServeJSON()
  130. }()
  131. user := this.User
  132. if user == nil {
  133. br.Msg = "请重新登录"
  134. br.Ret = 408
  135. return
  136. }
  137. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  138. themeType, _ := this.GetInt("ThemeType")
  139. if chartPermissionId < 1 {
  140. br.Msg = "请输入分类ID"
  141. return
  142. }
  143. pageSize, _ := this.GetInt("PageSize")
  144. currentIndex, _ := this.GetInt("CurrentIndex")
  145. var startSize int
  146. if pageSize <= 0 {
  147. pageSize = utils.PageSize15
  148. }
  149. if currentIndex <= 0 {
  150. currentIndex = 1
  151. }
  152. startSize = utils.StartIndex(currentIndex, pageSize)
  153. var condition string
  154. if themeType != 2 {
  155. condition = `ORDER BY sum_num DESC `
  156. } else {
  157. condition = `ORDER BY publish_date DESC `
  158. }
  159. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  160. if err != nil {
  161. br.Msg = "获取信息失败"
  162. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  163. return
  164. }
  165. total, err := models.GetThemeHeatListCount(categoryinfo.PermissionName, "")
  166. if err != nil {
  167. br.Msg = "获取失败"
  168. br.ErrMsg = "获取失败,Err:" + err.Error()
  169. return
  170. }
  171. list, err := models.GetThemeHeatList(categoryinfo.PermissionName, user.UserId, condition, startSize, pageSize)
  172. if err != nil {
  173. br.Msg = "获取信息失败"
  174. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  175. return
  176. }
  177. newMap := make(map[int]string)
  178. listNew, err := models.GetIndustrialManagementNewList(categoryinfo.PermissionName)
  179. if err != nil {
  180. br.Msg = "获取信息失败"
  181. br.ErrMsg = "获取产业最新信息失败,Err:" + err.Error()
  182. return
  183. }
  184. for _, v := range listNew {
  185. newMap[v.IndustrialManagementId] = v.IndustryName
  186. }
  187. condition = ` AND a.category_name LIKE '%` + categoryinfo.PermissionName + `%' `
  188. listSubjcet, err := models.GetThemeHeatSubjectList(condition)
  189. if err != nil {
  190. br.Msg = "获取信息失败"
  191. br.ErrMsg = "获取标的信息失败,Err:" + err.Error()
  192. return
  193. }
  194. mapHot := make(map[string]int)
  195. condition = ` ORDER BY sum_num DESC `
  196. listHot, err := models.GetThemeHeatList(categoryinfo.PermissionName, user.UserId, condition, 0, 3)
  197. if err != nil {
  198. br.Msg = "获取信息失败"
  199. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  200. return
  201. }
  202. for _, v := range listHot {
  203. mapHot[v.IndustryName] = v.IndustrialManagementId
  204. }
  205. for k, v := range list {
  206. if newMap[v.IndustrialManagementId] != "" {
  207. list[k].IsNew = true
  208. }
  209. if v.FllowNum > 0 {
  210. list[k].IsFollw = true
  211. }
  212. for _, v2 := range listSubjcet {
  213. if v2.IndustrialManagementId == v.IndustrialManagementId {
  214. list[k].IndustrialSubjectList = append(list[k].IndustrialSubjectList, v2)
  215. }
  216. }
  217. if mapHot[v.IndustryName] > 0 {
  218. list[k].IsHot = true
  219. }
  220. }
  221. page := paging.GetPaging(currentIndex, pageSize, total)
  222. resp := new(models.IndustrialManagementHotListResp)
  223. resp.Paging = page
  224. resp.List = list
  225. br.Ret = 200
  226. br.Success = true
  227. br.Msg = "获取成功"
  228. br.Data = resp
  229. }
  230. // @Title KOL榜列表
  231. // @Description KOL榜列表接口
  232. // @Param ChartPermissionId query int true "分类ID"
  233. // @Success 200 {object} models.DepartmentListResp
  234. // @router /kolList [get]
  235. func (this *ResearchController) KolList() {
  236. br := new(models.BaseResponse).Init()
  237. defer func() {
  238. this.Data["json"] = br
  239. this.ServeJSON()
  240. }()
  241. user := this.User
  242. if user == nil {
  243. br.Msg = "请重新登录"
  244. br.Ret = 408
  245. return
  246. }
  247. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  248. if chartPermissionId < 1 {
  249. br.Msg = "请输入分类ID"
  250. return
  251. }
  252. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  253. if err != nil {
  254. br.Msg = "获取信息失败"
  255. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  256. return
  257. }
  258. list, err := models.GetDepartmentList(categoryinfo.PermissionName, user.UserId)
  259. if err != nil {
  260. br.Msg = "获取信息失败"
  261. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  262. return
  263. }
  264. listIndustrial, err := models.GetIndustrialDepartmentList(categoryinfo.PermissionName)
  265. if err != nil {
  266. br.Msg = "获取信息失败"
  267. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  268. return
  269. }
  270. departmentMap := make(map[string]string)
  271. for k, v := range list {
  272. if v.FllowNum > 0 {
  273. list[k].IsFollw = true
  274. }
  275. for _, v2 := range listIndustrial {
  276. if v2.DepartmentId == v.DepartmentId {
  277. if departmentMap["D"+strconv.Itoa(v2.DepartmentId)+"In"+strconv.Itoa(v2.IndustrialManagementId)] == "" && len(list[k].List) < 4 {
  278. list[k].List = append(list[k].List, v2)
  279. departmentMap["D"+strconv.Itoa(v2.DepartmentId)+"In"+strconv.Itoa(v2.IndustrialManagementId)] = v.NickName
  280. }
  281. }
  282. }
  283. }
  284. resp := new(models.DepartmentListResp)
  285. resp.List = list
  286. br.Ret = 200
  287. br.Success = true
  288. br.Msg = "获取成功"
  289. br.Data = resp
  290. }
  291. // @Title 主题详情
  292. // @Description 主题详情接口
  293. // @Param IndustrialManagementId query int true "分类ID"
  294. // @Success 200 {object} models.GetThemeDetailResp
  295. // @router /theme/detail [get]
  296. func (this *ResearchController) ThemeDetail() {
  297. br := new(models.BaseResponse).Init()
  298. defer func() {
  299. this.Data["json"] = br
  300. this.ServeJSON()
  301. }()
  302. user := this.User
  303. if user == nil {
  304. br.Msg = "请重新登录"
  305. br.Ret = 408
  306. return
  307. }
  308. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  309. if industrialManagementId < 1 {
  310. br.Msg = "请输入产业ID"
  311. return
  312. }
  313. resp := new(models.GetThemeDetailResp)
  314. list, err := models.GetThemeDetail(user.UserId, industrialManagementId)
  315. if err != nil {
  316. br.Msg = "获取信息失败"
  317. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  318. return
  319. }
  320. var itemsNull []*models.GetThemeAericleListResp
  321. subjectMap := make(map[string]string)
  322. articleMap := make(map[int]int)
  323. for _, v := range list {
  324. resp.IndustryName = v.IndustryName
  325. resp.IndustrialManagementId = v.IndustrialManagementId
  326. itemSubJect := new(models.IndustrialSubject)
  327. itemSubJect.SubjectName = v.SubjectName
  328. itemSubJect.IndustrialSubjectId = v.IndustrialSubjectId
  329. if subjectMap[v.SubjectName] == "" && v.SubjectName != "" {
  330. resp.ListSubject = append(resp.ListSubject, itemSubJect)
  331. }
  332. subjectMap[v.SubjectName] = v.IndustryName
  333. if v.FllowNum > 0 {
  334. resp.IsFollw = true
  335. }
  336. if v.SubjectName == "" {
  337. item := new(models.GetThemeAericleListResp)
  338. item.ArticleId = v.ArticleId
  339. item.Title = v.Title
  340. item.PublishDate = v.PublishDate
  341. item.SubjectName = v.SubjectName
  342. item.DepartmentId = v.DepartmentId
  343. item.NickName = v.NickName
  344. item.Pv = v.Pv
  345. item.CollectNum = v.CollectNum
  346. itemsNull = append(itemsNull, item)
  347. }
  348. }
  349. for _, v := range resp.ListSubject {
  350. subjetcGroup := new(models.GetThemeAericleListBuSubjectResp)
  351. for _, v2 := range list {
  352. if v2.IndustrialSubjectId == v.IndustrialSubjectId && articleMap[v2.ArticleId] == 0 {
  353. item := new(models.GetThemeAericleListResp)
  354. item.ArticleId = v2.ArticleId
  355. item.Title = v2.Title
  356. item.PublishDate = v2.PublishDate
  357. item.SubjectName = v2.SubjectName
  358. item.IndustrialSubjectId = v2.IndustrialSubjectId
  359. for _, v3 := range list {
  360. if v3.ArticleId == v2.ArticleId && v3.SubjectName != v2.SubjectName && v3.SubjectName != "" {
  361. item.SubjectName += "/" + v3.SubjectName
  362. }
  363. }
  364. item.DepartmentId = v2.DepartmentId
  365. item.NickName = v2.NickName
  366. item.Pv = v2.Pv
  367. item.CollectNum = v2.CollectNum
  368. item.MyCollectNum = v2.MyCollectNum
  369. if v2.MyCollectNum > 0 {
  370. item.IsCollect = true
  371. }
  372. resp.List = append(resp.List, item)
  373. articleMap[v2.ArticleId] = v2.ArticleId
  374. //subjetcGroup.List = append(subjetcGroup.List, item)
  375. }
  376. subjetcGroup.SubjectName = v.SubjectName
  377. }
  378. }
  379. //当标的为空时进行合并
  380. if len(itemsNull) > 0 {
  381. for _, v := range itemsNull {
  382. resp.List = append(resp.List, v)
  383. }
  384. }
  385. br.Ret = 200
  386. br.Success = true
  387. br.Msg = "获取成功"
  388. br.Data = resp
  389. }
  390. // @Title 研选作者详情
  391. // @Description 研选作者详情接口
  392. // @Param DepartmentId query int true "作者ID"
  393. // @Success 200 {object} models.DepartmentDetailResp
  394. // @router /departmentId/detail [get]
  395. func (this *ResearchController) DepartmentIdDetail() {
  396. br := new(models.BaseResponse).Init()
  397. defer func() {
  398. this.Data["json"] = br
  399. this.ServeJSON()
  400. }()
  401. user := this.User
  402. if user == nil {
  403. br.Msg = "请重新登录"
  404. br.Ret = 408
  405. return
  406. }
  407. departmentId, _ := this.GetInt("DepartmentId")
  408. if departmentId < 1 {
  409. br.Msg = "请输入作者ID"
  410. return
  411. }
  412. resp := new(models.DepartmentDetailResp)
  413. detail, err := models.GetDepartmentDetail(user.UserId, departmentId)
  414. if err != nil {
  415. br.Msg = "获取信息失败"
  416. br.ErrMsg = "获取作者信息失败,Err:" + err.Error()
  417. return
  418. }
  419. resp.DepartmentId = detail.DepartmentId
  420. resp.NickName = detail.NickName
  421. resp.ImgUrl = detail.ImgUrl
  422. resp.FllowNum = detail.FllowNum
  423. resp.ArticleNum = detail.ArticleNum
  424. resp.CollectNum = detail.CollectNum
  425. if detail.MyFllowNum > 0 {
  426. resp.IsFllow = true
  427. }
  428. var condition string
  429. condition = ` AND a.department_id = ` + strconv.Itoa(departmentId) + ` ORDER BY a.publish_date DESC `
  430. list, err := models.GetArticleCollectionList(condition, user.UserId)
  431. if err != nil {
  432. br.Msg = "获取信息失败"
  433. br.ErrMsg = "获取文章列表失败,Err:" + err.Error()
  434. return
  435. }
  436. for k, v := range list {
  437. if v.MyCollectNum > 0 {
  438. list[k].IsCollect = true
  439. }
  440. }
  441. resp.List = list
  442. br.Ret = 200
  443. br.Success = true
  444. br.Msg = "获取成功"
  445. br.Data = resp
  446. }
  447. // @Title 文章相关热门收藏
  448. // @Description 文章相关热门收藏接口
  449. // @Param ArticleId query int true "文章ID"
  450. // @Success 200 {object} models.ArticleCollectionLIstResp
  451. // @router /article/hotList [get]
  452. func (this *ResearchController) ArticleHotList() {
  453. br := new(models.BaseResponse).Init()
  454. defer func() {
  455. this.Data["json"] = br
  456. this.ServeJSON()
  457. }()
  458. user := this.User
  459. if user == nil {
  460. br.Msg = "请重新登录"
  461. br.Ret = 408
  462. return
  463. }
  464. articleId, _ := this.GetInt("ArticleId")
  465. if articleId < 1 {
  466. br.Msg = "请输入分类ID"
  467. return
  468. }
  469. var condition string
  470. condition = ` AND a.article_id IN (SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id IN (SELECT industrial_management_id FROM cygx_industrial_article_group_management WHERE article_id = ` + strconv.Itoa(articleId) + ` ) ) AND a.article_id != ` + strconv.Itoa(articleId) + ` AND a.category_name LIKE '%研选%' AND publish_status = 1 GROUP BY a.article_id ORDER BY collect_num DESC, publish_date DESC LIMIT 3 `
  471. list, err := models.GetArticleCollectionList(condition, user.UserId)
  472. if err != nil {
  473. br.Msg = "获取信息失败"
  474. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  475. return
  476. }
  477. for k, v := range list {
  478. if v.MyCollectNum > 0 {
  479. list[k].IsCollect = true
  480. }
  481. }
  482. resp := new(models.ArticleCollectionLIstResp)
  483. resp.List = list
  484. br.Ret = 200
  485. br.Success = true
  486. br.Msg = "获取成功"
  487. br.Data = resp
  488. }
  489. // @Title 热搜关键词
  490. // @Description 热搜关键词接口
  491. // @Success 200 {object} models.UserSearchKeyWordListResp
  492. // @router /hotKeyWord [get]
  493. func (this *ResearchController) HotKeyWord() {
  494. br := new(models.BaseResponse).Init()
  495. defer func() {
  496. this.Data["json"] = br
  497. this.ServeJSON()
  498. }()
  499. user := this.User
  500. if user == nil {
  501. br.Msg = "请重新登录"
  502. br.Ret = 408
  503. return
  504. }
  505. //本来应该放在config控制器下,与未上线的代码冲突,所以放在这里
  506. list, err := models.GetUserSearchKeyWord()
  507. if err != nil {
  508. br.Msg = "获取信息失败"
  509. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  510. return
  511. }
  512. resp := new(models.UserSearchKeyWordListResp)
  513. resp.List = list
  514. br.Ret = 200
  515. br.Success = true
  516. br.Msg = "获取成功"
  517. br.Data = resp
  518. }