作者 邓超

同步到es脚本优化

@@ -89,7 +89,6 @@ class SyncToEsCmd { @@ -89,7 +89,6 @@ class SyncToEsCmd {
89 } 89 }
90 // 再次验证是否是自动回复 90 // 再次验证是否是自动回复
91 if($this->folders[$data['folder_id']] == '收件箱' && !$data['is_auto']){ 91 if($this->folders[$data['folder_id']] == '收件箱' && !$data['is_auto']){
92 - echo "xx";  
93 $filter = redis()->get('ai_email_filter_lists',[]); 92 $filter = redis()->get('ai_email_filter_lists',[]);
94 $filter = is_array($filter) ? $filter : []; 93 $filter = is_array($filter) ? $filter : [];
95 foreach ($filter as $f){ 94 foreach ($filter as $f){
@@ -101,7 +100,6 @@ class SyncToEsCmd { @@ -101,7 +100,6 @@ class SyncToEsCmd {
101 $haystack = $data['from']; 100 $haystack = $data['from'];
102 } 101 }
103 if($haystack && $str && stripos($haystack,$str)!==false){ 102 if($haystack && $str && stripos($haystack,$str)!==false){
104 - echo 'auto';  
105 $data['is_auto'] = 1; 103 $data['is_auto'] = 1;
106 break; 104 break;
107 } 105 }
@@ -97,6 +97,28 @@ class SyncToEsCmd { @@ -97,6 +97,28 @@ class SyncToEsCmd {
97 } 97 }
98 // 为文件夹打标 方便查询 98 // 为文件夹打标 方便查询
99 $data['folder_as_int'] = folder2int($this->folders[$data['folder_id']]); 99 $data['folder_as_int'] = folder2int($this->folders[$data['folder_id']]);
  100 +
  101 + // 再次验证是否是自动回复
  102 + if($data['folder_as_int'] === 1 && !$data['is_auto']){
  103 + $filter = redis()->get('ai_email_filter_lists',[]);
  104 + $filter = is_array($filter) ? $filter : [];
  105 + foreach ($filter as $f){
  106 + list($t,$str) = $f;
  107 + $haystack = '';
  108 + if($t==2){
  109 + $haystack = $data['subject'];
  110 + }elseif ($t==1){
  111 + $haystack = $data['from'];
  112 + }
  113 + if($haystack && $str && stripos($haystack,$str)!==false){
  114 + $data['is_auto'] = 1;
  115 + break;
  116 + }
  117 + }
  118 + }
  119 + // 再次验证是否是预热邮件
  120 +// if()
  121 +
100 // postid ai邮箱要用 这个是查询黑格 122 // postid ai邮箱要用 这个是查询黑格
101 list($data['postid'],$data['source']) = $this->getPostid($data['email_id']); 123 list($data['postid'],$data['source']) = $this->getPostid($data['email_id']);
102 }catch (Throwable $e){ 124 }catch (Throwable $e){