home.go 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hongze_cygx/models"
  6. "hongze/hongze_cygx/services"
  7. "hongze/hongze_cygx/utils"
  8. "html"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. type HomeController struct {
  14. BaseAuthController
  15. }
  16. type BaseHomeController struct {
  17. BaseCommonController
  18. }
  19. // @Title 首页列表接口
  20. // @Description 首页列表接口
  21. // @Param PageSize query int true "每页数据条数"
  22. // @Param CurrentIndex query int true "当前页页码,从1开始"
  23. // @Param ChartPermissionId query int true "品类id,最新传0"
  24. // @Success 200 {object} models.HomeListResp
  25. // @router /list [get]
  26. func (this *HomeController) ListHome() {
  27. br := new(models.BaseResponse).Init()
  28. defer func() {
  29. this.Data["json"] = br
  30. this.ServeJSON()
  31. }()
  32. user := this.User
  33. if user == nil {
  34. br.Msg = "请登录"
  35. br.ErrMsg = "请登录,用户信息为空"
  36. br.Ret = 408
  37. return
  38. }
  39. pageSize, _ := this.GetInt("PageSize")
  40. currentIndex, _ := this.GetInt("CurrentIndex")
  41. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  42. var startSize int
  43. if pageSize <= 0 {
  44. pageSize = utils.PageSize20
  45. }
  46. if currentIndex <= 0 {
  47. currentIndex = 1
  48. }
  49. startSize = paging.StartIndex(currentIndex, pageSize)
  50. var condition string
  51. var pars []interface{}
  52. var total int
  53. resp := new(models.HomeListResp)
  54. page := paging.GetPaging(currentIndex, pageSize, total)
  55. resp.HaveResearch = true
  56. userType, _, err := services.GetUserType(user.CompanyId)
  57. if err != nil {
  58. br.Msg = "获取信息失败"
  59. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  60. return
  61. }
  62. condition += ` AND is_summary = 1 `
  63. if chartPermissionId > 0 {
  64. categoryId, err := models.GetCategoryId(chartPermissionId)
  65. if err != nil && err.Error() != utils.ErrNoRow() {
  66. br.Msg = "获取信息失败"
  67. br.ErrMsg = "获取分类权限信息失败,Err:" + err.Error()
  68. return
  69. }
  70. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  71. if err != nil {
  72. br.Msg = "获取信息失败"
  73. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  74. return
  75. }
  76. if userType == 1 && categoryinfo.PermissionName == "研选" {
  77. resp.HaveResearch = false
  78. resp.Paging = page
  79. br.Ret = 200
  80. br.Success = true
  81. br.Msg = "获取成功"
  82. br.Data = resp
  83. return
  84. }
  85. page = paging.GetPaging(currentIndex, pageSize, total)
  86. //if categoryId != "" {
  87. // condition += ` AND category_id IN(` + categoryId + `)`
  88. // condition += ` OR ( category_name LIKE '%研选%' AND publish_status = 1 AND is_summary = 1 )`
  89. //} else {
  90. // condition += ` AND category_name LIKE '%研选%' `
  91. //}
  92. if categoryId != "" {
  93. condition += ` AND category_id IN(` + categoryId + `)`
  94. //condition += ` OR ( category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%' AND publish_status = 1 AND is_summary = 1 )`
  95. } else {
  96. condition += ` AND category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%'`
  97. }
  98. }
  99. //永续客户无法查看研选分类的内容
  100. if userType == 1 {
  101. condition += ` AND category_name NOT LIKE '%研选` + `%'`
  102. }
  103. total, err = models.GetHomeCount(condition, pars)
  104. if err != nil {
  105. br.Msg = "获取信息失败"
  106. br.Msg = "获取帖子总数失败,Err:" + err.Error()
  107. return
  108. }
  109. page = paging.GetPaging(currentIndex, pageSize, total)
  110. list, err := models.GetHomeList(condition, pars, startSize, pageSize)
  111. if err != nil {
  112. br.Msg = "获取信息失败"
  113. br.Msg = "获取帖子数据失败,Err:" + err.Error()
  114. return
  115. }
  116. //研选的五张图片
  117. detailResearch, err := models.GetConfigByCode("category_research_img_url")
  118. if err != nil {
  119. br.Msg = "获取数据失败"
  120. br.ErrMsg = "获取数据研选分类图片失败,Err:" + err.Error()
  121. return
  122. }
  123. researchList := strings.Split(detailResearch.ConfigValue, "{|}")
  124. //对应分类的所图片
  125. detailCategoryUrl, err := models.GetConfigByCode("category_map_img_url")
  126. if err != nil {
  127. br.Msg = "获取数据失败"
  128. br.ErrMsg = "行业配置信息失败,Err:" + err.Error()
  129. return
  130. }
  131. categoryUrlList := strings.Split(detailCategoryUrl.ConfigValue, "{|}")
  132. mapCategoryUrl := make(map[string]string)
  133. var categoryId string
  134. var imgUrlChart string
  135. for _, v := range categoryUrlList {
  136. vslice := strings.Split(v, "_")
  137. categoryId = vslice[0]
  138. imgUrlChart = vslice[len(vslice)-1]
  139. mapCategoryUrl[categoryId] = imgUrlChart
  140. }
  141. for k, v := range list {
  142. item := list[k]
  143. //如果文章一开始的内容是图片,优先展示第一张图片
  144. imgurl, _ := services.FixArticleImgUrl(html.UnescapeString(list[k].Body))
  145. newBody, _ := services.GetReportContentTextSub(item.Body)
  146. list[k].Body = newBody
  147. if imgurl != "" {
  148. list[k].BodyHtml = imgurl
  149. }
  150. list[k].PublishDate = utils.StrTimeToTime(item.PublishDate).Format(utils.FormatDateTimeNoSecond) //时间字符串格式转时间格式
  151. if strings.Contains(item.CategoryName, "研选") {
  152. list[k].IsResearch = true
  153. }
  154. if item.Pv > 999 {
  155. list[k].Pv = 999
  156. }
  157. //如果是研选系列的任意取五张图片的中的一张
  158. if v.CategoryId == "0" {
  159. knum := v.ArticleId % 5
  160. list[k].ImgUrlPc = researchList[knum]
  161. } else {
  162. list[k].ImgUrlPc = mapCategoryUrl[v.CategoryId]
  163. }
  164. if list[k].ArticleId < utils.SummaryArticleId {
  165. list[k].HttpUrl = utils.StrategyPlatform + strconv.Itoa(v.ArticleId)
  166. list[k].IsNeedJump = true
  167. }
  168. }
  169. resp.List = list
  170. resp.Paging = page
  171. br.Ret = 200
  172. br.Success = true
  173. br.Msg = "获取成功"
  174. br.Data = resp
  175. }
  176. // @Title 首页列表接口(无需token)
  177. // @Description 首页列表接口(无需token)
  178. // @Param PageSize query int true "每页数据条数"
  179. // @Param CurrentIndex query int true "当前页页码,从1开始"
  180. // @Param ChartPermissionId query int true "品类id,最新传0"
  181. // @Param CompanyCode query string false "机构编号"
  182. // @Param CompanyName query string false "机构名称"
  183. // @Param Email query string false "邮箱"
  184. // @Param Sign query string false "加密签名"
  185. // @Success 200 {object} models.HomeListResp
  186. // @router /listPublic [get]
  187. func (this *BaseHomeController) ListHomePublic() {
  188. br := new(models.BaseResponse).Init()
  189. defer func() {
  190. this.Data["json"] = br
  191. this.ServeJSON()
  192. }()
  193. companyCode := this.GetString("CompanyCode")
  194. companyName := this.GetString("CompanyName")
  195. email := this.GetString("Email")
  196. sign := this.GetString("Sign")
  197. var userType int
  198. var err error
  199. if companyCode != "" && companyName != "" && email != "" {
  200. errMsg, errHt, wxUser, _ := services.CheckHtgj(companyCode, companyName, email, sign)
  201. if errHt != nil {
  202. br.Msg = "获取"
  203. br.ErrMsg = "获取数据失败,Err:" + errHt.Error()
  204. return
  205. }
  206. if errMsg == "机构下账号个数已达上限" {
  207. goto Loop
  208. }
  209. if errMsg != "" {
  210. br.Msg = errMsg
  211. return
  212. }
  213. user := wxUser
  214. if user == nil {
  215. br.Msg = "请登录"
  216. br.ErrMsg = "请登录,用户信息为空"
  217. br.Ret = 408
  218. return
  219. }
  220. userType, _, err = services.GetUserType(user.CompanyId)
  221. if err != nil {
  222. br.Msg = "获取信息失败"
  223. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  224. return
  225. }
  226. }
  227. Loop:
  228. pageSize, _ := this.GetInt("PageSize")
  229. currentIndex, _ := this.GetInt("CurrentIndex")
  230. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  231. var startSize int
  232. if pageSize <= 0 {
  233. pageSize = utils.PageSize20
  234. }
  235. if currentIndex <= 0 {
  236. currentIndex = 1
  237. }
  238. startSize = paging.StartIndex(currentIndex, pageSize)
  239. var condition string
  240. var pars []interface{}
  241. var total int
  242. resp := new(models.HomeListResp)
  243. page := paging.GetPaging(currentIndex, pageSize, total)
  244. resp.HaveResearch = true
  245. condition += ` AND is_summary = 1 `
  246. if chartPermissionId > 0 {
  247. categoryId, err := models.GetCategoryId(chartPermissionId)
  248. if err != nil && err.Error() != utils.ErrNoRow() {
  249. br.Msg = "获取信息失败"
  250. br.ErrMsg = "获取分类权限信息失败,Err:" + err.Error()
  251. return
  252. }
  253. categoryinfo, err := models.GetChartPermissionById(chartPermissionId)
  254. if err != nil {
  255. br.Msg = "获取信息失败"
  256. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  257. return
  258. }
  259. if userType == 1 && strings.Contains(categoryinfo.PermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  260. resp.HaveResearch = false
  261. resp.Paging = page
  262. br.Ret = 200
  263. br.Success = true
  264. br.Msg = "获取成功"
  265. br.Data = resp
  266. return
  267. }
  268. page = paging.GetPaging(currentIndex, pageSize, total)
  269. if categoryId != "" {
  270. condition += ` AND category_id IN(` + categoryId + `)`
  271. //condition += ` OR ( category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%' AND publish_status = 1 AND is_summary = 1 )`
  272. } else {
  273. condition += ` AND category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%'`
  274. }
  275. }
  276. //永续客户无法查看研选分类的内容
  277. if userType == 1 {
  278. condition += ` AND category_name NOT LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%'`
  279. }
  280. total, err = models.GetHomeCount(condition, pars)
  281. if err != nil {
  282. br.Msg = "获取信息失败"
  283. br.Msg = "获取帖子总数失败,Err:" + err.Error()
  284. return
  285. }
  286. page = paging.GetPaging(currentIndex, pageSize, total)
  287. list, err := models.GetHomeList(condition, pars, startSize, pageSize)
  288. if err != nil {
  289. br.Msg = "获取信息失败"
  290. br.Msg = "获取帖子数据失败,Err:" + err.Error()
  291. return
  292. }
  293. list, err = services.HandleArticleCategoryImg(list)
  294. if err != nil {
  295. br.Msg = "获取信息失败"
  296. br.Msg = "图片预处理失败,HandleArticleCategoryImg,Err:" + err.Error()
  297. return
  298. }
  299. for _, v := range list {
  300. v.Annotation, _ = services.GetReportContentTextSub(v.Annotation)
  301. v.Body = v.Annotation
  302. }
  303. resp.List = list
  304. resp.Paging = page
  305. br.Ret = 200
  306. br.Success = true
  307. br.Msg = "获取成功"
  308. br.Data = resp
  309. }
  310. // @Title 首页/搜索头部导航接口
  311. // @Description 首页/搜索头部导航接口
  312. // @Param SearchPage query int false "是否为搜索页面"
  313. // @Success 200 {object} models.HomeListResp
  314. // @router /header_tab [get]
  315. func (this *HomeController) HeaderTab() {
  316. br := new(models.BaseResponse).Init()
  317. defer func() {
  318. this.Data["json"] = br
  319. this.ServeJSON()
  320. }()
  321. user := this.User
  322. if user == nil {
  323. br.Msg = "请登录"
  324. br.ErrMsg = "请登录,用户信息为空"
  325. br.Ret = 408
  326. return
  327. }
  328. searchPage, _ := this.GetInt("SearchPage")
  329. key := models.HomeHeaderTabConfigKey
  330. conf, e := models.GetConfigByCode(key)
  331. if e != nil {
  332. br.Msg = "获取失败"
  333. br.ErrMsg = "获取首页头部导航失败, Err: " + e.Error()
  334. return
  335. }
  336. if conf.ConfigValue == "" {
  337. br.Msg = "获取失败"
  338. br.ErrMsg = "首页头部导航配置值有误"
  339. return
  340. }
  341. list := new(models.HomeHeaderTabList)
  342. if e = json.Unmarshal([]byte(conf.ConfigValue), &list); e != nil {
  343. br.Msg = "获取失败"
  344. br.ErrMsg = "首页头部导航配置值解析失败, Err: " + e.Error()
  345. return
  346. }
  347. resp := list.Home
  348. if searchPage == 1 {
  349. resp = list.SearchPage
  350. }
  351. br.Ret = 200
  352. br.Success = true
  353. br.Msg = "获取成功"
  354. br.Data = resp
  355. }
  356. // @Title 首页列表接口v7.6版本
  357. // @Description 首页列表接口v7.6版本
  358. // @Param PageSize query int true "每页数据条数"
  359. // @Param CurrentIndex query int true "当前页页码,从1开始"
  360. // @Param ChartPermissionId query int true "品类id,最新传0"
  361. // @Param CtagId query int true "图表子类ID"
  362. // @Param ListType query int true "列表类型,1最新,2 纪要 ,3图表 默认1"
  363. // @Success 200 {object} models.HomeArtAndChartListResp
  364. // @router /artAndChart/list [get]
  365. func (this *HomeController) ListHomeArtAndChart() {
  366. br := new(models.BaseResponse).Init()
  367. defer func() {
  368. this.Data["json"] = br
  369. this.ServeJSON()
  370. }()
  371. user := this.User
  372. if user == nil {
  373. br.Msg = "请登录"
  374. br.ErrMsg = "请登录,用户信息为空"
  375. br.Ret = 408
  376. return
  377. }
  378. pageSize, _ := this.GetInt("PageSize")
  379. currentIndex, _ := this.GetInt("CurrentIndex")
  380. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  381. ctagId, _ := this.GetInt("CtagId")
  382. listType, _ := this.GetInt("ListType")
  383. var startSize int
  384. if pageSize <= 0 {
  385. pageSize = utils.PageSize20
  386. }
  387. if currentIndex <= 0 {
  388. currentIndex = 1
  389. }
  390. if listType <= 0 {
  391. listType = 1
  392. }
  393. startSize = paging.StartIndex(currentIndex, pageSize)
  394. var condition string
  395. var pars []interface{}
  396. var total, chartTotal int
  397. resp := new(models.HomeArtAndChartListResp)
  398. page := paging.GetPaging(currentIndex, pageSize, total)
  399. resp.HaveResearch = true
  400. var chartList []*models.HomeChartListResp
  401. var err error
  402. // 最新
  403. if listType == 1 {
  404. if currentIndex <= 2 {
  405. listCtagId := [10]int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
  406. var chartIds string
  407. for _, v := range listCtagId {
  408. chartListTwo, err := models.GetChartList(`AND ctag_id = `+strconv.Itoa(v), pars, 0, 2)
  409. if err != nil {
  410. br.Msg = "获取信息失败"
  411. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  412. return
  413. }
  414. for _, vChart := range chartListTwo {
  415. chartIds += strconv.Itoa(vChart.ChartId) + ","
  416. }
  417. }
  418. chartIds = strings.TrimRight(chartIds, ",")
  419. condition += ` AND chart_id IN (` + chartIds + `) `
  420. chartList, err = models.GetChartList(condition, pars, startSize, pageSize)
  421. if err != nil {
  422. br.Msg = "获取信息失败"
  423. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  424. return
  425. }
  426. }
  427. }
  428. // 图表
  429. if listType == 3 {
  430. if chartPermissionId > 0 {
  431. condition += ` AND a.ptag_id =? `
  432. pars = append(pars, chartPermissionId)
  433. }
  434. if ctagId > 0 {
  435. condition += ` AND a.ctag_id =? `
  436. pars = append(pars, ctagId)
  437. }
  438. chartList, err = models.GetChartList(condition, pars, startSize, pageSize)
  439. if err != nil {
  440. br.Msg = "获取信息失败"
  441. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  442. return
  443. }
  444. chartTotal, err = models.GetChartCount(condition, pars)
  445. if err != nil {
  446. br.Msg = "获取信息失败"
  447. br.Msg = "获取帖子总数失败,Err:" + err.Error()
  448. return
  449. }
  450. }
  451. for k, v := range chartList {
  452. if v.PtagName != "" {
  453. chartList[k].CtagNamePc = v.PtagName
  454. }
  455. if v.CtagName != "" {
  456. chartList[k].CtagNamePc += "," + v.CtagName
  457. }
  458. if v.PtagNameTwo != "" {
  459. chartList[k].CtagNamePc += "," + v.PtagNameTwo
  460. }
  461. if v.CtagNameTwo != "" {
  462. chartList[k].CtagNamePc += "," + v.CtagNameTwo
  463. }
  464. chartList[k].IsNeedJump = true
  465. chartList[k].Source = 2
  466. }
  467. resp.ChartList = chartList
  468. // 最新/纪要
  469. if listType != 3 {
  470. userType, _, err := services.GetUserType(user.CompanyId)
  471. if err != nil {
  472. br.Msg = "获取信息失败"
  473. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  474. return
  475. }
  476. condition = ` AND is_summary = 1 `
  477. if chartPermissionId > 0 {
  478. categoryId, err := models.GetCategoryId(chartPermissionId)
  479. if err != nil && err.Error() != utils.ErrNoRow() {
  480. br.Msg = "获取信息失败"
  481. br.ErrMsg = "获取分类权限信息失败,Err:" + err.Error()
  482. return
  483. }
  484. categoryInfo, err := models.GetChartPermissionById(chartPermissionId)
  485. if err != nil {
  486. br.Msg = "获取信息失败"
  487. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  488. return
  489. }
  490. if userType == 1 && strings.Contains(categoryInfo.PermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  491. resp.HaveResearch = false
  492. resp.Paging = page
  493. br.Ret = 200
  494. br.Success = true
  495. br.Msg = "获取成功"
  496. br.Data = resp
  497. return
  498. }
  499. page = paging.GetPaging(currentIndex, pageSize, total)
  500. if categoryId != "" {
  501. condition += ` AND category_id IN(` + categoryId + `)`
  502. //condition += ` OR ( category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%' AND publish_status = 1 AND is_summary = 1 )`
  503. } else {
  504. condition += ` AND category_name LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%'`
  505. }
  506. }
  507. //永续客户无法查看研选分类的内容
  508. if userType == 1 {
  509. condition += ` AND category_name NOT LIKE '%` + utils.CHART_PERMISSION_NAME_YANXUAN + `%'`
  510. }
  511. list := make([]*models.HomeArticle, 0)
  512. // 7.6-与音频作联合查询, 整体进行发布时间的排序(代码写的嘎嘎烂, 将就着用吧=_=!)
  513. if listType == 1 {
  514. var unionPars []interface{}
  515. unionList, unionTotal, e := services.GetHomeNewestList(user.UserId, user.CompanyId, startSize, pageSize, condition, unionPars)
  516. if e != nil {
  517. br.Msg = "获取信息失败"
  518. br.Msg = "获取纪要音频联合列表失败, Err: " + e.Error()
  519. return
  520. }
  521. total = unionTotal
  522. list = unionList
  523. } else {
  524. total, err = models.GetHomeCount(condition, pars)
  525. if err != nil {
  526. br.Msg = "获取信息失败"
  527. br.Msg = "获取帖子总数失败,Err:" + err.Error()
  528. return
  529. }
  530. homeList, err := models.GetHomeList(condition, pars, startSize, pageSize)
  531. if err != nil {
  532. br.Msg = "获取信息失败"
  533. br.Msg = "获取帖子数据失败,Err:" + err.Error()
  534. return
  535. }
  536. list = homeList
  537. }
  538. resp.List, err = services.HandleArticleCategoryImg(list)
  539. if err != nil {
  540. br.Msg = "获取信息失败"
  541. br.Msg = "处理封面图片失败,HandleArticleCategoryImg,Err:" + err.Error()
  542. return
  543. }
  544. resp.List = list
  545. }
  546. if chartTotal > total {
  547. total = chartTotal
  548. }
  549. page = paging.GetPaging(currentIndex, pageSize, total)
  550. resp.Paging = page
  551. br.Ret = 200
  552. br.Success = true
  553. br.Msg = "获取成功"
  554. br.Data = resp
  555. }
  556. // @Title 首页列表接口
  557. // @Description 首页列表接口
  558. // @Param TagIds query string true "标签选择"
  559. // @Param ChartPermissionId query int false "行业id"
  560. // @Param PageSize query int true "每页数据条数"
  561. // @Param CurrentIndex query int true "当前页页码,从1开始"
  562. // @Success 200 {object} models.HomeArtAndChartListResp
  563. // @router /new [get]
  564. func (this *HomeController) NewList() {
  565. br := new(models.BaseResponse).Init()
  566. defer func() {
  567. this.Data["json"] = br
  568. this.ServeJSON()
  569. }()
  570. user := this.User
  571. if user == nil {
  572. br.Msg = "请登录"
  573. br.ErrMsg = "请登录,用户信息为空"
  574. br.Ret = 408
  575. return
  576. }
  577. pageSize, _ := this.GetInt("PageSize")
  578. currentIndex, _ := this.GetInt("CurrentIndex")
  579. tagIds := this.GetString("TagIds")
  580. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  581. var startSize int
  582. if pageSize <= 0 {
  583. pageSize = utils.PageSize20
  584. }
  585. if currentIndex <= 0 {
  586. currentIndex = 1
  587. }
  588. startSize = paging.StartIndex(currentIndex, pageSize)
  589. var condition string
  590. var conditionInit string
  591. var pars []interface{}
  592. //var total int
  593. resp := new(models.HomeResourceDataListResp)
  594. totalRai, err := models.GetCountCompanyProductCompanyId(user.CompanyId, utils.COMPANY_PRODUCT_RAI_ID)
  595. if err != nil && err.Error() != utils.ErrNoRow() {
  596. br.Msg = "获取失败"
  597. br.ErrMsg = "GetCountCompanyProductCompanyId,Err:" + err.Error()
  598. return
  599. }
  600. //var articleTypes, activityTypes, industries, subjectNames string
  601. //articleTypeCondSlice := make([]string, 0)
  602. //activityTypesCondSlice := make([]string, 0)
  603. //industriesCondSlice := make([]string, 0)
  604. //subjectNamesSlice := make([]string, 0)
  605. //articleTypeSlice := make([]string, 0)
  606. //if tagIds != "" {
  607. // tags := strings.Split(tagIds, ",")
  608. // for _, tagIdStr := range tags {
  609. // tagId, err := strconv.Atoi(tagIdStr)
  610. // if err != nil {
  611. // br.Msg = "转换失败"
  612. // br.ErrMsg = "tagid转换失败,Err:" + err.Error()
  613. // return
  614. // }
  615. // tagInfo, err := models.GetCygxTagByTagId(tagId)
  616. // if err != nil && err.Error() != utils.ErrNoRow() {
  617. // br.Msg = "获取失败"
  618. // br.ErrMsg = "GetCygxTagByTagId,Err:" + err.Error()
  619. // return
  620. // }
  621. // // 只有AB或CD的情况
  622. // if (tagInfo.ActivityTypes == "" && tagInfo.ArticleTypes == "") || (tagInfo.Industries == "" && tagInfo.SubjectNames == "") {
  623. // if tagInfo.ActivityTypes != "" {
  624. // activityTypes += tagInfo.ActivityTypes + ","
  625. // }
  626. // if tagInfo.ArticleTypes != "" {
  627. // articleTypes += tagInfo.ArticleTypes + ","
  628. // }
  629. // if tagInfo.Industries != "" {
  630. // industries += tagInfo.Industries + ","
  631. // }
  632. // if tagInfo.SubjectNames != "" {
  633. // subjectNames += tagInfo.SubjectNames + ","
  634. // }
  635. // } else {
  636. // // ABCD都有的情况
  637. // // 每一个tag都单独处理
  638. // var articleType, activityType, industry, subjectName string
  639. //
  640. // if tagInfo.ActivityTypes != "" {
  641. // activityType = tagInfo.ActivityTypes
  642. // }
  643. // if tagInfo.ArticleTypes != "" {
  644. // articleType = tagInfo.ArticleTypes
  645. // }
  646. // if tagInfo.Industries != "" {
  647. // industry = tagInfo.Industries
  648. // }
  649. // if tagInfo.SubjectNames != "" {
  650. // subjectName = tagInfo.SubjectNames
  651. // }
  652. // articleTypeCond := ``
  653. // var articleTypeStr string
  654. // if articleType != "" {
  655. // articleTypeSlice := strings.Split(articleType, ",")
  656. // newArticleTypeSlice := make([]string, 0)
  657. // for _, s := range articleTypeSlice {
  658. // newArticleTypeSlice = append(newArticleTypeSlice, "'"+s+"'")
  659. // }
  660. // articleTypeStr = strings.Join(newArticleTypeSlice, ",")
  661. // articleTypeStr = strings.TrimRight(articleTypeStr, ",")
  662. // articleTypeCond += ` AND (art.sub_category_name In (` + articleTypeStr + `) OR (art.article_type_name In (` + articleTypeStr + `) AND art.article_type_name <> '路演精华' AND art.article_type_id <> 0 ) ) `
  663. // }
  664. // activityTypesCond := ``
  665. // if activityType != "" {
  666. // activityTypeSlice := strings.Split(activityType, ",")
  667. // newActivityTypeSlice := make([]string, 0)
  668. // for _, s := range activityTypeSlice {
  669. // newActivityTypeSlice = append(newActivityTypeSlice, "'"+s+"'")
  670. // }
  671. // activityTypeStr := strings.Join(newActivityTypeSlice, ",")
  672. // activityTypeStr = strings.TrimRight(activityTypeStr, ",")
  673. // activityTypesCond += ` AND act.activity_type_name In (` + activityTypeStr + `) `
  674. // }
  675. // industriesCond := ``
  676. // var industryStr string
  677. // if industry != "" {
  678. // industrieSlice := strings.Split(industry, ",")
  679. // newIndustrieSlice := make([]string, 0)
  680. // for _, s := range industrieSlice {
  681. // newIndustrieSlice = append(newIndustrieSlice, "'"+s+"'")
  682. // }
  683. // industryStr = strings.Join(newIndustrieSlice, ",")
  684. // industryStr = strings.TrimRight(industryStr, ",")
  685. // industriesCond += ` AND im.industry_name In (` + industryStr + `) `
  686. // }
  687. // subjectNamesCond := ``
  688. // var subjectNameStr string
  689. // if subjectName != "" {
  690. // subjectNameSlice := strings.Split(subjectName, ",")
  691. // newSubjectNameSlice := make([]string, 0)
  692. // for _, s := range subjectNameSlice {
  693. // newSubjectNameSlice = append(newSubjectNameSlice, "'"+s+"'")
  694. // }
  695. // subjectNameStr = strings.Join(newSubjectNameSlice, ",")
  696. // subjectNameStr = strings.TrimRight(subjectNameStr, ",")
  697. // subjectNamesCond += ` AND cis.subject_name In (` + subjectNameStr + `) `
  698. // }
  699. // articleTypeCondSlice = append(articleTypeCondSlice, articleTypeCond)
  700. // activityTypesCondSlice = append(activityTypesCondSlice, activityTypesCond)
  701. // industriesCondSlice = append(industriesCondSlice, industryStr)
  702. // subjectNamesSlice = append(subjectNamesSlice, subjectNameStr)
  703. // articleTypeSlice = append(articleTypeSlice, articleType)
  704. // }
  705. //
  706. // }
  707. //}
  708. //
  709. //// 先拿abdc都有的tag取合集的ids。。。
  710. //soloTagArticleIds, soloTagActivityIds, soloMmIds, err := models.GetCygxCygxArticleListByConditionSoloTag(articleTypeCondSlice, activityTypesCondSlice, industriesCondSlice, subjectNamesSlice, articleTypeSlice)
  711. //if err != nil && err.Error() != utils.ErrNoRow() {
  712. // br.Msg = "获取失败"
  713. // br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  714. // return
  715. //}
  716. //
  717. //articleTypes = strings.TrimRight(articleTypes, ",")
  718. //activityTypes = strings.TrimRight(activityTypes, ",")
  719. //industries = strings.TrimRight(industries, ",")
  720. //subjectNames = strings.TrimRight(subjectNames, ",")
  721. //
  722. //articleTypesCond := ``
  723. //var articleTypeStr string
  724. //if articleTypes != "" {
  725. // articleTypeSlice := strings.Split(articleTypes, ",")
  726. // newArticleTypeSlice := make([]string, 0)
  727. // for _, s := range articleTypeSlice {
  728. // newArticleTypeSlice = append(newArticleTypeSlice, "'"+s+"'")
  729. // }
  730. // articleTypeStr = strings.Join(newArticleTypeSlice, ",")
  731. // articleTypeStr = strings.TrimRight(articleTypeStr, ",")
  732. // articleTypesCond += ` AND (art.sub_category_name In (` + articleTypeStr + `) OR (art.article_type_name In (` + articleTypeStr + `) AND art.article_type_name <> '路演精华' AND art.article_type_id <> 0 ) ) `
  733. //}
  734. //activityTypesCond := ``
  735. //if activityTypes != "" {
  736. // activityTypeSlice := strings.Split(activityTypes, ",")
  737. // newActivityTypeSlice := make([]string, 0)
  738. // for _, s := range activityTypeSlice {
  739. // newActivityTypeSlice = append(newActivityTypeSlice, "'"+s+"'")
  740. // }
  741. // activityTypeStr := strings.Join(newActivityTypeSlice, ",")
  742. // activityTypeStr = strings.TrimRight(activityTypeStr, ",")
  743. // activityTypesCond += ` AND act.activity_type_name In (` + activityTypeStr + `) `
  744. //}
  745. //industriesCond := ``
  746. //var industryStr string
  747. //if industries != "" {
  748. // industrieSlice := strings.Split(industries, ",")
  749. // newIndustrieSlice := make([]string, 0)
  750. // for _, s := range industrieSlice {
  751. // newIndustrieSlice = append(newIndustrieSlice, "'"+s+"'")
  752. // }
  753. // industryStr = strings.Join(newIndustrieSlice, ",")
  754. // industryStr = strings.TrimRight(industryStr, ",")
  755. // industriesCond += ` AND im.industry_name In (` + industryStr + `) `
  756. //}
  757. //subjectNamesCond := ``
  758. //var subjectNameStr string
  759. //if subjectNames != "" {
  760. // subjectNameSlice := strings.Split(subjectNames, ",")
  761. // newSubjectNameSlice := make([]string, 0)
  762. // for _, s := range subjectNameSlice {
  763. // newSubjectNameSlice = append(newSubjectNameSlice, "'"+s+"'")
  764. // }
  765. // subjectNameStr = strings.Join(newSubjectNameSlice, ",")
  766. // subjectNameStr = strings.TrimRight(subjectNameStr, ",")
  767. // subjectNamesCond += ` AND cis.subject_name In (` + subjectNameStr + `) `
  768. //}
  769. //
  770. //var tagArticleIds, tagActivityIds, mmIds string
  771. //if articleTypesCond != "" || activityTypesCond != "" || industryStr != "" || subjectNameStr != "" {
  772. // tagArticleIds, tagActivityIds, mmIds, err = models.GetCygxCygxArticleListByCondition(articleTypesCond, activityTypesCond, industryStr, subjectNameStr, articleTypeStr)
  773. // if err != nil && err.Error() != utils.ErrNoRow() {
  774. // br.Msg = "获取失败"
  775. // br.ErrMsg = "获取单个标签ids失败,Err:" + err.Error()
  776. // return
  777. // }
  778. //}
  779. //
  780. //if soloTagArticleIds != "" {
  781. // if tagArticleIds != "" {
  782. // tagArticleIds += "," + soloTagArticleIds
  783. // } else {
  784. // tagArticleIds = soloTagArticleIds
  785. // }
  786. //}
  787. //if soloTagActivityIds != "" {
  788. // if tagActivityIds != "" {
  789. // tagActivityIds += "," + soloTagActivityIds
  790. // } else {
  791. // tagActivityIds = soloTagActivityIds
  792. // }
  793. //}
  794. //if soloMmIds != "" {
  795. // if mmIds != "" {
  796. // mmIds += "," + soloMmIds
  797. // } else {
  798. // mmIds = soloMmIds
  799. // }
  800. //}
  801. //fmt.Println("condition:",condition)
  802. if tagIds != "" {
  803. conditionTagIdsInit, err := services.GetConditionInitByTagIds(tagIds)
  804. if err != nil {
  805. br.Msg = "获取失败"
  806. br.ErrMsg = "获取活动权限数据失败,GetConditionInitByTagIds Err:" + err.Error()
  807. return
  808. }
  809. conditionInit += conditionTagIdsInit
  810. }
  811. //行业筛选
  812. if chartPermissionId > 0 {
  813. conditionInit += " AND chart_permission_id = " + strconv.Itoa(chartPermissionId)
  814. }
  815. if tagIds == "" && chartPermissionId == 0 {
  816. //查询近一个月的数据
  817. conditionInit += " AND publish_date > '" + time.Now().AddDate(0, 0, -30).Format(utils.FormatDateTime) + "'"
  818. }
  819. //conditionInit += ` AND source IN ('newchart')`
  820. if user.CompanyId <= 1 || totalRai == 0 {
  821. //condition += " AND source IN ('roadshow','article') "
  822. condition += " AND source NOT IN ('activityspecial') "
  823. listActivityYiDong, err := models.GetActivityListHomeNew(" AND art.yidong_activity_id != '' ", 0, 1000)
  824. if err != nil {
  825. br.Msg = "获取失败"
  826. br.ErrMsg = "获取可见活动数据失败,Err:" + err.Error()
  827. return
  828. }
  829. //易董的活动不查看 v12.2.1
  830. var yiDongactivityIds []int
  831. for _, v := range listActivityYiDong {
  832. yiDongactivityIds = append(yiDongactivityIds, v.ActivityId)
  833. }
  834. lenyiDongactivityIds := len(yiDongactivityIds)
  835. condition += ` AND IF ( source = 'activity' , source_id NOT IN (` + utils.GetOrmInReplace(lenyiDongactivityIds) + `) ,1=1 ) `
  836. pars = append(pars, yiDongactivityIds)
  837. } else {
  838. condition += ` AND source NOT IN ('activity','activityspecial','newchart') ` + conditionInit
  839. //conditionActivity, err := services.GetActivityonditionList(user, "", "", "", "1,2,3", "", 0, 0, "", 0, 1)
  840. conditionActivity, err := services.ActivityConditioninitSql(user, "", 0)
  841. if err != nil && err.Error() != utils.ErrNoRow() {
  842. br.Msg = "获取失败"
  843. br.ErrMsg = "获取活动权限数据失败,Err:" + err.Error()
  844. return
  845. }
  846. conditionActivity += ` AND art.publish_status = 1 `
  847. var conditionOrder string
  848. conditionOrder = ` ORDER BY art.activity_time DESC , art.active_state ASC `
  849. conditionActivity += conditionOrder
  850. actPageSize := 200
  851. if tagIds != "" {
  852. actPageSize = 2000
  853. }
  854. listActivity, err := models.GetActivityListHomeNew(conditionActivity, 0, actPageSize)
  855. if err != nil {
  856. br.Msg = "获取失败"
  857. br.ErrMsg = "获取可见活动数据失败,Err:" + err.Error()
  858. return
  859. }
  860. var activityIds []int
  861. for _, v := range listActivity {
  862. activityIds = append(activityIds, v.ActivityId)
  863. }
  864. lenActivityIds := len(activityIds)
  865. listActivitySpecial, _, err := services.GetActivitySpecialList(user, 1, 200, "")
  866. if err != nil {
  867. br.Msg = "获取失败"
  868. br.ErrMsg = "获取专项调研可见权限失败失败,Err:" + err.Error()
  869. return
  870. }
  871. var activityspecialIds []int
  872. for _, v := range listActivitySpecial {
  873. activityspecialIds = append(activityspecialIds, v.ActivityId)
  874. }
  875. lenActivityspecialIds := len(activityspecialIds)
  876. //if tagIds != "" {
  877. // if tagArticleIds != "" {
  878. // condition = ` AND ((source = 'article' AND source_id IN (` + tagArticleIds + `) ) `
  879. // if mmIds != "" {
  880. // condition += ` OR ( source = 'meetingreviewchapt' AND source_id IN (` + mmIds + `) ) `
  881. // }
  882. // if tagActivityIds != "" && lenActivityIds > 0 {
  883. // condition += ` OR (source = 'activity' AND source_id IN (` + tagActivityIds + `) AND source_id IN (` + utils.GetOrmInReplace(lenActivityIds) + `) )) `
  884. // pars = append(pars, activityIds)
  885. // } else {
  886. // // 无可见活动
  887. // condition += ` OR (source = 'activity' AND source_id IN (0))) `
  888. // }
  889. // } else if tagActivityIds != "" {
  890. // condition = ` AND ((source = 'article' AND source_id IN (0)) `
  891. // if mmIds != "" {
  892. // condition += ` OR ( source = 'meetingreviewchapt' AND source_id IN (` + mmIds + `) ) `
  893. // }
  894. // if tagActivityIds != "" && lenActivityIds > 0 {
  895. // condition += ` OR (source = 'activity' AND source_id IN (` + tagActivityIds + `) AND source_id IN (` + utils.GetOrmInReplace(lenActivityIds) + `))) `
  896. // pars = append(pars, activityIds)
  897. // } else {
  898. // // 无可见活动
  899. // condition += ` OR (source = 'activity' AND source_id IN (0))) `
  900. // }
  901. // } else if mmIds != "" {
  902. // condition = ` AND ( source = 'meetingreviewchapt' AND source_id IN (` + mmIds + `) ) `
  903. // } else {
  904. // condition += ` AND ((source = 'article' AND source_id IN (0)) OR (source = 'activity' AND source_id IN (0))) `
  905. // }
  906. //}
  907. if lenActivityIds > 0 {
  908. condition += ` OR ( source = 'activity' AND source_id IN (` + utils.GetOrmInReplace(lenActivityIds) + `) ` + conditionInit + ` ) `
  909. pars = append(pars, activityIds)
  910. }
  911. if lenActivityspecialIds > 0 {
  912. condition += ` OR ( source = 'activityspecial' AND source_id IN (` + utils.GetOrmInReplace(lenActivityspecialIds) + `) ` + conditionInit + ` ) `
  913. pars = append(pars, activityspecialIds)
  914. }
  915. }
  916. //fmt.Println("condition:",condition)
  917. total, err := models.GetResourceDataCount(condition, pars)
  918. if err != nil {
  919. br.Msg = "获取失败"
  920. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  921. return
  922. }
  923. //if user.Mobile == "" && user.Email == "" {
  924. // total = pageSize
  925. //}
  926. page := paging.GetPaging(currentIndex, pageSize, total)
  927. //Source string `description:"资源类型 报告 :article 、图表 :newchart、微路演 :roadshow、活动 :activity、活动视频:activityvideo、活动音频:activityvoice、专项调研活动:activityspecial"`
  928. list, err := services.GetResourceDataList(condition, pars, startSize, pageSize, user)
  929. if err != nil {
  930. br.Msg = "获取失败"
  931. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  932. return
  933. }
  934. page = paging.GetPaging(currentIndex, pageSize, total)
  935. resp.Paging = page
  936. resp.List = list
  937. br.Ret = 200
  938. br.Success = true
  939. br.Msg = "获取成功"
  940. br.Data = resp
  941. }