Lots of changes, still more to do
This commit is contained in:
21
services/admin/manualtriggers.go
Normal file
21
services/admin/manualtriggers.go
Normal file
@@ -0,0 +1,21 @@
|
||||
package services
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"synlotto-website/services"
|
||||
)
|
||||
|
||||
var db *sql.DB
|
||||
|
||||
func AdminMatchHandler(w http.ResponseWriter, r *http.Request) {
|
||||
stats, err := services.RunTicketMatching(db, "manual")
|
||||
if err != nil {
|
||||
http.Error(w, "Matching failed: "+err.Error(), 500)
|
||||
return
|
||||
}
|
||||
http.Redirect(w, r, "/admin?flash=Matched "+
|
||||
strconv.Itoa(stats.TicketsMatched)+" tickets, "+
|
||||
strconv.Itoa(stats.WinnersFound)+" winners.", http.StatusSeeOther)
|
||||
}
|
||||
90
services/ticketchecker.go
Normal file
90
services/ticketchecker.go
Normal file
@@ -0,0 +1,90 @@
|
||||
package services
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
"log"
|
||||
"synlotto-website/handlers"
|
||||
"synlotto-website/models"
|
||||
"synlotto-website/rules"
|
||||
)
|
||||
|
||||
func RunTicketMatching(db *sql.DB, triggeredBy string) (models.MatchRunStats, error) {
|
||||
stats := models.MatchRunStats{}
|
||||
|
||||
rows, err := db.Query(`
|
||||
SELECT id, game_type, draw_date, ball1, ball2, ball3, ball4, ball5, bonus1
|
||||
FROM my_tickets
|
||||
WHERE matched_draw_id IS NULL
|
||||
`)
|
||||
if err != nil {
|
||||
return stats, err
|
||||
}
|
||||
defer rows.Close()
|
||||
|
||||
for rows.Next() {
|
||||
var t models.Ticket
|
||||
var b1, b2, b3, b4, b5, bonus sql.NullInt64
|
||||
if err := rows.Scan(&t.ID, &t.GameType, &t.DrawDate, &b1, &b2, &b3, &b4, &b5, &bonus); err != nil {
|
||||
continue
|
||||
}
|
||||
|
||||
t.Balls = []int{int(b1.Int64), int(b2.Int64), int(b3.Int64), int(b4.Int64), int(b5.Int64)}
|
||||
if bonus.Valid {
|
||||
t.BonusBalls = []int{int(bonus.Int64)}
|
||||
} else {
|
||||
t.BonusBalls = nil
|
||||
}
|
||||
|
||||
draw := GetDrawResultForTicket(db, t.GameType, t.DrawDate)
|
||||
result := handlers.MatchTicketToDraw(t, draw, rules.ThunderballPrizeRules)
|
||||
|
||||
if result.MatchedDrawID == 0 {
|
||||
continue // no draw found
|
||||
}
|
||||
|
||||
_, err := db.Exec(`
|
||||
UPDATE my_tickets SET
|
||||
matched_draw_id = ?, matched_main = ?, matched_bonus = ?, prize_tier = ?, is_winner = ?
|
||||
WHERE id = ?`,
|
||||
result.MatchedDrawID, result.MatchedMain, result.MatchedBonus, result.PrizeTier, result.IsWinner, t.ID,
|
||||
)
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
|
||||
stats.TicketsMatched++
|
||||
if result.IsWinner {
|
||||
stats.WinnersFound++
|
||||
}
|
||||
}
|
||||
|
||||
_, _ = db.Exec(`
|
||||
INSERT INTO matching_log (triggered_by, tickets_matched, winners_found)
|
||||
VALUES (?, ?, ?)`,
|
||||
triggeredBy, stats.TicketsMatched, stats.WinnersFound,
|
||||
)
|
||||
|
||||
return stats, nil
|
||||
}
|
||||
|
||||
func GetDrawResultForTicket(db *sql.DB, game string, drawDate string) models.DrawResult {
|
||||
var result models.DrawResult
|
||||
query := `
|
||||
SELECT id, ball1, ball2, ball3, ball4, ball5, bonus1
|
||||
FROM results_thunderball
|
||||
WHERE draw_date = ?
|
||||
`
|
||||
var b1, b2, b3, b4, b5, bonus sql.NullInt64
|
||||
err := db.QueryRow(query, drawDate).Scan(&result.DrawID, &b1, &b2, &b3, &b4, &b5, &bonus)
|
||||
if err != nil {
|
||||
log.Printf("No draw found for %s %s: %v", game, drawDate, err)
|
||||
return result
|
||||
}
|
||||
result.GameType = game
|
||||
result.DrawDate = drawDate
|
||||
result.Balls = []int{int(b1.Int64), int(b2.Int64), int(b3.Int64), int(b4.Int64), int(b5.Int64)}
|
||||
if bonus.Valid {
|
||||
result.BonusBalls = []int{int(bonus.Int64)}
|
||||
}
|
||||
return result
|
||||
}
|
||||
Reference in New Issue
Block a user