优化同步

@@ -58,7 +58,7 @@ function start(){
                                     (new \Lib\Imap\ImapSearch())
                                     (new \Lib\Imap\ImapSearch())
                                         ->dateGt(date('Y-m-d',strtotime("-1 day")))
                                         ->dateGt(date('Y-m-d',strtotime("-1 day")))
                                 );
                                 );
-                                $sync->sync();
+                                $sync->isUidAfter(2)->sync();
 
 
                                 $sync = null;
                                 $sync = null;
                                 unset($sync);
                                 unset($sync);

@@ -195,12 +195,12 @@ class Msg extends Request{
      * @author：dc
      * @author：dc
      * @time 2024/9/14 15:34
      * @time 2024/9/14 15:34
      */
      */
-    public function get():Messager{
+    public function get(string $number = ''):Messager{
         $this->folder->exec(); // 防止在其他文件夹下面
         $this->folder->exec(); // 防止在其他文件夹下面
         $this->cmd(
         $this->cmd(
             "%sFETCH %s (UID FLAGS INTERNALDATE RFC822.SIZE BODYSTRUCTURE RFC822.HEADER)",
             "%sFETCH %s (UID FLAGS INTERNALDATE RFC822.SIZE BODYSTRUCTURE RFC822.HEADER)",
             $this->isUid?'UID ':'',
             $this->isUid?'UID ':'',
-            implode(',',$this->number)
+            $number?$number:implode(',',$this->number)
         );
         );
 
 
         return new Messager($this->result, $this);
         return new Messager($this->result, $this);

@@ -105,6 +105,20 @@ class SyncMail {
         return $this;
         return $this;
     }
     }
 
 
+    // 查找uid之后的数据
+    public $isUid = 0;
+
+    /**
+     * @param $uid 2 表示没有数据 则执行下一个条件  1表示没有数据就没有数据
+     * @return $this
+     * @author：dc
+     * @time 2025/3/7 14:53
+     */
+    public function isUidAfter($uid=1){
+        $this->isUid = $uid;
+        return $this;
+    }
+
 
 
     protected function emailId(){
     protected function emailId(){
         return $this->email['id'];
         return $this->email['id'];
@@ -334,6 +348,25 @@ class SyncMail {
                 $p=1;
                 $p=1;
                 while (1){
                 while (1){
                     if($this->isStop) return $sync_number;
                     if($this->isStop) return $sync_number;
+
+                    if($this->isUid){
+                        $maxUid = $this->db->value(listsSql::first(dbWhere([
+                            'email_id'=>$this->emailId(),
+                            'folder_id'=>$folder_id,
+                        ]),'max(uid)'));
+                        $maxUid = $maxUid?$maxUid:0;
+                        if($this->isUid==1&&!$maxUid){
+                            return 0;
+                        }
+                        if($maxUid){
+                            $lists = $msg->uid(1)->get($maxUid.':*')->all();
+                            if($lists){
+                                $this->saveMail($folder_id,$lists,$isBody);
+                                return count($lists);
+                            }
+                        }
+                    }
+
                     // 是否搜索
                     // 是否搜索
                     if ($this->search instanceof ImapSearch){
                     if ($this->search instanceof ImapSearch){
                         $uids = $msg->search($this->search)->getUids();
                         $uids = $msg->search($this->search)->getUids();