'commit'

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

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.AuthToken = ConfigUtil.DataExchangeAuthToken
-	ps.SystemId = "BASE_GO"
+	ps.SystemId = ConfigUtil.DataExchangeSystemId
 
 	var dsMap = make([]dataStruct, 0)
 	for k := range list {

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 {