.

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).
+		Where("org_id IN (?)", idArgs...). // 显式展开
-		Query() // 用 Query 而不是 Find
+		Query()
 	if err != nil {
 		return nil, 0, err
 	}