hanfuit
645b64fe21
服务端（Go）： - GM 塞背包/带属性装备发放：在线角色推送 op14 增量物品行，背包实时刷新，无需回角色选择界面 - GM 改金币/改等级：去掉在线拒绝，落库后推送 op14 钱包/op37 等级状态，在线实时刷新 - 等级端点统一切换到新版 GMSetCharacterLevel（自带在线刷新） - 无限/锁死疲劳模式 + 燃烧疲劳：每房间消耗 2 点、打怪与通关经验双倍 - 燃烧疲劳开关时给所有在线角色推送系统提示（op12 mode 0） - 深渊史诗掉率：GM 全局倍率 + 城镇增益药剂窗口倍率，真实接入掉落结算 启动器（Python/JS）： - 标题栏自绘、窗口 1204x717、禁止拖拽改大小、仅最小化/关闭 - GM 工具：疲劳与燃烧、深渊史诗掉率、拍卖行上架（单一定价对齐） - 拍卖行上架前端对齐服务端单一价格语义，修复 400 报错
136 lines
3.1 KiB
Go
136 lines
3.1 KiB
Go
package accountcenter
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"regexp"
|
|
"strings"
|
|
)
|
|
|
|
var (
|
|
ErrSQLDBRequired = errors.New("account center sql db is required")
|
|
ErrInvalidTable = errors.New("account center sql table is invalid")
|
|
)
|
|
|
|
const (
|
|
defaultSQLTable = "account_center_state"
|
|
sqlStateName = "default"
|
|
)
|
|
|
|
var sqlTablePattern = regexp.MustCompile(`^[A-Za-z0-9_]+$`)
|
|
|
|
type SQLStore struct {
|
|
db *sql.DB
|
|
stmts SQLStatements
|
|
}
|
|
|
|
type SQLOptions struct {
|
|
DB *sql.DB
|
|
Table string
|
|
}
|
|
|
|
type SQLStatements struct {
|
|
Table string
|
|
EnsureSchema string
|
|
Load string
|
|
Save string
|
|
}
|
|
|
|
func NewSQLStore(options SQLOptions) (*SQLStore, error) {
|
|
if options.DB == nil {
|
|
return nil, ErrSQLDBRequired
|
|
}
|
|
stmts, err := NewSQLStatements(options.Table)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &SQLStore{db: options.DB, stmts: stmts}, nil
|
|
}
|
|
|
|
func NewSQLStatements(table string) (SQLStatements, error) {
|
|
table, err := normalizeSQLTable(table)
|
|
if err != nil {
|
|
return SQLStatements{}, err
|
|
}
|
|
quoted := "`" + table + "`"
|
|
return SQLStatements{
|
|
Table: table,
|
|
EnsureSchema: fmt.Sprintf(`CREATE TABLE IF NOT EXISTS %s (
|
|
name VARCHAR(64) NOT NULL,
|
|
payload LONGTEXT NOT NULL,
|
|
updated_at TIMESTAMP(6) NOT NULL DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6),
|
|
PRIMARY KEY (name)
|
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4`, quoted),
|
|
Load: fmt.Sprintf(`SELECT payload FROM %s WHERE name=?`, quoted),
|
|
Save: fmt.Sprintf(`INSERT INTO %s (name, payload) VALUES (?, ?) ON DUPLICATE KEY UPDATE payload=VALUES(payload), updated_at=CURRENT_TIMESTAMP(6)`, quoted),
|
|
}, nil
|
|
}
|
|
|
|
func (s *SQLStore) EnsureSchema(ctx context.Context) error {
|
|
if err := ctxErr(ctx); err != nil {
|
|
return err
|
|
}
|
|
if s == nil || s.db == nil {
|
|
return ErrSQLDBRequired
|
|
}
|
|
_, err := s.db.ExecContext(ctx, s.stmts.EnsureSchema)
|
|
return err
|
|
}
|
|
|
|
func (s *SQLStore) Load(ctx context.Context) (Export, bool, error) {
|
|
if err := ctxErr(ctx); err != nil {
|
|
return Export{}, false, err
|
|
}
|
|
if s == nil || s.db == nil {
|
|
return Export{}, false, ErrSQLDBRequired
|
|
}
|
|
var payload []byte
|
|
if err := s.db.QueryRowContext(ctx, s.stmts.Load, sqlStateName).Scan(&payload); err != nil {
|
|
if errors.Is(err, sql.ErrNoRows) {
|
|
return Export{}, false, nil
|
|
}
|
|
return Export{}, false, err
|
|
}
|
|
var exported Export
|
|
if err := json.Unmarshal(payload, &exported); err != nil {
|
|
return Export{}, false, err
|
|
}
|
|
return exported, true, nil
|
|
}
|
|
|
|
func (s *SQLStore) Save(ctx context.Context, exported Export) error {
|
|
if err := ctxErr(ctx); err != nil {
|
|
return err
|
|
}
|
|
if s == nil || s.db == nil {
|
|
return ErrSQLDBRequired
|
|
}
|
|
payload, err := json.Marshal(exported)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = s.db.ExecContext(ctx, s.stmts.Save, sqlStateName, payload)
|
|
return err
|
|
}
|
|
|
|
func (s *SQLStore) Close() error {
|
|
if s == nil || s.db == nil {
|
|
return nil
|
|
}
|
|
return s.db.Close()
|
|
}
|
|
|
|
func normalizeSQLTable(table string) (string, error) {
|
|
table = strings.TrimSpace(table)
|
|
if table == "" {
|
|
table = defaultSQLTable
|
|
}
|
|
if !sqlTablePattern.MatchString(table) {
|
|
return "", ErrInvalidTable
|
|
}
|
|
return table, nil
|
|
}
|