同步优化es

@@ -230,19 +230,10 @@ class SyncToEsCmd {
         unset($data['from_name']);
         unset($data['date']);
 
-        if(!empty($data['to_name']) && strlen($data['to_name'])>10000){
-            $data['to_name'] = @json_decode($data['to_name'],true);
-            if(is_array($data['to_name'])){
-                $data['to_name'] = array_map(function ($v){
-                    $v['name'] = '';
-                    return $v;
-                },$data['to_name']);
-                $data['to_name'] = array_slice($data['to_name'],0,100);
-                $data['to_name'] = json_encode($data['to_name']);
-            }else{
-                $data['to_name'] = '';
-            }
-        }
+        $data['to_name'] = $this->trimEmail($data['to_name']??[]);
+        $data['cc'] = $this->trimEmail($data['cc']??[]);
+        $data['bcc'] = $this->trimEmail($data['bcc']??[]);
+
         $data['description'] = str_replace(["\n"],"",$data['description']);
         // unset($data['to_name']);
 
@@ -257,6 +248,22 @@ class SyncToEsCmd {
     }
 
 
+    private function trimEmail($emails){
+        if($emails){
+            $emails = is_array($emails) ? $emails : @json_decode($emails,true);
+            if(is_array($emails) && count($emails)>100){
+
+                $emails = array_map(function ($v){
+                    $v['name'] = '';
+                    return $v;
+                },$emails);
+                $emails = array_slice($emails,0,100);
+                return json_encode($emails);
+            }
+        }
+        return '';
+    }
+
 }
 
 (new SyncToEsCmd())->handler();