tank/code/rest/base_bean.go

package rest

import (
	"github.com/eyebluecn/tank/code/core"
	"github.com/eyebluecn/tank/code/tool/result"
	"github.com/eyebluecn/tank/code/tool/util"
	"net/http"
)

type BaseBean struct {
	logger core.Logger
}

func (this *BaseBean) Init() {
	this.logger = core.LOGGER
}

func (this *BaseBean) Bootstrap() {

}

//系统大清理，一般时产品即将上线时，清除脏数据，只执行一次。
func (this *BaseBean) Cleanup() {

}

//处理错误的统一方法 可以省去if err!=nil 这段代码
func (this *BaseBean) PanicError(err error) {
	util.PanicError(err)
}

//能找到一个user就找到一个
func (this *BaseBean) findUser(writer http.ResponseWriter, request *http.Request) *User {

	//验证用户是否已经登录。
	//登录身份有效期以数据库中记录的为准
	sessionId := util.GetSessionUuidFromRequest(request, core.COOKIE_AUTH_KEY)
	if sessionId == "" {
		return nil
	}

	//去缓存中捞取看看
	cacheItem, err := core.CONTEXT.GetSessionCache().Value(sessionId)
	if err != nil {
		this.logger.Warn("获取缓存时出错了" + err.Error())
		return nil
	}

	if cacheItem == nil || cacheItem.Data() == nil {

		this.logger.Warn("cache item中已经不存在了 ")
		return nil
	}

	if value, ok := cacheItem.Data().(*User); ok {
		return value
	} else {
		this.logger.Error("cache item中的类型不是*User ")
	}

	return nil
}

//获取当前登录的用户，找不到就返回登录错误
func (this *BaseBean) checkUser(writer http.ResponseWriter, request *http.Request) *User {
	if this.findUser(writer, request) == nil {
		panic(result.ConstWebResult(result.CODE_WRAPPER_LOGIN))
	} else {
		return this.findUser(writer, request)
	}
}