report.go 67 KB

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