优化

@@ -2,6 +2,7 @@
 
 
 //error_reporting();
 //error_reporting();
 
 
+use Swlib\SaberGM;
 use Swoole\Process;
 use Swoole\Process;
 
 
 // 表示同步ai邮件脚本
 // 表示同步ai邮件脚本
@@ -42,6 +43,19 @@ function start(){
                 co::sleep(1);
                 co::sleep(1);
                 continue;
                 continue;
             }
             }
+
+            if(redis()->add('mailbox_status_setlock',1,120)){
+                $data = [];
+                foreach (range(1,100) as $v){
+                    $data[$v] = redis()->lPop('fob_mailbox_status_set');
+                    if(!$data[$v]){ unset($data[$v]); break;}
+                }
+                SaberGM::post(SUPER_DATA2_HOST . 'api/mailbox_status_sets', [
+                    'data'  =>  $data
+                ]);
+            }
+
+
             // 需要同步的id
             // 需要同步的id
             $id = redis()->lPop('sync_email_lists');
             $id = redis()->lPop('sync_email_lists');
 
 

@@ -664,8 +664,7 @@ class SyncMail {
                         // 日志记录
                         // 日志记录
                         logs('退信邮件(cli)，id【' . $id . '】body:' . $mailBody, $logFilename);
                         logs('退信邮件(cli)，id【' . $id . '】body:' . $mailBody, $logFilename);
                         try {
                         try {
-                            // 通知到黑格 es
-                            SaberGM::post(SUPER_DATA2_HOST . 'api/mailbox_status_set', [
+                            redis()->rPush('fob_mailbox_status_set',[
                                 'id' => $id,
                                 'id' => $id,
                                 'subject' => $data['subject'],
                                 'subject' => $data['subject'],
                                 'udate' => $data['udate'],
                                 'udate' => $data['udate'],