report.go 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hongze_clpt/models"
  6. "hongze/hongze_clpt/services"
  7. "hongze/hongze_clpt/utils"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. // 报告
  13. type ReportController struct {
  14. BaseAuthController
  15. }
  16. type ReportCommonController struct {
  17. BaseCommonController
  18. }
  19. type MobileReportController struct {
  20. BaseAuthMobileController
  21. }
  22. // @Title 行业报告分类列表接口
  23. // @Description 获取行业报告分类列表接口
  24. // @Param ChartPermissionId query int true "分类ID"
  25. // @Success 200 {object} models.TradeReportMappingResp
  26. // @router /tradeList [get]
  27. func (this *MobileReportController) TradeList() {
  28. br := new(models.BaseResponse).Init()
  29. defer func() {
  30. this.Data["json"] = br
  31. this.ServeJSON()
  32. }()
  33. user := this.User
  34. if user == nil {
  35. br.Msg = "请重新登录"
  36. br.Ret = 408
  37. return
  38. }
  39. //uid := user.UserId
  40. ChartPermissionId, _ := this.GetInt("ChartPermissionId")
  41. if ChartPermissionId < 1 {
  42. br.Msg = "请输入分类ID"
  43. return
  44. }
  45. //var result []*models.SearchItem
  46. var list []*models.TradeReportMapping
  47. var err error
  48. mapCategory := make(map[int]int)
  49. if ChartPermissionId == utils.CE_LUE_ID || ChartPermissionId == utils.GU_SHOU_ID {
  50. listTrade, errTrade := models.GetReportMappingStrategyHomeAllByCygx(user.UserId, ChartPermissionId)
  51. err = errTrade
  52. if ChartPermissionId == utils.CE_LUE_ID {
  53. cf, err := models.GetConfigByCode(utils.CYGX_TACTICS_TIME_LINE_STATUS)
  54. if err != nil {
  55. br.Msg = "获取失败"
  56. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  57. return
  58. }
  59. if cf.ConfigValue == "1" || user.CompanyId == utils.HZ_COMPANY_ID {
  60. item := new(models.TradeReportMapping)
  61. item.CategoryId = utils.TIME_LINE_ID
  62. item.MatchTypeName = utils.TIME_LINE_NAME
  63. list = append(list, item)
  64. }
  65. }
  66. for _, v := range listTrade {
  67. list = append(list, v)
  68. }
  69. if user.Mobile != "" {
  70. //策略的处理
  71. categoryList, err := models.GetCygxXzsChooseCategoryList(user.Mobile)
  72. if err != nil && err.Error() != utils.ErrNoRow() {
  73. br.Msg = "获取信息失败"
  74. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  75. return
  76. }
  77. for _, v := range categoryList {
  78. mapCategory[v.IdCygx] = v.IdCygx
  79. }
  80. }
  81. } else {
  82. listCategory, err := models.GetTradeArticleAndProductInterior(ChartPermissionId)
  83. if err != nil {
  84. br.Msg = "获取信息失败"
  85. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  86. return
  87. }
  88. categoryMap := make(map[int]int)
  89. for _, v := range listCategory {
  90. if categoryMap[v.CategoryId] > 0 {
  91. continue
  92. }
  93. categoryMap[v.CategoryId] = v.CategoryId
  94. list = append(list, v)
  95. }
  96. //加了一个需求,现有数据结构不支持,手动添加 2023-06-12
  97. //if ChartPermissionId == utils.KE_JI_ID {
  98. // list = append(list, &models.TradeReportMapping{MatchTypeName: "AI前沿", CategoryId: utils.ACTEGORY_ID_AI_QY})
  99. //}
  100. }
  101. if err != nil {
  102. br.Msg = "获取信息失败"
  103. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  104. return
  105. }
  106. for k, v := range list {
  107. if ChartPermissionId != utils.CE_LUE_ID && ChartPermissionId != utils.GU_SHOU_ID {
  108. var pageSize int
  109. var listArticle []*models.HomeArticle
  110. pageSize = 3
  111. if v.CategoryId == utils.ACTEGORY_ID_AI_QY {
  112. //加了一个需求,现有数据结构不支持,手动添加 2023-06-12
  113. listArticle, _, err = services.GetAiQianYanArtilceList(0, pageSize)
  114. } else {
  115. listArticle, _, err = models.GetReportAndproductIndustrylList(v.CategoryId, 0, pageSize)
  116. }
  117. if err != nil {
  118. br.Msg = "获取信息失败"
  119. br.Msg = "GetHomeList,Err:" + err.Error()
  120. return
  121. }
  122. if len(listArticle) > 0 {
  123. list[k].UpdateTime = utils.StrTimeToTime(listArticle[0].PublishDate).Format(utils.FormatDate) //时间字符串格式转时间格式
  124. }
  125. list[k].ListArticle = listArticle
  126. } else {
  127. if mapCategory[v.CategoryId] > 0 {
  128. list[k].IsFollow = true
  129. }
  130. list[k].ListArticle = make([]*models.HomeArticle, 0)
  131. }
  132. }
  133. resp := new(models.TradeReportMappingResp)
  134. if len(list) == 0 {
  135. list = make([]*models.TradeReportMapping, 0)
  136. }
  137. resp.List = list
  138. br.Ret = 200
  139. br.Success = true
  140. br.Msg = "获取成功"
  141. br.Data = resp
  142. }
  143. // @Title 产业报告分类列表接口
  144. // @Description 获取产业报告分类列表接口
  145. // @Param ChartPermissionId query int true "分类ID"
  146. // @Param DeepCover query int false "是否选择深度覆盖,1是,0否 不填默认为0"
  147. // @Param RecommendFocus query int false "是否选择推荐关注,1是,0否 不填默认为0"
  148. // @Param PageSize query int true "每页数据条数"
  149. // @Param CurrentIndex query int true "当前页页码,从1开始"
  150. // @Param IsBillboard query bool false "是否属于榜单 是true 否 false"
  151. // @Success 200 {object} models.IndustrialManagementList
  152. // @router /industryList [get]
  153. func (this *MobileReportController) IndustryList() {
  154. br := new(models.BaseResponse).Init()
  155. defer func() {
  156. this.Data["json"] = br
  157. this.ServeJSON()
  158. }()
  159. user := this.User
  160. if user == nil {
  161. br.Msg = "请重新登录"
  162. br.Ret = 408
  163. return
  164. }
  165. uid := user.UserId
  166. ChartPermissionId, _ := this.GetInt("ChartPermissionId")
  167. orderColumn := this.GetString("OrderColumn")
  168. orderColumnNew := this.GetString("OrderColumn")
  169. isNewLabel := this.GetString("IsNewLabel")
  170. isDeepLabel := this.GetString("IsDeepLabel")
  171. pageSize, _ := this.GetInt("PageSize")
  172. currentIndex, _ := this.GetInt("CurrentIndex")
  173. deepCover, _ := this.GetInt("DeepCover")
  174. recommendFocus, _ := this.GetInt("RecommendFocus")
  175. isBillboard, _ := this.GetBool("IsBillboard", false)
  176. var orderSrt string
  177. var condition string
  178. var startSize int
  179. resp := new(models.IndustrialManagementList)
  180. if pageSize <= 0 {
  181. pageSize = utils.PageSize20
  182. }
  183. if currentIndex <= 0 {
  184. currentIndex = 1
  185. }
  186. startSize = paging.StartIndex(currentIndex, pageSize)
  187. if ChartPermissionId > 0 {
  188. condition += ` AND man.chart_permission_id IN (` + strconv.Itoa(ChartPermissionId) + `)`
  189. }
  190. // 获取近一个月产业报告阅读次数最多的产业
  191. var topCond string
  192. var topPars []interface{}
  193. topReadIndustryId := 0
  194. if ChartPermissionId > 0 {
  195. topCond += ` AND chart_permission_id = ?`
  196. topPars = append(topPars, ChartPermissionId)
  197. }
  198. topReadIndustry, e := models.GetTopOneMonthArtReadNumIndustry(topCond, topPars)
  199. if e != nil && e.Error() != utils.ErrNoRow() {
  200. br.Msg = "获取信息失败"
  201. br.ErrMsg = "获取近一个月报告阅读次数最多的产业失败, Err: " + e.Error()
  202. return
  203. }
  204. if topReadIndustry != nil {
  205. topReadIndustryId = topReadIndustry.IndustrialManagementId
  206. }
  207. // 深度覆盖
  208. if deepCover == 1 {
  209. // 查询深标签产业报告数
  210. var deepCondition string
  211. var deepPars []interface{}
  212. deepCondition += ` AND man.is_deep_label = 1`
  213. if ChartPermissionId > 0 {
  214. deepCondition += ` AND man.chart_permission_id = ?`
  215. deepPars = append(deepPars, ChartPermissionId)
  216. }
  217. industryCountList, e := models.GetIndustryArtCountByCondition(deepCondition, deepPars)
  218. if e != nil {
  219. br.Msg = "获取信息失败"
  220. br.ErrMsg = "获取深标签产业报告数失败, Err: " + e.Error()
  221. return
  222. }
  223. deepIdArr := make([]string, 0)
  224. for i := range industryCountList {
  225. if industryCountList[i].ArtNum > 10 {
  226. deepIdArr = append(deepIdArr, strconv.Itoa(industryCountList[i].IndustrialManagementId))
  227. }
  228. }
  229. deepIds := strings.Join(deepIdArr, ",")
  230. if deepIds != "" {
  231. condition = `AND man.industrial_management_id IN (` + deepIds + `)`
  232. }
  233. }
  234. // 推荐关注
  235. if recommendFocus == 1 {
  236. condition += ` AND man.recommended_index >= 80`
  237. }
  238. var list []*models.IndustrialManagement
  239. total, err := models.GetIndustrialManagementAllCount(condition)
  240. if err != nil {
  241. br.Msg = "获取信息失败"
  242. br.ErrMsg = "获取数量失败,Err:" + err.Error()
  243. return
  244. }
  245. if orderColumn == "" {
  246. orderColumn = "NewTime"
  247. }
  248. if orderColumn == "NewTime" {
  249. orderSrt = "update_time DESC"
  250. } else {
  251. orderSrt = "man.recommended_index DESC,update_time DESC"
  252. }
  253. if isBillboard {
  254. // 查询有已归类行业报告的行业IDs
  255. activeIndustryIds, e := models.GetActiveArticleIndustryIds()
  256. if e != nil {
  257. br.Msg = "获取失败"
  258. br.ErrMsg = "获取已归类行业失败, Err:" + e.Error()
  259. return
  260. }
  261. activeIndustryLen := len(activeIndustryIds)
  262. //topNum := pageSize
  263. condition = ""
  264. var parsBd []interface{}
  265. if ChartPermissionId > 0 {
  266. condition += ` AND man.chart_permission_id = ? `
  267. parsBd = append(parsBd, ChartPermissionId)
  268. }
  269. if activeIndustryLen > 0 {
  270. condition += ` AND man.industrial_management_id IN (` + utils.GetOrmInReplace(activeIndustryLen) + `)`
  271. parsBd = append(parsBd, activeIndustryIds)
  272. }
  273. nowTime := time.Now().Local()
  274. startTime := nowTime.AddDate(0, -1, 0)
  275. endTime := nowTime.AddDate(0, 0, -1)
  276. condition += ` AND idf.create_time BETWEEN ? AND ?`
  277. parsBd = append(parsBd, startTime, endTime)
  278. list, e = models.GetTopIndustryFollowData(0, pageSize, condition, parsBd)
  279. if e != nil {
  280. br.Msg = "获取失败"
  281. br.ErrMsg = "获取关注度最高的产业数据失败, Err:" + e.Error()
  282. return
  283. }
  284. } else {
  285. list, err = models.GetIndustrialManagementAll(uid, condition, orderSrt, startSize, pageSize, isBillboard)
  286. if err != nil {
  287. br.Msg = "获取信息失败"
  288. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  289. return
  290. }
  291. }
  292. var resource string
  293. if ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  294. resource = utils.REOURCE_YX
  295. } else {
  296. resource = utils.REOURCE_HZ
  297. }
  298. list, err = services.HandleIndustryList(list, user, resource)
  299. if err != nil {
  300. br.Msg = "获取信息失败"
  301. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  302. return
  303. }
  304. industrialIdArr := make([]int, 0)
  305. for k, v := range list {
  306. industrialIdArr = append(industrialIdArr, v.IndustrialManagementId)
  307. if topReadIndustryId > 0 && list[k].IndustrialManagementId == topReadIndustryId {
  308. list[k].IsHot = true
  309. }
  310. }
  311. if orderColumnNew != "" {
  312. item := new(models.CygxReportIndustrialSeaarchHistory)
  313. item.UserId = user.UserId
  314. item.Mobile = user.Mobile
  315. item.CompanyId = user.CompanyId
  316. item.CompanyName = user.CompanyName
  317. item.CreateTime = time.Now()
  318. item.IsDeepLabel = isDeepLabel
  319. item.IsNewLabel = isNewLabel
  320. item.ChartPermissionId = ChartPermissionId
  321. if orderColumnNew == "NewTime" {
  322. item.OrderColumn = "0"
  323. } else {
  324. item.OrderColumn = "1"
  325. }
  326. go models.AddCygxReportIndustrialSeaarchHistory(item)
  327. }
  328. if len(list) == 0 {
  329. list = make([]*models.IndustrialManagement, 0)
  330. }
  331. page := paging.GetPaging(currentIndex, pageSize, total)
  332. if isBillboard {
  333. total = len(list)
  334. }
  335. resp.List = list
  336. resp.Paging = page
  337. br.Ret = 200
  338. br.Success = true
  339. br.Msg = "获取成功"
  340. br.Data = resp
  341. }
  342. // @Title 产业下所关联的文章分类列表
  343. // @Description 产业下所关联的文章分类列表接口
  344. // @Param IndustrialManagementId query int true "产业ID"
  345. // @Success 200 {object} models.IndustrialToArticleCategoryListRep
  346. // @router /toArticleCategoryList [get]
  347. func (this *MobileReportController) ArticleCategoryList() {
  348. br := new(models.BaseResponse).Init()
  349. defer func() {
  350. this.Data["json"] = br
  351. this.ServeJSON()
  352. }()
  353. user := this.User
  354. if user == nil {
  355. br.Msg = "请重新登录"
  356. br.Ret = 408
  357. return
  358. }
  359. //uid := user.UserId
  360. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  361. if industrialManagementId < 1 {
  362. br.Msg = "请输入分类ID"
  363. return
  364. }
  365. detail, err := models.GetIndustrialManagementDetail(industrialManagementId)
  366. if err != nil {
  367. br.Msg = "获取信息失败"
  368. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  369. return
  370. }
  371. listCategory, err := models.IndustrialToArticleAndProductInteriorCategoryNew(industrialManagementId)
  372. if err != nil {
  373. br.Msg = "获取信息失败"
  374. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  375. return
  376. }
  377. var list []*models.IndustrialToArticleCategoryRep
  378. categoryMap := make(map[int]int)
  379. for _, v := range listCategory {
  380. if categoryMap[v.CategoryId] > 0 {
  381. continue
  382. }
  383. categoryMap[v.CategoryId] = v.CategoryId
  384. list = append(list, v)
  385. }
  386. //标的列表
  387. industrialSubjectList, err := models.GetIndustrialArticleGroupSubjectListByHz(industrialManagementId)
  388. if err != nil {
  389. br.Msg = "获取信息失败"
  390. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  391. return
  392. }
  393. videoSimple, au, err := services.GetindustryVideo(user, industrialManagementId)
  394. if err != nil {
  395. br.Msg = "获取失败"
  396. br.ErrMsg = "获取用户权限失败, Err: " + err.Error()
  397. return
  398. }
  399. timeLineItem := models.IndustrialToArticleCategoryRep{
  400. CategoryId: utils.TIME_CATEGORYID,
  401. MatchTypeName: "时间线",
  402. }
  403. timeLineIsRed, err := services.GetShowTimeLineIsRed(user, industrialManagementId)
  404. if err != nil {
  405. br.Msg = "获取失败"
  406. br.ErrMsg = "获取用户权限失败, Err: " + err.Error()
  407. return
  408. }
  409. timeLineItem.IsRed = timeLineIsRed
  410. list = append([]*models.IndustrialToArticleCategoryRep{&timeLineItem}, list...)
  411. resp := new(models.IndustrialToArticleCategoryListRep)
  412. resp.List = list
  413. resp.ListSubject = industrialSubjectList
  414. resp.LayoutTime = utils.TimeRemoveHms(detail.LayoutTime)
  415. resp.IndustryName = detail.IndustryName
  416. resp.IndustrialManagementId = industrialManagementId
  417. if videoSimple != nil && videoSimple.Id > 0 {
  418. resp.IndustryVideo = videoSimple
  419. }
  420. resp.AuthInfo = au
  421. br.Ret = 200
  422. br.Success = true
  423. br.Msg = "获取成功"
  424. br.Data = resp
  425. }
  426. // @Title 根据行业分类获取文章列表
  427. // @Description根据行业分类获取文章列表接口
  428. // @Param PageSize query int true "每页数据条数"
  429. // @Param CurrentIndex query int true "当前页页码,从1开始"
  430. // @Param CategoryId query int true "分类ID"
  431. // @Param IndustrialManagementId query int false "产业ID"
  432. // @Success 200 {object} models.TacticsListResp
  433. // @router /articleList/byCategoryId [get]
  434. func (this *MobileReportController) List() {
  435. br := new(models.BaseResponse).Init()
  436. defer func() {
  437. this.Data["json"] = br
  438. this.ServeJSON()
  439. }()
  440. user := this.User
  441. if user == nil {
  442. br.Msg = "请重新登录"
  443. br.Ret = 408
  444. return
  445. }
  446. //uid := user.UserId
  447. pageSize, _ := this.GetInt("PageSize")
  448. currentIndex, _ := this.GetInt("CurrentIndex")
  449. categoryId, _ := this.GetInt("CategoryId")
  450. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  451. uid := user.UserId
  452. var startSize int
  453. if pageSize <= 0 {
  454. pageSize = utils.PageSize20
  455. }
  456. if currentIndex <= 0 {
  457. currentIndex = 1
  458. }
  459. startSize = paging.StartIndex(currentIndex, pageSize)
  460. //var condition string
  461. var pars []interface{}
  462. var total int
  463. resp := new(models.TacticsListResp)
  464. page := paging.GetPaging(currentIndex, pageSize, total)
  465. list := make([]*models.ArticleListResp, 0)
  466. if categoryId == utils.TIME_CATEGORYID {
  467. var err error
  468. list, total, err = models.GetTimeLineReportIndustrialList(industrialManagementId, startSize, pageSize)
  469. if err != nil {
  470. br.Msg = "获取信息失败"
  471. br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
  472. return
  473. }
  474. } else {
  475. //获取该产业下所对应的行业图片
  476. //var reportType int
  477. //if industrialManagementId > 0 {
  478. // reportType = 2
  479. //} else {
  480. // reportType = 1
  481. //}
  482. //detail, errCategory := models.GetdetailByCategoryIdOne(categoryId, reportType)
  483. //if errCategory != nil {
  484. // br.Msg = "获取信息失败"
  485. // br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在:" + strconv.Itoa(categoryId)
  486. // return
  487. //}
  488. //对应行业的图片
  489. detailChartPermissionUrl, err := models.GetConfigByCode("category_chart_permissionimg_url")
  490. if err != nil {
  491. br.Msg = "获取数据失败"
  492. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  493. return
  494. }
  495. chartPermissionUrlList := strings.Split(detailChartPermissionUrl.ConfigValue, "{|}")
  496. mapChartPermission := make(map[string]string)
  497. var permissionName string
  498. var imgUrlChartPermission string
  499. for _, v := range chartPermissionUrlList {
  500. vslice := strings.Split(v, "_")
  501. permissionName = vslice[0]
  502. imgUrlChartPermission = vslice[len(vslice)-1]
  503. mapChartPermission[permissionName] = imgUrlChartPermission
  504. }
  505. //对应分类的所图片
  506. detailCategoryUrl, err := models.GetConfigByCode("category_map_img_url")
  507. if err != nil {
  508. br.Msg = "获取数据失败"
  509. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  510. return
  511. }
  512. categoryUrlList := strings.Split(detailCategoryUrl.ConfigValue, "{|}")
  513. mapCategoryUrl := make(map[string]string)
  514. var categoryIdStr string
  515. var imgUrlChart string
  516. for _, v := range categoryUrlList {
  517. vslice := strings.Split(v, "_")
  518. categoryIdStr = vslice[0]
  519. imgUrlChart = vslice[len(vslice)-1]
  520. mapCategoryUrl[categoryIdStr] = imgUrlChart
  521. }
  522. //if detail.CeLueFieldId != "" {
  523. // condition = ` AND ce_lue_field_id IN(` + detail.CeLueFieldId + `)`
  524. //} else if detail.PolymerizationId != "" {
  525. // condition = ` AND category_id IN(` + detail.PolymerizationId + `)`
  526. //} else {
  527. // categoryIdSet, errCategory := models.GetdetailByCategoryIdSet(categoryId)
  528. // if errCategory != nil {
  529. // br.Msg = "获取信息失败"
  530. // br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在:" + strconv.Itoa(categoryId)
  531. // return
  532. // }
  533. // if categoryIdSet != "" {
  534. // condition = ` AND category_id IN(` + categoryIdSet + `)`
  535. // } else {
  536. // condition = ` AND category_id IN(` + strconv.Itoa(categoryId) + `)`
  537. // }
  538. //}
  539. //
  540. //if industrialManagementId > 0 {
  541. // industrialManageentList, err := models.GetIndustrialArticleGroupManagementByIndustrialManagementId(industrialManagementId)
  542. // if err != nil {
  543. // br.Msg = "获取信息失败"
  544. // br.Msg = "获取产业关联的文章ID失败,GetIndustrialArticleGroupManagementByIndustrialManagementIdErr:" + err.Error()
  545. // return
  546. // }
  547. // articleIdList := make([]string, 0)
  548. // for _, v := range industrialManageentList {
  549. // articleIdList = append(articleIdList, strconv.Itoa(v.ArticleId))
  550. // }
  551. // condition += ` AND a.article_id IN ( ` + utils.GetOrmInReplace(len(articleIdList)) + ` ) `
  552. // pars = append(pars, articleIdList)
  553. //}
  554. //total, err = models.GetHomeCount(condition, pars)
  555. //if err != nil {
  556. // br.Msg = "获取信息失败"
  557. // br.Msg = "获取帖子总数失败,Err:" + err.Error()
  558. // return
  559. //}
  560. //
  561. //list, err = models.GetHomeListNew(condition, pars, startSize, pageSize)
  562. //if err != nil {
  563. // br.Msg = "获取信息失败"
  564. // br.Msg = "获取帖子数据失败,Err:" + err.Error()
  565. // return
  566. //}
  567. list, total, err = models.GetReportAndproductInteriorIndustrialList(pars, categoryId, industrialManagementId, uid, startSize, pageSize)
  568. if err != nil {
  569. br.Msg = "获取信息失败"
  570. br.ErrMsg = "获取帖子数据失败,Err:" + err.Error()
  571. return
  572. }
  573. articleIdMap, err := services.GetUserArticleHistoryRecord(user)
  574. if err != nil {
  575. br.Msg = "获取信息失败"
  576. br.Msg = "获取帖子数据失败,Err:" + err.Error()
  577. return
  578. }
  579. for k, v := range list {
  580. list[k].ImgUrlPc = mapCategoryUrl[v.CategoryId]
  581. if !articleIdMap[v.ArticleId] && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
  582. list[k].IsRed = true
  583. }
  584. }
  585. //if categoryId > 0 {
  586. // detail, errCategory := models.GetdetailByCategoryId(categoryId)
  587. // if errCategory != nil {
  588. // br.Msg = "获取信息失败"
  589. // br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在:" + strconv.Itoa(categoryId)
  590. // return
  591. // }
  592. // resp.MatchTypeName = detail.MatchTypeName
  593. //}
  594. //resp.CategoryImgUrlPc = mapChartPermission[detail.ChartPermissionName]
  595. }
  596. listPublic, err := services.HandleArticleCategoryImg(list, user)
  597. if err != nil {
  598. br.Msg = "获取失败"
  599. br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
  600. return
  601. }
  602. listResp := make([]*models.HomeArticle, 0)
  603. //listResp :=
  604. for _, v := range listPublic {
  605. listResp = append(listResp, &models.HomeArticle{
  606. ArticleId: v.ArticleId,
  607. Title: v.Title,
  608. Annotation: "核心观点:" + v.Annotation,
  609. Abstract: v.Abstract,
  610. ImgUrlPc: v.ImgUrlPc,
  611. PublishDate: v.PublishDate,
  612. Resource: v.Resource,
  613. })
  614. }
  615. //lenList := len(list)
  616. //for i := 0; i < lenList; i++ {
  617. // item := list[i]
  618. // list[i].Body = ""
  619. // list[i].Abstract, _ = services.GetReportContentTextSub(item.Abstract)
  620. // list[i].Annotation, _ = services.GetReportContentTextSub(item.Annotation)
  621. // list[i].PublishDate = utils.StrTimeToTime(item.PublishDate).Format(utils.FormatDate) //时间字符串格式转时间格式
  622. // //行业比较研究、资金流向,显示报告的摘要
  623. // if resp.MatchTypeName == "行业比较研究" || resp.MatchTypeName == "资金流向" {
  624. // list[i].Annotation = list[i].Abstract
  625. // }
  626. //}
  627. if len(listResp) == 0 {
  628. listResp = make([]*models.HomeArticle, 0)
  629. }
  630. page = paging.GetPaging(currentIndex, pageSize, total)
  631. resp.List = listResp
  632. resp.Paging = page
  633. br.Ret = 200
  634. br.Success = true
  635. br.Msg = "获取成功"
  636. br.Data = resp
  637. }
  638. // @Title 产业关注/取消关注
  639. // @Description 产业关注/取消关注 接口
  640. // @Param request body models.CygxIndustryFllowRep true "type json string"
  641. // @Success 200
  642. // @router /industrial/fllow [post]
  643. func (this *ReportController) IndustrialFllow() {
  644. br := new(models.BaseResponse).Init()
  645. defer func() {
  646. this.Data["json"] = br
  647. this.ServeJSON()
  648. }()
  649. user := this.User
  650. if user == nil {
  651. br.Msg = "请重新登录"
  652. br.Ret = 408
  653. return
  654. }
  655. uid := user.UserId
  656. var req models.CygxIndustryFllowRep
  657. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  658. if err != nil {
  659. br.Msg = "参数解析异常!"
  660. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  661. return
  662. }
  663. industrialManagementId := req.IndustrialManagementId
  664. var condition string
  665. countIndustrial, err := models.GetIndustrialManagementCount(industrialManagementId)
  666. if err != nil {
  667. br.Msg = "获取数据失败!"
  668. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  669. return
  670. }
  671. if countIndustrial == 0 {
  672. br.Msg = "产业不存在!"
  673. br.ErrMsg = "产业ID不存在:" + strconv.Itoa(industrialManagementId)
  674. return
  675. }
  676. count, err := models.GetCountCygxIndustryFllow(industrialManagementId, user.UserId, condition)
  677. if err != nil {
  678. br.Msg = "获取数据失败!"
  679. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  680. return
  681. }
  682. resp := new(models.CygxIndustryFllowResp)
  683. if count == 0 {
  684. item := new(models.CygxIndustryFllow)
  685. item.IndustrialManagementId = industrialManagementId
  686. item.UserId = uid
  687. item.Email = user.Email
  688. item.Mobile = user.Mobile
  689. item.RealName = user.RealName
  690. item.CompanyId = user.CompanyId
  691. item.CompanyName = user.CompanyName
  692. item.Type = 1
  693. item.CreateTime = time.Now()
  694. item.ModifyTime = time.Now()
  695. _, err = models.AddCygxIndustryFllow(item)
  696. if err != nil {
  697. br.Msg = "操作失败"
  698. br.ErrMsg = "操作失败,Err:" + err.Error()
  699. return
  700. }
  701. resp.Status = 1
  702. br.Msg = "关注成功"
  703. } else {
  704. err = models.RemoveCygxIndustryFllow(uid, industrialManagementId)
  705. if err != nil {
  706. br.Msg = "操作失败"
  707. br.ErrMsg = "取消关注失败,Err:" + err.Error()
  708. return
  709. }
  710. resp.Status = 2
  711. br.Msg = "已取消关注"
  712. }
  713. //处理是否关注全部赛道字段
  714. go services.IndustryFllowWithTrack(industrialManagementId, count, uid)
  715. go services.IndustryFllowUserLabelLogAdd(industrialManagementId, count, uid) //处理用户标签
  716. br.Ret = 200
  717. br.Success = true
  718. br.Data = resp
  719. }
  720. // @Title 行业关注/取消关注
  721. // @Description 行业关注/取消关注 接口
  722. // @Param request body models.CygxCategoryFllowRep true "type json string"
  723. // @Success 200
  724. // @router /category/fllow [post]
  725. func (this *ReportController) CategoryFllow() {
  726. br := new(models.BaseResponse).Init()
  727. defer func() {
  728. this.Data["json"] = br
  729. this.ServeJSON()
  730. }()
  731. user := this.User
  732. if user == nil {
  733. br.Msg = "请重新登录"
  734. br.Ret = 408
  735. return
  736. }
  737. uid := user.UserId
  738. var req models.CygxCategoryFllowRep
  739. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  740. if err != nil {
  741. br.Msg = "参数解析异常!"
  742. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  743. return
  744. }
  745. categoryId := req.CategoryId
  746. var condition string
  747. //countCategory, err := models.GetCategoryCount(categoryId)
  748. //if err != nil {
  749. // br.Msg = "获取数据失败!"
  750. // br.ErrMsg = "获取数据失败,Err:" + err.Error()
  751. // return
  752. //}
  753. //if countCategory == 0 {
  754. // br.Msg = "产业不存在!"
  755. // br.ErrMsg = "产业ID不存在:" + strconv.Itoa(categoryId)
  756. // return
  757. //}
  758. listMap, err := models.GetCygxXzsChooseCategoryMapList()
  759. if err != nil {
  760. br.Msg = "操作失败!"
  761. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  762. return
  763. }
  764. mapReport := make(map[int]int)
  765. for _, v := range listMap {
  766. mapReport[v.Id] = v.CategoryId
  767. }
  768. if mapReport[categoryId] == 0 {
  769. br.Msg = "操作失败!"
  770. br.ErrMsg = "分类ID不存在,ID:" + strconv.Itoa(categoryId)
  771. return
  772. }
  773. count, err := models.GetCountCategoryFllow(mapReport[categoryId], user.Mobile, condition)
  774. if err != nil {
  775. br.Msg = "获取数据失败!"
  776. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  777. return
  778. }
  779. resp := new(models.CygxIndustryFllowResp)
  780. if count == 0 {
  781. item := new(models.CygxXzsChooseCategory)
  782. item.CategoryId = mapReport[categoryId]
  783. item.IdCygx = categoryId
  784. item.UserId = uid
  785. item.Email = user.Email
  786. item.Mobile = user.Mobile
  787. item.RealName = user.RealName
  788. item.CompanyId = user.CompanyId
  789. item.CompanyName = user.CompanyName
  790. item.CreateTime = time.Now()
  791. item.ModifyTime = time.Now()
  792. _, err = models.AddCygxCategoryFllow(item)
  793. if err != nil {
  794. br.Msg = "操作失败"
  795. br.ErrMsg = "操作失败,Err:" + err.Error()
  796. return
  797. }
  798. resp.Status = 1
  799. br.Msg = "关注成功"
  800. } else {
  801. err = models.RemoveCygxCategoryFllow(user.Mobile, mapReport[categoryId])
  802. if err != nil {
  803. br.Msg = "操作失败"
  804. br.ErrMsg = "取消关注失败,Err:" + err.Error()
  805. return
  806. }
  807. resp.Status = 2
  808. br.Msg = "已取消关注"
  809. }
  810. go services.CategoryFllowUserLabelLogAdd(categoryId, count, uid) //处理用户标签
  811. br.Ret = 200
  812. br.Success = true
  813. br.Data = resp
  814. }
  815. // @Title 报告搜索
  816. // @Description 报告搜索接口
  817. // @Param PageSize query int true "每页数据条数"
  818. // @Param CurrentIndex query int true "当前页页码,从1开始"
  819. // @Param KeyWord query string true "搜索关键词"
  820. // @Param ArticleType query int true "文章类型,1弘则报告、2研选 "
  821. // @Param IsAll query bool true "是否为综合 "
  822. // @Success 200 {object} models.ReoprtSearchResp
  823. // @router /searchReport [get]
  824. func (this *MobileReportController) SearchReport() {
  825. br := new(models.BaseResponse).Init()
  826. defer func() {
  827. this.Data["json"] = br
  828. this.ServeJSON()
  829. }()
  830. user := this.User
  831. if user == nil {
  832. br.Msg = "请重新登录"
  833. br.Ret = 408
  834. return
  835. }
  836. pageSize, _ := this.GetInt("PageSize")
  837. currentIndex, _ := this.GetInt("CurrentIndex")
  838. articleType, _ := this.GetInt("ArticleType", 1)
  839. keyWord := this.GetString("KeyWord")
  840. isAll, _ := this.GetBool("IsAll")
  841. var condition string
  842. var pars []interface{}
  843. //var conditionSql string
  844. var total int
  845. var startSize int
  846. if pageSize <= 0 {
  847. pageSize = utils.PageSize20
  848. }
  849. if isAll {
  850. pageSize = utils.PageSize5
  851. }
  852. if currentIndex <= 0 {
  853. currentIndex = 1
  854. }
  855. startSize = paging.StartIndex(currentIndex, pageSize)
  856. resp := new(models.ReoprtSearchResp)
  857. //匹配报告标题、
  858. articleTypeIds, err := services.GetYanXuanArticleTypeIds()
  859. if err != nil {
  860. br.Msg = "获取信息失败"
  861. br.ErrMsg = "GetYanXuanArticleTypeIds,Err:" + err.Error()
  862. return
  863. }
  864. if articleTypeIds == "" {
  865. br.Msg = "获取信息失败"
  866. br.ErrMsg = "研选分类ID不能为空"
  867. return
  868. }
  869. //处理对应的文章类型标签按钮
  870. nameMap, styleMap, err := services.GetArticleTypeMap()
  871. if err != nil {
  872. br.Msg = "获取信息失败"
  873. br.ErrMsg = "GetArticleTypeMap Err:" + err.Error()
  874. return
  875. }
  876. if isAll {
  877. total = utils.PageSize5
  878. conditionHz := ` AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%' OR a.annotation LIKE '%` + keyWord + `%' OR a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1 AND a.article_type_id NOT IN (` + articleTypeIds + `) `
  879. conditionYx := ` AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%' OR a.annotation LIKE '%` + keyWord + `%' OR a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1 AND a.article_type_id IN (` + articleTypeIds + `) `
  880. listHz, err := models.GetArticleResearchListHz(conditionHz, pars, startSize, pageSize, user.UserId)
  881. if err != nil {
  882. br.Msg = "获取信息失败"
  883. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  884. return
  885. }
  886. listYx, err := models.GetArticleResearchList(conditionYx, pars, startSize, pageSize, user.UserId)
  887. if err != nil {
  888. br.Msg = "获取信息失败"
  889. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  890. return
  891. }
  892. listHz, err = services.HandleArticleCategoryImg(listHz, user)
  893. if err != nil {
  894. br.Msg = "获取信息失败"
  895. br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
  896. return
  897. }
  898. listYx, err = services.HandleArticleCategoryImg(listYx, user)
  899. if err != nil {
  900. br.Msg = "获取信息失败"
  901. br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
  902. return
  903. }
  904. for _, v := range listHz {
  905. item := models.ArticleResearchResp{
  906. ArticleId: v.ArticleId,
  907. ArticleTypeId: v.ArticleTypeId,
  908. Title: v.Title,
  909. PublishDate: v.PublishDate,
  910. DepartmentId: v.DepartmentId,
  911. NickName: v.NickName,
  912. IsCollect: v.IsCollect,
  913. Pv: v.Pv,
  914. CollectNum: v.CollectNum,
  915. Abstract: v.Abstract,
  916. Annotation: v.Annotation,
  917. ImgUrlPc: v.ImgUrlPc,
  918. ArticleTypeName: nameMap[v.ArticleTypeId],
  919. ButtonStyle: styleMap[v.ArticleTypeId],
  920. List: v.List,
  921. }
  922. resp.ListHz = append(resp.ListHz, &item)
  923. }
  924. for _, v := range listYx {
  925. item := models.ArticleResearchResp{
  926. ArticleId: v.ArticleId,
  927. ArticleTypeId: v.ArticleTypeId,
  928. Title: v.Title,
  929. PublishDate: v.PublishDate,
  930. DepartmentId: v.DepartmentId,
  931. NickName: v.NickName,
  932. IsCollect: v.IsCollect,
  933. Pv: v.Pv,
  934. CollectNum: v.CollectNum,
  935. Abstract: v.Abstract,
  936. Annotation: v.Annotation,
  937. ImgUrlPc: v.ImgUrlPc,
  938. ArticleTypeName: nameMap[v.ArticleTypeId],
  939. ButtonStyle: styleMap[v.ArticleTypeId],
  940. List: v.List,
  941. }
  942. resp.ListYx = append(resp.ListYx, &item)
  943. }
  944. } else {
  945. //condition = `AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%' OR a.annotation LIKE '%` + keyWord + `%' OR a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1 `
  946. if articleType == 1 {
  947. condition = ` AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%' OR a.annotation LIKE '%` + keyWord + `%' OR a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1 AND a.article_type_id NOT IN (` + articleTypeIds + `) `
  948. total, err = models.GetReoprtSearchCountHz(condition)
  949. } else {
  950. condition = ` AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%' OR a.annotation LIKE '%` + keyWord + `%' OR a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1 AND a.article_type_id IN (` + articleTypeIds + `) `
  951. total, err = models.GetReoprtSearchCountYx(condition)
  952. }
  953. if err != nil {
  954. br.Msg = "获取信息失败"
  955. br.Msg = "获取总数失败,Err:" + err.Error()
  956. return
  957. }
  958. var list []*models.ArticleListResp
  959. //list := new([]models.ArticleResearchResp)
  960. if articleType == 1 {
  961. list, err = models.GetArticleResearchListHz(condition, pars, startSize, pageSize, user.UserId)
  962. } else {
  963. list, err = models.GetArticleResearchList(condition, pars, startSize, pageSize, user.UserId)
  964. }
  965. if err != nil {
  966. br.Msg = "获取信息失败"
  967. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  968. return
  969. }
  970. //return
  971. list, err = services.HandleArticleCategoryImg(list, user)
  972. if err != nil {
  973. br.Msg = "获取信息失败"
  974. br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
  975. return
  976. }
  977. for _, v := range list {
  978. item := models.ArticleResearchResp{
  979. ArticleId: v.ArticleId,
  980. ArticleTypeId: v.ArticleTypeId,
  981. Title: v.Title,
  982. PublishDate: v.PublishDate,
  983. DepartmentId: v.DepartmentId,
  984. NickName: v.NickName,
  985. IsCollect: v.IsCollect,
  986. Pv: v.Pv,
  987. CollectNum: v.CollectNum,
  988. Abstract: v.Abstract,
  989. Annotation: v.Annotation,
  990. ImgUrlPc: v.ImgUrlPc,
  991. ArticleTypeName: nameMap[v.ArticleTypeId],
  992. ButtonStyle: styleMap[v.ArticleTypeId],
  993. List: v.List,
  994. }
  995. if articleType == 1 {
  996. resp.ListHz = append(resp.ListHz, &item)
  997. } else {
  998. resp.ListYx = append(resp.ListYx, &item)
  999. }
  1000. }
  1001. }
  1002. if keyWord != "" {
  1003. //go services.AddUserSearchLog(user, keyWord, 5)
  1004. }
  1005. if len(resp.ListHz) == 0 {
  1006. resp.ListHz = make([]*models.ArticleResearchResp, 0)
  1007. }
  1008. if len(resp.ListYx) == 0 {
  1009. resp.ListYx = make([]*models.ArticleResearchResp, 0)
  1010. }
  1011. page := paging.GetPaging(currentIndex, pageSize, total)
  1012. resp.Paging = page
  1013. br.Ret = 200
  1014. br.Success = true
  1015. br.Msg = "获取成功"
  1016. br.Data = resp
  1017. }
  1018. // @Title 资源包搜索
  1019. // @Description 资源包搜索接口
  1020. // @Param KeyWord query string true "搜索关键词"
  1021. // @Success 200 {object} models.SearchResourceResp
  1022. // @router /searchResource [get]
  1023. func (this *MobileReportController) SearchResource() {
  1024. br := new(models.BaseResponse).Init()
  1025. defer func() {
  1026. this.Data["json"] = br
  1027. this.ServeJSON()
  1028. }()
  1029. user := this.User
  1030. if user == nil {
  1031. br.Msg = "请重新登录"
  1032. br.Ret = 408
  1033. return
  1034. }
  1035. uid := user.UserId
  1036. fllowList, err := models.GetUserFllowIndustrialList(uid)
  1037. if err != nil {
  1038. br.Msg = "获取失败"
  1039. br.ErrMsg = "获取失败,GetUserFllowIndustrialList Err:" + err.Error()
  1040. return
  1041. }
  1042. fllowMap := make(map[int]int)
  1043. if len(fllowList) > 0 {
  1044. for _, v := range fllowList {
  1045. fllowMap[v.IndustrialManagementId] = v.IndustrialManagementId
  1046. }
  1047. }
  1048. keyWord := this.GetString("KeyWord")
  1049. var condition string
  1050. articleTypeIds, err := services.GetYanXuanArticleTypeIds()
  1051. if err != nil {
  1052. br.Msg = "获取信息失败"
  1053. br.ErrMsg = "GetYanXuanArticleTypeIds,Err:" + err.Error()
  1054. return
  1055. }
  1056. if articleTypeIds == "" {
  1057. br.Msg = "获取信息失败"
  1058. br.ErrMsg = "研选分类ID不能为空"
  1059. return
  1060. }
  1061. condition = ` AND a.publish_status = 1 AND a.article_type_id NOT IN (` + articleTypeIds + `) AND (m.industry_name LIKE '%` + keyWord + `%' OR m.subject_names LIKE '%` + keyWord + `%' ) `
  1062. listHz, err := models.GetSearchResourceList(condition)
  1063. if err != nil {
  1064. br.Msg = "获取信息失败"
  1065. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1066. return
  1067. }
  1068. condition = ` AND a.publish_status = 1 AND a.article_type_id IN (` + articleTypeIds + `) AND (m.industry_name LIKE '%` + keyWord + `%' OR m.subject_names LIKE '%` + keyWord + `%' ) `
  1069. listYx, err := models.GetSearchResourceList(condition)
  1070. if err != nil {
  1071. br.Msg = "获取信息失败"
  1072. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1073. return
  1074. }
  1075. if len(listYx) > 0 {
  1076. listYx, err = services.HandleIndustryList(listYx, user, "Yx")
  1077. if err != nil {
  1078. br.Msg = "获取信息失败"
  1079. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1080. return
  1081. }
  1082. }
  1083. if len(listHz) > 0 {
  1084. listHz, err = services.HandleIndustryList(listHz, user, "Hz")
  1085. if err != nil {
  1086. br.Msg = "获取信息失败"
  1087. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1088. return
  1089. }
  1090. }
  1091. if keyWord != "" {
  1092. //go services.AddUserSearchLog(user, keyWord, 4)
  1093. }
  1094. resp := new(models.SearchResourceResp)
  1095. if len(listHz) == 0 {
  1096. listHz = make([]*models.IndustrialManagement, 0)
  1097. }
  1098. if len(listYx) == 0 {
  1099. listYx = make([]*models.IndustrialManagement, 0)
  1100. }
  1101. resp.ListHz = listHz
  1102. resp.ListYx = listYx
  1103. br.Ret = 200
  1104. br.Success = true
  1105. br.Msg = "获取成功"
  1106. br.Data = resp
  1107. }
  1108. // @Title 报告搜索、资源包搜索接口
  1109. // @Description 报告搜索、资源包搜索接口接口
  1110. // @Param KeyWord query string true "搜索关键词"
  1111. // @Param PageSize query int true "每页数据条数"
  1112. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1113. // @Param SearchType query int true "1:综合,2:全部"
  1114. // @Success 200 {object} models.SearchReportAndResourceResp
  1115. // @router /searchReportAndResource [get]
  1116. func (this *MobileReportController) SearchReportAndResource() {
  1117. br := new(models.BaseResponse).Init()
  1118. defer func() {
  1119. this.Data["json"] = br
  1120. this.ServeJSON()
  1121. }()
  1122. user := this.User
  1123. if user == nil {
  1124. br.Msg = "请重新登录"
  1125. br.Ret = 408
  1126. return
  1127. }
  1128. //uid := user.UserId
  1129. keyWord := this.GetString("KeyWord")
  1130. pageSize, _ := this.GetInt("PageSize")
  1131. currentIndex, _ := this.GetInt("CurrentIndex")
  1132. searchType, _ := this.GetInt("SearchType")
  1133. var total int
  1134. var startSize int
  1135. if pageSize <= 0 {
  1136. pageSize = utils.PageSize20
  1137. }
  1138. if currentIndex <= 0 {
  1139. currentIndex = 1
  1140. }
  1141. startSize = paging.StartIndex(currentIndex, pageSize)
  1142. page := paging.GetPaging(currentIndex, pageSize, total)
  1143. var condition string
  1144. var conditionSql string
  1145. //匹配报告标题、
  1146. condition = ` AND ( a.title LIKE '%` + keyWord + `%' OR a.body LIKE '%` + keyWord + `%') AND a.publish_status = 1 `
  1147. conditionSql = ` AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId) + condition + ` OR ( article_type = 'lyjh' ` + condition + ` ) `
  1148. total, err := models.GetReoprtSearchCount(conditionSql)
  1149. if err != nil {
  1150. br.Msg = "获取信息失败"
  1151. br.Msg = "获取总数失败,Err:" + err.Error()
  1152. return
  1153. }
  1154. if searchType == 1 {
  1155. pageSize = utils.PageSize5
  1156. }
  1157. ListHzReport, err := services.GetReoprtSearchListHz(conditionSql, user.UserId, startSize, pageSize)
  1158. if err != nil {
  1159. br.Msg = "获取失败"
  1160. br.ErrMsg = "获取失败,GetReoprtSearchListHz Err:" + err.Error()
  1161. return
  1162. }
  1163. if len(ListHzReport) == 0 {
  1164. ListHzReport = make([]*models.ArticleCollectionResp, 0)
  1165. }
  1166. var conditionOr string
  1167. conditionOr += ` OR ( m.subject_names LIKE '%` + keyWord + `%' AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId) + ` AND publish_status = 1 ) `
  1168. condition = ` AND m.industry_name LIKE '%` + keyWord + `%' AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId) + conditionOr
  1169. listHzResource, err := services.GetSearchResourceListHz(condition, user)
  1170. if err != nil {
  1171. br.Msg = "获取信息失败"
  1172. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1173. return
  1174. }
  1175. resp := new(models.SearchReportAndResourceResp)
  1176. if len(listHzResource) == 0 {
  1177. listHzResource = make([]*models.IndustrialManagement, 0)
  1178. }
  1179. if keyWord != "" {
  1180. //go services.AddUserSearchLog(user, keyWord, 5)
  1181. }
  1182. page = paging.GetPaging(currentIndex, pageSize, total)
  1183. resp.Paging = page
  1184. resp.ListHzResource = listHzResource
  1185. resp.ListHzReport = ListHzReport
  1186. br.Ret = 200
  1187. br.Success = true
  1188. br.Msg = "获取成功"
  1189. br.Data = resp
  1190. }
  1191. // @Title 公司速览
  1192. // @Description 公司速览接口
  1193. // @Param ChartPermissionId query int false "分类ID"
  1194. // @Success 200 {object} models.ArticleDataLogoListResp
  1195. // @router /companyList [get]
  1196. func (this *ReportCommonController) CompanyList() {
  1197. br := new(models.BaseResponse).Init()
  1198. defer func() {
  1199. this.Data["json"] = br
  1200. this.ServeJSON()
  1201. }()
  1202. var condition string
  1203. var pars []interface{}
  1204. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  1205. if chartPermissionId > 1 {
  1206. categoryId, err := models.GetCategoryId(chartPermissionId)
  1207. if err != nil && err.Error() != utils.ErrNoRow() {
  1208. br.Msg = "获取信息失败"
  1209. br.ErrMsg = "获取分类权限信息失败,Err:" + err.Error()
  1210. return
  1211. }
  1212. if categoryId != "" {
  1213. condition += ` AND a.category_id IN (` + categoryId + `)`
  1214. }
  1215. }
  1216. condition += ` AND a.type_name = '综述报告' ORDER BY a.modify_time_by_cl DESC `
  1217. list, err := models.CygxArticleDataList(condition, pars)
  1218. if err != nil {
  1219. br.Msg = "获取失败"
  1220. br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
  1221. return
  1222. }
  1223. listLogo := make([]*models.ArticleDataLogoResp, 0)
  1224. for i := range list {
  1225. v := list[i]
  1226. comapnyList := services.HandleArticleStock(v.Stock)
  1227. if len(comapnyList) > 1 {
  1228. for kC, vC := range comapnyList {
  1229. sliceCovers := strings.Split(v.Cover, "{|}")
  1230. cover := v.Cover
  1231. if len(sliceCovers) == len(comapnyList) {
  1232. cover = sliceCovers[kC]
  1233. }
  1234. listLogo = append(listLogo, &models.ArticleDataLogoResp{
  1235. ArticleId: v.ArticleId,
  1236. Cover: cover,
  1237. ComapnyList: services.HandleArticleStock(vC.ComapnyName),
  1238. })
  1239. }
  1240. } else {
  1241. listLogo = append(listLogo, &models.ArticleDataLogoResp{
  1242. ArticleId: v.ArticleId,
  1243. Cover: v.Cover,
  1244. ComapnyList: services.HandleArticleStock(v.Stock),
  1245. })
  1246. }
  1247. }
  1248. resp := new(models.ArticleDataLogoListResp)
  1249. resp.List = listLogo
  1250. br.Ret = 200
  1251. br.Success = true
  1252. br.Msg = "获取成功"
  1253. br.Data = resp
  1254. }
  1255. // @Title 时间线
  1256. // @Description 时间线接口
  1257. // @Param PageSize query int true "每页数据条数"
  1258. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1259. // @Param IndustrialManagementId query int false "产业ID"
  1260. // @Success 200 {object} models.TacticsListResp
  1261. // @router /timeline [get]
  1262. func (this *MobileReportController) Timeline() {
  1263. br := new(models.BaseResponse).Init()
  1264. defer func() {
  1265. this.Data["json"] = br
  1266. this.ServeJSON()
  1267. }()
  1268. user := this.User
  1269. if user == nil {
  1270. br.Msg = "请重新登录"
  1271. br.Ret = 408
  1272. return
  1273. }
  1274. pageSize, _ := this.GetInt("PageSize")
  1275. currentIndex, _ := this.GetInt("CurrentIndex")
  1276. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  1277. var startSize int
  1278. if pageSize <= 0 {
  1279. pageSize = utils.PageSize20
  1280. }
  1281. if currentIndex <= 0 {
  1282. currentIndex = 1
  1283. }
  1284. startSize = paging.StartIndex(currentIndex, pageSize)
  1285. var total int
  1286. resp := new(models.TacticsListTimeResp)
  1287. page := paging.GetPaging(currentIndex, pageSize, total)
  1288. list := make([]*models.TimeLineReportItem, 0)
  1289. var err error
  1290. list, total, err = models.GetTimeLineReportIndustrialListTime(user.UserId, industrialManagementId, startSize, pageSize)
  1291. if err != nil {
  1292. br.Msg = "获取信息失败"
  1293. br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
  1294. return
  1295. }
  1296. //查询用户今天是否看过时间线
  1297. count, err := models.GetTimeLineRecordCount(user.UserId, industrialManagementId)
  1298. if err != nil {
  1299. br.Msg = "查询浏览记录数量失败"
  1300. br.ErrMsg = "查询浏览记录数量失败,Err:" + err.Error()
  1301. return
  1302. }
  1303. var recordItem *models.CygxPageHistoryRecord
  1304. if count > 1 {
  1305. recordItem, err = models.GetTimeLineRecordItem(user.UserId, industrialManagementId)
  1306. if err != nil {
  1307. br.Msg = "查询浏览记录失败"
  1308. br.ErrMsg = "查询浏览记录失败,Err:" + err.Error()
  1309. return
  1310. }
  1311. }
  1312. for k, v := range list {
  1313. if v.SubCategoryName != "时间线" && v.Readnum == 0 && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
  1314. list[k].IsRed = true
  1315. }
  1316. timeLineRed := false
  1317. if count < 2 && v.SubCategoryName == "时间线" {
  1318. timeLineRed = true
  1319. } else if count > 1 && recordItem.CreateTime.Before(utils.StrTimeToTime(v.PublishDate)) {
  1320. timeLineRed = true
  1321. }
  1322. if v.SubCategoryName == "时间线" && timeLineRed {
  1323. list[k].IsRed = true
  1324. }
  1325. if v.VideoUrl != "" {
  1326. list[k].IsHaveVideo = true
  1327. }
  1328. v.PublishDate = utils.TimeRemoveHms2(v.PublishDate)
  1329. }
  1330. //添加我的日程访问记录
  1331. item := new(models.CygxPageHistoryRecord)
  1332. item.UserId = user.UserId
  1333. item.CreateTime = time.Now()
  1334. item.CompanyId = user.CompanyId
  1335. item.CompanyName = user.CompanyName
  1336. item.Router = utils.TIME_LINE_ROUTE + strconv.Itoa(industrialManagementId)
  1337. go models.AddCygxPageHistoryRecord(item)
  1338. if len(list) == 0 {
  1339. list = make([]*models.TimeLineReportItem, 0)
  1340. }
  1341. page = paging.GetPaging(currentIndex, pageSize, total)
  1342. resp.List = list
  1343. resp.Paging = page
  1344. br.Ret = 200
  1345. br.Success = true
  1346. br.Msg = "获取成功"
  1347. br.Data = resp
  1348. }
  1349. // @Title 文章留言接口
  1350. // @Description 文章留言接口
  1351. // @Param request body models.AddCygxActivityHelpAsk true "type json string"
  1352. // @Success 200 {object} models.TacticsListResp
  1353. // @router /commentAdd [post]
  1354. func (this *ReportController) CommentAdd() {
  1355. br := new(models.BaseResponse).Init()
  1356. defer func() {
  1357. this.Data["json"] = br
  1358. this.ServeJSON()
  1359. }()
  1360. user := this.User
  1361. if user == nil {
  1362. br.Msg = "请重新登录"
  1363. br.Ret = 408
  1364. return
  1365. }
  1366. var req models.AddCygxArticleCommentReq
  1367. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1368. if err != nil {
  1369. br.Msg = "参数解析异常!"
  1370. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1371. return
  1372. }
  1373. if req.ArticleId <= 0 {
  1374. br.Msg = "文章不存在"
  1375. br.ErrMsg = "文章不存在,文章ID错误"
  1376. return
  1377. }
  1378. if req.Content == "" {
  1379. br.Msg = "建议内容不可为空"
  1380. return
  1381. }
  1382. content := req.Content
  1383. if content == "" {
  1384. br.Msg = "留言内容不能为空!"
  1385. return
  1386. }
  1387. //itemToken, err := services.WxGetToken()
  1388. //if err != nil {
  1389. // br.Msg = "GetWxAccessToken Err:" + err.Error()
  1390. // return
  1391. //}
  1392. //if itemToken.AccessToken == "" {
  1393. // br.Msg = "accessToken is empty"
  1394. // return
  1395. //}
  1396. //commerr, err := weapp.MSGSecCheck(itemToken.AccessToken, content)
  1397. //if err != nil {
  1398. // br.Msg = "内容校验失败!"
  1399. // br.ErrMsg = "内容校验失败,Err:" + err.Error()
  1400. // return
  1401. //}
  1402. //if commerr.ErrCode != 0 {
  1403. // br.Msg = "内容违规,请重新提交!"
  1404. // br.ErrMsg = "内容违规,Err:" + commerr.ErrMSG
  1405. // return
  1406. //}
  1407. articleId := req.ArticleId
  1408. articleInfo, errInfo := models.GetArticleDetailById(articleId)
  1409. if articleInfo == nil {
  1410. br.Msg = "操作失败"
  1411. br.ErrMsg = "文章ID错误,不存在articleId:" + strconv.Itoa(articleId)
  1412. return
  1413. }
  1414. if errInfo != nil {
  1415. br.Msg = "操作失败"
  1416. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1417. return
  1418. }
  1419. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1420. if err != nil {
  1421. br.Msg = "提交失败!"
  1422. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1423. return
  1424. }
  1425. if companyDetail == nil {
  1426. br.Msg = "提交失败!"
  1427. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId)
  1428. return
  1429. }
  1430. item := models.CygxArticleComment{
  1431. UserId: user.UserId,
  1432. ArticleId: req.ArticleId,
  1433. CreateTime: time.Now(),
  1434. Mobile: user.Mobile,
  1435. Email: user.Email,
  1436. CompanyId: user.CompanyId,
  1437. CompanyName: companyDetail.CompanyName,
  1438. Content: content,
  1439. Title: articleInfo.Title,
  1440. }
  1441. msgId, err := models.AddArticleComment(&item)
  1442. if err != nil {
  1443. br.Msg = "提交失败"
  1444. br.ErrMsg = "提交留言失败,Err:" + err.Error()
  1445. return
  1446. }
  1447. go services.SendCommentWxTemplateMsg(req, user, articleInfo, int(msgId))
  1448. br.Ret = 200
  1449. br.Success = true
  1450. br.Msg = "提交成功"
  1451. }
  1452. // @Title 报告精选、本周研究汇总、上周纪要汇总列表
  1453. // @Description 获取报告精选、本周研究汇总、上周纪要汇总列表接口
  1454. // @Param PageSize query int true "每页数据条数"
  1455. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1456. // @Param ReportType string query true "报告类型 ,1报告精选、2本周研究汇总、3上周纪要汇总"
  1457. // @Success 200 {object} models.CygxReportSelectionListPublicRep
  1458. // @router /reportList/byType [get]
  1459. func (this *ReportController) ReportListByType() {
  1460. br := new(models.BaseResponse).Init()
  1461. defer func() {
  1462. this.Data["json"] = br
  1463. this.ServeJSON()
  1464. }()
  1465. user := this.User
  1466. if user == nil {
  1467. br.Msg = "请重新登录"
  1468. br.Ret = 408
  1469. return
  1470. }
  1471. uid := user.UserId
  1472. pageSize, _ := this.GetInt("PageSize")
  1473. currentIndex, _ := this.GetInt("CurrentIndex")
  1474. reportType := this.GetString("ReportType")
  1475. var condition string
  1476. var startSize int
  1477. if pageSize <= 0 {
  1478. pageSize = utils.PageSize20
  1479. }
  1480. if currentIndex <= 0 {
  1481. currentIndex = 1
  1482. }
  1483. startSize = paging.StartIndex(currentIndex, pageSize)
  1484. var pars []interface{}
  1485. var total int
  1486. resp := new(models.CygxReportSelectionListPublicRep)
  1487. page := paging.GetPaging(currentIndex, pageSize, total)
  1488. var tbdb string
  1489. var readSql string
  1490. var reportTypeStr string
  1491. if reportType == "1" {
  1492. tbdb = "cygx_report_selection"
  1493. reportTypeStr = "bgjx"
  1494. } else if reportType == "2" {
  1495. tbdb = "cygx_research_summary"
  1496. reportTypeStr = "bzyjhz"
  1497. } else if reportType == "3" {
  1498. tbdb = "cygx_minutes_summary"
  1499. reportTypeStr = "szjyhz"
  1500. } else {
  1501. br.Msg = "请选择报告类型"
  1502. return
  1503. }
  1504. condition = ` AND publish_status = 1 `
  1505. if user.CompanyId != utils.HZ_COMPANY_ID {
  1506. condition += ` AND visible_range = 1 `
  1507. }
  1508. total, err := models.GetCygxReportSelectionPublic(condition, tbdb, pars)
  1509. if err != nil {
  1510. br.Msg = "获取信息失败"
  1511. br.ErrMsg = "获取帖子总数失败,Err:" + err.Error()
  1512. return
  1513. }
  1514. //研究汇总--报告精选 只显示最新一期,往期都隐藏
  1515. if reportType == "1" {
  1516. startSize = 0
  1517. pageSize = 1
  1518. total = 1
  1519. }
  1520. readSql = ` (SELECT COUNT(1) AS count FROM cygx_report_history_record AS h WHERE h.article_id = art.article_id AND report_type ='` + reportTypeStr + `' AND h.user_id = ` + strconv.Itoa(uid) + `) as read_num`
  1521. page = paging.GetPaging(currentIndex, pageSize, total)
  1522. list, err := models.GetReportSelectionListPublic(condition, readSql, tbdb, pars, startSize, pageSize)
  1523. if err != nil {
  1524. br.Msg = "获取失败"
  1525. br.ErrMsg = "获取失败,Err:" + err.Error()
  1526. return
  1527. }
  1528. for k, v := range list {
  1529. if reportType == "1" {
  1530. list[k].Abstract = v.UpdateDescription
  1531. }
  1532. list[k].PublishDate = utils.StrTimeToTime(v.PublishDate).Format("2006-01-02")
  1533. if v.ReadNum == 0 {
  1534. list[k].IsRed = true
  1535. }
  1536. }
  1537. resp.List = list
  1538. resp.Paging = page
  1539. br.Ret = 200
  1540. br.Success = true
  1541. br.Msg = "获取成功"
  1542. br.Data = resp
  1543. }
  1544. // @Title 获取本周研究汇总详情
  1545. // @Description 获取本周研究汇总详情接口
  1546. // @Param ArticleId query int true "报告ID"
  1547. // @Success 200 {object} models.ResearchSummaryLetailResp
  1548. // @router /researchSummary/detail [get]
  1549. func (this *ReportController) ResearchDetail() {
  1550. br := new(models.BaseResponse).Init()
  1551. defer func() {
  1552. this.Data["json"] = br
  1553. this.ServeJSON()
  1554. }()
  1555. user := this.User
  1556. if user == nil {
  1557. br.Msg = "请重新登录"
  1558. br.Ret = 408
  1559. return
  1560. }
  1561. //uid := user.UserId
  1562. articleId, _ := this.GetInt("ArticleId")
  1563. if articleId < 0 {
  1564. br.Msg = "参数错误"
  1565. br.ErrMsg = "参数错误"
  1566. return
  1567. }
  1568. resp := new(models.ResearchSummaryLetailResp)
  1569. //判断用户权限
  1570. hasPermission, err := services.GetUserhasPermission(user)
  1571. if err != nil {
  1572. br.Msg = "获取信息失败"
  1573. br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
  1574. }
  1575. detail, err := models.GetCygxResearchSummaryInfoById(articleId)
  1576. if err != nil {
  1577. br.Msg = "获取信息失败"
  1578. br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId:" + strconv.Itoa(articleId)
  1579. return
  1580. }
  1581. //未设置全部可见的只能给弘则内部查看
  1582. if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
  1583. resp.IsShow = true
  1584. }
  1585. resp.HasPermission = hasPermission
  1586. if hasPermission != 1 || !resp.IsShow {
  1587. br.Ret = 200
  1588. br.Success = true
  1589. br.Msg = "获取成功"
  1590. br.Data = resp
  1591. return
  1592. }
  1593. detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format(utils.FormatDate)
  1594. detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
  1595. listFirst, err := models.GetResearchSummarylogListFirst(articleId)
  1596. if err != nil {
  1597. br.Msg = "获取失败"
  1598. br.ErrMsg = "获取子类信息失败,Err:" + err.Error()
  1599. return
  1600. }
  1601. listArticleType, err := models.GetCygxArticleTypeList()
  1602. if err != nil {
  1603. br.Msg = "获取失败"
  1604. br.ErrMsg = "获取文章类型数据失败,Err:" + err.Error()
  1605. return
  1606. }
  1607. for k, v := range listFirst {
  1608. listSecond, err := models.GetResearchSummarylogSonListSecond(articleId, v.Type)
  1609. if err != nil && err.Error() != utils.ErrNoRow() {
  1610. br.Msg = "获取信息失败"
  1611. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1612. return
  1613. }
  1614. for k2, v2 := range listSecond {
  1615. listThird, err := models.GetResearchSummarylogSonListThird(articleId, v2.ChartPermissionId, v.Type)
  1616. if err != nil && err.Error() != utils.ErrNoRow() {
  1617. br.Msg = "获取信息失败"
  1618. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1619. return
  1620. }
  1621. for _, vType := range listArticleType {
  1622. if v2.ChartPermissionId == vType.YanxPermissionId {
  1623. listSecond[k2].IcoLink = vType.IcoLinkM
  1624. listSecond[k2].PermissionName = vType.YanxPermissionName
  1625. }
  1626. }
  1627. if len(listThird) > 0 {
  1628. for k3, v3 := range listThird {
  1629. if v3.VideoUrl != "" {
  1630. listThird[k3].IsHaveVideo = true
  1631. }
  1632. if v3.ReportLink == "0" {
  1633. listThird[k3].ReportLink = ""
  1634. }
  1635. }
  1636. listSecond[k2].List = listThird
  1637. }
  1638. }
  1639. if len(listSecond) > 0 {
  1640. listFirst[k].List = listSecond
  1641. }
  1642. //`description:"类型'SDBG深度报告片篇,’CYDYJY:产业调研纪要’,’SJDP事件点评,’BZCHJH:本周晨会精华’"`
  1643. if v.Type == "SDBG" {
  1644. listFirst[k].ListName = "深度报告"
  1645. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211027/le8AcRjDz0MhA72bVDiaf3d5ALSe.png"
  1646. } else if v.Type == "BZCHJH" {
  1647. listFirst[k].ListName = "本周晨会精华"
  1648. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/DCfekcxaIKGePBsNVu1ULfmNcJBY.png"
  1649. } else if v.Type == "CYDYJY" {
  1650. listFirst[k].ListName = "产业调研纪要"
  1651. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/UPAdozy96z9ypzY04vi0Y3Ogqzji.png"
  1652. } else if v.Type == "SSGS" {
  1653. listFirst[k].ListName = "上市公司调研纪要篇"
  1654. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211101/ujHXB48I8ay9T0XoPRI7lorz7OkL.png"
  1655. } else if v.Type == "SJDP" {
  1656. listFirst[k].ListName = "市场QA汇总"
  1657. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/2a5cXafO3Iws4QcFp1bd5WPdYikV.png"
  1658. } else if v.Type == "YANX" {
  1659. listFirst[k].ListName = "买方研选"
  1660. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211104/QbTGTNhD9MxYp24cJ7V5WpCN0oNl.png"
  1661. }
  1662. }
  1663. //go services.AddCygxReportHistoryRecord(user, articleId, "bzyjhz")
  1664. resp.List = listFirst
  1665. resp.Detail = detail
  1666. br.Ret = 200
  1667. br.Success = true
  1668. br.Msg = "获取成功"
  1669. br.Data = resp
  1670. }
  1671. // @Title 上周纪要汇总内容详情
  1672. // @Description 获取上周纪要汇总内容详情接口
  1673. // @Param ArticleId query int true "报告ID"
  1674. // @Success 200 {object} models.MinutesSummaryLetailResp
  1675. // @router /minutesSummary/detail [get]
  1676. func (this *ReportController) MinutesDetail() {
  1677. br := new(models.BaseResponse).Init()
  1678. defer func() {
  1679. this.Data["json"] = br
  1680. this.ServeJSON()
  1681. }()
  1682. user := this.User
  1683. if user == nil {
  1684. br.Msg = "请重新登录"
  1685. br.Ret = 408
  1686. return
  1687. }
  1688. articleId, _ := this.GetInt("ArticleId")
  1689. if articleId < 0 {
  1690. br.Msg = "参数错误"
  1691. br.ErrMsg = "参数错误"
  1692. return
  1693. }
  1694. resp := new(models.MinutesSummaryLetailRespV4)
  1695. //判断用户权限
  1696. hasPermission, err := services.GetUserhasPermission(user)
  1697. if err != nil {
  1698. br.Msg = "获取信息失败"
  1699. br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
  1700. }
  1701. detail, err := models.GetCygxMinutesSummaryInfoById(articleId)
  1702. if err != nil {
  1703. br.Msg = "获取信息失败"
  1704. br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId:" + strconv.Itoa(articleId)
  1705. return
  1706. }
  1707. //未设置全部可见的只能给弘则内部查看
  1708. if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
  1709. resp.IsShow = true
  1710. }
  1711. resp.HasPermission = hasPermission
  1712. if hasPermission != 1 || !resp.IsShow {
  1713. br.Ret = 200
  1714. br.Success = true
  1715. br.Msg = "获取成功"
  1716. br.Data = resp
  1717. return
  1718. }
  1719. detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format(utils.FormatDate)
  1720. detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
  1721. listFirst, err := models.GetMinutesSummarylogListAllV4(articleId)
  1722. if err != nil {
  1723. br.Msg = "获取失败"
  1724. br.ErrMsg = "获取子类信息失败,Err:" + err.Error()
  1725. return
  1726. }
  1727. for k, v := range listFirst {
  1728. listSecond, err := models.GetMinutesSummarylogSonListSecond(articleId, v.Type)
  1729. if err != nil && err.Error() != utils.ErrNoRow() {
  1730. br.Msg = "获取信息失败"
  1731. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1732. return
  1733. }
  1734. for k2, v2 := range listSecond {
  1735. listThird, err := models.GetMinutesSummarylogListThird(articleId, v2.ChartPermissionId, v.Type)
  1736. if err != nil && err.Error() != utils.ErrNoRow() {
  1737. br.Msg = "获取信息失败"
  1738. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  1739. return
  1740. }
  1741. if len(listThird) > 0 {
  1742. for k3, v3 := range listThird {
  1743. if v3.VideoUrl != "" {
  1744. listThird[k3].IsHaveVideo = true
  1745. }
  1746. if v3.ReportLink == "0" {
  1747. listThird[k3].ReportLink = ""
  1748. }
  1749. }
  1750. listSecond[k2].List = listThird
  1751. }
  1752. }
  1753. if len(listSecond) > 0 {
  1754. listFirst[k].List = listSecond
  1755. }
  1756. //`description:"类型'SDBG深度报告片篇,’CYDYJY:产业调研纪要’,’SJDP事件点评,’BZCHJH:本周晨会精华’"`
  1757. if v.Type == "CYDYJY" {
  1758. listFirst[k].ListName = "产业调研纪要"
  1759. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/UPAdozy96z9ypzY04vi0Y3Ogqzji.png"
  1760. } else if v.Type == "SSGS" {
  1761. listFirst[k].ListName = "上市公司调研纪要篇"
  1762. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211101/ujHXB48I8ay9T0XoPRI7lorz7OkL.png"
  1763. } else if v.Type == "YANX" {
  1764. listFirst[k].ListName = "买方研选纪要"
  1765. listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211104/QbTGTNhD9MxYp24cJ7V5WpCN0oNl.png"
  1766. }
  1767. }
  1768. //go services.AddCygxReportHistoryRecord(user, articleId, "szjyhz")
  1769. resp.List = listFirst
  1770. resp.Detail = detail
  1771. br.Ret = 200
  1772. br.Success = true
  1773. br.Msg = "获取成功"
  1774. br.Data = resp
  1775. }
  1776. // @Title 记录用户浏览音频回放接口
  1777. // @Description 记录用户浏览音频回放接口
  1778. // @Param request body models.ArticleIdReq true "type json string"
  1779. // @Success Ret=200 操作成功
  1780. // @router /voiceHistory/add [post]
  1781. func (this *ReportController) ResearchSummaryVoiceHistoryAdd() {
  1782. br := new(models.BaseResponse).Init()
  1783. defer func() {
  1784. this.Data["json"] = br
  1785. this.ServeJSON()
  1786. }()
  1787. user := this.User
  1788. if user == nil {
  1789. br.Msg = "请登录"
  1790. br.ErrMsg = "请登录,用户信息为空"
  1791. br.Ret = 408
  1792. return
  1793. }
  1794. uid := user.UserId
  1795. var req models.ArticleIdReq
  1796. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1797. if err != nil {
  1798. br.Msg = "参数解析异常!"
  1799. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1800. return
  1801. }
  1802. articleId := req.ArticleId
  1803. playSeconds := req.PlaySeconds
  1804. reportType := req.ReportType
  1805. //本周研究汇总
  1806. if reportType == 2 {
  1807. articleInfo, errInfo := models.GetCygxResearchSummaryInfoById(articleId)
  1808. if articleInfo == nil {
  1809. br.Msg = "操作失败"
  1810. br.ErrMsg = "文章ID错误,不存在articleId:" + strconv.Itoa(articleId)
  1811. return
  1812. }
  1813. if errInfo != nil {
  1814. br.Msg = "操作失败"
  1815. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1816. return
  1817. }
  1818. var sellerName string
  1819. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  1820. if err != nil {
  1821. br.Msg = "报名失败!"
  1822. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  1823. return
  1824. }
  1825. item := models.CygxResearchSummaryVoiceHistory{
  1826. ArticleId: articleId,
  1827. UserId: uid,
  1828. CreateTime: time.Now(),
  1829. Mobile: user.Mobile,
  1830. Email: user.Email,
  1831. CompanyId: user.CompanyId,
  1832. CompanyName: user.CompanyName,
  1833. RealName: user.RealName,
  1834. SellerName: sellerName,
  1835. PlaySeconds: strconv.Itoa(req.PlaySeconds),
  1836. ModifyTime: time.Now(),
  1837. RegisterPlatform: utils.REGISTER_PLATFORM,
  1838. }
  1839. if playSeconds != 0 {
  1840. lastItem, err := models.GetLastCygxResearchSummaryVoiceHistory(articleId, user.UserId)
  1841. if err != nil {
  1842. br.Msg = "操作失败"
  1843. br.ErrMsg = "操作失败,GetLastCygxResearchSummaryVoiceHistory Err:" + err.Error()
  1844. return
  1845. }
  1846. err = models.UpdateLastCygxResearchSummaryVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
  1847. if err != nil {
  1848. br.Msg = "更新失败"
  1849. br.ErrMsg = "更新失败,UpdateLastCygxResearchSummaryVoiceHistory Err:" + err.Error()
  1850. return
  1851. }
  1852. } else {
  1853. err = models.AddCygxResearchSummaryVoiceHistory(&item)
  1854. if err != nil {
  1855. br.Msg = "操作失败"
  1856. br.ErrMsg = "操作失败,Err:" + err.Error()
  1857. return
  1858. }
  1859. err = models.UpdateResearchSummaryVoiceCounts(articleId)
  1860. if err != nil {
  1861. br.Msg = "更新失败"
  1862. br.ErrMsg = "更新失败,Err:" + err.Error()
  1863. return
  1864. }
  1865. }
  1866. } else if reportType == 3 {
  1867. articleInfo, errInfo := models.GetCygxMinutesSummaryInfoById(articleId)
  1868. if articleInfo == nil {
  1869. br.Msg = "操作失败"
  1870. br.ErrMsg = "文章ID错误,不存在articleId:" + strconv.Itoa(articleId)
  1871. return
  1872. }
  1873. if errInfo != nil {
  1874. br.Msg = "操作失败"
  1875. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1876. return
  1877. }
  1878. var sellerName string
  1879. sellerName, err = models.GetCompanySellerName(user.CompanyId)
  1880. if err != nil {
  1881. br.Msg = "报名失败!"
  1882. br.ErrMsg = "获取对应销售失败,Err:" + err.Error()
  1883. return
  1884. }
  1885. item := models.CygxMinutesSummaryVoiceHistory{
  1886. ArticleId: articleId,
  1887. UserId: uid,
  1888. CreateTime: time.Now(),
  1889. Mobile: user.Mobile,
  1890. Email: user.Email,
  1891. CompanyId: user.CompanyId,
  1892. CompanyName: user.CompanyName,
  1893. RealName: user.RealName,
  1894. SellerName: sellerName,
  1895. PlaySeconds: strconv.Itoa(req.PlaySeconds),
  1896. ModifyTime: time.Now(),
  1897. RegisterPlatform: utils.REGISTER_PLATFORM,
  1898. }
  1899. if playSeconds != 0 {
  1900. lastItem, err := models.GetLastCygxMinutesSummaryVoiceHistory(articleId, user.UserId)
  1901. if err != nil {
  1902. br.Msg = "操作失败"
  1903. br.ErrMsg = "操作失败,GetLastCygxSummaryVoiceHistory Err:" + err.Error()
  1904. return
  1905. }
  1906. err = models.UpdateLastCygxMinutesSummaryVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
  1907. if err != nil {
  1908. br.Msg = "更新失败"
  1909. br.ErrMsg = "更新失败,UpdateLastCygxSummaryVoiceHistory Err:" + err.Error()
  1910. return
  1911. }
  1912. } else {
  1913. err = models.AddCygxMinutesSummaryVoiceHistory(&item)
  1914. if err != nil {
  1915. br.Msg = "操作失败"
  1916. br.ErrMsg = "操作失败,Err:" + err.Error()
  1917. return
  1918. }
  1919. err = models.UpdateMinutesSummaryVoiceCounts(articleId)
  1920. if err != nil {
  1921. br.Msg = "更新失败"
  1922. br.ErrMsg = "更新失败,Err:" + err.Error()
  1923. return
  1924. }
  1925. }
  1926. }
  1927. br.Ret = 200
  1928. br.Success = true
  1929. br.Msg = "操作成功"
  1930. return
  1931. }
  1932. // @Title 根据行业分类获取行业文章列表
  1933. // @Description 根据行业分类获取行业文章列表接口
  1934. // @Param PageSize query int true "每页数据条数"
  1935. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1936. // @Param CategoryId query int true "分类ID"
  1937. // @Param IndustrialManagementId query int false "产业ID"
  1938. // @Success 200 {object} models.TacticsListResp
  1939. // @router /tactics/list [get]
  1940. func (this *MobileReportController) TacticsList() {
  1941. br := new(models.BaseResponse).Init()
  1942. defer func() {
  1943. this.Data["json"] = br
  1944. this.ServeJSON()
  1945. }()
  1946. user := this.User
  1947. if user == nil {
  1948. br.Msg = "请重新登录"
  1949. br.Ret = 408
  1950. return
  1951. }
  1952. //uid := user.UserId
  1953. pageSize, _ := this.GetInt("PageSize")
  1954. currentIndex, _ := this.GetInt("CurrentIndex")
  1955. categoryId, _ := this.GetInt("CategoryId")
  1956. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  1957. var startSize int
  1958. if pageSize <= 0 {
  1959. pageSize = utils.PageSize20
  1960. }
  1961. if currentIndex <= 0 {
  1962. currentIndex = 1
  1963. }
  1964. startSize = paging.StartIndex(currentIndex, pageSize)
  1965. //var condition string
  1966. //var pars []interface{}
  1967. var total int
  1968. var err error
  1969. resp := new(models.TacticsListResp)
  1970. page := paging.GetPaging(currentIndex, pageSize, total)
  1971. list := make([]*models.ArticleListResp, 0)
  1972. if categoryId == utils.TIME_CATEGORYID {
  1973. list, total, err = models.GetTimeLineReportIndustrialList(industrialManagementId, startSize, pageSize)
  1974. if err != nil {
  1975. br.Msg = "获取信息失败"
  1976. br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
  1977. return
  1978. }
  1979. } else {
  1980. if categoryId == utils.ACTEGORY_ID_AI_QY {
  1981. listArticle := make([]*models.HomeArticle, 0)
  1982. listArticle, total, err = services.GetAiQianYanArtilceList(0, pageSize)
  1983. if err != nil {
  1984. br.Msg = "获取信息失败"
  1985. br.Msg = "GetAiQianYanArtilceList,Err:" + err.Error()
  1986. return
  1987. }
  1988. for _, v := range listArticle {
  1989. list = append(list, &models.ArticleListResp{
  1990. ArticleId: v.ArticleId,
  1991. Title: v.Title,
  1992. CategoryId: v.CategoryId,
  1993. Annotation: v.Annotation,
  1994. Abstract: v.Abstract,
  1995. Body: v.Body,
  1996. PublishDate: v.PublishDate,
  1997. Resource: v.Resource,
  1998. })
  1999. }
  2000. } else {
  2001. list, total, err = models.GetReportAndproductIndustrylListimg(categoryId, user.UserId, startSize, pageSize)
  2002. if err != nil {
  2003. br.Msg = "获取信息失败"
  2004. br.Msg = "GetHomeList,Err:" + err.Error()
  2005. return
  2006. }
  2007. }
  2008. articleIdMap, err := services.GetUserArticleHistoryRecord(user)
  2009. if err != nil {
  2010. br.Msg = "获取信息失败"
  2011. br.Msg = "获取帖子数据失败,Err:" + err.Error()
  2012. return
  2013. }
  2014. for k, v := range list {
  2015. //list[k].ImgUrlPc = mapCategoryUrl[v.CategoryId]
  2016. if !articleIdMap[v.ArticleId] && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
  2017. list[k].IsRed = true
  2018. }
  2019. }
  2020. if categoryId > 0 {
  2021. detail, errCategory := models.GetCygxReportMappingCygxByCategoryId(categoryId)
  2022. if errCategory != nil {
  2023. br.Msg = "获取信息失败"
  2024. br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在:" + strconv.Itoa(categoryId)
  2025. return
  2026. }
  2027. resp.MatchTypeName = detail.MatchTypeName
  2028. }
  2029. //resp.CategoryImgUrlPc = mapChartPermission[detail.ChartPermissionName]
  2030. }
  2031. listPublic, err := services.HandleArticleCategoryImg(list, user)
  2032. if err != nil {
  2033. br.Msg = "获取失败"
  2034. br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
  2035. return
  2036. }
  2037. listResp := make([]*models.HomeArticle, 0)
  2038. for _, v := range listPublic {
  2039. listResp = append(listResp, &models.HomeArticle{
  2040. ArticleId: v.ArticleId,
  2041. Title: v.Title,
  2042. Annotation: "核心观点:" + v.Annotation,
  2043. Abstract: v.Abstract,
  2044. ImgUrlPc: v.ImgUrlPc,
  2045. PublishDate: v.PublishDate,
  2046. Resource: v.Resource,
  2047. })
  2048. }
  2049. if len(listResp) == 0 {
  2050. listResp = make([]*models.HomeArticle, 0)
  2051. }
  2052. page = paging.GetPaging(currentIndex, pageSize, total)
  2053. resp.List = listResp
  2054. resp.Paging = page
  2055. br.Ret = 200
  2056. br.Success = true
  2057. br.Msg = "获取成功"
  2058. br.Data = resp
  2059. }