es

@@ -74,7 +74,7 @@ class SyncMailToEs {
             if(empty($this->data['is_auto'])){
             if(empty($this->data['is_auto'])){
                 $this->data['is_auto'] = 0;
                 $this->data['is_auto'] = 0;
             }
             }
-            $this->es->create($this->data,$id);
+            $this->es->create($this->getData($this->data),$id);
         }
         }
         else if($this->table == 'lists_auto'){
         else if($this->table == 'lists_auto'){
             $id = db()->first(listsSql::first($this->data['lists_id'],'`email_id`,`folder_id`,`uid`'));
             $id = db()->first(listsSql::first($this->data['lists_id'],'`email_id`,`folder_id`,`uid`'));
@@ -98,13 +98,32 @@ class SyncMailToEs {
             $lists = db()->all(listsSql::all($this->where,'`email_id`,`folder_id`,`uid`'));
             $lists = db()->all(listsSql::all($this->where,'`email_id`,`folder_id`,`uid`'));
             foreach ($lists as $list){
             foreach ($lists as $list){
                 $id = $list['email_id'].'_'.$list['folder_id'].'_'.$list['uid'];
                 $id = $list['email_id'].'_'.$list['folder_id'].'_'.$list['uid'];
-                $this->es->update($id,$this->data);
+                $this->es->update($id,$this->getData($this->data));
             }
             }
         }
         }
 
 
     }
     }
 
 
 
 
+    public function getData($data){
+        if(!empty($data['from'])){
+            $data['from'] = [
+                'email' =>  $data['from'],
+                'name'  =>  $data['from_name']??''
+            ];
+            unset($data['from_name']);
+        }
+        unset($data['date']);
+        if(!empty($data['created_at'])){
+            $data['created_at'] = date('Y-m-d\TH:i:s',strtotime($data['created_at']));
+        }
+        if(!empty($data['updated_at'])){
+            $data['updated_at'] = date('Y-m-d\TH:i:s',strtotime($data['updated_at']));
+        }
+        $data['references'] = empty($data['references']) ? '' : $data['references'];
+        return $data;
+    }
+