<?php

//error_reporting();

use Swoole\Process;

// 表示同步ai邮件脚本
// 这个的作用主要用于 凡ai邮箱收件箱邮件，同步回来都是未读，不读取远程的
define('CLI_AI_SYNC_START', 1);

function start(){

// 删除停止运行的值
//    redis()->delete(SYNC_RUNNING_REDIS_KEY,'email_sync_stop_num');

    // 进程管理器
    $pm = new Process\Manager();

    // 启动业务进程
    $pm->addBatch(11,function (Process\Pool $pool, int $worker_id){

        if($worker_id===0){
            $i=43200;
            while($i>0){
                $i--;
                co::sleep(1);

            }
            $pool->shutdown();
            return 0;
        }

        include_once __DIR__."/../vendor/autoload.php";
        _echo("业务进程（{$worker_id}）启动成功");
        \Lib\DbPool::$clientNumber = 55;
        \Lib\RedisPool::$clientNumber = 55;

        // 循环阻塞
        while (true){

            while (\Lib\SwGo::$runNumber > 50){
                co::sleep(1);
                continue;
            }
            // 需要同步的id
            $id = redis()->lPop('sync_email_lists');

            if($id && is_numeric($id)){

                // 占用当前的id,占用2小时
                if(redis()->add('just_sync_'.$id,time(),600)){

                    \Lib\SwGo::start(function ($id){
                        try{
                            // 开始同步
                            $email = db()->cache(3600)->first(\Model\emailSql::first($id));
                            if($email){
                                $sync = new \Service\SyncMail($email);
                                // ai邮件只同步2天内的
                                $sync->search(
                                    (new \Lib\Imap\ImapSearch())
                                        ->dateGt(date('Y-m-d',strtotime("-1 day")))
                                );
                                $sync->isUidAfter(2)->sync();

                                $sync = null;
                                unset($sync);
                            }

                        }catch (Throwable $e){
                            logs('sync : '.$e->getMessage());
                        }


                        // 30秒后 消除占用
                        redis()->expire('just_sync_'.$id,120);

                    },$id);
                }
            }

            //每次都暂停1秒，防止同一时间启动太多的任务
            co::sleep(0.2);

        }

        return 0;

    },true);


    // 启动管理器
    $pm->start();

}




start();