x

@@ -41,7 +41,7 @@ class HotMail {
     private function start(){
     private function start(){
         _echo('启动预热邮件处理 '.getmypid());
         _echo('启动预热邮件处理 '.getmypid());
 
 
-        if(redis()->add('hot_mail_sync',1,300)){
+        if(redis()->add('hot_mail_sync',1,60)){
             $fob = $this->getFobHotEmail();
             $fob = $this->getFobHotEmail();
 
 
             // 把黑格自己的也算进去
             // 把黑格自己的也算进去
@@ -62,35 +62,35 @@ class HotMail {
                 }catch (Throwable $e){}
                 }catch (Throwable $e){}
             }
             }
 
 
-            $maxId = $this->db->value("select `id` from `lists` order by `id` desc limit 1");
-            $id = 0;
-            while (1){
-                $ids = [];
-                for ($i=0;$i<1000;$i++){
-                    $ids[] = $i+$id;
-                }
-                $id = end($ids);
-
-                redis()->rPush('hot_check_ids',implode(',',$ids));
-
-                if($id>$maxId){
-                    break;
-                }
-            }
+//            $maxId = $this->db->value("select `id` from `lists` order by `id` desc limit 1");
+//            $id = 0;
+//            while (1){
+//                $ids = [];
+//                for ($i=0;$i<1000;$i++){
+//                    $ids[] = $i+$id;
+//                }
+//                $id = end($ids);
+//
+//                redis()->rPush('hot_check_ids',implode(',',$ids));
+//
+//                if($id>$maxId){
+//                    break;
+//                }
+//            }
 
 
         }
         }
 
 
 
 
-        while (1){
-            $ids = redis()->lPop('hot_check_ids');
-            if($ids){
-                $ids = explode(',',$ids);
-                $this->run($ids);
-            }else{
-                echo '等待'.PHP_EOL;
-                co::sleep(2);
-            }
-        }
+//        while (1){
+//            $ids = redis()->lPop('hot_check_ids');
+//            if($ids){
+//                $ids = explode(',',$ids);
+//                $this->run($ids);
+//            }else{
+//                echo '等待'.PHP_EOL;
+//                co::sleep(2);
+//            }
+//        }
 
 
 
 
 
 
@@ -173,7 +173,7 @@ swoole_set_process_name('hot-email-run-man');
 
 
 $pm = new Swoole\Process\Manager();
 $pm = new Swoole\Process\Manager();
 
 
-$pm->addBatch(10,function (){
+$pm->addBatch(1,function (){
 
 
     swoole_set_process_name('hot-email-run');
     swoole_set_process_name('hot-email-run');
 
 
@@ -181,7 +181,7 @@ $pm->addBatch(10,function (){
 
 
     new HotMail();
     new HotMail();
     // 执行完了暂停5分钟在执行
     // 执行完了暂停5分钟在执行
-    sleep(300);
+    sleep(120);
 },true);
 },true);
 
 
 $pm->start();
 $pm->start();