import (
	"fmt"
	"gorm.io/driver/mysql"
	"gorm.io/gorm"
	"os"
)

var db *gorm.DB

type DBConfig struct {
	DbUser     string
	DbPassword string
	DbName     string
	DbHost     string
	DbPort     string
}

func NewDBConfig() *DBConfig {
	return &DBConfig{
		DbUser:     os.Getenv("DB_USER"),
		DbPassword: os.Getenv("DB_PASSWORD"),
		DbName:     os.Getenv("DB_NAME"),
		DbHost:     os.Getenv("DB_HOST"),
		DbPort:     os.Getenv("DB_PORT"),
	}
}
func InitDB() {
	config := NewDBConfig()
	dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", config.DbUser, config.DbPassword, config.DbHost, config.DbPort, config.DbName)
	var err error
	db, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})
	if err != nil {
		panic("failed to connect database")
	}
}

func main() {
	//初始化連接池

	db.InitDB()
	// 創(chuàng)建路由

	r := gin.Default()

	r.POST("/register", func(c *gin.Context) {
		email := c.PostForm("email")
		username := c.PostForm("username")
		age, _ := strconv.Atoi(c.PostForm("age"))

		fmt.Println("email->"+email, "username->"+username+"age->", age)
		code, data := controller.RegisterUser(email, username, age)
		c.JSON(code, gin.H{"data": data})
	})

	// 運(yùn)行服務(wù)器
	r.Run(":8080")
}

package logic

import "easylive-user/db"

func RegisterUser(email string, username string, age int) (int, interface{}) {
	return db.AddUser(email, username, age)
}

package logic

import "easylive-user/db"

func RegisterUser(email string, username string, age int) (int, interface{}) {
	affected := db.AddUser(email, username, age)
	if affected >= 1 {
		return 200, nil
	} else {
		return 500, nil
	}
}

func AddUser(email string, username string, age int) int {
	result := db.Create(&User{Email: email, Name: username, Age: age})
	fmt.Println(result)
	return int(result.RowsAffected)

}

type User struct {
	id    int
	Name  string
	Email string
	Age   int
}