hongze_mobile_admin/controllers/base_not_auth.go

package controllers

import (
	"fmt"
	"hongze/hongze_mobile_admin/utils"
	"net/url"
	"strings"
)

//不需要授权的基类
type BaseNotAuth struct {
	BaseCommon
}

func (this *BaseNotAuth) 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))
	}
	fmt.Println("requestBody:", requestBody)
	ip := this.Ctx.Input.IP()
	fmt.Println("ip:", ip)
	apiLog.Println("请求地址：", this.Ctx.Input.URI(), "RequestBody：", requestBody, "IP：", ip)

	authorization := this.Ctx.Input.Header("Authorization")
	if authorization == "" {
		cookie := this.Ctx.GetCookie("rddp_access_token")
		utils.FileLog.Info("authorization:%s,cookie:%s", authorization, cookie)
		authorization = cookie
	}
	uri := this.Ctx.Input.URI()
	utils.FileLog.Info("URI:%s", uri)
	if strings.Contains(uri, "/api/wechat/login") {
		authorization = ""
	}
	//if authorization != "" {
	//	session, err := models.GetSessionByToken(authorization)
	//	if err != nil {
	//		if err.Error() == utils.ErrNoRow() {
	//			this.JSON(models.BaseResponse{Ret: 408, Msg: "信息已变更,请重新登陆！", ErrMsg: "Token 信息已变更:Token: " + authorization}, false, false)
	//			this.StopRun()
	//			return
	//		}
	//		this.JSON(models.BaseResponse{Ret: 408, Msg: "网络异常，请稍后重试!", ErrMsg: "获取用户信息异常，Eerr:" + err.Error()}, false, false)
	//		this.StopRun()
	//		return
	//	}
	//	if session == nil {
	//		this.JSON(models.BaseResponse{Ret: 408, Msg: "网络异常，请稍后重试!", ErrMsg: "sesson is empty "}, false, false)
	//		this.StopRun()
	//		return
	//	}
	//
	//	var wxUser *models.WxUserItem
	//	if session.UserId > 0 {
	//		tmpWxUser, tmpErr := services.GetWxUserItemByUserId(session.UserId, utils.WxPcPlatform)
	//		wxUser = tmpWxUser
	//		err = tmpErr
	//	} else if session.OpenId != "" {
	//		tmpWxUser, tmpErr := services.GetWxUserItemByOpenId(session.OpenId)
	//		wxUser = tmpWxUser
	//		err = tmpErr
	//	} else {
	//		this.JSON(models.BaseResponse{Ret: 408, Msg: "数据异常!", ErrMsg: "sesson is empty "}, false, false)
	//		this.StopRun()
	//		return
	//	}
	//	//wxUser, err := models.GetWxUserItemByUserId(session.UserId)
	//	//wxUser, err := services.GetWxUserItemByOpenId(session.OpenId)
	//	if err != nil {
	//		//没有找到记录
	//		if err.Error() == utils.ErrNoRow() {
	//			this.JSON(models.BaseResponse{Ret: 408, Msg: "信息已变更,请重新登陆！", ErrMsg: "获取admin 信息失败 " + strconv.Itoa(session.UserId)}, false, false)
	//			this.StopRun()
	//			return
	//		}
	//		this.JSON(models.BaseResponse{Ret: 408, Msg: "网络异常，请稍后重试!", ErrMsg: "获取wx_user信息异常，Eerr:" + err.Error()}, false, false)
	//		this.StopRun()
	//		return
	//	}
	//	if wxUser == nil {
	//		this.JSON(models.BaseResponse{Ret: 408, Msg: "网络异常，请稍后重试!", ErrMsg: "admin is empty "}, false, false)
	//		this.StopRun()
	//		return
	//	}
	//	this.User = wxUser
	//}
	//this.Token = authorization
}