From 0a93698d5ef2daa39747368d6757b631748210ca Mon Sep 17 00:00:00 2001
From: huzhengrong <huzhengrong@axbbaoxian.com>
Date: Tue, 28 Oct 2025 16:46:20 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20fix(msgManager):=20=E4=BF=AE?=
 =?UTF-8?q?=E6=AD=A3=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86=E6=97=B6=E9=97=B4?=
 =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E4=B8=BA=E4=B8=8B=E5=8D=884=E7=82=B912?=
 =?UTF-8?q?=E5=88=86=EF=BC=8C=E4=BC=98=E5=8C=96=E9=80=9A=E7=9F=A5=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E9=80=BB=E8=BE=91=E4=BB=A5=E8=BF=94=E5=9B=9E=E5=93=8D?=
 =?UTF-8?q?=E5=BA=94=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/msgManager.js | 15 +++++++--------
 utils.js              |  4 +++-
 2 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/service/msgManager.js b/service/msgManager.js
index 45b1eb9..776c998 100644
--- a/service/msgManager.js
+++ b/service/msgManager.js
@@ -140,15 +140,14 @@ class MessageQueue extends EventEmitter {
         );
       }
     }
-    let html = "";
+
     for (const spiderName in msgMap) {
-      html += this.generateTable(spiderName, msgMap[spiderName]);
-    }
-    try {
-      // this.emailSender.sendBulkEmail(this.recipients, "招标项目最新公告", html);
-      await sendQYWechatMessage(html)
-    } catch (error) {
-      console.error(`❌ 通知发送失败: ${error}`);
+      try {
+        let sendResult = await sendQYWechatMessage(this.generateTable(spiderName, msgMap[spiderName]))
+        console.log(`✅ 通知发送成功: ${JSON.stringify(sendResult)}`);
+      } catch (error) {
+        console.error(`❌ 通知发送失败: ${error}`);
+      }
     }
 
     this.processing = false;
diff --git a/utils.js b/utils.js
index 8ce5c25..85042d6 100644
--- a/utils.js
+++ b/utils.js
@@ -254,7 +254,7 @@ function dealNullAndUndefined(value) {
 async function sendQYWechatMessage(message) {
   try {
     const webhook = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=7de26c43-8652-4204-9665-47a5cef58b58";
-    await axios.post(webhook, {
+    const response = await axios.post(webhook, {
       msgtype: "markdown",
       markdown: {
         content: message
@@ -265,8 +265,10 @@ async function sendQYWechatMessage(message) {
       }
     });
     console.log(`企业微信消息推送成功: ${message}`);
+    return response.data; // 返回响应数据
   } catch (error) {
     console.error(`企业微信消息推送失败:`, error.message);
+    throw error; // 重新抛出错误以便调用方可以处理
   }
 }
 export {