plug_link.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. package admin
  2. import (
  3. "gfast/app/model/admin/plug_link"
  4. "gfast/app/service/admin/plug_link_service"
  5. "gfast/library/response"
  6. "github.com/gogf/gf/frame/g"
  7. "github.com/gogf/gf/net/ghttp"
  8. "github.com/gogf/gf/util/gconv"
  9. "github.com/gogf/gf/util/gvalid"
  10. )
  11. type PlugLink struct{}
  12. // 添加链接
  13. func (c *PlugLink) Add(r *ghttp.Request) {
  14. if r.Method == "POST" {
  15. var req *plug_link.AddReq
  16. // 通过Parse方法解析获取参数
  17. err := r.Parse(&req)
  18. if err != nil {
  19. response.FailJson(true, r, err.(*gvalid.Error).FirstString())
  20. }
  21. // 调用service中的添加函数添加链接
  22. err = plug_link_service.AddSavePlugLink(req)
  23. if err != nil {
  24. response.FailJson(true, r, err.Error())
  25. }
  26. response.SusJson(true, r, "添加成功!")
  27. }
  28. }
  29. // 批量删除链接
  30. func (c *PlugLink) Delete(r *ghttp.Request) {
  31. ids := r.GetInts("plugLinkID")
  32. if len(ids) == 0 {
  33. response.FailJson(true, r, "ID获取失败,删除失败")
  34. }
  35. err := plug_link_service.DeleteByIDs(ids)
  36. if err != nil {
  37. response.FailJson(true, r, err.Error())
  38. }
  39. response.SusJson(true, r, "删除成功")
  40. }
  41. // 修改链接
  42. func (c *PlugLink) Edit(r *ghttp.Request) {
  43. // 如果是post提交的请求就执行修改操作
  44. if r.Method == "POST" {
  45. var editReq *plug_link.EditReq
  46. // 通过Parse方法解析获取参数
  47. err := r.Parse(&editReq)
  48. if err != nil {
  49. response.FailJson(true, r, err.(*gvalid.Error).FirstString())
  50. }
  51. err = plug_link_service.EditPlugLinkSave(editReq)
  52. if err != nil {
  53. response.FailJson(true, r, err.Error())
  54. }
  55. response.SusJson(true, r, "修改链接成功")
  56. }
  57. // 不是post提交的请求就到修改页面后查询出要修改的记录
  58. id := r.GetInt("plugLinkID")
  59. params, err := plug_link_service.GetPlugLinkByID(int64(id))
  60. if err != nil {
  61. response.FailJson(true, r, err.Error())
  62. }
  63. response.SusJson(true, r, "ok", params)
  64. }
  65. // 友情链接列表
  66. func (c *PlugLink) List(r *ghttp.Request) {
  67. // 定义一个结构体存储请求参数
  68. var req *plug_link.SelectPageReq
  69. // 获取参数
  70. err := r.Parse(&req)
  71. if err != nil {
  72. response.FailJson(true, r, err.Error())
  73. }
  74. total, page, list, err := plug_link_service.SelectPlugLinkListByPage(req)
  75. if err != nil {
  76. response.FailJson(true, r, err.Error())
  77. }
  78. result := g.Map{
  79. "currentPage": page,
  80. "total": total,
  81. "list": list,
  82. }
  83. response.SusJson(true, r, "链接列表", result)
  84. }
  85. // 链接排序
  86. func (c *PlugLink) Sort(r *ghttp.Request) {
  87. sorts := r.Get("sorts")
  88. s := gconv.Map(sorts)
  89. if s == nil {
  90. response.FailJson(true, r, "获取记录id、序号失败")
  91. }
  92. var err error
  93. for k, v := range s {
  94. _, err = plug_link.Model.Where("link_id=?", k).Data("link_order", v).Update()
  95. if err != nil {
  96. response.FailJson(true, r, err.Error())
  97. }
  98. }
  99. response.SusJson(true, r, "排序成功")
  100. }