作者 邓超

sync

@@ -4,7 +4,9 @@ @@ -4,7 +4,9 @@
4 4
5 use Swoole\Process; 5 use Swoole\Process;
6 6
7 - 7 +// 表示同步ai邮件脚本
  8 +// 这个的作用主要用于 凡ai邮箱收件箱邮件,同步回来都是未读,不读取远程的
  9 +define('CLI_AI_SYNC_START', 1);
8 10
9 function start(){ 11 function start(){
10 12
@@ -337,6 +337,9 @@ class SyncMail { @@ -337,6 +337,9 @@ class SyncMail {
337 } 337 }
338 338
339 $folder_id = $this->getFolderId($folder->getName()); 339 $folder_id = $this->getFolderId($folder->getName());
  340 + if($folder->getName() == 'INBOX'){
  341 + $this->folder_inbox_id = $folder_id;
  342 + }
340 if(in_array($folder->getName(),['INBOX','[Gmail]/Important','[Gmail]/Starred','星标邮件','Important'])){ 343 if(in_array($folder->getName(),['INBOX','[Gmail]/Important','[Gmail]/Starred','星标邮件','Important'])){
341 $isBody = true; 344 $isBody = true;
342 } 345 }
@@ -456,18 +459,15 @@ class SyncMail { @@ -456,18 +459,15 @@ class SyncMail {
456 'folder_id' => $data['folder_id'], 459 'folder_id' => $data['folder_id'],
457 'uid' => $data['uid'] 460 'uid' => $data['uid']
458 ]),'`id`')); 461 ]),'`id`'));
459 - if(!$id){  
460 - $id = $this->db->value(listsSql::firstHot(dbWhere([  
461 - 'email_id'=> $data['email_id'],  
462 - 'folder_id' => $data['folder_id'],  
463 - 'uid' => $data['uid']  
464 - ]),'`id`'));  
465 - }  
466 -  
467 462
468 if(!$id){ 463 if(!$id){
469 464
470 $id = $this->insert($data); 465 $id = $this->insert($data);
  466 + // 收件箱直接 未读 不远程为准
  467 + if(defined('CLI_AI_SYNC_START') && !empty($this->folder_inbox_id) && $this->folder_inbox_id == $data['folder_id']){
  468 + $data['seen'] = 0;
  469 + }
  470 +
471 if(!$id){ 471 if(!$id){
472 continue; 472 continue;
473 } 473 }