report_selection.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_clpt/models"
  6. "hongze/hongze_clpt/services"
  7. "hongze/hongze_clpt/utils"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. // 报告
  13. type ReportSelectionController struct {
  14. BaseAuthController
  15. }
  16. // @Title 获取报告精选详情
  17. // @Description 获取报告精选详情接口
  18. // @Param ArticleId query int true "报告ID"
  19. // @Param IsBestNew query bool false "是否获取最新的一篇报告"
  20. // @Success 200 {object} models.ReportSelectionLetailResp
  21. // @router /detail [get]
  22. func (this *ReportSelectionController) Detail() {
  23. br := new(models.BaseResponse).Init()
  24. defer func() {
  25. this.Data["json"] = br
  26. this.ServeJSON()
  27. }()
  28. user := this.User
  29. if user == nil {
  30. br.Msg = "请重新登录"
  31. br.Ret = 408
  32. return
  33. }
  34. //uid := user.UserId
  35. articleId, _ := this.GetInt("ArticleId")
  36. isBestNew, _ := this.GetBool("IsBestNew")
  37. if isBestNew {
  38. tbdb := "cygx_report_selection"
  39. condition := ` AND publish_status = 1 `
  40. var pars []interface{}
  41. list, err := models.GetReportSelectionListPublic(condition, "1", tbdb, pars, 0, 1)
  42. if err != nil {
  43. br.Msg = "获取失败"
  44. br.ErrMsg = "获取失败,Err:" + err.Error()
  45. return
  46. }
  47. for _, v := range list {
  48. articleId = v.ArticleId
  49. }
  50. }
  51. if articleId < 1 {
  52. br.Msg = "获取信息失败"
  53. br.ErrMsg = "报告ID错误" + strconv.Itoa(articleId)
  54. return
  55. }
  56. PermissionNameMap, err := services.GetPermissionNameMap()
  57. if err != nil {
  58. br.Msg = "获取失败"
  59. br.ErrMsg = "获取失败 GetPermissionNameMap,Err:" + err.Error()
  60. return
  61. }
  62. PermissionIcoMap, err := services.GetPermissionNameIcoMap()
  63. if err != nil {
  64. br.Msg = "获取失败"
  65. br.ErrMsg = "获取失败 GetPermissionNameMap,Err:" + err.Error()
  66. return
  67. }
  68. resp := new(models.ReportSelectionLetailResp)
  69. //判断用户权限
  70. hasPermission, err := services.GetUserhasPermission(user)
  71. if err != nil {
  72. br.Msg = "获取信息失败"
  73. br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
  74. }
  75. detail, err := models.GetCygxReportSelectionInfoById(articleId)
  76. if err != nil {
  77. br.Msg = "获取信息失败"
  78. br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId:" + strconv.Itoa(articleId)
  79. return
  80. }
  81. //未设置全部可见的只能给弘则内部查看
  82. if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
  83. resp.IsShow = true
  84. }
  85. resp.HasPermission = hasPermission
  86. if hasPermission != 1 || !resp.IsShow {
  87. br.Ret = 200
  88. br.Success = true
  89. br.Msg = "获取成功"
  90. resp.Detail = detail
  91. br.Data = resp
  92. return
  93. }
  94. if detail.ReportLink != "" {
  95. articleIdLink, _ := services.GetReportLinkToArticleid(detail.ReportLink)
  96. detail.CeLueArticleId = articleIdLink
  97. }
  98. articleStockMap, _ := services.GetArticleStockMap()
  99. detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format("2006-01-02")
  100. existMap := make(map[int]int)
  101. var items []*models.ReportSelectionChartPermission
  102. var itemsSubject []*models.ReportSelectionChartLogPermission
  103. listLog, err := models.GetReportSelectionlogListAll(articleId)
  104. if err != nil {
  105. br.Msg = "获取失败"
  106. br.ErrMsg = "获取子类信息失败,Err:" + err.Error()
  107. return
  108. }
  109. detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
  110. //获取行业核心逻辑汇总
  111. listChartLog, err := models.GetCygxReportSelectionChartLogRepList(articleId)
  112. if err != nil {
  113. br.Msg = "获取失败"
  114. br.ErrMsg = "获取失败,Err:" + err.Error()
  115. return
  116. }
  117. mapChartLog := make(map[string]string)
  118. for _, v := range listChartLog {
  119. mapChartLog[v.ChartPermissionName] = v.BodyChartSummary
  120. }
  121. for _, v := range listLog {
  122. v.PermissionName = PermissionNameMap[v.ChartPermissionId]
  123. item := new(models.ReportSelectionChartPermission)
  124. itemSubject := new(models.ReportSelectionChartLogPermission)
  125. itemSubject.PermissionName = v.PermissionName
  126. if existMap[v.ChartPermissionId] == 0 {
  127. //item.PermissionName = v.PermissionName + "领域深度报告和调研"
  128. item.PermissionName = v.PermissionName
  129. item.ChartPermissionId = v.ChartPermissionId
  130. item.IcoLink = v.IcoLink
  131. listSonLog, err := models.GetReportSelectionlogSonListAll(articleId, v.ChartPermissionId)
  132. if err != nil && err.Error() != utils.ErrNoRow() {
  133. br.Msg = "获取信息失败"
  134. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  135. return
  136. }
  137. for k2, v2 := range listSonLog {
  138. if v2.IndustrialManagementId != "" {
  139. listIndustrial, err := models.GetIndustrialByIds(v2.IndustrialManagementId)
  140. if err != nil && err.Error() != utils.ErrNoRow() {
  141. br.Msg = "获取信息失败"
  142. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  143. return
  144. }
  145. //后台如果勾了隐藏那么这里就不展示 V11.3 2023-08-17
  146. if listSonLog[k2].IsShowOverviewArticle == 1 {
  147. listSonLog[k2].OverviewArticleId = articleStockMap[v2.SubjectName]
  148. } else {
  149. listSonLog[k2].OverviewArticleId = 0
  150. }
  151. listSonLog[k2].List = listIndustrial
  152. //listSonLog[k2].IsShowApplyButton = true
  153. if v2.Label != "" {
  154. CompanyLabelSlice := strings.Split(v2.Label, "{|}")
  155. for _, vCompanyLabel := range CompanyLabelSlice {
  156. v2.CompanyLabel = append(v2.CompanyLabel, vCompanyLabel+"#")
  157. }
  158. }
  159. }
  160. subjectItem := new(models.ReportSelectionChartLogSubjectName)
  161. subjectItem.SubjectName = v2.SubjectName
  162. subjectItem.IsNew = v2.IsNew
  163. subjectItem.IndustrialSubjectId = v2.IndustrialSubjectId
  164. subjectItem.IndustrialManagementId, _ = strconv.Atoi(v2.IndustrialManagementId)
  165. subjectItem.IndustrialManagementName = v2.IndustrialManagementNames
  166. if subjectItem.SubjectName == "" {
  167. subjectItem.SubjectName = subjectItem.IndustrialManagementName
  168. }
  169. subjectItem.Md5String = utils.MD5(fmt.Sprint("IN_ID", v2.IndustrialManagementId, "S_ID", v2.IndustrialSubjectId))
  170. v2.Md5String = subjectItem.Md5String
  171. itemSubject.ListSubject = append(itemSubject.ListSubject, subjectItem)
  172. //itemSubject.ListSubject = append(itemSubject.ListSubject, &models.ReportSelectionChartLogSubjectName{SubjectName: v2.SubjectName, IsNew: v2.IsNew, IndustrialSubjectId: v2.IndustrialSubjectId})
  173. }
  174. item.BodyChartSummary = mapChartLog[v.PermissionName]
  175. item.List = listSonLog
  176. item.PermissionName = PermissionNameMap[v.ChartPermissionId]
  177. item.IcoLink = PermissionIcoMap[v.ChartPermissionId]
  178. items = append(items, item)
  179. itemsSubject = append(itemsSubject, itemSubject)
  180. //itemLogs = make([]*models.CygxReportSelectionLogDetail, 0)
  181. }
  182. existMap[v.ChartPermissionId] = v.ChartPermissionId
  183. }
  184. //historyRecord := new(models.CygxReportHistoryRecord)
  185. //historyRecord.UserId = uid
  186. //historyRecord.ArticleId = articleId
  187. //historyRecord.CreateTime = time.Now()
  188. //historyRecord.Mobile = user.Mobile
  189. //historyRecord.Email = user.Email
  190. //historyRecord.CompanyId = user.CompanyId
  191. //historyRecord.CompanyName = user.CompanyName
  192. //historyRecord.RegisterPlatform = utils.REGISTER_PLATFORM
  193. //historyRecord.ReportType = "bgjx"
  194. //sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  195. //if err != nil && err.Error() != utils.ErrNoRow() {
  196. // br.Msg = "获取信息失败"
  197. // br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  198. // return
  199. //}
  200. //historyRecord.RealName = user.RealName
  201. //if sellerItem != nil {
  202. // historyRecord.SellerName = sellerItem.RealName
  203. //}
  204. //go services.AddCygxReportHistoryRecord(user, articleId, "bgjx")
  205. resp.List = items
  206. resp.ListPermissionSubject = itemsSubject
  207. resp.Detail = detail
  208. br.Ret = 200
  209. br.Success = true
  210. br.Msg = "获取成功"
  211. br.Data = resp
  212. }
  213. // @Title 标的点击记录
  214. // @Description 标的点击记录接口
  215. // @Param request body models.AddCygxReportSelectionSubjectHistoryReq true "type json string"
  216. // @router /click/history [post]
  217. func (this *ReportSelectionController) ClickHistory() {
  218. br := new(models.BaseResponse).Init()
  219. defer func() {
  220. this.Data["json"] = br
  221. this.ServeJSON()
  222. }()
  223. user := this.User
  224. if user == nil {
  225. br.Msg = "请重新登录"
  226. br.Ret = 408
  227. return
  228. }
  229. var req models.AddCygxReportSelectionSubjectHistoryReq
  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.ArticleId <= 0 {
  237. br.Msg = "文章不存在"
  238. br.ErrMsg = "文章不存在,文章ID错误"
  239. return
  240. }
  241. if req.IndustrialSubjectId+req.IndustrialManagementId <= 0 {
  242. br.Msg = "标的ID不存在"
  243. br.ErrMsg = "产业或标的ID不存在"
  244. return
  245. }
  246. item := models.CygxReportSelectionSubjectHistory{
  247. UserId: user.UserId,
  248. ArticleId: req.ArticleId,
  249. CreateTime: time.Now(),
  250. ModifyTime: time.Now(),
  251. Mobile: user.Mobile,
  252. Email: user.Email,
  253. CompanyId: user.CompanyId,
  254. CompanyName: user.CompanyName,
  255. IndustrialSubjectId: req.IndustrialSubjectId,
  256. IndustrialManagementId: req.IndustrialManagementId,
  257. RegisterPlatform: utils.REGISTER_PLATFORM,
  258. }
  259. err = models.AddCygxReportSelectionSubjectHistory(&item)
  260. if err != nil {
  261. br.Msg = "记录失败"
  262. br.ErrMsg = "记录失败,Err:" + err.Error()
  263. return
  264. }
  265. br.Ret = 200
  266. br.Success = true
  267. br.Msg = "记录成功"
  268. }
  269. // @Title 上传文章阅读时间
  270. // @Description 上传文章阅读时间接口
  271. // @Param request body models.AddStopTimeRep true "type json string"
  272. // @Success 200 {object} models.ArticleDetailResp
  273. // @router /addStopTime [post]
  274. func (this *ReportSelectionController) AddStopTime() {
  275. br := new(models.BaseResponse).Init()
  276. defer func() {
  277. this.Data["json"] = br
  278. this.ServeJSON()
  279. }()
  280. user := this.User
  281. if user == nil {
  282. br.Msg = "请登录"
  283. br.ErrMsg = "请登录,用户信息为空"
  284. br.Ret = 408
  285. return
  286. }
  287. var req models.AddReportSelectionStopTimeRep
  288. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  289. if err != nil {
  290. br.Msg = "参数解析异常!"
  291. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  292. return
  293. }
  294. uid := user.UserId
  295. articleId := req.ArticleId
  296. stopTime := req.StopTime
  297. outType := req.OutType
  298. source := req.Source
  299. var reportType string
  300. if source == 1 {
  301. reportType = "bgjx"
  302. } else if source == 2 {
  303. reportType = "bzyjhz"
  304. } else if source == 3 {
  305. reportType = "szjyhz"
  306. }
  307. hasPermission, err := services.GetUserhasPermission(user)
  308. if err != nil {
  309. br.Msg = "获取信息失败"
  310. br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
  311. }
  312. if hasPermission == 1 {
  313. historyRecord := new(models.CygxReportHistoryRecord)
  314. historyRecord.UserId = uid
  315. historyRecord.ArticleId = articleId
  316. historyRecord.CreateTime = time.Now().Add(-time.Second * time.Duration(stopTime))
  317. historyRecord.Mobile = user.Mobile
  318. historyRecord.Email = user.Email
  319. historyRecord.CompanyId = user.CompanyId
  320. historyRecord.CompanyName = user.CompanyName
  321. historyRecord.StopTime = stopTime
  322. historyRecord.OutType = outType
  323. historyRecord.ReportType = reportType
  324. historyRecord.RegisterPlatform = utils.REGISTER_PLATFORM
  325. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  326. if err != nil && err.Error() != utils.ErrNoRow() {
  327. br.Msg = "获取信息失败"
  328. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  329. return
  330. }
  331. historyRecord.RealName = user.RealName
  332. if sellerItem != nil {
  333. historyRecord.SellerName = sellerItem.RealName
  334. }
  335. go services.AddCygxReportHistoryRecord(historyRecord)
  336. }
  337. br.Ret = 200
  338. br.Success = true
  339. br.Msg = "操作成功"
  340. }
  341. // @Title 报告精选申请路演
  342. // @Description 报告精选申请路演
  343. // @Param request body cygx.CygxBannerIdReq true "type json string"
  344. // @Success 200 Ret=200 提交成功
  345. // @router /report_selection_log/apply [post]
  346. func (this *ReportSelectionController) ReportSelectionLogApply() {
  347. br := new(models.BaseResponse).Init()
  348. defer func() {
  349. this.Data["json"] = br
  350. this.ServeJSON()
  351. }()
  352. user := this.User
  353. if user == nil {
  354. br.Msg = "请登录"
  355. br.ErrMsg = "请登录,用户信息为空"
  356. br.Ret = 408
  357. return
  358. }
  359. var req models.CygxReportSelectionLogApplyReq
  360. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  361. if err != nil {
  362. br.Msg = "参数解析异常!"
  363. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  364. return
  365. }
  366. articleId := req.ArticleId
  367. subjectName := req.SubjectName
  368. var condition string
  369. var pars []interface{}
  370. condition += ` AND article_id = ? AND subject_name = ? AND user_id = ? `
  371. pars = append(pars, articleId, subjectName, user.UserId)
  372. totalApply, err := models.GetCygxReportSelectionLogApplyCount(condition, pars)
  373. if err != nil {
  374. br.Msg = "申请失败!"
  375. br.ErrMsg = "申请失败,Err:" + err.Error()
  376. return
  377. }
  378. if totalApply > 0 {
  379. br.Msg = "您已提交过此公司的路演申请,请等待销售与您联系!"
  380. return
  381. }
  382. logDetail, err := models.GetCygxReportSelectionLogDetail(articleId, subjectName)
  383. if err != nil {
  384. br.Msg = "申请失败!"
  385. br.ErrMsg = "申请失败,Err:" + err.Error()
  386. return
  387. }
  388. item := new(models.CygxReportSelectionLogApply)
  389. item.UserId = user.UserId
  390. item.CreateTime = time.Now()
  391. item.ModifyTime = time.Now()
  392. item.Mobile = user.Mobile
  393. item.Email = user.Email
  394. item.CompanyId = user.CompanyId
  395. item.CompanyName = user.CompanyName
  396. item.ArticleId = logDetail.ArticleId
  397. item.SubjectName = logDetail.SubjectName
  398. item.IndustrialSubjectId = logDetail.IndustrialSubjectId
  399. item.RegisterPlatform = utils.REGISTER_PLATFORM
  400. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  401. if err != nil && err.Error() != utils.ErrNoRow() {
  402. return
  403. }
  404. item.RealName = user.RealName
  405. if sellerItem != nil {
  406. item.SellerName = sellerItem.RealName
  407. }
  408. _, err = models.AddCygxReportSelectionLogApply(item)
  409. if err != nil {
  410. br.Msg = "申请失败"
  411. br.ErrMsg = "申请失败,Err:" + err.Error()
  412. return
  413. }
  414. go services.SendCygxReportSelectionLogApplyTemplateMsg(user, logDetail.SubjectName)
  415. br.Ret = 200
  416. br.Success = true
  417. br.Msg = "记录成功"
  418. }