auto_reply_mail.php
2.9 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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
<?php
use Model\listsSql;
/**
* 自动回复的邮件
* @author：dc
* @time 2024/9/6 17:09
* Class HotMail
*/
class AutoMail {
public function __construct(){
$this->db = db();
$this->start();
}
/**
* shopk那边的预热邮箱
* @var array
*/
private $shopkHotEmail = [];
/**
* @var \Lib\Db|\Lib\DbPool
*/
private $db;
private $fids = [];
/**
* @author：dc
* @time 2024/7/18 14:04
*/
private function start(){
$this->fids = $this->db->all("select `id` from `folders` where `folder` = '收件箱'");
$this->fids = array_column($this->fids,'id');
$filter = @file_get_contents('https://fob.ai.cc/api/mail/ai_inbox_filter/'.md5('aicc.'.date('ymdh')));
$filter = @json_decode($filter,true);
if(!is_array($filter)){
return 0;
}
array_map(function ($v){
$this->filter[] = [
$v['type'],
$v['text'],
];
},$filter[0]);
if($this->filter){
redis()->set('ai_email_filter_lists',$this->filter,86400);
}
if(redis()->add('auto_mail_sync2',1,60)){
_echo('正在计算数据');
$maxId = $this->db->value("select `id` from `lists` order by `id` desc limit 1");
$startId = $maxId-200000;
foreach (minMaxToArray($startId,$maxId) as $ids){
redis()->rPush('auto_check_ids',implode(',',$ids));
}
_echo('计算完成');
}
while (1){
$ids = redis()->lPop('auto_check_ids');
if($ids){
$ids = explode(',',$ids);
$this->run($ids);
}else{
break;
}
}
}
private $filter = [];
private function run($id){
$list = $this->db->all(\Model\listsSql::all(dbWhere(['id'=>$id]),'`id`,`from`,`subject`,`folder_id`'));
foreach ($list as $item){
// 必须是收件箱
if(in_array($item['folder_id'],$this->fids)){
foreach ($this->filter as $f){
list($t,$str) = $f;
$haystack = '';
if($t==2){
$haystack = $item['subject'];
}elseif ($t==1){
$haystack = $item['from'];
}
if(stripos($haystack,$str)!==false){
if(!$this->db->count("select count(*) from `lists_auto` where `list_id` = ".$item['id'])){
_echo("插入数据 ".$item['id'].'==>'.$this->db->create('lists_auto',['list_id'=>$item['id']],false).'==>'.$haystack);
}
break;
}
}
}
}
}
}
include_once "../vendor/autoload.php";
new AutoMail();