chart.go 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hongze_cygx/models"
  7. "hongze/hongze_cygx/services"
  8. "hongze/hongze_cygx/utils"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. type ChartController struct {
  14. BaseAuthController
  15. }
  16. type BaseChartController struct {
  17. BaseCommonController
  18. }
  19. // @Title 图表标签分类
  20. // @Description 图表标签分类接口
  21. // @Success 200 {object} models.ChartPtagResp
  22. // @router /patg [get]
  23. func (this *BaseChartController) Patg() {
  24. br := new(models.BaseResponse).Init()
  25. defer func() {
  26. this.Data["json"] = br
  27. this.ServeJSON()
  28. }()
  29. list, err := services.GetChartPtagByApi()
  30. if err != nil {
  31. br.Msg = "获取图表分类失败!"
  32. br.ErrMsg = "获取图表分类失败"
  33. return
  34. }
  35. br.Ret = 200
  36. br.Success = true
  37. br.Msg = "获取成功"
  38. br.Data = list
  39. }
  40. // @Title 我的收藏列表
  41. // @Description 我的收藏列表接口
  42. // @Param PageSize query int true "每页数据条数"
  43. // @Param CurrentIndex query int true "当前页页码,从1开始"
  44. // @Success 200 {object} models.HomeChartListItem
  45. // @router /my/collection [get]
  46. func (this *ChartController) Collection() {
  47. br := new(models.BaseResponse).Init()
  48. defer func() {
  49. this.Data["json"] = br
  50. this.ServeJSON()
  51. }()
  52. user := this.User
  53. if user == nil {
  54. br.Msg = "请重新登录"
  55. br.Ret = 408
  56. return
  57. }
  58. mobile := user.Mobile
  59. uid := user.UserId
  60. pageSize, _ := this.GetInt("PageSize")
  61. currentIndex, _ := this.GetInt("CurrentIndex")
  62. var startSize int
  63. if pageSize <= 0 {
  64. pageSize = utils.PageSize20
  65. }
  66. if currentIndex <= 0 {
  67. currentIndex = 1
  68. }
  69. startSize = utils.StartIndex(currentIndex, pageSize)
  70. resp := new(models.HomeChartListItem)
  71. if mobile == "" {
  72. page := paging.GetPaging(currentIndex, pageSize, 0)
  73. resp.Paging = page
  74. br.Ret = 200
  75. br.Success = true
  76. br.Msg = "获取成功"
  77. br.Data = resp
  78. resp.IsBindingMobile = false
  79. return
  80. } else {
  81. resp.IsBindingMobile = true
  82. }
  83. //list, err, total := services.GetChartCollectionByApi(mobile, pageSize, (currentIndex-1)*pageSize)
  84. //if err != nil {
  85. // br.Msg = "获取图表分类失败!"
  86. // br.ErrMsg = "获取图表分类失败"
  87. // return
  88. //}
  89. list, err, _ := services.GetChartCollectionByApi(mobile, 9999, 0)
  90. if err != nil {
  91. br.Msg = "获取图表分类失败!"
  92. br.ErrMsg = "获取图表分类失败"
  93. return
  94. }
  95. var chartIds string
  96. var condition string
  97. var pars []interface{}
  98. if len(list) > 0 {
  99. for _, v := range list {
  100. chartIds += strconv.Itoa(v.ChartId) + ","
  101. }
  102. }
  103. chartIds = strings.TrimRight(chartIds, ",")
  104. if chartIds == "" {
  105. chartIds = "0"
  106. }
  107. condition = ` AND a.chart_id IN (` + chartIds + `) `
  108. total, err := models.GetChartCount(condition, pars)
  109. if err != nil {
  110. br.Msg = "获取信息失败"
  111. br.Msg = "获取帖子总数失败,Err:" + err.Error()
  112. return
  113. }
  114. startSize = paging.StartIndex(currentIndex, pageSize)
  115. listCollection, err := models.GetChartListCollection(chartIds, uid, startSize, pageSize)
  116. if err != nil {
  117. br.Msg = "获取信息失败"
  118. br.Msg = "获取帖子总数失败,GetChartListCollection Err:" + err.Error()
  119. return
  120. }
  121. for k, v := range listCollection {
  122. if v.NumTop > 0 {
  123. listCollection[k].IsTop = true
  124. }
  125. listCollection[k].Source = 2
  126. }
  127. page := paging.GetPaging(currentIndex, pageSize, total)
  128. resp.List = listCollection
  129. resp.Paging = page
  130. br.Ret = 200
  131. br.Success = true
  132. br.Msg = "获取成功"
  133. br.Data = resp
  134. }
  135. // @Title 图表详情
  136. // @Description 我的收藏接口
  137. // @Param ChartId query int true "图表ID"
  138. // @Success 200 {object} models.CygxChartDetail
  139. // @router /detail [get]
  140. func (this *ChartController) Detail() {
  141. br := new(models.BaseResponse).Init()
  142. defer func() {
  143. this.Data["json"] = br
  144. this.ServeJSON()
  145. }()
  146. user := this.User
  147. if user == nil {
  148. br.Msg = "请重新登录"
  149. br.Ret = 408
  150. return
  151. }
  152. mobile := user.Mobile
  153. if mobile == "" {
  154. br.Msg = "请绑定手机号!"
  155. return
  156. }
  157. chartId, _ := this.GetInt("ChartId")
  158. if chartId <= 0 {
  159. br.Msg = "图表信息不存在!"
  160. return
  161. }
  162. detail, err := models.GetChartDetailById(chartId, user.UserId)
  163. if err != nil {
  164. br.Msg = "获取信息失败"
  165. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  166. return
  167. }
  168. GetIsCollectionChart, err := services.GetIsCollectionChart(mobile, chartId)
  169. if err != nil {
  170. br.Msg = "获取信息失败"
  171. br.ErrMsg = "获取三方关注信息失败,Err:" + err.Error()
  172. return
  173. }
  174. detail.IsCollection = GetIsCollectionChart
  175. if detail.IsCollection {
  176. err = models.RemoveChartCollect(user.UserId, chartId)
  177. }
  178. br.Ret = 200
  179. br.Success = true
  180. br.Msg = "获取成功"
  181. br.Data = detail
  182. }
  183. // @Title 收藏、取消收藏
  184. // @Description 收藏、取消收藏
  185. // @Param request body models.ChartCollectReq true "type json string"
  186. // @Success 200 {object} models.FontsCollectResp
  187. // @router /collect [post]
  188. func (this *ChartController) ChartCollect() {
  189. br := new(models.BaseResponse).Init()
  190. defer func() {
  191. this.Data["json"] = br
  192. this.ServeJSON()
  193. }()
  194. user := this.User
  195. if user == nil {
  196. br.Msg = "请重新登录"
  197. br.Ret = 408
  198. return
  199. }
  200. uid := user.UserId
  201. mobile := user.Mobile
  202. var req models.ChartCollectReq
  203. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  204. if err != nil {
  205. br.Msg = "参数解析异常!"
  206. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  207. return
  208. }
  209. count, err := models.GetChartCountByUserId(uid, req.ChartId)
  210. if err != nil {
  211. br.Msg = "获取数据失败!"
  212. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  213. return
  214. }
  215. resp := new(models.ArticleCollectResp)
  216. if count <= 0 {
  217. item := new(models.CygxChartCollect)
  218. item.ChartId = req.ChartId
  219. item.UserId = uid
  220. item.RealName = user.RealName
  221. item.CreateTime = time.Now()
  222. item.Mobile = user.Mobile
  223. item.Email = user.Email
  224. item.CompanyId = user.CompanyId
  225. item.CompanyName = user.CompanyName
  226. _, err = models.AddCygxChartCollect(item)
  227. if err != nil {
  228. br.Msg = "收藏失败"
  229. br.ErrMsg = "收藏失败,Err:" + err.Error()
  230. return
  231. }
  232. br.Msg = "收藏成功"
  233. resp.Status = 1
  234. } else {
  235. err = models.RemoveChartCollect(uid, req.ChartId)
  236. if err != nil {
  237. br.Msg = "取消收藏失败"
  238. br.ErrMsg = "取消收藏失败,Err:" + err.Error()
  239. return
  240. }
  241. br.Msg = "已取消收藏"
  242. resp.Status = 2
  243. }
  244. GetIsCollectionChart, err := services.GetIsCollectionChart(mobile, req.ChartId)
  245. if err != nil {
  246. br.Msg = "获取信息失败"
  247. br.ErrMsg = "获取三方关注信息失败,Err:" + err.Error()
  248. return
  249. }
  250. fmt.Println("GetIsCollectionChart", GetIsCollectionChart)
  251. //如果存在就取消收藏、反之添加收藏
  252. if GetIsCollectionChart {
  253. go services.DeleteCollectionChart(mobile, req.ChartId)
  254. } else {
  255. go services.AddCollectionChart(mobile, req.ChartId)
  256. }
  257. br.Ret = 200
  258. br.Success = true
  259. br.Data = resp
  260. }
  261. // @Title 置顶、取消置顶
  262. // @Description 置顶、取消置顶
  263. // @Param request body models.ChartCollectReq true "type json string"
  264. // @Success 200 {object} models.FontsCollectResp
  265. // @router /top [post]
  266. func (this *ChartController) ChartTop() {
  267. br := new(models.BaseResponse).Init()
  268. defer func() {
  269. this.Data["json"] = br
  270. this.ServeJSON()
  271. }()
  272. user := this.User
  273. if user == nil {
  274. br.Msg = "请重新登录"
  275. br.Ret = 408
  276. return
  277. }
  278. uid := user.UserId
  279. var req models.ChartCollectReq
  280. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  281. if err != nil {
  282. br.Msg = "参数解析异常!"
  283. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  284. return
  285. }
  286. count, err := models.GetChartTopCountByUserId(uid, req.ChartId)
  287. if err != nil {
  288. br.Msg = "获取数据失败!"
  289. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  290. return
  291. }
  292. resp := new(models.ArticleCollectResp)
  293. if count <= 0 {
  294. item := new(models.CygxChartTop)
  295. item.ChartId = req.ChartId
  296. item.UserId = uid
  297. item.RealName = user.RealName
  298. item.CreateTime = time.Now()
  299. item.Mobile = user.Mobile
  300. item.Email = user.Email
  301. item.CompanyId = user.CompanyId
  302. item.CompanyName = user.CompanyName
  303. _, err = models.AddCygxChartTop(item)
  304. if err != nil {
  305. br.Msg = "置顶失败"
  306. br.ErrMsg = "收置顶失败,Err:" + err.Error()
  307. return
  308. }
  309. br.Msg = "收藏成功"
  310. resp.Status = 1
  311. } else {
  312. err = models.RemoveChartTop(uid, req.ChartId)
  313. if err != nil {
  314. br.Msg = "取消置顶失败"
  315. br.ErrMsg = "取消置顶失败,Err:" + err.Error()
  316. return
  317. }
  318. br.Msg = "已取消置顶"
  319. resp.Status = 2
  320. }
  321. br.Ret = 200
  322. br.Success = true
  323. br.Data = resp
  324. }