~jinersong/ruleprocess.git

			@@ -1,23 +1,22 @@
			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"
			)
			@@ -177,7 +176,7 @@
			Source:false,
			}
			serverIp, _ := GetLocalIP()
			bytes := Push("tcp://"+serverIp+":40010",comArg,sock)
			bytes := Push("tcp://"+serverIp+":4010",comArg,sock)
			var scResult protomsg.SdkCompareResult
			err1 := proto.Unmarshal(bytes, &scResult)
			if err1 != nil {
			@@ -193,16 +192,20 @@
			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))
			}
			@@ -357,11 +360,11 @@
			//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