phyer/core
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

max add Timestamp

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-17 16:55:23 +08:00
parent 86b595e00d
commit ee2e50aed3
1 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
maX.go
View File

@ -18,14 +18,15 @@ type MaXList struct {
} }
type MaX struct { type MaX struct {
InstID string `json:"instID"` InstID string `json:"instID"`
Period string `json:"period"` Period string `json:"period"`
KeyName string `json:"keyName"` Timestamp time.Time `json:"timestamp"`
Data []interface{} `json:"data"` KeyName string `json:"keyName"`
Count int `json:"count,number"` Data []interface{} `json:"data"`
Ts int64 `json:"ts,number"` Count int `json:"count,number"`
AvgVal float64 `json:"avgVal,number"` Ts int64 `json:"ts,number"`
From string `json:"from,string"` AvgVal float64 `json:"avgVal,number"`
From string `json:"from,string"`
} }
type WillMX struct { type WillMX struct {
@ -35,6 +36,7 @@ type WillMX struct {
func (mx MaX) SetToKey(cr *Core) ([]interface{}, error) { func (mx MaX) SetToKey(cr *Core) ([]interface{}, error) {
// fmt.Println(utils.GetFuncName(), " step1 ", mx.InstID, " ", mx.Period) // fmt.Println(utils.GetFuncName(), " step1 ", mx.InstID, " ", mx.Period)
mx.Timestamp, _ = Int64ToTime(mx.Ts)
cstr := strconv.Itoa(mx.Count) cstr := strconv.Itoa(mx.Count)
tss := strconv.FormatInt(mx.Ts, 10) tss := strconv.FormatInt(mx.Ts, 10)
//校验时间戳是否合法 //校验时间戳是否合法
@ -71,6 +73,20 @@ func (mx MaX) SetToKey(cr *Core) ([]interface{}, error) {
return mx.Data, err return mx.Data, err
} }
func Int64ToTime(ts int64) (time.Time, error) {
timestamp := int64(ts)
// 将时间戳转换为 time.Time 类型，单位为秒
t := time.Unix(timestamp/1000, (timestamp%1000)*int64(time.Millisecond))
// 获取东八区（北京时间）的时区信息
loc, err := time.LoadLocation("Asia/Shanghai")
if err != nil {
fmt.Println("加载时区失败:", err)
return t, err
}
// 将时间转换为东八区时间
t = t.In(loc)
return t, nil
}
func (mx *MaX) PushToWriteLogChan(cr *Core) error { func (mx *MaX) PushToWriteLogChan(cr *Core) error {
s := strconv.FormatFloat(float64(mx.Ts), 'f', 0, 64) s := strconv.FormatFloat(float64(mx.Ts), 'f', 0, 64)
did := mx.InstID + mx.Period + s did := mx.InstID + mx.Period + s