auto_reply_mail.php
2.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
<?php
use Model\listsSql;
/**
* 自动回复的邮件
* @author：dc
* @time 2024/9/6 17:09
* Class HotMail
*/
class AutoMail {
public function __construct(){
$this->db = db();
$this->start();
}
/**
* @var \Lib\Db|\Lib\DbPool
*/
private $db;
/**
* @author：dc
* @time 2024/7/18 14:04
*/
private function start(){
$filter = isAiAutoMail(true,true);
$es = es('email_lists_copy');
$not_must = [];
foreach ($filter as $f){
list($t,$str) = $f;
if($t==2){
$not_must[] = ["match_phrase"=>["subject"=>$str]];
}elseif ($t==1){
$not_must[] = ["match_phrase"=>["from.email"=>$str]];
}
}
echo json_encode([
"_source" => ["uuid"],
"query"=>[
"bool"=>[
"must"=>[
["term"=>["folder_as_int" => 1]], // 收件箱
["term"=>["is_auto" => 0]], // 非auto
["term"=>["is_hots" => 0]], // 非预热
["term"=>["deleted" => 0]], // 非删除
// 自动关键字
[
"bool" => [
"should"=> $not_must,
"minimum_should_match" => 1
]
]
]
]
]
]);exit;
// 查询自动回的邮件
$lists = $es->search([
"_source" => ["uuid"],
"query"=>[
"bool"=>[
"must"=>[
["term"=>["folder_as_int" => 1]], // 收件箱
["term"=>["is_auto" => 0]], // 非auto
["term"=>["is_hots" => 0]], // 非预热
["term"=>["deleted" => 0]], // 非删除
// 自动关键字
[
"bool" => [
"should"=> $not_must,
"minimum_should_match" => 1
]
]
]
]
]
],0,1000,[],1000);
foreach ($lists['hits']['hits']??[] as $list){
$id = intval($list['_source']['uuid']??0);
if($id){
_echo("id = ".$id);
redis()->rPush('sync_to_es',$id);
}
}
}
}
include_once "../vendor/autoload.php";
new AutoMail();