luoshanxianjicengzhili/app/Jobs/Manage/MergeMessageJob.php

<?php

/*
 * This file is part of the ZhMead/laravel-logger.
 *
 * (c) Mead <751066209@qql.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */

namespace App\Jobs\Manage;

use App\Repositories\Enums\Manage\AnalysisStatusEnum;
use App\Repositories\Enums\Manage\DealStatusEnum;
use App\Repositories\Enums\ModelStatusEnum;
use App\Repositories\Models\Manage\Message;
use App\Repositories\Models\Manage\PreMessage;
use App\Repositories\Models\Manage\Task;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class MergeMessageJob implements ShouldQueue
{
    use InteractsWithQueue;
    use Queueable;

    private $ID;

    /**
     * Create a new job instance.
     */
    public function __construct($ID)
    {
        $this->ID = $ID;
    }

    /**
     * 确定任务应该超时的时间
     *
     * @return \DateTime
     */
    public function retryUntil()
    {
        return Carbon::now()->addHours(8);
    }

    /**
     * Execute the job.
     */
    public function handle()
    {
        $this->merge();
    }

    /**
     * 导入数据
     * @return false|void
     */
    public function merge()
    {
        $model = Task::query()->find($this->ID);

        $model->status = AnalysisStatusEnum::MERGE_IN;
        $model->save();

        DB::beginTransaction();
        try {
            Log::error('*************合并数据中*****************');
            $messages = PreMessage::query()
                ->where('task_id', $this->ID)
                ->where('status', ModelStatusEnum::OK)
                ->where('pid', '>', 0)
                ->where('is_check', 1)
                ->select(['id', 'message_id', 'pid'])->get()->groupBy('pid')->toArray();
            foreach ($messages as $message) {
                $message_ids = array_column($message, 'message_id');
                $message_main_id = PreMessage::query()->where('id', $message[0]['pid'])->value('message_id');

                $ids = array_merge($message_ids, [$message_main_id]);
                $message_main = Message::query()->whereIn('id', $ids)->where('deal_status', DealStatusEnum::OK)->orderBy('id')->first();
                if (!$message_main) {
                    //不存在处理
                    $message_main = Message::query()->whereIn('id', $message_main_id)->orderBy('id')->first();
//                    $message_main->similar_nums = count($message_ids);
//                    $message_main->save();
//
//                    Message::query()->whereIn('id', $message_ids)->update([
//                        'similar_pid' => $message_main_id,
//                        'deal_department_id' => $message_main['deal_department_id'],
//                        'deal_admin_id' => $message_main['deal_admin_id'],
//                        'deal_status' => $message_main['deal_status'],
//                        'deal_idea' => $message_main['deal_idea'],
//                        'deal_time' => $message_main['deal_time'],
//                    ]);
//                    continue;
                }

                $message_main->similar_nums = count($message_ids);
                $message_main->task_id = $model->id;
                $message_main->save();

                Message::query()->whereIn('id', $message_ids)->update([
                    'similar_pid' => $message_main_id,
                    'deal_department_id' => $message_main['deal_department_id'],
                    'deal_admin_id' => $message_main['deal_admin_id'],
                    'deal_status' => $message_main['deal_status'],
                    'deal_idea' => $message_main['deal_idea'],
                    'deal_time' => $message_main['deal_time'],
                    'task_id' => $model->id,
                ]);
            }

            DB::commit();
            $model->status = AnalysisStatusEnum::MERGE_OK;

        } catch (\Exception $exception) {
            DB::rollBack();
            Log::error($exception);
            $model->status = AnalysisStatusEnum::MERGE_ERROR;
            $model->message = $exception;
        }
        $model->save();
        Log::error("-----------完成---------------");
    }
}