From a5dec478e435f4fd1662c651c9904c0648da5655 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期四, 05 十二月 2019 19:44:46 +0800 Subject: [PATCH] ants协程数量100改为20 --- labelFilter/readyDataForLabel.go | 72 +++++++++++++++++------------------- 1 files changed, 34 insertions(+), 38 deletions(-) diff --git a/labelFilter/readyDataForLabel.go b/labelFilter/readyDataForLabel.go index 5c792e1..e102273 100644 --- a/labelFilter/readyDataForLabel.go +++ b/labelFilter/readyDataForLabel.go @@ -1,7 +1,7 @@ package labelFilter import ( - "basic.com/valib/logger.git" + logger "github.com/alecthomas/log4go" "ruleprocess/cache" "ruleprocess/structure" "time" @@ -13,49 +13,45 @@ CameraAddr string TaskId string Time string - Persons []structure.FaceResult + Persons []structure.Result DefenceLevel []int32 } // 鎶婃暟鎹閰嶅埌label func (label *Label)DataFormatToLabel(result structure.ResultMsg) { - logger.Debug("face缁撴灉锛�",result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.FaceResult)) > 0) - logger.Debug("yolo缁撴灉锛�",result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0) - if (result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.FaceResult)) > 0) || (result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0) { // 寰楁湁浜鸿劯鎴栬�厃olo瑙勫垯鎵嶅彲浠� - - // 鍏堝垽鏂竴涓嬫暟鎹甫鐨勮鍒欐爣绛炬槸鍚︽湁鎶ヨ鐨勫彲浠ユ帹閫佺殑 - flag := false - for _, res := range result.RuleResult["yolo"].([]structure.Result) { - //logger.Info("瀹氭椂鍣ㄦ墦鐨勬暟瀛楁爣绛撅細",res.Others.TimeLabel) - if res.Others.TimeLabel == "01" || res.Others.TimeLabel == "10" { - flag = true - } - } - if flag || (result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.FaceResult)) > 0){ - logger.Info("---------------鏍囩杩囨护鍣ㄨ祴鍊�") - label.CameraId = result.Cid - camera, err := cache.GetCameraById(result.Cid) - if err != nil { - logger.Error("鏌ヨ鎽勫儚鏈轰俊鎭嚭閿�") - } - label.CameraName = camera.Name - label.CameraAddr = camera.Addr - label.TaskId = result.Tasklab.Taskid - label.Time = time.Now().Format("2006-01-02 15:04:05") - if result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.FaceResult)) > 0 { - for _,faceGroup := range result.RuleResult["face"].([]structure.FaceResult) { - label.Persons = append(label.Persons,faceGroup) - label.DefenceLevel = append(label.DefenceLevel,faceGroup.AlarmLevel) + flag1 := false + for _,value := range result.RuleResult { + if value != nil && len(value.([]structure.Result)) > 0{ + for _,res := range value.([]structure.Result) { + if res.Others.TimeLabel == "01" || res.Others.TimeLabel == "10" { + flag1 = true } } - if result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0 { - - for _,yoloGroup := range result.RuleResult["yolo"].([]structure.Result) { - label.DefenceLevel = append(label.DefenceLevel,yoloGroup.AlarmLevel) - } - } - logger.Info("------------鏍囩杩囨护鍣ㄨ祴鍊煎畬姣�") } } -} + if flag1{ // 鏈夊彲鎺ㄩ�佺殑鏁版嵁 + //logger.Info("---------------鏍囩杩囨护鍣ㄨ祴鍊�") + label.CameraId = result.Cid + camera, err := cache.GetCameraById(result.Cid) + if err != nil { + logger.Error("鏌ヨ鎽勫儚鏈轰俊鎭嚭閿�") + } + label.CameraName = camera.Name + label.CameraAddr = camera.Addr + label.TaskId = result.Tasklab.Taskid + label.Time = time.Now().Format("2006-01-02 15:04:05") -// 浠庣紦瀛樹腑鏌ュ嚭鎵�鏈夌殑瑙勫垯鏁版嵁 + for key,value := range result.RuleResult { + if value != nil && len(value.([]structure.Result)) > 0{ + for _,res := range value.([]structure.Result) { + if res.Others.TimeLabel == "01" || res.Others.TimeLabel == "10" { + label.DefenceLevel = append(label.DefenceLevel,res.AlarmLevel) + if key == "face" { + label.Persons = append(label.Persons,res) + } + } + } + } + } + //logger.Info("------------鏍囩杩囨护鍣ㄨ祴鍊煎畬姣�") + } +} \ No newline at end of file -- Gitblit v1.8.0