package dbapi
//
//import (
//	"basic.com/pubsub/protomsg.git"
//	"encoding/json"
//	"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 := api.getBasicUrl() + DATA_URL_PREFIX + "/task/findAllTaskSdkRules"
//	client := NewClient()
//	body, err := client.DoGetRequest(url, nil, nil)
//	if err != nil {
//		return false,nil
//	}
//
//	var res Result
//	if err = json.Unmarshal(body, &res); err != nil {
//		logPrint(err)
//		return false,nil
//	}
//	bytes, _ := json.Marshal(res.Data)
//	err = json.Unmarshal(bytes, &rules)
//	if err !=nil{
//		return false,nil
//	}
//	return res.Success,rules
//}
//
//func (api TaskSdkRuleApi) GetRulesByTaskSdk(taskId string,sdkId string) (bool,interface{}){
//	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/getRulesByTaskSdk"
//	client := NewClient()
//	paramQ := make(map[string]string,0)
//	paramQ["taskId"] = taskId
//	paramQ["sdkId"] = sdkId
//	body, err := client.DoGetRequest(url, paramQ, nil)
//	if err != nil {
//		return false,err
//	}
//
//	var res Result
//	if err = json.Unmarshal(body, &res); err != nil {
//		logPrint(err)
//		return false,err
//	}
//	return res.Success,res.Data
//}
//
//func (api TaskSdkRuleApi) DeleteTaskSdkRule(taskId string,sdkId string) bool{
//	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/deleteTaskSdkRule"
//	client := NewClient()
//	paramBody := map[string]interface{}{
//		"taskId": taskId,
//		"sdkId": sdkId,
//	}
//	body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil)
//	if err != nil {
//		return false
//	}
//
//	var res Result
//	if err = json.Unmarshal(body, &res); err != nil {
//		logPrint(err)
//		return false
//	}
//
//	return res.Success
//}
//
//func (api TaskSdkRuleApi) SaveTaskSdkRule(paramBody map[string]interface{}) (bool,interface{}) {
//	url := api.getBasicUrl() + DATA_URL_PREFIX + "/task/saveTaskSdkRule"
//	client := NewClient()
//	body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
//	if err != nil {
//		return false,nil
//	}
//
//	var res Result
//	if err = json.Unmarshal(body, &res); err != nil {
//		logPrint(err)
//		return false,nil
//	}
//
//	return res.Success,res.Data
//}