diff --git a/pkg/dal/dao/news.go b/pkg/dal/dao/news.go index c79da68..527a74a 100644 --- a/pkg/dal/dao/news.go +++ b/pkg/dal/dao/news.go @@ -508,6 +508,11 @@ func (dao *NewsDAO) QueryAsyncBatch(pairs []OrgDigestPair) (dos []*models.NewsDO // } func (dao *NewsDAO) QueryPullNew(cond *NewsPullNewCondition) (dos []*models.NewsDO, total int64, err error) { + if cond == nil || len(cond.Pairs) == 0 { + // 客户端没传org_id列表,返回空 + return []*models.NewsDO{}, 0, nil + } + e := dao.db.Model(&dos). Table(models.TableNameNews). Select(