.

pkg/dal/core/core_biz.go

@@ -948,12 +948,21 @@ func (m *BizCore) NewsAsyncBatch(ctx *itypes.Context, req *proto.NewsAsyncBatchR
 }
 
 func (m *BizCore) NewsPullNew(ctx *itypes.Context, req *proto.NewsPullNewReq) (resp *proto.NewsPullNewResp, total int64, code itypes.BizCode) {
+	// 1. 提取 OrgIDs
+	orgIDs := make([]int64, 0, len(req.List))
+	for _, item := range req.List {
+		orgIDs = append(orgIDs, item.OrgID)
+	}
+
+	// 2. 调用 DAO 查询
 	dos, total, err := m.newsDAO.QueryPullNew(&dao.NewsPullNewCondition{
-		OrgIDs: req.OrgIDs,
+		OrgIDs: orgIDs,
 	})
 	if err != nil {
 		return nil, 0, itypes.NewBizCodeDatabaseError(err.Error())
 	}
+
+	// 3. 返回结果
 	return &proto.NewsPullNewResp{
 		List: dos,
 	}, total, itypes.BizOK

pkg/proto/proto_biz.go

@@ -293,10 +293,18 @@ type NewsAsyncResp struct {
 	List []*models.NewsDO `json:"list"`
 }
 
-type NewsPullNewReq struct {
-	OrgIDs []int64 `json:"org_ids"`
+// type NewsPullNewReq struct {
+// 	OrgIDs []int64 `json:"org_ids"`
+// 	Digest string  `json:"digest"`
+// }
+
+type NewsPullNewItem struct {
+	OrgID  int64  `json:"org_id"`
 	Digest string `json:"digest"`
 }
+type NewsPullNewReq struct {
+	List []NewsPullNewItem `json:"list"`
+}
 
 type NewsPullNewResp struct {
 	List []*models.NewsDO `json:"list"`