.

pkg/dal/dao/news.go

@@ -490,7 +490,8 @@ func (dao *NewsDAO) QueryPullNew(cond *NewsPullNewCondition) (dos []*models.News
 	}
 	_, total, err = e.QueryEx()
 	if err != nil {
-		return nil, 0, log.Errorf(err.Error())
+		log.Errorf("QueryPullNew failed: %v", err)
+		return nil, 0, err
 	}
 
 	log.Infof(".................[DEBUG] QueryPullNew 返回数据: %+v", dos)

pkg/proto/proto_biz.go

@@ -295,6 +295,7 @@ type NewsAsyncResp struct {
 
 type NewsPullNewReq struct {
 	OrgIDs []int64 `json:"org_ids"`
+	Digest string  `json:"digest"`
 }
 
 type NewsPullNewResp struct {