预热脚本移入

@@ -6,28 +6,62 @@ include_once "../vendor/autoload.php";
  * 把lists表的is_hots字段为1的记录插入到list_hot表中 并删除list表中的这些记录
  */
 
-// 一个月以前的数据
-$one_month_ago = strtotime(date('Y-m-d', strtotime('-1 month')));
+// 进程管理器
+$pm = new \Swoole\Process\Manager();
+
+// 启动业务进程
+$pm->addBatch(10,function (\Swoole\Process\Pool $pool, int $worker_id){
+    if($worker_id == 0){
+        // 一个月以前的数据
+        $one_month_ago = strtotime(date('Y-m-d', strtotime('-1 month')));
 
 // 查询lists lists_hot
-$id = 389884523;
-while (true){
-    $data = db()->first("select * from lists where  id > {$id} and `is_hots` = 1 and `udate` < {$one_month_ago} limit 1;");
+        $id = redis()->rPop('lists_to_lists_hot');
+        if(!$id) {
+            $id = 389884523;
+        }else{
+            $id = redis()->rPush('lists_to_lists_hot', $id);
+        }
+        $limit = 100;
+        while (true){
+//            echo "正在查询 id {$id}\n";
+            $data = db()->all("select `id` from lists where  id > {$id} and `is_hots` = 1 and `udate` < {$one_month_ago} limit {$limit};");
+            if($data){
+                foreach ($data as $item) {
+                    $id = $item['id'];
+                    redis()->rPush('lists_to_lists_hot', $item['id']);
+                }
+            }else{
+                sleep(5);
+            }
+        }
+    }else{
+
+        // 迁移数据
+        while (true){
+            $id = redis()->lPop('lists_to_lists_hot');
+            if($id){
+                $data = db()->first("select * from lists where `id` = {$id} limit 1;");
                 if($data){
-        $id = $data['id'];
                     try {
                         db()->throw()->insert('lists_hot', $data);
                     } catch (\Exception $e) {
                         @file_put_contents('lists_to_lists_hot.data.error.log', json_encode($data)."\n", FILE_APPEND);
                     }
-        db()->delete('lists', ['id' => $data['id']]);
+                    db()->delete('lists', ['id' => $id]);
+
                     echo $id . " ok \n";
-//        break;
+                }
             }else{
-        sleep(5);
+                sleep(1);
+            }
+        }
+
+
     }
-}
+});
 
+$pm->start();