{ "85_mgo_addr": "192.168.3.207:27092", "mongodbPoolSize": 10, "collection": "result_20210109", "163_mgo_addr": "172.17.4.187:27082,172.17.145.163:27083", "163_userName": "zhengkun", "163_passWord": "zk@123123", "fields": { "buyer": 1, "agency": 1, "winner": 1, "s_winner": 1 }, "buyer_c": "", "agency_c": "", "winner_c": "", "udpport": "1782", "nextNode": [ { "addr": "127.0.0.1", "port": 88888, "memo": "抽取城市" } ], "userName": "", "passWord": "", "client_es": "http://ela.spdata.jianyu360.com", "es_type": "unique_qy", "es_index": "unique_qy" } if win, isok := tmp["winner"].(string); isok { if fok, flog, fname := cheakname(win); fok && flog != "" && flog != "tremQuery" { tmp["winner"] = fname up["winner"] = fmt.Sprintf("%s_%s", flog, win) } } if win, isok := tmp["s_winner"].(string); isok { if fok, flog, fname := cheakname(win); fok && flog != "" && flog != "tremQuery" { tmp["s_winner"] = fname up["s_winner"] = fmt.Sprintf("%s_%s", flog, win) } } if agency, isok := tmp["agency"].(string); isok { if fok, flog, fname := cheakname(agency); fok && flog != "" && flog != "tremQuery" { tmp["agency"] = fname up["agency"] = fmt.Sprintf("%s_%s", flog, agency) } } if buyer, isok := tmp["buyer"].(string); isok { if fok, flog, fname := cheakname(buyer); fok && flog != "" && flog != "tremQuery"&& flog != "queryScore"&& flog != "queryString" { tmp["buyer"] = fname up["buyer"] = fmt.Sprintf("%s_%s", flog, buyer) } }