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
|
//}
|
