<?php


use Model\folderSql;

require_once "../vendor/autoload.php";


/**
 * 预热自动回复
 * @author：dc
 * @time 2025/7/2 9:58
 * Class fob_ai_mail_auto_reply
 */
class fob_hot_ai_mail_auto_reply {


    public $isStop = false;


    /**
     * @var \Lib\Db
     */
    public $db;


    public $startTime = 0;

    /**
     * SyncToEsCmd constructor.
     */
    public function __construct()
    {
        $this->db = db();

        $handler = function ($signal){
            _echo('收到进程信号 '. $signal);
            // 可以处理其他程序
            $this->isStop = true;
        };
        pcntl_signal(SIGTERM, $handler); // 这个是kill
        pcntl_signal(SIGINT, $handler); // 这个是 ctrl+c

        $this->startTime = time();
    }


    /**
     * @return bool
     */
    public function isStop(): bool
    {
        // 检查是否接收到信号
        pcntl_signal_dispatch();

        // 是否超过来最大执行时间
        if(time()-43200 > $this->startTime){
            return true;
        }

        return $this->isStop;
    }

    protected $bodys = [];

    public function getDelayTime(){
        /**
         * 随机一个延时时间秒 极小的概率30-60分钟，小概率60-120分钟，中概率120-180分钟 大概率180-240分钟
         */

// 生成一个 0 到 100 之间的随机数
        $randomValue = rand(0, 100);

        // 根据随机值的范围来决定延迟时间
        if ($randomValue < 5) { // 5% 的概率
            // 随机 30-60分钟
            $rand = rand(45, 60) * 60; // 转换为秒
        } elseif ($randomValue < 15) { // 10% 的概率 (5% + 10%)
            // 随机 60-120分钟
            $rand = rand(65, 120) * 60; // 转换为秒
        } elseif ($randomValue < 45) { // 30% 的概率 (15% + 30%)
            // 随机 120-180分钟
            $rand = rand(125, 180) * 60; // 转换为秒
        } else { // 55% 的概率 (45% + 55%)
            // 随机 180-240分钟
            $rand = rand(180, 240) * 60; // 转换为秒
        }

        return time()+$rand;
    }

    public function handler(){

        $this->bodys = file_get_contents(__DIR__."/body.reply");
        $this->bodys = explode("--------------",$this->bodys);

        while (!$this->isStop()){

            $id = redis()->lPop('new_hot_mail_auto_reply_ids');
            if($id){
                // 检查是否到时间了
                list($did,$time)  = explode('.',((string) $id).'.0');
                if($time == '0'){
                    redis()->rPush('new_hot_mail_auto_reply_ids',$id.'.'.$this->getDelayTime());
                    continue;
                }

                $h = (int) date('H');
                if($h >= 23 || $h < 6 ){
                    sleep(5);
                    continue;
                }


                 if($time > time()){
                     redis()->rPush('new_hot_mail_auto_reply_ids',$id);
                     usleep(10000);
                     // echo $did." ".date("Y-m-d H:i:s",$time)." 时间未到 \n";
                     continue;
                 }
                // 查询数据
                $data = $this->db->first(\Model\listsSql::first('`id` = '.$did,'`id`,`to`,`folder_id`,`email_id`,`subject`,`is_hots`,`from`,`udate`,`uid`'));
                if($data && $data['is_hots']){
                    // 在检查下是否是 收件箱
                    if($this->db->cache(3600)->value(\Model\folderSql::has(['id'=>$data['folder_id'],'origin_folder'=>'INBOX']))){
                        _echo('处理 '.$data['id']);
                        $email = $this->db->throw()->cache(3600)->first(\Model\emailSql::first($data['email_id']));

                        // 验证是否是ai邮箱
                        if($this->db->count(sprintf("select count(*) from `hot_mail` where `email` = '%s'",$email['email']))){
                            // 标记已读
                            $email['password'] = base64_decode($email['password']);
                            $email['host'] = $email['imap'];
                            $mailInstance = \Lib\Imap\ImapPool::get(new \Lib\Imap\ImapConfig($email));
                            if($mailInstance->login()){
                                $mailInstance->folder('INBOX')->msg()->uid($data['uid'])->seen();
                                $mailInstance = null;
                            }

                            // 来回超过5次就不回了
                            if(substr_count($data['subject'],"Re:") < 3){
// 有配置才回复
                                $email['hot_email'] = 1;
                                $email['password'] = base64_encode($email['password']);
                                $ret = \Lib\Mail\MailFun::sendEmail([
                                    'subject'   =>  'Re:'.$data['subject'],
                                    'tos'   =>  [['email'=>$data['from'],'name'=>explode('@',$data['from'])[0]]],
                                    'body'  => $this->trimBody($data,$data['subject']),
                                    'mail-header' => [
                                        'Aicc-Hot-Mail' =>  'hot' // 预热邮件
                                    ]
                                ],$email);

                                _echo(($ret[0]?'回复成功 ':'失败 ').$data['id']." ".$email['email'].' to '.$data['from']." ".$ret[1]);
                            }else{
                                _echo('来回超过5次就不回了 '.$data['id']);
                            }
                        }
                    }

                }

            }else{
                sleep(1);
            }
        }

    }

    public function trimBody($data,$inbox){
        // 随机body内容
        $reply = $this->bodys[array_rand($this->bodys)];

        if(rand(1,2)==1){
            $reply = "<pre>".$reply."</pre>";
        }else{
            $reply = array_map(function ($v){
                return "<p>".$v."</p>";
            },explode("\n",$reply));
            $reply = implode("\n",$reply);
        }


        return "<pre style='background-color: #e8d6d6;'>------------------ 原始邮件 ------------------
发件人: {$data['from']};
发送时间: " .date("Y年m月d日 H:i",$data['udate'])."
收件人: {$data['to']};
主题: {$data['subject']}

{$inbox}</pre>".$reply;
    }




}

(new fob_hot_ai_mail_auto_reply())->handler();

return 1;