// 包裝所有注冊(cè)的Controller 然后前置方法加上錯(cuò)誤panic和超時(shí)控制
func TimeOutController(fun ControllerHandler, d time.Duration) ControllerHandler {
   return func(c *Context) error {
      finish := make(chan struct{}, 1)
      panicChan := make(chan interface{}, 1)
      context, cancel := context.WithTimeout(c, d)
      defer cancel()
      c.Request.WithContext(context)
      go func() {
         defer func() {
            if p := recover(); p != nil {
               panicChan <- p
            }
         }()
         fun(c)
         finish <- struct{}{}
      }()
      select {
      case p := <-panicChan:
         log.Println(p)
         c.ResponseWriter.WriteHeader(500)
      case <-finish:
         log.Println("finish")
      case <-context.Done():
         c.SetHasTimeOut()
         c.ResponseWriter.Write([]byte("time out"))
      }
      return nil
   }
}

core.Get("/user/login", framework.TimeOutController(UserLoginController,time.Second*2))

type Core struct {
	router map[string]*Tree
	handles []ControllerHandler  // 因?yàn)榘虚g件 所以是多個(gè)集合
}
// 在請(qǐng)求邏輯處理的函數(shù)中，添加上我們的next循環(huán)處理中間件的方法
func (c Core) ServeHTTP(writer http.ResponseWriter, request *http.Request) {
	ctx := NewContext(request, writer)
	handlers := c.FindRouteByRequest(request)
	if handlers== nil {
		ctx.Json(404, "router not found ")
		return
	}
  // 先設(shè)置該core添加的中間件方便next去調(diào)用執(zhí)行
	ctx.SetHandler(handlers)
	if err:=ctx.Next();err!=nil{
		ctx.Json(500, "server Interval")
		return
	}
}

// 注冊(cè)Get方法
func (c *Core) Get(pattern string, handler ...ControllerHandler) {
    str :=""
	if 	strings.HasPrefix(pattern,"/"){
		strs:=strings.SplitN(pattern,"/",2)
		str=strs[1]
		log.Println("去除首字符/",str)
	}
	url := strings.ToUpper(str)
	allHandlers:=append(c.handles,handler...)
	log.Println("進(jìn)來了",url)
	if err := c.router[GET].AddRoute(url, allHandlers); err != nil {
		log.Fatal("add router error:", err)
	}
}

func (c *Core)Use(middlewares ...ControllerHandler){
   c.handles=middlewares
}

type Group struct {
   core   *Core //
   perfix string // 自身前綴
   handler []ControllerHandler
}
//IGroup 代表前綴分組
type IGroup interface {
	Get(string, ...ControllerHandler)
	Post(string, ...ControllerHandler)
	Delete(string, ...ControllerHandler)
	Put(string, ...ControllerHandler)
	Use(middlewares ...ControllerHandler)
}
// 獲得中間件集合
func (g Group)getMiddlewares()[]ControllerHandler{
	if g.handler==nil{
		g.handler=make([]ControllerHandler,0)
	}
	return g.handler
}
// 支持傳入多個(gè)中間件
func (g Group) Get(s string, handler ...ControllerHandler) {
	url := g.perfix + s
	allHandlers := append(g.getMiddlewares(), handler...)
	g.core.Get(url, allHandlers...)
}

func (g *Group)Use(middlewares ...ControllerHandler){
   g.handler=middlewares
}

// 代表節(jié)點(diǎn)
type node struct {
   isLast  bool              // 代表這個(gè)節(jié)點(diǎn)是否可以成為最終的路由規(guī)則。 該節(jié)點(diǎn)是否能成為一
   segment string            // url 中的字符串，代表這個(gè)節(jié)點(diǎn)表示的路由中某個(gè)段的字符串
   handler []ControllerHandler // 代表這個(gè)節(jié)點(diǎn)中包含的控制器，用于最終加載調(diào)用
   childes []*node           // 代表這個(gè)節(jié)點(diǎn)下的子節(jié)點(diǎn)
}

func (tree *Tree) AddRoute(url string, handler []ControllerHandler) error {<!--{C}%3C!%2D%2D%20%2D%2D%3E-->...}

type Context struct {
	Request        *http.Request
	ResponseWriter http.ResponseWriter
	hasTimeOut     bool // 是否超時(shí)標(biāo)記位
	writerMux      *sync.Mutex
	// 當(dāng)前請(qǐng)求的handler鏈條
	handlers []ControllerHandler
	index    int // 請(qǐng)求調(diào)用到的方法下標(biāo)   每執(zhí)行一個(gè)向后+1
}
/*
Next() 函數(shù)會(huì)在框架的兩個(gè)地方被調(diào)用：
這里要注意，index 下標(biāo)表示當(dāng)前調(diào)用 Next 要執(zhí)行的控制器序列，它的初始值應(yīng)該為-1，每次調(diào)用都會(huì)自增 1，這樣才能保證第一次調(diào)用的時(shí)候 index 為 0，定位到控制器鏈條的下標(biāo)為 0 的控制器，即第一個(gè)控制器。
在框架文件夾 context.go 的初始化 Context 函數(shù)中，代碼如下：
   第一個(gè)是在此次請(qǐng)求處理的入口處，即 Core 的 ServeHttp；
   第二個(gè)是在每個(gè)中間件的邏輯代碼中，用于調(diào)用下個(gè)中間件
*/
func (ctx *Context) Next() error {
   ctx.index++
   if ctx.index < len(ctx.handlers) {
      if err := ctx.handlers[ctx.index](ctx); err != nil {
         return err
      }
   }
   return nil
}
// 設(shè)置可可執(zhí)行方法
func (ctx *Context)SetHandler(fn []ControllerHandler){
	if ctx.handlers==nil{
		ctx.handlers=make([]ControllerHandler,0)
	}
	ctx.handlers=append(ctx.handlers,fn...)
}

// recovery機(jī)制，將協(xié)程中的函數(shù)異常進(jìn)行捕獲
func Recovery() framework.ControllerHandler { // 使用函數(shù)回調(diào)
   return func(c *framework.Context) error {
      // 核心在增加這個(gè)recover機(jī)制，捕獲c.Next()出現(xiàn)的panic
      defer func() {
         if err := recover(); err != nil {
            c.Json(500, err)
         }
      }()
      // 使用next執(zhí)行具體的業(yè)務(wù)邏輯
      c.Next()
      return nil
   }
}
// 例子1
func Test1()framework.ControllerHandler{
	return func(c *framework.Context) error {
		log.Println("middleware test1")
		c.Next()
		log.Println("middleware end test1")
		return nil
	}
}
// 例子2
func Test2()framework.ControllerHandler{
	return func(c *framework.Context) error {
		log.Println("middleware test2")
		c.Next()
		log.Println("middleware end test2")
		return nil
	}
}

func registerRouter(core *framework.Core) {
   print(111)
   // 設(shè)置控制器
   core.Use(middleware.Recovery())
   core.Get("/foo", FooController)
   core.Get("/user/login", framework.TimeOutController(UserLoginController,time.Second*2))
   core.Use(
      middleware.Test1(),
      middleware.Test2(),
   )
   subjectApi := core.Group("/subject")
   subjectApi.Use(middleware.Test2())
   {
      subjectApi.Get("/list/all", SubjectListController)
      subjectApi.Post("/add", SubjectListController)
      subjectApi.Delete("/:id", SubjectListController)
      subjectApi.Put("/:id", SubjectListController)
      subjectApi.Get("/:id", SubjectListController)
   }
}