添加布控模块，合并person_status和snapshot_count_summary数据库等

sunty

2024-05-26 d6a49ae26c8723d737e36d1ee544b2edafdae501

 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)