fix: upgrade cbc message
This commit is contained in:
1 parent
de0b81ee01
commit
e0fa00bc05
4 files changed
+32
-5
No files matched your search
@@ -39,13 +39,13 @@ func (s *CBCMessage) SelectByPage(query model.CBCMessageQuery) ([]model.CBCMessa
|
||||
var startMicro, endMicro int64
|
||||
var err error
|
||||
if query.StartTime != "" {
|
||||
startMicro, err = parseTimeToMicro(query.StartTime)
|
||||
startMicro, err = parseTimeToMilli(query.StartTime)
|
||||
if err != nil {
|
||||
return nil, 0, fmt.Errorf("invalid start time: %w", err)
|
||||
}
|
||||
}
|
||||
if query.EndTime != "" {
|
||||
endMicro, err = parseTimeToMicro(query.EndTime)
|
||||
endMicro, err = parseTimeToMilli(query.EndTime)
|
||||
if err != nil {
|
||||
return nil, 0, fmt.Errorf("invalid end time: %w", err)
|
||||
}
|
||||
@@ -243,7 +243,7 @@ func (s *CBCMessage) SelectByNeId(neId string, msgs *[]model.CBCMessage) error {
|
||||
}
|
||||
|
||||
// 假设 query.StartTime 和 query.EndTime 是 "2006-01-02 15:04:05" 格式字符串
|
||||
func parseTimeToMicro(ts string) (int64, error) {
|
||||
func parseTimeToMilli(ts string) (int64, error) {
|
||||
if ts == "" {
|
||||
return 0, nil
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user