es 批量添加

+<?php
+
+namespace Lib\Es;
+
+
+/**
+ * 批量添加数据的类
+ * @author：dc
+ * @time 2025/8/6 16:37
+ * Class BulkData
+ * @package Lib\Es
+ */
+class BulkData {
+
+    /**
+     * @var string
+     */
+    private array $data = [];
+
+    /**
+     * 添加数据
+     * @param string $index 必须全小写
+     * @param string $_id 指定文档id
+     * @param array $data
+     * @author：dc
+     * @time 2025/8/6 16:41
+     */
+    public function add(string $index,string $_id, array $data){
+        $index = strtolower($index);
+        if(empty($this->data[$index])){
+            $this->data[$index] = [];
+        }
+        $this->data[$index][] = [
+            '_id'   => $_id,
+            '_source'   => $data,
+        ];
+    }
+
+
+    /**
+     * 转换成es可识别的数据
+     * @return array
+     * @author：dc
+     * @time 2025/8/6 16:42
+     */
+    public function toParams():array {
+        $params = [];
+        foreach ($this->data as $index=>$item){
+            $params[] = [
+                'index' =>  [
+                    '_index'    =>  $index,
+                    '_id'   =>  $item['_id']
+                ]
+            ];
+            $params[] = $item['_source'];
+        }
+        return $params;
+    }
+
+
+
+
+}

@@ -281,6 +281,23 @@ class Es {
 
     }
 
+    /**
+     * 批量添加数据
+     * @param BulkData $data
+     * data 格式要求
+     * @return array
+     * @throws \Elastic\Elasticsearch\Exception\ClientResponseException
+     * @throws \Elastic\Elasticsearch\Exception\ServerResponseException
+     * @author：dc
+     * @time 2025/8/6 16:36
+     */
+    public function bulk(BulkData $data){
+
+        $res = $this->client->bulk($data->toParams());
+
+        return $res->asArray();
+    }
+
 
     /**
      * @return \Elastic\Elasticsearch\Client