92 lines
2.0 KiB
Go
92 lines
2.0 KiB
Go
package scoresaber
|
|
|
|
import (
|
|
"log"
|
|
"time"
|
|
|
|
"git.lxtend.com/qqbot/sqlite3"
|
|
"git.lxtend.com/qqbot/util"
|
|
"github.com/gorilla/websocket"
|
|
)
|
|
|
|
const wsURL = "wss://scoresaber.com/ws"
|
|
|
|
var ScoresManager = scoresManager{}
|
|
|
|
type scoresManager struct {
|
|
conn *websocket.Conn
|
|
retryTimes int
|
|
}
|
|
|
|
func init() {
|
|
for err := ScoresManager.connect(); err != nil; err = ScoresManager.connect() {
|
|
log.Print("连接 WebSocket 失败:", err)
|
|
time.Sleep(time.Second)
|
|
}
|
|
util.AddCycleTask("cleanOldScores", 0, 1*time.Hour, cleanOldScores)
|
|
}
|
|
|
|
func (sm *scoresManager) connect() error {
|
|
var err error
|
|
sm.conn, _, err = websocket.DefaultDialer.Dial(wsURL, nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
sm.retryTimes = 0
|
|
go sm.receiveData()
|
|
return nil
|
|
}
|
|
|
|
func (sm *scoresManager) receiveData() {
|
|
defer func() {
|
|
for err := ScoresManager.connect(); err != nil; err = ScoresManager.connect() {
|
|
log.Printf("连接 WebSocket 失败:%v", err)
|
|
time.Sleep(time.Second)
|
|
}
|
|
}()
|
|
for {
|
|
var cmd Command
|
|
err := sm.conn.ReadJSON(&cmd)
|
|
if err != nil {
|
|
log.Print("读取数据失败:", err)
|
|
time.Sleep(time.Second)
|
|
sm.retryTimes++
|
|
if sm.retryTimes > 3 {
|
|
return
|
|
}
|
|
continue
|
|
}
|
|
SSQuery.SaveRecord(cmd.CommandData)
|
|
}
|
|
}
|
|
|
|
func (sm *scoresManager) GetRecentScores(count int, predict string) []RecordDataLite {
|
|
db := sqlite3.GetDB() // 假设 sqlite3.GetDB() 返回 *sqlx.DB
|
|
scoresCopy := make([]RecordDataLite, 0, count)
|
|
|
|
query := "SELECT * FROM ssRecordData"
|
|
if predict != "" {
|
|
query += " " + predict
|
|
}
|
|
query += " ORDER BY generated_time DESC LIMIT ?"
|
|
|
|
err := db.Select(&scoresCopy, query, count)
|
|
if err != nil {
|
|
log.Print(err)
|
|
return nil
|
|
}
|
|
|
|
return scoresCopy
|
|
}
|
|
|
|
func cleanOldScores() {
|
|
//清除>1天前且未绑定ss的记录
|
|
//1.获取所有绑定ss
|
|
//2.获取所有>1天前的记录
|
|
//3.删除未绑定ss的记录
|
|
db := sqlite3.GetDB()
|
|
ssBind := make([]string, 0)
|
|
db.Select(&ssBind, "SELECT ssid FROM ssBind")
|
|
db.Exec("DELETE FROM ssRecordData WHERE generated_time < ? AND ssid NOT IN (?)", time.Now().AddDate(0, 0, -1).Unix(), ssBind)
|
|
}
|