From 0499de0bdaa4d6c20e14911d09c21a3f9d4f8516 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 09 十二月 2019 14:28:52 +0800
Subject: [PATCH] ---

---
 labelFilter/req.go                   |   12 +++---
 algorithm/middleware/middleware.go   |    2 
 algorithm/personTrack/personTrack.go |   12 +++---
 insertdata/insertDataToEs.go         |   30 +++++++-------
 algorithm/insertEs/insertDataToEs.go |   30 +++++++-------
 ruleserver/readyDataForRule.go       |   18 ++++----
 6 files changed, 52 insertions(+), 52 deletions(-)

diff --git a/algorithm/insertEs/insertDataToEs.go b/algorithm/insertEs/insertDataToEs.go
index 4fbe1d0..1d06682 100644
--- a/algorithm/insertEs/insertDataToEs.go
+++ b/algorithm/insertEs/insertDataToEs.go
@@ -107,7 +107,7 @@
 func InsertToEs(msg structure.ResultMsg) {
 	defer func() {
 		if err := recover(); err != nil {
-			_ = logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
+			logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
 		}
 	}()
 	localConfig1, err := cache.GetServerInfo()
@@ -143,7 +143,7 @@
 		faces = PutFace(faces, results.([]structure.Result))
 		//logger.Info("鏁寸悊鍚庣殑鏁版嵁锛�",faces)
 		if faces != nil {
-			_ = logger.Warn("face涓嶄负nil")
+			logger.Warn("face涓嶄负nil")
 			var imgMaxUrl []string = []string{}
 			var picTime string = ""
 			for _, face := range faces {
@@ -165,7 +165,7 @@
 				bytes := util.SubImg(i, int(face.Location.X), int(face.Location.Y), int(face.Location.X+face.Location.Width), int(face.Location.Y+face.Location.Height),face.Type)
 				resp, err := util.PostFormBufferData1(weedfsUrl, bytes, uuid.NewV4().String())
 				if err != nil {
-					_ = logger.Error("涓婁紶灏忓浘鍑洪敊")
+					logger.Error("涓婁紶灏忓浘鍑洪敊")
 				}
 				// 涓婁紶澶у浘
 				if len(imgMaxUrl) == 0 {
@@ -242,7 +242,7 @@
 					esid := face.Liker[0].TargetId
 					returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
 					if err1 != nil {
-						_ = logger.Error("杩藉姞鏁版嵁鍑洪敊锛�---", err1)
+						logger.Error("杩藉姞鏁版嵁鍑洪敊锛�---", err1)
 					} else {
 						logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", returnMsg)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -251,7 +251,7 @@
 				} else {
 					resp1, err1 := EsReq("POST", videoPersonUrl, requstbody)
 					if err1 != nil {
-						_ = logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
+						logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
 					} else {
 						logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -347,7 +347,7 @@
 							err = proto.Unmarshal(bdata, &i)
 							resp1, err1 := util.DrawPolygonOnImageForYolo(msg1.Cid, i, msg1.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 							if err1 != nil {
-								_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+								logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 							} else {
 								logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 							}
@@ -407,7 +407,7 @@
 				//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 				resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 				if err != nil {
-					_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+					logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 					return
 				} else {
 					logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
@@ -461,7 +461,7 @@
 				}
 				resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
 				if err2 != nil {
-					_ = logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
+					logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
 				} else {
 					logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛坹olo锛夛細", resp1)
 					// 鍙戝嚭褰曞儚淇″彿
@@ -470,7 +470,7 @@
 						logger.Info("鑱斿姩浠诲姟鐨勫綍鍍忎俊鍙凤細", index)
 						ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: link.CameraId, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{strconv.Itoa(index)}, Type: 2})
 					}
-					_ = logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
+					logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
 					//os.Exit(1)
 				}
 			}
@@ -544,7 +544,7 @@
 					//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 					resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["target"].([]structure.Result), weedfsUrl)
 					if err != nil {
-						_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+						logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 						return
 					} else {
 						logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
@@ -621,7 +621,7 @@
 					}
 					resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
 					if err2 != nil {
-						_ = logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
+						logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
 					} else {
 						logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛坱arget锛夛細", resp1)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -630,7 +630,7 @@
 							logger.Info("鑱斿姩浠诲姟鐨勫綍鍍忎俊鍙凤細", index)
 							ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: link.CameraId, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{strconv.Itoa(index)}, Type: 2})
 						}
-						_ = logger.Warn("__________________________________________寰�ES鎻掑叆target鏁版嵁鎴愬姛")
+						logger.Warn("__________________________________________寰�ES鎻掑叆target鏁版嵁鎴愬姛")
 						//os.Exit(1)
 					}
 				}
@@ -704,7 +704,7 @@
 	err = proto.Unmarshal(bdata, &i)
 	resp1, err1 := util.DrawPolygonOnImageForTarget(msg.Cid, i, msg.RuleResult["target"].([]structure.Result), weedfsUrl)
 	if err1 != nil {
-		_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+		logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 	} else {
 		logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 	}
@@ -813,7 +813,7 @@
 							err = proto.Unmarshal(bdata, &i)
 							resp1, err1 := util.DrawPolygonOnImageForYolo(msg1.Cid, i, msg1.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 							if err1 != nil {
-								_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+								logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 							} else {
 								logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 							}
@@ -856,7 +856,7 @@
 				//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 				resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 				if err != nil {
-					_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+					logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 					return nil
 				} else {
 					logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
diff --git a/algorithm/middleware/middleware.go b/algorithm/middleware/middleware.go
index a9c4ea7..e21e9bb 100644
--- a/algorithm/middleware/middleware.go
+++ b/algorithm/middleware/middleware.go
@@ -207,7 +207,7 @@
 				// 鏍规嵁瑙勫垯鐨剆dkId鏌ュ嚭鍏跺搴旂殑ipcId锛岀敤ipcId鍘绘壘璇ユ瘮瀵圭殑鏁版嵁
 				sdk, err := cache.GetSdkById(groupRule.Rules[j].SdkId)
 				if err != nil {
-					_ = logger.Error("娌℃煡鍒皊dk鐨勪俊鎭�---", err)
+					logger.Error("娌℃煡鍒皊dk鐨勪俊鎭�---", err)
 				}
 				ipcId := sdk.IpcId
 				sdkName := sdk.SdkName
diff --git a/algorithm/personTrack/personTrack.go b/algorithm/personTrack/personTrack.go
index 858a3bc..25f9965 100644
--- a/algorithm/personTrack/personTrack.go
+++ b/algorithm/personTrack/personTrack.go
@@ -104,7 +104,7 @@
 	trackArg["faceFeature"]	= arg.AttachArg.Feature
 	b,err := json.Marshal(trackArg)
 	if err != nil {
-		_ = logger.Error("json搴忓垪鍖栭敊璇�", err)
+		logger.Error("json搴忓垪鍖栭敊璇�", err)
 	}
 	dataId := getCompareMsg(b)
 	if esId == dataId { // 璇存槑娌℃瘮鍒扮浉浼肩殑浜�
@@ -143,17 +143,17 @@
 	var msg []byte
 
 	if sock, err = req.NewSocket(); err != nil {
-		_ = logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
+		logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
 	}
 	errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
 	if errSize != nil {
-		_ = logger.Error("Failed set MaxRecvSize: %v", err)
+		logger.Error("Failed set MaxRecvSize: %v", err)
 	}
 	//sock.AddTransport(ipc.NewTransport())
 	sock.AddTransport(tcp.NewTransport())
 	serverIP, _ := GetLocalIP()
 	if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
-		_ = logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
+		logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
 	}
 	logger.Info("搴忓垪鍖栨暟鎹�")
 	initFlag = true
@@ -162,10 +162,10 @@
 		case data := <- sender:
 			logger.Debug("鎺ㄩ�佹暟鎹�:",len(data))
 			if err = sock.Send(data); err != nil {
-				_ = logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
+				logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
 			}
 			if msg, err = sock.Recv(); err != nil {
-				_ = logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
+				logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
 			}
 			logger.Debug("鏁版嵁鎺ㄩ�佹垚鍔燂紒鏀跺埌鍝嶅簲,鏁版嵁闀垮害涓猴細",len(msg))
 			receiver <- string(msg)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index 4fbe1d0..1d06682 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -107,7 +107,7 @@
 func InsertToEs(msg structure.ResultMsg) {
 	defer func() {
 		if err := recover(); err != nil {
-			_ = logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
+			logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
 		}
 	}()
 	localConfig1, err := cache.GetServerInfo()
@@ -143,7 +143,7 @@
 		faces = PutFace(faces, results.([]structure.Result))
 		//logger.Info("鏁寸悊鍚庣殑鏁版嵁锛�",faces)
 		if faces != nil {
-			_ = logger.Warn("face涓嶄负nil")
+			logger.Warn("face涓嶄负nil")
 			var imgMaxUrl []string = []string{}
 			var picTime string = ""
 			for _, face := range faces {
@@ -165,7 +165,7 @@
 				bytes := util.SubImg(i, int(face.Location.X), int(face.Location.Y), int(face.Location.X+face.Location.Width), int(face.Location.Y+face.Location.Height),face.Type)
 				resp, err := util.PostFormBufferData1(weedfsUrl, bytes, uuid.NewV4().String())
 				if err != nil {
-					_ = logger.Error("涓婁紶灏忓浘鍑洪敊")
+					logger.Error("涓婁紶灏忓浘鍑洪敊")
 				}
 				// 涓婁紶澶у浘
 				if len(imgMaxUrl) == 0 {
@@ -242,7 +242,7 @@
 					esid := face.Liker[0].TargetId
 					returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
 					if err1 != nil {
-						_ = logger.Error("杩藉姞鏁版嵁鍑洪敊锛�---", err1)
+						logger.Error("杩藉姞鏁版嵁鍑洪敊锛�---", err1)
 					} else {
 						logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", returnMsg)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -251,7 +251,7 @@
 				} else {
 					resp1, err1 := EsReq("POST", videoPersonUrl, requstbody)
 					if err1 != nil {
-						_ = logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
+						logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
 					} else {
 						logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -347,7 +347,7 @@
 							err = proto.Unmarshal(bdata, &i)
 							resp1, err1 := util.DrawPolygonOnImageForYolo(msg1.Cid, i, msg1.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 							if err1 != nil {
-								_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+								logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 							} else {
 								logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 							}
@@ -407,7 +407,7 @@
 				//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 				resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 				if err != nil {
-					_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+					logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 					return
 				} else {
 					logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
@@ -461,7 +461,7 @@
 				}
 				resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
 				if err2 != nil {
-					_ = logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
+					logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
 				} else {
 					logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛坹olo锛夛細", resp1)
 					// 鍙戝嚭褰曞儚淇″彿
@@ -470,7 +470,7 @@
 						logger.Info("鑱斿姩浠诲姟鐨勫綍鍍忎俊鍙凤細", index)
 						ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: link.CameraId, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{strconv.Itoa(index)}, Type: 2})
 					}
-					_ = logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
+					logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
 					//os.Exit(1)
 				}
 			}
@@ -544,7 +544,7 @@
 					//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 					resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["target"].([]structure.Result), weedfsUrl)
 					if err != nil {
-						_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+						logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 						return
 					} else {
 						logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
@@ -621,7 +621,7 @@
 					}
 					resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
 					if err2 != nil {
-						_ = logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
+						logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
 					} else {
 						logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛坱arget锛夛細", resp1)
 						// 鍙戝嚭褰曞儚淇″彿
@@ -630,7 +630,7 @@
 							logger.Info("鑱斿姩浠诲姟鐨勫綍鍍忎俊鍙凤細", index)
 							ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: link.CameraId, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{strconv.Itoa(index)}, Type: 2})
 						}
-						_ = logger.Warn("__________________________________________寰�ES鎻掑叆target鏁版嵁鎴愬姛")
+						logger.Warn("__________________________________________寰�ES鎻掑叆target鏁版嵁鎴愬姛")
 						//os.Exit(1)
 					}
 				}
@@ -704,7 +704,7 @@
 	err = proto.Unmarshal(bdata, &i)
 	resp1, err1 := util.DrawPolygonOnImageForTarget(msg.Cid, i, msg.RuleResult["target"].([]structure.Result), weedfsUrl)
 	if err1 != nil {
-		_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+		logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 	} else {
 		logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 	}
@@ -813,7 +813,7 @@
 							err = proto.Unmarshal(bdata, &i)
 							resp1, err1 := util.DrawPolygonOnImageForYolo(msg1.Cid, i, msg1.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 							if err1 != nil {
-								_ = logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+								logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 							} else {
 								logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp1)
 							}
@@ -856,7 +856,7 @@
 				//resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
 				resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
 				if err != nil {
-					_ = logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
+					logger.Error("鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 					return nil
 				} else {
 					logger.Info("涓婁紶鐨勫浘鐗囦俊鎭細", resp)
diff --git a/labelFilter/req.go b/labelFilter/req.go
index f2b57ba..2677ef6 100644
--- a/labelFilter/req.go
+++ b/labelFilter/req.go
@@ -90,32 +90,32 @@
 	}
 	errSize := sock.SetOption(mangos.OptionMaxRecvSize,30*1024*1024)
 	if errSize != nil {
-		_ = logger.Error("浼犺緭鐨勬暟鎹秴杩囧ぇ灏忛檺鍒�")
+		logger.Error("浼犺緭鐨勬暟鎹秴杩囧ぇ灏忛檺鍒�")
 		return
 	}
 	errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 1500)
 	if errTimeOut != nil {
-		_ = logger.Error("鎺ユ敹鍝嶅簲瓒呮椂")
+		logger.Error("鎺ユ敹鍝嶅簲瓒呮椂")
 		return
 	}
 	errTimeOut1 := sock.SetOption(mangos.OptionSendDeadline,time.Millisecond * 1500)
 	if errTimeOut1 != nil {
-		_ = logger.Error("鍙戦�佽秴鏃�")
+		logger.Error("鍙戦�佽秴鏃�")
 		return
 	}
 	errWrite := sock.SetOption(mangos.OptionWriteQLen,5)
 	if errWrite != nil {
-		_ = logger.Error("璁剧疆浼犺緭缂撳瓨澶у皬澶辫触")
+		logger.Error("璁剧疆浼犺緭缂撳瓨澶у皬澶辫触")
 		return
 	}
 	errRead := sock.SetOption(mangos.OptionReadQLen,5)
 	if errRead != nil {
-		_ = logger.Error("璁剧疆浼犺緭缂撳瓨澶у皬澶辫触")
+		logger.Error("璁剧疆浼犺緭缂撳瓨澶у皬澶辫触")
 		return
 	}
 	sock.AddTransport(tcp.NewTransport())
 	if err = sock.Dial("tcp://"+url); err != nil {
-		_ = logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: ", err.Error())
+		logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: ", err.Error())
 	}
 	logger.Info("搴忓垪鍖栨暟鎹�")
 
diff --git a/ruleserver/readyDataForRule.go b/ruleserver/readyDataForRule.go
index 4feafdc..479e9d5 100644
--- a/ruleserver/readyDataForRule.go
+++ b/ruleserver/readyDataForRule.go
@@ -281,12 +281,12 @@
 	//}
 	errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
 	if errSize != nil {
-		_ = logger.Error("Failed set MaxRecvSize: %v", err)
+		logger.Error("Failed set MaxRecvSize: %v", err)
 		return nil
 	}
 	serverIP, _ := GetLocalIP()
 	if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
-		_ = logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
+		logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
 	}
 	//sock.AddTransport(ipc.NewTransport())
 	sock.AddTransport(tcp.NewTransport())
@@ -300,11 +300,11 @@
 	logger.Debug("鎺ㄩ�佹暟鎹�")
 	//bytes := []byte("ndfasojdfaidsos")
 	if err = sock.Send(bytes); err != nil {
-		_ = logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
+		logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
 		//os.Exit(1)
 	}
 	if msg, err = sock.Recv(); err != nil {
-		_ = logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
+		logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
 		//os.Exit(1)
 	}
 	logger.Debug("鏁版嵁鎺ㄩ�佹垚鍔燂紒鏀跺埌鍝嶅簲,鏁版嵁闀垮害涓猴細",len(msg))
@@ -317,17 +317,17 @@
 	var msg []byte
 
 	if sock, err = req.NewSocket(); err != nil {
-		_ = logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
+		logger.Error("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
 	}
 	errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
 	if errSize != nil {
-		_ = logger.Error("Failed set MaxRecvSize: %v", err)
+		logger.Error("Failed set MaxRecvSize: %v", err)
 	}
 	//sock.AddTransport(ipc.NewTransport())
 	sock.AddTransport(tcp.NewTransport())
 	serverIP, _ := GetLocalIP()
 	if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
-		_ = logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
+		logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: %s", err.Error())
 	}
 	logger.Info("搴忓垪鍖栨暟鎹�")
 
@@ -344,10 +344,10 @@
 			}
 			logger.Debug("鎺ㄩ�佹暟鎹�")
 			if err = sock.Send(bytes); err != nil {
-				_ = logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
+				logger.Error("鎺ㄩ�乻ocket鍙戦�佹暟鎹け璐�: %s", err.Error())
 			}
 			if msg, err = sock.Recv(); err != nil {
-				_ = logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
+				logger.Error("鎺ユ敹鍝嶅簲澶辫触: %s", err.Error())
 			}
 			logger.Debug("鏁版嵁鎺ㄩ�佹垚鍔燂紒鏀跺埌鍝嶅簲,鏁版嵁闀垮害涓猴細",len(msg))
 			receiver <- msg

--
Gitblit v1.8.0