<?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}）启动成功");


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

            $id = db()->value('select `id` from `'.\Model\emailSql::$table.'` where `id` > '.$id.' limit 1');

            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{
                //每次都暂停1秒，防止同一时间启动太多的任务
                co::sleep(300);
                break;
            }
        }

    },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." where `email_id` = {$email_id} and `folder_id` = {$folder_id} limit 100 offset ".($page*100));
            $page++;
            if($ids){
                $ids = array_column($ids,'id','uid');
                try {
                    $result = $mailServer->client->fetch(array_keys($ids),'UID',true);
                }catch (Throwable $e){
                    return 0;
                }
                foreach ($ids as $uid=>$id){
                    if(!isset($result[$uid])){
                        _echo('删除 e '.$email_id.' f '.$folder_id.' u '.$uid.' id '.$id.' d '.$db->delete(\Model\listsSql::$table,['id'=>$id]).' fd '.$db->delete('fob_hot_mail',['lists_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();