<?php


/**
 * 循环本地，验证远程是否存在 不存在则删除本地
 */
//error_reporting();

use Swoole\Process;



function start(){

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

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

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

        swoole_set_process_name('php-email-sync-list-check-'.$worker_id);

        include_once __DIR__."/../vendor/autoload.php";
        _echo("业务进程（{$worker_id}）启动成功");

        $run_timer  = time();

        $id = 0;
        // 循环阻塞
        while (true){

            // 运行超过1天的 停止
            if($run_timer < (time()-21600)){
                break;
            }

            $id = db()->value(\Model\listsSql::first('`id` > '.$id,'`id`'));

            if($id){
                // 占用当前的id,占用2小时
                if(redis()->add('just_sync_delete_'.$id,time(),3600)){
                    // 启动一个协程
                    go(function () use ($id){
                        // 开始同步
                        try {
                            sync($id);
                        }catch (\Throwable $e){
                            echo $e->getMessage();
                        }
                        \Lib\Log::getInstance()->write();
                    });
                }
            }else{
                co::sleep(1);
            }
            //每次都暂停1秒，防止同一时间启动太多的任务
            co::sleep(0.5);
        }

    },true);


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

}

/**
 * 开始同步, 这里是主要的业务代码
 * @param $email_id
 * @param $worker_id
 * @return int
 * @author：dc
 * @time 2023/3/10 10:19
 */
function sync($email_id){

    $email = db()->first(\Model\emailSql::first($email_id));
    if(!$email || $email['pwd_error']){
        return 0;
    }

    // 读取到邮箱中的文件夹
    $folders = db()->all(\Model\folderSql::all($email['id']));
    if(!$folders){
        return 3;
    }


    $mailServer = new Lib\Mail\Mail($email['email'],base64_decode($email['password']),$email['imap']);

    // 登录服务器
    if($mailServer->login()!==1){
        return 2;
    }

    $call = function ($email_id,$folder_id,$origin_folder) use ($mailServer){
        // gmail 邮箱 这个是不可选的
        if($origin_folder == '[Gmail]'){
            return;
        }
        // 同步父文件夹
        $mailServer->client->selectFolder($origin_folder);
        $page = 0;
        $db = db();
        while (1){
            $ids = $db->all("select `id`,`uid` from ".\Model\listsSql::$table." limit 100 offset ".($page*100));
            $page++;
            if($ids){
                $ids = array_column($ids,'id','uid');
                $result = $mailServer->client->fetch(array_keys($ids),'UID',true);
                foreach ($ids as $uid=>$id){
                    if(!isset($result[$uid])){
                        _echo('删除 e '.$email_id.' f '.$folder_id.' u '.$uid.' id '.$id);
                        // 删除 如果远程没有，就删除本地
                        $db->delete(\Model\listsSql::$table,['id'=>$id]);
                    }
                }
            }
            // 结束了
            if(count($ids) < 100){
                break;
            }

        }


    };

//    $folders = list_to_tree($folders);
    foreach ($folders as $folder){
        try {

            if(empty($folder['_child'])){
                $call($email_id,$folder['id'],$folder['origin_folder']);
            }else{
                foreach ($folder['_child'] as $item){
                    // 同步子文件夹
                    $call($email_id,$item['id'],$item['origin_folder']);
                }
            }

        }catch (\Throwable $e){
            logs(
                $e->getMessage().$e->getTraceAsString(),
                LOG_PATH.'/imap/'.$email['email'].'.error.log'
            );
        }
    }


    $email = null;
    $mailServer = null;
}


if(!function_exists("imap_8bit")){
    echo '请安装imap扩展';
    exit(0);
}



start();