gxAiblog自动发布

@@ -50,15 +50,41 @@ class lyhDemo extends Command
     protected $description = '更新路由';
 
     public function handle(){
-//        $projectModel = new Project();
-//        $lists = $projectModel->list(['delete_status' => 0,'extend_type'=>0,'type'=>['in',[1,2,3,4,6]]], 'id', ['id']);
-//        foreach ($lists as $val) {
-//            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $val['id'] . PHP_EOL;
-//            ProjectServer::useProject($val['id']);
-//            DB::disconnect('custom_mysql');
-//            echo date('Y-m-d H:i:s') . '结束--项目的id:'. $val['id'] . PHP_EOL;
-//        }
-        $this->_action();
+        $projectModel = new Project();
+        $lists = $projectModel->list(['delete_status' => 0,'extend_type'=>0,'type'=>['in',[1,2,3,4,6]]], 'id', ['id']);
+        foreach ($lists as $val) {
+            $aiSettingInfo = $this->getSetting($val['id']);
+            if($aiSettingInfo === false){
+                echo '当前项目未注册。'.$val['id'].PHP_EOL;
+                continue;
+            }
+            $aiBlogTaskModel = new AiBlogTask();
+            $blog_lists = $aiBlogTaskModel->list(['type'=>2,'status'=>2,'project_id'=>$val['id']]);
+            echo date('Y-m-d H:i:s') . '开始--项目的id:'. $val['id'] . PHP_EOL;
+            ProjectServer::useProject($val['id']);
+            $aiBlogService = new AiBlogService($val['id']);
+            foreach ($blog_lists as $item) {
+                echo date('Y-m-d H:i:s') . '开始--项目的id:' . $item['project_id'] . PHP_EOL;
+                $aiBlogModel = new AiBlog();
+                $aiBlogInfo = $aiBlogModel->read(['task_id' => $item['task_id']], ['id']);
+                if ($aiBlogInfo === false) {
+                    continue;
+                }
+                try {
+                    $aiBlogService->task_id = $item['task_id'];
+                    //拉取文章数据
+                    $result = $aiBlogService->getDetail();
+                    if (isset($result) && ($result['status'] == 200)) {
+                        $aiBlogModel->edit(['seo_description' => $result['data']['description']], ['task_id' => $item['task_id']]);
+                    }
+                } catch (\Exception $e) {
+                    echo '跳过。' . PHP_EOL;
+                    continue;
+                }
+            }
+            DB::disconnect('custom_mysql');
+            echo date('Y-m-d H:i:s') . '结束--项目的id:'. $val['id'] . PHP_EOL;
+        }
         return true;
     }