1

business/jxutils/tasksch/task.go

@@ -3,7 +3,8 @@ package tasksch
 import (
 	"encoding/json"
 	"fmt"
-	"git.rosy.net.cn/jx-callback/business/jxutils/weixinmsg"
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
+	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"strings"
 	"sync"
 	"time"
@@ -173,6 +174,18 @@ func (t *BaseTask) GetID() string {
 	return t.ID
 }
 
+func (t *BaseTask) GetIsGetResultCalled() bool {
+	return t.isGetResultCalled
+}
+
+func (t *BaseTask) GetParent() ITask {
+	return t.parent
+}
+
+func (t *BaseTask) GetContext() *jxcontext.Context {
+	return t.ctx
+}
+
 func (t *BaseTask) Run() {
 }
 
@@ -495,8 +508,7 @@ func SendMessage(t *BaseTask) {
 			} else {
 				content += ",\n" + t.Error()
 			}
-			// ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
-			weixinmsg.SendMsgToUser(authInfo.UserID, weixinmsg.WX_NORMAL_STORE_MSG_TEMPLATE_ID, "异步任务完成:"+content)
+			ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
 		}
 	}
 }