添加企业微信消息通知

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)
+}

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)
+			}
 		}
 	}
 }