xg

src/timetask/wxworkwarn.go

@@ -6,6 +6,7 @@ import (
 	"math"
 	"net/http"
 	qu "qfw/util"
+	"strings"
 	"time"
 	"util"
 )
@@ -38,8 +39,14 @@ var UserContentModel = `
 var MarkdownModel = `{
     "msgtype": "markdown",
     "markdown": {
-        "content": "%s",
-        "mentioned_mobile_list":["%s"]
+        "content": "%s"
+    }
+}`
+var TextModel = `{
+    "msgtype": "text",
+    "text": {
+        "content": "",
+        "mentioned_mobile_list":[%s]
     }
 }`
 
@@ -102,17 +109,25 @@ func SendInfoToWxWork() {
 	resultContent := fmt.Sprintf(TitleContentModel, failedTaskCount, heartCodeCount)
 	mobileArr := []string{}
 	for mobile, t := range userTextMap {
-		mobileArr = append(mobileArr, mobile)
+		mobileArr = append(mobileArr, "\""+mobile+"\"")
 		resultContent += fmt.Sprintf(UserContentModel, t.Username, t.FailedTaskCount, t.FailedTaskOverdueDay, t.HeartErrCount, t.NoCollectDataDay)
 	}
-	msg := fmt.Sprintf(MarkdownModel, resultContent, "@all")
-	qu.Debug(msg)
-	resp, err := http.Post(
+	msg := fmt.Sprintf(MarkdownModel, resultContent)
+	qu.Debug("msg", msg)
+	toUserMsg := fmt.Sprintf(TextModel, strings.Join(mobileArr, ","))
+	qu.Debug("toUserMsg", toUserMsg)
+	resp1, err := http.Post(
+		"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=97850772-88d0-4544-a2c3-6201aeddff9e",
+		"application/json",
+		bytes.NewBuffer([]byte(toUserMsg)),
+	)
+	defer resp1.Body.Close()
+	resp2, err := http.Post(
 		"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=97850772-88d0-4544-a2c3-6201aeddff9e",
 		"application/json",
 		bytes.NewBuffer([]byte(msg)),
 	)
-	defer resp.Body.Close()
+	defer resp2.Body.Close()
 	if err != nil {
 		fmt.Println("request error:", err)
 	}