new frame

.gitignore

@@ -0,0 +1,2 @@
+*.exe
+*.exe~

conf/aliyun.conf

@@ -0,0 +1,5 @@
+[oss]
+Endpoint=oss-cn-shanghai.aliyuncs.com
+AccessKeyId=LTAIkc75dpkJw8Lb
+AccessKeySecret=v4bvXCaix6vSDTCFfwSAdqV53iFEQw
+Bucket=jingcheng-h5temp

conf/app.conf

@@ -1,6 +1,22 @@
-appname = spaceofcheng
-httpport = 8777
+appname = services
+httpport = 8080
 runmode = dev
+autorender = false
+copyrequestbody = true
+EnableDocs = true
 sessionon = true
 
-ApiPrefix = /api
+
+[cros]
+allowMode = dev
+allowCredentials = true
+allowOrigin = http://localhost:9528
+
+# GET, POST etc
+allowMethods = *
+
+[api]
+prefix = "/api"
+guest = "/guest"
+common = "/common"
+wechat = "/wechat"

conf/db.conf

@@ -11,10 +11,10 @@ db_addr      = localhost
 db_port      = 3306
 
 ; 用户名
-username     = h5-template
+username     = spaceofcheng
 
 ; 密码
-password     = h5-template
+password     = spaceofcheng
 
 ; 数据库名或者schema
 database     = spaceofcheng
@@ -26,4 +26,4 @@ dbprefix     =
 db_debug     = false
 
 ; 字符集
-char_set     = utf8mb4
+char_set     = utf8

controllers/auth.go

@@ -0,0 +1,40 @@
+package controllers
+
+import (
+	"strings"
+
+	"github.com/astaxie/beego"
+)
+
+// Authenticate 权限验证
+func (c *BaseController) authenticate() {
+	if !c.needAuth() {
+		return
+	}
+
+	userID, _ := c.GetSession(SNUserID).(string)
+	// userType := c.GetSession(SNUserType).(string)
+
+	// 未登录状态
+	if userID == "" {
+		return
+	}
+
+	// clientType := utils.GetClientType()
+	// if clientType == utils.ClientWechat {
+
+	// }
+
+}
+
+func (c *BaseController) needAuth() bool {
+	route := c.Ctx.Input.URL()
+	apiPrefix := beego.AppConfig.String("api::prefix")
+	guestAPI := beego.AppConfig.String("api::guest")
+
+	if strings.Index(route, apiPrefix+guestAPI) > -1 {
+		return false
+	}
+
+	return true
+}

controllers/base.go

@@ -2,100 +2,90 @@ package controllers
 
 import (
 	"net/http"
-	"reflect"
-	"space-of-cheng/helper"
-	"space-of-cheng/models"
+	"spaceofcheng/services/utils"
 
 	"github.com/astaxie/beego"
-	"github.com/yl10/kit/orm"
 )
 
-//Message api统一的返回消息格式
-type Message struct {
-	Code    int         `json:"code"`
-	Message interface{} `json:"message"`
-}
-
 //BaseController 基础controller
 type BaseController struct {
 	beego.Controller
-	Context *helper.Context
-}
-
-// BaseControllerInterface 项目约定的 Controller 须满足的接口
-type BaseControllerInterface interface {
-	Constructor()
+	Context *utils.Context
 }
 
 //Prepare 继承beego的
 func (c *BaseController) Prepare() {
 	// 初始化上下文
 	c.initContext()
-	c.Context.Ready(nil)
+
+	// 鉴权
+	c.authenticate()
 
 	// 路由对应的实际 Controller 初始化
 	c.initController()
 }
 
-// ResponseJson 自定义的JSON返回
-func (c *BaseController) ResponseJson(msg interface{}, code ...int) {
+// ResponseJSON 返回JSON数据
+func (c *BaseController) ResponseJSON(data interface{}) {
+	c.ResponseData(data, "")
+}
+
+// ResponseError 返回错误
+func (c *BaseController) ResponseError(err error, code ...int) {
+	c.ResponseData(nil, err, code...)
+}
+
+// ResponseData 自定义的JSON返回
+func (c *BaseController) ResponseData(data interface{}, msg interface{}, code ...int) {
 	status := http.StatusOK
 	if len(code) > 0 {
 		status = code[0]
 	}
 
-	if status < http.StatusMultipleChoices {
-		c.Context.Commit()
-	} else {
-		c.Context.RollBack()
-	}
-
-	c.Context.Destroy()
+	c.destroyContext(status < http.StatusMultipleChoices)
 
-	if reflect.ValueOf(msg).Type().String() == "*errors.errorString" {
-		err := msg.(error)
-		c.Data["json"] = Message{status, err.Error()}
-	} else {
-		c.Data["json"] = Message{status, msg}
+	sendMessage := ""
+	switch msgVal := msg.(type) {
+	case error:
+		sendMessage = msgVal.Error()
+	case string:
+		sendMessage = msgVal
+	default:
+		sendMessage = ""
 	}
 
+	c.Data["json"] = JSONMessage{status, sendMessage, data}
+	c.Ctx.Output.Header("Access-Control-Expose-Headers", "X-Token")
+
+	c.crosPolicy()
 	c.ServeJSON()
 	c.StopRun()
 }
 
-// ResponseRaw 返回
-func (c *BaseController) ResponseRaw(msg []byte) {
-	c.Ctx.ResponseWriter.Write(msg)
-	c.Context.Commit()
-	c.Context.Destroy()
-
-	c.StopRun()
+// Options 解决跨域先发送 options
+func (c *BaseController) Options() {
+	c.ResponseJSON("")
 }
 
-// initContext 初始化 Context
-func (c *BaseController) initContext() {
-	// 分页设置
-	pageSetting := map[string]int{
-		"pageNum": 100,
+// crosPolicy 跨域策略
+func (c *BaseController) crosPolicy() {
+	runMode := beego.AppConfig.String("runmode")
+	allowMode := beego.AppConfig.String("cros::allowMode")
+	allowMethods := beego.AppConfig.String("cros::allowMethods")
+	allowOrigin := beego.AppConfig.String("cros::allowOrigin")
+	allowCredentials := beego.AppConfig.String("cros::allowCredentials")
+
+	if runMode == allowMode {
+		c.Ctx.Output.Header("Access-Control-Allow-Origin", allowOrigin)
+		c.Ctx.Output.Header("Access-Control-Allow-Methods", allowMethods)
+		c.Ctx.Output.Header("Access-Control-Allow-Credentials", allowCredentials)
+		c.Ctx.Output.Header("Access-Control-Allow-Headers", "X-Token,Authorization")
 	}
-	// 初始化 orm
-	o, _ := orm.NewXormPlus(models.Dao.NewSession())
-	o.SetPageNavi(pageSetting)
-
-	c.Context = helper.NewContext(o, nil)
 }
 
 // initAppController 执行当前路由请求对应的 Controller 初始化
 func (c *BaseController) initController() {
-	if ctrl, ok := c.AppController.(BaseControllerInterface); ok {
+	if ctrl, ok := c.AppController.(ControllerInterface); ok {
 		ctrl.Constructor()
 	}
 }
-
-// Options 解决跨域先发送 options
-func (c *BaseController) Options() {
-	c.ResponseJson(map[string]interface{}{
-		"Status":  true,
-		"Message": "ok",
-	})
-}

controllers/context.go

@@ -0,0 +1,34 @@
+package controllers
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/utils"
+)
+
+/**
+* Context 说明
+* - 所有 stuct 类型均不是指针
+* - 包含内容如下
+* user					用户基本信息
+* customer			会员基本信息
+* cases					用户所有案场信息
+* currentCase 	当前案场
+* org						用户当前组织
+**/
+
+// initContext 初始化 Context
+func (c *BaseController) initContext() {
+	c.Context = utils.NewContext(models.DBEngine, nil)
+	c.Context.Ready()
+}
+
+// initContext 销毁 Context
+func (c *BaseController) destroyContext(ok ...bool) {
+	if len(ok) == 0 || ok[0] {
+		c.Context.DB.Rollback()
+	} else {
+		c.Context.DB.Commit()
+	}
+
+	c.Context.Destroy()
+}

controllers/file.go

@@ -0,0 +1,49 @@
+package controllers
+
+import (
+	"spaceofcheng/services/utils"
+	"strconv"
+	"time"
+
+	"net/http"
+
+	"github.com/astaxie/beego/config"
+)
+
+// FileUpload 文件上传
+func (c *BaseController) FileUpload() {
+	file, err := c.uploadFileToOSS("file")
+	if err != nil {
+		c.ResponseError(err, http.StatusInternalServerError)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"url": file,
+	})
+}
+
+func (c *BaseController) uploadFileToOSS(field string) (string, error) {
+	aliConf, err := config.NewConfig("ini", "conf/aliyun.conf")
+	if err != nil {
+		return "", err
+	}
+
+	endpoint := aliConf.String("oss::Endpoint")
+	accessKeyID := aliConf.String("oss::AccessKeyId")
+	accessKeySecret := aliConf.String("oss::AccessKeySecret")
+	bucket := aliConf.String("oss::Bucket")
+
+	aliCli, err := utils.GetOssClient(endpoint, accessKeyID, accessKeySecret)
+	if err != nil {
+		return "", err
+	}
+
+	fNameExtra := strconv.FormatInt(time.Now().Unix(), 10)
+
+	fileURL, err := utils.UploadFileToBucket(aliCli, c.Ctx.Request, bucket, field, fNameExtra)
+	if err != nil {
+		return "", err
+	}
+
+	return fileURL, nil
+}

controllers/session.go

@@ -0,0 +1,9 @@
+package controllers
+
+// session key 列表
+const (
+	// 用户ID
+	SNUserID = "userid"
+	// 用户类型
+	SNUserType = "userType"
+)

controllers/types.go

@@ -0,0 +1,20 @@
+package controllers
+
+// 用户类型列表
+const (
+	UserGuest    = "guest"
+	UserCommon   = "common"
+	UserCustomer = "customer"
+)
+
+// JSONMessage 主要用于 Response 返回
+type JSONMessage struct {
+	Code    int         `json:"code"`
+	Message string      `json:"message"`
+	Result  interface{} `json:"result"`
+}
+
+// ControllerInterface 项目约定的 Controller 须满足的接口
+type ControllerInterface interface {
+	Constructor()
+}

helper/clienttype.go

@@ -1,24 +0,0 @@
-package helper
-
-import "strings"
-
-const (
-	CLIENT_PC     = "PC"
-	CLIENT_MOBILE = "Mobile"
-	CLIENT_WECHAT = "Wechat"
-)
-
-func GetClientType(ua string) string {
-	tp := CLIENT_PC
-
-	ua = strings.ToLower(ua)
-
-	if strings.Index(ua, "mobile") > -1 {
-		tp = CLIENT_MOBILE
-	}
-	if strings.Index(ua, "micromessenger") > -1 {
-		tp = CLIENT_WECHAT
-	}
-
-	return tp
-}

helper/context.go

@@ -1,105 +0,0 @@
-package helper
-
-import (
-	"github.com/yl10/kit/orm"
-)
-
-// Context 上下文
-// 只限制在每次 Request 内
-type Context struct {
-	db      *orm.XormPlus
-	options map[string]interface{}
-	User    interface{}
-}
-
-// NewContext 初始化上下文
-func NewContext(db *orm.XormPlus, opt map[string]interface{}) *Context {
-	return &Context{
-		db:      db,
-		options: opt,
-	}
-}
-
-// Ready Request 级别初始化
-func (c *Context) Ready(options map[string]interface{}) error {
-	if options != nil {
-		c.options = options
-	}
-
-	// 自动提交, 默认是否
-	autoCommit, _ := c.getOption("autoCommit", false).(bool)
-	if !autoCommit {
-		// 开启事务
-		if err := c.openDBTransaction(); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}
-
-// Destroy 析构函数
-func (c *Context) Destroy() {
-	// 自动提交, 默认是否
-	autoCommit, _ := c.getOption("autoCommit", false).(bool)
-	if !autoCommit {
-		c.closeDBTransaction()
-	} else {
-		c.db.Close()
-	}
-}
-
-// Commit 提交
-func (c *Context) Commit() error {
-	return c.db.Commit()
-}
-
-// RollBack 回滚
-func (c *Context) RollBack() error {
-	return c.db.Rollback()
-}
-
-// GetDB 获取数据库操作实例
-func (c *Context) GetDB() *orm.XormPlus {
-	return c.db
-}
-
-// SetDB 设置数据库操作实例
-func (c *Context) SetDB(db *orm.XormPlus) *Context {
-	c.db = db
-	return c
-}
-
-// openDBTransaction 开启事务
-func (c *Context) openDBTransaction() error {
-	// 开启写事务
-	if err := c.db.Begin(); err != nil {
-		return err
-	}
-
-	return nil
-}
-
-// closeDBTransaction 关闭事务
-// 注意, 事务关闭后, DB 将不能再使用
-func (c *Context) closeDBTransaction() error {
-	// 自动提交, 默认是否
-	autoCommit, _ := c.getOption("autoCommit", false).(bool)
-
-	if !autoCommit {
-		c.db.Close()
-	}
-
-	return nil
-}
-
-// getOption 读取配置项
-func (c *Context) getOption(key string, def interface{}) interface{} {
-	if c.options != nil {
-		if opt, has := c.options[key]; has {
-			return opt
-		}
-	}
-
-	return def
-}

helper/error.go

@@ -1,18 +0,0 @@
-package helper
-
-import (
-	"errors"
-
-	"github.com/astaxie/beego"
-)
-
-// LogError 错误日志
-func LogError(err string, v ...interface{}) error {
-	beego.Error(err)
-
-	if len(v) > 0 {
-		beego.Error(v...)
-	}
-
-	return errors.New(err)
-}

main.go

@@ -1,13 +1,15 @@
 package main
 
 import (
-	_ "cdkj-check/routers"
+	_ "spaceofcheng/services/routers"
 
 	"github.com/astaxie/beego"
 )
 
 func main() {
-
-	beego.InsertFilter("/*", beego.BeforeExec, accessLog)
+	if beego.BConfig.RunMode == "dev" {
+		beego.BConfig.WebConfig.DirectoryIndex = true
+		beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
+	}
 	beego.Run()
 }

models/models.go

@@ -7,42 +7,37 @@ import (
 )
 
 var (
-	Dao *xorm.Engine
+	DBEngine *xorm.Engine
 )
 
 func init() {
-	Dao = NewDAO()
+	DBEngine = NewDBEngine()
 }
 
-// NewDAO 初始化数据库连接
-func NewDAO() *xorm.Engine {
+// NewDBEngine 初始化数据库连接
+func NewDBEngine() *xorm.Engine {
 	dbType := "mysql"
-	dns := getMysqlDns()
+	dns := getMySQLDNS()
 
-	dao, err := xorm.NewEngine(dbType, dns)
+	engine, err := xorm.NewEngine(dbType, dns)
 	// dao.ShowSQL()
 
 	if err != nil {
 		panic(err)
-		return nil
 	}
 
-	Dao = dao
-	return dao
+	return engine
 }
 
-func getMysqlDns() string {
+func getMySQLDNS() string {
 	dbconf, _ := config.NewConfig("ini", "conf/db.conf")
 
-	// db_type  := dbconf.DefaultString("db_type", "mysql")
 	conProt := dbconf.DefaultString("con_protocol", "tcp")
 	dbAddr := dbconf.DefaultString("db_addr", "localhost")
 	dbPort := dbconf.DefaultString("db_port", "3306")
 	userName := dbconf.DefaultString("username", "root")
 	password := dbconf.String("password")
 	database := dbconf.String("database")
-	// dbprefix := dbconf.String("dbprefix")
-	// db_debug := dbconf.DefaultBool("db_debug", false)
 	charSet := dbconf.DefaultString("char_set", "utf8")
 
 	dns := userName

models/sys.go

@@ -0,0 +1,21 @@
+package models
+
+import (
+	"spaceofcheng/services/utils"
+
+	"github.com/go-xorm/xorm"
+)
+
+// SysDAO 系统
+type SysDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewSysDAO New Inst
+func NewSysDAO(ctx *utils.Context) *SysDAO {
+	return &SysDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}

models/system/user.go

@@ -1 +0,0 @@
-package system

models/user.go

@@ -0,0 +1,21 @@
+package models
+
+import (
+	"spaceofcheng/services/utils"
+
+	"github.com/go-xorm/xorm"
+)
+
+// UserDAO 系统
+type UserDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewUserDAO New Inst
+func NewUserDAO(ctx *utils.Context) *UserDAO {
+	return &UserDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}

plugins.go

@@ -1,31 +0,0 @@
-package main
-
-import (
-	"github.com/astaxie/beego/context"
-)
-
-func accessLog(ctx *context.Context) {
-	// plugin := func(ctx *context.Context) {
-	// 	access := model.TaApiAccessLog{
-	// 		Protocal: ctx.Input.Protocol(),
-	// 		Schema:   ctx.Input.Scheme(),
-	// 		Host:     ctx.Input.Host(),
-	// 		Uri:      ctx.Input.URI(),
-	// 		Port:     ctx.Input.Port(),
-	// 		Referer:  ctx.Input.Referer(),
-	// 		Ip:       ctx.Input.IP(),
-	// 		Ua:       ctx.Input.UserAgent(),
-	// 		Method:   ctx.Input.Method(),
-	// 	}
-
-	// 	if strings.Index(access.Ua, "mobile") > 0 {
-	// 		access.ClientType = accLog.CLIENT_MOBILE
-	// 	}
-
-	// 	dao := accLog.NewDAO(nil)
-	// 	dao.SaveAccessLog(&access)
-	// }
-
-	// // 不影响主进程
-	// go plugin(ctx)
-}

routers/common.go

@@ -0,0 +1,15 @@
+package routers
+
+import (
+	"spaceofcheng/services/controllers"
+
+	"github.com/astaxie/beego"
+)
+
+func getCommonRoutes() beego.LinkNamespace {
+	prefix := beego.AppConfig.String("api::common")
+
+	return beego.NSNamespace(prefix,
+		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
+	)
+}

routers/guest.go

@@ -0,0 +1 @@
+package routers

routers/router.go

@@ -1,17 +1,28 @@
+// @APIVersion 1.0.0
+// @Title beego Test API
+// @Description beego has a very cool tools to autogenerate documents for your API
+// @Contact astaxie@gmail.com
+// @TermsOfServiceUrl http://beego.me/
+// @License Apache 2.0
+// @LicenseUrl http://www.apache.org/licenses/LICENSE-2.0.html
 package routers
 
 import (
-	"tolet/controllers"
+	"spaceofcheng/services/controllers"
 
 	"github.com/astaxie/beego"
 )
 
 func init() {
-	beego.Router("/*", &controllers.BaseController{}, "options:Options")
+	prefix := beego.AppConfig.String("api::prefix")
 
-	// apiPrefix := beego.AppConfig.String("ApiPrefix")
-	// ns := beego.NewNamespace(apiPrefix,
-	// 	beego.NSRouter("/GetCheckByUser", &bodycheck.BodyCheckController{}, "get:GetCheckByUser"),
-	// )
-	// beego.AddNamespace(ns)
+	ns := beego.NewNamespace(prefix,
+		// 解决跨域时 先发送 options 问题
+		beego.NSRouter("*", &controllers.BaseController{}, "options:Options"),
+
+		// 通用需要鉴权路由
+		getCommonRoutes(),
+	)
+
+	beego.AddNamespace(ns)
 }

routers/wechat.go

@@ -0,0 +1 @@
+package routers

service/events.go

@@ -0,0 +1,4 @@
+package service
+
+// EventServ 事件 Serv
+type EventServ struct{}

service/service.go

@@ -0,0 +1 @@
+package service

service/sys.go

@@ -0,0 +1,24 @@
+package service
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/utils"
+)
+
+// SysServ 系统处理
+type SysServ struct {
+	ctx *utils.Context
+	dao *models.SysDAO
+}
+
+// NewSysServ 初始化
+func NewSysServ(ctx *utils.Context) *SysServ {
+	return &SysServ{
+		ctx: ctx,
+		dao: models.NewSysDAO(ctx),
+	}
+}
+
+func (s *SysServ) GetUserByID(id string) error {
+	return nil
+}

utils/aliyun.go

@@ -0,0 +1,104 @@
+package utils
+
+import (
+	"bytes"
+	"encoding/base64"
+	"net/http"
+	"strings"
+	"time"
+
+	"github.com/yl10/kit/guid"
+
+	"github.com/aliyun/aliyun-oss-go-sdk/oss"
+)
+
+// GetOssClient 获取 OSS 客户端
+func GetOssClient(endpoint, accessKeyID, accessKeySecret string) (*oss.Client, error) {
+	return oss.New(endpoint, accessKeyID, accessKeySecret)
+}
+
+// UploadFileToBucket 简单上传文件
+func UploadFileToBucket(cli *oss.Client, req *http.Request, bucket, fromFront string, nameSuffix ...string) (string, error) {
+	bkt, err := cli.Bucket(bucket)
+	if err != nil {
+		return "", err
+	}
+
+	file, fh, err := req.FormFile(fromFront)
+	if err != nil {
+		return "", err
+	}
+	defer file.Close()
+
+	fname := fh.Filename
+	if len(nameSuffix) > 0 && nameSuffix[0] != "" {
+		fArr := strings.Split(fname, ".")
+		fArr[0] = fArr[0] + nameSuffix[0]
+		fname = strings.Join(fArr, ".")
+	}
+
+	err = bkt.PutObject(fname, file)
+	if err != nil {
+		return "", err
+	}
+
+	return strings.Join([]string{
+		"http://",
+		bucket + ".",
+		cli.Config.Endpoint + "/",
+		fname,
+	}, ""), nil
+}
+
+// UploadStringToBucket 上传base64图片
+func UploadStringToBucket(cli *oss.Client, bucket, fromStr string) (string, error) {
+	bkt, err := cli.Bucket(bucket)
+	if err != nil {
+		return "", err
+	}
+
+	imgName := guid.NewGUIDString() + "-" + time.Now().Local().Format("20060102150405")
+	imgExt := ".jpg"
+	switch getMIMEFromBase64(fromStr) {
+	case "image/gif":
+		imgExt = ".gif"
+	case "image/bmp":
+		imgExt = ".bmp"
+	case "image/png", "image/x-png":
+		imgExt = ".png"
+	case "image/pipeg":
+		imgExt = ".jfif"
+	case "image/webp":
+		imgExt = ".webp"
+	}
+
+	fName := imgName + imgExt
+
+	imgData, err := base64.StdEncoding.DecodeString(strings.Split(fromStr, "base64,")[1])
+	if err != nil {
+		return "", err
+	}
+
+	err = bkt.PutObject(fName, bytes.NewBuffer(imgData))
+	if err != nil {
+		return "", err
+	}
+
+	return strings.Join([]string{
+		"http://",
+		bucket + ".",
+		cli.Config.Endpoint + "/",
+		fName,
+	}, ""), nil
+}
+
+// utils
+// getMIMEFromBase64 获取 base64 字串中的 mime
+func getMIMEFromBase64(str string) string {
+	g := strings.Split(str, ";")
+	if len(g) < 2 {
+		return ""
+	}
+
+	return strings.ToLower(strings.TrimLeft(g[0], "data:"))
+}

utils/context.go

@@ -0,0 +1,59 @@
+package utils
+
+import (
+	"github.com/go-xorm/xorm"
+)
+
+// Context 上下文
+// 只限制在每次 Request 内
+type Context struct {
+	DB  *xorm.Session
+	box map[string]interface{}
+}
+
+// NewContext 初始化上下文
+func NewContext(engine *xorm.Engine, opt map[string]interface{}) *Context {
+	return &Context{
+		DB:  engine.NewSession(),
+		box: opt,
+	}
+}
+
+// Get 获取
+func (c *Context) Get(key string, def ...interface{}) interface{} {
+	if c.box != nil {
+		if opt, has := c.box[key]; has {
+			return opt
+		}
+	}
+
+	if len(def) > 0 {
+		return def[0]
+	}
+
+	return nil
+}
+
+// Set 设置
+func (c *Context) Set(key string, val interface{}) {
+	if c.box == nil {
+		c.box = make(map[string]interface{})
+	}
+
+	c.box[key] = val
+}
+
+// Ready Request 级别初始化
+func (c *Context) Ready() error {
+	// 开启事务
+	if err := c.DB.Begin(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// Destroy 析构函数
+func (c *Context) Destroy() {
+	c.DB.Close()
+}

utils/utils.go

@@ -0,0 +1,13 @@
+package utils
+
+// 客户端类型
+const (
+	ClientAdmin  = "client-admin"
+	ClientWechat = "client-wechat"
+	ClientMini   = "client-mini"
+)
+
+// GetClientType 获取客户端类型
+func GetClientType() string {
+	return ""
+}