mark 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. {
  2. "85_mgo_addr": "192.168.3.207:27092",
  3. "mongodbPoolSize": 10,
  4. "collection": "result_20210109",
  5. "163_mgo_addr": "172.17.4.187:27082,172.17.145.163:27083",
  6. "163_userName": "zhengkun",
  7. "163_passWord": "zk@123123",
  8. "fields": {
  9. "buyer": 1,
  10. "agency": 1,
  11. "winner": 1,
  12. "s_winner": 1
  13. },
  14. "buyer_c": "",
  15. "agency_c": "",
  16. "winner_c": "",
  17. "udpport": "1782",
  18. "nextNode": [
  19. {
  20. "addr": "127.0.0.1",
  21. "port": 88888,
  22. "memo": "抽取城市"
  23. }
  24. ],
  25. "userName": "",
  26. "passWord": "",
  27. "client_es": "http://ela.spdata.jianyu360.com",
  28. "es_type": "unique_qy",
  29. "es_index": "unique_qy"
  30. }
  31. if win, isok := tmp["winner"].(string); isok {
  32. if fok, flog, fname := cheakname(win); fok && flog != "" && flog != "tremQuery" {
  33. tmp["winner"] = fname
  34. up["winner"] = fmt.Sprintf("%s_%s", flog, win)
  35. }
  36. }
  37. if win, isok := tmp["s_winner"].(string); isok {
  38. if fok, flog, fname := cheakname(win); fok && flog != "" && flog != "tremQuery" {
  39. tmp["s_winner"] = fname
  40. up["s_winner"] = fmt.Sprintf("%s_%s", flog, win)
  41. }
  42. }
  43. if agency, isok := tmp["agency"].(string); isok {
  44. if fok, flog, fname := cheakname(agency); fok && flog != "" && flog != "tremQuery" {
  45. tmp["agency"] = fname
  46. up["agency"] = fmt.Sprintf("%s_%s", flog, agency)
  47. }
  48. }
  49. if buyer, isok := tmp["buyer"].(string); isok {
  50. if fok, flog, fname := cheakname(buyer); fok && flog != "" && flog != "tremQuery"&& flog != "queryScore"&& flog != "queryString" {
  51. tmp["buyer"] = fname
  52. up["buyer"] = fmt.Sprintf("%s_%s", flog, buyer)
  53. }
  54. }