请求体数组允许最多不超过20个元素

consumers/consumerESDeepExcavation.go

@@ -109,11 +109,13 @@ func (c *consumerESDeepExcavation) Work() {
 		}
 
 		if len(dataList) > 0 {
-			err := c.sendData(dataList)
-			if err != nil {
-				log.Printf("发送数据失败: %v", err)
-			} else {
-				log.Printf("成功发送 %d 条数据", len(dataList))
+			for i, data := range dataList {
+				err := c.sendData(data)
+				if err != nil {
+					log.Printf("发送第 %d 条数据失败: %v", i+1, err)
+				} else {
+					log.Printf("成功发送第 %d 条数据", i+1)
+				}
 			}
 		}
 
@@ -298,7 +300,7 @@ func (c *consumerESDeepExcavation) transformFactor31(theme models.EsTheme) *Deep
 	}
 }
 
-func (c *consumerESDeepExcavation) sendData(dataList []DeepExcavationData) error {
+func (c *consumerESDeepExcavation) sendData(data DeepExcavationData) error {
 	// 生成签名
 	sign := generateSign(c.Info.Secret, c.Info.Appid, c.Info.ProjectId)
 
@@ -306,8 +308,8 @@ func (c *consumerESDeepExcavation) sendData(dataList []DeepExcavationData) error
 	fullURL := fmt.Sprintf("%s?appid=%s&projectId=%s&sign=%s",
 		c.Info.URL, c.Info.Appid, c.Info.ProjectId, sign)
 
-	// 序列化数据
-	bodyBytes, err := json.Marshal(dataList)
+	// 序列化数据（每个请求只发送一个数据，包装成数组）
+	bodyBytes, err := json.Marshal([]DeepExcavationData{data})
 	if err != nil {
 		return fmt.Errorf("序列化数据失败: %v", err)
 	}