jackyu66gitandClaude Opus 4.6
b7767c95ae
- 新增OKX WebSocket行情连接器，扩展4交易所价格监控 - 新增z-score趋势检测引擎(TrendDetector)，识别价格异动/趋势启动 - 新增累积变动跟踪(CumulativeTracker)，基于1min/5min多交易所共识 - 趋势事件和累积变动事件持久化到SQLite - 新增Binance/OKX动量检测字段，扩展前端动量卡片至15列 - 迁移至macOS(darwin-arm64)，更新前端依赖 - Dashboard网格重构：非交易卡片置顶，交易卡片置底 - TrackedCoin添加OK字段，添加ExBinance/ExOKX常量 - 前端新增趋势检测卡片、趋势历史卡片、累积变动卡片 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
61 lines
2.1 KiB
Go
61 lines
2.1 KiB
Go
package db
|
|
|
|
import (
|
|
"time"
|
|
)
|
|
|
|
// TrendEventRecord represents a persisted trend state transition.
|
|
type TrendEventRecord struct {
|
|
ID int64 `json:"id"`
|
|
Coin string `json:"coin"`
|
|
PrevState string `json:"prev_state"`
|
|
NewState string `json:"new_state"`
|
|
Direction string `json:"direction"`
|
|
ZScore float64 `json:"z_score"`
|
|
Volatility float64 `json:"volatility"`
|
|
BGChange float64 `json:"bg_change"`
|
|
HLChange float64 `json:"hl_change"`
|
|
BNChange float64 `json:"bn_change"`
|
|
OKXChange float64 `json:"okx_change"`
|
|
ExAgree int `json:"ex_agree"`
|
|
ExTotal int `json:"ex_total"`
|
|
CreatedAt string `json:"created_at"`
|
|
}
|
|
|
|
// InsertTrendEvent saves a trend event to the database.
|
|
func (d *DB) InsertTrendEvent(coin, prevState, newState, direction string, zScore, volatility, bgChange, hlChange, bnChange, okxChange float64, exAgree, exTotal int) error {
|
|
_, err := d.Exec(`
|
|
INSERT INTO trend_events (coin, prev_state, new_state, direction, z_score, volatility, bg_change, hl_change, bn_change, okx_change, ex_agree, ex_total, created_at)
|
|
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
|
|
coin, prevState, newState, direction, zScore, volatility, bgChange, hlChange, bnChange, okxChange, exAgree, exTotal, Now().Format(time.RFC3339))
|
|
return err
|
|
}
|
|
|
|
// GetTrendEvents returns trend events ordered by creation time descending.
|
|
func (d *DB) GetTrendEvents(limit int) ([]TrendEventRecord, error) {
|
|
if limit <= 0 {
|
|
limit = 100
|
|
}
|
|
rows, err := d.Query(`
|
|
SELECT id, coin, prev_state, new_state, direction, z_score, volatility, bg_change, hl_change, bn_change, okx_change, ex_agree, ex_total, created_at
|
|
FROM trend_events
|
|
ORDER BY created_at DESC
|
|
LIMIT ?`, limit)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
|
|
var result []TrendEventRecord
|
|
for rows.Next() {
|
|
var r TrendEventRecord
|
|
if err := rows.Scan(&r.ID, &r.Coin, &r.PrevState, &r.NewState, &r.Direction,
|
|
&r.ZScore, &r.Volatility, &r.BGChange, &r.HLChange, &r.BNChange, &r.OKXChange,
|
|
&r.ExAgree, &r.ExTotal, &r.CreatedAt); err != nil {
|
|
return nil, err
|
|
}
|
|
result = append(result, r)
|
|
}
|
|
return result, rows.Err()
|
|
}
|