From 4860c7b312cdce2d948ee417b0bb1fed60fd9dc7 Mon Sep 17 00:00:00 2001 From: liujiandao <274878379@qq.com> Date: 星期二, 20 二月 2024 17:09:37 +0800 Subject: [PATCH] 更新与对比修改 --- cache/compare.go | 30 +++++++++++++++--------------- 1 files changed, 15 insertions(+), 15 deletions(-) diff --git a/cache/compare.go b/cache/compare.go index d2e5b23..88fd8d7 100644 --- a/cache/compare.go +++ b/cache/compare.go @@ -82,7 +82,7 @@ // 璋冪敤澧為噺鐨勬帴鍙� captures, err := libEs.GetPeriodInfos(serverIp, alarmPort, laststring, curstring, indexName, shardStr, targetType) if err != nil { - logger.Debug(err) + logger.Error(err) return } for _, ei := range captures { @@ -102,7 +102,7 @@ func getShards(serverIp string, alarmIp string, alarmPort string) (string, error) { infos, e := libEs.GetShardsByIndex(alarmIp, alarmPort, config.EsInfo.EsIndex.AiOcean.IndexName) if e != nil || infos == nil { - logger.Debug("get es primary ips err") + logger.Error("get es primary ips err") return "", errors.New("get es primary ips err") } @@ -148,7 +148,7 @@ captures, err := libEs.GetOceanFeatures(serverIp, alarmPort, 1000, indexName, shardStr, targetType) if err != nil { - logger.Debug("libEs.GetOceanFeatures err:", err) + logger.Error("libEs.GetOceanFeatures err:", err) return err } logger.Debug("len(captures):", len(captures)) @@ -238,7 +238,7 @@ defer wg.Done() dbpersons, err := dbpApi.GetPersonsCompareCacheBase(j, queryEachNum) if err != nil { - logger.Debug(err) + logger.Error(err) return } logger.Debugf("鑾峰彇%d鏉′汉鍛樹俊鎭�", len(dbpersons)) @@ -271,7 +271,7 @@ var dbpApi DbPersons info, err := dbpApi.GetPersonsCompareCacheById(id) if err != nil { - logger.Debug(err) + logger.Error(err) return } if info.Tableid != "" { @@ -310,7 +310,7 @@ Cmap.Cam[tableId].Del(id) logger.Debug("DelPerson ok success") } else { - logger.Debug("tableId:", tableId, " not exist") + logger.Error("tableId:", tableId, " not exist") } } @@ -425,7 +425,7 @@ for _, tid := range compareArgs.TableIds { //ruleProcess姣斿鎸囧畾搴曞簱 shardins, ok := Cmap.Cam[tid] if !ok { - logger.Debug("ruleProcess compare get shard error by tableId:", tid) + logger.Error("ruleProcess compare get shard error by tableId:", tid) continue } if tShard, hasT := Cmap.Cam[PRE_DBTABLE]; hasT { @@ -438,10 +438,10 @@ } } } else { - logger.Debug("ruleProcess compare tables,tShard not exist tableId:", tid) + logger.Error("ruleProcess compare tables,tShard not exist tableId:", tid) } } else { - logger.Debug("ruleProcess compare tables,PRE_DBTABLE tableId:", tid, " not exist") + logger.Error("ruleProcess compare tables,PRE_DBTABLE tableId:", tid, " not exist") } } } else { //web璇锋眰锛屾瘮瀵规寚瀹氱殑鎶撴媿搴撴垨鑰呭簳搴� @@ -450,7 +450,7 @@ tStart := time.Now() serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter) if e != nil { - logger.Debug("util.GetLocalIP err:", e) + logger.Error("util.GetLocalIP err:", e) continue } alarmPort := config.EsCompServerInfo.ESPort @@ -519,7 +519,7 @@ } else { shardins, ok := Cmap.Cam[tid] if !ok { - logger.Debug("get shard error by tableId:", tid) + logger.Error("get shard error by tableId:", tid) continue } @@ -536,7 +536,7 @@ buf, err := proto.Marshal(&scResult) if err != nil { - logger.Debug("scResult Marshal error!", err) + logger.Error("scResult Marshal error!", err) return nil } @@ -547,16 +547,16 @@ co_d, err := base64.StdEncoding.DecodeString(co) if err != nil { - logger.Debug("DoSdkCompare err:", err) + logger.Error("DoSdkCompare err:", err) return -1 } if len(co_d) != 2560 { - logger.Debug("target fea.len !=2560") + logger.Error("target fea.len !=2560") return -1 } if len(ci) != 2560 { - logger.Debug("source fea.len !=2560") + logger.Error("source fea.len !=2560") return -1 } sec := DecCompare(ci, co_d) -- Gitblit v1.8.0