|
| 1 | +package data |
| 2 | + |
| 3 | +type Alert struct { |
| 4 | + ID int64 |
| 5 | + TimeStamp int64 |
| 6 | + Symbol string |
| 7 | + Hash string |
| 8 | + Amount int64 |
| 9 | + AmountUsd int64 |
| 10 | + FromAddr string |
| 11 | + FromOwner string |
| 12 | + TomAddr string |
| 13 | + TomOwner string |
| 14 | +} |
| 15 | + |
| 16 | +func (al *Alert) Insert() error { |
| 17 | + statement := "insert into alert (time_stamp,symbol,hash,amount,amount_usd,from_addr,from_owner,to_addr,to_owner) values(?,?,?,?,?,?,?,?,?)" |
| 18 | + stmt, err := DB.Prepare(statement) |
| 19 | + if err != nil { |
| 20 | + Log.Debug(err) |
| 21 | + return err |
| 22 | + } |
| 23 | + defer stmt.Close() |
| 24 | + _, err = stmt.Exec(al.TimeStamp,al.Symbol,al.Hash,al.Amount,al.AmountUsd,al.FromAddr,al.FromOwner,al.TomAddr, al.TomOwner) |
| 25 | + if err != nil { |
| 26 | + if err != nil { |
| 27 | + Log.Debug(err) |
| 28 | + return err |
| 29 | + } |
| 30 | + } |
| 31 | + return nil |
| 32 | +} |
| 33 | + |
| 34 | +func GetAlertsByTimeStamp(symbol string, timestamp int64) []*Alert { |
| 35 | + statement := "select id,time_stamp,symbol,hash,amount,amount_usd,from_addr,from_owner,to_addr,to_owner from alert where symbol=? and time_stamp>=? order by time_stamp" |
| 36 | + stmt, err := DB.Prepare(statement) |
| 37 | + if err != nil { |
| 38 | + Log.Debug(err) |
| 39 | + return nil |
| 40 | + } |
| 41 | + defer stmt.Close() |
| 42 | + rows, err := stmt.Query(symbol, timestamp) |
| 43 | + if err != nil { |
| 44 | + Log.Debug(err) |
| 45 | + return nil |
| 46 | + } |
| 47 | + defer rows.Close() |
| 48 | + re := make([]*Alert,0) |
| 49 | + for rows.Next() { |
| 50 | + al := &Alert{} |
| 51 | + err = rows.Scan(&al.ID, &al.TimeStamp, &al.Symbol, &al.Hash, &al.Amount, &al.AmountUsd, &al.FromAddr, &al.FromOwner, &al.TomAddr, &al.TomOwner) |
| 52 | + if err != nil { |
| 53 | + Log.Debug(err) |
| 54 | + return nil |
| 55 | + } |
| 56 | + re = append(re, al) |
| 57 | + } |
| 58 | + return re |
| 59 | +} |
| 60 | + |
| 61 | +func DeleteAlert(timestamp int64) { |
| 62 | + statement := "delete from alert where time_stamp < ?" |
| 63 | + stmt, err := DB.Prepare(statement) |
| 64 | + if err != nil { |
| 65 | + Log.Debug(err) |
| 66 | + return |
| 67 | + } |
| 68 | + defer stmt.Close() |
| 69 | + res, err := stmt.Exec(timestamp) |
| 70 | + if err != nil { |
| 71 | + Log.Debug(err) |
| 72 | + return |
| 73 | + } |
| 74 | + rows, _ := res.RowsAffected() |
| 75 | + Log.Debug("delete success, rows affect", rows) |
| 76 | +} |
| 77 | + |
0 commit comments