job

@@ -548,7 +548,7 @@ class Home extends Base {
     public function sync(){
     public function sync(){
 
 
         $emails = web_request_emails();
         $emails = web_request_emails();
-
+        $sync_type = app()->request('sync_type');
         if(empty($emails)){
         if(empty($emails)){
             app()->e('sync_request_param_error');
             app()->e('sync_request_param_error');
         }else{
         }else{
@@ -576,7 +576,21 @@ class Home extends Base {
 
 
                     }
                     }
                     $source = app()->request('source');
                     $source = app()->request('source');
-                    redis()->rPush('sync_email_lists'.($source==1?'_my':''), $v['id']);
+
+                    // 是否立即同步
+                    if($sync_type == 'immediately'){
+                        try{
+                            if(redis()->add('sync_immediately:'.$v['id'],1,10)){
+                                (new SyncMail($v['id']))->isUidAfter()->sync();
+                            }
+                        }catch (\Throwable $e){
+                            logs($e->getTraceAsString());
+                        }
+
+                    }else{
+                        redis()->rPush('sync_email_lists'.($source==1?'_my':''), $v['id']);
+                    }
+
                 }
                 }
                 $datas[$k]['have_new'] = redis()->getDel('have_new_mail_'.$v['id']);
                 $datas[$k]['have_new'] = redis()->getDel('have_new_mail_'.$v['id']);