From 3ccea2fc0dfa1b210abdd97f291427c644c6e95d Mon Sep 17 00:00:00 2001 From: dengchao <200582249@qq.com> Date: Thu, 20 Mar 2025 11:08:12 +0800 Subject: [PATCH] job --- service/SyncMail.php | 49 +++++++++++++++++++++++++++++++++++++++++++++---- 1 file changed, 45 insertions(+), 4 deletions(-) diff --git a/service/SyncMail.php b/service/SyncMail.php index 63ef173..c3bfc6d 100644 --- a/service/SyncMail.php +++ b/service/SyncMail.php @@ -55,6 +55,12 @@ class SyncMail { */ protected $isForceUpdate = false; + /** + * 是否输出日志 + * @var bool + */ + protected $echoLog = false; + /** * SyncMail constructor. @@ -94,6 +100,27 @@ class SyncMail { } /** + * @param bool $echoLog + */ + public function setEchoLog() + { + $this->echoLog = true; + return $this; + } + + /** + * 输出日志 + * @param $msg + * @author:dc + * @time 2025/3/20 11:03 + */ + protected function eLog($msg){ + if($this->echoLog){ + _echo($msg); + } + } + + /** * 搜索 * @param ImapSearch $search * @return $this @@ -335,7 +362,7 @@ class SyncMail { if(is_string($folder)){ $folder = $this->imap->folder($folder)->exec(); } - + $this->eLog("正在同步 ".$folder->getName()); $folder_id = $this->getFolderId($folder->getName()); if($folder->getName() == 'INBOX'){ $this->folder_inbox_id = $folder_id; @@ -461,12 +488,19 @@ class SyncMail { ]),'`id`')); if(!$id){ - - $id = $this->insert($data); - // 收件箱直接 未读 不远程为准 + $this->eLog( + sprintf("正在插入数据 eid:%d fid:%d uid:%d subject: %s", + $data['email_id'], + $data['folder_id'], + $data['uid'], + $data['subject'], + )); + +// 收件箱直接 未读 不远程为准 if(defined('CLI_AI_SYNC_START') && !empty($this->folder_inbox_id) && $this->folder_inbox_id == $data['folder_id']){ $data['seen'] = 0; } + $id = $this->insert($data); if(!$id){ continue; @@ -482,6 +516,13 @@ class SyncMail { }else{ // 非ai邮件才更新 if(!defined('CLI_AI_SYNC_START')){ + $this->eLog( + sprintf("正在update数据 eid:%d fid:%d uid:%d subject: %s", + $data['email_id'], + $data['folder_id'], + $data['uid'], + $data['subject'], + )); $this->db->update(listsSql::$table,$data,dbWhere(['id'=> $id])); } -- libgit2 0.24.0