usedcar/app/applet/service/DraftsDataService.php

<?php

namespace app\applet\service;

use app\applet\model\DraftsAlbumModel;
use app\applet\model\DraftsDataModel;
use app\mzl\common\services\BaseService;
use app\mzl\modules\translation\service\TranslationService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Model;
use support\Db;
use support\exception\BusinessException;

class DraftsDataService extends BaseService
{
    /**
     * 定义模型
     *
     * @return string
     */
    public function getModel(): string
    {
        return DraftsDataModel::class;
    }

    /**
     * 多场景配置
     */
    public function queryScenes(): array
    {
        return [
            // 'default' => function ($params) {
            //     $keyword = $params['keyword'] ?? '';
            //     return [
            //         'filters' => [
            //             ['field' => '***', 'operator' => '=', 'value' => '***']
            //         ],
            //         'fields' => ['id'],
            //         'relations' => [],
            //         'custom' => function(Builder $q) use ($keyword) {
            //             // 示例
            //             if ($keyword) {
            //                 $q->where(function($q2) use($keyword) {
            //                     $q2->whereHas('***', function($q3) use($keyword) {
            //                         $q3->where('***', 'like', "%{$keyword}%");
            //                     })->orWhereHas('***', function($q4) use($keyword) {
            //                         $q4->where('***', 'like', "%{$keyword}%");
            //                     });
            //                 });
            //             }
            //         },
            //         'sorts' => [
            //             ['field' => 'created_at', 'direction' => 'desc']
            //         ],
            //         'pagination' => [
            //             'page' => $params['page'] ?? 1,
            //             'per_page' => $params['per_page'] ?? 10,
            //         ]
            //     ];
            // }
            'show' => function(array $params) {
                return [
                    'filters'       => [
                        ['field'=>'id', 'operator'=>'=', 'value'=> $params['id']],
                    ],
                    'fields'        => [
                        'id','vin','price','cover',
                        'type','energy','model','mileage','vehicle_age',
                        'views','is_hot','created_at','updated_at', 'brand', 'model', 'user_id', 'store_status', 'location'
                    ],
                    'relations'     => [
                        'translation' => ['vehicle_id', 'name','condition_desc'],
                        'brand.translation' => ['brand_id', 'name'],
                        'album'              => [
                            'id', 'vehicle_data_id', 'front_45_degree',
                            'front_left_45_degree', 'front_left_headlight',
                            'front_view', 'lower_front', 'wheel_hub',
                            'front_right_seat', 'right_lower_side',
                            'rear_right_taillight', 'rear_right_45_degree',
                            'lower_rear', 'trunk', 'left_lower_side',
                            'rear_seats', 'center_console', 'control_panel',
                            'gear_shift', 'car_key', 'steering_wheel',
                            'dashboard', 'odometer_reading',
                            'front_left_door_panel', 'front_left_door_function_area',
                            'front_left_seat', 'interior_ceiling'
                        ],
                        'user'      => ['realname', 'nickname'],
                        'types.translation'     => ['type_id', 'name'],
                        'energy.translation'    => ['energy_id', 'name'],
                        'models.translation'    => ['model_id', 'name'],
                        'user'      => ['nickname'],
                        'location.translation' => ['location_id', 'name']
                    ],
                    'sorts'      => [
                        ['field'=>'id','direction'=>'desc'],
                    ],
                    'pagination' => [
                        'page'     => $params['page']     ?? 1,
                        'per_page' => $params['per_page'] ?? 10,
                    ],
                ];
            },
        ];
    }

    // 声明需要多语言翻译
    protected array $translatable = [
        'name',
        'condition_desc',
        // 'location'
    ];

    /**
     * 从$data中提取出源文本字段，并从$data里删除它们
     */
    protected function extractSourceFields(array &$data): array
    {
        $source = [];
        foreach ($this->translatable as $field) {
            if (array_key_exists($field, $data)) {
                $source[$field] = $data[$field];
                unset($data[$field]);
            }
        }
        return $source;
    }

    public function add(array $params)
    {
        $sourceLocale  = locale();
        $sourceFields  = $this->extractSourceFields($params);
        if (empty($sourceFields)) {
            throw new \InvalidArgumentException("请传递至少一条 {$sourceLocale} 语言的翻译字段");
        };

        $albums = DraftsAlbumModel::VEHICLE_ALBUM_FIELDS;
        foreach ($params as $ko => $vo) {
            if (in_array($ko, $albums)) {
                $album[$ko] = $vo ?? '';
            } else {
                if (in_array($ko, DraftsDataModel::TRANS_FIELDS)) {
                    $trans[$ko] = $vo ?? '';
                } else {
                    $data[$ko] = $vo ?? '';
                }
            }
        }

        Db::beginTransaction();
        try {
            $info = $this->create($data);
            if (!$info) {
                throw new BusinessException('提交失败');
            }

            // 异步翻译并写入 hs_drafts_translation 表
            (new TranslationService())->queueTranslations(
                'drafts',
                $info->id,
                $sourceLocale,
                $sourceFields
            );

            $album['drafts_data_id'] = $info->id;
            $albumModel = new DraftsAlbumModel();
            if (!$albumModel->create($album)) {
                throw new BusinessException('保存失败');
            }

            Db::commit();
            return true;
        } catch (\Throwable $th) {
            Db::rollBack();
            throw $th;
        }
    }

    public function edit(array $params, int $id)
    {
        $sourceLocale  = locale();
        $sourceFields  = $this->extractSourceFields($params);
        if (empty($sourceFields)) {
            throw new \InvalidArgumentException("请传递至少一条 {$sourceLocale} 语言的翻译字段");
        };

        $album = [];
        $trans = [];
        $albums = DraftsAlbumModel::VEHICLE_ALBUM_FIELDS;
        foreach ($params as $ko => $vo) {
            if (in_array($ko, $albums)) {
                $album[$ko] = $vo ?? '';
            } else {
                if (in_array($ko, DraftsAlbumModel::TRANS_FIELDS)) {
                    $trans[$ko] = $vo ?? '';
                } else {
                    $data[$ko] = $vo ?? '';
                }
            }
        }

        Db::beginTransaction();
        try {
            $params['info_status'] = 0;
            $info = $this->update($id, $params);
            if (!$info) {
                throw new BusinessException('提交失败');
            }

            // 异步翻译并写入 hs_vehicle_data_translation 表
            (new TranslationService())->queueTranslations(
                'vehicle',
                $id,
                $sourceLocale,
                $sourceFields
            );

            if ($album) {
                // $album['vehicle_data_id'] = $info->id;
                $albumModel = new DraftsAlbumModel();
                if (!$albumModel->updateOrCreate(
                    ['vehicle_data_id' => $id],
                    $album
                )) {
                    throw new BusinessException('提交失败');
                }
            }

            Db::commit();
            return true;
        } catch (\Throwable $th) {
            Db::rollBack();
            throw $th;
        }
    }
}