diff --git a/business/jxutils/enterprise_msg/enterprise_send_msg.go b/business/jxutils/enterprise_msg/enterprise_send_msg.go
new file mode 100644
index 000000000..bf37ab428
--- /dev/null
+++ b/business/jxutils/enterprise_msg/enterprise_send_msg.go
@@ -0,0 +1,27 @@
+package enterprise_msg
+
+import (
+	enterprise "git.rosy.net.cn/baseapi/platformapi/enterprise_wechat"
+	"git.rosy.net.cn/jx-callback/globals/api"
+)
+
+func SendUserMessage(phone, title, description, url string) error {
+	// 根据电话号码获取用户touserId
+	enterpriseUserId, err := api.EnterpriseChatMin.GetUserIdByMobile(phone)
+	if err != nil {
+		return err
+	}
+
+	msg := &enterprise.EnterpriseSendMsgReq{
+		Touser:  enterpriseUserId,
+		Msgtype: enterprise.MsgTypeTextCard,
+		Agentid: 1000005,
+		Textcard: enterprise.TextCardObject{
+			Title:       title,
+			Description: description,
+			Url:         url,
+			Btntxt:      "详情",
+		},
+	}
+	return api.EnterpriseChatMin.SendMsgToUser(msg)
+}
diff --git a/business/jxutils/tasksch/task.go b/business/jxutils/tasksch/task.go
index bb04f2c5a..f8edc2c5b 100644
--- a/business/jxutils/tasksch/task.go
+++ b/business/jxutils/tasksch/task.go
@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
+	"git.rosy.net.cn/jx-callback/business/jxutils/enterprise_msg"
 	"strings"
 	"sync"
 	"time"
@@ -508,7 +509,9 @@ func SendMessage(t *BaseTask) {
 			} else {
 				content += ",\n" + t.Error()
 			}
-			ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
+			if err := ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content); err != nil {
+				enterprise_msg.SendUserMessage(authInfo.Mobile, "异步任务完成", "", content)
+			}
 		}
 	}
 }