<?php

namespace Event;

use Model\folderSql;
use Model\listsSql;
use Swlib\Saber;
use Swlib\SaberGM;

/**
 * 邮件同步成功的事件
 * @author：dc
 * @time 2024/8/22 15:47
 * Class syncMail
 * @package Event
 */
class syncMail {
    /**
     * @var \Lib\Db|\Lib\DbPool
     */
    private $db;


    public function __construct($id,$header,$data)
    {
        $this->db = db();

        // 是否是预热邮件 aicc专用
        if(!empty($header['Aicc-Hot-Mail']) || !empty($header['aicc-hot-mail'])){
            return $this->hot($id);
        }

        // 是否在指定文件夹内
        $f = $this->db->value(folderSql::first($data['folder_id'],'folder'));
        if(!$f){
            return true;
        }
        $f = folderAlias($f);
        if($f=='发件箱'){
            if(empty($data['to_name'])){
                $data['to_name'] = [];
            }

            $data['to_name'] = is_array($data['to_name'])?$data['to_name']:json_decode($data['to_name']);

            $w = ['email' => array_column($data['to_name'],'email')];
        }else{
            $w = ['email' =>$data['from']];
        }
        // 是否在 预热邮箱中
        if($this->db->count('select count(*) from `hot_mail` where '.dbWhere($w))){
            return $this->hot($id);
        }


        // 不是预热邮箱
        if($f=='收件箱'){

            $this->auto_mail($id,$data);

            $this->black_mail($id,$data);

            // 邮件过滤 这些邮箱都是系统邮箱
//            if(!$this->checkEmail($data['from']) && !$this->checkSubject($data['subject'])){
            //只提醒re
            if(stripos(trim($data['subject']),'re:')===0){
                // 通知黑格 2024-08-22 新上 这个是异步的不会阻塞当前进程
                try {
                    SaberGM::post('https://fob.ai.cc/api/email_new_push',[
                        'sign'  =>  md5(date('ymd').'fob.ai.cc.email'),
                        'id'    =>  $id,
                        'subject'   =>  $data['subject'],
                        'udate'   =>  $data['udate'],
                        'from'   =>  $data['from'],
                        'tos'    =>  array_column(json_decode($data['to_name'],1),'email')
                    ]);
                }catch (\Throwable $e){
                    // 就算异常了也不在推送了
                }

            }


        }

    }

    private function hot($id){
        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;
    }


    /**
     * 自动回复邮箱
     * @param $id
     * @param $data
     * @author：dc
     * @time 2024/9/12 15:29
     */
    private function auto_mail($id,$data){
        $filter = '2	Automatic reply
2	Delivery
2	Automatische Antwort
2	Undeliverable
2	Failure
2	Undelivered
1	noreply
1	postmaster
1	email-notifications
1	mailer-daemon
1	no-reply
2	自动回复
2	Returned mail
2	Autosvar
2	Out Of Office Re
2	Change_of_email_address
2	delivered
2	automatique
2	Reply auto
2	automatic
2	Request received
2	Automatisch
2	Unzustellbar
2	Notification
2	Invitation
2	expired';
        $filter = explode("\n",$filter);

        foreach ($filter as $f){
            if(!$f) continue;
            list($t,$str) = [
                intval(mb_substr($f,0,1)),
                trim(mb_substr($f,1,99)),
            ];
            $haystack = '';
            if($t==2){
                $haystack = $data['subject'];
            }elseif ($t==1){
                $haystack = $data['from'];
            }
            if(stripos($haystack,$str)!==false){
                if(!$this->db->count("select count(*) from `lists_auto` where `list_id` = ".$id)){
                    $this->db->create('lists_auto',['list_id'=>$id],false);
                }
                break;
            }
        }



    }

    /**
     * 黑名单邮箱，直接delete
     * @param $id
     * @param $data
     * @author：dc
     * @time 2024/9/12 15:29
     */
    private function black_mail($id,$data){

        if(!empty($data['from'])){
            // 是否是ai邮件
            if($this->db->count("select count(*) from `hot_mail` where ".dbWhere([
                'email'=> $this->db->value(listsSql::first(dbWhere(['id'=>$data['email_id']]),'email'))
                ]))){
                // 是否在黑名单中
                if($this->db->count("select count(*) from `ai_black_email` where ".dbWhere(['email'=>$data['from']]))){

                    $this->db->update(listsSql::$table,['deleted'=>1],dbWhere(['id'=>$id]));
                }

            }

        }

    }


}