report_chapter.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438
  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.TypeId = reportChapter.TypeId
  227. reportChapterItem.Title = reportChapter.Title
  228. reportChapterItem.ReportId = reportChapter.ReportId
  229. reportChapterItem.PublishTime = reportChapter.PublishTime
  230. reportChapterItem.VideoPlaySeconds = reportChapter.VideoPlaySeconds
  231. reportChapterItem.VideoName = reportChapter.VideoName
  232. if reportChapter.VideoUrl != "" && reportChapter.VideoName == "" {
  233. reportChapterItem.VideoName = reportChapter.Title
  234. }
  235. reportChapterItem.VideoSize = reportChapter.VideoSize
  236. videoImgMap := map[string]string{
  237. "day": "report_list_chen.png",
  238. "week": "report_list_zhou.png",
  239. }
  240. reportChapterItem.VideoImg = utils.ALIYUN_YBIMG_HOST + videoImgMap[reportChapter.ReportType]
  241. reportChapterItem.TypeName = reportChapter.TypeName
  242. reportChapterItem.Author = reportChapter.Author
  243. reportChapterItem.Stage = reportChapter.Stage
  244. reportChapterItem.ClassifyNameFirst = reportChapter.ClassifyNameFirst
  245. reportChapterItem.ClassifyIdFirst = reportChapter.ClassifyIdFirst
  246. var likeNum int64
  247. var likeEnabled int8
  248. if authOk {
  249. reportChapterItem.Content = html.UnescapeString(reportChapter.Content)
  250. reportChapterItem.VideoUrl = reportChapter.VideoUrl
  251. //底部菜单切换
  252. if reportInfo.ClassifyNameFirst == "周报" {
  253. chapterMenu, err = GetMenuChapter(reportInfo.Id, newTypeIds, reportInfo.ClassifyNameFirst, reportInfo.CreateTime)
  254. }else{
  255. chapterMenu, err = GetMenuChapter(reportInfo.Id, typeIds, reportInfo.ClassifyNameFirst, reportInfo.CreateTime)
  256. }
  257. //查询点赞数
  258. likeNum,likeEnabled, _ = services.GetReportLikeByReportIdOldReportId(user.UserID, reportInfo.Id, reportChapter.ReportChapterId,0,0)
  259. go AddViewRecord(user, reportInfo.Id, reportInfo.ClassifyNameFirst, reportChapterId)
  260. }else{
  261. reportChapterItem.ContentSub = html.UnescapeString(reportChapter.ContentSub)
  262. }
  263. go AddUserAccessRecord(user, reportInfo.Id, reportInfo.ClassifyNameFirst, reportChapterId, authOk)
  264. reportChapterDetail = new(response.ReportChapterDetail)
  265. reportChapterDetail.ReportChapterItem = reportChapterItem
  266. reportChapterDetail.PermissionCheck = &permissionCheckInfo
  267. reportChapterDetail.ReportChapterMenuList = chapterMenu
  268. reportChapterDetail.AuthOk = authOk
  269. reportChapterDetail.LikeNum = likeNum
  270. reportChapterDetail.LikeEnabled = likeEnabled
  271. return
  272. }
  273. func GetMenuChapter(reportId int, typeIds []int, classifyNameFirst string, reportCreateTime time.Time) (reportTypeList response.ReportChapterMenuList, err error) {
  274. //查询有效的章节
  275. typeList, tErr := report_chapter_type.GetEffectTypes()
  276. if tErr != nil {
  277. return
  278. }
  279. if len(typeList) == 0 {
  280. err = errors.New("无有效的章节")
  281. return
  282. }
  283. typeMap := make(map[uint64]*report_chapter_type.ReportChapterType)
  284. for _, v := range typeList {
  285. typeMap[v.ReportChapterTypeId] = v
  286. }
  287. //获取所有当前研报的章节
  288. chapterList, tErr := report_chapter.GetListByReportIdTypeIds(reportId, typeIds, classifyNameFirst)
  289. if tErr != nil && tErr != utils.ErrNoRow{
  290. return
  291. }
  292. if len(chapterList) > 0 {
  293. for _, item := range chapterList {
  294. if typeItem, ok := typeMap[uint64(item.TypeId)]; ok {
  295. if reportCreateTime.Before(typeItem.PauseStartTime) || reportCreateTime.After(typeItem.PauseEndTime) {
  296. temp := new(response.ReportChapterMenu)
  297. temp.ReportChapterId = item.ReportChapterId
  298. temp.ReportId = item.ReportId
  299. temp.ReportChapterTypeName = typeItem.ReportChapterTypeName
  300. temp.ReportChapterTypeThumb = typeItem.YbBottomIcon
  301. temp.Sort = typeItem.Sort
  302. reportTypeList = append(reportTypeList, temp)
  303. }
  304. }
  305. }
  306. }
  307. if len(reportTypeList) > 0{
  308. sort.Sort(reportTypeList)
  309. }
  310. return
  311. }
  312. // CheckWeekReportPermission 验证周报的权限
  313. func CheckWeekReportPermission(userInfo user.UserInfo, productAuthOk bool) (authOk bool, permissionCheckInfo response.PermissionCheckInfo, validTypeIds []int, err error) {
  314. var permissionIds []int
  315. var validPermissionIds []int //最后允许显示的章节
  316. if productAuthOk {
  317. permissionIds, err = chart_permission_chapter_mapping.GetPermissionIdsByWeek()
  318. if err != nil && err != utils.ErrNoRow {
  319. return
  320. }
  321. }
  322. authOk, permissionCheckInfo, validPermissionIds, err = company.GetCheckPermission(userInfo.CompanyID, int(userInfo.UserID), permissionIds)
  323. if err != nil {
  324. return
  325. }
  326. //返回可用的章节列表
  327. if len(validPermissionIds) > 0 {
  328. validTypeIds, err = chart_permission_chapter_mapping.GetReportIdsByPermisssionIds(validPermissionIds, "week")
  329. }
  330. return
  331. }
  332. // CheckDayReportPermission 验证晨报的权限
  333. func CheckDayReportPermission(userInfo user.UserInfo, productAuthOk bool) (authOk bool, permissionCheckInfo response.PermissionCheckInfo, err error) {
  334. if productAuthOk {
  335. authOk = true
  336. return
  337. }
  338. authOk, permissionCheckInfo,_, err = company.GetCheckPermission(userInfo.CompanyID, int(userInfo.UserID), []int{})
  339. return
  340. }
  341. // GetReportChapterVideoList 根据报告获取章节的音频列表
  342. func GetReportChapterVideoList(permissionIds []int, classifyName string, list []*report.Report) (videoMap map[int][]*response.VideoListItem, weekAuthMap map[int]bool, errMsg string, err error) {
  343. videoMap = make(map[int][]*response.VideoListItem)
  344. weekAuthMap = make(map[int]bool)
  345. var reportIds []int
  346. reportMap := make(map[int]*report.Report)
  347. for _, reportInfo := range list {
  348. reportMap[reportInfo.Id] = reportInfo
  349. reportIds = append(reportIds, reportInfo.Id)
  350. }
  351. // 查询有效的章节
  352. //查询有效的章节
  353. typeList, tErr := report_chapter_type.GetEffectTypes()
  354. if tErr != nil {
  355. errMsg = tErr.Error()
  356. err = errors.New("章节类型查询出错")
  357. return
  358. }
  359. if len(typeList) == 0 {
  360. err = errors.New("无有效的章节")
  361. return
  362. }
  363. typeMap := make(map[int]*report_chapter_type.ReportChapterType)
  364. var typeIds []int
  365. for _, v := range typeList {
  366. typeMap[int(v.ReportChapterTypeId)] = v
  367. typeIds = append(typeIds, int(v.ReportChapterTypeId))
  368. }
  369. var chapters []*report_chapter.ReportChapter
  370. if classifyName == "周报" {
  371. // 查询用户有权限的章节ID
  372. newTypeIds, tErr := GetWeekTypeIdsByPermissionIds(permissionIds, typeIds)
  373. if tErr != nil {
  374. errMsg = tErr.Error()
  375. err = errors.New("查询章节类型权限出错")
  376. return
  377. }
  378. // 查询章节列表
  379. chapters, err = report_chapter.GetByTypeIdsAndReportIds(newTypeIds, reportIds, classifyName)
  380. }else{
  381. // 查询章节列表
  382. chapters, err = report_chapter.GetByTypeIdsAndReportIds(typeIds, reportIds, classifyName)
  383. }
  384. if err != nil {
  385. errMsg = err.Error()
  386. err = errors.New("查询章节出错")
  387. return
  388. }
  389. for _, v := range chapters {
  390. if classifyName == "周报" {
  391. weekAuthMap[v.ReportId] = true
  392. }
  393. if temp, ok := typeMap[v.TypeId]; ok && v.VideoUrl != "" {
  394. if reportDetail, ok1 := reportMap[v.ReportId]; ok1 {
  395. reportDate := reportDetail.CreateTime
  396. if reportDate.Before(temp.PauseStartTime) || reportDate.After(temp.PauseEndTime) {
  397. videoItem := new(response.VideoListItem)
  398. videoItem.VideoPlaySeconds = v.VideoPlaySeconds
  399. videoItem.VideoName = v.VideoName
  400. if v.VideoName == "" {
  401. videoItem.VideoName = v.Title
  402. }
  403. videoItem.VideoUrl = v.VideoUrl
  404. videoItem.Sort = v.Sort
  405. videoMap[v.ReportId] = append(videoMap[v.ReportId], videoItem)
  406. }
  407. }
  408. }
  409. }
  410. return
  411. }