report.go 63 KB

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