report.go 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011
  1. package report
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. report_chapter_type_cache "hongze/hongze_yb/cache/report_chapter_type"
  7. "hongze/hongze_yb/global"
  8. "hongze/hongze_yb/models/response"
  9. "hongze/hongze_yb/models/response/purchase"
  10. "hongze/hongze_yb/models/tables/chart_permission"
  11. "hongze/hongze_yb/models/tables/chart_permission_chapter_mapping"
  12. "hongze/hongze_yb/models/tables/chart_permission_search_key_word_mapping"
  13. "hongze/hongze_yb/models/tables/company_product"
  14. "hongze/hongze_yb/models/tables/daily_base_column"
  15. "hongze/hongze_yb/models/tables/rddp/classify"
  16. "hongze/hongze_yb/models/tables/rddp/classify_menu"
  17. "hongze/hongze_yb/models/tables/rddp/report"
  18. "hongze/hongze_yb/models/tables/rddp/report_chapter"
  19. "hongze/hongze_yb/models/tables/rddp/report_chapter_ticker"
  20. "hongze/hongze_yb/models/tables/rddp/report_ppt_img"
  21. "hongze/hongze_yb/models/tables/rddp/smart_report_resource"
  22. "hongze/hongze_yb/models/tables/report_chapter_type"
  23. "hongze/hongze_yb/models/tables/report_chapter_type_permission"
  24. "hongze/hongze_yb/models/tables/user_report_chapter_set"
  25. "hongze/hongze_yb/models/tables/yb_road_video"
  26. "hongze/hongze_yb/services"
  27. "hongze/hongze_yb/services/collection"
  28. "hongze/hongze_yb/services/company"
  29. elasticService "hongze/hongze_yb/services/elastic"
  30. "hongze/hongze_yb/services/user"
  31. "hongze/hongze_yb/utils"
  32. "html"
  33. "sort"
  34. "strconv"
  35. "strings"
  36. "time"
  37. )
  38. // GetLatestClassReport 已购列表最新报告
  39. func GetLatestClassReport(permissionIds []int, userId uint64) (purchaseList []*purchase.PurchaseListItem, err error) {
  40. var errMsg string
  41. defer func() {
  42. if sysErr := recover(); sysErr != nil {
  43. err = errors.New("系统错误")
  44. global.LOG.Critical(fmt.Sprintf("GetLatestClassReport: userId=%d, err:%s,sysErr:%s", userId, err.Error(), sysErr))
  45. }
  46. if err != nil {
  47. global.LOG.Critical(fmt.Sprintf("GetLatestClassReport: userId=%d, err:%s, errMsg:%s", userId, err.Error(), errMsg))
  48. }
  49. }()
  50. //获取所有分类信息
  51. classifys, err := classify.GetSimpleAll()
  52. if err != nil {
  53. errMsg = err.Error()
  54. err = errors.New("分类查询出错")
  55. return
  56. }
  57. classifyFirstIconMap := make(map[int]string)
  58. //classifySecondNameMap := make(map[int]int)
  59. classifyFirstIdMap := make(map[int]bool)
  60. classifySecondIdMap := make(map[int]bool)
  61. for _, v := range classifys {
  62. if v.ParentId == 0 {
  63. classifyFirstIdMap[v.Id] = true
  64. classifyFirstIconMap[v.Id] = v.YbIconUrl
  65. } else {
  66. classifySecondIdMap[v.Id] = true
  67. //classifySecondNameMap[v.Id] = v.Id
  68. }
  69. }
  70. //获取最新的晨报
  71. dayReport, err := report.GetLatestDay()
  72. if err != nil {
  73. errMsg = err.Error()
  74. err = errors.New("晨报查询出错")
  75. return
  76. }
  77. //获取最新的有权限的周报
  78. //typeIds, err := report_chapter_type.GetEffectTypeID()
  79. typeIds, err := report_chapter_type_cache.GetEffectTypeID()
  80. if err != nil {
  81. errMsg = err.Error()
  82. err = errors.New("晨报查询出错")
  83. return
  84. }
  85. weekReport, err := GetLatestWeek(permissionIds, typeIds)
  86. if err != nil {
  87. errMsg = err.Error()
  88. err = errors.New("周报查询出错")
  89. return
  90. }
  91. // 有权限的二级分类
  92. var reports []*report.Report
  93. var classifyIdSeconds []int
  94. classifyIdSecondMap := make(map[int]bool)
  95. // 获取晨报和周报以外的其他报告
  96. // 获取有权限的二级分类
  97. chartPermissions, err := chart_permission_search_key_word_mapping.GetChartPermissionByFrom("rddp")
  98. if err != nil {
  99. errMsg = err.Error()
  100. err = errors.New("分类权限查询出错")
  101. return
  102. }
  103. if len(chartPermissions) > 0 {
  104. for _, v := range chartPermissions {
  105. for _, myPerId := range permissionIds {
  106. if v.ChartPermissionId == myPerId {
  107. if classifySecondIdMap[v.ClassifyId] {
  108. if _, ok := classifyIdSecondMap[v.ClassifyId]; !ok {
  109. classifyIdSeconds = append(classifyIdSeconds, v.ClassifyId)
  110. classifyIdSecondMap[v.ClassifyId] = true
  111. }
  112. }
  113. break
  114. }
  115. }
  116. }
  117. }
  118. reports, err = report.GetLatestClassReportsByClassifyIdSeconds(classifyIdSeconds)
  119. if err != nil {
  120. errMsg = err.Error()
  121. err = errors.New("二级分类最新报告查询出错")
  122. return
  123. }
  124. if dayReport.Id > 0 {
  125. reports = append(reports, dayReport)
  126. }
  127. if weekReport != nil && weekReport.Id > 0 {
  128. reports = append(reports, weekReport)
  129. }
  130. //获取未读数
  131. unReadItem, tErr := GetUnRead(classifyIdSeconds, userId)
  132. if tErr != nil {
  133. err = tErr
  134. return
  135. }
  136. if len(reports) > 0 {
  137. otherLatestItem := new(purchase.PurchaseListItem)
  138. // 处理其他报告()
  139. for _, v := range reports {
  140. temp := new(purchase.PurchaseListItem)
  141. temp.ReportId = v.Id
  142. temp.ClassifyIdFirst = v.ClassifyIdFirst
  143. temp.ClassifyNameFirst = v.ClassifyNameFirst
  144. temp.Stage = v.Stage
  145. temp.Title = v.Title
  146. temp.ClassifyIdSecond = v.ClassifyIdSecond
  147. temp.ClassifyNameSecond = v.ClassifyNameSecond
  148. temp.Time = v.PublishTime
  149. if temp.ClassifyNameFirst == "大事点评" || temp.ClassifyNameFirst == "会议纪要" || temp.ClassifyNameFirst == "年报合集" {
  150. if otherLatestItem.Time.Format(utils.FormatDateTime) > v.PublishTime.Format(utils.FormatDateTime) {
  151. continue
  152. }
  153. temp.Unread = unReadItem["大事点评"] + unReadItem["会议纪要"] + unReadItem["年报合集"]
  154. temp.Content = fmt.Sprintf("【第%d期|FICC】%s", temp.Stage, temp.ClassifyNameFirst)
  155. temp.ImgUrl = "https://hzstatic.hzinsights.com/static/yb_wx/purchase_icon_other.png"
  156. otherLatestItem = temp
  157. }
  158. }
  159. for _, v := range reports {
  160. if v.ClassifyNameFirst != "晨报" && v.ClassifyNameFirst != "周报" {
  161. // 报告的分类不存在
  162. if !classifyFirstIdMap[v.ClassifyIdFirst] || !classifyIdSecondMap[v.ClassifyIdSecond] {
  163. continue
  164. }
  165. }
  166. temp := new(purchase.PurchaseListItem)
  167. temp.ReportId = v.Id
  168. temp.ClassifyIdFirst = v.ClassifyIdFirst
  169. temp.ClassifyNameFirst = v.ClassifyNameFirst
  170. temp.Stage = v.Stage
  171. temp.Title = v.Title
  172. temp.ClassifyIdSecond = v.ClassifyIdSecond
  173. temp.ClassifyNameSecond = v.ClassifyNameSecond
  174. temp.Time = v.PublishTime
  175. temp.Unread = unReadItem[temp.ClassifyNameFirst]
  176. if imgUrl, ok := classifyFirstIconMap[temp.ClassifyIdFirst]; ok {
  177. temp.ImgUrl = imgUrl
  178. }
  179. if temp.ClassifyNameFirst == "晨报" || temp.ClassifyNameFirst == "周报" { //晨报或者周报,查询最新的章节信息
  180. temp.Content = fmt.Sprintf("【第%d期|FICC】%s", temp.Stage, temp.Title)
  181. } else if temp.ClassifyNameFirst == "大事点评" || temp.ClassifyNameFirst == "会议纪要" || temp.ClassifyNameFirst == "年报合集" {
  182. continue
  183. } else {
  184. if temp.ClassifyNameFirst != temp.ClassifyNameSecond { //包含二级分类
  185. temp.Content = fmt.Sprintf("【第%d期|FICC| %s】%s", temp.Stage, temp.ClassifyNameSecond, temp.ClassifyNameFirst)
  186. } else { //无二级分类
  187. temp.Content = fmt.Sprintf("【第%d期|FICC】%s", temp.Stage, temp.ClassifyNameFirst)
  188. }
  189. }
  190. purchaseList = append(purchaseList, temp)
  191. }
  192. if otherLatestItem.ReportId > 0 {
  193. purchaseList = append(purchaseList, otherLatestItem)
  194. }
  195. }
  196. return
  197. }
  198. // GetPurchaseDetail 已购详情页面
  199. func GetPurchaseDetail(permissionIds []int, userId uint64, classifyIdFirst int, pageIndex, pageSize int) (ret *purchase.DetailResp, err error) {
  200. var errMsg string
  201. defer func() {
  202. if err != nil {
  203. global.LOG.Critical(fmt.Sprintf("GetPurchaseDetail: userId=%d, err:%s, errMsg:%s", userId, err.Error(), errMsg))
  204. }
  205. }()
  206. var reports []*report.Report
  207. var weekReportIds []int
  208. classifyInfo, err := classify.GetByClassifyId(classifyIdFirst)
  209. if err != nil {
  210. errMsg = err.Error()
  211. err = errors.New("分类查询出错")
  212. return
  213. }
  214. if classifyInfo.Id == 0 {
  215. err = errors.New("分类不存在")
  216. return
  217. }
  218. classifyNameFirst := classifyInfo.ClassifyName
  219. offset := (pageIndex - 1) * pageSize
  220. var total int64
  221. var classifyIdSeconds []int
  222. if classifyNameFirst == "晨报" {
  223. //分类获取
  224. reports, err = report.GetListByClassifyIdFirst(classifyIdFirst, offset, pageSize)
  225. if err != nil {
  226. errMsg = err.Error()
  227. err = errors.New("晨报查询出错")
  228. return
  229. }
  230. total, err = report.GetListCountByClassifyIdFirst(classifyIdFirst)
  231. if err != nil {
  232. errMsg = err.Error()
  233. err = errors.New("查询报告总数出错")
  234. return
  235. }
  236. } else {
  237. if classifyNameFirst == "周报" {
  238. newTypeIds, tErr := GetWeekTypeIdsByPermissionIds(permissionIds, []int{})
  239. if tErr != nil {
  240. return
  241. }
  242. weekReportIds, err = report_chapter.GetReportIdsByTypeIdsAndClass(newTypeIds, classifyNameFirst)
  243. //分类获取
  244. reports, err = report.GetListByIDsAndClassifyIdFirst(weekReportIds, classifyIdFirst, offset, pageSize)
  245. if err != nil {
  246. return
  247. }
  248. total, err = report.GetListCountByIDsAndClassifyIdFirst(weekReportIds, classifyIdFirst)
  249. if err != nil {
  250. errMsg = err.Error()
  251. err = errors.New("查询报告总数出错")
  252. return
  253. }
  254. } else {
  255. //获取有权限的二级分类
  256. var classifyNameSeconds []string
  257. chartPermissions, tErr := chart_permission_search_key_word_mapping.GetChartPermissionByFrom("rddp")
  258. if tErr != nil {
  259. errMsg = tErr.Error()
  260. err = errors.New("分类权限查询出错")
  261. return
  262. }
  263. if len(chartPermissions) > 0 {
  264. for _, v := range chartPermissions {
  265. for _, myPerId := range permissionIds {
  266. if v.ChartPermissionId == myPerId {
  267. if classifyNameFirst == "大事点评" || classifyNameFirst == "会议纪要" || classifyNameFirst == "年报合集" {
  268. if v.KeyWord == "大事点评" || v.KeyWord == "会议纪要" || v.KeyWord == "年报合集" { //筛选出用户有权限的二级分类ID
  269. classifyNameSeconds = append(classifyNameSeconds, v.KeyWord)
  270. }
  271. } else {
  272. classifyNameSeconds = append(classifyNameSeconds, v.KeyWord)
  273. }
  274. break
  275. }
  276. }
  277. }
  278. }
  279. //获取所有二级分类的id
  280. if classifyNameFirst == "大事点评" || classifyNameFirst == "会议纪要" || classifyNameFirst == "年报合集" {
  281. classifyIdSeconds, tErr = classify.GetOtherSecondIds([]string{"大事点评", "会议纪要", "年报合集"})
  282. } else {
  283. classifyIdSeconds, tErr = classify.GetIdsByClassifyNameAndParentId(classifyNameSeconds, classifyIdFirst)
  284. }
  285. if tErr != nil {
  286. errMsg = tErr.Error()
  287. err = errors.New("二级分类查询出错")
  288. return
  289. }
  290. if len(classifyIdSeconds) > 0 {
  291. //分类获取
  292. reports, err = report.GetListByClassifyIdSeconds(classifyIdSeconds, offset, pageSize)
  293. if err != nil {
  294. return
  295. }
  296. total, err = report.GetListCountByClassifyIdSeconds(classifyIdSeconds)
  297. if err != nil {
  298. errMsg = err.Error()
  299. err = errors.New("查询报告总数出错")
  300. return
  301. }
  302. }
  303. }
  304. }
  305. var list []*purchase.Detail
  306. ret = new(purchase.DetailResp)
  307. if len(reports) > 0 {
  308. var viewReportIds []int
  309. for _, v := range reports {
  310. viewReportIds = append(viewReportIds, v.Id)
  311. temp := new(purchase.Detail)
  312. temp.ReportId = v.Id
  313. temp.ClassifyIdFirst = v.ClassifyIdFirst
  314. temp.ClassifyNameFirst = v.ClassifyNameFirst
  315. temp.Title = v.Title
  316. temp.ClassifyIdSecond = v.ClassifyIdSecond
  317. temp.ClassifyNameSecond = v.ClassifyNameSecond
  318. temp.Stage = v.Stage
  319. temp.ImgUrl = classifyInfo.YbBgUrl
  320. if temp.ClassifyNameFirst == "晨报" || temp.ClassifyNameFirst == "周报" { //晨报或者周报,查询最新的章节信息
  321. temp.Content = fmt.Sprintf("【第%d期|FICC】%s", temp.Stage, temp.Title)
  322. temp.TopName = temp.Title
  323. } else {
  324. if temp.ClassifyNameFirst != temp.ClassifyNameSecond { //包含二级分类
  325. temp.Content = fmt.Sprintf("【第%d期|FICC| %s】%s", temp.Stage, temp.ClassifyNameSecond, temp.ClassifyNameFirst)
  326. temp.TopName = temp.ClassifyNameSecond
  327. } else {
  328. temp.Content = fmt.Sprintf("【第%d期|FICC】%s", temp.Stage, temp.ClassifyNameFirst)
  329. temp.TopName = temp.ClassifyNameFirst
  330. }
  331. }
  332. temp.Time = v.PublishTime
  333. list = append(list, temp)
  334. }
  335. }
  336. ret.List = list
  337. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  338. // 执行一个协程任务,新增用户浏览记录
  339. //_, tErr := BatchInsertReportView(weekReportIds, userId, classifyNameFirst, classifyIdSeconds)
  340. go BatchInsertReportView(userId, weekReportIds, classifyNameFirst, classifyIdSeconds)
  341. /*if tErr != nil {
  342. err = tErr
  343. return
  344. }*/
  345. return
  346. }
  347. // 获取报告详情
  348. func GetReportDetail(userinfo user.UserInfo, reportId int) (reportDetail response.ReportDetail, err error) {
  349. var errMsg string
  350. defer func() {
  351. if err != nil {
  352. global.LOG.Critical(fmt.Sprintf("GetReportDetail: userId=%d, err:%s, errMsg:%s", userinfo.UserID, err.Error(), errMsg))
  353. }
  354. }()
  355. // 判断用户状态是否是正常和永续
  356. var productAuthOk bool
  357. companyProduct, err := company_product.GetByCompany2ProductId(userinfo.CompanyID, 1)
  358. if err == utils.ErrNoRow {
  359. err = nil
  360. }
  361. if err != nil {
  362. errMsg = err.Error()
  363. err = errors.New("查询用户购买产品出错")
  364. return
  365. }
  366. if companyProduct != nil {
  367. // 无FICC权限的客户不可见
  368. if companyProduct.CompanyProductID > 0 {
  369. // 已购或者试用用户可见
  370. if strings.Contains("永续,正式", companyProduct.Status) || (companyProduct.Status == "试用" && companyProduct.IsSuspend != 1) {
  371. productAuthOk = true
  372. }
  373. }
  374. }
  375. reportInfo, err := report.GetByReportId(reportId)
  376. if err != nil {
  377. errMsg = err.Error()
  378. err = errors.New("报告查询出错")
  379. return
  380. }
  381. if reportInfo.Id == 0 {
  382. err = errors.New("报告不存在")
  383. return
  384. }
  385. if reportInfo.State != 2 && reportInfo.State != 6 {
  386. err = errors.New("报告未发布")
  387. return
  388. }
  389. // 判断报告是否属于专栏报告
  390. firstClassify, e := classify.GetByClassifyId(reportInfo.ClassifyIdFirst)
  391. if e != nil {
  392. err = errors.New("报告一级分类有误")
  393. return
  394. }
  395. //判断权限
  396. var authOk bool
  397. var permissionCheckInfo response.PermissionCheckInfo
  398. var vaildWeekTypeIds []int
  399. if reportInfo.ClassifyNameFirst == "晨报" {
  400. authOk, permissionCheckInfo, err = CheckDayReportPermission(userinfo, productAuthOk)
  401. } else if reportInfo.ClassifyNameFirst == "周报" {
  402. authOk, permissionCheckInfo, vaildWeekTypeIds, err = CheckWeekReportPermission(userinfo, productAuthOk)
  403. } else {
  404. authOk, permissionCheckInfo, err = CheckReportPermission(userinfo, reportId, productAuthOk)
  405. }
  406. if err != nil {
  407. return
  408. }
  409. reportItem := new(response.ReportItem)
  410. reportItem.ReportId = reportInfo.Id
  411. reportItem.Title = reportInfo.Title
  412. reportItem.PublishTime = reportInfo.PublishTime
  413. reportItem.ClassifyNameFirst = reportInfo.ClassifyNameFirst
  414. reportItem.ClassifyNameSecond = reportInfo.ClassifyNameSecond
  415. reportItem.Stage = reportInfo.Stage
  416. reportItem.Abstract = reportInfo.Abstract
  417. reportItem.ContentSub = html.UnescapeString(reportInfo.ContentSub)
  418. reportItem.Frequency = reportInfo.Frequency
  419. reportItem.VideoName = reportInfo.VideoName
  420. reportItem.ReportLayout = reportInfo.ReportLayout
  421. reportItem.HeadImg = reportInfo.HeadImg
  422. reportItem.EndImg = reportInfo.EndImg
  423. reportItem.CanvasColor = reportInfo.CanvasColor
  424. // 版头版尾样式
  425. {
  426. if reportInfo.HeadResourceId > 0 {
  427. headResource, tmpErr := smart_report_resource.GetResourceItemById(reportInfo.HeadResourceId)
  428. if tmpErr != nil {
  429. err = tmpErr
  430. return
  431. }
  432. reportItem.HeadImg = headResource.ImgURL
  433. reportItem.HeadStyle = headResource.Style
  434. }
  435. if reportInfo.EndResourceId > 0 {
  436. endResource, tmpErr := smart_report_resource.GetResourceItemById(reportInfo.EndResourceId)
  437. if tmpErr != nil {
  438. err = tmpErr
  439. return
  440. }
  441. reportItem.EndImg = endResource.ImgURL
  442. reportItem.EndStyle = endResource.Style
  443. }
  444. }
  445. if reportInfo.VideoName == "" && reportInfo.VideoUrl != "" {
  446. reportItem.VideoName = reportInfo.Title
  447. }
  448. reportItem.VideoSize = reportInfo.VideoSize
  449. reportItem.VideoPlaySeconds = reportInfo.VideoPlaySeconds
  450. reportItem.Author = reportInfo.Author
  451. // 分享背景图取二级分类配图, 二级没有配图时使用一级配图, 一级也没有使用默认图
  452. reportItem.ShareBgImg = utils.DEFAULT_REPORT_SHARE_BG_IMG
  453. secondClassify, e := classify.GetByClassifyId(reportInfo.ClassifyIdSecond)
  454. if e != nil {
  455. err = errors.New("报告二级分类有误")
  456. return
  457. }
  458. if secondClassify.YbShareBgImg != "" {
  459. reportItem.ShareBgImg = secondClassify.YbShareBgImg
  460. } else {
  461. if firstClassify.YbShareBgImg != "" {
  462. reportItem.ShareBgImg = firstClassify.YbShareBgImg
  463. }
  464. }
  465. var reportTypeList []*response.ReportChapterListItem
  466. if reportInfo.HasChapter == 1 {
  467. //(晨报和周报的banner图)
  468. if reportInfo.ClassifyNameFirst == "晨报" {
  469. reportItem.BannerUrl = utils.ALIYUN_YBIMG_HOST + "report_banner_day.jpg"
  470. } else {
  471. reportItem.BannerUrl = utils.ALIYUN_YBIMG_HOST + "report_banner_week.jpg"
  472. }
  473. // 如果还没有配置banner图,则取晨报的
  474. if reportItem.BannerUrl == `` {
  475. reportItem.BannerUrl = utils.ALIYUN_YBIMG_HOST + "report_banner_day.jpg"
  476. }
  477. if authOk {
  478. reportTypeList, err = GetChapterListByReport(reportInfo.ClassifyNameFirst, reportInfo.Id, vaildWeekTypeIds, reportInfo.CreateTime)
  479. if err != nil {
  480. return
  481. }
  482. }
  483. } else {
  484. // 音频播放条图片用分类图片
  485. reportItem.VideoImg = utils.HZ_DEFAULT_AVATAR
  486. permissionIds, tmpErr := chart_permission_search_key_word_mapping.GetChartPermissionIdsByKeyWord(reportInfo.ClassifyIdSecond)
  487. if tmpErr != nil {
  488. errMsg = tmpErr.Error()
  489. err = errors.New("查询报告权限失败")
  490. return
  491. }
  492. if len(permissionIds) > 0 {
  493. chartPermission, tmpErr := chart_permission.GetListByIds(permissionIds)
  494. if tmpErr != nil {
  495. errMsg = tmpErr.Error()
  496. err = errors.New("查询品种信息失败")
  497. return
  498. }
  499. lenChart := len(chartPermission)
  500. for i := 0; i < lenChart; i++ {
  501. if chartPermission[i].YbImgUrl != "" {
  502. reportItem.VideoImg = utils.ALIYUN_YBIMG_HOST + chartPermission[i].YbImgUrl
  503. break
  504. }
  505. }
  506. }
  507. }
  508. //如果有权限则展示content
  509. var likeNum int64
  510. var likeEnabled int8
  511. if authOk {
  512. go AddViewRecord(userinfo, reportInfo.Id, reportInfo.ClassifyNameFirst, 0)
  513. reportItem.Content = html.UnescapeString(reportInfo.Content)
  514. reportItem.VideoUrl = reportInfo.VideoUrl
  515. //查询点赞数
  516. likeNum, likeEnabled, _ = services.GetReportLikeByReportIdOldReportId(userinfo.UserID, reportInfo.Id, 0, 0, 0)
  517. }
  518. //处理章节品种,音频开关
  519. {
  520. chapterSetList, err := user_report_chapter_set.GetUserReportChapterSet(userinfo.UserID)
  521. if err != nil {
  522. return reportDetail, err
  523. }
  524. setList := make([]*user_report_chapter_set.UserReportChapterSet, 0)
  525. reportTypeLen := len(reportTypeList)
  526. if len(chapterSetList) == 0 {
  527. for _, v := range reportTypeList {
  528. setItem := new(user_report_chapter_set.UserReportChapterSet)
  529. setItem.UserId = userinfo.UserID
  530. setItem.TypeId = v.TypeId
  531. setItem.TypeName = v.TypeName
  532. setItem.CreateTime = time.Now()
  533. setItem.ModifyTime = time.Now()
  534. setItem.IsClose = 0
  535. setList = append(setList, setItem)
  536. }
  537. } else {
  538. chapterSetMap := make(map[int]int)
  539. for _, v := range chapterSetList {
  540. chapterSetMap[v.TypeId] = v.IsClose
  541. }
  542. for i := 0; i < reportTypeLen; i++ {
  543. typeItem := reportTypeList[i]
  544. if findIsClose, ok := chapterSetMap[typeItem.TypeId]; ok {
  545. reportTypeList[i].IsClose = findIsClose
  546. } else {
  547. setItem := new(user_report_chapter_set.UserReportChapterSet)
  548. setItem.UserId = userinfo.UserID
  549. setItem.TypeId = typeItem.TypeId
  550. setItem.TypeName = typeItem.TypeName
  551. setItem.CreateTime = time.Now()
  552. setItem.ModifyTime = time.Now()
  553. setItem.IsClose = 0
  554. setList = append(setList, setItem)
  555. }
  556. }
  557. }
  558. if len(setList) > 0 {
  559. err = user_report_chapter_set.AddUserReportChapterSet(setList)
  560. if err != nil {
  561. return reportDetail, err
  562. }
  563. }
  564. }
  565. //新增用户访问日志
  566. go AddUserAccessRecord(userinfo, reportInfo.Id, reportInfo.ClassifyNameFirst, 0, authOk)
  567. reportDetail.ReportInfo = reportItem
  568. reportDetail.ReportChapterList = reportTypeList
  569. reportDetail.PermissionCheck = &permissionCheckInfo
  570. reportDetail.AuthOk = authOk
  571. reportDetail.LikeNum = likeNum
  572. reportDetail.LikeEnabled = likeEnabled
  573. reportDetail.ReportShowType = int(firstClassify.ShowType)
  574. // 收藏
  575. collectionId, e := collection.GetUserCollectByItem(int(userinfo.UserID), collection.CollectionTypeReport, reportId, 0)
  576. if e != nil {
  577. err = e
  578. return
  579. }
  580. reportDetail.CollectionId = collectionId
  581. // 绑定的路演视频
  582. roadVideo, e := yb_road_video.GetItemByReportId(reportId)
  583. if e != nil && e != utils.ErrNoRow {
  584. err = e
  585. return
  586. }
  587. if roadVideo != nil && roadVideo.RoadVideoID > 0 {
  588. reportDetail.RoadVideoId = roadVideo.RoadVideoID
  589. }
  590. return
  591. }
  592. // CheckReportPermission 验证用户查看报告的权限
  593. func CheckReportPermission(userInfo user.UserInfo, reportId int, productAuthOk bool) (authOk bool, permissionCheckInfo response.PermissionCheckInfo, err error) {
  594. var permissionIds []int
  595. if productAuthOk {
  596. permissionIds, err = chart_permission_chapter_mapping.GetPermissionIdsByReportId(reportId, "rddp")
  597. if err != nil && err != utils.ErrNoRow {
  598. return
  599. }
  600. }
  601. authOk, permissionCheckInfo, _, err = company.GetCheckPermission(userInfo.CompanyID, int(userInfo.UserID), permissionIds)
  602. return
  603. }
  604. // GetReportList 获取报告列表
  605. func GetReportList(user user.UserInfo, keyWord string, classifyIdFirst, classifyIdSecond, pageIndex, pageSize, classifyMenuId int) (ret *response.ReportList, err error) {
  606. var errMsg string
  607. defer func() {
  608. if err != nil {
  609. global.LOG.Critical(fmt.Sprintf("GetReportList: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  610. }
  611. }()
  612. // 判断用户状态是否是正常和永续
  613. var productAuthOk bool
  614. companyProduct, err := company_product.GetByCompany2ProductId(user.CompanyID, 1)
  615. if err == utils.ErrNoRow {
  616. err = nil
  617. }
  618. if err != nil {
  619. errMsg = err.Error()
  620. err = errors.New("查询用户购买产品出错")
  621. return
  622. }
  623. if companyProduct != nil {
  624. // 无FICC权限的客户不可见
  625. if companyProduct.CompanyProductID > 0 {
  626. // 已购或者试用用户可见
  627. if strings.Contains("永续,正式", companyProduct.Status) || (companyProduct.Status == "试用" && companyProduct.IsSuspend != 1) {
  628. productAuthOk = true
  629. }
  630. }
  631. }
  632. var condition string
  633. pars := make([]interface{}, 0)
  634. classifyParent, err := classify.GetByClassifyId(classifyIdFirst)
  635. if err != nil {
  636. errMsg = err.Error()
  637. err = errors.New("分类查询出错")
  638. return
  639. }
  640. if classifyParent.Id == 0 {
  641. err = errors.New("该分类不存在")
  642. return
  643. }
  644. condition = `classify_id_first = ? and state IN (2, 6)`
  645. pars = append(pars, classifyIdFirst)
  646. // 子目录
  647. menuClassifyIds := make([]int, 0)
  648. menuClassifyLen := 0
  649. if classifyMenuId > 0 {
  650. ids, e := classify_menu.GetClassifyIdsByMenuId(classifyMenuId)
  651. if e != nil {
  652. err = errors.New("获取子目录关联分类信息失败, Err: " + e.Error())
  653. return
  654. }
  655. menuClassifyIds = ids
  656. menuClassifyLen = len(menuClassifyIds)
  657. if menuClassifyLen == 0 {
  658. condition += ` AND 1 = 2`
  659. }
  660. }
  661. permissionMap := make(map[int][]int)
  662. checkPermissionMap := make(map[int]bool)
  663. //permissionImageMap := make(map[string]string)
  664. chartPermissionImageMap := make(map[int]string)
  665. var classifyIdSeconds []int
  666. //var reportImgUrl string
  667. chartPermissionList, err := chart_permission.GetFiccListExceptTacticByProductId()
  668. if err != nil {
  669. errMsg = err.Error()
  670. err = errors.New("分类查询出错")
  671. return
  672. }
  673. if len(chartPermissionList) > 0 {
  674. for _, v := range chartPermissionList {
  675. chartPermissionImageMap[int(v.ChartPermissionID)] = v.YbImgUrl
  676. }
  677. }
  678. if classifyIdSecond > 0 && keyWord == "" {
  679. classifyInfo, tErr := classify.GetByClassifyId(classifyIdSecond)
  680. if tErr != nil {
  681. errMsg = tErr.Error()
  682. err = errors.New("分类查询出错")
  683. return
  684. }
  685. if classifyInfo.Id == 0 {
  686. err = errors.New("该二级分类不存在")
  687. return
  688. }
  689. condition += " AND classify_id_second = ?"
  690. pars = append(pars, classifyIdSecond)
  691. //查询二级分类对应的权限
  692. permissionIds, tErr := chart_permission_search_key_word_mapping.GetChartPermissionIdsByKeyWord(classifyIdSecond)
  693. if tErr != nil {
  694. errMsg = tErr.Error()
  695. err = errors.New("分类权限查询出错")
  696. return
  697. }
  698. permissionMap[classifyInfo.Id] = permissionIds
  699. //if len(permissionIds) > 0 {
  700. // for _, v := range permissionIds {
  701. // reportImgUrl = chartPermissionImageMap[v]
  702. // }
  703. //}
  704. } else {
  705. if classifyParent.ClassifyName == "晨报" || classifyParent.ClassifyName == "周报" {
  706. //reportImgUrl = chartPermissionImageMap[1]
  707. classifyIdSeconds = append(classifyIdSeconds, 0)
  708. }
  709. chartPermissions, tErr := chart_permission_search_key_word_mapping.GetChartPermissionByFrom("rddp")
  710. if tErr != nil {
  711. errMsg = tErr.Error()
  712. err = errors.New("分类权限查询出错")
  713. return
  714. }
  715. if len(chartPermissions) > 0 {
  716. for _, v := range chartPermissions {
  717. permissionMap[v.ClassifyId] = append(permissionMap[v.ClassifyId], v.ChartPermissionId)
  718. //permissionImageMap[v.KeyWord] = chartPermissionImageMap[v.ChartPermissionId]
  719. }
  720. }
  721. //获取二级分类的所有头像
  722. classifyList, tErr := classify.GetListByPid(classifyIdFirst)
  723. if tErr != nil {
  724. errMsg = tErr.Error()
  725. err = errors.New("二级分类查询出错")
  726. return
  727. }
  728. // 子目录
  729. if menuClassifyLen > 0 {
  730. classifyIdSeconds = append(classifyIdSeconds, menuClassifyIds...)
  731. } else {
  732. for _, v := range classifyList {
  733. classifyIdSeconds = append(classifyIdSeconds, v.Id)
  734. }
  735. }
  736. if len(classifyIdSeconds) == 0 && classifyParent.ClassifyName != "晨报" && classifyParent.ClassifyName != "周报" {
  737. ret = new(response.ReportList)
  738. ret.Paging = response.GetPaging(pageIndex, pageSize, 0)
  739. return
  740. }
  741. condition += ` AND classify_id_second IN ? `
  742. pars = append(pars, classifyIdSeconds)
  743. }
  744. // 获取有效的权限id列表
  745. var validPermissionIdList []int
  746. if productAuthOk {
  747. validPermissionIdList, err = company.GetValidPermissionIdListByCompany2ProductId(user.CompanyID, 1)
  748. if err != nil && err != utils.ErrNoRow {
  749. errMsg = err.Error()
  750. err = errors.New("查询分类出错")
  751. return
  752. }
  753. }
  754. if len(validPermissionIdList) > 0 {
  755. for cid, perIds := range permissionMap {
  756. checkLoop:
  757. for _, checkId := range perIds {
  758. for _, validPerid := range validPermissionIdList {
  759. if checkId == validPerid {
  760. checkPermissionMap[cid] = true
  761. break checkLoop
  762. }
  763. }
  764. }
  765. }
  766. }
  767. var total int64
  768. var list []*report.Report
  769. if keyWord == "" {
  770. offset := (pageIndex - 1) * pageSize
  771. list, err = report.GetReportList(condition, pars, offset, pageSize)
  772. if err != nil {
  773. errMsg = err.Error()
  774. err = errors.New("报告查询出错")
  775. return
  776. }
  777. total, err = report.GetReportListCount(condition, pars)
  778. if err != nil {
  779. errMsg = err.Error()
  780. err = errors.New("查询报告总数出错")
  781. return
  782. }
  783. } else {
  784. if classifyIdSecond > 0 {
  785. classifyIdSeconds = append(classifyIdSeconds, classifyIdSecond)
  786. }
  787. if classifyParent.ClassifyName == "晨报" || classifyParent.ClassifyName == "周报" {
  788. classifyIdSeconds = append(classifyIdSeconds, 0)
  789. }
  790. // 子目录
  791. if menuClassifyLen > 0 {
  792. classifyIdSeconds = append(classifyIdSeconds, menuClassifyIds...)
  793. }
  794. searchResp, total1, tErr := elasticService.ReportListSearch(keyWord, classifyIdFirst, classifyIdSeconds, pageIndex, pageSize)
  795. if tErr != nil {
  796. errMsg = tErr.Error()
  797. err = errors.New("查询失败")
  798. return
  799. }
  800. total = int64(total1)
  801. if searchResp.Hits != nil && total > 0 {
  802. var reportIds []int
  803. for _, v := range searchResp.Hits.Hits {
  804. temp := new(report.Report)
  805. itemJson, tmpErr := v.Source.MarshalJSON()
  806. if tmpErr != nil {
  807. errMsg = tmpErr.Error()
  808. err = errors.New("解析出错")
  809. return
  810. }
  811. reportItem := new(response.EsReportItem)
  812. tmpErr = json.Unmarshal(itemJson, &reportItem)
  813. if tmpErr != nil {
  814. errMsg = tmpErr.Error()
  815. err = errors.New("解析json出错")
  816. return
  817. }
  818. temp.Id = reportItem.ReportId
  819. reportIds = append(reportIds, reportItem.ReportId)
  820. temp.ClassifyIdFirst = reportItem.ClassifyIdFirst
  821. temp.ClassifyNameFirst = reportItem.ClassifyNameFirst
  822. temp.ClassifyIdSecond = reportItem.ClassifyIdSecond
  823. temp.ClassifyNameSecond = reportItem.ClassifyNameSecond
  824. if len(v.Highlight["ClassifyNameSecond"]) > 0 {
  825. temp.ClassifyNameSecond = v.Highlight["ClassifyNameSecond"][0]
  826. }
  827. temp.Abstract = reportItem.Abstract
  828. stageInt, _ := strconv.Atoi(reportItem.StageStr)
  829. temp.Stage = stageInt
  830. temp.StageStr = reportItem.StageStr
  831. temp.Title = reportItem.Title
  832. temp.PublishTime, err = time.ParseInLocation(utils.FormatDateTime, reportItem.PublishTime, time.Local)
  833. if len(v.Highlight["Title"]) > 0 {
  834. temp.Title = v.Highlight["Title"][0]
  835. }
  836. if len(v.Highlight["Abstract"]) > 0 {
  837. temp.Abstract = v.Highlight["Abstract"][0]
  838. }
  839. if len(v.Highlight["StageStr"]) > 0 {
  840. temp.StageStr = v.Highlight["StageStr"][0]
  841. }
  842. list = append(list, temp)
  843. }
  844. reportInfoList, tmpErr := report.GetByReportIds(reportIds)
  845. if tmpErr != nil {
  846. errMsg = tmpErr.Error()
  847. err = errors.New("查询报告出错")
  848. return
  849. }
  850. reportListMap := make(map[int]*report.Report)
  851. for _, temp := range reportInfoList {
  852. reportListMap[temp.Id] = temp
  853. }
  854. for k, reportDetail := range list {
  855. if v, ok := reportListMap[reportDetail.Id]; ok {
  856. list[k].CreateTime = v.CreateTime
  857. }
  858. }
  859. }
  860. }
  861. var reportList []*response.ReportListItem
  862. if len(list) > 0 {
  863. // 封面图
  864. classifyList, e := classify.GetClassifyList()
  865. if e != nil {
  866. err = errors.New("获取报告分类列表失败" + e.Error())
  867. return
  868. }
  869. listImgMap := make(map[int]string, 0)
  870. classifyNameMap := make(map[int]string, 0)
  871. classifyLen := len(classifyList)
  872. for i := 0; i < classifyLen; i++ {
  873. listImgMap[classifyList[i].Id] = classifyList[i].YbListImg
  874. classifyNameMap[classifyList[i].Id] = classifyList[i].ClassifyName
  875. }
  876. var videoReportIds []int
  877. videoMap := make(map[int][]*response.VideoListItem)
  878. weekAuthMap := make(map[int]bool)
  879. if classifyParent.ClassifyName == "晨报" && productAuthOk {
  880. //获取晨报的音频列表
  881. videoMap, _, errMsg, err = GetReportChapterVideoList(validPermissionIdList, classifyParent.ClassifyName, list, user.UserID)
  882. if err != nil {
  883. return
  884. }
  885. } else if classifyParent.ClassifyName == "周报" {
  886. //查询所有权限typeID
  887. //如果存在可以查看的章节ID
  888. for _, reportInfo := range list {
  889. videoReportIds = append(videoReportIds, reportInfo.Id)
  890. }
  891. // 判断周报权限\查询周报的音频列表
  892. videoMap, weekAuthMap, errMsg, err = GetReportChapterVideoList(validPermissionIdList, classifyParent.ClassifyName, list, user.UserID)
  893. if err != nil {
  894. return
  895. }
  896. }
  897. // 以下分类图标特殊处理 =_=!
  898. //reportImgMap := map[string]string{
  899. // "晨报": "report_list_chen.png",
  900. // "周报": "report_list_zhou.png",
  901. // "月报": "report_list_yue.png",
  902. // "大事点评": "report_list_dashidianping.png",
  903. // "会议纪要": "report_list_huiyijiyao.png",
  904. // "年报合集": "report_list_nianbaoheji.png",
  905. //}
  906. for _, reportInfo := range list {
  907. reportItem := new(response.ReportListItem)
  908. reportItem.ReportId = reportInfo.Id
  909. reportItem.HasChapter = reportInfo.HasChapter
  910. // 样式限制行数
  911. reportItem.Title = "<div style=\"-webkit-line-clamp: 2;-webkit-box-orient: vertical;display: -webkit-box;overflow: hidden;text-overflow: ellipsis;\">" + reportInfo.Title + "</div>"
  912. reportItem.PublishTime = reportInfo.PublishTime
  913. //reportItem.ClassifyNameFirst = reportInfo.ClassifyNameFirst
  914. //reportItem.ClassifyNameSecond = reportInfo.ClassifyNameSecond
  915. reportItem.ClassifyNameFirst = classifyNameMap[reportInfo.ClassifyIdFirst]
  916. reportItem.ClassifyNameSecond = classifyNameMap[reportInfo.ClassifyIdSecond]
  917. reportItem.ClassifyIdFirst = reportInfo.ClassifyIdFirst
  918. reportItem.ClassifyIdSecond = reportInfo.ClassifyIdSecond
  919. reportItem.Stage = reportInfo.Stage
  920. reportItem.Abstract = reportInfo.Abstract
  921. if reportInfo.Abstract != "" {
  922. reportItem.Abstract = "<div style=\"display: -webkit-box;overflow: hidden;text-overflow: ellipsis;word-break: break-all;-webkit-box-orient: vertical;-webkit-line-clamp: 1;\">" + reportInfo.Abstract + "</div>"
  923. }
  924. reportItem.Author = reportInfo.Author
  925. stageStr := reportInfo.StageStr
  926. if stageStr == "" {
  927. stageStr = strconv.Itoa(reportInfo.Stage)
  928. }
  929. reportItem.TitleInfo = fmt.Sprintf("【第%s期|FICC|%s】", stageStr, reportItem.ClassifyNameSecond)
  930. //trimClassifyNameSecond := utils.TrimHtml(reportInfo.ClassifyNameSecond)
  931. if reportItem.ClassifyNameFirst == "晨报" || reportItem.ClassifyNameFirst == "周报" || classifyIdSecond > 0 {
  932. //reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + reportImgUrl
  933. reportItem.TitleInfo = fmt.Sprintf("【第%s期|FICC|%s】", stageStr, reportItem.ClassifyNameFirst)
  934. }
  935. //else if url, ok := permissionImageMap[trimClassifyNameSecond]; ok {
  936. // reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + url
  937. //}
  938. //if img, ok := reportImgMap[reportInfo.ClassifyNameFirst]; ok {
  939. // reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + img
  940. //}
  941. // 封面图-默认取二级分类的图片,二级分类图片没有(如晨周报)则取一级
  942. coverImg := listImgMap[reportInfo.ClassifyIdSecond]
  943. if coverImg == "" {
  944. coverImg = listImgMap[reportInfo.ClassifyIdFirst]
  945. }
  946. reportItem.ReportImgUrl = coverImg
  947. if classifyParent.ClassifyName == "晨报" && productAuthOk {
  948. // 查询当前晨报的所有音频
  949. if vList, ok := videoMap[reportInfo.Id]; ok {
  950. for _, vd := range vList {
  951. vd.VideoImg = reportItem.ReportImgUrl
  952. }
  953. reportItem.VideoList = vList
  954. }
  955. reportItem.AuthOk = productAuthOk
  956. } else if classifyParent.ClassifyName == "周报" {
  957. if wAuth, ok := weekAuthMap[reportInfo.Id]; ok {
  958. reportItem.AuthOk = wAuth
  959. if wAuth {
  960. // 查询当前晨报的所有音频
  961. if vList, ok2 := videoMap[reportInfo.Id]; ok2 {
  962. for _, vd := range vList {
  963. vd.VideoImg = reportItem.ReportImgUrl
  964. }
  965. reportItem.VideoList = vList
  966. }
  967. }
  968. }
  969. } else if authOk, ok := checkPermissionMap[reportInfo.ClassifyIdSecond]; ok && authOk {
  970. if reportInfo.VideoUrl != "" {
  971. videoTemp := new(response.VideoListItem)
  972. videoTemp.VideoUrl = reportInfo.VideoUrl
  973. videoTemp.VideoName = reportInfo.VideoName
  974. if reportInfo.VideoName == "" {
  975. videoTemp.VideoName = reportInfo.Title
  976. }
  977. videoTemp.VideoPlaySeconds = reportInfo.VideoPlaySeconds
  978. videoTemp.VideoImg = reportItem.ReportImgUrl
  979. reportItem.VideoList = append(reportItem.VideoList, videoTemp)
  980. }
  981. reportItem.AuthOk = authOk
  982. }
  983. reportList = append(reportList, reportItem)
  984. }
  985. }
  986. ret = new(response.ReportList)
  987. ret.List = reportList
  988. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  989. return
  990. }
  991. // GetCollectReportList 首页展示报告汇总列表
  992. func GetCollectReportList(user user.UserInfo, chartPermissionId, pageIndex, pageSize int) (ret *response.ReportCollectResp, err error) {
  993. var errMsg string
  994. defer func() {
  995. if err != nil {
  996. global.LOG.Critical(fmt.Sprintf("GetCollectReportList: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  997. }
  998. }()
  999. // 查询权限的基本信息
  1000. permissionInfo, err := chart_permission.GetByChartPermissionId(chartPermissionId)
  1001. if err != nil {
  1002. errMsg = err.Error()
  1003. err = errors.New("查询权限出错")
  1004. return
  1005. }
  1006. if permissionInfo.ChartPermissionID == 0 {
  1007. err = errors.New("权限不存在")
  1008. return
  1009. }
  1010. // 除了晨报和周报以外的其他报告
  1011. classifySecondIds, err := chart_permission_search_key_word_mapping.GetClassifyIdsByChartPermissionId(chartPermissionId, "rddp")
  1012. if err != nil {
  1013. errMsg = err.Error()
  1014. err = errors.New("查询权限对应的分类出错")
  1015. return
  1016. }
  1017. var reportList []*response.ReportCollectListItem
  1018. list := response.ReportCollectListResp{}
  1019. var total int64
  1020. {
  1021. offset := (pageIndex - 1) * pageSize
  1022. reportList, err = report.GetReportCollectListByPermissionV1(chartPermissionId, classifySecondIds, offset, pageSize)
  1023. if err != nil {
  1024. errMsg = err.Error()
  1025. err = errors.New("查询报告信息出错")
  1026. return
  1027. }
  1028. listMap := make(map[string]*response.ReportCollectList)
  1029. for _, v := range reportList {
  1030. v.ContentSub = GetReportContentSub(v.ContentSub, true)
  1031. if _, ok := listMap[v.PublishTime.Format("2006-01-02")]; !ok {
  1032. temp := new(response.ReportCollectList)
  1033. temp.Date = v.PublishTime.Format("2006-01-02")
  1034. listMap[v.PublishTime.Format("2006-01-02")] = temp
  1035. }
  1036. listMap[v.PublishTime.Format("2006-01-02")].SubList = append(listMap[v.PublishTime.Format("2006-01-02")].SubList, v)
  1037. }
  1038. for _, v := range listMap {
  1039. list = append(list, v)
  1040. }
  1041. total, err = report.GetReportCollectCountByPermissionV1(chartPermissionId, classifySecondIds)
  1042. if err != nil {
  1043. errMsg = err.Error()
  1044. err = errors.New("查询报告总数出错")
  1045. return
  1046. }
  1047. if len(list) > 0 {
  1048. sort.Sort(list)
  1049. }
  1050. }
  1051. ret = new(response.ReportCollectResp)
  1052. ret.List = list
  1053. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  1054. return
  1055. }
  1056. func GetCollectReportListBak(user user.UserInfo, chartPermissionId, pageIndex, pageSize int) (ret *response.ReportCollectResp, err error) {
  1057. var errMsg string
  1058. defer func() {
  1059. if err != nil {
  1060. global.LOG.Critical(fmt.Sprintf("GetCollectReportList: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  1061. }
  1062. }()
  1063. // 查询权限的基本信息
  1064. permissionInfo, err := chart_permission.GetByChartPermissionId(chartPermissionId)
  1065. if err != nil {
  1066. errMsg = err.Error()
  1067. err = errors.New("查询权限出错")
  1068. return
  1069. }
  1070. if permissionInfo.ChartPermissionID == 0 {
  1071. err = errors.New("权限不存在")
  1072. return
  1073. }
  1074. // 除了晨报和周报以外的其他报告
  1075. classifySecondIds, err := chart_permission_search_key_word_mapping.GetClassifyIdsByChartPermissionId(chartPermissionId, "rddp")
  1076. if err != nil {
  1077. errMsg = err.Error()
  1078. err = errors.New("查询权限对应的分类出错")
  1079. return
  1080. }
  1081. //var classifySecondIds []int
  1082. //if len(classifyNames) > 0 {
  1083. // classifySecondIds, err = classify.GetSecondIdsByClassifyNames(classifyNames)
  1084. // if err != nil {
  1085. // errMsg = err.Error()
  1086. // err = errors.New("查询分类出错")
  1087. // return
  1088. // }
  1089. //}
  1090. // 查询晨报和周报相对应的章节ID
  1091. reportChapterTypeIds, err := report_chapter_type_permission.GetTypeIdsByChartPermissionId(chartPermissionId)
  1092. if err != nil {
  1093. errMsg = err.Error()
  1094. err = errors.New("查询权限对应的章节出错")
  1095. return
  1096. }
  1097. var reportList []*response.ReportCollectListItem
  1098. list := response.ReportCollectListResp{}
  1099. var total int64
  1100. if len(reportChapterTypeIds) > 0 || len(classifySecondIds) > 0 {
  1101. offset := (pageIndex - 1) * pageSize
  1102. reportList, err = report.GetReportCollectListByPermission(classifySecondIds, reportChapterTypeIds, offset, pageSize)
  1103. if err != nil {
  1104. errMsg = err.Error()
  1105. err = errors.New("查询报告信息出错")
  1106. return
  1107. }
  1108. listMap := make(map[string]*response.ReportCollectList)
  1109. for _, v := range reportList {
  1110. v.ContentSub = GetReportContentSub(v.ContentSub, true)
  1111. if _, ok := listMap[v.PublishTime.Format("2006-01-02")]; !ok {
  1112. temp := new(response.ReportCollectList)
  1113. temp.Date = v.PublishTime.Format("2006-01-02")
  1114. listMap[v.PublishTime.Format("2006-01-02")] = temp
  1115. }
  1116. listMap[v.PublishTime.Format("2006-01-02")].SubList = append(listMap[v.PublishTime.Format("2006-01-02")].SubList, v)
  1117. }
  1118. for _, v := range listMap {
  1119. list = append(list, v)
  1120. }
  1121. total, err = report.GetReportCollectCountByPermission(classifySecondIds, reportChapterTypeIds)
  1122. if err != nil {
  1123. errMsg = err.Error()
  1124. err = errors.New("查询报告总数出错")
  1125. return
  1126. }
  1127. if len(list) > 0 {
  1128. sort.Sort(list)
  1129. }
  1130. }
  1131. ret = new(response.ReportCollectResp)
  1132. ret.List = list
  1133. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  1134. return
  1135. }
  1136. func SearchReport(user user.UserInfo, keyWord string, pageIndex, pageSize int) (ret *response.ReportSearchResp, err error) {
  1137. var errMsg string
  1138. defer func() {
  1139. if err != nil {
  1140. global.LOG.Critical(fmt.Sprintf("SearchReport: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  1141. }
  1142. }()
  1143. //查询正常状态的分类
  1144. classifys, err := classify.GetSimpleAll()
  1145. if err != nil {
  1146. errMsg = err.Error()
  1147. err = errors.New("分类查询出错")
  1148. return
  1149. }
  1150. classifyIdList := make([]int, 0)
  1151. var classifyIdFirsts []int
  1152. classifyIdSeconds := []int{0}
  1153. for _, v := range classifys {
  1154. if v.ParentId == 0 {
  1155. classifyIdFirsts = append(classifyIdFirsts, v.Id)
  1156. } else {
  1157. classifyIdSeconds = append(classifyIdSeconds, v.Id)
  1158. }
  1159. classifyIdList = append(classifyIdList, v.Id)
  1160. }
  1161. keyWord = addAliasToKeyword(keyWord)
  1162. searchResp, total, err := elasticService.SearchReport(keyWord, classifyIdList, pageIndex, pageSize)
  1163. if err != nil {
  1164. errMsg = err.Error()
  1165. err = errors.New("查询失败")
  1166. return
  1167. }
  1168. var reportList []*response.ReportCollectListItem
  1169. if searchResp.Hits != nil {
  1170. for _, v := range searchResp.Hits.Hits {
  1171. temp := new(response.ReportCollectListItem)
  1172. itemJson, tmpErr := v.Source.MarshalJSON()
  1173. if tmpErr != nil {
  1174. errMsg = tmpErr.Error()
  1175. err = errors.New("解析出错")
  1176. return
  1177. }
  1178. reportItem := new(response.EsReportItem)
  1179. tmpErr = json.Unmarshal(itemJson, &reportItem)
  1180. if tmpErr != nil {
  1181. errMsg = tmpErr.Error()
  1182. err = errors.New("解析json出错")
  1183. return
  1184. }
  1185. temp.ReportId = reportItem.ReportId
  1186. temp.ReportChapterId = reportItem.ReportChapterId
  1187. temp.ClassifyIdFirst = reportItem.ClassifyIdFirst
  1188. temp.ClassifyNameFirst = reportItem.ClassifyNameFirst
  1189. temp.ClassifyIdSecond = reportItem.ClassifyIdSecond
  1190. temp.ClassifyNameSecond = reportItem.ClassifyNameSecond
  1191. temp.ClassifyId = reportItem.ClassifyId
  1192. temp.ClassifyName = reportItem.ClassifyName
  1193. temp.Title = reportItem.Title
  1194. temp.ContentSub = reportItem.BodyContent
  1195. temp.PublishTime, err = time.ParseInLocation(utils.FormatDateTime, reportItem.PublishTime, time.Local)
  1196. if len(v.Highlight["Title"]) > 0 {
  1197. temp.Title = v.Highlight["Title"][0]
  1198. }
  1199. if len(v.Highlight["BodyContent"]) > 0 {
  1200. temp.ContentSub = v.Highlight["BodyContent"][0]
  1201. }
  1202. //if len(v.Highlight["Categories"]) > 0 {
  1203. // if temp.ClassifyNameSecond != "" {
  1204. // temp.ClassifyNameSecond = "<span style=\"color:#E3B377\">"+temp.ClassifyNameSecond+"</span>"
  1205. // }
  1206. // if temp.ClassifyNameFirst != "" {
  1207. // temp.ClassifyNameFirst = "<span style=\"color:#E3B377\">"+temp.ClassifyNameFirst+"</span>"
  1208. // }
  1209. //}
  1210. temp.ContentSub = GetReportContentSub(temp.ContentSub, false)
  1211. reportList = append(reportList, temp)
  1212. }
  1213. }
  1214. ret = new(response.ReportSearchResp)
  1215. ret.List = reportList
  1216. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  1217. return
  1218. }
  1219. // GetTickerData 获取指标数据
  1220. func GetTickerData(user user.UserInfo, reportChapterId int) (ret *response.TickerData, err error) {
  1221. var errMsg string
  1222. defer func() {
  1223. if err != nil {
  1224. global.LOG.Critical(fmt.Sprintf("GetTickerData: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  1225. }
  1226. }()
  1227. //查询章节类型
  1228. chapter, err := report_chapter.GetTypeIdById(reportChapterId)
  1229. if err != nil {
  1230. errMsg = err.Error()
  1231. err = errors.New("查询章节失败")
  1232. return
  1233. }
  1234. if chapter.ReportChapterId == 0 {
  1235. err = errors.New("章节不存在或者未发布")
  1236. return
  1237. }
  1238. tickers, err := report_chapter_ticker.GetTickerByChapterId(reportChapterId)
  1239. if err != nil {
  1240. errMsg = err.Error()
  1241. err = errors.New("查询章节指标失败")
  1242. return
  1243. }
  1244. var list []*response.TickerDataItem
  1245. if len(tickers) > 0 {
  1246. var tickerNames []string
  1247. for _, v := range tickers {
  1248. tickerNames = append(tickerNames, v.Ticker)
  1249. }
  1250. var dataList []*response.TickerDataItem
  1251. if chapter.TypeId == 17 {
  1252. dataList, err = daily_base_column.GetDataByBaseColumnTickers17(tickerNames)
  1253. } else {
  1254. dataList, err = daily_base_column.GetDataByBaseColumnTickers(tickerNames)
  1255. }
  1256. if err != nil {
  1257. errMsg = err.Error()
  1258. err = errors.New("查询指标数据失败")
  1259. return
  1260. }
  1261. chapterTypeInfo, tErr := report_chapter_type.GetTickerTitleByTypeId(chapter.TypeId)
  1262. if tErr != nil {
  1263. errMsg = tErr.Error()
  1264. err = errors.New("查询章节类型失败")
  1265. return
  1266. }
  1267. if len(dataList) >= 0 {
  1268. for _, v := range dataList {
  1269. temp := new(response.TickerDataItem)
  1270. temp.BaseColumnName = v.BaseColumnName
  1271. temp.Ticker = v.Ticker
  1272. temp.Date = v.Date
  1273. temp.TickerValue, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", v.TickerValue), 2)
  1274. temp.LastValue, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", v.LastValue), 2)
  1275. temp.MmValue, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", v.MmValue), 2)
  1276. temp.DdValue, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", v.DdValue), 2)
  1277. temp.WwValue, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", v.WwValue), 2)
  1278. list = append(list, temp)
  1279. }
  1280. }
  1281. tickerTitle := new(response.TickerTitleData)
  1282. tickerTitle.TickerTitle = chapterTypeInfo.TickerTitle
  1283. tickerTitle.ReportChapterTypeId = int(chapterTypeInfo.ReportChapterTypeId)
  1284. tickerTitle.ReportChapterTypeName = chapterTypeInfo.ReportChapterTypeName
  1285. tickerTitle.DataTableImage = fmt.Sprintf("http://hongze.oss-cn-shanghai.aliyuncs.com/data_table/%s.png", chapterTypeInfo.ReportChapterTypeKey)
  1286. ret = new(response.TickerData)
  1287. ret.List = list
  1288. ret.TickerTitle = tickerTitle
  1289. }
  1290. return
  1291. }
  1292. // GetReportContentSub 特殊处理contentSub
  1293. func GetReportContentSub(content string, scapeFlag bool) (contentSub string) {
  1294. if scapeFlag {
  1295. content = html.UnescapeString(content)
  1296. content = utils.TrimHtml(content) //只展示纯文本
  1297. }
  1298. contentSub = "<div style=\"-webkit-line-clamp: 3;-webkit-box-orient: vertical;display: -webkit-box;overflow: hidden;text-overflow: ellipsis;\">" + content + "</div>"
  1299. return
  1300. }
  1301. // addAliasToKeyword 品种别名
  1302. func addAliasToKeyword(keyword string) string {
  1303. if keyword == "" {
  1304. return ""
  1305. }
  1306. keywordArr := make([]string, 0)
  1307. keywordArr = append(keywordArr, keyword)
  1308. if strings.Contains(keyword, "沥青") || strings.Contains(keyword, "BU") {
  1309. keywordArr = append(keywordArr, "沥青", "BU")
  1310. }
  1311. if strings.Contains(keyword, "MEG") || strings.Contains(keyword, "EG") || strings.Contains(keyword, "乙二醇") {
  1312. keywordArr = append(keywordArr, "MEG", "EG", "乙二醇")
  1313. }
  1314. if strings.Contains(keyword, "聚酯") || strings.Contains(keyword, "长丝") || strings.Contains(keyword, "短纤") || strings.Contains(keyword, "瓶片") {
  1315. keywordArr = append(keywordArr, "聚酯", "长丝", "短纤", "瓶片")
  1316. }
  1317. if strings.Contains(keyword, "纯苯") || strings.Contains(keyword, "苯乙烯") || strings.Contains(keyword, "EB") {
  1318. keywordArr = append(keywordArr, "纯苯", "苯乙烯", "EB")
  1319. }
  1320. if strings.Contains(keyword, "甲醇") || strings.Contains(keyword, "MA") {
  1321. keywordArr = append(keywordArr, "甲醇", "MA")
  1322. }
  1323. if strings.Contains(keyword, "橡胶") || strings.Contains(keyword, "RU") {
  1324. keywordArr = append(keywordArr, "橡胶", "RU")
  1325. }
  1326. if strings.Contains(keyword, "聚乙烯") || strings.Contains(keyword, "PP") || strings.Contains(keyword, "PE") {
  1327. keywordArr = append(keywordArr, "聚乙烯", "PP", "PE")
  1328. }
  1329. if strings.Contains(keyword, "玻璃") || strings.Contains(keyword, "纯碱") || strings.Contains(keyword, "FG") || strings.Contains(keyword, "SA") {
  1330. keywordArr = append(keywordArr, "玻璃", "纯碱", "FG", "SA")
  1331. }
  1332. keyword = strings.Join(keywordArr, ",")
  1333. return keyword
  1334. }
  1335. // GetReportPptImgListByReportIdAndReportChapterId 首页展示报告汇总列表
  1336. func GetReportPptImgListByReportIdAndReportChapterId(reportId, reportChapterId int) (list []string, err error) {
  1337. list = make([]string, 0)
  1338. reportPptImgList, err := report_ppt_img.GetReportPptImgListByReportIdAndReportChapterId(reportId, reportChapterId)
  1339. for _, v := range reportPptImgList {
  1340. list = append(list, v.ImgURL)
  1341. }
  1342. return
  1343. }
  1344. // GetVarietyReportList 大宗商品报告列表
  1345. func GetVarietyReportList(user user.UserInfo, classifyId, chartPermissionId, pageIndex, pageSize int) (ret *response.ReportList, err error) {
  1346. var errMsg string
  1347. defer func() {
  1348. if err != nil {
  1349. global.LOG.Critical(fmt.Sprintf("GetCollectReportList: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  1350. }
  1351. }()
  1352. // 判断用户状态是否是正常和永续
  1353. var productAuthOk bool
  1354. companyProduct, err := company_product.GetByCompany2ProductId(user.CompanyID, 1)
  1355. if err == utils.ErrNoRow {
  1356. err = nil
  1357. }
  1358. if err != nil {
  1359. errMsg = err.Error()
  1360. err = errors.New("查询用户购买产品出错")
  1361. return
  1362. }
  1363. if companyProduct != nil {
  1364. // 无FICC权限的客户不可见
  1365. if companyProduct.CompanyProductID > 0 {
  1366. // 已购或者试用用户可见
  1367. if strings.Contains("永续,正式", companyProduct.Status) || (companyProduct.Status == "试用" && companyProduct.IsSuspend != 1) {
  1368. productAuthOk = true
  1369. }
  1370. }
  1371. }
  1372. // 查询权限的基本信息
  1373. permissionInfo, err := chart_permission.GetByChartPermissionId(chartPermissionId)
  1374. if err != nil {
  1375. errMsg = err.Error()
  1376. err = errors.New("查询权限出错")
  1377. return
  1378. }
  1379. if permissionInfo.ChartPermissionID == 0 {
  1380. err = errors.New("权限不存在")
  1381. return
  1382. }
  1383. //分类ids
  1384. var allClassifySecondIds []int
  1385. var classifySecondIds []int
  1386. allClassifySecondIds, err = chart_permission_search_key_word_mapping.GetClassifyIdsByChartPermissionId(chartPermissionId, "rddp")
  1387. if err != nil {
  1388. errMsg = err.Error()
  1389. err = errors.New("查询权限对应的分类出错")
  1390. return
  1391. }
  1392. //if len(classifyNames) > 0 {
  1393. // allClassifySecondIds, err = classify.GetSecondIdsByClassifyNames(classifyNames)
  1394. // if err != nil {
  1395. // errMsg = err.Error()
  1396. // err = errors.New("查询分类出错")
  1397. // return
  1398. // }
  1399. //}
  1400. //根据所选一级分类id查询二级分类
  1401. classifyChild, err := classify.GetChildByPid(classifyId)
  1402. if err != nil {
  1403. errMsg = err.Error()
  1404. err = errors.New("查询二级分类出错")
  1405. return
  1406. }
  1407. classifyMap := make(map[int]int, 0)
  1408. for _, c := range classifyChild {
  1409. classifyMap[c.Id] = c.Id
  1410. }
  1411. for _, id := range allClassifySecondIds {
  1412. if _, ok := classifyMap[id]; ok {
  1413. classifySecondIds = append(classifySecondIds, id)
  1414. }
  1415. }
  1416. listImgMap := make(map[int]string, 0)
  1417. for i := 0; i < len(classifyChild); i++ {
  1418. listImgMap[classifyChild[i].Id] = classifyChild[i].YbListImg
  1419. }
  1420. // 获取有效的权限id列表
  1421. var validPermissionIdList []int
  1422. if productAuthOk {
  1423. validPermissionIdList, err = company.GetValidPermissionIdListByCompany2ProductId(user.CompanyID, 1)
  1424. if err != nil && err != utils.ErrNoRow {
  1425. errMsg = err.Error()
  1426. err = errors.New("查询分类出错")
  1427. return
  1428. }
  1429. }
  1430. var authOk bool
  1431. if len(validPermissionIdList) > 0 {
  1432. checkLoop:
  1433. for _, validPerid := range validPermissionIdList {
  1434. if chartPermissionId == validPerid {
  1435. authOk = true
  1436. break checkLoop
  1437. }
  1438. }
  1439. }
  1440. //// 查询晨报和周报相对应的章节ID
  1441. //reportChapterTypeIds, err := report_chapter_type_permission.GetTypeIdsByChartPermissionId(chartPermissionId)
  1442. //if err != nil {
  1443. // errMsg = err.Error()
  1444. // err = errors.New("查询权限对应的章节出错")
  1445. // return
  1446. //}
  1447. var reportList []*report.Report
  1448. var total int64
  1449. if len(classifySecondIds) > 0 {
  1450. if productAuthOk {
  1451. offset := (pageIndex - 1) * pageSize
  1452. reportList, err = report.GetCommoditiesReportCollectListByPermission(classifySecondIds, offset, pageSize)
  1453. if err != nil {
  1454. errMsg = err.Error()
  1455. err = errors.New("查询报告信息出错")
  1456. return
  1457. }
  1458. total, err = report.GetCommoditiesReportCollectCountByPermission(classifySecondIds)
  1459. if err != nil {
  1460. errMsg = err.Error()
  1461. err = errors.New("查询报告总数出错")
  1462. return
  1463. }
  1464. }
  1465. }
  1466. var list []*response.ReportListItem
  1467. for _, r := range reportList {
  1468. // 封面图-默认取二级分类的图片,二级分类图片没有(如晨周报)则取一级
  1469. coverImg := listImgMap[r.ClassifyIdSecond]
  1470. if coverImg == "" {
  1471. coverImg = listImgMap[r.ClassifyIdFirst]
  1472. }
  1473. var VideoList []*response.VideoListItem
  1474. videoItem := response.VideoListItem{
  1475. VideoUrl: r.VideoUrl,
  1476. VideoName: r.VideoName,
  1477. VideoPlaySeconds: r.VideoPlaySeconds,
  1478. VideoImg: coverImg,
  1479. }
  1480. VideoList = append(VideoList, &videoItem)
  1481. stageStr := r.StageStr
  1482. if stageStr == "" {
  1483. stageStr = strconv.Itoa(r.Stage)
  1484. }
  1485. item := response.ReportListItem{
  1486. ReportId: r.Id,
  1487. ClassifyIdFirst: r.ClassifyIdFirst,
  1488. ClassifyNameFirst: r.ClassifyNameFirst,
  1489. ClassifyIdSecond: r.ClassifyIdSecond,
  1490. ClassifyNameSecond: r.ClassifyNameSecond,
  1491. Title: r.Title,
  1492. Abstract: r.Abstract,
  1493. Author: r.Author,
  1494. ReportImgUrl: coverImg,
  1495. PublishTime: r.PublishTime,
  1496. Stage: r.Stage,
  1497. VideoList: VideoList,
  1498. AuthOk: authOk,
  1499. TitleInfo: fmt.Sprintf("【第%s期|FICC|%s】", stageStr, r.ClassifyNameSecond),
  1500. }
  1501. list = append(list, &item)
  1502. }
  1503. ret = new(response.ReportList)
  1504. ret.List = list
  1505. ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  1506. return
  1507. }
  1508. // GetCommoditiesReportList 获取大宗商品报告列表
  1509. //func GetCommoditiesReportList(user user.UserInfo, chartPermissionId, pageIndex, pageSize int) (ret *response.ReportList, err error) {
  1510. // var errMsg string
  1511. // defer func() {
  1512. // if err != nil {
  1513. // global.LOG.Critical(fmt.Sprintf("GetReportList: userId=%d, err:%s, errMsg:%s", user.UserID, err.Error(), errMsg))
  1514. // }
  1515. // }()
  1516. //
  1517. // // 判断用户状态是否是正常和永续
  1518. // var productAuthOk bool
  1519. // companyProduct, err := company_product.GetByCompany2ProductId(user.CompanyID, 1)
  1520. // if err == utils.ErrNoRow {
  1521. // err = nil
  1522. // }
  1523. // if err != nil {
  1524. // errMsg = err.Error()
  1525. // err = errors.New("查询用户购买产品出错")
  1526. // return
  1527. // }
  1528. // if companyProduct != nil {
  1529. // // 无FICC权限的客户不可见
  1530. // if companyProduct.CompanyProductID > 0 {
  1531. // // 已购或者试用用户可见
  1532. // if strings.Contains("永续,正式", companyProduct.Status) || (companyProduct.Status == "试用" && companyProduct.IsSuspend != 1) {
  1533. // productAuthOk = true
  1534. // }
  1535. // }
  1536. // }
  1537. //
  1538. // // 查询权限的基本信息
  1539. // permissionInfo, err := chart_permission.GetByChartPermissionId(chartPermissionId)
  1540. // if err != nil {
  1541. // errMsg = err.Error()
  1542. // err = errors.New("查询权限出错")
  1543. // return
  1544. // }
  1545. //
  1546. // if permissionInfo.ChartPermissionID == 0 {
  1547. // err = errors.New("权限不存在")
  1548. // return
  1549. // }
  1550. // // 除了晨报和周报以外的其他报告
  1551. // classifyNames, err := chart_permission_search_key_word_mapping.GetClassifyIdsByChartPermissionId(chartPermissionId, "two_week")
  1552. // if err != nil {
  1553. // errMsg = err.Error()
  1554. // err = errors.New("查询权限对应的分类出错")
  1555. // return
  1556. // }
  1557. //
  1558. // var classifySecondIds []int
  1559. // if len(classifyNames) > 0 {
  1560. // classifySecondIds, err = classify.GetSecondIdsByClassifyNames(classifyNames)
  1561. // if err != nil {
  1562. // errMsg = err.Error()
  1563. // err = errors.New("查询分类出错")
  1564. // return
  1565. // }
  1566. // }
  1567. //
  1568. // var condition string
  1569. // pars := make([]interface{}, 0)
  1570. //
  1571. // classifyParent, err := classify.GetByClassifyId(classifyIdFirst)
  1572. // if err != nil {
  1573. // errMsg = err.Error()
  1574. // err = errors.New("分类查询出错")
  1575. // return
  1576. // }
  1577. // if classifyParent.Id == 0 {
  1578. // err = errors.New("该分类不存在")
  1579. // return
  1580. // }
  1581. // condition = `classify_id_first = ? and state IN (2, 6)`
  1582. // pars = append(pars, classifyIdFirst)
  1583. // permissionMap := make(map[string][]int)
  1584. // checkPermissionMap := make(map[string]bool)
  1585. // permissionImageMap := make(map[string]string)
  1586. // chartPermissionImageMap := make(map[int]string)
  1587. // var classifyIdSeconds []int
  1588. // //var reportImgUrl string
  1589. //
  1590. // chartPermissionList, err := chart_permission.GetFiccListExceptTacticByProductId()
  1591. // if err != nil {
  1592. // errMsg = err.Error()
  1593. // err = errors.New("分类查询出错")
  1594. // return
  1595. // }
  1596. //
  1597. // if len(chartPermissionList) > 0 {
  1598. // for _, v := range chartPermissionList {
  1599. // chartPermissionImageMap[int(v.ChartPermissionID)] = v.YbImgUrl
  1600. // }
  1601. // }
  1602. //
  1603. // if classifyIdSecond > 0 && keyWord == "" {
  1604. // classifyInfo, tErr := classify.GetByClassifyId(classifyIdSecond)
  1605. // if tErr != nil {
  1606. // errMsg = tErr.Error()
  1607. // err = errors.New("分类查询出错")
  1608. // return
  1609. // }
  1610. // if classifyInfo.Id == 0 {
  1611. // err = errors.New("该二级分类不存在")
  1612. // return
  1613. // }
  1614. //
  1615. // condition += " AND classify_id_second = ?"
  1616. // pars = append(pars, classifyIdSecond)
  1617. // //查询二级分类对应的权限
  1618. // permissionIds, tErr := chart_permission_search_key_word_mapping.GetChartPermissionIdsByKeyWord(classifyInfo.ClassifyName)
  1619. // if tErr != nil {
  1620. // errMsg = tErr.Error()
  1621. // err = errors.New("分类权限查询出错")
  1622. // return
  1623. // }
  1624. // permissionMap[classifyInfo.ClassifyName] = permissionIds
  1625. // //if len(permissionIds) > 0 {
  1626. // // for _, v := range permissionIds {
  1627. // // reportImgUrl = chartPermissionImageMap[v]
  1628. // // }
  1629. // //}
  1630. //
  1631. // } else {
  1632. // if classifyParent.ClassifyName == "晨报" || classifyParent.ClassifyName == "周报" {
  1633. // //reportImgUrl = chartPermissionImageMap[1]
  1634. // classifyIdSeconds = append(classifyIdSeconds, 0)
  1635. // }
  1636. //
  1637. // chartPermissions, tErr := chart_permission_search_key_word_mapping.GetChartPermissionByFrom("rddp")
  1638. // if tErr != nil {
  1639. // errMsg = tErr.Error()
  1640. // err = errors.New("分类权限查询出错")
  1641. // return
  1642. // }
  1643. //
  1644. // if len(chartPermissions) > 0 {
  1645. // for _, v := range chartPermissions {
  1646. // permissionMap[v.KeyWord] = append(permissionMap[v.KeyWord], v.ChartPermissionId)
  1647. // permissionImageMap[v.KeyWord] = chartPermissionImageMap[v.ChartPermissionId]
  1648. // }
  1649. // }
  1650. //
  1651. // //获取二级分类的所有头像
  1652. // classifyList, tErr := classify.GetListByPid(classifyIdFirst)
  1653. // if tErr != nil {
  1654. // errMsg = tErr.Error()
  1655. // err = errors.New("二级分类查询出错")
  1656. // return
  1657. // }
  1658. //
  1659. // for _, v := range classifyList {
  1660. // classifyIdSeconds = append(classifyIdSeconds, v.Id)
  1661. // }
  1662. //
  1663. // if len(classifyIdSeconds) == 0 && classifyParent.ClassifyName != "晨报" && classifyParent.ClassifyName != "周报" {
  1664. // ret = new(response.ReportList)
  1665. // ret.Paging = response.GetPaging(pageIndex, pageSize, 0)
  1666. // return
  1667. // }
  1668. // condition += ` AND classify_id_second IN ? `
  1669. // pars = append(pars, classifyIdSeconds)
  1670. // }
  1671. //
  1672. // // 获取有效的权限id列表
  1673. // var validPermissionIdList []int
  1674. // if productAuthOk {
  1675. // validPermissionIdList, err = company.GetValidPermissionIdListByCompany2ProductId(user.CompanyID, 1)
  1676. // if err != nil && err != utils.ErrNoRow {
  1677. // errMsg = err.Error()
  1678. // err = errors.New("查询分类出错")
  1679. // return
  1680. // }
  1681. // }
  1682. //
  1683. // if len(validPermissionIdList) > 0 {
  1684. // for classifyName, perIds := range permissionMap {
  1685. // checkLoop:
  1686. // for _, checkId := range perIds {
  1687. // for _, validPerid := range validPermissionIdList {
  1688. // if checkId == validPerid {
  1689. // checkPermissionMap[classifyName] = true
  1690. // break checkLoop
  1691. // }
  1692. // }
  1693. // }
  1694. // }
  1695. // }
  1696. //
  1697. // var total int64
  1698. // var list []*report.Report
  1699. // if keyWord == "" {
  1700. // offset := (pageIndex - 1) * pageSize
  1701. // list, err = report.GetReportList(condition, pars, offset, pageSize)
  1702. // if err != nil {
  1703. // errMsg = err.Error()
  1704. // err = errors.New("报告查询出错")
  1705. // return
  1706. // }
  1707. // total, err = report.GetReportListCount(condition, pars)
  1708. // if err != nil {
  1709. // errMsg = err.Error()
  1710. // err = errors.New("查询报告总数出错")
  1711. // return
  1712. // }
  1713. // } else {
  1714. // if classifyIdSecond > 0 {
  1715. // classifyIdSeconds = append(classifyIdSeconds, classifyIdSecond)
  1716. // }
  1717. // if classifyParent.ClassifyName == "晨报" || classifyParent.ClassifyName == "周报" {
  1718. // classifyIdSeconds = append(classifyIdSeconds, 0)
  1719. // }
  1720. // searchResp, total1, tErr := elasticService.ReportListSearch(keyWord, classifyIdFirst, classifyIdSeconds, pageIndex, pageSize)
  1721. // if tErr != nil {
  1722. // errMsg = tErr.Error()
  1723. // err = errors.New("查询失败")
  1724. // return
  1725. // }
  1726. // total = int64(total1)
  1727. // if searchResp.Hits != nil && total > 0 {
  1728. // var reportIds []int
  1729. // for _, v := range searchResp.Hits.Hits {
  1730. // temp := new(report.Report)
  1731. // itemJson, tmpErr := v.Source.MarshalJSON()
  1732. // if tmpErr != nil {
  1733. // errMsg = tmpErr.Error()
  1734. // err = errors.New("解析出错")
  1735. // return
  1736. // }
  1737. // reportItem := new(response.EsReportItem)
  1738. // tmpErr = json.Unmarshal(itemJson, &reportItem)
  1739. // if tmpErr != nil {
  1740. // errMsg = tmpErr.Error()
  1741. // err = errors.New("解析json出错")
  1742. // return
  1743. // }
  1744. // temp.Id = reportItem.ReportId
  1745. // reportIds = append(reportIds, reportItem.ReportId)
  1746. // temp.ClassifyIdFirst = reportItem.ClassifyIdFirst
  1747. // temp.ClassifyNameFirst = reportItem.ClassifyNameFirst
  1748. // temp.ClassifyIdSecond = reportItem.ClassifyIdSecond
  1749. // temp.ClassifyNameSecond = reportItem.ClassifyNameSecond
  1750. // if len(v.Highlight["ClassifyNameSecond"]) > 0 {
  1751. // temp.ClassifyNameSecond = v.Highlight["ClassifyNameSecond"][0]
  1752. // }
  1753. // temp.Abstract = reportItem.Abstract
  1754. // stageInt, _ := strconv.Atoi(reportItem.StageStr)
  1755. // temp.Stage = stageInt
  1756. // temp.StageStr = reportItem.StageStr
  1757. // temp.Title = reportItem.Title
  1758. // temp.PublishTime, err = time.ParseInLocation(utils.FormatDateTime, reportItem.PublishTime, time.Local)
  1759. // if len(v.Highlight["Title"]) > 0 {
  1760. // temp.Title = v.Highlight["Title"][0]
  1761. // }
  1762. // if len(v.Highlight["Abstract"]) > 0 {
  1763. // temp.Abstract = v.Highlight["Abstract"][0]
  1764. // }
  1765. // if len(v.Highlight["StageStr"]) > 0 {
  1766. // temp.StageStr = v.Highlight["StageStr"][0]
  1767. // }
  1768. // list = append(list, temp)
  1769. // }
  1770. // reportInfoList, tmpErr := report.GetByReportIds(reportIds)
  1771. // if tmpErr != nil {
  1772. // errMsg = tmpErr.Error()
  1773. // err = errors.New("查询报告出错")
  1774. // return
  1775. // }
  1776. // reportListMap := make(map[int]*report.Report)
  1777. // for _, temp := range reportInfoList {
  1778. // reportListMap[temp.Id] = temp
  1779. // }
  1780. // for k, reportDetail := range list {
  1781. // if v, ok := reportListMap[reportDetail.Id]; ok {
  1782. // list[k].CreateTime = v.CreateTime
  1783. // }
  1784. // }
  1785. // }
  1786. // }
  1787. //
  1788. // var reportList []*response.ReportListItem
  1789. // if len(list) > 0 {
  1790. // // 封面图
  1791. // classifyList, e := classify.GetClassifyList()
  1792. // if e != nil {
  1793. // err = errors.New("获取报告分类列表失败" + e.Error())
  1794. // return
  1795. // }
  1796. // listImgMap := make(map[int]string, 0)
  1797. // classifyLen := len(classifyList)
  1798. // for i := 0; i < classifyLen; i++ {
  1799. // listImgMap[classifyList[i].Id] = classifyList[i].YbListImg
  1800. // }
  1801. //
  1802. // var videoReportIds []int
  1803. // videoMap := make(map[int][]*response.VideoListItem)
  1804. // weekAuthMap := make(map[int]bool)
  1805. // if classifyParent.ClassifyName == "晨报" && productAuthOk {
  1806. // //获取晨报的音频列表
  1807. // videoMap, _, errMsg, err = GetReportChapterVideoList(validPermissionIdList, classifyParent.ClassifyName, list)
  1808. // if err != nil {
  1809. // return
  1810. // }
  1811. // } else if classifyParent.ClassifyName == "周报" {
  1812. // //查询所有权限typeID
  1813. // //如果存在可以查看的章节ID
  1814. // for _, reportInfo := range list {
  1815. // videoReportIds = append(videoReportIds, reportInfo.Id)
  1816. // }
  1817. // // 判断周报权限\查询周报的音频列表
  1818. // videoMap, weekAuthMap, errMsg, err = GetReportChapterVideoList(validPermissionIdList, classifyParent.ClassifyName, list)
  1819. // if err != nil {
  1820. // return
  1821. // }
  1822. // }
  1823. // // 以下分类图标特殊处理 =_=!
  1824. // //reportImgMap := map[string]string{
  1825. // // "晨报": "report_list_chen.png",
  1826. // // "周报": "report_list_zhou.png",
  1827. // // "月报": "report_list_yue.png",
  1828. // // "大事点评": "report_list_dashidianping.png",
  1829. // // "会议纪要": "report_list_huiyijiyao.png",
  1830. // // "年报合集": "report_list_nianbaoheji.png",
  1831. // //}
  1832. // for _, reportInfo := range list {
  1833. // reportItem := new(response.ReportListItem)
  1834. // reportItem.ReportId = reportInfo.Id
  1835. // // 样式限制行数
  1836. // reportItem.Title = "<div style=\"-webkit-line-clamp: 2;-webkit-box-orient: vertical;display: -webkit-box;overflow: hidden;text-overflow: ellipsis;\">" + reportInfo.Title + "</div>"
  1837. // reportItem.PublishTime = reportInfo.PublishTime
  1838. // reportItem.ClassifyNameFirst = reportInfo.ClassifyNameFirst
  1839. // reportItem.ClassifyNameSecond = reportInfo.ClassifyNameSecond
  1840. // reportItem.ClassifyIdFirst = reportInfo.ClassifyIdFirst
  1841. // reportItem.ClassifyIdSecond = reportInfo.ClassifyIdSecond
  1842. // reportItem.Stage = reportInfo.Stage
  1843. // reportItem.Abstract = reportInfo.Abstract
  1844. // if reportInfo.Abstract != "" {
  1845. // reportItem.Abstract = "<div style=\"overflow: hidden;white-space: nowrap;text-overflow: ellipsis;\">" + reportInfo.Abstract + "</div>"
  1846. // }
  1847. // reportItem.Author = reportInfo.Author
  1848. // stageStr := reportInfo.StageStr
  1849. // if stageStr == "" {
  1850. // stageStr = strconv.Itoa(reportInfo.Stage)
  1851. // }
  1852. // reportItem.TitleInfo = fmt.Sprintf("【第%s期|FICC|%s】", stageStr, reportItem.ClassifyNameSecond)
  1853. // //trimClassifyNameSecond := utils.TrimHtml(reportInfo.ClassifyNameSecond)
  1854. // if reportInfo.ClassifyNameFirst == "晨报" || reportInfo.ClassifyNameFirst == "周报" || classifyIdSecond > 0 {
  1855. // //reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + reportImgUrl
  1856. // reportItem.TitleInfo = fmt.Sprintf("【第%s期|FICC|%s】", stageStr, reportItem.ClassifyNameFirst)
  1857. // }
  1858. // //else if url, ok := permissionImageMap[trimClassifyNameSecond]; ok {
  1859. // // reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + url
  1860. // //}
  1861. // //if img, ok := reportImgMap[reportInfo.ClassifyNameFirst]; ok {
  1862. // // reportItem.ReportImgUrl = utils.ALIYUN_YBIMG_HOST + img
  1863. // //}
  1864. // // 封面图-默认取二级分类的图片,二级分类图片没有(如晨周报)则取一级
  1865. // coverImg := listImgMap[reportInfo.ClassifyIdSecond]
  1866. // if coverImg == "" {
  1867. // coverImg = listImgMap[reportInfo.ClassifyIdFirst]
  1868. // }
  1869. // reportItem.ReportImgUrl = coverImg
  1870. //
  1871. // if classifyParent.ClassifyName == "晨报" && productAuthOk {
  1872. // // 查询当前晨报的所有音频
  1873. // if vList, ok := videoMap[reportInfo.Id]; ok {
  1874. // for _, vd := range vList {
  1875. // vd.VideoImg = reportItem.ReportImgUrl
  1876. // }
  1877. // reportItem.VideoList = vList
  1878. // }
  1879. // reportItem.AuthOk = productAuthOk
  1880. // } else if classifyParent.ClassifyName == "周报" {
  1881. // if wAuth, ok := weekAuthMap[reportInfo.Id]; ok {
  1882. // reportItem.AuthOk = wAuth
  1883. // if wAuth {
  1884. // // 查询当前晨报的所有音频
  1885. // if vList, ok2 := videoMap[reportInfo.Id]; ok2 {
  1886. // for _, vd := range vList {
  1887. // vd.VideoImg = reportItem.ReportImgUrl
  1888. // }
  1889. // reportItem.VideoList = vList
  1890. // }
  1891. // }
  1892. // }
  1893. // } else if authOk, ok := checkPermissionMap[reportInfo.ClassifyNameSecond]; ok && authOk {
  1894. // if reportInfo.VideoUrl != "" {
  1895. // videoTemp := new(response.VideoListItem)
  1896. // videoTemp.VideoUrl = reportInfo.VideoUrl
  1897. // videoTemp.VideoName = reportInfo.VideoName
  1898. // if reportInfo.VideoName == "" {
  1899. // videoTemp.VideoName = reportInfo.Title
  1900. // }
  1901. // videoTemp.VideoPlaySeconds = reportInfo.VideoPlaySeconds
  1902. // videoTemp.VideoImg = reportItem.ReportImgUrl
  1903. // reportItem.VideoList = append(reportItem.VideoList, videoTemp)
  1904. // }
  1905. // reportItem.AuthOk = authOk
  1906. // }
  1907. //
  1908. // reportList = append(reportList, reportItem)
  1909. // }
  1910. //
  1911. // }
  1912. // ret = new(response.ReportList)
  1913. // ret.List = reportList
  1914. // ret.Paging = response.GetPaging(pageIndex, pageSize, int(total))
  1915. // return
  1916. //}