package controller

import (
	"fmt"
	"gitee.com/zhucheer/orange/app"
	"gitee.com/zhucheer/orange/captcha"
	"gitee.com/zhucheer/orange/cfg"
	"gitee.com/zhucheer/orange/database"
	"time"
)

func Welcome(c *app.Context) error {
	appName := cfg.GetString("app.name", "")
	return c.ToString("orange is a fast api framework-->" + appName)
}

func Welcome2(c *app.Context) error {
	size := c.GetPathParamToInt("size")
	fmt.Println(size)
	c.ResponseHeader().Set("Content-Type", "application/text")
	fmt.Println("session", c.Session().Get("test"))
	return c.ToString("orange is a fast api framework2")
}

func ViewShow(c *app.Context) error {
	c.AddIncludeTmpl("baseStyle")
	c.ShareAssign("shareIndex", "全局共享变量")

	showData := struct {
		Desc     string
		Title    string
		Status   int
		OpStatus int
		ItemArr  []int
	}{
		Title:    "title new",
		Desc:     "fast api framework <a href='#'>link</a>",
		Status:   1,
		OpStatus: 5,
		ItemArr:  []int{1, 2, 3, 4, 5},
	}
	return c.ViewHtml("home.index", showData, map[string]interface{}{"orange": "orange is sweet"})
}

func CsrfToken(c *app.Context) error {

	c.ResponseHeader().Set("Content-Type", "application/text")

	return c.ToString(c.CsrfToken)
}

func AppDefer(c *app.Context) error {
	stopSig := make(chan app.StopSignal, 1)
	go app.ListenStop(stopSig)

	go func() {
		select {
		case <-stopSig:
			fmt.Println("stopSign====>")
		}
	}()

	go app.ExitWaitFunDo(func() {
		for i := 0; i < 20; i++ {
			fmt.Println("===>", i)
			time.Sleep(time.Second)
		}
	})

	app.AppDefer(func() {
		fmt.Println("app defer controller do")
		time.Sleep(10 * time.Second)
		fmt.Println("app defer controller done")
	})

	return c.ToString("orange app shutdown wait proc done")
}

func AuthCheck(c *app.Context) error {

	return c.ToJson(map[string]interface{}{
		"auth": "auth is ok",
	})
}

func Test(c *app.Context) error {

	req := struct {
		VideoLink string `json:"videoLink"`
	}{}
	err := c.ParseForm(&req)

	fmt.Println(req)
	if err != nil {
		return c.ToJson(map[string]interface{}{
			"msg": "参数解析错误",
		})
	}
	return c.ToJson(map[string]interface{}{
		"test": "123",
	})
}

func ShowFile(c *app.Context) error {
	return c.ToFile("./storage/sim.sql", "")
}

func ShowImage(c *app.Context) error {
	return c.ToImage("./storage/logo.png")
}

func UploadForm(c *app.Context) error {

	return c.ViewHtml("fileForm")
}

func Upload(c *app.Context) error {
	req := struct {
		Iou int `json:"iou"`
	}{}
	c.ShouldBind(&req)

	fmt.Println(req)

	data, err := c.AppUploadToData("usfile")

	if err != nil {
		return c.ToString(err.Error())
	}
	fmt.Println(data.FileByte)

	if err != nil {
		return c.ToString(err.Error())
	}

	return c.ToJson(map[string]interface{}{
		"info": "upload success",
		"path": data.FileName,
	})
}

func Captcha(c *app.Context) error {
	return captcha.CaptchaImgShow(c, 4, 200, 70)
}

func CaptchaCode(c *app.Context) error {
	text, imgByte := captcha.CaptchaImgByte(c, 4)

	fmt.Println(text, imgByte)

	return c.ToString(text)

}

func VerifyImg(c *app.Context) error {
	code := c.Request().FormValue("code")

	fmt.Println(code)

	ret := captcha.CaptchaVerify(c, code)

	return c.ToJson(map[string]interface{}{
		"result": ret,
	})
}

type WxUsers struct {
	ID   uint   `gorm:"primary_key"`
	Name string `gorm:"nick_name"`
} // 默认表名是`users`
func SelectMySql(c *app.Context) error {
	db, put, err := database.GetMysql("default")
	defer func() {
		fmt.Println("put conn====>")
		database.PutConn(put)
	}()

	if err != nil {
		fmt.Println("db connect error", err)
		return nil
	}

	info := &WxUsers{}
	db.Table("qi_user").Where("id > ?", "1").First(&info)
	fmt.Println("db find====")

	return c.ToJson(map[string]interface{}{
		"result": "select success",
	})
}

func SelectMongo(c *app.Context) error {
	db, put, err := database.GetMongo("default")
	if err != nil {
		fmt.Println("db connect error", err)
		return nil
	}
	defer put()

	fmt.Println(db.Name)
	fmt.Println(db.C("user").Count())
	return c.ToString("mongo select")
}

func SelectRedis(c *app.Context) error {
	db, put, err := database.GetRedis("default")
	if err != nil {
		fmt.Println("db connect error", err)
		return nil
	}
	defer put()

	db.Do("SET", "tttx", "rrrrr")

	return c.ToJson(map[string]interface{}{
		"result": "select success",
	})
}