周海龙 / mail-serve · 提交

转到一个项目

作者 邓超
提交 2b9589772620287518d3ea6f633c9353a9bd0924 1 个父辈 e63df597

es

内嵌 并排对比
正在显示 6 个修改的文件 包含 515 行增加 和 85 行删除
... ... @@ -11,6 +11,7 @@
"ext-mbstring": "*",
"ext-pdo": "*",
"ext-redis": "*",
"elasticsearch/elasticsearch": "7.x",
"phpmailer/phpmailer": "^6.7",
"swlib/saber": "^1.0"
},
... ... @@ -35,7 +36,8 @@
"preferred-install": "dist",
"sort-packages": true,
"allow-plugins": {
"pestphp/pest-plugin": true
"pestphp/pest-plugin": true,
"php-http/discovery": true
}
},
"minimum-stability": "stable",
... ...
... ... @@ -16,17 +16,63 @@ class Test {
public function home(){
if(app()->request('sign')!='s1'){
http_response_code(404);
app()->e(404,404);
}
$email = db()->first(emailSql::first(app()->request('mid')));
$config = (new \Lib\Imap\ImapConfig())
->setEmail($email['email'])
->setPassword(base64_decode($email['password']))
->setHost($email['imap']);
// $urlGetSign = function ($mobile){
// $time = time();
// $s = 'MindrHbWGJaEfhw85oQW3LYTnUMebm4H';
// $data = [
// 'app_id' => 10002415,
// 'timestamp' => $time
// ];
// $data = http_build_query($data);
//
// $sign = md5(md5($data).$s);
//
// return 'http://local.admin.hagro.cn/'.app()->request('route').'?iframe_sign='.
// base64_encode($mobile.'.'.$sign.'.'.$time);
// };
//
//
// $url = $urlGetSign('18868868868');
// return '<html>
//<head><title>403 您没有权限访问</title></head>
//<body>
//<div style="display: flex">
//<div style="width: 200px;">
//<p><a href="/?route=ai_search">ai搜索</a></p>
//<p><a href="/?route=ai_company_search">企业洞察</a></p>
//<p><a href="/?route=ai_keyperson">ai决策人</a></p>
//<p><a href="/?route=customer_guide">海关数据</a></p>
//<p><a href="/?route=tools/tool_mobile_verify">验证手机号</a></p>
//<p><a href="/?route=tools/tool_translate">智能翻译</a></p>
//<p><a href="/?route=tools/tool_exchange_rate">实时汇率</a></p>
//<p><a href="/?route=tools/tool_mailbox_verify">邮箱验证</a></p>
//<p><a href="/?route=tools/tool_vat">VAT查询</a></p>
//<p><a href="/?route=pro/article/31">海外社媒（AI）</a></p>
//<p><a href="/?route=pro/article/29">网站文案（AI）</a></p>
//<p><a href="/?route=pro/article/73">邮件助手（AI）</a></p>
//<p><a href="/?route=pro/article/74">企业应用（AI）</a></p>
//<p><a href="/?route=pro/e/commerce">跨境电商（AI）</a></p>
//</div>
//<iframe src="'.$url.'" frameborder="0" style="width: 100%;height: 100vh;"></iframe>
//</div>
//
//</body>
//</html>';
// if(app()->request('sign')!='s1'){
// http_response_code(404);
// app()->e(404,404);
// }
//
//// $email = db()->first(emailSql::first(app()->request('mid')));
//
// $config = (new \Lib\Imap\ImapConfig())
// ->setEmail('CService001@spicay-meart.com')
// ->setPassword('5YmS77JBb7JJwuaD')
// ->setHost('imap.exmail.qq.com');
$imap = \Lib\Imap\ImapPool::get($config);
... ... @@ -41,23 +87,26 @@ class Test {
// echo '|';
// };
$folder = $imap->folder('INBOX');
// echo '总共有：';
// echo $folder->getTotal();
// echo "<br>";
// echo "<br>";
// echo '<a href="?msgno='.($msgno+1).'">下一个</a>';
// echo "<br>";
// echo "<hr>";
$msg = $folder->msg()->msgno($msgno)->get()->first();
if ($msg) {
echo '总共有：';
echo $folder->getTotal();
echo "<br>";
echo "<br>";
echo '<a href="?msgno='.($msgno+1).'">下一个</a>';
echo "<br>";
echo "<hr>";
$msgs = $folder->msg()->forPage(449)->get();
if ($msgs) {
$msgs->each(function ($msg){
echo '<p>'.$msg->uid.'==>'.$msg->header->getSubject().' =====> '.date('Y-m-d H:i:s',strtotime($msg->date)).'</p>';
});
// echo $msg->header->getSubject();
// echo '<br>-------------------------------------------------<br>';
if($msg->body->getHtml()){
echo $msg->body->getHtml();
}else{
echo $msg->body->getText();
}
// if($msg->body->getHtml()){
// echo $msg->body->getHtml();
// }else{
// echo $msg->body->getText();
// }
// $msg->header->getRaw()
// echo $msg->body->getAttachment();
// foreach ($msg->body->getAttachment() as $attachment){
... ...
... ... @@ -96,66 +96,6 @@ class SyncMail {
return $this->db->update(listsSql::$table,['is_hots'=>1],dbWhere(['id'=>$id]));
}
/**
* 验证邮箱
* @param $email
* @author：dc
* @time 2024/8/28 14:33
*/
public function checkEmail($email){
// mimecast@wsa.aero
$filterEmail = [
'mimecast@wsa.aero',
'support@sugardaddymeet.com',
'registration@facebookmail.com',
];
if(in_array($email,$filterEmail)){
return true;
}
if(preg_match("/^((no-?reply)|(postmaster)|(mailer-daemon)|(email-notifications)|(googleplay-noreply)|(postmaster-noreply)|(privacy-noreply))@/i",$email)){
return true;
}
if(preg_match("/((no-?reply)|(postmaster)|(mailer-daemon)|(email-notifications))/i",$email)){
return true;
}
return false;
}
/**
* 验证标题是否存在某些关键词
* @param string $subject
* @return bool
* @author：dc
* @time 2024/8/24 15:09
*/
public function checkSubject(string $subject){
$keys = [
'Automatic reply: ',
'Delivery Failure',
'Automatische Antwort:',
'Automatic_reply:',
'Undelivered Mail Returned',
'Mail delivery failed:',
'Delivery Status Notification',
'Undeliverable',
'failure',
'Undelivered',
];
foreach ($keys as $key){
if(stripos($subject,$key)!==false){
return true;
}
}
return false;
}
/**
* 自动回复邮箱
... ...
<?php
namespace Event;
use Lib\Es\Es;
use Model\listsSql;
/**
* 同步数据到es
* @author：dc
* @time 2025/3/1 17:57
* Class SyncMailToEs
* @package Event
*/
class SyncMailToEs {
public $type = '';
public $table = '';
public $where = '';
public $data = [];
public function __construct(string $type,int $table, $where=[],$data=[])
{
$this->type = $type;
$this->table = $table;
if ($type == 'create'){
$this->data = $where;
}else{
$this->where = is_array($where) ? dbWhere($where) : $where;
$this->data = $data;
}
$this->handler();
}
/**
* @var \Lib\Es\Es
*/
public $es;
public function handler(){
$this->es = new Es('hg_ai_emails');
if(in_array($this->table,['lists','lists_auto','lists_hot'])){
if($this->type=='create'){
$this->create();
}
else if($this->type=='update'){
$this->update();
}
else{
}
}
}
/**
* @author：dc
* @time 2025/3/3 9:41
*/
public function create(){
if($this->table == 'lists_hot'){
return ;
}
else if($this->table == 'lists'){
$id = $this->data['email_id'].'_'.$this->data['folder_id'].'_'.$this->data['uid'];
if(empty($this->data['is_auto'])){
$this->data['is_auto'] = 0;
}
$this->es->create($this->data,$id);
}
else if($this->table == 'lists_auto'){
$id = db()->first(listsSql::first($this->data['lists_id'],'`email_id`,`folder_id`,`uid`'));
$id = $id['email_id'].'_'.$id['folder_id'].'_'.$id['uid'];
$this->es->update($id,['is_auto'=>1]);
}
}
/**
* 更新数据
* @author：dc
* @time 2025/3/3 10:53
*/
public function update(){
// if($this->table == 'lists_hot'){
//
// }
if($this->table == 'lists'){
// 更新es
$lists = db()->all(listsSql::all($this->where,'`email_id`,`folder_id`,`uid`'));
foreach ($lists as $list){
$id = $list['email_id'].'_'.$list['folder_id'].'_'.$list['uid'];
$this->es->update($id,$this->data);
}
}
}
}
... ...
... ... @@ -142,6 +142,9 @@ trait DbQuery {
$data['updated_at'] = empty($data['updated_at']) ? date('Y-m-d H:i:s') : $data['updated_at'];
}
// es 同步数据
\Event\Event::call('\Event\SyncMailToEs','update',$table,$where,$data);
$sql = "update `{$table}` set ".dbUpdate($data). " where ".$where;
$data = $this->getData($data);
... ... @@ -215,6 +218,9 @@ trait DbQuery {
$query = $this->query([$sql,$data]);
if($query){
$data['uuid'] = $this->getClient()->lastInsertId();
// es 同步数据
\Event\Event::call('\Event\SyncMailToEs','create',$table, $data);
return true;
}
... ... @@ -235,6 +241,8 @@ trait DbQuery {
if($upFiled){
return $this->update($table,[$upFiled === true ? 'deleted_at' : $upFiled =>time()],$where);
}
// es 同步数据
\Event\Event::call('\Event\SyncMailToEs','delete',$table, $where);
$sql = "delete from `{$table}` where ".dbWhere($where);
... ...
<?php
namespace Lib\Es;
use Elasticsearch\ClientBuilder;
/**
* @see https://github.com/elastic/elasticsearch-php/tree/7.17
* @author：dc
* @time 2023/6/5 10:13
* Class Es
* @package GlobalSo\Tool\Es
*/
class Es {
// private $host = 'https://es-gqtfpyon.public.tencentelasticsearch.com:9200'; // 黑格那个服务器
// private $host = 'http://elastic:1qOtfZhqy4B7IXdIpl_W@192.168.80.129:9200';
// private $host = 'https://es-az664rii.public.tencentelasticsearch.com:9200'; // aicc 服务器
private $host = [
// 'http://elastic:1qOtfZhqy4B7IXdIpl_W@192.168.80.129:9200',
'https://elastic:rEHsd8xf4xGJKHdD@es-gqtfpyon.public.tencentelasticsearch.com:9200'
]; //内网地址 公网要加ip白名单
/**
* @var \Elasticsearch\Client
*/
protected $client;
/**
* @var string
*/
protected $index;
/**
* Es constructor.
* @param $index
*/
public function __construct($index)
{
$this->index = $index;
$this->client = ClientBuilder::create()
->setHosts($this->host)
// ->setBasicAuthentication($user, $password)
// ->setCABundle('path/to/http_ca.crt')
->build();
}
/**
* 搜索
* @param array $body
* @param int $from
* @param int $size
* @param array $sort
* @return array
* @author：dc
* @time 2023/6/5 14:35
*/
public function search(array $body,int $from=0,int $size=20,array $sort= []){
$params = [
'index' => $this->getIndex(),
'body' => $body,
'from' => $from,
'size' => $size
];
// 排序
if($sort){
$params['sort'] = $sort;
}
try {
$response = $this->client->search($params);
}catch (\Throwable $e) {
logs("搜索数据es:".$e->getMessage());
return [];
}
return $response;
}
/**
* @param array $params
* @return array|callable
* @author：dc
* @time 2023/6/9 15:50
*/
public function get(array $param){
$params = [
'index' => $this->getIndex()
];
if(!empty($param['id'])){
$params['id'] = $param['id'];
}
try {
$response = $this->client->get($params);
}catch (\Throwable $e) {
logs("读取数据es:".$e->getMessage());
return [];
}
return $response;
}
/**
* 获取索引
* @return string
* @author：dc
* @time 2023/6/5 10:51
*/
public function getIndex():string{
return $this->index;
}
/**
* 保存修改
* @param string $id
* @param array $data
* @return int
* @author：dc
* @time 2025/3/1 14:53
*/
public function save(string $id, array $data){
$params['index'] = $this->getIndex();
$params['id'] = $id;
$params['body'] = $data;
try {
$response = $this->client->index($params);
}catch (\Throwable $e) {
logs("创建或者修改es：".$e->getMessage());
return 500;
}
return $response['_shards']['successful']?200:500;
}
/**
* 创建数据
* @param array $params
* @return int
* @author：dc
* @time 2025/3/1 14:25
*/
public function create(array $data, string $id = ''){
$params['index'] = $this->getIndex();
$params['body'] = $data;
if($id){
$params['id'] = $id;
}
try {
$response = $this->client->create($params);
}catch (\Throwable $e) {
logs("新增es:".$e->getMessage());
return 500;
}
return $response['_shards']['successful']?200:500;
}
/**
* 更新文档
* @param string $id
* @param array $data
* @return int
* @author：dc
* @time 2025/3/1 14:30
*/
public function update(string $id, array $data){
$params['index'] = $this->getIndex();
$params = [
'index' => $this->getIndex(),
'id' => $id,
'body' => [
'doc' => $data
]
];
try {
$response = $this->client->update($params);
}catch (\Throwable $e) {
logs("更新es：".$e->getMessage());
return 500;
}
return $response['_shards']['successful']?200:500;
}
/**
* 删除
* @param string $id
* @return array|callable|false
* @author：dc
* @time 2023/6/5 16:26
*/
public function delete(string $id){
try {
$response = $this->client->delete([
'index' => $this->getIndex(),
'id' => $id
]);
} catch (\Throwable $e) {
logs('删除es数据：'.$e->getMessage());
return false;
}
return $response;
}
/**
* @return \Elasticsearch\Client
* @author：dc
* @time 2025/3/1 16:23
*/
public function getClient()
{
return $this->client;
}
/**
* 更新索引 Mapping
* @param array $params
* @author：dc
* @time 2023/6/29 11:17
*/
public function putMapping(array $params,array $setting=[]){
$params = [
"body" => [
"mappings" => $params,
]
];
$params['index'] = $this->getIndex();
if($setting){
$params['body']['settings'] = $setting;
}
try {
$response = $this->client->indices()->create($params);
}catch (\Throwable $e) {
logs('es 创建索引 映射:'.$e->getMessage());
return false;
}
return $response['acknowledged']??false;
}
/**
* @return array|false
* @author：dc
* @time 2024/1/9 10:12
*/
public function getMapping(){
$params = [];
$params['index'] = $this->getIndex();
try {
$response = $this->client->indices()->getMapping($params);
}catch (\Throwable $e) {
return [];
}
return $response[$this->getIndex()]['mappings']['properties']??[];
}
/**
* 判断是否存在索引
* @return bool
* @author：dc
* @time 2023/6/29 12:37
*/
public function hasIndex(){
$params['index'] = $this->getIndex();
$response = $this->client->indices()->exists($params);
return $response;
}
}
... ...