goodsnotices/app/Jobs/notice.php

<?php

namespace App\Jobs;

use App\helpers\apiRequest;
use App\helpers\FormType;
use App\Models\Good;
use App\Models\GoodsItem;
use Exception;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\DB;
use Throwable;

class notice implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public Client $client;

    /**
     * Create a new job instance.
     */
    public function __construct(public int $type, public mixed $data)
    {
        $this->goodsUrl = env('GOODS_URL');
    }

    public string $goodsUrl;

    /**
     * Execute the job.
     * @throws GuzzleException
     * @throws Throwable
     */
    public function handle(): void
    {
        switch ($this->type) {
            case 1:
                $this->addGoods();
                break;
            case 2:

            case 3:
                $this->changeProductState();
                break;
            case 4:
            case 5:
                $this->changePrice();
                break;
        }
    }

    /**
     * @throws GuzzleException
     * @throws Exception
     * @throws Throwable
     */
    public function addGoods(): void
    {
        $goods = $goodsItems = $noticeIds = [];
        $this->client = new Client();
        $apiToken = env('API_TOKEN');
        $now = date('Y-m-d H:i:s');
        $good = new Good();
        $goodsItem = new GoodsItem();
        $goodsIds = array_column(array_values($this->data), 'itemId');
        $existedIds = Good::query()->whereIn('itemid', $goodsIds)->select('itemid')->get()->toArray();
        $newIds = array_diff($goodsIds, $existedIds);
        if (!$newIds) {
            return;
        }

        foreach ($newIds as $id) {
            $item = $this->data[$id];
            $product = apiRequest::requests($this->client, $this->goodsUrl, [
                'token' => $apiToken,
                'itemId' => $item['result']['itemId'],
            ], FormType::json);
            if ($product['errCode'] != '0000') {
                throw new Exception('request item ' . $item['item_id'] . ' err:' . $product['desc'] ?? '');
            }
            $noticeIds[] = $item['notice_id'];
            $product = $product['data']['product'];
            $product['itemid'] = $product['itemId'];

            $good->fill($product);
            $goodsData = $good->toArray();
            $goodsData['created_at'] = $now;
            $goods[] = $goodsData;

            $product['item_id'] = $product['itemid'];
            $product['specifications'] = json_encode($product['specifications']);
            $goodsItem->fill($product);
            $itemData = $goodsItem->toArray();
            $itemData['created_at'] = $now;
            $goodsItems[] = $itemData;
        }
        try {
            DB::transaction(function () use ($goods, $goodsItems, $noticeIds) {
                if (!Good::insert($goods) || !GoodsItem::insert($goodsItems) || !\App\Models\Notice::query()->whereIn('notice_id', $noticeIds)->update(['state' => 3])) {
                    throw new Exception('insert failed');
                }
            });
        } catch (Throwable $throwable) {
            \App\Models\Notice::query()->whereIn('notice_id', $noticeIds)
                ->update(['err_message' => $throwable->getMessage()]);
            throw $throwable;
        }
    }

    /**
     * @throws Throwable
     */
    public function changeProductState(): void
    {
        $ids = $idss = [];
        foreach ($this->data as $item) {
            $idss[] = $item['notice_id'];
            $ids[$item['result']['state']][] = $item['result']['itemId'];
        }
        try {
            DB::transaction(function () use ($ids, $idss) {
                foreach ($ids as $state => $item) {
                    Good::query()->whereIn('itemid', $item)->update(['state' => $state]);
                }
                \App\Models\Notice::query()->whereIn('notice_id', $idss)
                    ->update(['state' => 3]);
            });
        } catch (Throwable $throwable) {
            \App\Models\Notice::query()->whereIn('notice_id', $idss)
                ->update(['err_message' => $throwable->getMessage()]);
            throw $throwable;
        }
    }

    /**
     * @throws Throwable
     */
    public function changePrice(): void
    {
        $updateData = array_column($this->data, 'result');
        $priceType = [4 => 'sell_price', 5 => 'settle_price'];
        $tablePriceType = [4 => 'market_price', 5 => 'settlement'];
        $updateData = array_map(function ($item) use ($priceType, $tablePriceType) {
            $item[$tablePriceType[$this->type]] = $item[$priceType[$this->type]];
            unset($item[$priceType[$this->type]]);
            return $item;
        }, $updateData);
        $ids = array_column($this->data, 'notice_id');
        try {
            DB::transaction(function () use ($updateData, $ids) {
                Good::updateBatch($updateData);
                \App\Models\Notice::query()->whereIn('notice_id', $ids)
                    ->update(['state' => 3]);
            });
        } catch (Throwable $throwable) {
            \App\Models\Notice::query()->whereIn('notice_id', $updateData)
                ->update(['err_message' => $throwable->getMessage()]);
            throw $throwable;
        }

    }
}