新车sku

2025-06-17 15:54:24 +08:00
parent 50e962c4aa
commit fee2241317
35 changed files with 2400 additions and 3 deletions
@@ -0,0 +1,192 @@
+<?php
+
+namespace app\console\service;
+
+use app\console\model\VehicleNewAttributesModel;
+use app\console\model\VehicleNewAttributeValuesModel;
+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 VehicleNewAttributesService extends BaseService
+{
+    /**
+     * 定义模型
+     *
+     * @return string
+     */
+    public function getModel(): string
+    {
+        return VehicleNewAttributesModel::class;
+    }
+
+    /**
+     * 多场景配置
+     */
+    public function queryScenes(): array
+    {
+        return [
+             'default' => function ($params) {
+                 return [
+                     'filters' => [
+                     ],
+                     'fields' => ['id','status'],
+                     'relations' => [
+                         'translation' => ['attributes_id', 'locale', 'attribute_name'],
+                         'value' => ['id', 'attribute_id', 'sort_order'],
+                         'value.translation' => ['id', 'values_id', 'locale', 'value_name'],
+                     ],
+                     'sorts' => [
+                         ['field' => 'created_at', 'direction' => 'desc']
+                     ],
+                     'pagination' => [
+                         'page' => $params['page'] ?? 1,
+                         'per_page' => $params['per_page'] ?? 10,
+                     ]
+                 ];
+             },
+             'show' => function ($params) {
+                 return [
+                     'filters' => [
+                         ['field'=>'id', 'operator'=>'=', 'value'=> $params['id']],
+                     ],
+                     'fields' => ['id', 'status'],
+                     'relations' => [
+                                                                                                                                                                                                                                                                                                                     'translation' => ['attributes_id', 'locale', 'attribute_name'],
+                         'value' => ['id', 'attribute_id', 'sort_order'],
+                         'value.translation' => ['id', 'values_id', 'locale', 'value_name'],
+                     ],
+                 ];
+             },
+        ];
+    }
+
+
+    // 声明需要多语言翻译
+    protected array $translatable = [
+        'attribute_name',
+    ];
+
+    public function add(array $params)
+    {
+        $sourceLocale  = locale();
+        $sourceFields  = $this->extractSourceFields($params);
+
+        if (empty($sourceFields)) {
+            throw new \InvalidArgumentException("请传递至少一条 {$sourceLocale} 语言的翻译字段");
+        };
+
+        $values = $params['value'];
+        unset($params['value']);
+        $VehicleNewAttributeValuesService = new VehicleNewAttributeValuesService(new VehicleNewAttributeValuesModel());
+        Db::beginTransaction();
+        try {
+            $info = $this->create($params);
+            if (!$info) {
+                throw new BusinessException('提交失败');
+            }
+
+            // 异步翻译并写入 hs_vehicle_data_translation 表
+            (new TranslationService())->queueTranslations(
+                'vehicleNewAttributes',
+                $info->id,
+                $sourceLocale,
+                $sourceFields
+            );
+
+            $valuesId = [];
+            foreach ($values as $value) {
+                $askedsourceFields  = $VehicleNewAttributeValuesService->extractSourceFields($value);
+                $value['attribute_id'] = $info->id;
+                $value_res = $VehicleNewAttributeValuesService->create($value);
+                if (!$value_res) {
+                    throw new BusinessException('提交失败');
+                }
+                (new TranslationService())->queueTranslations(
+                    'vehicleNewAttributeValues',
+                    $value_res->id,
+                    $sourceLocale,
+                    $askedsourceFields
+                );
+            }
+
+
+            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} 语言的翻译字段");
+        };
+
+        $values = $params['value'];
+        unset($params['value']);
+        $VehicleNewAttributeValuesService = new VehicleNewAttributeValuesService(new VehicleNewAttributeValuesModel());
+        Db::beginTransaction();
+        try {
+            $info = $this->update($id, $params);
+            if (!$info) {
+                throw new BusinessException('提交失败');
+            }
+
+            // 异步翻译并写入 hs_vehicle_data_translation 表
+            (new TranslationService())->queueTranslations(
+                'vehicleNewAttributes',
+                $id,
+                $sourceLocale,
+                $sourceFields
+            );
+
+
+            $valuesId = [];
+            foreach ($values as $value) {
+                $valuesourceFields  = $VehicleNewAttributeValuesService->extractSourceFields($value);
+                $value['attribute_id'] = $id;
+
+                if(!empty($value['id'])){
+                    $valueId = $value['id'];
+                    $valuesId[] = $valueId;
+                    $value_res = $VehicleNewAttributeValuesService->update($valueId, $value);
+                    if (!$value_res) {
+                        throw new BusinessException('提交失败:属性值');
+                    }
+                } else {
+                    unset($value['id']);
+                    $value_res = $VehicleNewAttributeValuesService->create($value);
+                    if (!$value_res) {
+                        throw new BusinessException('提交失败:属性值');
+                    }
+                    $valueId = $value_res->id;
+                    $valuesId[] = $valueId;
+                }
+
+                (new TranslationService())->queueTranslations(
+                    'vehicleNewAttributeValues',
+                    $valueId,
+                    $sourceLocale,
+                    $valuesourceFields
+                );
+            }
+            VehicleNewAttributeValuesModel::whereNotIn('id', $valuesId)->where('attribute_id',$id)->delete();
+
+
+            Db::commit();
+            return true;
+        } catch (\Throwable $th) {
+            Db::rollBack();
+            throw $th;
+        }
+    }
+}