parent
36e000b988
commit
4b21874251
|
@ -58,7 +58,7 @@ func nodataJudge() {
|
||||||
nodataJob.Acquire()
|
nodataJob.Acquire()
|
||||||
go AsyncJudge(nodataJob, stra, stra.Exprs, []*dataobj.HistoryData{}, judgeItem, now, []dataobj.History{}, "", "", "", []bool{})
|
go AsyncJudge(nodataJob, stra, stra.Exprs, []*dataobj.HistoryData{}, judgeItem, now, []dataobj.History{}, "", "", "", []bool{})
|
||||||
}
|
}
|
||||||
return
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, data := range respData {
|
for _, data := range respData {
|
||||||
|
|
|
@ -143,7 +143,7 @@ func popEvent(queues []interface{}) (*model.Event, bool) {
|
||||||
|
|
||||||
groups, err := json.Marshal(stra.NotifyGroup)
|
groups, err := json.Marshal(stra.NotifyGroup)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Errorf("users marshal failed, err: %v, event: %+v", err, event)
|
logger.Errorf("groups marshal failed, err: %v, event: %+v", err, event)
|
||||||
return nil, false
|
return nil, false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue