事件推送

panlei

2019-07-24 d0bc216665a6d53135641ff009014a02a3774dd9

 ruleserver/timeTicker.go

@@ -45,7 +45,7 @@
            for k, timeEle := range TimeEleList {
               if timeEle.N > 0 {
                  timeEle.N = timeEle.N - 1
                  logger.Error("-------------------------------------打印定时器元素当前值-----------------------------------------：", timeEle.N)
                  logger.Error("-------------------------------------打印定时器计数元素当前值-----------------------------------------：", timeEle.N)
               }
               if timeEle.GroupId != "" && timeEle.N == 0 {
                  // 说明是联动任务的时间窗口 到点儿了该销毁了,再来了再创建
@@ -66,7 +66,6 @@
   stopChan <- true
   TimeTicker()
}


// 判断是否符合定时器条件
func TimerAlarm(args *SdkDatas,groupId string,result bool) (string) {
@@ -134,6 +133,7 @@
   }
   return flagTime
}

// 结构体根据某字段排序
type SubList []*RuleResult