1

business/jxutils/tasksch/task.go

@@ -3,13 +3,12 @@ package tasksch
 import (
 	"encoding/json"
 	"fmt"
+	"git.rosy.net.cn/jx-callback/business/jxutils/weixinmsg"
 	"strings"
 	"sync"
 	"time"
 
-	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/baseapi/utils"
-	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/globals"
 )
@@ -496,7 +495,8 @@ func SendMessage(t *BaseTask) {
 			} else {
 				content += ",\n" + t.Error()
 			}
-			ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
+			// ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
+			weixinmsg.SendMsgToUser(authInfo.UserID, weixinmsg.WX_NORMAL_STORE_MSG_TEMPLATE_ID, "异步任务完成:"+content)
 		}
 	}
 }