From d6fe8a6e2bf01f425b8548d56f585ac5e73b9409 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期五, 26 七月 2019 15:37:50 +0800
Subject: [PATCH] log

---
 controllers/fileController.go |   57 +++++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 39 insertions(+), 18 deletions(-)

diff --git a/controllers/fileController.go b/controllers/fileController.go
index 74d1b25..394aebf 100644
--- a/controllers/fileController.go
+++ b/controllers/fileController.go
@@ -1,6 +1,7 @@
 package controllers
 
 import (
+	"basic.com/dbapi.git"
 	"basic.com/pubsub/protomsg.git"
 	"basic.com/fileServer/WeedFSClient.git"
 	"basic.com/valib/deliver.git"
@@ -181,44 +182,62 @@
 }
 
 var captureTable = "capturetable" // 鎶撴媿搴�
-type SearchCondition struct {
-	PicUrl string `json:"picUrl"`
-	Databases []string `json:"databases"`
-	Threshold string `json:"threshold"`
-}
 // @Summary 浠ュ浘鎼滃浘
 // @Description  浠ュ浘鎼滃浘
 // @Accept json
 // @Produce json
 // @Tags 浠ュ浘鎼滃浘
-// @Param condition body controllers.SearchCondition true "鎼滅储鍙傛暟"
+// @Param condition body models.EsSearch true "鎼滅储鍙傛暟"
 // @Success 200 {string} json "{"code":200, msg:"", data:"", success:true}"
 // @Failure 500 {string} json "{"code":500, msg:"", data:"", success:false}"
 // @Router /data/api-v/dbperson/searchByPhoto [POST]
 func (controller FileController) SearchByPhoto(c *gin.Context) {
-	var condition SearchCondition
-	err := c.BindJSON(&condition)
-	if err !=nil || condition.PicUrl == "" || len(condition.Databases) == 0 {
+	var searchBody models.EsSearch
+	err := c.BindJSON(&searchBody)
+	if err !=nil || searchBody.PicUrl == "" || len(searchBody.DataBases) == 0 {
 		util.ResponseFormat(c, code.RequestParamError, "鍙傛暟鏈夎")
 		return
 	}
-	compThreshold, err := strconv.ParseFloat(condition.Threshold,32)
-	if condition.PicUrl == "" || err != nil {
-		util.ResponseFormat(c, code.RequestParamError, "鍙傛暟鏈夎")
+	var sysSetApi dbapi.SysSetApi
+	analyServerId := ""
+	flag, sysconf := sysSetApi.GetServerInfo()
+	if flag {
+		analyServerId = sysconf.ServerId
+	} else {
+		util.ResponseFormat(c, code.ComError, "analyServerId涓虹┖锛岄厤缃湁璇�")
 		return
 	}
-	if face,ok := faceExtractedMap[condition.PicUrl];!ok{
+	if face,ok := faceExtractedMap[searchBody.PicUrl];!ok{
 		util.ResponseFormat(c, code.RequestParamError, "璇烽噸鏂颁笂浼犲浘鐗�")
 		return
 	} else {
 		arg := protomsg.CompareArgs{
-			TableIds: condition.Databases,
 			FaceFeature: face.FaceBytes,
-			CompareThreshold: float32(compThreshold),
+			CompareThreshold: searchBody.Threshold,
 		}
-		if condition.Databases !=nil {
-			arg.TableIds = append(arg.TableIds, condition.Databases...)
+
+		if searchBody.DataBases !=nil {
+			for idx,tableId :=range searchBody.DataBases {
+				if tableId == "esData" {
+					searchBody.DataBases = append(searchBody.DataBases[:idx], searchBody.DataBases[idx+1:]...)
+					searchBody.DataBases = append(searchBody.DataBases,captureTable)
+					break
+				}
+			}
+			arg.TableIds = searchBody.DataBases
 		}
+		arg.Source = true // 鏍囪瘑鏉ユ簮鏄痺eb
+		arg.AlarmLevel = searchBody.AlarmLevel
+		arg.Tasks = searchBody.Tasks
+		arg.TreeNodes = searchBody.TreeNodes
+		arg.Tabs = searchBody.Tabs
+		arg.SearchTime = searchBody.SearchTime
+		arg.InputValue = searchBody.InputValue
+		arg.Collection = searchBody.Collection
+		arg.AnalyServerId = analyServerId
+
+		logger.Debug("arg.TableIds:", arg.TableIds, ",alarmLevel:",arg.AlarmLevel,",treeNodes:",arg.TreeNodes,",searchTime:",arg.SearchTime,
+			",inputValue:",arg.InputValue,",tasks:",arg.Tasks,",compThreshold:",arg.CompareThreshold)
 		b, err := proto.Marshal(&arg)
 		if err !=nil{
 			util.ResponseFormat(c, code.ComError, "璇锋眰marshal澶辫触")
@@ -295,6 +314,7 @@
 					resultList = append(resultList,cr)
 				}
 			}
+
 			logger.Debug("resultList:",resultList)
 		}
 		util.ResponseFormat(c,code.Success,resultList)
@@ -388,6 +408,7 @@
 	dbperson.PersonPicUrl = field //  鍥剧墖璺粡
 	dbperson.TableId = tableId           //
 	dbperson.PersonName = fileNameOnly       // 鍥剧墖鍚�
+	dbperson.Enable = 1 //榛樿鏈夋晥
 	// 婕旂ずbase64缂栫爜
 
 	dbperson.FaceFeature = faceBase64 // 鐗瑰緛鍊糱ase64 鐮�
@@ -468,7 +489,7 @@
 	//addResult["detail"] = details
 	//fields := fdfsclient.UploadFileByBuffer100(bytess, extNames)     //  fastdfs 涓婁紶
 	if len(successList)>0 {
-		util.ResponseFormat(c, code.Success, addResult)
+		util.ResponseFormat(c, code.DbPersonUploadSuccess, addResult)
 	} else {
 		util.ResponseFormat(c, code.ServiceInsideError, err.Error())
 	}

--
Gitblit v1.8.0