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

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Models\Sentence;
use App\Models\PaliSentence;
use App\Models\Progress;
use App\Models\ProgressChapter;
use App\Models\PaliText;
use Illuminate\Support\Facades\Log;

class UpgradeProgress extends Command
{
    /**
     * The name and signature of the console command.
     * php artisan upgrade:progress --book=152 --channel=19f53a65-81db-4b7d-8144-ac33f1217d34
     * @var string
     */
    protected $signature = 'upgrade:progress {--book=} {--para=} {--channel=} {--resume}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Command description';

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

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        if (\App\Tools\Tools::isStop()) {
            return 0;
        }
        $this->info('upgrade:progress start');
        $startTime = time();
        $book = $this->option('book');
        $para = $this->option('para');
        $channelId = $this->option('channel');
        if ($channelId) {
            $this->line('channel=' . $channelId);
        }
        $table = Sentence::where('strlen', '>', 0);
        if ($book || $para || $channelId) {
            if ($book) {
                $table = $table->where('book_id', $book);
            }
            if ($para) {
                $table = $table->where('paragraph', $para);
            }
            if ($channelId) {
                $table = $table->where('channel_uid', $channelId);
            }
            $sentences = $table->groupby('book_id', 'paragraph', 'channel_uid')
                ->select('book_id', 'paragraph', 'channel_uid');
        } else {
            if ($this->option('resume')) {
                $sentences = Sentence::where('strlen', '>', 0)
                    ->whereBetween('book_id', [$book, 1000])
                    ->where('paragraph', '>=', $para)
                    ->whereNotNull('channel_uid')
                    ->groupby('book_id', 'paragraph', 'channel_uid')
                    ->select('book_id', 'paragraph', 'channel_uid');
            } else {
                $sentences = Sentence::where('strlen', '>', 0)
                    ->where('book_id', '<', 1000)
                    ->whereNotNull('channel_uid')
                    ->groupby('book_id', 'paragraph', 'channel_uid')
                    ->select('book_id', 'paragraph', 'channel_uid');
            }
        }
        $count = $sentences->count();
        $sentences = $sentences->cursor();
        $this->info('sentences:' . $count);
        #第二步 更新段落表
        foreach ($sentences as $sentence) {
            # 第二步 生成para progress 1,2,15,zh-tw
            # 计算此段落完成时间
            $finalAt = Sentence::where('strlen', '>', 0)
                ->where('book_id', $sentence->book_id)
                ->where('paragraph', $sentence->paragraph)
                ->where('channel_uid', $sentence->channel_uid)
                ->max('created_at');
            $updateAt = Sentence::where('strlen', '>', 0)
                ->where('book_id', $sentence->book_id)
                ->where('paragraph', $sentence->paragraph)
                ->where('channel_uid', $sentence->channel_uid)
                ->max('updated_at');
            # 查询每个段落的等效巴利语字符数
            $result_sent = Sentence::where('strlen', '>', 0)
                ->where('book_id', $sentence->book_id)
                ->where('paragraph', $sentence->paragraph)
                ->where('channel_uid', $sentence->channel_uid)
                ->select('word_start')
                ->get();
            if (count($result_sent) > 0) {
                #查询这些句子的总共等效巴利语字符数
                $para_strlen = 0;
                foreach ($result_sent as $sent) {
                    # code...
                    $para_strlen += PaliSentence::where('book', $sentence->book_id)
                        ->where('paragraph', $sentence->paragraph)
                        ->where('word_begin', $sent->word_start)
                        ->value('length');
                }
                $paraInfo = [
                    'book' => $sentence->book_id,
                    'para' => $sentence->paragraph,
                    'channel_id' => $sentence->channel_uid
                ];
                $paraData = [
                    'lang' => 'en',
                    'all_strlen' => $para_strlen,
                    'public_strlen' => $para_strlen,
                    'created_at' => $finalAt,
                    'updated_at' => $updateAt,
                ];
                //Log::debug('Progress updateOrInsert', ['para' => $paraInfo, 'data' => $paraData]);
                $this->info('Progress updateOrInsert' . json_encode($paraInfo));
                Progress::updateOrInsert($paraInfo, $paraData);
            }
        }

        $time = time() - $startTime;
        $this->info("upgrade progress finished in {$time}s");

        return 0;
    }
}