BaseController.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  1. package controllers
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "io"
  6. "strings"
  7. "time"
  8. "github.com/astaxie/beego"
  9. "github.com/lifei6671/mindoc/conf"
  10. "github.com/lifei6671/mindoc/models"
  11. "github.com/lifei6671/mindoc/utils"
  12. "github.com/lifei6671/mindoc/utils/filetil"
  13. "path/filepath"
  14. )
  15. type BaseController struct {
  16. beego.Controller
  17. Member *models.Member
  18. Option map[string]string
  19. EnableAnonymous bool
  20. EnableDocumentHistory bool
  21. }
  22. type CookieRemember struct {
  23. MemberId int
  24. Account string
  25. Time time.Time
  26. }
  27. // Prepare 预处理.
  28. func (c *BaseController) Prepare() {
  29. c.Data["SiteName"] = "MinDoc"
  30. c.Data["Member"] = models.NewMember()
  31. controller, action := c.GetControllerAndAction()
  32. c.Data["ActionName"] = action
  33. c.Data["ControllerName"] = controller
  34. c.EnableAnonymous = false
  35. c.EnableDocumentHistory = false
  36. if member, ok := c.GetSession(conf.LoginSessionName).(models.Member); ok && member.MemberId > 0 {
  37. c.Member = &member
  38. c.Data["Member"] = c.Member
  39. } else {
  40. var remember CookieRemember
  41. // //如果Cookie中存在登录信息,从cookie中获取用户信息
  42. if cookie, ok := c.GetSecureCookie(conf.GetAppKey(), "login"); ok {
  43. if err := utils.Decode(cookie, &remember); err == nil {
  44. if member, err := models.NewMember().Find(remember.MemberId); err == nil {
  45. c.Member = member
  46. c.Data["Member"] = member
  47. c.SetMember(*member)
  48. }
  49. }
  50. }
  51. }
  52. conf.BaseUrl = c.BaseUrl()
  53. c.Data["BaseUrl"] = c.BaseUrl()
  54. if options, err := models.NewOption().All(); err == nil {
  55. c.Option = make(map[string]string, len(options))
  56. for _, item := range options {
  57. c.Data[item.OptionName] = item.OptionValue
  58. c.Option[item.OptionName] = item.OptionValue
  59. if strings.EqualFold(item.OptionName, "ENABLE_ANONYMOUS") && item.OptionValue == "true" {
  60. c.EnableAnonymous = true
  61. }
  62. if strings.EqualFold(item.OptionName, "ENABLE_DOCUMENT_HISTORY") && item.OptionValue == "true" {
  63. c.EnableDocumentHistory = true
  64. }
  65. }
  66. }
  67. c.Data["HighlightStyle"] = beego.AppConfig.DefaultString("highlight_style","github")
  68. if filetil.FileExists(filepath.Join(beego.BConfig.WebConfig.ViewsPath,"widgets","scripts.tpl")) {
  69. c.LayoutSections["Scripts"] = "widgets/scripts.tpl"
  70. }
  71. }
  72. // SetMember 获取或设置当前登录用户信息,如果 MemberId 小于 0 则标识删除 Session
  73. func (c *BaseController) SetMember(member models.Member) {
  74. if member.MemberId <= 0 {
  75. c.DelSession(conf.LoginSessionName)
  76. c.DelSession("uid")
  77. c.DestroySession()
  78. } else {
  79. c.SetSession(conf.LoginSessionName, member)
  80. c.SetSession("uid", member.MemberId)
  81. }
  82. }
  83. // JsonResult 响应 json 结果
  84. func (c *BaseController) JsonResult(errCode int, errMsg string, data ...interface{}) {
  85. jsonData := make(map[string]interface{}, 3)
  86. jsonData["errcode"] = errCode
  87. jsonData["message"] = errMsg
  88. if len(data) > 0 && data[0] != nil {
  89. jsonData["data"] = data[0]
  90. }
  91. returnJSON, err := json.Marshal(jsonData)
  92. if err != nil {
  93. beego.Error(err)
  94. }
  95. c.Ctx.ResponseWriter.Header().Set("Content-Type", "application/json; charset=utf-8")
  96. c.Ctx.ResponseWriter.Header().Set("Cache-Control", "no-cache, no-store")
  97. io.WriteString(c.Ctx.ResponseWriter, string(returnJSON))
  98. c.StopRun()
  99. }
  100. // ExecuteViewPathTemplate 执行指定的模板并返回执行结果.
  101. func (c *BaseController) ExecuteViewPathTemplate(tplName string, data interface{}) (string, error) {
  102. var buf bytes.Buffer
  103. viewPath := c.ViewPath
  104. if c.ViewPath == "" {
  105. viewPath = beego.BConfig.WebConfig.ViewsPath
  106. }
  107. if err := beego.ExecuteViewPathTemplate(&buf, tplName, viewPath, data); err != nil {
  108. return "", err
  109. }
  110. return buf.String(), nil
  111. }
  112. func (c *BaseController) BaseUrl() string {
  113. baseUrl := beego.AppConfig.DefaultString("baseurl", "")
  114. if baseUrl != "" {
  115. if strings.HasSuffix(baseUrl, "/") {
  116. baseUrl = strings.TrimSuffix(baseUrl, "/")
  117. }
  118. } else {
  119. baseUrl = c.Ctx.Input.Scheme() + "://" + c.Ctx.Request.Host
  120. }
  121. return baseUrl
  122. }
  123. //显示错误信息页面.
  124. func (c *BaseController) ShowErrorPage(errCode int, errMsg string) {
  125. c.TplName = "errors/error.tpl"
  126. c.Data["ErrorMessage"] = errMsg
  127. c.Data["ErrorCode"] = errCode
  128. var buf bytes.Buffer
  129. if err := beego.ExecuteViewPathTemplate(&buf, "errors/error.tpl", beego.BConfig.WebConfig.ViewsPath, map[string]interface{}{"ErrorMessage": errMsg, "ErrorCode": errCode, "BaseUrl": conf.BaseUrl}); err != nil {
  130. c.Abort("500")
  131. }
  132. if errCode >= 200 && errCode <= 510 {
  133. c.CustomAbort(errCode, buf.String())
  134. }else{
  135. c.CustomAbort(500, buf.String())
  136. }
  137. }