49 lines
1.2 KiB
Go
49 lines
1.2 KiB
Go
package storage
|
|
|
|
import (
|
|
"database/sql"
|
|
"log"
|
|
"strings"
|
|
"synlotto-website/models"
|
|
)
|
|
|
|
func InsertThunderballResult(db *sql.DB, res models.ThunderballResult) error {
|
|
stmt := `
|
|
INSERT INTO results_thunderball (
|
|
draw_date, machine, ballset,
|
|
ball1, ball2, ball3, ball4, ball5, thunderball
|
|
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);`
|
|
|
|
_, err := db.Exec(stmt,
|
|
res.DrawDate, res.Machine, res.Ballset,
|
|
res.Ball1, res.Ball2, res.Ball3, res.Ball4, res.Ball5, res.Thunderball,
|
|
)
|
|
if err != nil {
|
|
if strings.Contains(err.Error(), "UNIQUE constraint failed") {
|
|
log.Printf("⚠️ Draw for %s already exists. Skipping insert.\n", res.DrawDate)
|
|
return nil
|
|
}
|
|
log.Println("❌ InsertThunderballResult error:", err)
|
|
}
|
|
return err
|
|
}
|
|
|
|
func InsertMyTicket(db *sql.DB, ticket models.MyTicket) error {
|
|
stmt := `
|
|
INSERT INTO my_tickets (
|
|
game_type, draw_date,
|
|
ball1, ball2, ball3, ball4, ball5,
|
|
bonus1, bonus2
|
|
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);`
|
|
|
|
_, err := db.Exec(stmt,
|
|
ticket.GameType, ticket.DrawDate,
|
|
ticket.Ball1, ticket.Ball2, ticket.Ball3, ticket.Ball4, ticket.Ball5,
|
|
ticket.Bonus1, ticket.Bonus2,
|
|
)
|
|
if err != nil {
|
|
log.Println("❌ InsertMyTicket error:", err)
|
|
}
|
|
return err
|
|
}
|