| | |
| | | } |
| | | } |
| | | } |
| | | 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解压错误", 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) |
| | | } |
| | | } |
| | | func Compare(args *SdkDatas, groupRule *protomsg.GroupRule) { |
| | | compareFlag := 0 |
| | | tableIds := "" |
| | |
| | | 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解压错误", 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, ",") |
| | |
| | | logger.Info("-------------------成功给liker赋值,长度为:", len(arg.Liker)) |
| | | } |
| | | logger.Info("=======第一次看args:",areaMap.args) |
| | | 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解压错误", 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解压错误", 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("-------------------成功给liker赋值,长度为:", len(arg.Liker)) |
| | | } |
| | | logger.Info("----------------------第二次看args:",areaMap.filterData) |
| | | } |
| | | } |
| | | } |