report_billboard.go 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274
  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. "strings"
  8. "time"
  9. )
  10. //报告榜单
  11. type ReportBillboardController struct {
  12. BaseAuthController
  13. }
  14. // @Title 报告榜单table栏
  15. // @Description 报告榜单table栏
  16. // @Success 200 {object} models.ReportBillboardTableListResp
  17. // @router /table/list [get]
  18. func (this *ReportBillboardController) CompanyTableList() {
  19. br := new(models.BaseResponse).Init()
  20. defer func() {
  21. this.Data["json"] = br
  22. this.ServeJSON()
  23. }()
  24. user := this.User
  25. if user == nil {
  26. br.Msg = "请重新登录"
  27. br.Ret = 408
  28. return
  29. }
  30. ListPermission := []*models.ChartPermission{{PermissionName: utils.YI_YAO_NAME, ChartPermissionId: utils.YI_YAO_ID}, {PermissionName: utils.XIAO_FEI_NAME, ChartPermissionId: utils.XIAO_FEI_ID}, {PermissionName: utils.KE_JI_NAME, ChartPermissionId: utils.KE_JI_ID}, {PermissionName: utils.ZHI_ZAO_NAME, ChartPermissionId: utils.ZHI_ZAO_ID}}
  31. ListAllPermission := []*models.ChartPermission{{PermissionName: utils.YI_YAO_NAME, ChartPermissionId: utils.YI_YAO_ID}, {PermissionName: utils.XIAO_FEI_NAME, ChartPermissionId: utils.XIAO_FEI_ID}, {PermissionName: utils.KE_JI_NAME, ChartPermissionId: utils.KE_JI_ID}, {PermissionName: utils.ZHI_ZAO_NAME, ChartPermissionId: utils.ZHI_ZAO_ID}, {PermissionName: utils.CE_LUE_NAME, ChartPermissionId: utils.CE_LUE_ID}}
  32. List := []*models.ReportBillboardTableResp{{Name: "产业关注", Source: 1, List: ListPermission}, {Name: "阅读飙升榜", Source: 2, List: ListPermission}, {Name: "报告收藏", Source: 3, List: ListAllPermission}}
  33. resp := new(models.ReportBillboardTableListResp)
  34. resp.List = List
  35. br.Ret = 200
  36. br.Success = true
  37. br.Msg = "获取成功"
  38. br.Data = resp
  39. }
  40. // @Title 产业关注榜
  41. // @Description 获取产业关注榜接口
  42. // @Param ChartPermissionId query int true "分类ID"
  43. // @Success 200 {object} models.IndustrialManagementList
  44. // @router /industry/fllowList [get]
  45. func (this *ReportBillboardController) FllowList() {
  46. br := new(models.BaseResponse).Init()
  47. defer func() {
  48. this.Data["json"] = br
  49. this.ServeJSON()
  50. }()
  51. user := this.User
  52. if user == nil {
  53. br.Msg = "请重新登录"
  54. br.Ret = 408
  55. return
  56. }
  57. uid := user.UserId
  58. pageSize, _ := this.GetInt("PageSize")
  59. currentIndex, _ := this.GetInt("CurrentIndex")
  60. var startSize int
  61. if pageSize <= 0 {
  62. pageSize = utils.PageSize15
  63. }
  64. if currentIndex <= 0 {
  65. currentIndex = 1
  66. }
  67. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  68. if chartPermissionId < 1 {
  69. br.Msg = "请输入行业ID"
  70. return
  71. }
  72. var condition string
  73. var pars []interface{}
  74. var orderSrt string
  75. var industrialManagementIds string
  76. condition += ` AND man.chart_permission_id = ? `
  77. pars = append(pars, chartPermissionId)
  78. orderSrt = " man.user_fllow_num DESC " // 排序方式
  79. list, err := models.GetIndustrialManagementFllowBillboard(pars, condition, orderSrt, startSize, pageSize)
  80. if err != nil {
  81. br.Msg = "获取失败"
  82. br.ErrMsg = "获取失败,GetIndustrialManagementFllowBillboard Err:" + err.Error()
  83. return
  84. }
  85. fllowList, err := models.GetUserFllowIndustrialList(uid)
  86. if err != nil {
  87. br.Msg = "获取失败"
  88. br.ErrMsg = "获取失败,GetUserFllowIndustrialList Err:" + err.Error()
  89. return
  90. }
  91. fllowMap := make(map[int]int)
  92. if len(fllowList) > 0 {
  93. for _, v := range fllowList {
  94. fllowMap[v.IndustrialManagementId] = uid
  95. }
  96. }
  97. for k, v := range list {
  98. if fllowMap[v.IndustrialManagementId] > 0 {
  99. list[k].IsFollow = 1
  100. }
  101. industrialManagementIds += strconv.Itoa(v.IndustrialManagementId) + ","
  102. }
  103. industrialManagementIds = strings.TrimRight(industrialManagementIds, ",")
  104. silceindustrialManagementIds := strings.Split(industrialManagementIds, ",")
  105. //获取关联的标的
  106. pars = make([]interface{}, 0)
  107. industrialIdList := make([]string, 0)
  108. for _, v := range silceindustrialManagementIds {
  109. industrialIdList = append(industrialIdList, v)
  110. }
  111. condition = `AND s.industrial_management_id IN ( ` + utils.GetOrmInReplace(len(silceindustrialManagementIds)) + ` ) `
  112. pars = append(pars, industrialIdList)
  113. subjectList, err := models.GetSubjectList(pars, condition)
  114. if err != nil {
  115. br.Msg = "获取失败"
  116. br.ErrMsg = "获取失败,GetSubjectList Err:" + err.Error()
  117. return
  118. }
  119. subjectMap := make(map[int][]*models.IndustrialSubject)
  120. if len(fllowList) > 0 {
  121. for _, v := range subjectList {
  122. item := new(models.IndustrialSubject)
  123. item.SubjectName = v.SubjectName
  124. item.IndustrialManagementId = v.IndustrialManagementId
  125. subjectMap[v.IndustrialManagementId] = append(subjectMap[v.IndustrialManagementId], item)
  126. }
  127. }
  128. for k, v := range list {
  129. list[k].IndustrialSubjectList = subjectMap[v.IndustrialManagementId]
  130. }
  131. page := paging.GetPaging(currentIndex, pageSize, len(list))
  132. resp := new(models.IndustrialManagementList)
  133. resp.List = list
  134. resp.Paging = page
  135. br.Ret = 200
  136. br.Success = true
  137. br.Msg = "获取成功"
  138. br.Data = resp
  139. }
  140. // @Title 阅读飙升榜/报告收藏榜
  141. // @Description 获取阅读飙升榜/报告收藏榜接口
  142. // @Param ChartPermissionId query int true "分类ID"
  143. // @Param Source query int true "来源 2:阅读飙升 ,3:报告收藏"
  144. // @Success 200 {object} models.ArticleReportBillboardLIstResp
  145. // @router /industry/readList [get]
  146. func (this *ReportBillboardController) ReadList() {
  147. br := new(models.BaseResponse).Init()
  148. defer func() {
  149. this.Data["json"] = br
  150. this.ServeJSON()
  151. }()
  152. user := this.User
  153. if user == nil {
  154. br.Msg = "请重新登录"
  155. br.Ret = 408
  156. return
  157. }
  158. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  159. source, _ := this.GetInt("Source")
  160. var list []*models.ArticleReportBillboardResp
  161. if chartPermissionId < 1 {
  162. br.Msg = "请输入行业ID"
  163. return
  164. }
  165. var err error
  166. var condition string
  167. var pars []interface{}
  168. condition += ` AND m.chart_permission_id = ? `
  169. pars = append(pars, chartPermissionId)
  170. if source == 2 {
  171. //阅读飙升榜
  172. var conditionPv string
  173. var articleTopIds string
  174. conditionPv = condition
  175. dateTime := time.Now().AddDate(0, 0, -15).Format(utils.FormatDate)
  176. conditionPv += ` AND l.create_time > ? AND l.create_time < ? `
  177. pars = append(pars, dateTime, time.Now().Format(utils.FormatDate))
  178. listTop, err := models.GetCygxArticleHistoryAllTop(pars, conditionPv)
  179. if err != nil {
  180. br.Msg = "获取失败"
  181. br.ErrMsg = "获取失败,GetCygxArticleHistoryAllTop Err:" + err.Error()
  182. return
  183. }
  184. for _, v := range listTop {
  185. articleTopIds += strconv.Itoa(v.ArticleId) + ","
  186. item := new(models.ArticleReportBillboardResp)
  187. item.ArticleId = v.ArticleId
  188. list = append(list, item)
  189. }
  190. articleTopIds = strings.TrimRight(articleTopIds, ",")
  191. //获取文章关联的产业
  192. pars = make([]interface{}, 0)
  193. articleIdList := make([]string, 0)
  194. silcearticleIds := strings.Split(articleTopIds, ",")
  195. for _, v := range silcearticleIds {
  196. articleIdList = append(articleIdList, v)
  197. }
  198. condition = ` AND a.article_id IN ( ` + utils.GetOrmInReplace(len(silcearticleIds)) + ` ) `
  199. pars = append(pars, articleIdList)
  200. condition += ` AND m.chart_permission_id = ? `
  201. pars = append(pars, chartPermissionId)
  202. listPv, err := models.GetReportPvBillboardList(pars, condition)
  203. if err != nil {
  204. br.Msg = "获取失败"
  205. br.ErrMsg = "获取失败,GetReportPvBillboardList Err:" + err.Error()
  206. return
  207. }
  208. //按照查询出来的顺序赋值
  209. mapPv := make(map[int]*models.ArticleReportBillboardResp)
  210. for _, v := range listPv {
  211. mapPv[v.ArticleId] = v
  212. }
  213. for k, v := range list {
  214. list[k] = mapPv[v.ArticleId]
  215. }
  216. } else {
  217. //获取报告收藏
  218. condition += `GROUP BY a.article_id ORDER BY a.user_collection_num DESC, ac.id DESC, a.publish_date DESC LIMIT 15 `
  219. list, err = models.GetReportCollectionBillboardList(pars, condition)
  220. }
  221. if err != nil {
  222. br.Msg = "获取失败"
  223. br.ErrMsg = "获取失败,GetSubjectList Err:" + err.Error()
  224. return
  225. }
  226. var articleIds string
  227. for _, v := range list {
  228. articleIds += strconv.Itoa(v.ArticleId) + ","
  229. }
  230. articleIds = strings.TrimRight(articleIds, ",")
  231. silcearticleIds := strings.Split(articleIds, ",")
  232. //获取文章关联的产业
  233. pars = make([]interface{}, 0)
  234. articleIdList := make([]string, 0)
  235. for _, v := range silcearticleIds {
  236. articleIdList = append(articleIdList, v)
  237. }
  238. condition = ` AND mg.article_id IN ( ` + utils.GetOrmInReplace(len(silcearticleIds)) + ` ) `
  239. pars = append(pars, articleIdList)
  240. industrialList, err := models.GetIndustrialListByarticleId(pars, condition)
  241. if err != nil {
  242. br.Msg = "获取失败"
  243. br.ErrMsg = "获取失败,GetSubjectList Err:" + err.Error()
  244. return
  245. }
  246. industrialMap := make(map[int][]*models.IndustrialManagementIdInt)
  247. if len(industrialList) > 0 {
  248. for _, v := range industrialList {
  249. item := new(models.IndustrialManagementIdInt)
  250. item.ArticleId = v.ArticleId
  251. item.IndustrialManagementId = v.IndustrialManagementId
  252. item.IndustryName = v.IndustryName
  253. industrialMap[v.ArticleId] = append(industrialMap[v.ArticleId], item)
  254. }
  255. }
  256. for k, v := range list {
  257. if len(industrialMap[v.ArticleId]) > 0 {
  258. list[k].List = industrialMap[v.ArticleId]
  259. } else {
  260. list[k].List = make([]*models.IndustrialManagementIdInt, 0)
  261. }
  262. }
  263. resp := new(models.ArticleReportBillboardLIstResp)
  264. resp.List = list
  265. br.Ret = 200
  266. br.Success = true
  267. br.Msg = "获取成功"
  268. br.Data = resp
  269. }