package controllers import ( "encoding/json" "net/http" "net/url" "github.com/astaxie/beego" "hongze/hongze_api/models" "hongze/hongze_api/utils" ) type BaseCommonController struct { beego.Controller } func (this *BaseCommonController) Prepare() { var requestBody string method := this.Ctx.Input.Method() if method == "GET" { requestBody = this.Ctx.Request.RequestURI } else { requestBody, _ = url.QueryUnescape(string(this.Ctx.Input.RequestBody)) } ip := this.Ctx.Input.IP() apiLog.Println("请求地址:", this.Ctx.Input.URI(), "RequestBody:", requestBody, "IP:", ip) } func (c *BaseCommonController) ServeJSON(encoding ...bool) { var ( hasIndent = false hasEncoding = false ) if beego.BConfig.RunMode == beego.PROD { hasIndent = false } if len(encoding) > 0 && encoding[0] == true { hasEncoding = true } if c.Data["json"] == nil { go utils.SendEmail("异常提醒:", "接口:"+"URI:"+c.Ctx.Input.URI()+";无返回值", utils.EmailSendToUsers) return } baseRes := c.Data["json"].(*models.BaseResponse) if baseRes != nil && !baseRes.Success { go utils.SendEmail(utils.APPNAME+"失败提醒", "URI:"+c.Ctx.Input.URI()+" ErrMsg:"+baseRes.ErrMsg+";Msg"+baseRes.Msg, utils.EmailSendToUsers) } c.JSON(c.Data["json"], hasIndent, hasEncoding) } func (c *BaseCommonController) JSON(data interface{}, hasIndent bool, coding bool) error { c.Ctx.Output.Header("Content-Type", "application/json; charset=utf-8") var content []byte var err error if hasIndent { content, err = json.MarshalIndent(data, "", " ") } else { content, err = json.Marshal(data) } if err != nil { http.Error(c.Ctx.Output.Context.ResponseWriter, err.Error(), http.StatusInternalServerError) return err } ip := c.Ctx.Input.IP() requestBody, _ := url.QueryUnescape(string(c.Ctx.Input.RequestBody)) apiLog.Println("请求地址:", c.Ctx.Input.URI(), "Authorization:", c.Ctx.Input.Header("Authorization"), "RequestBody:", requestBody, "ResponseBody", string(content), "IP:", ip) if coding { content = []byte(utils.StringsToJSON(string(content))) } return c.Ctx.Output.Body(content) }