From 6597287fc412ce914aba41fe571ed05817cf371c Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期一, 27 五月 2024 11:34:58 +0800
Subject: [PATCH] fix script
---
rule/service.go | 39 +++++++++++++++++++++++++++++++++++++++
1 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/rule/service.go b/rule/service.go
index 6294c83..c77e096 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,6 +31,42 @@
// 鎵ц绋嬪簭鍏ュ彛
func ExecuteTask() {
+ //杩涘嚭寮傚父甯冩帶浠诲姟锛屾殏鏃跺綊绫诲埌鏍囩璁＄畻閮ㄥ垎
+ 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 {
--
Gitblit v1.8.0