gx登录生成token

@@ -51,11 +51,12 @@ class GeneratePage extends Command
     {
     {
         $noticeModel = new NoticeLog();
         $noticeModel = new NoticeLog();
         while (true){
         while (true){
-            $noticeInfo = $noticeModel->read(['status'=>0,'type'=>$noticeModel::GENERATE_PAGE,'start_at'=>['<=',date('Y-m-d H:i:s')]]);
+            $task_id = $this->getTaskId();
             if (empty($noticeInfo)) {
             if (empty($noticeInfo)) {
                 sleep(10);
                 sleep(10);
                 continue;
                 continue;
             }
             }
+            $noticeInfo = $noticeModel->read(['id'=>$task_id]);
             try {
             try {
                 $this->output(' taskID: ' . $noticeInfo['id'] . ' start');
                 $this->output(' taskID: ' . $noticeInfo['id'] . ' start');
                 $notice_data = json_decode($noticeInfo['data'],true);
                 $notice_data = json_decode($noticeInfo['data'],true);
@@ -80,6 +81,28 @@ class GeneratePage extends Command
         return true;
         return true;
     }
     }
 
 
+    /**
+     * @remark :获取任务id
+     * @name   :getTaskId
+     * @author :lyh
+     * @method :post
+     * @time   :2025/6/19 10:02
+     */
+    public function getTaskId()
+    {
+        $task_id = Redis::rpop('generate_page_id');
+        if (empty($task_id)) {
+            $noticeModel = new NoticeLog();
+            $ids = $noticeModel->selectField(['status'=>0],'id');
+            if(!empty($ids)){
+                foreach ($ids as $id) {
+                    Redis::lpush('generate_page_id', $id);
+                }
+            }
+            $task_id = Redis::rpop('generate_page_id');
+        }
+        return $task_id;
+    }
 
 
     /**
     /**
      * 输出message
      * 输出message