From 8c44f6b907da137d2b07f50a1521c6759d56c8ec Mon Sep 17 00:00:00 2001
From: lijianbin <513837235@.qq.com>
Date: Sat, 9 Oct 2021 14:20:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E4=BB=BB=E5=8A=A1=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/client.dotask.go b/client.dotask.go
index d7f395b..8376f7d 100644
--- a/client.dotask.go
+++ b/client.dotask.go
@@ -1 +1,59 @@
 package taskrpc
+
+import (
+    "encoding/json"
+    "errors"
+    "log"
+)
+
+func DoTask(dbname, siteid, userId, task_type string, url ...string) (bool, error) {
+
+    if dbname == "" || userId == "" || task_type == ""{
+        return false, errors.New("参数错误")
+    }
+
+    conn, err := rpc_server_conn(url...)
+    if err != nil {
+        return false, err
+    }
+    defer conn.Close()
+
+    data := DoTaskParam{}
+    data.Dbname = dbname
+    data.SiteId = siteid
+    data.UserId = userId
+    data.Type = task_type
+
+    req, err := SetReqData(data)
+    if err != nil {
+        log.Println("DoTask crypter error:", err)
+        return false, err
+    }
+
+    res := &Response{}
+
+    err = conn.DoTask(req, res)
+
+    if err != nil {
+        log.Println("taskrpc DoTask 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
+}