report_selection.go 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "hongze/hongze_clpt/models"
  5. "hongze/hongze_clpt/services"
  6. "hongze/hongze_clpt/utils"
  7. "strconv"
  8. "strings"
  9. "time"
  10. )
  11. // 报告
  12. type ReportSelectionController struct {
  13. BaseAuthController
  14. }
  15. // @Title 获取报告精选详情
  16. // @Description 获取报告精选详情接口
  17. // @Param ArticleId query int true "报告ID"
  18. // @Param IsBestNew query bool false "是否获取最新的一篇报告"
  19. // @Success 200 {object} models.ReportSelectionLetailResp
  20. // @router /detail [get]
  21. func (this *ReportSelectionController) Detail() {
  22. br := new(models.BaseResponse).Init()
  23. defer func() {
  24. this.Data["json"] = br
  25. this.ServeJSON()
  26. }()
  27. user := this.User
  28. if user == nil {
  29. br.Msg = "请重新登录"
  30. br.Ret = 408
  31. return
  32. }
  33. //uid := user.UserId
  34. articleId, _ := this.GetInt("ArticleId")
  35. isBestNew, _ := this.GetBool("IsBestNew")
  36. if isBestNew {
  37. tbdb := "cygx_report_selection"
  38. condition := ` AND publish_status = 1 `
  39. var pars []interface{}
  40. list, err := models.GetReportSelectionListPublic(condition, "1", tbdb, pars, 0, 1)
  41. if err != nil {
  42. br.Msg = "获取失败"
  43. br.ErrMsg = "获取失败,Err:" + err.Error()
  44. return
  45. }
  46. for _, v := range list {
  47. articleId = v.ArticleId
  48. }
  49. }
  50. if articleId < 1 {
  51. br.Msg = "获取信息失败"
  52. br.ErrMsg = "报告ID错误" + strconv.Itoa(articleId)
  53. return
  54. }
  55. resp := new(models.ReportSelectionLetailResp)
  56. //判断用户权限
  57. hasPermission, err := services.GetUserhasPermission(user)
  58. if err != nil {
  59. br.Msg = "获取信息失败"
  60. br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
  61. }
  62. detail, err := models.GetCygxReportSelectionInfoById(articleId)
  63. if err != nil {
  64. br.Msg = "获取信息失败"
  65. br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId:" + strconv.Itoa(articleId)
  66. return
  67. }
  68. //未设置全部可见的只能给弘则内部查看
  69. if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
  70. resp.IsShow = true
  71. }
  72. resp.HasPermission = hasPermission
  73. if hasPermission != 1 || !resp.IsShow {
  74. br.Ret = 200
  75. br.Success = true
  76. br.Msg = "获取成功"
  77. resp.Detail = detail
  78. br.Data = resp
  79. return
  80. }
  81. if detail.ReportLink != "" {
  82. articleIdLink, _ := services.GetReportLinkToArticleid(detail.ReportLink)
  83. detail.CeLueArticleId = articleIdLink
  84. }
  85. articleStockMap, _ := services.GetArticleStockMap()
  86. detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format("2006-01-02")
  87. existMap := make(map[int]int)
  88. var items []*models.ReportSelectionChartPermission
  89. var itemsSubject []*models.ReportSelectionChartLogPermission
  90. listLog, err := models.GetReportSelectionlogListAll(articleId)
  91. if err != nil {
  92. br.Msg = "获取失败"
  93. br.ErrMsg = "获取子类信息失败,Err:" + err.Error()
  94. return
  95. }
  96. detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
  97. //获取行业核心逻辑汇总
  98. listChartLog, err := models.GetCygxReportSelectionChartLogRepList(articleId)
  99. if err != nil {
  100. br.Msg = "获取失败"
  101. br.ErrMsg = "获取失败,Err:" + err.Error()
  102. return
  103. }
  104. mapChartLog := make(map[string]string)
  105. for _, v := range listChartLog {
  106. mapChartLog[v.ChartPermissionName] = v.BodyChartSummary
  107. }
  108. for _, v := range listLog {
  109. item := new(models.ReportSelectionChartPermission)
  110. itemSubject := new(models.ReportSelectionChartLogPermission)
  111. itemSubject.PermissionName = v.PermissionName
  112. if existMap[v.ChartPermissionId] == 0 {
  113. //item.PermissionName = v.PermissionName + "领域深度报告和调研"
  114. item.PermissionName = v.PermissionName
  115. item.ChartPermissionId = v.ChartPermissionId
  116. item.IcoLink = v.IcoLink
  117. listSonLog, err := models.GetReportSelectionlogSonListAll(articleId, v.ChartPermissionId)
  118. if err != nil && err.Error() != utils.ErrNoRow() {
  119. br.Msg = "获取信息失败"
  120. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  121. return
  122. }
  123. for k2, v2 := range listSonLog {
  124. if v2.IndustrialManagementId != "" {
  125. listIndustrial, err := models.GetIndustrialByIds(v2.IndustrialManagementId)
  126. if err != nil && err.Error() != utils.ErrNoRow() {
  127. br.Msg = "获取信息失败"
  128. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  129. return
  130. }
  131. listSonLog[k2].OverviewArticleId = articleStockMap[v2.SubjectName]
  132. listSonLog[k2].List = listIndustrial
  133. if v2.Label != "" {
  134. v2.CompanyLabel = strings.Split(v2.Label, "{|}")
  135. }
  136. }
  137. itemSubject.ListSubject = append(itemSubject.ListSubject, &models.ReportSelectionChartLogSubjectName{SubjectName: v2.SubjectName, IsNew: v2.IsNew, IndustrialSubjectId: v2.IndustrialSubjectId})
  138. }
  139. item.BodyChartSummary = mapChartLog[v.PermissionName]
  140. item.List = listSonLog
  141. items = append(items, item)
  142. itemsSubject = append(itemsSubject, itemSubject)
  143. //itemLogs = make([]*models.CygxReportSelectionLogDetail, 0)
  144. }
  145. existMap[v.ChartPermissionId] = v.ChartPermissionId
  146. }
  147. //historyRecord := new(models.CygxReportHistoryRecord)
  148. //historyRecord.UserId = uid
  149. //historyRecord.ArticleId = articleId
  150. //historyRecord.CreateTime = time.Now()
  151. //historyRecord.Mobile = user.Mobile
  152. //historyRecord.Email = user.Email
  153. //historyRecord.CompanyId = user.CompanyId
  154. //historyRecord.CompanyName = user.CompanyName
  155. //historyRecord.RegisterPlatform = utils.REGISTER_PLATFORM
  156. //historyRecord.ReportType = "bgjx"
  157. //sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  158. //if err != nil && err.Error() != utils.ErrNoRow() {
  159. // br.Msg = "获取信息失败"
  160. // br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  161. // return
  162. //}
  163. //historyRecord.RealName = user.RealName
  164. //if sellerItem != nil {
  165. // historyRecord.SellerName = sellerItem.RealName
  166. //}
  167. go services.AddCygxReportHistoryRecord(user, articleId, "bgjx")
  168. resp.List = items
  169. resp.ListPermissionSubject = itemsSubject
  170. resp.Detail = detail
  171. br.Ret = 200
  172. br.Success = true
  173. br.Msg = "获取成功"
  174. br.Data = resp
  175. }
  176. // @Title 标的点击记录
  177. // @Description 标的点击记录接口
  178. // @Param request body models.AddCygxReportSelectionSubjectHistoryReq true "type json string"
  179. // @router /click/history [post]
  180. func (this *ReportSelectionController) ClickHistory() {
  181. br := new(models.BaseResponse).Init()
  182. defer func() {
  183. this.Data["json"] = br
  184. this.ServeJSON()
  185. }()
  186. user := this.User
  187. if user == nil {
  188. br.Msg = "请重新登录"
  189. br.Ret = 408
  190. return
  191. }
  192. var req models.AddCygxReportSelectionSubjectHistoryReq
  193. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  194. if err != nil {
  195. br.Msg = "参数解析异常!"
  196. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  197. return
  198. }
  199. if req.ArticleId <= 0 {
  200. br.Msg = "文章不存在"
  201. br.ErrMsg = "文章不存在,文章ID错误"
  202. return
  203. }
  204. if req.IndustrialSubjectId <= 0 {
  205. br.Msg = "标的ID不存在"
  206. br.ErrMsg = "标的ID不存在,标的ID错误"
  207. return
  208. }
  209. item := models.CygxReportSelectionSubjectHistory{
  210. UserId: user.UserId,
  211. ArticleId: req.ArticleId,
  212. CreateTime: time.Now(),
  213. ModifyTime: time.Now(),
  214. Mobile: user.Mobile,
  215. Email: user.Email,
  216. CompanyId: user.CompanyId,
  217. CompanyName: user.CompanyName,
  218. IndustrialSubjectId: req.IndustrialSubjectId,
  219. RegisterPlatform: utils.REGISTER_PLATFORM,
  220. }
  221. err = models.AddCygxReportSelectionSubjectHistory(&item)
  222. if err != nil {
  223. br.Msg = "记录失败"
  224. br.ErrMsg = "记录失败,Err:" + err.Error()
  225. return
  226. }
  227. br.Ret = 200
  228. br.Success = true
  229. br.Msg = "记录成功"
  230. }