项目升级

@@ -3,7 +3,9 @@
 namespace App\Console\Commands\Update;
 namespace App\Console\Commands\Update;
 
 
 use App\Helper\Arr;
 use App\Helper\Arr;
+use App\Models\Blog\Blog;
 use App\Models\Com\UpdateLog;
 use App\Models\Com\UpdateLog;
+use App\Models\News\News;
 use App\Models\Product\Keyword;
 use App\Models\Product\Keyword;
 use App\Models\Product\Product;
 use App\Models\Product\Product;
 use App\Models\RouteMap\RouteMap;
 use App\Models\RouteMap\RouteMap;
@@ -140,6 +142,44 @@ class ProjectUpdate extends Command
                         }
                         }
                     }
                     }
                 }
                 }
+            } elseif ($api_type == 'news' || $api_type == 'blog') {
+                //产品
+                $url = $api_url . '?' . http_build_query(['w' => $api_type, 'page' => 1, 'pagesize' => 0]);
+                $data = http_get($url, ['charset' => 'UTF-8']);
+                if (isset($data['code']) && $data['code'] == 200) {
+                    $count = $data['data']['count'] ?? 0;
+
+                    $total_page = ceil($count / $page_size);
+                    for ($page = 1; $page <= $total_page; $page++) {
+                        $url_page = $api_url . '?' . http_build_query(['w' => $api_type, 'page' => $page, 'pagesize' => $page_size]);
+                        $data_page = http_get($url_page, ['charset' => 'UTF-8']);
+                        if (isset($data_page['code']) && $data_page['code'] == 200) {
+                            $items = $data_page['data']['data'] ?? [];
+
+                            if ($api_type == 'news') {
+                                $model = new News();
+                            } else {
+                                $model = new Blog();
+                            }
+
+                            foreach ($items as $item) {
+
+                                $news = $model->read(['name' => $item['ttile']], 'id');
+                                if (!$news) {
+                                    $id = $model->addReturnId([
+                                        'project_id' => $project_id,
+                                        'name' => $item['ttile'],
+                                        'text' => $item['content'],
+                                        'image' => $item['images'][0] ?? '',
+                                        'status' => $api_type == 'news' ? News::STATUS_ONE : Blog::STATUS_ONE
+                                    ]);
+                                    $route = RouteMap::setRoute($item['ttile'], $api_type == 'news' ? RouteMap::SOURCE_NEWS : RouteMap::SOURCE_BLOG, $id, $project_id);
+                                    $model->edit(['url' => $route], ['id' => $id]);
+                                }
+                            }
+                        }
+                    }
+                }
             }
             }
         }
         }
         //关闭数据库
         //关闭数据库