| | |
|---|
| | | package ruleserver |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "basic.com/dbapi.git" |
|---|
| | | bigCache "basic.com/pubsub/cache.git" |
|---|
| | | "basic.com/pubsub/cache.git/esutil" |
|---|
| | | "basic.com/pubsub/protomsg.git" |
|---|
| | | "encoding/json" |
|---|
| | | "errors" |
|---|
| | | "fmt" |
|---|
| | | "github.com/go-yaml/yaml" |
|---|
| | | "github.com/golang/protobuf/proto" |
|---|
| | | "io/ioutil" |
|---|
| | | "math" |
|---|
| | | "nanomsg.org/go-mangos" |
|---|
| | | "nanomsg.org/go-mangos/protocol/req" |
|---|
| | | "nanomsg.org/go-mangos/transport/tcp" |
|---|
| | | "net" |
|---|
| | | "os" |
|---|
| | | "ruleprocess/cache" |
|---|
| | | "ruleprocess/logger" |
|---|
| | | "github.com/golang/protobuf/proto" |
|---|
| | | "strconv" |
|---|
| | | "time" |
|---|
| | | ) |
|---|
| | |
|---|
| | | logger.Info("------------------------------------------------------------------------------------------------------------------------") |
|---|
| | | //logger.Info("=====================人员id的集合为：",ids) |
|---|
| | | if len(ids) > 0 { |
|---|
| | | baseinfos, err1 := esutil.Dbpersoninfosbyid(ids, dbTablePersons, serverIp, serverPort) |
|---|
| | | var dbApi dbapi.DbPersonApi |
|---|
| | | baseinfos, err1 := dbApi.Dbpersoninfosbyid(ids) |
|---|
| | | //baseinfos, err1 := esutil.Dbpersoninfosbyid(ids, dbTablePersons, serverIp, serverPort) |
|---|
| | | if err1 != nil { |
|---|
| | | logger.Error("查询底库人员信息出错", err1) |
|---|
| | | } |
|---|
| | | var dtapi dbapi.DbTableApi |
|---|
| | | for _, baseinfo := range baseinfos { |
|---|
| | | // 根据tableId查询底库信息给liker赋值 |
|---|
| | | //logger.Info("---------看看每个底库人员的信息：",baseinfo.Id,baseinfo.PersonName) |
|---|
| | | tableIds := []string{} |
|---|
| | | tableIds = append(tableIds, baseinfo.TableId) // 虽然是传入数组返回数组的接口，但我按单个的使用了 |
|---|
| | | table, err := esutil.Dbtablefosbyid(tableIds, "dbtables", serverIp, serverPort) |
|---|
| | | table, err := dtapi.DbtablesById(tableIds) |
|---|
| | | //table, err := esutil.Dbtablefosbyid(tableIds, "dbtables", serverIp, serverPort) |
|---|
| | | if err != nil || len(table) == 0 { |
|---|
| | | logger.Error("根据id查询底库信息出错！", err, "--返回值长度为：", len(table)) |
|---|
| | | } |
|---|
| | |
|---|
| | | //bytes := []byte("ndfasojdfaidsos") |
|---|
| | | if err = sock.Send(bytes); err != nil { |
|---|
| | | logger.Error("推送socket发送数据失败: %s", err.Error()) |
|---|
| | | os.Exit(1) |
|---|
| | | //os.Exit(1) |
|---|
| | | } |
|---|
| | | if msg, err = sock.Recv(); err != nil { |
|---|
| | | logger.Error("接收响应失败: %s", err.Error()) |
|---|
| | | os.Exit(1) |
|---|
| | | //os.Exit(1) |
|---|
| | | } |
|---|
| | | logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg)) |
|---|
| | | return msg |
|---|
