From d6a49ae26c8723d737e36d1ee544b2edafdae501 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期日, 26 五月 2024 18:51:15 +0800
Subject: [PATCH] 添加布控模块，合并person_status和snapshot_count_summary数据库等
---
rule/service.go | 41 ++++++++++++++++++++++++++++++++++++++++-
1 files changed, 40 insertions(+), 1 deletions(-)
diff --git a/rule/service.go b/rule/service.go
index 6294c83..1323d28 100644
--- a/rule/service.go
+++ b/rule/service.go
@@ -3,8 +3,11 @@
import (
"basic.com/valib/logger.git"
"fmt"
+ "ruleModelEngine/config"
"ruleModelEngine/data"
"ruleModelEngine/db"
+ "ruleModelEngine/task"
+ "strconv"
)
//
@@ -28,7 +31,43 @@
// 鎵ц绋嬪簭鍏ュ彛
func ExecuteTask() {
- //return
+ //杩涘嚭寮傚父甯冩帶浠诲姟锛屾殏鏃跺綊绫诲埌鏍囩璁＄畻閮ㄥ垎
+ fmt.Println("杩涘嚭寮傚父寮�濮嬪叆鍙ｏ紒锛侊紒锛侊紒锛�")
+ tasks, err := db.GetAllTaskData()
+ if err != nil {
+ logger.Error("GetAllTaskData Error", err)
+ }
+ var tkInfo db.Task
+ for _, taskInfo := range tasks {
+ if taskInfo.Name == "杩涘嚭寮傚父" {
+ tkInfo.Id = taskInfo.Id
+ tkInfo.Name = taskInfo.Name
+ }
+ }
+ fmt.Println("tkInfo: ", tkInfo)
+ days := config.Api.AInterval
+ docNumIdMap, err := db.QueryLastIdByDayRange(days, days-1)
+ if err != nil {
+ logger.Error("QueryByDayRange err: ", err)
+ }
+ fmt.Println("docNumIdMap: ", len(docNumIdMap))
+ for docNumber, id := range docNumIdMap {
+ fmt.Println(docNumber, id)
+ alarmRules := make([]db.AlarmRule, 0)
+ flag := task.EnteringButNotLeaving(docNumber, id, days)
+ if flag == true {
+ alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(tkInfo.Id), RuleText: tkInfo.Name, AlarmLevel: "0"})
+ }
+ addFlag, err := db.AddAlarmRules(alarmRules, id)
+ if err != nil {
+ logger.Error("AddAlarmRules err: ", err)
+ }
+ if addFlag == true {
+ logger.Info("AddAlarmRules success: ", id)
+ }
+ }
+
+ return
ruleInfo, err := db.GetAllData()
if err != nil {
logger.Error("GetAllData Error", err)
--
Gitblit v1.8.0