message.go 9.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304
  1. package controllers
  2. import (
  3. "eta/eta_mini_crm_ht/models"
  4. "eta/eta_mini_crm_ht/models/response"
  5. "eta/eta_mini_crm_ht/utils"
  6. "github.com/rdlucklib/rdluck_tools/paging"
  7. "strconv"
  8. "strings"
  9. )
  10. type MessageController struct {
  11. BaseAuthController
  12. }
  13. // ReportList
  14. // @Title 研报列表
  15. // @Description pdf研报列表
  16. // @Param PageSize query int true "每页数据条数"
  17. // @Param CurrentIndex query int true "当前页页码,从1开始"
  18. // @Param ClassifyIds query string true "二级分类id,可多选用英文,隔开"
  19. // @Param KeyWord query string true "报告标题/创建人"
  20. // @Param SortType query string true "排序方式"
  21. // @Success 200 {object} models.ReportAuthorResp
  22. // @router /reportList [get]
  23. func (this *MessageController) ReportList() {
  24. br := new(models.BaseResponse).Init()
  25. defer func() {
  26. this.Data["json"] = br
  27. this.ServeJSON()
  28. }()
  29. pageSize, _ := this.GetInt("PageSize")
  30. currentIndex, _ := this.GetInt("CurrentIndex")
  31. permissionIds := this.GetString("PermissionIds")
  32. analystNames := this.GetString("AnalystNames")
  33. sortType := this.GetString("SortType")
  34. var permissionCondition string
  35. var condition string
  36. var pars []interface{}
  37. if pageSize <= 0 {
  38. pageSize = utils.PageSize20
  39. }
  40. if currentIndex <= 0 {
  41. currentIndex = 1
  42. }
  43. var permissionPars []interface{}
  44. var classifyPars []interface{}
  45. if permissionIds != "" {
  46. permissionArr := strings.Split(permissionIds, ",")
  47. for _, permissionId := range permissionArr {
  48. perId, _ := strconv.Atoi(permissionId)
  49. permissionPars = append(permissionPars, perId)
  50. }
  51. permissionCondition += " AND chart_permission_id in (" + utils.GetOrmReplaceHolder(len(permissionPars)) + ")"
  52. classifyIds, err := models.GetClassifyIdsByPermissionIds(permissionCondition, permissionPars)
  53. if err != nil {
  54. br.Msg = "获取报告列表失败"
  55. br.ErrMsg = "eta获取品种信息失败,Err:" + err.Error()
  56. return
  57. }
  58. classifyCondition := " AND COALESCE(NULLIF(classify_id_third,0),NULLIF(classify_id_second,0),classify_id_first) in (" + utils.GetOrmReplaceHolder(len(classifyIds)) + ")"
  59. classifyPars = append(classifyPars, classifyIds)
  60. var ids []int
  61. ids, _ = models.GetETAReportIdsByCondition(classifyCondition, classifyPars)
  62. if err != nil {
  63. br.Msg = "获取报告列表失败"
  64. br.ErrMsg = "获取报告表ids失败,Err:" + err.Error()
  65. return
  66. }
  67. condition += " AND id in (" + utils.GetOrmReplaceHolder(len(ids)) + ") And source ='ETA'"
  68. pars = append(pars, ids)
  69. }
  70. if analystNames != "" {
  71. analystNameArr := strings.Split(analystNames, ",")
  72. condition += " AND author in (" + utils.GetOrmReplaceHolder(len(analystNameArr)) + ")"
  73. pars = append(pars, analystNameArr)
  74. }
  75. sortCondition := " ORDER BY published_time "
  76. if sortType == "" {
  77. sortType = "DESC"
  78. }
  79. sortCondition = sortCondition + sortType
  80. total, err := models.GetReportCountByCondition(condition, pars)
  81. if err != nil {
  82. br.Msg = "获取报告列表失败"
  83. br.ErrMsg = "获取报告列表统计失败,Err:" + err.Error()
  84. return
  85. }
  86. startSize := utils.StartIndex(currentIndex, pageSize)
  87. reportList, err := models.GetReportByCondition(condition, sortCondition, pars, startSize, pageSize)
  88. if err != nil {
  89. br.Msg = "获取报告列表失败"
  90. br.ErrMsg = "获取报告列表失败,Err:" + err.Error()
  91. return
  92. }
  93. var reportViewList []*models.ReportView
  94. for _, report := range reportList {
  95. reportView := report.ToView()
  96. reportViewList = append(reportViewList, reportView)
  97. }
  98. page := paging.GetPaging(currentIndex, pageSize, total)
  99. resp := new(response.ReportListResp)
  100. resp.List = reportViewList
  101. resp.Paging = page
  102. br.Ret = 200
  103. br.Success = true
  104. br.Data = resp
  105. br.Msg = "获取成功"
  106. }
  107. // AudioList
  108. // @Title 研报列表
  109. // @Description pdf研报列表
  110. // @Param PageSize query int true "每页数据条数"
  111. // @Param CurrentIndex query int true "当前页页码,从1开始"
  112. // @Param ClassifyIds query string true "二级分类id,可多选用英文,隔开"
  113. // @Param KeyWord query string true "报告标题/创建人"
  114. // @Param SortType query string true "排序方式"
  115. // @Success 200 {object} models.ReportAuthorResp
  116. // @router /audioList [get]
  117. func (this *MessageController) AudioList() {
  118. br := new(models.BaseResponse).Init()
  119. defer func() {
  120. this.Data["json"] = br
  121. this.ServeJSON()
  122. }()
  123. pageSize, _ := this.GetInt("PageSize")
  124. currentIndex, _ := this.GetInt("CurrentIndex")
  125. permissionIds := this.GetString("PermissionIds")
  126. analystIds := this.GetString("AnalystIds")
  127. sortType := this.GetString("SortType")
  128. KeyWord := this.GetString("KeyWord")
  129. var permissionCondition string
  130. var condition string
  131. var pars []interface{}
  132. if pageSize <= 0 {
  133. pageSize = utils.PageSize20
  134. }
  135. if currentIndex <= 0 {
  136. currentIndex = 1
  137. }
  138. if KeyWord != "" {
  139. condition += " AND media_name like '%" + KeyWord + "%'"
  140. }
  141. var permissionPars []interface{}
  142. if permissionIds != "" {
  143. permissionArr := strings.Split(permissionIds, ",")
  144. for _, permissionId := range permissionArr {
  145. perId, _ := strconv.Atoi(permissionId)
  146. permissionPars = append(permissionPars, perId)
  147. }
  148. permissionCondition += " AND permission_id in (" + utils.GetOrmReplaceHolder(len(permissionPars)) + ")"
  149. ids, err := models.GetMappingsByCondition(permissionCondition, permissionPars)
  150. if err != nil {
  151. condition += " AND id in (" + utils.GetOrmReplaceHolder(len(ids)) + ")"
  152. pars = append(pars, ids)
  153. }
  154. }
  155. if analystIds != "" {
  156. analystIdArr := strings.Split(analystIds, ",")
  157. var authorIds []int
  158. for _, analystId := range analystIdArr {
  159. id, _ := strconv.Atoi(analystId)
  160. authorIds = append(authorIds, id)
  161. }
  162. condition += " AND author_id in (" + utils.GetOrmReplaceHolder(len(authorIds)) + ")"
  163. pars = append(pars, authorIds)
  164. }
  165. sortCondition := " ORDER BY published_time "
  166. if sortType == "" {
  167. sortType = "DESC"
  168. }
  169. sortCondition = sortCondition + sortType
  170. total, err := models.GetMediaCountByCondition(models.Audio, condition, pars)
  171. if err != nil {
  172. br.Msg = "获取研报列表失败"
  173. br.ErrMsg = "获取研报列表统计失败,Err:" + err.Error()
  174. return
  175. }
  176. startSize := utils.StartIndex(currentIndex, pageSize)
  177. reportList, err := models.GetMediaByCondition(models.Audio, condition, sortCondition, pars, startSize, pageSize)
  178. if err != nil {
  179. br.Msg = "获取研报列表失败"
  180. br.ErrMsg = "获取研报列表失败,Err:" + err.Error()
  181. return
  182. }
  183. var reportViewList []*models.ESMedia
  184. for _, report := range reportList {
  185. reportView := report.ToView()
  186. reportViewList = append(reportViewList, reportView)
  187. }
  188. page := paging.GetPaging(currentIndex, pageSize, total)
  189. resp := new(response.MediaListResp)
  190. resp.List = reportViewList
  191. resp.Paging = page
  192. br.Ret = 200
  193. br.Success = true
  194. br.Data = resp
  195. br.Msg = "获取成功"
  196. }
  197. // VideoList
  198. // @Title 研报列表
  199. // @Description pdf研报列表
  200. // @Param PageSize query int true "每页数据条数"
  201. // @Param CurrentIndex query int true "当前页页码,从1开始"
  202. // @Param ClassifyIds query string true "二级分类id,可多选用英文,隔开"
  203. // @Param KeyWord query string true "报告标题/创建人"
  204. // @Param SortType query string true "排序方式"
  205. // @Success 200 {object} models.ReportAuthorResp
  206. // @router /videoList [get]
  207. func (this *MessageController) VideoList() {
  208. br := new(models.BaseResponse).Init()
  209. defer func() {
  210. this.Data["json"] = br
  211. this.ServeJSON()
  212. }()
  213. pageSize, _ := this.GetInt("PageSize")
  214. currentIndex, _ := this.GetInt("CurrentIndex")
  215. permissionIds := this.GetString("PermissionIds")
  216. analystIds := this.GetString("AnalystIds")
  217. sortType := this.GetString("SortType")
  218. KeyWord := this.GetString("KeyWord")
  219. var permissionCondition string
  220. var condition string
  221. var pars []interface{}
  222. if pageSize <= 0 {
  223. pageSize = utils.PageSize20
  224. }
  225. if currentIndex <= 0 {
  226. currentIndex = 1
  227. }
  228. if KeyWord != "" {
  229. condition += " AND media_name like '%" + KeyWord + "%'"
  230. }
  231. var permissionPars []interface{}
  232. if permissionIds != "" {
  233. permissionArr := strings.Split(permissionIds, ",")
  234. for _, permissionId := range permissionArr {
  235. perId, _ := strconv.Atoi(permissionId)
  236. permissionPars = append(permissionPars, perId)
  237. }
  238. permissionCondition += " AND permission_id in (" + utils.GetOrmReplaceHolder(len(permissionPars)) + ")"
  239. ids, err := models.GetMappingsByCondition(permissionCondition, permissionPars)
  240. if err != nil {
  241. condition += " AND id in (" + utils.GetOrmReplaceHolder(len(ids)) + ")"
  242. pars = append(pars, ids)
  243. }
  244. }
  245. if analystIds != "" {
  246. analystIdArr := strings.Split(analystIds, ",")
  247. var authorIds []int
  248. for _, analystId := range analystIdArr {
  249. id, _ := strconv.Atoi(analystId)
  250. authorIds = append(authorIds, id)
  251. }
  252. condition += " AND author_id in (" + utils.GetOrmReplaceHolder(len(authorIds)) + ")"
  253. pars = append(pars, authorIds)
  254. }
  255. sortCondition := " ORDER BY published_time "
  256. if sortType == "" {
  257. sortType = "DESC"
  258. }
  259. sortCondition = sortCondition + sortType
  260. total, err := models.GetMediaCountByCondition(models.Video, condition, pars)
  261. if err != nil {
  262. br.Msg = "获取研报列表失败"
  263. br.ErrMsg = "获取研报列表统计失败,Err:" + err.Error()
  264. return
  265. }
  266. startSize := utils.StartIndex(currentIndex, pageSize)
  267. List, err := models.GetMediaByCondition(models.Video, condition, sortCondition, pars, startSize, pageSize)
  268. if err != nil {
  269. br.Msg = "获取研报列表失败"
  270. br.ErrMsg = "获取研报列表失败,Err:" + err.Error()
  271. return
  272. }
  273. var reportViewList []*models.ESMedia
  274. for _, report := range List {
  275. reportView := report.ToView()
  276. reportViewList = append(reportViewList, reportView)
  277. }
  278. page := paging.GetPaging(currentIndex, pageSize, total)
  279. resp := new(response.MediaListResp)
  280. resp.List = reportViewList
  281. resp.Paging = page
  282. br.Ret = 200
  283. br.Success = true
  284. br.Data = resp
  285. br.Msg = "获取成功"
  286. }