From d8d991f239fb5e2fcb8ca134da6feb1758f6dade Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 19 十月 2019 19:43:27 +0800
Subject: [PATCH] add ip config

---
 syssetApi.go         |   37 ++-
 sysRoleApi.go        |   25 ++
 sdkApi.go            |   26 ++
 cameraApi.go         |   60 ++++--
 dbpersonApi.go       |   34 ++-
 client.go            |    3 
 eventPush.go         |   29 ++
 cluster.go           |   35 ++-
 sysMenuApi.go        |   21 ++
 areaApi.go           |   30 ++
 taskSdkRuleApi.go    |   23 ++
 userApi.go           |   25 ++
 cameraTaskApi.go     |   31 ++
 soApi.go             |   23 ++
 cameraTaskArgsApi.go |   27 ++
 dbtableApi.go        |   53 +++--
 taskApi.go           |   33 ++
 dicApi.go            |   19 +
 18 files changed, 403 insertions(+), 131 deletions(-)

diff --git a/areaApi.go b/areaApi.go
index e1d10ca..64fb84a 100644
--- a/areaApi.go
+++ b/areaApi.go
@@ -3,9 +3,25 @@
 import (
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type AreaApi struct {
+	Ip string
+	Port int
+}
+
+func (api AreaApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 //parentId 瑕佹煡瀵荤殑鐩綍鏍戠殑鏍硅妭鐐筰d
@@ -16,7 +32,7 @@
 
 	client := NewClient()
 
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/localmenu"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/localmenu"
 	params := make(map[string]string, 0)
 	params["parentId"] = parentId
 	params["searchType"] = searchType
@@ -47,7 +63,7 @@
 
 	client := NewClient()
 
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/gb28181Tree"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/gb28181Tree"
 	params := make(map[string]string, 0)
 	params["parentId"] = parentId
 	params["searchType"] = searchType
@@ -72,7 +88,7 @@
 
 func (api AreaApi) Gb28181TreeRefresh(id string) bool {
 	flag := false
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/gb28181TreeRefresh"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/gb28181TreeRefresh"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"id":id,
@@ -91,7 +107,7 @@
 
 func (api AreaApi) Gb28181TreeDelete() bool {
 	flag := false
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/gb28181TreeDelete"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/gb28181TreeDelete"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, nil, nil, nil)
 	if err != nil {
@@ -108,7 +124,7 @@
 //娣诲姞鐩綍鑺傜偣
 func (api AreaApi) AreaAdd(paramBody map[string]interface{}) bool {
 	flag := false
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/add"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/add"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil)
 	if err != nil {
@@ -125,7 +141,7 @@
 //鐩綍鏇存柊
 func (api AreaApi) AreaUpdate(paramBody map[string]interface{}) bool {
 	flag := false
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/update"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/update"
 	client := NewClient()
 
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil, nil)
@@ -147,7 +163,7 @@
 	if id == "" {
 		return flag
 	}
-	url := BASIC_URL + DATA_URL_PREFIX + "/area/del"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/area/del"
 	client := NewClient()
 	paramBody := make(map[string]interface{}, 0)
 	paramBody["id"] = id
diff --git a/cameraApi.go b/cameraApi.go
index 3c7b69e..a4d2311 100644
--- a/cameraApi.go
+++ b/cameraApi.go
@@ -7,10 +7,26 @@
 	"strconv"
 )
 
-type CameraApi struct{}
+type CameraApi struct{
+	Ip string
+	Port int
+}
+
+func (api CameraApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
 
 func (api CameraApi) CameraAdd(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/add"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/add"
 	client := NewClient()
 	body, err := client.DoPostRequest(url,CONTENT_TYPE_JSON,paramBody,nil,nil)
 	if err != nil {
@@ -25,7 +41,7 @@
 }
 
 func (api CameraApi) CameraUpdate(paramBody map[string]interface{}) bool {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/update"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/update"
 	client := NewClient()
 	body, err := client.DoPutRequest(url,CONTENT_TYPE_JSON,paramBody,nil)
 	if err != nil {
@@ -40,7 +56,7 @@
 }
 
 func (api CameraApi) UpdateSnapshotUrl(cameraId string, snapshot string) bool {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/updateSnapshot"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/updateSnapshot"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["snapshot"] = snapshot
@@ -60,7 +76,7 @@
 }
 
 func (api CameraApi) CameraDelete(cid string) bool {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/del/"+cid
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/del/"+cid
 	client := NewClient()
 	paramMap := make(map[string]string,0)
 	paramMap["cid"] = cid
@@ -78,7 +94,7 @@
 
 //閫氳繃cameraId鑾峰彇鎽勫儚鏈轰俊鎭�
 func (api CameraApi) GetCameraById(cameraId string) (camera protomsg.Camera, err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/show/" + cameraId
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/show/" + cameraId
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -98,7 +114,7 @@
 }
 
 func (api CameraApi) FindAll() (cameras []protomsg.Camera) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/showAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/showAll"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -119,7 +135,7 @@
 }
 
 func (api CameraApi) GetAllCamerasByServer(serverId string,cameraName string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/getAllCamerasByServer"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/getAllCamerasByServer"
 	client := NewClient()
 	paramQuery := make(map[string]string,0)
 	paramQuery["serverId"] = serverId
@@ -139,7 +155,7 @@
 
 //鑾峰彇鎵�鏈夋憚鍍忔満鐨勪俊鎭互鍙婂叾鎵�鏈変换鍔�
 func (api CameraApi) FindAllCameraAndTask() (cameraTasks []protomsg.CameraAndTaskInfo){
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/queryCameraAndTaskInfo"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/queryCameraAndTaskInfo"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -160,7 +176,7 @@
 }
 
 func (api CameraApi) SaveCameraPolygon(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/save"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/save"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -177,7 +193,7 @@
 }
 
 func (api CameraApi) DeleteCameraPolygon(id string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/delete"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/delete"
 	client := NewClient()
 	paramQuery := make(map[string]string,0)
 	paramQuery["id"]=id
@@ -195,7 +211,7 @@
 
 func (api CameraApi) FindAllPolygons() ([]protomsg.CameraPolygon) {
 	polygons := make([]protomsg.CameraPolygon,0)
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/findAll"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -216,7 +232,7 @@
 }
 
 func (api CameraApi) FindPolygonsByCameraId(cameraId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/findByCameraId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/findByCameraId"
 	client := NewClient()
 	paramQuery := make(map[string]string,0)
 	paramQuery["cameraId"] = cameraId
@@ -234,7 +250,7 @@
 
 //鏂板鎴栨洿鏂版椂闂磋鍒�
 func (api CameraApi) SaveCameraTimerule(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTimerule/save"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTimerule/save"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -251,7 +267,7 @@
 }
 
 func (api CameraApi) DeleteCameraTimerule (id string) bool {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTimerule/delete"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTimerule/delete"
 	client := NewClient()
 	paramQuery := make(map[string]string,0)
 	paramQuery["id"]=id
@@ -269,7 +285,7 @@
 
 //鏍规嵁鎽勫儚鏈篿d鏌ユ壘鎵�鏈夌殑鏃堕棿瑙勫垯
 func (api CameraApi) FindAllTimeRules() (flag bool,rules []protomsg.CameraTimerule) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTimerule/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTimerule/findAll"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
@@ -288,7 +304,7 @@
 }
 
 func (api CameraApi) UpdateDefenceStateByPolygonId(polygonId string,state string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/updateDefenceStateByPolygonId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/updateDefenceStateByPolygonId"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["polygonId"] = polygonId
@@ -306,7 +322,7 @@
 }
 
 func (api CameraApi) UpdateDefenceStateByCameraId(cameraId string,state string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/polygon/updateDefenceStateByCameraId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/polygon/updateDefenceStateByCameraId"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["cameraId"] = cameraId
@@ -326,7 +342,7 @@
 //鏍规嵁杩愯绫诲瀷鑾峰彇鎽勫儚鏈哄垪琛�
 //runType(0:鑾峰彇杞鍒楄〃锛�1锛氳幏鍙栧疄鏃跺垪琛�)
 func (api CameraApi) GetCamerasByRunType(runType int,cameraName string)(flag bool,cameras []protomsg.Camera){
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/getCamerasByRunType"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/getCamerasByRunType"
 	client := NewClient()
 	paramQuery := make(map[string]string,2)
 	paramQuery["runType"]=strconv.Itoa(runType)
@@ -353,7 +369,7 @@
 }
 
 func (api CameraApi) UpdateRunEnable(cameraId string,runEnable bool) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/updateRunEnable"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/updateRunEnable"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["cameraId"] = cameraId
@@ -373,7 +389,7 @@
 }
 
 func (api CameraApi) UpdateIsRunningState(cameraId string,isRunning bool) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/updateIsRunningState"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/updateIsRunningState"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["cameraId"] = cameraId
@@ -394,7 +410,7 @@
 
 //鎵归噺鍒囨崲鎽勫儚鏈鸿疆璇㈡垨瀹炴椂鐘舵��
 func (api CameraApi) ChangeRunType(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/changeRunType"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/changeRunType"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
diff --git a/cameraTaskApi.go b/cameraTaskApi.go
index 8e44d94..20cdf3d 100644
--- a/cameraTaskApi.go
+++ b/cameraTaskApi.go
@@ -2,14 +2,29 @@
 
 import (
 	"encoding/json"
+	"strconv"
 )
 
 type CameraTaskApi struct {
+	Ip string
+	Port int
+}
 
+func (api CameraTaskApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api CameraTaskApi) AddTask(cameraId string,taskId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/addTask"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/addTask"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"cameraId": cameraId,
@@ -27,7 +42,7 @@
 }
 
 func (api CameraTaskApi) CameraTaskSave(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/saveTask"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/saveTask"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
 	if err != nil {
@@ -41,7 +56,7 @@
 }
 
 func (api CameraTaskApi) FindTasksByCameraIds(cameraIds []string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/alltask"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/alltask"
 	client := NewClient()
 	paramBody :=make(map[string]interface{})
 	paramBody["cameraIds"] = cameraIds
@@ -57,7 +72,7 @@
 }
 
 func (api CameraTaskApi) CameraTaskAll(cameraId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/task/"+cameraId
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/task/"+cameraId
 	client := NewClient()
 	paramQuery :=make(map[string]string)
 	paramQuery["cameraId"] = cameraId
@@ -73,7 +88,7 @@
 }
 
 func (api CameraTaskApi) DeleteCameraTask(cameraId string,taskId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId
 	client := NewClient()
 	respBody, err := client.DoDeleteRequest(url, CONTENT_TYPE_FORM, nil,nil)
 	if err != nil {
@@ -87,7 +102,7 @@
 }
 
 func (api CameraTaskApi) SaveIsDataTrans(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
 	if err != nil {
@@ -101,7 +116,7 @@
 }
 
 func (api CameraTaskApi) SaveAlarmLevelByGroup(groupId string,alarmLevel int) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["group_id"] = groupId
@@ -119,7 +134,7 @@
 
 //鏇存柊鎽勫儚鏈轰换鍔＄姸鎬�
 func (api CameraTaskApi) UpdateCameraTaskStatus(cameraId string,taskId string,statusInt int) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus"
 	client := NewClient()
 	paramBody :=make(map[string]interface{})
 	paramBody["cameraId"] = cameraId
diff --git a/cameraTaskArgsApi.go b/cameraTaskArgsApi.go
index e3b0eaf..5d2b0c6 100644
--- a/cameraTaskArgsApi.go
+++ b/cameraTaskArgsApi.go
@@ -3,14 +3,29 @@
 import (
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
+	"strconv"
 )
 
 type CameraTaskArgsApi struct {
+	Ip string
+	Port int
+}
 
+func (api CameraTaskArgsApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api CameraTaskArgsApi) FindByCameraAndTask(cameraId string,taskId string,setType string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/camera/getRulesByCameraAndTask"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/getRulesByCameraAndTask"
 	client := NewClient()
 	paramQuery :=make(map[string]string)
 	paramQuery["cameraId"] = cameraId
@@ -28,7 +43,7 @@
 }
 
 func (api CameraTaskArgsApi) UpdateDefenceStateByGroup(groupId string,defenceState bool)(bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTaskArgs/updateDefenceStateByGroup"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTaskArgs/updateDefenceStateByGroup"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["groupId"] = groupId
@@ -45,7 +60,7 @@
 }
 
 func (api CameraTaskArgsApi) DeleteByGroup(groupId string)(bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTaskArgs/deleteByGroup"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTaskArgs/deleteByGroup"
 	client := NewClient()
 	paramQuery :=make(map[string]string)
 	paramQuery["groupId"] = groupId
@@ -61,7 +76,7 @@
 }
 
 func (api CameraTaskArgsApi) FindAll() ([]protomsg.CameraTaskArgs){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTaskArgs/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTaskArgs/findAll"
 	client := NewClient()
 	respBody, err := client.DoGetRequest(url, nil,nil)
 	if err != nil {
@@ -78,7 +93,7 @@
 }
 
 func (api CameraTaskArgsApi) GetLinkRulesByCameraIds(paramBody map[string]interface{})(bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTaskArgs/getLinkRulesByCameraIds"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTaskArgs/getLinkRulesByCameraIds"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url,CONTENT_TYPE_JSON,paramBody,nil,nil)
 	if err != nil {
@@ -92,7 +107,7 @@
 }
 
 func (api CameraTaskArgsApi) SaveLinkRulesByGroup(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/cameraTaskArgs/saveLinkRulesByGroup"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTaskArgs/saveLinkRulesByGroup"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
 	if err != nil {
diff --git a/client.go b/client.go
index 897ac64..98807f2 100644
--- a/client.go
+++ b/client.go
@@ -15,6 +15,9 @@
 
 var BASIC_URL            = "http://127.0.0.1:8001"
 
+var DEFAULT_IP			 = "127.0.0.1"
+var DEFAULT_PORT         = 8001
+
 const (
 	DATA_URL_PREFIX      = "/data/api-v"
 	CONTENT_TYPE_FORM    = "application/x-www-form-urlencoded"
diff --git a/cluster.go b/cluster.go
index de4d3a8..f3992ce 100644
--- a/cluster.go
+++ b/cluster.go
@@ -1,13 +1,30 @@
 package dbapi
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"strconv"
+)
 
 type ClusterApi struct {
+	Ip string
+	Port int
+}
 
+func (api ClusterApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api ClusterApi) FindCluster() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/findCluster"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/findCluster"
 	client := NewClient()
 	body,err := client.DoGetRequest(url, nil,nil)
 	if err != nil {
@@ -23,7 +40,7 @@
 }
 
 func (api ClusterApi) Create(clusterName string, password string, virtualIp string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/create"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/create"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"clusterName": clusterName,
@@ -44,7 +61,7 @@
 }
 
 func (api ClusterApi) Search(searchNum string, password string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/search"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/search"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"searchNum": searchNum,
@@ -64,7 +81,7 @@
 }
 
 func (api ClusterApi) GetSearchNodes() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/getSearchNodes"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/getSearchNodes"
 	client := NewClient()
 	body,err := client.DoGetRequest(url, nil,nil)
 	if err != nil {
@@ -80,7 +97,7 @@
 }
 
 func (api ClusterApi) StopSearching(searchNum string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/stopSearching"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/stopSearching"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"searchNum": searchNum,
@@ -99,7 +116,7 @@
 }
 
 func (api ClusterApi) UpdateClusterName(clusterName string, virtualIp string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/updateClusterName"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/updateClusterName"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"clusterName": clusterName,
@@ -119,7 +136,7 @@
 }
 
 func (api ClusterApi) Leave() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/leave"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/leave"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, nil,nil,nil)
 	if err != nil {
@@ -136,7 +153,7 @@
 
 
 func (api ClusterApi) JoinCluster(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/cluster/joinCluster"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/cluster/joinCluster"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
diff --git a/dbpersonApi.go b/dbpersonApi.go
index e1a07f0..cc54192 100644
--- a/dbpersonApi.go
+++ b/dbpersonApi.go
@@ -7,11 +7,25 @@
 )
 
 type DbPersonApi struct {
+	Ip string
+	Port int
+}
 
+func (api DbPersonApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api DbPersonApi) QueryDbPersonsByTbId(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/queryDbPersonsByTbId"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -27,7 +41,7 @@
 }
 
 func (api DbPersonApi) UpdateDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/updateDbPerson"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/updateDbPerson"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -43,7 +57,7 @@
 }
 
 func (api DbPersonApi) UpdateFace(id string,faceFeature string, pic string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/updateFace"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/updateFace"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"id": id,
@@ -64,7 +78,7 @@
 }
 
 func (api DbPersonApi) AddDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/addDbPerson"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/addDbPerson"
 	client := NewClient()
 	body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
 	if err != nil {
@@ -80,7 +94,7 @@
 }
 
 func (api DbPersonApi) DeleteDbPerson(id string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deleteDbPersonById/"+id
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/deleteDbPersonById/"+id
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
 	if err != nil {
@@ -96,7 +110,7 @@
 }
 
 func (api DbPersonApi) DeleteMoreDbPerson(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/deleteMoreDbPerson"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -112,7 +126,7 @@
 }
 
 func (api DbPersonApi) DeletePersonsByTbId(tableId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId/"+tableId
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/deletePersonsByTbId/"+tableId
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
 	if err != nil {
@@ -129,7 +143,7 @@
 
 //鏍规嵁搴曞簱浜哄憳id鏌ヨ浜哄憳淇℃伅璇︽儏
 func (api DbPersonApi) Dbpersoninfosbyid (ids []string) (persons []protomsg.Dbperson,err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/dbPersonInfoByIds"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"ids": ids,
@@ -151,7 +165,7 @@
 }
 
 func (api DbPersonApi) GetPersonTotal (tableId string) (total int64,err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/getPersonTotal"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/getPersonTotal"
 	client := NewClient()
 	paramBody := map[string]string{
 		"tableId": tableId,
@@ -170,7 +184,7 @@
 }
 
 func (api DbPersonApi) GetPersonsCompareCacheBase (from int,size int) (persons []*protomsg.Esinfo,err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbperson/getPersonsCompareCacheBase"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbperson/getPersonsCompareCacheBase"
 	client := NewClient()
 	paramBody := map[string]string{
 		"from": strconv.Itoa(from),
diff --git a/dbtableApi.go b/dbtableApi.go
index cd95c01..a00f20c 100644
--- a/dbtableApi.go
+++ b/dbtableApi.go
@@ -4,14 +4,29 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"errors"
+	"strconv"
 )
 
 type DbTableApi struct {
-
+	Ip string
+	Port int
 }
 
-func (dbt DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
+func (api DbTableApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
+
+func (api DbTableApi) AddDbTableInfo(paramBody map[string]interface{}) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/addDbTableInfo"
 	client := NewClient()
 	body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
 	if err != nil {
@@ -26,8 +41,8 @@
 	return res.Success,res.Data
 }
 
-func (dbt DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/queryDbTables/"+isSync
+func (api DbTableApi) QueryDbTables(isSync string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/queryDbTables/"+isSync
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
 	if err != nil {
@@ -42,8 +57,8 @@
 	return res.Success,res.Data
 }
 
-func (dbt DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/updateDbTables"
+func (api DbTableApi) UpdateDbTables(paramBody map[string]interface{}) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/updateDbTables"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -58,8 +73,8 @@
 	return res.Success,res.Data
 }
 
-func (dbt DbTableApi) UpdateDbTableStatus(id string,enable int) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/updateDbTableStatus"
+func (api DbTableApi) UpdateDbTableStatus(id string,enable int) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/updateDbTableStatus"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"id": id,
@@ -78,8 +93,8 @@
 	return res.Success,res.Data
 }
 
-func (dbt DbTableApi) DeleteById(id string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/deleteDBtablesById/"+id
+func (api DbTableApi) DeleteById(id string) (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/deleteDBtablesById/"+id
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, nil,nil,nil)
 	if err != nil {
@@ -95,8 +110,8 @@
 }
 
 //鏍规嵁澶氫釜搴曞簱id鏌ヨ搴曞簱淇℃伅
-func (dbt DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
+func (api DbTableApi) DbtablesById(ids []string) (dts []protomsg.Dbtable,err error) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/dbtablesByIds"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"ids": ids,
@@ -118,8 +133,8 @@
 }
 
 // 鏍规嵁tableid 鏌ヨtablename
-func (dbt DbTableApi) Dbtablename(tableId string) (tableName string,err error) {
-	dts, e := dbt.DbtablesById([]string{tableId})
+func (api DbTableApi) Dbtablename(tableId string) (tableName string,err error) {
+	dts, e := api.DbtablesById([]string{tableId})
 	if e !=nil {
 		return "",e
 	}
@@ -129,8 +144,8 @@
 	return "",errors.New("table not found")
 }
 
-func (dbt DbTableApi) FindAllDbTables() (dts []protomsg.Dbtable,err error) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/findAllDbTables"
+func (api DbTableApi) FindAllDbTables() (dts []protomsg.Dbtable,err error) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/findAllDbTables"
 	client := NewClient()
 	body,err := client.DoGetRequest(url, nil,nil)
 	if err != nil {
@@ -148,8 +163,8 @@
 	return dts,nil
 }
 
-func (dbt DbTableApi) FindAllDbTablesByCurServer(isDelete string) (dts []protomsg.Dbtable,err error){
-	url := BASIC_URL + DATA_URL_PREFIX + "/dbtable/findAllDbTablesByCurServer"
+func (api DbTableApi) FindAllDbTablesByCurServer(isDelete string) (dts []protomsg.Dbtable,err error){
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dbtable/findAllDbTablesByCurServer"
 	client := NewClient()
 	paramQuery := map[string]string{
 		"isDelete":isDelete,
diff --git a/dicApi.go b/dicApi.go
index 0a2e455..bd0edda 100644
--- a/dicApi.go
+++ b/dicApi.go
@@ -3,14 +3,29 @@
 import (
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type DicApi struct {
+	Ip string
+	Port int
+}
 
+func (api DicApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api DicApi) FindByType(dicType string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/dictionary/findByType"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dictionary/findByType"
 	client := NewClient()
 	paramMap := make(map[string]string)
 	paramMap["type"] = dicType
@@ -27,7 +42,7 @@
 }
 
 func (api DicApi) FindByParentId(parentId string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/dictionary/findByParentId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/dictionary/findByParentId"
 	client := NewClient()
 	paramMap := make(map[string]string)
 	paramMap["parentId"] = parentId
diff --git a/eventPush.go b/eventPush.go
index ca1e341..090ece0 100644
--- a/eventPush.go
+++ b/eventPush.go
@@ -4,14 +4,29 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type EventPushApi struct {
+	Ip string
+	Port int
+}
 
+func (api EventPushApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api EventPushApi) Save(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/save"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/save"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -28,7 +43,7 @@
 }
 
 func (api EventPushApi) FindByEventTopic(topic string,childType string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/findByEventTopic"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/findByEventTopic"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["topic"] = topic
@@ -46,7 +61,7 @@
 }
 
 func (api EventPushApi) FindAll(name string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/findAll"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["name"] = name
@@ -63,7 +78,7 @@
 }
 
 func (api EventPushApi) FindAllDetails() (b bool,allRules []protomsg.EventPush){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/findAllDetails"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/findAllDetails"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
@@ -84,7 +99,7 @@
 }
 
 func (api EventPushApi) GetById(id string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/getById"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/getById"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["id"] = id
@@ -101,7 +116,7 @@
 }
 
 func (api EventPushApi) ChangeStatus(id string,enable bool) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/changeStatus"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/changeStatus"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["id"] = id
@@ -119,7 +134,7 @@
 }
 
 func (api EventPushApi) Delete(id string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/eventPush/delete"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/eventPush/delete"
 	client := NewClient()
 	paramForm :=make(map[string]interface{},0)
 	paramForm["id"] = id
diff --git a/sdkApi.go b/sdkApi.go
index 8b4709d..0c95d22 100644
--- a/sdkApi.go
+++ b/sdkApi.go
@@ -4,15 +4,31 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type SdkApi struct{
+	Ip string
+	Port int
+}
+
+func (api SdkApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 //淇濆瓨绠楁硶锛屾柊澧�(绠楁硶id涓虹┖)锛屾洿鏂帮紙绠楁硶id涓嶄负绌猴級
 func (api SdkApi)Save(paramBody map[string]interface{}) (bool,interface{}) {
 	flag := false
-	url := BASIC_URL + DATA_URL_PREFIX + "/sdk/saveSdk"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sdk/saveSdk"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
 	if err != nil {
@@ -29,7 +45,7 @@
 //鏌ユ壘鎵�鏈夌畻娉�
 func (api SdkApi) FindAll(sdkName string)[]protomsg.Sdk{
 	var sdkArr []protomsg.Sdk
-	url := BASIC_URL + DATA_URL_PREFIX + "/sdk/findAllSdk"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sdk/findAllSdk"
 	client := NewClient()
 	paramMap := make(map[string]string, 0)
 	paramMap["sdkName"] = sdkName
@@ -87,7 +103,7 @@
 
 //閫氳繃id鑾峰彇绠楁硶淇℃伅
 func (api SdkApi) GetById(id string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sdk/getById"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sdk/getById"
 	client := NewClient()
 	paramMap := make(map[string]string)
 	paramMap["id"] = id
@@ -104,7 +120,7 @@
 }
 
 func (api SdkApi) FindByTaskId(taskId string) (flag bool,sdks []protomsg.Sdk) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/sdk/findByTaskId"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sdk/findByTaskId"
 	client := NewClient()
 	paramMap := make(map[string]string)
 	paramMap["taskId"] = taskId
@@ -123,7 +139,7 @@
 }
 
 func (api SdkApi) GetSdkArgs(sdkId string, scope string) (b bool,args []protomsg.SdkArg) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/sdkArg/getSdkArgs"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sdkArg/getSdkArgs"
 	client := NewClient()
 	paramMap := make(map[string]string)
 	paramMap["sdkId"] = sdkId
diff --git a/soApi.go b/soApi.go
index ec35758..fc888b5 100644
--- a/soApi.go
+++ b/soApi.go
@@ -4,13 +4,30 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
-type SoApi struct {}
+type SoApi struct {
+	Ip string
+	Port int
+}
+
+func (api SoApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
 
 //鑾峰彇鎵�鏈塻dkId涓巗oName鏄犲皠淇℃伅
 func (api SoApi) FindAll() (soInfos []protomsg.SoInfo) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/so/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/so/findAll"
 	client := NewClient()
 
 	respBody, err := client.DoGetRequest(url, nil, nil)
@@ -28,7 +45,7 @@
 }
 
 func (api SoApi) Add(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/so/addSo"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/so/addSo"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
 	if err != nil {
diff --git a/sysMenuApi.go b/sysMenuApi.go
index 8ede4bf..7c10ad1 100644
--- a/sysMenuApi.go
+++ b/sysMenuApi.go
@@ -1,13 +1,30 @@
 package dbapi
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"strconv"
+)
 
 type SysMenuApi struct {
+	Ip string
+	Port int
+}
 
+func (api SysMenuApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api SysMenuApi) MenuTree() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/menu/tree"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/menu/tree"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
diff --git a/sysRoleApi.go b/sysRoleApi.go
index a20ca13..a608450 100644
--- a/sysRoleApi.go
+++ b/sysRoleApi.go
@@ -1,13 +1,30 @@
 package dbapi
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"strconv"
+)
 
 type SysRoleApi struct {
-
+	Ip string
+	Port int
 }
 
-func (sra SysRoleApi) FindAll() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/role/findAll"
+func (api SysRoleApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
+
+func (api SysRoleApi) FindAll() (bool,interface{}) {
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/role/findAll"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
diff --git a/syssetApi.go b/syssetApi.go
index 93a561c..1f94681 100644
--- a/syssetApi.go
+++ b/syssetApi.go
@@ -4,14 +4,29 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type SysSetApi struct {
+	Ip string
+	Port int
+}
 
+func (api SysSetApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 //鑾峰彇鏈嶅姟鍣ㄦ湰鏈洪厤缃俊鎭�
 func (api SysSetApi) GetServerInfo() (flag bool,sysconf protomsg.LocalConfig){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/getServerInfo"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/getServerInfo"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -38,7 +53,7 @@
 }
 //淇濆瓨杞閰嶇疆
 func (api SysSetApi) SavePollPeriod(period int) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/pollConfig/savePollPeriod"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/pollConfig/savePollPeriod"
 	client := NewClient()
 	paramBody := make(map[string]interface{},0)
 	paramBody["period"] = period
@@ -57,7 +72,7 @@
 }
 
 func (api SysSetApi) SavePollDelay(delay int) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/pollConfig/savePollDelay"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/pollConfig/savePollDelay"
 	client := NewClient()
 	paramBody := make(map[string]interface{},0)
 	paramBody["delay"] = delay
@@ -77,7 +92,7 @@
 
 //鑾峰彇杞閰嶇疆
 func (api SysSetApi) GetPollConfig() (flag bool,config protomsg.PollConfig) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/pollConfig/getPollConfig"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/pollConfig/getPollConfig"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -105,7 +120,7 @@
 
 //鍒囨崲杞鏄惁寮�鍚拰鍏抽棴
 func (api SysSetApi) UpdatePollEnable(enable bool) bool{
-	url := BASIC_URL + DATA_URL_PREFIX + "/pollConfig/updateEnable"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/pollConfig/updateEnable"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["enable"] = enable
@@ -123,7 +138,7 @@
 }
 
 func (api SysSetApi) AlarmEdit(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/alarmEdit"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/alarmEdit"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
@@ -139,7 +154,7 @@
 }
 
 func (api SysSetApi) VideoLenShow() (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/videoLenShow"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/videoLenShow"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -155,7 +170,7 @@
 }
 
 func (api SysSetApi) VideoLenEdit(maxVideoLen string,minVideoLen string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/videoLenEdit"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/videoLenEdit"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["max_video_len"] = maxVideoLen
@@ -174,7 +189,7 @@
 }
 
 func (api SysSetApi) SaveServerInfo(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/saveServerInfo"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/saveServerInfo"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil)
 	if err != nil {
@@ -190,7 +205,7 @@
 }
 
 func (api SysSetApi) Gb28181ConfigShow() (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/gb28181ConfigShow"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/gb28181ConfigShow"
 	client := NewClient()
 
 	body, err := client.DoGetRequest(url, nil, nil)
@@ -206,7 +221,7 @@
 }
 
 func (api SysSetApi) Gb28181ConfigEdit(paramBody map[string]interface{}) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/sysset/gb28181ConfigEdit"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/sysset/gb28181ConfigEdit"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
diff --git a/taskApi.go b/taskApi.go
index 46d2020..1bd69f1 100644
--- a/taskApi.go
+++ b/taskApi.go
@@ -4,13 +4,30 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
-type TaskApi struct {}
+type TaskApi struct {
+	Ip string
+	Port int
+}
+
+func (api TaskApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
+}
 
 //鑾峰彇鎵�鏈変换鍔′俊鎭�(鍖呭惈绠楁硶瀹氫箟)
 func (api TaskApi) FindAll() (taskInfos []protomsg.TaskSdkInfo) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/findAll"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/findAll"
 	client := NewClient()
 
 	respBody, err := client.DoGetRequest(url, nil, nil)
@@ -55,7 +72,7 @@
 }
 
 func (api TaskApi) Add(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/addTask"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/addTask"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
 	if err != nil {
@@ -70,7 +87,7 @@
 }
 
 func (api TaskApi) Delete(taskId string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/delete"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/delete"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["taskId"] = taskId
@@ -86,7 +103,7 @@
 }
 
 func (api TaskApi) AddTaskSdk(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/addTaskSdk"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/addTaskSdk"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody, nil,nil)
 	if err != nil {
@@ -100,7 +117,7 @@
 }
 
 func (api TaskApi) UpdateTaskName(taskId string, taskName string) bool {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/updateTaskName"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/updateTaskName"
 	client := NewClient()
 	paramBody := make(map[string]interface{},0)
 	paramBody["taskId"] = taskId
@@ -117,7 +134,7 @@
 }
 
 func (api TaskApi) UpdateTaskStatus(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/updateTaskStatus"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/updateTaskStatus"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
 	if err != nil {
@@ -131,7 +148,7 @@
 }
 
 func (api TaskApi) DeleteTaskSdk(taskId string,sdkId string) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/delTaskSdk"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/delTaskSdk"
 	client := NewClient()
 	paramQuery :=make(map[string]string,0)
 	paramQuery["taskId"] = taskId
diff --git a/taskSdkRuleApi.go b/taskSdkRuleApi.go
index e8718c2..9b31170 100644
--- a/taskSdkRuleApi.go
+++ b/taskSdkRuleApi.go
@@ -4,14 +4,29 @@
 	"basic.com/pubsub/protomsg.git"
 	"encoding/json"
 	"fmt"
+	"strconv"
 )
 
 type TaskSdkRuleApi struct {
+	Ip string
+	Port int
+}
 
+func (api TaskSdkRuleApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api TaskSdkRuleApi) FindAllTaskSdkRules() (b bool,rules []protomsg.TaskSdkRule){
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/findAllTaskSdkRules"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/findAllTaskSdkRules"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
@@ -32,7 +47,7 @@
 }
 
 func (api TaskSdkRuleApi) GetRulesByTaskSdk(taskId string,sdkId string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/getRulesByTaskSdk"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/getRulesByTaskSdk"
 	client := NewClient()
 	paramQ := make(map[string]string,0)
 	paramQ["taskId"] = taskId
@@ -51,7 +66,7 @@
 }
 
 func (api TaskSdkRuleApi) DeleteTaskSdkRule(taskId string,sdkId string) bool{
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/deleteTaskSdkRule"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/deleteTaskSdkRule"
 	client := NewClient()
 	paramBody := map[string]interface{}{
 		"taskId": taskId,
@@ -72,7 +87,7 @@
 }
 
 func (api TaskSdkRuleApi) SaveTaskSdkRule(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/saveTaskSdkRule"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/saveTaskSdkRule"
 	client := NewClient()
 	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
 	if err != nil {
diff --git a/userApi.go b/userApi.go
index 9f30daa..5016f90 100644
--- a/userApi.go
+++ b/userApi.go
@@ -1,13 +1,30 @@
 package dbapi
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"strconv"
+)
 
 type UserApi struct {
+	Ip string
+	Port int
+}
 
+func (api UserApi) getBasicUrl() string {
+	if api.Ip == "" {
+		return BASIC_URL
+	}
+	if api.Ip == "" {
+		api.Ip = DEFAULT_IP
+	}
+	if api.Port == 0 {
+		api.Port = DEFAULT_PORT
+	}
+	return "http://"+api.Ip+":"+strconv.Itoa(api.Port)
 }
 
 func (api UserApi) Login(username string,password string) (bool,interface{}){
-	url := BASIC_URL + DATA_URL_PREFIX + "/user/login"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/login"
 	client := NewClient()
 	paramBody :=make(map[string]interface{},0)
 	paramBody["username"]=username
@@ -24,7 +41,7 @@
 }
 
 func (api UserApi) FindAllUser() (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/user/findAllUser"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/findAllUser"
 	client := NewClient()
 	body, err := client.DoGetRequest(url, nil, nil)
 	if err != nil {
@@ -39,7 +56,7 @@
 }
 
 func (api UserApi) Edit(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/user/edit"
+	url := api.getBasicUrl() + DATA_URL_PREFIX + "/user/edit"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil)
 	if err != nil {

--
Gitblit v1.8.0