mail del

+<?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();
+
+
+
+
+
+
+
+
+