~jinersong/ruleprocess.git

			@@ -13,7 +13,7 @@
			"nanomsg.org/go-mangos/transport/tcp"
			"net"
			"ruleprocess/cache"
			"ruleprocess/logger"
			"basic.com/valib/logger.git"
			"strconv"
			"time"
			)
			@@ -219,7 +219,7 @@
			if groupRule.Rules[j].SdkArgAlias == "compareBase" && groupRule.Rules[j].SdkArgValue == "" { // 配的参数是比对全部底库
			compareFlag = 1
			}
			if groupRule.Rules[j].SdkArgAlias == "threshold" {
			if groupRule.Rules[j].SdkArgAlias == "cmpThreshold" {
			v2, err := strconv.ParseFloat(groupRule.Rules[j].SdkArgValue, 32)
			if err != nil {
			logger.Error("string转float32失败！")
			@@ -384,7 +384,7 @@
			// case <-ctx.Done():
			// return
			case data := <- sender:
			logger.Info("比对进程入参：",data.TableIds)
			logger.Info("比对进程入参：",data.TableIds,data.CompareThreshold)
			bytes,err1 := proto.Marshal(data)
			logger.Info("数据长度为：",len(bytes))
			if err1 != nil {