From a8dc00e0473c493d8b54d9e1ceec9a2beb16ca1f Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期二, 24 九月 2019 20:43:57 +0800
Subject: [PATCH] findAllDbTablesByCurServer add isDelete arg

---
 taskApi.go |   12 +++++-------
 1 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/taskApi.go b/taskApi.go
index 56fe342..46d2020 100644
--- a/taskApi.go
+++ b/taskApi.go
@@ -31,6 +31,9 @@
 	taskInfos := api.FindAll()
 	if taskInfos !=nil {
 		for _,ti :=range taskInfos{
+			if !ti.Task.Enable {
+				continue
+			}
 			tsr := protomsg.TaskSdkRun{
 				Task:ti.Task,
 			}
@@ -52,7 +55,7 @@
 }
 
 func (api TaskApi) Add(paramBody map[string]interface{}) (bool,interface{}) {
-	url := BASIC_URL + DATA_URL_PREFIX + "/task/add"
+	url := BASIC_URL + DATA_URL_PREFIX + "/task/addTask"
 	client := NewClient()
 	respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
 	if err != nil {
@@ -82,14 +85,9 @@
 	return res.Success,res.Data
 }
 
-func (api TaskApi) AddTaskSdk(taskId string,sdkId string,sort int) (bool,interface{}) {
+func (api TaskApi) AddTaskSdk(paramBody map[string]interface{}) (bool,interface{}) {
 	url := BASIC_URL + DATA_URL_PREFIX + "/task/addTaskSdk"
 	client := NewClient()
-	paramBody :=map[string]interface{}{
-		"taskId":taskId,
-		"sdkId":sdkId,
-		"sort":sort,
-	}
 	respBody, err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody, nil,nil)
 	if err != nil {
 		return false,nil

--
Gitblit v1.8.0