预热邮件

@@ -35,6 +35,12 @@ class HotMailArchive {
     private function start(){
         _echo('启动预热邮件归档处理 '.getmypid());
 
+//         $fid = [235623,235628,235633,235638,235643,235648,235653,235658,235663,235668,235673,235678,235683,235688,235693,235698,235703,235708,235713,235718,235723,235728,235733,235738,235743,235748,235753,235758,235763,235768,235773,235778,235783,235788,235793,235798,235803,235808,235813,235818,235823,235828,235833,235838,235843,235848,235853,235858,235863,235868,235873,235878,235883,235888,235893,235898,235903,235908,235913,235918,235923,235928,235933,235938,235943,235948,235953,235958,235963,235968,235973,235978,235983,235988,235993,235998,236003,236008,236013,236018];
+//         foreach ($fid as $i){
+//             $this->move($i);
+//         }
+// return 0;
+
         $id = 0;
         while (1){
             $id = $this->run($id);
@@ -67,13 +73,11 @@ class HotMailArchive {
                 foreach ($list as $item){
                     try {
                         $ret = $this->db->throw()->insert('lists_hot',$item,false);
+                        if($ret){
+                            $this->db->delete(listsSql::$table,['id'=>$item['id']]);
+                        }
                     }catch (Throwable $e){
-                        $this->db->delete('lists_hot',['id'=>$item['id']]);
-                        unset($item['updated_at']);
-                        $ret = $this->db->throw()->insert('lists_hot',$item,false);
-                    }
-                    if($ret){
-                        $this->db->delete(listsSql::$table,['id'=>$item['id']]);
+                        $this->db->update('lists_hot',$item,dbWhere(['id'=>$item['id']]));
                     }
                 }
                 return true;