项目升级

@@ -2,8 +2,10 @@
 
 
 namespace App\Console\Commands\Update;
 namespace App\Console\Commands\Update;
 
 
+use App\Helper\Arr;
 use App\Models\Com\UpdateLog;
 use App\Models\Com\UpdateLog;
 use App\Models\Product\Keyword;
 use App\Models\Product\Keyword;
+use App\Models\Product\Product;
 use App\Models\RouteMap\RouteMap;
 use App\Models\RouteMap\RouteMap;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
@@ -60,6 +62,8 @@ class ProjectUpdate extends Command
         $api_url_arr = explode('?', $task->api_url);
         $api_url_arr = explode('?', $task->api_url);
         $api_url = $api_url_arr[0];
         $api_url = $api_url_arr[0];
 
 
+        $page_size = 10;
+
         echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', task_type: ' . $api_type . ', update start' . PHP_EOL;
         echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', task_type: ' . $api_type . ', update start' . PHP_EOL;
 
 
         $task->status = UpdateLog::STATUS_ING;//同步中
         $task->status = UpdateLog::STATUS_ING;//同步中
@@ -69,27 +73,66 @@ class ProjectUpdate extends Command
         $project = ProjectServer::useProject($task->project_id);
         $project = ProjectServer::useProject($task->project_id);
         if ($project) {
         if ($project) {
             if ($api_type == 'website_info') {
             if ($api_type == 'website_info') {
+                //关键词
                 $url = $api_url . '?' . http_build_query(['w' => 'website_info']);
                 $url = $api_url . '?' . http_build_query(['w' => 'website_info']);
                 $data = http_get($url, ['charset' => 'UTF-8']);
                 $data = http_get($url, ['charset' => 'UTF-8']);
                 if (isset($data['code']) && $data['code'] == 200) {
                 if (isset($data['code']) && $data['code'] == 200) {
-                    $tags = $data['data']['tags'] ?? [];
+                    $items = $data['data']['tags'] ?? [];
 
 
                     $model = new Keyword();
                     $model = new Keyword();
-                    foreach ($tags as $tag) {
-                        if(strlen($tag) > 50){
+                    foreach ($items as $item) {
+                        if (strlen($item) > 50) {
                             continue;
                             continue;
                         }
                         }
-                        $keyword = $model->read(['title' => $tag], 'id');
+                        $keyword = $model->read(['title' => $item], 'id');
                         if (!$keyword) {
                         if (!$keyword) {
                             $id = $model->addReturnId([
                             $id = $model->addReturnId([
                                 'project_id' => $project_id,
                                 'project_id' => $project_id,
-                                'title' => $tag
+                                'title' => $item
                             ]);
                             ]);
-                            $route = RouteMap::setRoute($tag, RouteMap::SOURCE_PRODUCT_KEYWORD, $id, $project_id);
+                            $route = RouteMap::setRoute($item, RouteMap::SOURCE_PRODUCT_KEYWORD, $id, $project_id);
                             $model->edit(['route' => $route], ['id' => $id]);
                             $model->edit(['route' => $route], ['id' => $id]);
                         }
                         }
                     }
                     }
                 }
                 }
+            } elseif ($api_type == 'post') {
+                //产品
+                $url = $api_url . '?' . http_build_query(['w' => 'post', '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' => 'post', '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['data']['data'] ?? [];
+
+                            $model = new Product();
+
+                            foreach ($items as $item) {
+
+                                $product = $model->read(['title' => $item], 'id');
+                                if (!$product) {
+                                    $gallery = [];
+                                    foreach ($item['images'] as $k_img => $img) {
+                                        $gallery[] = ['alt' => '这是一张产品图', 'url' => $img];
+                                    }
+                                    $id = $model->addReturnId([
+                                        'project_id' => $project_id,
+                                        'title' => $item['ttile'],
+                                        'content' => $item['content'],
+                                        'thumb' => isset($gallery[0]) ? Arr::a2s($gallery[0]) : '',
+                                        'gallery' => Arr::a2s($gallery),
+                                    ]);
+                                    $route = RouteMap::setRoute($item['ttile'], RouteMap::SOURCE_PRODUCT, $id, $project_id);
+                                    $model->edit(['route' => $route], ['id' => $id]);
+                                }
+                            }
+                        }
+                    }
+                }
             }
             }
         }
         }
         //关闭数据库
         //关闭数据库