From 0bc51062de4147830c5ccb4957cec5575ae1f76c Mon Sep 17 00:00:00 2001
From: hailin <hailin@gdzx.xyz>
Date: Fri, 20 Jun 2025 13:52:54 +0800
Subject: [PATCH] .

---
 pkg/dal/dao/news.go | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/pkg/dal/dao/news.go b/pkg/dal/dao/news.go
index 8ca1cfb..05da3a6 100644
--- a/pkg/dal/dao/news.go
+++ b/pkg/dal/dao/news.go
@@ -416,12 +416,17 @@ func (dao *NewsDAO) QueryAsyncBatch(pairs []OrgDigestPair) (dos []*models.NewsDO
 
 	// ② 一次 SQL：SELECT * FROM news WHERE org_id IN ( … )
 	var rows []*models.NewsDO
-	// err 已在函数签名里声明
+	// 显式展开 orgIDs
+	idArgs := make([]interface{}, 0, len(orgIDs))
+	for _, id := range orgIDs {
+		idArgs = append(idArgs, id)
+	}
+
 	_, err = dao.db.
-		Model(&rows). // 告诉 sqlca 目标对象是 []*models.NewsDO
+		Model(&rows).
 		Table(models.TableNameNews).
-		Where("org_id IN ?", orgIDs).
-		Query() // 用 Query 而不是 Find
+		Where("org_id IN (?)", idArgs...). // 显式展开
+		Query()
 	if err != nil {
 		return nil, 0, err
 	}