From def600f2e383669f4e8187fb4369168e2357a430 Mon Sep 17 00:00:00 2001
From: lijianbin <513837235@.qq.com>
Date: Tue, 30 Nov 2021 14:13:25 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BE=AA=E7=8E=AF=E7=B1=BB?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client.dotask.go | 53 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)

diff --git a/client.dotask.go b/client.dotask.go
index 1f61ea9..5949e73 100644
--- a/client.dotask.go
+++ b/client.dotask.go
@@ -58,3 +58,56 @@ func DoTask(dbname, siteid, userId, task_type string, url ...string) (bool, erro
 
     return task_res, nil
 }
+
+// 完成循环类任务
+func DoCycleTask(dbname, siteid, userId, task_id string, url ...string) (bool, error) {
+
+    if dbname == "" || userId == "" || task_id == ""{
+        return false, errors.New("参数错误")
+    }
+
+    conn, err := rpc_server_conn(url...)
+    if err != nil {
+        return false, err
+    }
+    defer conn.Close()
+
+    data := DoCycleTaskParam{}
+    data.Dbname = dbname
+    data.SiteId = siteid
+    data.UserId = userId
+    data.TaskId = task_id
+
+    req, err := SetReqData(data)
+    if err != nil {
+        log.Println("DoCycleTask crypter error:", err)
+        return false, err
+    }
+
+    res := &Response{}
+
+    err = conn.DoCycleTask(req, res)
+
+    if err != nil {
+        log.Println("taskrpc DoCycleTask error:", err)
+        return false, err
+    }
+
+    res_data_de, err := GetResData(res)
+
+    if err != nil {
+        return false, err
+    }
+    if res_data_de == "" {
+        return false, nil
+    }
+
+    var task_res bool
+    err = json.Unmarshal([]byte(res_data_de), &task_res)
+
+    if err != nil {
+        return false, err
+    }
+
+    return task_res, nil
+}