1

+<?php
+
+//error_reporting();
+
+use Swoole\Process;
+
+
+
+include_once __DIR__."/../vendor/autoload.php";
+
+
+function start(){
+
+// 删除停止运行的值
+    redis()->delete(RUNNING_REDIS_KEY);
+
+    // 进程管理器
+    $pm = new Process\Manager();
+
+    // 启动一个进程来管理定时
+    $pm->add(function (Process\Pool $pool, int $workerId){
+        _echo("定时进程（{$workerId}）启动成功");
+
+
+        // 进行阻塞，否则定时器无法运行
+        while (true){
+            co::sleep(9999);
+        }
+    },true);
+
+
+// 协程配置
+    \co::set([
+        'max_coroutine'=>COROUTINE_MAX_NUM, // 最大携程数量
+        'hook_flags'=>SWOOLE_HOOK_TCP,  //  redis需要的配置
+    ]);
+
+    // 启动业务进程
+    $pm->addBatch(WORKER_NUM,function (Process\Pool $pool, int $worker_id){
+        _echo("业务进程（{$worker_id}）启动成功");
+
+        $start_num = 0;// 启动的协程数量
+
+        // 循环阻塞
+        while (true){
+            // 是否到了协程配置的数量上限
+            if($start_num < COROUTINE_MAX_NUM){
+                // 需要同步的id
+                $id = redis()->lPop('sync_email_lists');
+
+                if(!$id){
+                    co::sleep(1);
+                }else{
+                    // 启动一个协程
+                    go(function () use (&$start_num,$worker_id,$id){
+                        $start_num++;
+
+                        // 开始同步
+                        try {
+                            sync($id,$worker_id);
+                        }catch (\Throwable $e){
+                            // 重新发布同步任务,如果失败了是否重新发布
+                            redis()->rPush('sync_email_lists',$id);
+
+//                            _echo($e->getMessage());
+                            logs(
+                                $e->getMessage().PHP_EOL.$e->getTraceAsString(),
+                                LOG_PATH.'/'.$worker_id.'_'.co::getCid().'.log'
+                            );
+                        }
+
+                        // 协程完成后执行的函数
+                        co::defer(function () use (&$start_num,$worker_id){
+//                        _echo('正常关闭进程（'.$worker_id.'）下的协程（'.co::getCid().'）');
+                            $start_num--;
+                        });
+
+                    });
+
+                }
+            }else{
+                // 协程到了最大的数量，阻塞1秒
+                co::sleep(1);
+            }
+
+
+        }
+
+
+    },true);
+
+
+    // 启动管理器
+    $pm->start();
+
+}
+
+
+/**
+ * 开始同步, 这里是主要的业务代码
+ * @param $email_id
+ * @param $worker_id
+ * @return int
+ * @author：dc
+ * @time 2023/3/10 10:19
+ */
+function sync($email_id,$worker_id){
+
+    $email = db()->first(\Model\emailSql::first($email_id));
+    if(!$email){
+        return 0;
+    }
+
+    if($email['pwd_error']){
+        return 1;
+    }
+
+    $mailServer = new Lib\Mail\Mail();
+
+    try {
+        // 登录服务器
+        $mailServer->login($email['email'],base64_decode($email['password']),$email['imap']);
+    }catch (Throwable $e){
+        if($e->getCode() == 403){
+            // 登录失败了 ，
+            db()->update(\Model\emailSql::$table,['pwd_error'=>1],dbWhere(['id'=>$email_id]));
+        }
+
+        return 2;
+    }
+
+    // 同步文件夹
+    $mailServer->syncFolder($email_id,db());
+
+
+    // 读取到邮箱中的文件夹
+    $folders = db()->all(\Model\folderSql::all($email['id']));
+    if(!$folders){
+        return 3;
+    }
+    $folders = list_to_tree($folders);
+    foreach ($folders as $folder){
+        try {
+            if(empty($folder['_child'])){
+                // 同步父文件夹
+                $mailServer->syncMail($email_id,$folder['id'],$folder['origin_folder']);
+            }else{
+                foreach ($folder as $item){
+                    // 同步子文件夹
+                    $mailServer->syncMail($email_id,$item['id'],$item['origin_folder']);
+                }
+            }
+
+        }catch (Throwable $e){
+            logs(
+                $e->getMessage(),
+                LOG_PATH.'/imap/'.$email['email'].'.error.log'
+            );
+        }
+    }
+
+
+    $email = null;
+    $mailServer = null;
+}
+
+
+
+
+switch ($argv[1]){
+    case 'start':{
+        start();
+        break;
+    }
+    case 'stop':{
+        \Co\run(function (){
+            echo "正在退出程序...\n非必要请不要强制kill掉进程\n";
+            redis()->set(RUNNING_REDIS_KEY,'stop');
+            while (true){
+                $num = exec("ps -ef | grep \"sync.php start\" | grep -v grep | wc -l");
+                if(!$num){
+                    break;
+                }
+                co::sleep(0.5);
+            }
+            echo "已退出程序\n";
+        });
+        break;
+    }
+    default:{
+        break;
+    }
+}
+
+
+
+
+
+
+
+
+
+

 <?php
 
+/**
+ * TODO:: 这个文件是定时去拉取所有邮箱中的邮件
+ * 暂时不用这个
+ */
 //error_reporting();
 
 use Swoole\Process;

@@ -3,9 +3,9 @@
 error_reporting(E_ERROR | E_NOTICE);
 
 // 开启4个进程
-define('WORKER_NUM',2);
+define('WORKER_NUM',10);
 // 开启最大1000个协程
-define('COROUTINE_MAX_NUM',1000);
+define('COROUTINE_MAX_NUM',5000);
 // 是否继续运行
 define('RUNNING_REDIS_KEY','worker_is_running');
 // 记录日志的目录

@@ -3,6 +3,7 @@
 namespace Controller;
 
 
+use Lib\Mail\Mail;
 use Lib\Mail\MailFun;
 use Model\folderSql;
 
@@ -70,12 +71,41 @@ class Folder extends Base {
             ]
         ));
 
+        if($has){
+            app()->e('folder_is_exist');
+        }
+
+        // 远程创建
+        $mail = new Mail();
+        $mail->login($this->login_email['email'],$this->login_email['password'],$this->login_email['imap']);
+        $folder = $mail->client->folderCreate($formData['folder']);
+
+
+
 
 
 
     }
 
 
+    /**
+     * 改名
+     * @author：dc
+     * @time 2023/3/3 17:40
+     */
+    public function rename(){
+
+    }
+
+    /**
+     * 删除
+     * @author：dc
+     * @time 2023/3/3 17:38
+     */
+    public function delete(){
+
+    }
+
 
 
 

@@ -258,7 +258,7 @@ function list_to_tree($list, $pk='id',$pid = 'pid',$child = '_child',$root=0,$em
  * @author：dc
  * @time 2023/2/18 11:04
  */
-function start_now_mail(){
+function start_now_mail($email=null){
     $id = 0;
 
     while (true){

@@ -23,5 +23,6 @@ return [
     'folder_create_name_error' =>  '文件夹名称只能输入中文英文数字',
     'folder_parent_not_fount' =>  '上级文件夹不存在',
     'folder_tree_max_two' =>  '文件夹最多2级',
+    'folder_is_exist' =>  '文件夹已存在',
 
 ];
\ No newline at end of file

@@ -430,12 +430,12 @@ class Imap {
      * 创建文件夹
      * $folder 目录 创建二级目录用/  a/b
      * @param string $folder
-     * @return bool
+     * @return string
      * @throws \Exception
      * @author：dc
      * @time 2022/11/24 23:35
      */
-    public function folderCreate(string $folder):bool {
+    public function folderCreate(string $folder):string {
         // 需要转码
         $folder = mb_convert_encoding($folder,'UTF7-IMAP','UTF-8');
 //        A003 CREATE owatagusiam 顶级
@@ -443,7 +443,7 @@ class Imap {
         $res = $this->request('CREATE '.$folder);
 
         if ($res[0] == 'ok'){
-            return true;
+            return $folder;
         }
 
         throw new \Exception('create folder error:'.end($res[1]));

@@ -46,6 +46,20 @@ return [
     'mail/folder/create' =>  [\Controller\Folder::class, 'create'],
 
     /**
+     * 邮件/重命名文件夹
+     * @see \Controller\Folder::rename()
+     * @param string _token_ token登录凭证
+     */
+    'mail/folder/rename' =>  [\Controller\Folder::class, 'rename'],
+
+    /**
+     * 邮件/删除文件夹
+     * @see \Controller\Folder::delete()
+     * @param string _token_ token登录凭证
+     */
+    'mail/folder/delete' =>  [\Controller\Folder::class, 'delete'],
+
+    /**
      * 发送邮件
      * @see \Controller\Home::send_mail()
      * @param string _token_ token登录凭证