From a3a788801fcd2efb16d58e91f393bad8d7730b96 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期三, 26 六月 2019 18:35:19 +0800
Subject: [PATCH] 加上人脸,过完规则的标签区分人脸和yolo

---
 ruleserver/ruleToformula.go |  177 +++++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 131 insertions(+), 46 deletions(-)

diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go
index 6f6ffbf..07aa2d1 100644
--- a/ruleserver/ruleToformula.go
+++ b/ruleserver/ruleToformula.go
@@ -3,6 +3,7 @@
 import (
 	"encoding/json"
 	"fmt"
+	"log"
 	"sort"
 	"strconv"
 	"strings"
@@ -56,10 +57,17 @@
 
 // 姣忎釜鐩爣鐨勫弬鏁帮細鐩镐技搴︼紝鍗犳瘮锛屽昂瀵�
 type Arg struct {
-	id         string
 	score      float64 // 鍖哄煙鍐呯殑鐩爣鐨勭浉浼煎害
 	proportion float64 // 鍖哄煙鍐呯殑鐩爣鐨勫崰姣�
 	size       float64 // 鍖哄煙鍐呯殑鐩爣鐨勫昂瀵�
+	isYolo	   bool    // 鏄惁鏄痽olo鏁版嵁
+	location   Rect    // 璁颁笅姣忎釜鐩爣鐨勪綅缃弬鏁帮紝鏈�鍚庣粰缁撴灉瑁呴厤浜鸿劯鏁版嵁鐨勬椂鍊欑敤鐨勫埌
+	liker      []LikePerson
+}
+
+type LikePerson struct {
+	Id    string  // 涓庝箣鐩镐技鐨勫簳搴撲汉鍛樼殑id
+	Score float64 // 涓庡簳搴撲汉鍛樼殑鐩镐技鍊�
 }
 
 // 姣忎釜鍖哄煙鍐呯殑鍥剧墖鏁版嵁闆嗗悎
@@ -73,7 +81,7 @@
 	triggerLine   string
 	directionLine string
 	targetNum     int    // 鍖哄煙鍐呯洰鏍囨暟閲�
-	args          []Arg  // 鍖哄煙鍐呯洰鏍囩殑鍙傛暟闆嗗悎
+	args          []Arg  // 鍖哄煙鍐呯洰鏍囬泦鍚�
 	filterData    []Arg  // 杩囨护鍚庡尯鍩熷唴鐩爣闆嗗悎
 	time          string // 褰撳墠鏃堕棿锛堢敤浠ュ尮閰嶆椂闂磋鍒欙級
 	keepRight     bool   // 鏄惁闈犲彸琛�
@@ -82,8 +90,10 @@
 
 // sdk杈撳嚭鐨勫浘鐗囦笂鍗曚釜鐩爣鐨勬暟鎹�
 type PhotoMap struct {
-	Rects Rect    // 鐭╁舰鍖哄煙鍙傛暟
-	Score float64 // 鐩镐技搴﹀緱鍒�
+	Rects Rect         // 鐭╁舰鍖哄煙鍙傛暟
+	Score float64      // 鐩镐技搴﹀緱鍒嗭紙鏈夊澶х▼搴﹀儚涓�涓洰鏍囥�備汉鑴革紝浜轰綋鎴栬溅绛夌瓑锛�
+	IsYolo bool		   // 鏄惁鏄痽olo鏁版嵁
+	Liker []LikePerson // 濡傛灉鏄汉鑴哥殑璇濆挨鍏舵槸姣斿锛屽簲瀛樹笅浠栬窡搴曞簱鐨勪汉鍛樼殑鐩镐技鎯呭喌 yolo鐨勮瘽缁檔il灏辫
 }
 
 // 浠庨�氶亾涓幏鍙栫殑sdk杈撳嚭鐨勫浘鍍忔暟鎹�(鐩墠涓昏鏄痽olo绠楁硶鐨勬暟鎹�)
@@ -109,9 +119,17 @@
 // 杩囪鍒欏簱鎵撲笂鐨勬爣绛�
 type Result struct {
 	TaskId      string // 浠诲姟id
+	IsYolo		bool   // 鏄惁鏄痽olo瑙﹀彂鐨勮鍒�
 	RuleGroupId string // 瑙勫垯缁刬d
-	AlarmLevel  int32 // 鎶ヨ绛夌骇
+	AlarmLevel  int32  // 鎶ヨ绛夌骇
 	RuleText    string // 鏂囧瓧鐗堣鍒欑粍
+	Faces       []Face // 瑙﹀彂姝よ鍒欑粍鐨勪汉鑴革紙浜鸿劯绯诲垪瑙勫垯涓撶敤锛寉olo绯诲垪涓嶉渶瑕侊級
+}
+
+//
+type Face struct {
+	Location Rect         // 浜鸿劯鍧愭爣妗�
+	liker    []LikePerson // 鐩镐技浜哄憳锛堝鏋滄槸鍗曠函鐨勪汉鑴告娴嬪彲鏃犳椤癸級
 }
 
 // 鍖呭惈N鏉¤鍒欏厓绱犵殑涓�鏁存潯瑙勫垯
@@ -147,6 +165,7 @@
 		areaMap.CountAreaObjs(arg)
 		list.areaMapList = append(list.areaMapList, areaMap)
 	}
+
 	//fmt.Println("涓烘瘡涓憚鍍忔満鍖哄煙濉厖鏁版嵁鍚庣殑鍐呭", list.areaMapList)
 	// 灏嗘甯ф暟鎹寜鎽勫儚鏈哄尯鍩熷垎绫绘墦鍖呭悗鍒ゆ柇鏄惁鎶ヨ
 	judge(&list, arg)
@@ -170,16 +189,16 @@
 
 	// }
 	for _, obj := range arg.Photo {
-		if threshold <= obj.Score &&
-			size <= float64(obj.Rects.Width*obj.Rects.Height) &&
-			intersectionper <= PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale) {
+		if threshold <= obj.Score && size <= float64(obj.Rects.Width*obj.Rects.Height) && intersectionper <= PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale){
 			// 杩欐瑕佸榻愯〃杈惧紡閲屾墍闇�瑕佺殑鎵�鏈夊弬鏁�
 			a.targetNum++
-			arg := Arg{score: obj.Score, proportion: PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale), size: float64(obj.Rects.Width * obj.Rects.Height)}
-			a.args = append(a.args, arg)
-			a.filterData = append(a.filterData, arg)
+			arg1 := Arg{ obj.Score,PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale), float64(obj.Rects.Width * obj.Rects.Height),  obj.IsYolo,obj.Rects, obj.Liker}
+			log.Println("鏀捐繘鍘荤殑arg锛�-------", arg1)
+			a.args = append(a.args, arg1)
+			a.filterData = append(a.filterData, arg1)
 		}
 	}
+
 	a.time = time.Unix(time.Now().Unix(), 0).String()[11:16]
 	a.keepRight = arg.KeepRight
 	a.isStatic = arg.IsStatic
@@ -188,11 +207,17 @@
 // 灏嗗瓧绗︿覆鏍煎紡鐨勫潗鏍囧簭鍒楀寲涓篜oint鏍煎紡
 func Json2points(areaPoints string) []Point {
 	var pts []Point
-
-	err := json.Unmarshal([]byte(areaPoints), &pts)
-	if err != nil {
-		fmt.Println("json.Unmarshal閿欒", err)
-		panic("搴忓垪鍖栧潗鏍囧紓甯革紝绋嬪簭閫�鍑�")
+	if areaPoints == "" {
+		pts = append(pts, Point{0, 0})
+		pts = append(pts, Point{0, 540})
+		pts = append(pts, Point{960, 540})
+		pts = append(pts, Point{960, 0})
+	} else {
+		err := json.Unmarshal([]byte(areaPoints), &pts)
+		if err != nil {
+			fmt.Println("json.Unmarshal閿欒", err)
+			panic("搴忓垪鍖栧潗鏍囧紓甯革紝绋嬪簭閫�鍑�")
+		}
 	}
 	return pts
 }
@@ -294,14 +319,19 @@
 // 鐙珛浠诲姟
 func singleTask(aml *AreaMapList, arg *ArgsFromSdk, groupRule *protomsg.GroupRule, taskId string) bool {
 	var completeFormula string = ""
+	var okSdks string = "" // 璁板綍涓嬭Е鍙戣鍒欑殑鏄痽olo杩樻槸face
 	for _, areaMap := range aml.areaMapList {
+		//fmt.Println("褰撳墠瑙勫垯缁勪负---------锛�",groupRule)
 		for j := 0; j < len(groupRule.Rules); j++ {
 			// 鍏堣繃瀹屾潯浠舵暟鎹�
 			filterRule(groupRule.Rules[j], &areaMap)
 		}
 		for j := 0; j < len(groupRule.Rules); j++ {
 			// 鍐嶈繃鍏朵粬鏁版嵁 杩欐鐩存帴寰楀埌缁撴灉锛堢湡鎴栧亣锛� 杩囩洰鏍囨暟閲�
-			flag := transferParameters(groupRule.Rules[j], &areaMap)
+			flag,sdk := transferParameters(groupRule.Rules[j], &areaMap)
+			if flag == "true" {
+				okSdks = okSdks + "," + sdk
+			}
 			if flag != "" {
 				fmt.Println("寰楀嚭鐨勭粨鏋�", flag)
 				completeFormula = completeFormula + groupRule.Rules[j].RuleWithPre + "" + flag
@@ -311,9 +341,9 @@
 			flag := splice1(&areaMap)
 			if flag != "" {
 				fmt.Println("寮鸿鎷煎噾涓�涓汉鏁版槸鍚﹀ぇ浜�0鐨勭粨鏋�", flag)
-				completeFormula = completeFormula + groupRule.Rules[j].RuleWithPre + "" + flag
+				completeFormula = flag
 			}
-
+			okSdks = okSdks + "," + "yolo"
 		}
 		for j := 0; j < len(groupRule.Rules); j++ {
 			// 杩欐杩囩殑鏄椂闂磋鍒欙紙鏃堕棿娈电瓑锛�
@@ -334,7 +364,7 @@
 	if completeFormula != "" {
 		expression, _ := govaluate.NewEvaluableExpression(completeFormula)
 		result, _ := expression.Evaluate(nil) // 寰楀埌鏁板鍏紡鐨勭粨鏋�
-		fmt.Println("杩欏抚鍥惧儚鍦ㄤ换鍔′笅鐨勯櫎浜嗘寔缁椂闂村鐨勪竴鏁存潯瑙勫垯涓嬬殑鍒ゆ柇缁撴灉", result)
+		//fmt.Println("杩欏抚鍥惧儚鍦ㄤ换鍔′笅鐨勯櫎浜嗘寔缁椂闂村鐨勪竴鏁存潯瑙勫垯涓嬬殑鍒ゆ柇缁撴灉", result)
 		// 鐢变簬澶╃劧鎴栫殑鍏崇郴锛屾弧瓒充竴涓氨璇ユ姤璀�,鍗宠甯ф暟鎹浜庢煇涓换鍔$殑鏌愪釜瑙勫垯缁勫簲璇ユ姤璀�
 		if !result.(bool) { // 濡傛灉涓嶇鍚堟潯浠讹紝搴旇閲嶇疆瀹氭椂鍣ㄥ厓绱狅紝绛夌鍚堟椂鍐嶅紑鍚�,鎶妅ey涓寘鍚换鍔d鐨則imeEle閮介噸缃�
 			for k, timeEle := range TimeEleList {
@@ -344,7 +374,7 @@
 			}
 			return false
 		} else {
-			// 鍘荤湅瀹氭椂鍣ㄦ鏃舵槸鍚﹁蛋鍒�0锛岃蛋鍒�0鐨勮瘽杩斿洖鎴愬姛鎶ヨ
+			// 鍘荤湅姹犲瓙閲屾槸鍚︽湁涓庢湰甯ф暟鎹湁鍏崇殑瀹氭椂鍣紝濡傛灉鏈夛紝鐪嬫鏃舵槸鍚﹁蛋鍒�0锛屾病鏈夋瀹氭椂鍣ㄦ垨鏈夊畾鏃跺櫒璧板埌0鐨勮瘽杩斿洖鎴愬姛鎶ヨ
 			var flag bool = true
 			for k, timeEle := range TimeEleList {
 				if strings.Index(k, taskId) != -1 {
@@ -354,9 +384,24 @@
 				}
 			}
 			if flag {
-				fmt.Println("瀹氭椂鍣ㄦ姤璀︿簡")
-				// 杩囧畬瑙勫垯鍚庢墦涓爣绛撅紝鍛婅瘔璋冪敤鑰呮湰甯ф暟鎹拡瀵瑰摢涓换鍔″摢缁勮鍒欐姤璀︿簡
-				arg.RuleResult = append(arg.RuleResult, Result{taskId, groupRule.GroupId,groupRule.AlarmLevel,groupRule.GroupText})
+				fmt.Println("鏈抚鏁版嵁绗﹀悎瑙勫垯")
+				// 鍙栧嚭鎵�鏈夊尯鍩熷唴缁忚繃杩囨护鍚庤繕鍓╀笅鐨勪汉鑴革紝鏀捐繘缁撴灉涓�
+				faces := []Face{}
+				for _, areaMap := range aml.areaMapList {
+					if len(areaMap.filterData) > 0 {
+						for _, arg := range areaMap.filterData {
+							faces = append(faces,Face{arg.location,arg.liker})
+						}
+					}
+				}
+				// 濡傛灉瀵箉olo鍜屼汉鑴搁兘鎶ヨ锛岄偅灏辨墦涓ら亶鏍囩
+				if strings.Contains(okSdks,"yolo") {
+					// 杩囧畬瑙勫垯鍚庢墦涓爣绛撅紝鍛婅瘔璋冪敤鑰呮湰甯ф暟鎹拡瀵瑰摢涓换鍔″摢缁勮鍒欐姤璀︿簡     鍚庡姞锛氬彲鑳借繕涓嶅锛岃繕闇�瑕佸尯鍒嗚Е鍙戞姤璀︾殑瀵硅薄锛屽悗闈㈠線es鏁版嵁搴撴彃鏁版嵁鏃惰鐢�
+					arg.RuleResult = append(arg.RuleResult, Result{taskId, true,groupRule.GroupId, groupRule.AlarmLevel, groupRule.GroupText, faces})
+				}
+				if strings.Contains(okSdks,"face") {
+					arg.RuleResult = append(arg.RuleResult, Result{taskId, false,groupRule.GroupId, groupRule.AlarmLevel, groupRule.GroupText, faces})
+				}
 				return true
 			} else {
 				return false
@@ -414,7 +459,7 @@
 					formula = strconv.FormatFloat(arg.size, 'f', -1, 64) + " " + rule.Operator + " " + rule.SdkArgValue // 寰楀埌瀛楃涓插叕寮�
 				}
 				expression, _ := govaluate.NewEvaluableExpression(formula) // 寰楀埌鏁板鍏紡
-				result, _ := expression.Evaluate(nil)          // 寰楀埌鏁板鍏紡鐨勭粨鏋�
+				result, _ := expression.Evaluate(nil)                      // 寰楀埌鏁板鍏紡鐨勭粨鏋�
 				if result.(bool) {
 					am.filterData = append(am.filterData, arg) // 寰楀埌绗﹀悎鏉′欢鐨勮繃婊ゆ暟鎹�
 				}
@@ -447,53 +492,93 @@
 		}
 	}
 }
-// 鍐椾綑鎷兼帴
-func splice1 (am *AreaMap) string {
-	args := am.targetNum
-	formula := strconv.Itoa(args) + " "  + ">" + "0"
+
+// 鍐椾綑鎷兼帴涓�涓洰鏍囨暟閲忓ぇ浜�0
+func splice1(am *AreaMap) string {
+	var num int = 0
+	for _,data := range am.filterData{
+		if data.isYolo {
+			num++
+		}
+	}
+	log.Println("鐪嬬湅鍖哄煙鍐呯鍚堟潯浠剁殑鐩爣鏁伴噺锛�----------", num)
+	formula := strconv.Itoa(num) + " " + ">" + "0"
 	expression, _ := govaluate.NewEvaluableExpression(formula) // 寰楀埌鏁板鍏紡
-	result, _ := expression.Evaluate(nil)                      // 寰楀埌鏁板鍏紡鐨勭粨鏋�
+	result, _ := expression.Evaluate(nil)          // 寰楀埌鏁板鍏紡鐨勭粨鏋�
 	return strconv.FormatBool(result.(bool))
 }
+
 // 缁欐暟鎹簱鐨勮鍒欒〃杈惧紡浠e弬 args: 涓�鏉″瓙瑙勫垯锛屽尯鍩熸暟鎹�
-func transferParameters(rule *protomsg.Rule, am *AreaMap) string {
+func transferParameters(rule *protomsg.Rule, am *AreaMap) (string,string) {
 	if rule.PolygonId == am.areaId { // 棣栧厛瑙勫垯鎵�瀵瑰簲鐨勫尯鍩焛d瑕佽窡鍖哄煙鏁版嵁鐨刬d瀵圭殑涓�
-		if rule.SdkArgAlias == "targetNum" { // 濡傛灉鍙傛暟鏄鍖哄煙鍐呯洰鏍囨暟閲� 鍗硑olo
+		if rule.SdkArgAlias == "targetNum" { // 濡傛灉鍙傛暟鏄鍖哄煙鍐呯洰鏍囨暟閲� 鍗硑olo 浜鸿劯涓嶄細鏈夋暟閲�
 			//fmt.Println("寰楀嚭缁撴灉闃舵", "姣旇緝鐨勮鍒欐槸锛�", rule)
 			if rule.Operator == "" {
-				return strconv.Itoa(am.targetNum) // 濡傛灉鍚庨潰涓嶈窡鎿嶄綔绗﹀氨鐩存帴杩斿洖鏁伴噺  姣斿瑕佽窡涓嬩竴涓尯鍩熸瘮杈冩暟閲忕殑灏辩洿鎺ヨ繑鍥炴湰鍖哄煙鐨勬暟閲�
+				return strconv.Itoa(am.targetNum),"" // 濡傛灉鍚庨潰涓嶈窡鎿嶄綔绗﹀氨鐩存帴杩斿洖鏁伴噺  姣斿瑕佽窡涓嬩竴涓尯鍩熸瘮杈冩暟閲忕殑灏辩洿鎺ヨ繑鍥炴湰鍖哄煙鐨勬暟閲�
 			}
-			args := am.targetNum
-			formula := strconv.Itoa(args) + " " + rule.Operator + " " + rule.SdkArgValue
+			//args := am.targetNum     targetNum 宸叉垚鎵�鏈夌洰鏍囩殑鎬绘暟閲忥紝杩欓噷鍙畻yolo鐨�
+			var num int = 0
+			for _,data := range am.filterData{
+				if data.isYolo {
+					num++
+				}
+			}
+			formula := strconv.Itoa(num) + " " + rule.Operator + " " + rule.SdkArgValue
 			expression, _ := govaluate.NewEvaluableExpression(formula) // 寰楀埌鏁板鍏紡
 			result, _ := expression.Evaluate(nil)                      // 寰楀埌鏁板鍏紡鐨勭粨鏋�
-			return strconv.FormatBool(result.(bool))
+			return strconv.FormatBool(result.(bool)),""
 			// 鍔犱笂鍏充簬绠楁硶鐨勫垽鏂潯浠讹紝涓嶈兘鍙湁鍏充簬瑙勫垯鐨勶紝鏈夌殑绠楁硶鏈韩灏辨槸涓�涓鍒欙紝濡備釜浣撻潤姝紝闈犲彸琛�,鎵�浠ワ紝鎷垮埌褰撳墠瀛愯鍒欑殑sdkid鏉ュ垽鏂槸鍚︽槸閭d簺鐗规畩鐨勮鍒�
 		} else if rule.SdkId == "IsStatic" { // 闈欐绠楁硶
 			if am.isStatic {
-				return "true"
+				return "true","static"
 			} else {
-				return "false"
+				return "false","static"
 			}
 		} else if rule.SdkId == "KeepRight" { // 闈犲彸琛岀畻娉�
 			if am.keepRight {
-				return "true"
+				return "true","keepRight"
 			} else {
-				return "false"
+				return "false","keepRight"
 			}
 		} else if rule.SdkId == "FaceDetect" { // 浜鸿劯妫�娴�
 			if rule.Operator == "==" || rule.Operator == ">=" || rule.Operator == "<=" || rule.Operator == "<" || rule.Operator == ">" || rule.Operator == "!=" {
 				// 濡傛灉鏄笉瑙勭煩鐨勮繛鎺ョ缁熺粺杩斿洖false 瑙勫垯涔熷彧鑳藉垽鏂汉鑴哥殑鐩镐技搴︼紝鎵�浠ヤ笉瀛樺湪鍒殑杩炴帴绗�
-				return "false"
-			} else {
-				return "false"
-			}
-		} else {
 
+				return "false","face"
+			} else {
+				return "false","face"
+			}
+		} else if rule.SdkId == "FaceCompare" {
+			// 鍙渶瑕佽繃婊ら槇鍊硷紝杩囨护瀹屽悗鏁扮粍闀垮害澶т簬0鍗充负鎶ヨ锛屼絾瑕佽�冭檻濡備綍瀵规瘡涓�寮犻兘鎶ヨ鍛�
+			argValue, err := strconv.ParseFloat(rule.SdkArgValue, 64)
+			if err != nil {
+				log.Println("瑙勫垯閰嶇疆鐨勯槇鍊奸潪娉�")
+				return "false","face"
+			}
+			flag := "false"
+			for _, obj := range am.filterData {
+				if !obj.isYolo {  // 浜鸿劯鏁版嵁鎵嶈繃婊ょ浉浼艰��
+					for index := 0; index < len(obj.liker); {
+						// 灏嗚揪涓嶅埌闃堝�肩殑鐩镐技鑰呬粠鐩镐技鑰呮暟缁勪腑鍒犻櫎
+						if obj.liker[index].Score < argValue {
+							// Go 璇█涓垏鐗囧垹闄ゅ厓绱犵殑鏈川鏄細浠ヨ鍒犻櫎鍏冪礌涓哄垎鐣岀偣锛屽皢鍓嶅悗涓や釜閮ㄥ垎鐨勫唴瀛橀噸鏂拌繛鎺ヨ捣鏉ャ�備笉鐢ㄦ��鐤戯紝鏁扮粍鍒犻櫎鍏冪礌灏辫繖涔堝潙鐖�
+							obj.liker = append(obj.liker[:index], obj.liker[index+1:]...)
+						} else {
+							index++
+						}
+					}
+				}
+			}
+			for _,obj2 := range am.filterData {
+				if !obj2.isYolo && len(obj2.liker) > 0 {
+					flag = "true"
+				}
+			}
+			return flag,"face"
 		}
 
 	}
-	return ""
+	return "",""
 }
 func timeRuleResult(rule *protomsg.Rule, am *AreaMap) string {
 	if rule.PolygonId == am.areaId { // 棣栧厛瑙勫垯鎵�瀵瑰簲鐨勫尯鍩焛d瑕佽窡鍖哄煙鏁版嵁鐨刬d瀵圭殑涓�

--
Gitblit v1.8.0