package main

import (
	"encoding/json"
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/thinkerou/favicon"
)

// 中間件（攔截器），功能：預(yù)處理，登錄授權(quán)、驗(yàn)證、分頁(yè)、耗時(shí)統(tǒng)計(jì)...
// func myHandler() gin.HandlerFunc {
// 	return func(ctx *gin.Context) {
// 		// 通過(guò)自定義中間件，設(shè)置的值，在后續(xù)處理只要調(diào)用了這個(gè)中間件的都可以拿到這里的參數(shù)
// 		ctx.Set("usersesion", "userid-1")
// 		ctx.Next()  // 放行
// 		ctx.Abort() // 阻止
// 	}
// }

func main() {
	// 創(chuàng)建一個(gè)服務(wù)
	ginServer := gin.Default()
	ginServer.Use(favicon.New("./Arctime.ico")) // 這里如果添加了東西然后再運(yùn)行沒(méi)有變化，請(qǐng)重啟瀏覽器，瀏覽器有緩存

	// 加載靜態(tài)頁(yè)面
	ginServer.LoadHTMLGlob("templates/*") // 一種是全局加載，一種是加載指定的文件

	// 加載資源文件
	ginServer.Static("/static", "./static")

	// 相應(yīng)一個(gè)頁(yè)面給前端

	ginServer.GET("/index", func(ctx *gin.Context) {
		ctx.HTML(http.StatusOK, "index.html", gin.H{
			"msg": "This data is come from Go background.",
		})
	})

	// 能加載靜態(tài)頁(yè)面也可以加載測(cè)試文件

	// 獲取請(qǐng)求中的參數(shù)

	// 傳統(tǒng)方式：usl?userid=xxx&username=conqueror712
	// Rustful方式：/user/info/1/conqueror712

	// 下面是傳統(tǒng)方式的例子
	ginServer.GET("/user/info", func(context *gin.Context) { // 這個(gè)格式是固定的
		userid := context.Query("userid")
		username := context.Query("username")
		// 拿到之后返回給前端
		context.JSON(http.StatusOK, gin.H{
			"userid":   userid,
			"username": username,
		})
	})
	// 此時(shí)執(zhí)行代碼之后，在瀏覽器中可以輸入http://localhost:8081/user/info?userid=111&username=666
	// 就可以看到返回了JSON格式的數(shù)據(jù)

	// 下面是Rustful方式的例子
	ginServer.GET("/user/info/:userid/:username", func(context *gin.Context) {
		userid := context.Param("userid")
		username := context.Param("username")
		// 還是一樣，返回給前端
		context.JSON(http.StatusOK, gin.H{
			"userid":   userid,
			"username": username,
		})
	})
	// 指定代碼后，只需要在瀏覽器中http://localhost:8081/user/info/111/555
	// 就可以看到返回了JSON數(shù)據(jù)了，非常方便簡(jiǎn)潔

	// 序列化
	// 前端給后端傳遞JSON
	ginServer.POST("/json", func(ctx *gin.Context) {
		// request.body
		data, _ := ctx.GetRawData()
		var m map[string]interface{} // Go語(yǔ)言中object一般用空接口來(lái)表示，可以接收anything
		// 順帶一提，1.18以上，interface可以直接改成any
		_ = json.Unmarshal(data, &m)
		ctx.JSON(http.StatusOK, m)
	})
	// 用apipost或者postman寫(xiě)一段json傳到localhost:8081/json里就可以了
	/*
		json示例：
		{
			"name": "Conqueror712",
			"age": 666,
			"address": "Mars"
		}
	*/
	// 看到后端的實(shí)時(shí)響應(yīng)里面接收到數(shù)據(jù)就可以了

	// 處理表單請(qǐng)求 這些都是支持函數(shù)式編程，Go語(yǔ)言特性，可以把函數(shù)作為參數(shù)傳進(jìn)來(lái)
	ginServer.POST("/user/add", func(ctx *gin.Context) {
		username := ctx.PostForm("username")
		password := ctx.PostForm("password")
		ctx.JSON(http.StatusOK, gin.H{
			"msg":      "ok",
			"username": username,
			"password": password,
		})
	})

	// 路由
	ginServer.GET("/test", func(ctx *gin.Context) {
		// 重定向 -> 301
		ctx.Redirect(301, "https://conqueror712.gitee.io/conqueror712.gitee.io/")
	})
	// http://localhost:8081/test

	// 404
	ginServer.NoRoute(func(ctx *gin.Context) {
		ctx.HTML(404, "404.html", nil)
	})

	// 路由組暫略

	// 服務(wù)器端口，用服務(wù)器端口來(lái)訪問(wèn)地址
	ginServer.Run(":8081") // 不寫(xiě)的話默認(rèn)是8080，也可以更改
}

$ go build -tags=jsoniter .

go get -u gorm.io/gorm
go get -u gorm.io/driver/sqlite

package main

import (
	"fmt"
	"time"

	// "gorm.io/driver/sqlite"
	"github.com/gin-gonic/gin"
	"gorm.io/driver/mysql"
	"gorm.io/gorm"
)

func main() {
	// 如何連接數(shù)據(jù)庫(kù) ? MySQL + Navicat
	// 需要更改的內(nèi)容：用戶名，密碼，數(shù)據(jù)庫(kù)名稱
	dsn := "root:BqV?eGcc_1o+@tcp(127.0.0.1:3306)/crud-list?charset=utf8mb4&parseTime=True&loc=Local"
	db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})

	fmt.Println("db = ", db)
	fmt.Println("err = ", err)

	// 連接池
	sqlDB, err := db.DB()
	// SetMaxIdleConns 設(shè)置空閑連接池中連接的最大數(shù)量
	sqlDB.SetMaxIdleConns(10)
	// SetMaxOpenConns 設(shè)置打開(kāi)數(shù)據(jù)庫(kù)連接的最大數(shù)量。
	sqlDB.SetMaxOpenConns(100)
	// SetConnMaxLifetime 設(shè)置了連接可復(fù)用的最大時(shí)間。
	sqlDB.SetConnMaxLifetime(10 * time.Second) // 10秒鐘

	// 結(jié)構(gòu)體
	type List struct {
		Name    string
		State   string
		Phone   string
		Email   string
		Address string
	}

	// 遷移
	db.AutoMigrate(&List{})

	// 接口
	r := gin.Default()

	// 端口號(hào)
	PORT := "3001"
	r.Run(":" + PORT)
}

`gorm:"type:varchar(20); not null" json:"name" binding:"required"`

// 測(cè)試
r.GET("/", func(c *gin.Context) {
	c.JSON(200, gin.H{
		"message": "請(qǐng)求成功",
	})
})

{
	"name" : "張三",
    "state" : "在職",
    "phone" : "13900000000",
    "email" : "6666@qq.com",
    "address" : "二仙橋成華大道"
}

{
    "code": "200",
    "data": {
        "ID": 1,
        "CreatedAt": "2023-01-24T09:27:36.73+08:00",
        "UpdatedAt": "2023-01-24T09:27:36.73+08:00",
        "DeletedAt": null,
        "name": "張三",
        "state": "在職",
        "phone": "13900000000",
        "email": "6666@qq.com",
        "address": "二仙橋成華大道"
    },
    "msg": "添加成功"
}

{
    "code": 200,
    "msg": "刪除成功"
}

{
    "code": 400,
    "msg": "id沒(méi)有找到，刪除失敗"
}

{
	"name" : "張三",
    "state" : "離職",
    "phone" : "13900000000",
    "email" : "6666@qq.com",
    "address" : "二仙橋成華大道"
}

{
    "code": 200,
    "msg": "修改成功"
}

{
    "code": "200",
    "data": [
        {
            "ID": 3,
            "CreatedAt": "2023-01-24T10:06:25.305+08:00",
            "UpdatedAt": "2023-01-24T10:06:25.305+08:00",
            "DeletedAt": null,
            "name": "王五",
            "state": "在職",
            "phone": "13100000000",
            "email": "8888@qq.com",
            "address": "八仙橋成華大道"
        }
    ],
    "msg": "查詢成功"
}

{
    "code": 200,
    "data": {
        "list": [
            {
                "ID": 3,
                "CreatedAt": "2023-01-24T10:06:25.305+08:00",
                "UpdatedAt": "2023-01-24T10:06:25.305+08:00",
                "DeletedAt": null,
                "name": "王五",
                "state": "在職",
                "phone": "13100000000",
                "email": "8888@qq.com",
                "address": "八仙橋成華大道"
            }
        ],
        "pageNum": 1,
        "pageSize": 2,
        "total": 2
    },
    "msg": "查詢成功"
}

{
    "code": 200,
    "data": {
        "list": [
            {
                "ID": 1,
                "CreatedAt": "2023-01-24T09:27:36.73+08:00",
                "UpdatedAt": "2023-01-24T09:55:20.351+08:00",
                "DeletedAt": null,
                "name": "張三",
                "state": "離職",
                "phone": "13900000000",
                "email": "6666@qq.com",
                "address": "二仙橋成華大道"
            },
            {
                "ID": 3,
                "CreatedAt": "2023-01-24T10:06:25.305+08:00",
                "UpdatedAt": "2023-01-24T10:06:25.305+08:00",
                "DeletedAt": null,
                "name": "王五",
                "state": "在職",
                "phone": "13100000000",
                "email": "8888@qq.com",
                "address": "八仙橋成華大道"
            }
        ],
        "pageNum": 0,
        "pageSize": 0,
        "total": 2
    },
    "msg": "查詢成功"
}

package main

import (
	"fmt"
	"strconv"
	"time"

	// "gorm.io/driver/sqlite"
	"github.com/gin-gonic/gin"
	"gorm.io/driver/mysql"
	"gorm.io/gorm"
	"gorm.io/gorm/schema"
)

func main() {
	// 如何連接數(shù)據(jù)庫(kù) ? MySQL + Navicat
	// 需要更改的內(nèi)容：用戶名，密碼，數(shù)據(jù)庫(kù)名稱
	dsn := "root:password@tcp(127.0.0.1:3306)/database?charset=utf8mb4&parseTime=True&loc=Local"
	db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{
		NamingStrategy: schema.NamingStrategy{
			SingularTable: true,
		},
	})

	fmt.Println("db = ", db)
	fmt.Println("err = ", err)

	// 連接池
	sqlDB, err := db.DB()
	// SetMaxIdleConns 設(shè)置空閑連接池中連接的最大數(shù)量
	sqlDB.SetMaxIdleConns(10)
	// SetMaxOpenConns 設(shè)置打開(kāi)數(shù)據(jù)庫(kù)連接的最大數(shù)量。
	sqlDB.SetMaxOpenConns(100)
	// SetConnMaxLifetime 設(shè)置了連接可復(fù)用的最大時(shí)間。
	sqlDB.SetConnMaxLifetime(10 * time.Second) // 10秒鐘

	// 結(jié)構(gòu)體
	type List struct {
		gorm.Model        // 主鍵
		Name       string `gorm:"type:varchar(20); not null" json:"name" binding:"required"`
		State      string `gorm:"type:varchar(20); not null" json:"state" binding:"required"`
		Phone      string `gorm:"type:varchar(20); not null" json:"phone" binding:"required"`
		Email      string `gorm:"type:varchar(40); not null" json:"email" binding:"required"`
		Address    string `gorm:"type:varchar(200); not null" json:"address" binding:"required"`
	}

	// 遷移
	db.AutoMigrate(&List{})

	// 接口
	r := gin.Default()

	// 測(cè)試
	// r.GET("/", func(c *gin.Context) {
	// 	c.JSON(200, gin.H{
	// 		"message": "請(qǐng)求成功",
	// 	})
	// })

	// 業(yè)務(wù)碼約定：正確200，錯(cuò)誤400

	// 增
	r.POST("/user/add", func(ctx *gin.Context) {
		// 定義一個(gè)變量指向結(jié)構(gòu)體
		var data List
		// 綁定方法
		err := ctx.ShouldBindJSON(&data)
		// 判斷綁定是否有錯(cuò)誤
		if err != nil {
			ctx.JSON(200, gin.H{
				"msg":  "添加失敗",
				"data": gin.H{},
				"code": "400",
			})
		} else {
			// 數(shù)據(jù)庫(kù)的操作
			db.Create(&data) // 創(chuàng)建一條數(shù)據(jù)
			ctx.JSON(200, gin.H{
				"msg":  "添加成功",
				"data": data,
				"code": "200",
			})
		}
	})

	// 刪
	// 1. 找到對(duì)應(yīng)的id對(duì)應(yīng)的條目
	// 2. 判斷id是否存在
	// 3. 從數(shù)據(jù)庫(kù)中刪除 or 返回id沒(méi)有找到

	// Restful編碼規(guī)范
	r.DELETE("/user/delete/:id", func(ctx *gin.Context) {
		var data []List
		// 接收id
		id := ctx.Param("id") // 如果有鍵值對(duì)形式的話用Query()
		// 判斷id是否存在
		db.Where("id = ? ", id).Find(&data)
		if len(data) == 0 {
			ctx.JSON(200, gin.H{
				"msg":  "id沒(méi)有找到，刪除失敗",
				"code": 400,
			})
		} else {
			// 操作數(shù)據(jù)庫(kù)刪除（刪除id所對(duì)應(yīng)的那一條）
			// db.Where("id = ? ", id).Delete(&data) <- 其實(shí)不需要這樣寫(xiě)，因?yàn)椴榈降膁ata里面就是要?jiǎng)h除的數(shù)據(jù)
			db.Delete(&data)

			ctx.JSON(200, gin.H{
				"msg":  "刪除成功",
				"code": 200,
			})
		}

	})

	// 改
	r.PUT("/user/update/:id", func(ctx *gin.Context) {
		// 1. 找到對(duì)應(yīng)的id所對(duì)應(yīng)的條目
		// 2. 判斷id是否存在
		// 3. 修改對(duì)應(yīng)條目 or 返回id沒(méi)有找到
		var data List
		id := ctx.Param("id")
		// db.Where("id = ?", id).Find(&data) 可以這樣寫(xiě)，也可以寫(xiě)成下面那樣
		// 還可以再Where后面加上Count函數(shù)，可以查出來(lái)這個(gè)條件對(duì)應(yīng)的條數(shù)
		db.Select("id").Where("id = ? ", id).Find(&data)
		if data.ID == 0 {
			ctx.JSON(200, gin.H{
				"msg":  "用戶id沒(méi)有找到",
				"code": 400,
			})
		} else {
			// 綁定一下
			err := ctx.ShouldBindJSON(&data)
			if err != nil {
				ctx.JSON(200, gin.H{
					"msg":  "修改失敗",
					"code": 400,
				})
			} else {
				// db修改數(shù)據(jù)庫(kù)內(nèi)容
				db.Where("id = ?", id).Updates(&data)
				ctx.JSON(200, gin.H{
					"msg":  "修改成功",
					"code": 200,
				})
			}
		}
	})

	// 查
	// 第一種：條件查詢，
	r.GET("/user/list/:name", func(ctx *gin.Context) {
		// 獲取路徑參數(shù)
		name := ctx.Param("name")
		var dataList []List
		// 查詢數(shù)據(jù)庫(kù)
		db.Where("name = ? ", name).Find(&dataList)
		// 判斷是否查詢到數(shù)據(jù)
		if len(dataList) == 0 {
			ctx.JSON(200, gin.H{
				"msg":  "沒(méi)有查詢到數(shù)據(jù)",
				"code": "400",
				"data": gin.H{},
			})
		} else {
			ctx.JSON(200, gin.H{
				"msg":  "查詢成功",
				"code": "200",
				"data": dataList,
			})
		}
	})

	// 第二種：全部查詢 / 分頁(yè)查詢
	r.GET("/user/list", func(ctx *gin.Context) {
		var dataList []List
		// 查詢?nèi)繑?shù)據(jù) or 查詢分頁(yè)數(shù)據(jù)
		pageSize, _ := strconv.Atoi(ctx.Query("pageSize"))
		pageNum, _ := strconv.Atoi(ctx.Query("pageNum"))

		// 判斷是否需要分頁(yè)
		if pageSize == 0 {
			pageSize = -1
		}
		if pageNum == 0 {
			pageNum = -1
		}

		offsetVal := (pageNum - 1) * pageSize // 固定寫(xiě)法 記住就行
		if pageNum == -1 && pageSize == -1 {
			offsetVal = -1
		}

		// 返回一個(gè)總數(shù)
		var total int64

		// 查詢數(shù)據(jù)庫(kù)
		db.Model(dataList).Count(&total).Limit(pageSize).Offset(offsetVal).Find(&dataList)

		if len(dataList) == 0 {
			ctx.JSON(200, gin.H{
				"msg":  "沒(méi)有查詢到數(shù)據(jù)",
				"code": 400,
				"data": gin.H{},
			})
		} else {
			ctx.JSON(200, gin.H{
				"msg":  "查詢成功",
				"code": 200,
				"data": gin.H{
					"list":     dataList,
					"total":    total,
					"pageNum":  pageNum,
					"pageSize": pageSize,
				},
			})
		}

	})

	// 端口號(hào)
	PORT := "3001"
	r.Run(":" + PORT)
}