sign in
This commit is contained in:
		@@ -59,7 +59,7 @@ func (tag *Tag) Delete() error {
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (tag *Tag) Update() error {
 | 
			
		||||
func (tag *Tag) Update(name string) error {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
@@ -72,7 +72,22 @@ func (tag *Tag) Update() error {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer stmt.Close()
 | 
			
		||||
	_, err = stmt.Exec(tag.Name, tag.UpdatedAt, tag.ID)
 | 
			
		||||
	_, err = stmt.Exec(name, tag.UpdatedAt, tag.ID)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (tag *Tag) Get() error {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	err = db.QueryRow("SELECT * FROM tags WHERE id = ?", tag.ID).Scan(&tag.ID, &tag.Name, &tag.CreatedAt, &tag.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
 
 | 
			
		||||
@@ -15,8 +15,8 @@ type User struct {
 | 
			
		||||
	Email     string `json:"email"`
 | 
			
		||||
	CreatedAt string `json:"created_at"`
 | 
			
		||||
	UpdatedAt string `json:"updated_at"`
 | 
			
		||||
	password  string
 | 
			
		||||
	slat      string
 | 
			
		||||
	Password  string `json:"-"`
 | 
			
		||||
	Slat      string `json:"-"`
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (user *User) Create(name, email, password string) error {
 | 
			
		||||
@@ -25,8 +25,8 @@ func (user *User) Create(name, email, password string) error {
 | 
			
		||||
		return fmt.Errorf("name, email and password can not be empty")
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	user.slat = utils.RandomString(16)
 | 
			
		||||
	user.password = fmt.Sprintf("%x", md5.Sum([]byte(password+user.slat)))
 | 
			
		||||
	user.Slat = utils.RandomString(16)
 | 
			
		||||
	user.Password = fmt.Sprintf("%x", md5.Sum([]byte(password+user.Slat)))
 | 
			
		||||
	user.Name = name
 | 
			
		||||
	user.Email = email
 | 
			
		||||
	user.CreatedAt = time.Now().Format("2006-01-02 15:04:05")
 | 
			
		||||
@@ -45,7 +45,7 @@ func (user *User) Create(name, email, password string) error {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer stmt.Close()
 | 
			
		||||
	result, err := stmt.Exec(user.Name, user.Email, user.password, user.slat, user.CreatedAt, user.UpdatedAt)
 | 
			
		||||
	result, err := stmt.Exec(user.Name, user.Email, user.Password, user.Slat, user.CreatedAt, user.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
@@ -107,7 +107,7 @@ func (user *User) Get() error {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	err = db.QueryRow("SELECT name, email, created_at, updated_at FROM users WHERE id = ?", user.ID).Scan(&user.Name, &user.Email, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	err = db.QueryRow("SELECT id, name, email, password, slat, created_at, updated_at FROM users WHERE email = ?", user.ID).Scan(&user.ID, &user.Name, &user.Email, &user.Password, &user.Slat, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
@@ -141,19 +141,67 @@ func (user *User) GetAll() ([]User, error) {
 | 
			
		||||
	return users, nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (user *User) GetByEmail() error {
 | 
			
		||||
// 驗證用戶密碼
 | 
			
		||||
func (user *User) CheckPassword(password string) bool {
 | 
			
		||||
	return user.Password == fmt.Sprintf("%x", md5.Sum([]byte(password+user.Slat)))
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// 使用Email和Password驗證登錄
 | 
			
		||||
func (user *User) CheckLogin(email, password string) bool {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
		return false
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	err = db.QueryRow("SELECT id, name, email, created_at, updated_at FROM users WHERE email = ?", user.Email).Scan(&user.ID, &user.Name, &user.Email, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	err = db.QueryRow("SELECT id, name, email, password, slat, created_at, updated_at FROM users WHERE email = ?", email).Scan(&user.ID, &user.Name, &user.Email, &user.Password, &user.Slat, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
		return false
 | 
			
		||||
	}
 | 
			
		||||
	return nil
 | 
			
		||||
	if user.ID == 0 {
 | 
			
		||||
		fmt.Println("user not found")
 | 
			
		||||
		return false
 | 
			
		||||
	}
 | 
			
		||||
	if user.Password == "" {
 | 
			
		||||
		fmt.Println("password is empty")
 | 
			
		||||
		return false
 | 
			
		||||
	}
 | 
			
		||||
	if user.Password == fmt.Sprintf("%x", md5.Sum([]byte(password+user.Slat))) {
 | 
			
		||||
		return true
 | 
			
		||||
	}
 | 
			
		||||
	return false
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// 獲取用戶實體
 | 
			
		||||
func GetUserByEmail(email string) (user User, err error) {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	err = db.QueryRow("SELECT id, name, email, password, slat, created_at, updated_at FROM users WHERE email = ?", email).Scan(&user.ID, &user.Name, &user.Email, &user.Password, &user.Slat, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	return
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func QueryUserByEmail(email string) (user User, err error) {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	err = db.QueryRow("SELECT id, name, email, created_at, updated_at FROM users WHERE email = ?", email).Scan(&user.ID, &user.Name, &user.Email, &user.CreatedAt, &user.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	return
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func QueryUsers(page, pagesize int) (list []interface{}) {
 | 
			
		||||
 
 | 
			
		||||
@@ -3,11 +3,12 @@ package models
 | 
			
		||||
import (
 | 
			
		||||
	"log"
 | 
			
		||||
	"main/configs"
 | 
			
		||||
	"time"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
type Session struct {
 | 
			
		||||
	ID        int    `json:"id"`
 | 
			
		||||
	Name      string `json:"name"`
 | 
			
		||||
	ID        string `json:"id"`
 | 
			
		||||
	UserID    int    `json:"user_id"`
 | 
			
		||||
	CreatedAt string `json:"created_at"`
 | 
			
		||||
	UpdatedAt string `json:"updated_at"`
 | 
			
		||||
}
 | 
			
		||||
@@ -20,7 +21,7 @@ func (session *Session) Get() {
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	row := db.QueryRow("SELECT * FROM sessions WHERE id = ?", session.ID)
 | 
			
		||||
	err = row.Scan(&session.ID, &session.Name, &session.CreatedAt, &session.UpdatedAt)
 | 
			
		||||
	err = row.Scan(&session.ID, &session.UserID, &session.CreatedAt, &session.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
@@ -28,28 +29,25 @@ func (session *Session) Get() {
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (session *Session) Create() error {
 | 
			
		||||
	session.CreatedAt = time.Now().Format("2006-01-02 15:04:05")
 | 
			
		||||
	session.UpdatedAt = session.CreatedAt
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	stmt, err := db.Prepare("INSERT INTO sessions(name) values(?)")
 | 
			
		||||
	stmt, err := db.Prepare("INSERT INTO sessions (id, user_id, created_at, updated_at) VALUES (?, ?, ?, ?)")
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer stmt.Close()
 | 
			
		||||
	result, err := stmt.Exec(session.Name)
 | 
			
		||||
	_, err = stmt.Exec(session.ID, session.UserID, session.CreatedAt, session.UpdatedAt)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	id, err := result.LastInsertId()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	session.ID = int(id)
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
@@ -75,19 +73,20 @@ func (session *Session) Delete() error {
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (session *Session) Update() error {
 | 
			
		||||
	session.UpdatedAt = time.Now().Format("2006-01-02 15:04:05")
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	stmt, err := db.Prepare("UPDATE sessions SET name = ? WHERE id = ?")
 | 
			
		||||
	stmt, err := db.Prepare("UPDATE sessions SET user_id = ?, updated_at = ? WHERE id = ?")
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
	defer stmt.Close()
 | 
			
		||||
	_, err = stmt.Exec(session.Name, session.ID)
 | 
			
		||||
	_, err = stmt.Exec(session.UpdatedAt, session.UserID, session.ID)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return err
 | 
			
		||||
@@ -95,30 +94,30 @@ func (session *Session) Update() error {
 | 
			
		||||
	return nil
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func GetSessions() ([]Session, error) {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return nil, err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	rows, err := db.Query("SELECT id, name FROM sessions")
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return nil, err
 | 
			
		||||
	}
 | 
			
		||||
	defer rows.Close()
 | 
			
		||||
	sessions := []Session{}
 | 
			
		||||
	for rows.Next() {
 | 
			
		||||
		var session Session
 | 
			
		||||
		if err := rows.Scan(&session.ID, &session.Name); err != nil {
 | 
			
		||||
			log.Println(err)
 | 
			
		||||
			return nil, err
 | 
			
		||||
		}
 | 
			
		||||
		sessions = append(sessions, session)
 | 
			
		||||
	}
 | 
			
		||||
	return sessions, nil
 | 
			
		||||
}
 | 
			
		||||
//func GetSessions() ([]Session, error) {
 | 
			
		||||
//	db, err := configs.GetDB()
 | 
			
		||||
//	if err != nil {
 | 
			
		||||
//		log.Println(err)
 | 
			
		||||
//		return nil, err
 | 
			
		||||
//	}
 | 
			
		||||
//	defer db.Close()
 | 
			
		||||
//	rows, err := db.Query("SELECT id, name FROM sessions")
 | 
			
		||||
//	if err != nil {
 | 
			
		||||
//		log.Println(err)
 | 
			
		||||
//		return nil, err
 | 
			
		||||
//	}
 | 
			
		||||
//	defer rows.Close()
 | 
			
		||||
//	sessions := []Session{}
 | 
			
		||||
//	for rows.Next() {
 | 
			
		||||
//		var session Session
 | 
			
		||||
//		if err := rows.Scan(&session.ID, &session.Name); err != nil {
 | 
			
		||||
//			log.Println(err)
 | 
			
		||||
//			return nil, err
 | 
			
		||||
//		}
 | 
			
		||||
//		sessions = append(sessions, session)
 | 
			
		||||
//	}
 | 
			
		||||
//	return sessions, nil
 | 
			
		||||
//}
 | 
			
		||||
 | 
			
		||||
func GetSession(id int) (*Session, error) {
 | 
			
		||||
	db, err := configs.GetDB()
 | 
			
		||||
@@ -127,9 +126,9 @@ func GetSession(id int) (*Session, error) {
 | 
			
		||||
		return nil, err
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	row := db.QueryRow("SELECT id, name FROM sessions WHERE id = ?", id)
 | 
			
		||||
	row := db.QueryRow("SELECT id, user_id, created_at, updated_at FROM sessions WHERE id = ?", id)
 | 
			
		||||
	var session Session
 | 
			
		||||
	if err := row.Scan(&session.ID, &session.Name); err != nil {
 | 
			
		||||
	if err := row.Scan(&session.ID, &session.UserID, &session.CreatedAt, &session.UpdatedAt); err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return nil, err
 | 
			
		||||
	}
 | 
			
		||||
@@ -143,7 +142,7 @@ func QuerySessions(page, pagesize int) (list []interface{}) {
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
	defer db.Close()
 | 
			
		||||
	rows, err := db.Query("SELECT id, name FROM sessions LIMIT ?, ?", (page-1)*pagesize, pagesize)
 | 
			
		||||
	rows, err := db.Query("SELECT id, user_id, created_at, updated_at FROM sessions LIMIT ?, ?", (page-1)*pagesize, pagesize)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		log.Println(err)
 | 
			
		||||
		return
 | 
			
		||||
@@ -151,7 +150,7 @@ func QuerySessions(page, pagesize int) (list []interface{}) {
 | 
			
		||||
	defer rows.Close()
 | 
			
		||||
	for rows.Next() {
 | 
			
		||||
		var session Session
 | 
			
		||||
		if err := rows.Scan(&session.ID, &session.Name); err != nil {
 | 
			
		||||
		if err := rows.Scan(&session.ID, &session.UserID, &session.CreatedAt, &session.UpdatedAt); err != nil {
 | 
			
		||||
			log.Println(err)
 | 
			
		||||
			return
 | 
			
		||||
		}
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user