fix: 数据节点接口参数名

controller/knowledge/knowledge.go

@@ -7,6 +7,7 @@ import (
 	knowledgeDao "eta_gn/eta_bridge/models/request/knowledge"
 	"eta_gn/eta_bridge/services/index_data"
 	"eta_gn/eta_bridge/services/knowledge"
+	"fmt"
 
 	"github.com/gin-gonic/gin"
 )
@@ -36,25 +37,29 @@ func (k *KnowledgeController) ReportSave(c *gin.Context) {
 }
 
 func (k *KnowledgeController) ViewPointAcquire(c *gin.Context) {
-
 	var req knowledgeDao.KnowledgeRefreshReq
 	if e := c.Bind(&req); e != nil {
 		resp.FailData("参数解析失败", "Err:"+e.Error(), c)
 		return
 	}
+	global.LOG.Info(fmt.Sprintf("ViewPointAcquire, PageSize: %d, UpdateTime: %s", req.PageSize, req.UpdateTime))
 
 	param := make(map[string]interface{})
 	var res *index_data.MarketOverviewResp
 	pageNum := 1
+	pageSize := 100
 	for {
-		param["pageNum"] = pageNum
-		param["pageSize"] = req.PageSise
+		global.LOG.Info(fmt.Sprintf("ViewPointAcquire, 当前pageNo: %d, size: %d", pageNum, pageSize))
+		//param["pageNum"] = pageNum
+		//param["pageSize"] = req.PageSize
+		param["pageNo"] = pageNum
+		param["size"] = pageSize
 		if req.UpdateTime != "" {
 			param["UPDATE_TIME"] = req.UpdateTime
 		}
 		tmp, err := index_data.GetMarketOverview(param)
 		if err != nil {
-			global.LOG.Error("knowledge save error: ", err)
+			global.LOG.Error("GetMarketOverview save error: ", err)
 			resp.Fail("保存失败", c)
 			return
 		}
@@ -64,10 +69,12 @@ func (k *KnowledgeController) ViewPointAcquire(c *gin.Context) {
 			res.Data.Records = append(res.Data.Records, tmp.Data.Records...)
 		}
 		if res.Code != "000000" {
-			global.LOG.Info("knowledgeResp Res:%v ", res)
+			global.LOG.Info("GetMarketOverview Res: %v ", res)
 			continue
 		}
-		if len(res.Data.Records) != req.PageSise {
+		global.LOG.Info(fmt.Sprintf("ViewPointAcquire, Total: %d", res.Data.Total))
+		if len(res.Data.Records) != req.PageSize {
+			global.LOG.Info(fmt.Sprintf("ViewPointAcquire, End"))
 			break
 		}
 		pageNum++

models/request/knowledge/knowledge.go

@@ -1,6 +1,6 @@
 package knowledge
 
 type KnowledgeRefreshReq struct {
-	PageSise   int    `json:"pageSize"`
+	PageSize   int    `json:"pageSize"`
 	UpdateTime string `json:"UPDATE_TIME"`
 }