|
@@ -404,7 +404,7 @@ func PrepareTimeWindowProducerQueue() {
|
|
|
lastTimeWindow := commonEntity.GetLastTimeWindow() // 获取最后一个时间窗口
|
|
|
var faultLabel string
|
|
|
for _, f := range masterConfig.RuleOfCicvLocation {
|
|
|
- faultLabel = f(data)
|
|
|
+ faultLabel = f(data, pjisuvParam)
|
|
|
if faultLabel != "" {
|
|
|
saveTimeWindow(faultLabel, faultHappenTime, lastTimeWindow)
|
|
|
break
|