| | |
|---|
| | | package service |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "basic.com/valib/logger.git" |
|---|
| | | "encoding/json" |
|---|
| | | "fmt" |
|---|
| | | "strconv" |
|---|
| | | "webserver/cache" |
|---|
| | | "webserver/extend/config" |
|---|
| | | "webserver/extend/esutil" |
|---|
| | | "webserver/models" |
|---|
| | |
|---|
| | | |
|---|
| | | // 地库人员数据 为 比对做准备 |
|---|
| | | func QueryDbPersonsForCompare(reqBody models.EsSearch) map[string]interface{} { |
|---|
| | | url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport + |
|---|
| | | localConf, err2 := cache.GetServerInfo() |
|---|
| | | if err2 !=nil || localConf.AlarmIp == "" { |
|---|
| | | logger.Debug("localConfig is wrong!!!") |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) + |
|---|
| | | "/" + config.EsInfo.EsIndex.Dbtablepersons.IndexName + "/_search" |
|---|
| | | tableIds := make([]string, 20) |
|---|
| | | if reqBody.DataBases != nil { |
|---|
