From b389b057d61f22961fb06fdd5a26bbdf7c407b03 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期四, 11 七月 2019 14:05:53 +0800 Subject: [PATCH] --- --- ruleserver/ruleToformula.go | 78 ++++++++++---------------------------- 1 files changed, 21 insertions(+), 57 deletions(-) diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go index 0d2e914..ccb3552 100644 --- a/ruleserver/ruleToformula.go +++ b/ruleserver/ruleToformula.go @@ -222,6 +222,25 @@ } } } +func (arg *Arg) fillLiker(){ + bytes := bigCache.Getdbpersonmsg("", arg.Feature, true) + var m map[string]float32 + err1 := json.Unmarshal(bytes, &m) + if err1 != nil { + logger.Error("getBaseInfo瑙e帇閿欒", err1) + } + logger.Info("----------------------------------------map鏄�", m) + for key, val := range m { + logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val) + baseinfo, err1 := esutil.Dbpersoninfosbyid(key) + if err1 != nil { + logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1) + } + baseinfo.CompareScore = val + arg.Liker = append(arg.Liker, &baseinfo) + } + logger.Info("------------------绗竴娆$湅args:",*arg) +} func Compare(args *SdkDatas, groupRule *protomsg.GroupRule) { compareFlag := 0 tableIds := "" @@ -253,22 +272,7 @@ if groupRule.Rules[j].PolygonId == areaMap.areaId { for _, arg := range areaMap.args { if compareFlag == 1 { - bytes := bigCache.Getdbpersonmsg("", arg.Feature, true) - var m map[string]float32 - err1 := json.Unmarshal(bytes, &m) - if err1 != nil { - logger.Error("getBaseInfo瑙e帇閿欒", err1) - } - logger.Info("----------------------------------------map鏄�", m) - for key, val := range m { - logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val) - baseinfo, err1 := esutil.Dbpersoninfosbyid(key) - if err1 != nil { - logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1) - } - baseinfo.CompareScore = val - arg.Liker = append(arg.Liker, &baseinfo) - } + arg.fillLiker() } if compareFlag == 2 { array := strings.Split(tableIds, ",") @@ -291,47 +295,7 @@ } logger.Info("-------------------鎴愬姛缁檒iker璧嬪��,闀垮害涓猴細", len(arg.Liker)) } - for _, arg := range areaMap.filterData { - if compareFlag == 1 { - bytes := bigCache.Getdbpersonmsg("", arg.Feature, true) - var m map[string]float32 - err1 := json.Unmarshal(bytes, &m) - if err1 != nil { - logger.Error("getBaseInfo瑙e帇閿欒", err1) - } - logger.Info("----------------------------------------map鏄�", m) - for key, val := range m { - logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val) - baseinfo, err1 := esutil.Dbpersoninfosbyid(key) - if err1 != nil { - logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1) - } - baseinfo.CompareScore = val - arg.Liker = append(arg.Liker, &baseinfo) - } - } - if compareFlag == 2 { - array := strings.Split(tableIds, ",") - for i := 0; i < len(array)-1; i++ { - bytes := bigCache.Getdbpersonmsg(array[i], arg.Feature, true) - var m map[string]float32 - err1 := json.Unmarshal(bytes, &m) - if err1 != nil { - logger.Error("getBaseInfo瑙e帇閿欒", err1) - } - for key, val := range m { - baseinfo, err1 := esutil.Dbpersoninfosbyid(key) - if err1 != nil { - logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1) - } - baseinfo.CompareScore = val - arg.Liker = append(arg.Liker, &baseinfo) - } - } - } - logger.Info("-------------------鎴愬姛缁檒iker璧嬪��,闀垮害涓猴細", len(arg.Liker)) - } - logger.Info("----------------------绗簩娆$湅args锛�",areaMap.filterData) + logger.Info("=======绗竴娆$湅args锛�",areaMap.args) } } } -- Gitblit v1.8.0