report_chapter.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440
  1. package report
  2. import (
  3. "errors"
  4. "fmt"
  5. report_chapter_type_cache "hongze/hongze_yb/cache/report_chapter_type"
  6. "hongze/hongze_yb/global"
  7. "hongze/hongze_yb/models/response"
  8. "hongze/hongze_yb/models/tables/chart_permission_chapter_mapping"
  9. "hongze/hongze_yb/models/tables/company_product"
  10. "hongze/hongze_yb/models/tables/rddp/report"
  11. "hongze/hongze_yb/models/tables/rddp/report_chapter"
  12. "hongze/hongze_yb/models/tables/report_chapter_type"
  13. "hongze/hongze_yb/services"
  14. "hongze/hongze_yb/services/company"
  15. "hongze/hongze_yb/services/user"
  16. "hongze/hongze_yb/utils"
  17. "html"
  18. "sort"
  19. "strings"
  20. "time"
  21. )
  22. // GetReportTypeIdsByPermissionIds 获取所有和权限绑定的报告章节ID
  23. func GetReportTypeIdsByPermissionIds(permissionIds []int) (ids []int, err error) {
  24. ids, err = chart_permission_chapter_mapping.GetReportIdsByPermisssionIds(permissionIds, "week")
  25. return
  26. }
  27. // GetLatestWeek 获取有权限的最新的周报
  28. func GetLatestWeek(permissionIds []int, typeIds []int) (reportInfo *report.Report, err error) {
  29. newTypeIds, err := GetWeekTypeIdsByPermissionIds(permissionIds, typeIds)
  30. chapters, err := report_chapter.GetLatestChaptersByTypeIdsAndClass(newTypeIds,"week")
  31. if err != nil {
  32. return
  33. }
  34. var reportIds []int
  35. for _, v := range chapters {
  36. reportIds = append(reportIds, v.ReportId)
  37. }
  38. reportInfo, err = report.GetLatestByReportIds(reportIds)
  39. return
  40. }
  41. // GetWeekTypeIdsByPermissionIds 获取有权限的章节类型ID
  42. func GetWeekTypeIdsByPermissionIds(permissionIds []int, typeIds []int) (newTypeIds []int, err error) {
  43. ids, err := GetReportTypeIdsByPermissionIds(permissionIds)
  44. if err != nil {
  45. return
  46. }
  47. if len(typeIds) == 0 {
  48. typeIds, err = report_chapter_type_cache.GetEffectTypeID()
  49. if err != nil {
  50. return
  51. }
  52. }
  53. for _, v1 := range typeIds {
  54. for _, v2 := range ids {
  55. if v1 == v2 {
  56. newTypeIds = append(newTypeIds, v2)
  57. }
  58. }
  59. }
  60. return
  61. }
  62. // GetChapterListByReport 根据报告获取章节列表
  63. func GetChapterListByReport(classifyNameFirst string, reportId int, validWeekTypeIds []int, reportCreateTime time.Time) (reportTypeList response.ReportChapterList, err error) {
  64. var errMsg string
  65. defer func() {
  66. if err != nil {
  67. global.LOG.Critical(fmt.Sprintf("GetChapterListByReport: err:%s, errMsg:%s", err.Error(), errMsg))
  68. }
  69. }()
  70. //查询有效的章节
  71. typeList, tErr := report_chapter_type.GetEffectTypes()
  72. if tErr != nil {
  73. errMsg = tErr.Error()
  74. err = errors.New("章节类型查询出错")
  75. return
  76. }
  77. if len(typeList) == 0 {
  78. err = errors.New("无有效的章节")
  79. return
  80. }
  81. typeMap := make(map[uint64]*report_chapter_type.ReportChapterType)
  82. var typeIds []int
  83. newTypeMap := make(map[int]bool)
  84. for _, v := range typeList {
  85. typeMap[v.ReportChapterTypeId] = v
  86. typeIds = append(typeIds, int(v.ReportChapterTypeId))
  87. }
  88. if classifyNameFirst == "周报" {
  89. for _, v := range validWeekTypeIds {
  90. newTypeMap[v] = true
  91. }
  92. }
  93. //获取所有当前研报的章节
  94. chapterList, tErr := report_chapter.GetListByReportId(reportId, classifyNameFirst)
  95. if tErr != nil && tErr != utils.ErrNoRow{
  96. errMsg = err.Error()
  97. err = errors.New("章节查询出错")
  98. return
  99. }
  100. if len(chapterList) == 0 {
  101. err = errors.New("无有效章节")
  102. return
  103. }
  104. for _, item := range chapterList {
  105. if typeItem, ok := typeMap[uint64(item.TypeId)]; ok {
  106. // 如果是周报只展示有权限的章节
  107. if classifyNameFirst == "周报" {
  108. if _, ok1 := newTypeMap[item.TypeId]; !ok1 {
  109. continue
  110. }
  111. }
  112. temp := new(response.ReportChapterListItem)
  113. if reportCreateTime.Before(typeItem.PauseStartTime) || reportCreateTime.After(typeItem.PauseEndTime) {
  114. temp.ReportChapterId = item.ReportChapterId
  115. temp.TypeId = item.TypeId
  116. temp.TypeName = item.TypeName
  117. temp.Title = item.Title
  118. temp.Trend = item.Trend
  119. temp.ReportId = item.ReportId
  120. temp.Sort = typeItem.Sort
  121. temp.PublishTime = item.PublishTime
  122. temp.ReportChapterTypeKey = typeItem.ReportChapterTypeKey
  123. temp.ReportChapterTypeName = typeItem.ReportChapterTypeName
  124. temp.ReportChapterTypeThumb = typeItem.YbIconUrl
  125. reportTypeList = append(reportTypeList, temp)
  126. }
  127. }
  128. }
  129. if len(reportTypeList) > 0 {
  130. sort.Sort(reportTypeList)
  131. }
  132. return
  133. }
  134. // GetChapterDetail 获取章节详情
  135. func GetChapterDetail(user user.UserInfo, reportChapterId int) (reportChapterDetail *response.ReportChapterDetail, err error) {
  136. var errMsg string
  137. defer func() {
  138. if err != nil {
  139. global.LOG.Critical(fmt.Sprintf("GetChapterDetail: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  140. }
  141. }()
  142. var authOk bool
  143. var productAuthOk bool
  144. var chapterAuthOk bool
  145. var permissionCheckInfo response.PermissionCheckInfo
  146. // 判断用户状态是否是正常和永续
  147. companyProduct, err := company_product.GetByCompany2ProductId(user.CompanyID, 1)
  148. if err == utils.ErrNoRow {
  149. err = nil
  150. }
  151. if err != nil {
  152. errMsg = err.Error()
  153. err = errors.New("查询用户购买产品出错")
  154. return
  155. }
  156. if companyProduct != nil {
  157. // 无FICC权限的客户不可见
  158. if companyProduct.CompanyProductID > 0 {
  159. // 已购或者试用用户可见
  160. if strings.Contains("永续,正式", companyProduct.Status) || (companyProduct.Status == "试用" && companyProduct.IsSuspend != 1) {
  161. productAuthOk = true
  162. }
  163. }
  164. }
  165. typeIds, err := report_chapter_type_cache.GetEffectTypeID()
  166. if err != nil {
  167. errMsg = err.Error()
  168. err = errors.New("章节类型查询出错")
  169. return
  170. }
  171. if len(typeIds) == 0 {
  172. err = errors.New("无有效的章节类型")
  173. return
  174. }
  175. reportChapter, err := report_chapter.GetContentById(reportChapterId, typeIds)
  176. if err != nil {
  177. errMsg = err.Error()
  178. err = errors.New("章节查询出错")
  179. return
  180. }
  181. if reportChapter.ReportChapterId == 0 {
  182. err = errors.New("章节不存在")
  183. return
  184. }
  185. reportInfo, tErr := report.GetByReportId(reportChapter.ReportId)
  186. if tErr != nil {
  187. errMsg = tErr.Error()
  188. err = errors.New("报告查询出错")
  189. return
  190. }
  191. if reportInfo.Id == 0 {
  192. err = errors.New("报告不存在")
  193. return
  194. }
  195. if reportInfo.ClassifyNameFirst == "周报" && reportChapter.IsEdit != 1 {
  196. err = errors.New("章节未编辑")
  197. return
  198. }
  199. //判断权限
  200. var newTypeIds []int
  201. if reportInfo.ClassifyNameFirst == "晨报"{
  202. authOk, permissionCheckInfo, err = CheckDayReportPermission(user, productAuthOk)
  203. if err != nil && err != utils.ErrNoRow {
  204. errMsg = err.Error()
  205. err = errors.New("权限查询出错")
  206. return
  207. }
  208. }else if reportInfo.ClassifyNameFirst == "周报"{
  209. authOk, permissionCheckInfo, newTypeIds, err = CheckWeekReportPermission(user, productAuthOk)
  210. if err != nil && err != utils.ErrNoRow {
  211. errMsg = err.Error()
  212. err = errors.New("权限查询出错")
  213. return
  214. }
  215. for _, v := range newTypeIds {
  216. if v == reportChapter.TypeId {
  217. chapterAuthOk = true
  218. }
  219. }
  220. authOk = chapterAuthOk
  221. }
  222. var chapterMenu []*response.ReportChapterMenu
  223. reportChapterItem := new(response.ReportChapterItem)
  224. reportChapterItem.ReportChapterId = reportChapter.ReportChapterId
  225. reportChapterItem.ReportId = reportChapter.ReportId
  226. reportChapterItem.Abstract = reportChapter.Abstract
  227. reportChapterItem.TypeId = reportChapter.TypeId
  228. reportChapterItem.Title = reportChapter.Title
  229. reportChapterItem.ReportId = reportChapter.ReportId
  230. reportChapterItem.PublishTime = reportChapter.PublishTime
  231. reportChapterItem.VideoPlaySeconds = reportChapter.VideoPlaySeconds
  232. reportChapterItem.VideoName = reportChapter.VideoName
  233. if reportChapter.VideoUrl != "" && reportChapter.VideoName == "" {
  234. reportChapterItem.VideoName = reportChapter.Title
  235. }
  236. reportChapterItem.VideoSize = reportChapter.VideoSize
  237. videoImgMap := map[string]string{
  238. "day": "report_list_chen.png",
  239. "week": "report_list_zhou.png",
  240. }
  241. reportChapterItem.VideoImg = utils.ALIYUN_YBIMG_HOST + videoImgMap[reportChapter.ReportType]
  242. reportChapterItem.TypeName = reportChapter.TypeName
  243. reportChapterItem.Author = reportChapter.Author
  244. reportChapterItem.Stage = reportChapter.Stage
  245. reportChapterItem.ClassifyNameFirst = reportChapter.ClassifyNameFirst
  246. reportChapterItem.ClassifyIdFirst = reportChapter.ClassifyIdFirst
  247. var likeNum int64
  248. var likeEnabled int8
  249. if authOk {
  250. reportChapterItem.Content = html.UnescapeString(reportChapter.Content)
  251. reportChapterItem.VideoUrl = reportChapter.VideoUrl
  252. //底部菜单切换
  253. if reportInfo.ClassifyNameFirst == "周报" {
  254. chapterMenu, err = GetMenuChapter(reportInfo.Id, newTypeIds, reportInfo.ClassifyNameFirst, reportInfo.CreateTime)
  255. }else{
  256. chapterMenu, err = GetMenuChapter(reportInfo.Id, typeIds, reportInfo.ClassifyNameFirst, reportInfo.CreateTime)
  257. }
  258. //查询点赞数
  259. likeNum,likeEnabled, _ = services.GetReportLikeByReportIdOldReportId(user.UserID, reportInfo.Id, reportChapter.ReportChapterId,0,0)
  260. go AddViewRecord(user, reportInfo.Id, reportInfo.ClassifyNameFirst, reportChapterId)
  261. }else{
  262. reportChapterItem.ContentSub = html.UnescapeString(reportChapter.ContentSub)
  263. }
  264. go AddUserAccessRecord(user, reportInfo.Id, reportInfo.ClassifyNameFirst, reportChapterId, authOk)
  265. reportChapterDetail = new(response.ReportChapterDetail)
  266. reportChapterDetail.ReportChapterItem = reportChapterItem
  267. reportChapterDetail.PermissionCheck = &permissionCheckInfo
  268. reportChapterDetail.ReportChapterMenuList = chapterMenu
  269. reportChapterDetail.AuthOk = authOk
  270. reportChapterDetail.LikeNum = likeNum
  271. reportChapterDetail.LikeEnabled = likeEnabled
  272. return
  273. }
  274. func GetMenuChapter(reportId int, typeIds []int, classifyNameFirst string, reportCreateTime time.Time) (reportTypeList response.ReportChapterMenuList, err error) {
  275. //查询有效的章节
  276. typeList, tErr := report_chapter_type.GetEffectTypes()
  277. if tErr != nil {
  278. return
  279. }
  280. if len(typeList) == 0 {
  281. err = errors.New("无有效的章节")
  282. return
  283. }
  284. typeMap := make(map[uint64]*report_chapter_type.ReportChapterType)
  285. for _, v := range typeList {
  286. typeMap[v.ReportChapterTypeId] = v
  287. }
  288. //获取所有当前研报的章节
  289. chapterList, tErr := report_chapter.GetListByReportIdTypeIds(reportId, typeIds, classifyNameFirst)
  290. if tErr != nil && tErr != utils.ErrNoRow{
  291. return
  292. }
  293. if len(chapterList) > 0 {
  294. for _, item := range chapterList {
  295. if typeItem, ok := typeMap[uint64(item.TypeId)]; ok {
  296. if reportCreateTime.Before(typeItem.PauseStartTime) || reportCreateTime.After(typeItem.PauseEndTime) {
  297. temp := new(response.ReportChapterMenu)
  298. temp.ReportChapterId = item.ReportChapterId
  299. temp.ReportId = item.ReportId
  300. temp.ReportChapterTypeName = typeItem.ReportChapterTypeName
  301. temp.ReportChapterTypeThumb = typeItem.YbBottomIcon
  302. temp.Sort = typeItem.Sort
  303. temp.PcSelectedThumb = typeItem.PcSelectedImage
  304. temp.PcUnselectedThumb = typeItem.PcUnselectedImage
  305. reportTypeList = append(reportTypeList, temp)
  306. }
  307. }
  308. }
  309. }
  310. if len(reportTypeList) > 0{
  311. sort.Sort(reportTypeList)
  312. }
  313. return
  314. }
  315. // CheckWeekReportPermission 验证周报的权限
  316. func CheckWeekReportPermission(userInfo user.UserInfo, productAuthOk bool) (authOk bool, permissionCheckInfo response.PermissionCheckInfo, validTypeIds []int, err error) {
  317. var permissionIds []int
  318. var validPermissionIds []int //最后允许显示的章节
  319. if productAuthOk {
  320. permissionIds, err = chart_permission_chapter_mapping.GetPermissionIdsByWeek()
  321. if err != nil && err != utils.ErrNoRow {
  322. return
  323. }
  324. }
  325. authOk, permissionCheckInfo, validPermissionIds, err = company.GetCheckPermission(userInfo.CompanyID, int(userInfo.UserID), permissionIds)
  326. if err != nil {
  327. return
  328. }
  329. //返回可用的章节列表
  330. if len(validPermissionIds) > 0 {
  331. validTypeIds, err = chart_permission_chapter_mapping.GetReportIdsByPermisssionIds(validPermissionIds, "week")
  332. }
  333. return
  334. }
  335. // CheckDayReportPermission 验证晨报的权限
  336. func CheckDayReportPermission(userInfo user.UserInfo, productAuthOk bool) (authOk bool, permissionCheckInfo response.PermissionCheckInfo, err error) {
  337. if productAuthOk {
  338. authOk = true
  339. return
  340. }
  341. authOk, permissionCheckInfo,_, err = company.GetCheckPermission(userInfo.CompanyID, int(userInfo.UserID), []int{})
  342. return
  343. }
  344. // GetReportChapterVideoList 根据报告获取章节的音频列表
  345. func GetReportChapterVideoList(permissionIds []int, classifyName string, list []*report.Report) (videoMap map[int][]*response.VideoListItem, weekAuthMap map[int]bool, errMsg string, err error) {
  346. videoMap = make(map[int][]*response.VideoListItem)
  347. weekAuthMap = make(map[int]bool)
  348. var reportIds []int
  349. reportMap := make(map[int]*report.Report)
  350. for _, reportInfo := range list {
  351. reportMap[reportInfo.Id] = reportInfo
  352. reportIds = append(reportIds, reportInfo.Id)
  353. }
  354. // 查询有效的章节
  355. //查询有效的章节
  356. typeList, tErr := report_chapter_type.GetEffectTypes()
  357. if tErr != nil {
  358. errMsg = tErr.Error()
  359. err = errors.New("章节类型查询出错")
  360. return
  361. }
  362. if len(typeList) == 0 {
  363. err = errors.New("无有效的章节")
  364. return
  365. }
  366. typeMap := make(map[int]*report_chapter_type.ReportChapterType)
  367. var typeIds []int
  368. for _, v := range typeList {
  369. typeMap[int(v.ReportChapterTypeId)] = v
  370. typeIds = append(typeIds, int(v.ReportChapterTypeId))
  371. }
  372. var chapters []*report_chapter.ReportChapter
  373. if classifyName == "周报" {
  374. // 查询用户有权限的章节ID
  375. newTypeIds, tErr := GetWeekTypeIdsByPermissionIds(permissionIds, typeIds)
  376. if tErr != nil {
  377. errMsg = tErr.Error()
  378. err = errors.New("查询章节类型权限出错")
  379. return
  380. }
  381. // 查询章节列表
  382. chapters, err = report_chapter.GetByTypeIdsAndReportIds(newTypeIds, reportIds, classifyName)
  383. }else{
  384. // 查询章节列表
  385. chapters, err = report_chapter.GetByTypeIdsAndReportIds(typeIds, reportIds, classifyName)
  386. }
  387. if err != nil {
  388. errMsg = err.Error()
  389. err = errors.New("查询章节出错")
  390. return
  391. }
  392. for _, v := range chapters {
  393. if classifyName == "周报" {
  394. weekAuthMap[v.ReportId] = true
  395. }
  396. if temp, ok := typeMap[v.TypeId]; ok && v.VideoUrl != "" {
  397. if reportDetail, ok1 := reportMap[v.ReportId]; ok1 {
  398. reportDate := reportDetail.CreateTime
  399. if reportDate.Before(temp.PauseStartTime) || reportDate.After(temp.PauseEndTime) {
  400. videoItem := new(response.VideoListItem)
  401. videoItem.VideoPlaySeconds = v.VideoPlaySeconds
  402. videoItem.VideoName = v.VideoName
  403. if v.VideoName == "" {
  404. videoItem.VideoName = v.Title
  405. }
  406. videoItem.VideoUrl = v.VideoUrl
  407. videoItem.Sort = v.Sort
  408. videoMap[v.ReportId] = append(videoMap[v.ReportId], videoItem)
  409. }
  410. }
  411. }
  412. }
  413. return
  414. }