diff --git a/dsBaseRpc/Config/Config.ini b/dsBaseRpc/Config/Config.ini index 6db2b79d..f6bc271f 100644 --- a/dsBaseRpc/Config/Config.ini +++ b/dsBaseRpc/Config/Config.ini @@ -32,4 +32,6 @@ KafkaAddress = server.dsmin.com:9092 # 数据汇集的地址 [dataExchange] -url = http://10.10.14.239:9009/v1/dataex/DataexSet +url = http://10.10.14.239:9009/v1/dataex/DataexSet +AuthToken = DSDataex_Token_eb4ab2fea87161dc08fa794a648584c4 +SystemId = BASE_GO diff --git a/dsBaseRpc/DataExchange/DataExchange.go b/dsBaseRpc/DataExchange/DataExchange.go index ea8aab00..f1f542f0 100644 --- a/dsBaseRpc/DataExchange/DataExchange.go +++ b/dsBaseRpc/DataExchange/DataExchange.go @@ -223,8 +223,8 @@ func PostToServer(t tableStruct, list []map[string]interface{}) bool { //上报到Http Api--->Body--->Post var ps postStruct ps.DataSource = t.DataSource - ps.AuthToken = "DSDataex_Token_eb4ab2fea87161dc08fa794a648584c4" - ps.SystemId = "BASE_GO" + ps.AuthToken = ConfigUtil.DataExchangeAuthToken + ps.SystemId = ConfigUtil.DataExchangeSystemId var dsMap = make([]dataStruct, 0) for k := range list { diff --git a/dsBaseRpc/Utils/ConfigUtil/ConfigUtil.go b/dsBaseRpc/Utils/ConfigUtil/ConfigUtil.go index cb947408..dbc003d5 100644 --- a/dsBaseRpc/Utils/ConfigUtil/ConfigUtil.go +++ b/dsBaseRpc/Utils/ConfigUtil/ConfigUtil.go @@ -40,7 +40,9 @@ var ( KafkaAddress string //数据汇集中心地址 - DataExchangeUrl string + DataExchangeUrl string + DataExchangeAuthToken string + DataExchangeSystemId string ) func init() { @@ -98,6 +100,8 @@ func init() { //数据汇集中心地址 DataExchangeUrl=iniParser.GetString("dataExchange","url") + DataExchangeAuthToken =iniParser.GetString("dataExchange","AuthToken") + DataExchangeSystemId =iniParser.GetString("dataExchange","SystemId") } type IniParser struct {