<?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');


        if(redis()->add('auto_mail_sync2',1,60)){
            echo '正在计算数据';
            $maxId = $this->db->value("select `id` from `lists` order by `id` desc limit 1");
            $id = 0;
            while (1){
                $ids = [];
                for ($i=0;$i<1000;$i++){
                    $ids[] = $i+$id;
                }
                $id = end($ids);

                redis()->rPush('auto_check_ids',implode(',',$ids));

                if($id>$maxId){
                    break;
                }
            }
            echo '计算完成';
        }


        while (1){
            $ids = redis()->lPop('auto_check_ids');
            if($ids){
                $ids = explode(',',$ids);
                $this->run($ids);
            }else{
                echo '等待'.PHP_EOL;
                co::sleep(2);
            }
        }

    }

    private $filter = [
        ['2','Automatic reply'],
        ['2','Delivery'],
        ['2','Automatische Antwort:'],
        ['2','Automatic_reply'],
        ['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']
    ];

    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'])){
                            $this->db->insert('`lists_auto`',['list_id'=>$item['id']],false);
                            echo "插入数据 ".$item['id']."\n";
                        }
                    }
                }
            }

        }
    }



}


swoole_set_process_name('auto-reply-run-man');

$pm = new Swoole\Process\Manager();

$pm->addBatch(2,function (){

    swoole_set_process_name('auto-reply-email-run');

    include_once "../vendor/autoload.php";

//    while(1){
    new AutoMail();
    // 执行完了暂停5分钟在执行
    sleep(40);
//    }

},true);

$pm->start();