From 5e7865c0c5ebd780033bef147a819992638ede67 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 13 七月 2020 15:38:00 +0800
Subject: [PATCH] fix

---
 taskSdkRuleApi.go |  204 +++++++++++++++++++++++++-------------------------
 1 files changed, 102 insertions(+), 102 deletions(-)

diff --git a/taskSdkRuleApi.go b/taskSdkRuleApi.go
index dd95155..a61d491 100644
--- a/taskSdkRuleApi.go
+++ b/taskSdkRuleApi.go
@@ -1,103 +1,103 @@
 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
-}
\ No newline at end of file
+//
+//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
+//}
\ No newline at end of file

--
Gitblit v1.8.0