mint/api-v13/app/Console/Commands/ImportArticle.php

<?php

namespace App\Console\Commands;

use App\Http\Api\StudioApi;
use App\Models\Article;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Log;

class ImportArticle extends Command
{
    /**
     * The name and signature of the console command.
     * php artisan import:article --studio=visuddhinanda --anthology=eb9e3f7f-b942-4ca4-bd6f-b7876b59a523 --token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJuYmYiOjE2OTc3Mjg2ODUsImV4cCI6MTcyOTI2NDY4NSwidWlkIjoiYmE1NDYzZjMtNzJkMS00NDEwLTg1OGUtZWFkZDEwODg0NzEzIiwiaWQiOjR9.fiXhnY2LczZ9kKVHV0FfD3AJPZt-uqM5wrDe4EhToVexdd007ebPFYssZefmchfL0mx9nF0rgHSqjNhx4P0yDA
     *
     * @var string
     */
    protected $signature = 'import:article {--studio=} {--anthology=} {--token=}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '导入缅文tipitaka sarupa文章';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     * 分两个步骤导入
     * 1. 导入文章到文集
     * 2. 重新生成目录结构
     *
     * @return int
     */
    public function handle()
    {
        if (! $this->confirm('Do you wish to continue?')) {
            return 0;
        }
        $token = $this->option('token');
        $studioName = $this->option('studio');
        $anthologyId = $this->option('anthology');

        // 先获取文章列表，建立全部目录
        $head = [];
        $strFileName = __DIR__.'/tipitaka-sarupa.csv';
        if (! file_exists($strFileName)) {
            $this->error($strFileName.'文件不存在');

            return 1;
        }

        if (($fp = fopen($strFileName, 'r')) === false) {
            $this->error("can not open csv {$strFileName}");

            return 0;
        }
        $this->info('打开csv文件成功');

        $studioId = StudioApi::getIdByName($studioName);
        if (! $studioId) {
            $this->error("can not found studio name {$studioName}");

            return 0;
        }
        // 导入文章
        $url = config('app.url').'/api/v2/article';
        $inputRow = 0;
        fseek($fp, 0);
        $count = 0;
        $success = 0;
        $fail = 0;
        while (($data = fgetcsv($fp, 0, ',')) !== false) {
            if ($inputRow > 0) {
                $id = $data[0];
                $dir = $data[1];
                $title = $data[2];
                $realTitle = "[{$id}]{$title}";
                $content = str_replace('\n', "\n", $data[4]);
                $reference = str_replace(['(', ')'], ['({{ql|type=m|title=', '}})'], $data[5]);
                $contentCombine = "{$title}\n\n{$content}\n\n{$reference}";
                $percent = (int) ($inputRow * 100 / 7000);
                $this->info("[{$percent}%] doing ".$realTitle);
                // 先查是否有
                $hasArticle = Article::where('owner', $studioId)
                    ->where('title', $realTitle)
                    ->exists();
                if ($hasArticle) {
                    $this->error('文章已经存在 title='.$realTitle);

                    continue;
                }
                $count++;
                $this->info('新建 title='.$realTitle);
                sleep(2);
                $response = Http::withToken($token)->post($url,
                    [
                        'title' => $realTitle,
                        'lang' => 'my',
                        'studio' => $studioName,
                        'anthologyId' => $anthologyId,
                    ]);
                if ($response->ok()) {
                    $this->info('create ok');
                    $articleId = $response->json('data')['uid'];
                } else {
                    $this->error('create article fail.'.$realTitle);
                    Log::error('create article fail title='.$realTitle);
                    $fail++;

                    continue;
                }
                sleep(2);
                $this->info('修改 id='.$articleId);
                $response = Http::withToken($token)->put($url.'/'.$articleId,
                    [
                        'title' => $realTitle,
                        'summary' => $title.'#'.$id,
                        'lang' => 'my',
                        'content' => $contentCombine,
                        'anthology_id' => $anthologyId,
                        'to_tpl' => true,
                        'status' => 30,
                    ]);

                if ($response->ok()) {
                    $this->info('edit ok');
                    $success++;
                } else {
                    $this->error('edit article fail');
                    Log::error('edit article fail ', ['id' => $articleId, 'title' => $realTitle]);
                    $fail++;
                }
            }
            $inputRow++;
        }

        fclose($fp);

        $this->info('成功='.$success.' 失败='.$fail);

        return 0;
    }
}