fix script

sunty

2024-05-27 6597287fc412ce914aba41fe571ed05817cf371c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package task
 
import (
    "basic.com/valib/logger.git"
    "ruleModelEngine/config"
    "ruleModelEngine/db"
    "strconv"
    "time"
)
 
func TaskAnalysisService(id string) {
    //fmt.Println("布控入口")
    alarmRules := make([]db.AlarmRule, 0)
    time.Sleep(time.Millisecond * 1)
    var taskPerson db.TaskPerson
    var err error
    for i := 0; i <= 2; i++ {
        taskPerson, err = db.QueryById(id)
        if err != nil {
            logger.Error("QueryById Error", err)
        }
        if taskPerson.Id != "" {
            break
        }
        time.Sleep(time.Second * 1)
    }
    //fmt.Println("personInfo: ", taskPerson)
    //fmt.Println("device: ", cache.Device)
    tasks, err := db.GetAllTaskData()
    if err != nil {
        logger.Error("GetAllTaskData Error", err)
    }
    //fmt.Println(tasks)
 
    for _, task := range tasks {
        switch task.Name {
        case "未成年出顶楼":
            flag := UnderageClimbingToRooftop(taskPerson)
            if flag == true {
                alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            }
        case "未成年入商住楼":
            flag := UnderageEnteringCommercialBuilding(taskPerson)
            if flag == true {
                alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            }
        case "窜楼":
            flag := ClimbingFloorsIllegally(taskPerson, config.Api.CsHours, config.Api.CsTimes)
            if flag == true {
                alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            }
        case "进出异常":
            continue
            //days := config.Api.AInterval
            //docNumIdMap, err := db.QueryLastIdByDayRange(days, days-1)
            //if err != nil {
            //    logger.Error("QueryByDayRange err: ", err)
            //}
            //
            //for docNumber, id := range docNumIdMap {
            //    flag := EnteringButNotLeaving(docNumber, id, days)
            //    alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            //
            //    if flag == true {
            //        alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            //    }
            //}
 
        case "申住不一":
            flag := registeredAddressNotMatchActualResidence(taskPerson)
            if flag == true {
                alarmRules = append(alarmRules, db.AlarmRule{RuleId: strconv.Itoa(task.Id), RuleText: task.Name, AlarmLevel: "0"})
            }
        default:
            continue
 
        }
    }
    addFlag, err := db.AddAlarmRules(alarmRules, id)
    if err != nil {
        logger.Error("AddAlarmRules err: ", err)
    }
    if addFlag == true {
        logger.Info("AddAlarmRules success: ", id)
    }
 
}