feat: 新增产品兼容数据、产品兼容数据配件类型相关接口

LICENSE

@@ -1,208 +0,0 @@
-Apache License
-
-Version 2.0, January 2004
-
-http://www.apache.org/licenses/ TERMS AND CONDITIONS FOR USE, REPRODUCTION,
-AND DISTRIBUTION
-
-   1. Definitions.
-
-      
-
-"License" shall mean the terms and conditions for use, reproduction, and distribution
-as defined by Sections 1 through 9 of this document.
-
-      
-
-"Licensor" shall mean the copyright owner or entity authorized by the copyright
-owner that is granting the License.
-
-      
-
-"Legal Entity" shall mean the union of the acting entity and all other entities
-that control, are controlled by, or are under common control with that entity.
-For the purposes of this definition, "control" means (i) the power, direct
-or indirect, to cause the direction or management of such entity, whether
-by contract or otherwise, or (ii) ownership of fifty percent (50%) or more
-of the outstanding shares, or (iii) beneficial ownership of such entity.
-
-      
-
-"You" (or "Your") shall mean an individual or Legal Entity exercising permissions
-granted by this License.
-
-      
-
-"Source" form shall mean the preferred form for making modifications, including
-but not limited to software source code, documentation source, and configuration
-files.
-
-      
-
-"Object" form shall mean any form resulting from mechanical transformation
-or translation of a Source form, including but not limited to compiled object
-code, generated documentation, and conversions to other media types.
-
-      
-
-"Work" shall mean the work of authorship, whether in Source or Object form,
-made available under the License, as indicated by a copyright notice that
-is included in or attached to the work (an example is provided in the Appendix
-below).
-
-      
-
-"Derivative Works" shall mean any work, whether in Source or Object form,
-that is based on (or derived from) the Work and for which the editorial revisions,
-annotations, elaborations, or other modifications represent, as a whole, an
-original work of authorship. For the purposes of this License, Derivative
-Works shall not include works that remain separable from, or merely link (or
-bind by name) to the interfaces of, the Work and Derivative Works thereof.
-
-      
-
-"Contribution" shall mean any work of authorship, including the original version
-of the Work and any modifications or additions to that Work or Derivative
-Works thereof, that is intentionally submitted to Licensor for inclusion in
-the Work by the copyright owner or by an individual or Legal Entity authorized
-to submit on behalf of the copyright owner. For the purposes of this definition,
-"submitted" means any form of electronic, verbal, or written communication
-sent to the Licensor or its representatives, including but not limited to
-communication on electronic mailing lists, source code control systems, and
-issue tracking systems that are managed by, or on behalf of, the Licensor
-for the purpose of discussing and improving the Work, but excluding communication
-that is conspicuously marked or otherwise designated in writing by the copyright
-owner as "Not a Contribution."
-
-      
-
-"Contributor" shall mean Licensor and any individual or Legal Entity on behalf
-of whom a Contribution has been received by Licensor and subsequently incorporated
-within the Work.
-
-2. Grant of Copyright License. Subject to the terms and conditions of this
-License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive,
-no-charge, royalty-free, irrevocable copyright license to reproduce, prepare
-Derivative Works of, publicly display, publicly perform, sublicense, and distribute
-the Work and such Derivative Works in Source or Object form.
-
-3. Grant of Patent License. Subject to the terms and conditions of this License,
-each Contributor hereby grants to You a perpetual, worldwide, non-exclusive,
-no-charge, royalty-free, irrevocable (except as stated in this section) patent
-license to make, have made, use, offer to sell, sell, import, and otherwise
-transfer the Work, where such license applies only to those patent claims
-licensable by such Contributor that are necessarily infringed by their Contribution(s)
-alone or by combination of their Contribution(s) with the Work to which such
-Contribution(s) was submitted. If You institute patent litigation against
-any entity (including a cross-claim or counterclaim in a lawsuit) alleging
-that the Work or a Contribution incorporated within the Work constitutes direct
-or contributory patent infringement, then any patent licenses granted to You
-under this License for that Work shall terminate as of the date such litigation
-is filed.
-
-4. Redistribution. You may reproduce and distribute copies of the Work or
-Derivative Works thereof in any medium, with or without modifications, and
-in Source or Object form, provided that You meet the following conditions:
-
-(a) You must give any other recipients of the Work or Derivative Works a copy
-of this License; and
-
-(b) You must cause any modified files to carry prominent notices stating that
-You changed the files; and
-
-(c) You must retain, in the Source form of any Derivative Works that You distribute,
-all copyright, patent, trademark, and attribution notices from the Source
-form of the Work, excluding those notices that do not pertain to any part
-of the Derivative Works; and
-
-(d) If the Work includes a "NOTICE" text file as part of its distribution,
-then any Derivative Works that You distribute must include a readable copy
-of the attribution notices contained within such NOTICE file, excluding those
-notices that do not pertain to any part of the Derivative Works, in at least
-one of the following places: within a NOTICE text file distributed as part
-of the Derivative Works; within the Source form or documentation, if provided
-along with the Derivative Works; or, within a display generated by the Derivative
-Works, if and wherever such third-party notices normally appear. The contents
-of the NOTICE file are for informational purposes only and do not modify the
-License. You may add Your own attribution notices within Derivative Works
-that You distribute, alongside or as an addendum to the NOTICE text from the
-Work, provided that such additional attribution notices cannot be construed
-as modifying the License.
-
-You may add Your own copyright statement to Your modifications and may provide
-additional or different license terms and conditions for use, reproduction,
-or distribution of Your modifications, or for any such Derivative Works as
-a whole, provided Your use, reproduction, and distribution of the Work otherwise
-complies with the conditions stated in this License.
-
-5. Submission of Contributions. Unless You explicitly state otherwise, any
-Contribution intentionally submitted for inclusion in the Work by You to the
-Licensor shall be under the terms and conditions of this License, without
-any additional terms or conditions. Notwithstanding the above, nothing herein
-shall supersede or modify the terms of any separate license agreement you
-may have executed with Licensor regarding such Contributions.
-
-6. Trademarks. This License does not grant permission to use the trade names,
-trademarks, service marks, or product names of the Licensor, except as required
-for reasonable and customary use in describing the origin of the Work and
-reproducing the content of the NOTICE file.
-
-7. Disclaimer of Warranty. Unless required by applicable law or agreed to
-in writing, Licensor provides the Work (and each Contributor provides its
-Contributions) on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied, including, without limitation, any warranties
-or conditions of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR
-A PARTICULAR PURPOSE. You are solely responsible for determining the appropriateness
-of using or redistributing the Work and assume any risks associated with Your
-exercise of permissions under this License.
-
-8. Limitation of Liability. In no event and under no legal theory, whether
-in tort (including negligence), contract, or otherwise, unless required by
-applicable law (such as deliberate and grossly negligent acts) or agreed to
-in writing, shall any Contributor be liable to You for damages, including
-any direct, indirect, special, incidental, or consequential damages of any
-character arising as a result of this License or out of the use or inability
-to use the Work (including but not limited to damages for loss of goodwill,
-work stoppage, computer failure or malfunction, or any and all other commercial
-damages or losses), even if such Contributor has been advised of the possibility
-of such damages.
-
-9. Accepting Warranty or Additional Liability. While redistributing the Work
-or Derivative Works thereof, You may choose to offer, and charge a fee for,
-acceptance of support, warranty, indemnity, or other liability obligations
-and/or rights consistent with this License. However, in accepting such obligations,
-You may act only on Your own behalf and on Your sole responsibility, not on
-behalf of any other Contributor, and only if You agree to indemnify, defend,
-and hold each Contributor harmless for any liability incurred by, or claims
-asserted against, such Contributor by reason of your accepting any such warranty
-or additional liability. END OF TERMS AND CONDITIONS
-
-APPENDIX: How to apply the Apache License to your work.
-
-To apply the Apache License to your work, attach the following boilerplate
-notice, with the fields enclosed by brackets "[]" replaced with your own identifying
-information. (Don't include the brackets!) The text should be enclosed in
-the appropriate comment syntax for the file format. We also recommend that
-a file or class name and description of purpose be included on the same "printed
-page" as the copyright notice for easier identification within third-party
-archives.
-
-Copyright [yyyy] [name of copyright owner]
-
-Licensed under the Apache License, Version 2.0 (the "License");
-
-you may not use this file except in compliance with the License.
-
-You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-
-distributed under the License is distributed on an "AS IS" BASIS,
-
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-
-See the License for the specific language governing permissions and
-
-limitations under the License.

app/admin/common.php

@@ -9,9 +9,13 @@ if (!function_exists('xlsx_reader')) {
      * @param array $keys_map 列 -> 键 例：['A' => 'name', 'B' => 'age', 'C' => 'sex']
      * @return array
      */
-    function xlsx_reader(string $file, int $initial_row = 1, array $keys_map = []): array
+    function xlsx_reader(string $file, int $initial_row = 1, array $keys_map = [], bool $read_only = false): array
     {
         $reader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx');
+        if ($read_only) {
+            // 只读模式，不读取公式，样式等等，减少内存消耗
+            $reader->setReadDataOnly(true);
+        }
 
         // 读取文件
         $spreadsheet = $reader->load($file);
@@ -42,6 +46,54 @@ if (!function_exists('xlsx_reader')) {
     }
 }
 
+if (!function_exists('xlsx_stream_reader')) {
+    /**
+     * 读取Excel数据
+     * @param string $file Excel文件路径
+     * @param int $initial_row 初始行
+     * @param array $keys_map 列 -> 键 例：['A' => 'name', 'B' => 'age', 'C' => 'sex']
+     * @return Generator
+     */
+    function xlsx_stream_reader(string $file, int $initial_row = 1, array $keys_map = [], bool $read_only = false): Generator
+    {
+        $reader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx');
+        if ($read_only) {
+            // 只读模式，不读取公式，样式等等，减少内存消耗
+            $reader->setReadDataOnly(true);
+        }
+
+        // 读取文件
+        $spreadsheet = $reader->load($file);
+
+        // 获取活动sheet
+        $sheet = $spreadsheet->getActiveSheet();
+
+        // 获取最大行
+        $max_row = $sheet->getHighestRow();
+
+        // 获取最大列
+        $max_col = $sheet->getHighestColumn();
+
+        $xlsx_row = [];
+        $first_col = ord('A');
+        $last_col  = ord($max_col);
+        for ($row = $initial_row; $row <= $max_row; $row++) {
+            for ($col = $first_col; $col <= $last_col; $col++) {
+                $key = $col_chr = chr($col);
+                if (!empty($keys_map)) {
+                    $key = $keys_map[$col_chr] ?? $col_chr;
+                }
+                $xlsx_row[$key] = $sheet->getCell($col_chr . $row)->getValue();
+            }
+            yield $xlsx_row;
+        }
+
+        // 主动销毁对象以释放内存
+        $spreadsheet->disconnectWorksheets();
+        unset($spreadsheet);
+    }
+}
+
 if (!function_exists('xlsx_writer')) {
     /**
      * 构建Excel数据

app/admin/controller/v1/ProductCompat.php

@@ -0,0 +1,312 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\controller\v1;
+
+use app\admin\model\v1\ProductCompatModel;
+use app\admin\model\v1\ProductCompatPartsModel;
+use app\admin\validate\v1\ProductCompatValidate;
+
+class ProductCompat
+{
+    /**
+     * 产品兼容性数据列表
+     */
+    public function index()
+    {
+        $params = request()->param([
+            'label_name',
+            'model',
+            'page/d' => 1,
+            'size/d' => 10
+        ]);
+
+        $list = ProductCompatModel::withoutField([
+                'language_id',
+                'deleted_at'
+            ])
+            ->with(['parts' => function ($query) {
+                $query->field(['id', 'name']);
+            }])
+            ->language(request()->lang_id)
+            ->withSearch(['label_name', 'model'], [
+                'label_name' => $params['label_name'] ?? null,
+                'model'      => $params['model'] ?? null,
+            ])
+            ->order(['updated_at' => 'desc'])
+            ->paginate([
+                'list_rows' => $params['size'],
+                'page'      => $params['page'],
+            ])
+            ?->bindAttr('parts', ['part_name' => 'name'])
+            ?->hidden(['parts']);
+
+        return success("获取成功", $list);
+    }
+
+    /**
+     * 导入产品兼容性数据
+     */
+    public function import()
+    {
+        // 获取上传文件
+        $file = request()->file('file');
+        if (empty($file)) {
+            return error('请上传文件');
+        }
+        $lang_id = request()->lang_id;
+
+        // 读取文件
+        $keys_map = [
+            'A' => 'label_name',
+            'B' => 'part_name',
+            'C' => 'brand_name',
+            'D' => 'level_name',
+            'E' => 'class_name',
+            'F' => 'series_name',
+            'G' => 'model',
+            'H' => 'capacity',
+            'I' => 'interface_type',
+            'J' => 'compat_status',
+        ];
+
+        $chunk       = 500; // 每批次处理的条数
+        $items       = 0;   // 已处理的条数
+        $xlsx_data   = [];
+        $xlsx_reader = xlsx_stream_reader($file->getRealPath(), 2, $keys_map, true);
+
+        \think\facade\Db::startTrans();
+        try {
+            foreach ($xlsx_reader as $row) {
+                $items++;
+                $row['seq_no'] = $items; // 记录行序号，防止后续顺序打乱
+                $xlsx_data[]   = $row;
+                if ($items % $chunk == 0) {
+                    // 每500条，为一批次进行处理
+                    $this->handleImport($xlsx_data, $lang_id);
+                    $xlsx_data = [];
+                }
+            }
+
+            if (!empty($xlsx_data)) {
+                // 处理剩余的
+                $this->handleImport($xlsx_data, $lang_id);
+            }
+        } catch (\Throwable $th) {
+            \think\facade\Db::rollback();
+            return error($th->getMessage());
+        }
+        \think\facade\Db::commit();
+
+        return success('操作成功');
+    }
+    private function handleImport(array $xlsx_data, int $lang_id): void
+    {
+        $compat_datas = $this->matchExistCompatData($xlsx_data, $lang_id);
+
+        // 校验数据并组装sql语句
+        $raw_sql = $this->validateAndBuildSql($compat_datas);
+        if (false === \think\facade\Db::execute($raw_sql)) {
+            throw new \Exception(sprintf('第【%s】行执行导入 SQL 失败', implode(',', array_column($xlsx_data, 'seq_no'))));
+        }
+    }
+    private function matchExistCompatData(array $datas, int $lang_id)
+    {
+        $models     = array_column($datas, 'model');
+        $compat_map = ProductCompatModel::language($lang_id)
+            ->modelName($models)
+            ->column('id', 'model');
+
+        $part_names = array_unique(array_column($datas, 'part_name'));
+        $part_map   = ProductCompatPartsModel::language($lang_id)
+            ->partName($part_names)
+            ->column('id', 'name');
+
+        // 匹配已存在数据的主键、配件id
+        foreach ($datas as &$d) {
+            $d['id']          = $compat_map[$d['model']] ?? null;
+            $d['language_id'] = $lang_id;
+            $d['part_id']     = $part_map[$d['part_name']] ?? 0;
+        }
+        unset($d);
+
+        return $datas;
+    }
+    private function validateAndBuildSql(array $compat_datas)
+    {
+        $sql_values = [];
+        $validate   = new ProductCompatValidate;
+        foreach ($compat_datas as $compat) {
+            // 校验数据
+            $scene  = is_null($compat['id']) ? 'add' : 'edit';
+            if (!$validate->scene($scene)->check($compat)) {
+                throw new \Exception(sprintf('第【%s】行%s', $compat['seq_no'], $validate->getError()));
+            }
+
+            // 组装 sql values
+            $sql_values[] = $this->buildSqlValue($compat);
+        }
+
+        return $this->buildRawSql($sql_values);
+    }
+    private function buildSqlValue(array $compat)
+    {
+        $pdo = \think\facade\Db::connect()->getPdo();
+        return sprintf(
+            '(%d, %d, %d, %s, %s, %s, %s, %s, %s, %s, %s, %s)',
+            $compat['id'],
+            $compat['language_id'],
+            $compat['part_id'],
+            is_string($compat['label_name']) ? $pdo->quote($compat['label_name']) : $compat['label_name'],
+            is_string($compat['brand_name']) ? $pdo->quote($compat['brand_name']) : $compat['brand_name'],
+            is_string($compat['level_name']) ? $pdo->quote($compat['level_name']) : $compat['level_name'],
+            is_string($compat['class_name']) ? $pdo->quote($compat['class_name']) : $compat['class_name'],
+            is_string($compat['series_name']) ? $pdo->quote($compat['series_name']) : $compat['series_name'],
+            is_string($compat['model']) ? $pdo->quote($compat['model']) : $compat['model'],
+            is_string($compat['capacity']) ? $pdo->quote($compat['capacity']) : $compat['capacity'],
+            is_string($compat['interface_type']) ? $pdo->quote($compat['interface_type']) : $compat['interface_type'],
+            is_string($compat['compat_status']) ? $pdo->quote($compat['compat_status']) : $compat['compat_status']
+        );
+    }
+    private function buildRawSql(array $values)
+    {
+        return sprintf(
+            'INSERT INTO %s (
+                `id`,
+                `language_id`,
+                `part_id`,
+                `label_name`,
+                `brand_name`,
+                `level_name`,
+                `class_name`,
+                `series_name`,
+                `model`,
+                `capacity`,
+                `interface_type`,
+                `compat_status`
+            ) VALUES %s
+            ON DUPLICATE KEY UPDATE
+                `part_id`        = VALUES(`part_id`),
+                `label_name`     = VALUES(`label_name`),
+                `brand_name`     = VALUES(`brand_name`),
+                `level_name`     = VALUES(`level_name`),
+                `class_name`     = VALUES(`class_name`),
+                `series_name`    = VALUES(`series_name`),
+                `model`          = VALUES(`model`),
+                `capacity`       = VALUES(`capacity`),
+                `interface_type` = VALUES(`interface_type`),
+                `compat_status`  = VALUES(`compat_status`)
+            ',
+            (new ProductCompatModel)->getTable(),
+            implode(',', $values)
+        );
+    }
+
+    /**
+     * 产品兼容性数据添加
+     */
+    public function save()
+    {
+        $post = request()->post([
+            'part_id',
+            'label_name',
+            'brand_name',
+            'level_name',
+            'class_name',
+            'series_name',
+            'model',
+            'capacity',
+            'interface_type',
+            'compat_status',
+            'sort',
+            'disabled'
+        ]);
+        $data = array_merge($post, ['language_id' => request()->lang_id]);
+
+        // 校验输入
+        $validate = new ProductCompatValidate;
+        if (!$validate->scene('add')->check($data)) {
+            return error($validate->getError());
+        }
+
+        $compat = ProductCompatModel::create($data);
+        if ($compat->isEmpty()) {
+            return error('操作失败');
+        }
+
+        return success('操作成功');
+    }
+
+    /**
+     * 产品兼容性数据详细
+     */
+    public function read()
+    {
+        $id   = request()->param('id');
+        $data = ProductCompatModel::withoutField(['language_id', 'deleted_at'])
+            ->bypk($id)
+            ->find();
+        if (empty($data)) {
+            return error('获取失败');
+        }
+
+        return success("获取成功", $data);
+    }
+
+    /**
+     * 产品兼容性数据更新
+     */
+    public function update()
+    {
+        $id  = request()->param('id');
+        $put = request()->put([
+            'part_id',
+            'label_name',
+            'brand_name',
+            'level_name',
+            'class_name',
+            'series_name',
+            'model',
+            'capacity',
+            'interface_type',
+            'compat_status',
+            'sort',
+            'disabled'
+        ]);
+        $data = array_merge($put, ['id' => $id, 'language_id' => request()->lang_id]);
+
+        // 校验输入
+        $validate = new ProductCompatValidate;
+        if (!$validate->scene('edit')->check($data)) {
+            return error($validate->getError());
+        }
+
+        $compat = ProductCompatModel::bypk($id)->find();
+        if (empty($compat)) {
+            return error('请确认操作对象是否正确');
+        }
+        if (!$compat->save($data)) {
+            return error('操作失败');
+        }
+
+        return success('操作成功');
+    }
+
+    /**
+     * 产品兼容性数据删除
+     */
+    public function delete()
+    {
+        $id   = request()->param('id');
+        $data = ProductCompatModel::bypk($id)->find();
+        if (empty($data)) {
+            return error("请确认操作对象是否正确");
+        }
+
+        if (!$data->delete()) {
+            return error("操作失败");
+        }
+
+        return success("操作成功");
+    }
+}

app/admin/controller/v1/ProductCompatParts.php

@@ -0,0 +1,133 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\controller\v1;
+
+use app\admin\model\v1\ProductCompatPartsModel;
+use app\admin\validate\v1\ProductCompatPartsValidate;
+use think\Request;
+
+class ProductCompatParts
+{
+    /**
+     * 兼容配件列表
+     */
+    public function index()
+    {
+        $params = request()->param([
+            'name',
+            'page/d' => 1,
+            'size/d' => 10
+        ]);
+
+        $list = ProductCompatPartsModel::withoutField([
+                'language_id',
+                'deleted_at'
+            ])
+            ->language(request()->lang_id)
+            ->withSearch('name', [
+                'name' => $params['name']??null
+            ])
+            ->order(['id' => 'desc'])
+            ->paginate([
+                'list_rows' => $params['size'],
+                'page'      => $params['page'],
+            ]);
+
+        return success('获取成功', $list);
+    }
+
+    /**
+     * 添加兼容配件
+     */
+    public function save()
+    {
+        $post = request()->post([
+            'name',
+            'sort',
+            'disabled'
+        ]);
+        $data = array_merge($post, ['language_id' => request()->lang_id]);
+
+        // 校验输入
+        $validate = new ProductCompatPartsValidate;
+        if (!$validate->scene('add')->check($data)) {
+            return error($validate->getError());
+        }
+
+        $parts = ProductCompatPartsModel::create($data);
+        if ($parts->isEmpty()) {
+            return error('操作失败');
+        }
+
+        return success('操作成功');
+    }
+
+    /**
+     * 兼容配件详细
+     */
+    public function read()
+    {
+        $id = request()->param('id');
+
+        $parts = ProductCompatPartsModel::withoutField([
+                'language_id',
+                'deleted_at'
+            ])
+            ->bypk($id)
+            ->find();
+        if (empty($parts)) {
+            return error('获取失败');
+        }
+
+        return success('获取成功', $parts);
+    }
+
+    /**
+     * 兼容配件更新
+     */
+    public function update()
+    {
+        $id  = request()->param('id');
+        $put = request()->put([
+            'name',
+            'sort',
+            'disabled'
+        ]);
+        $data = array_merge($put, ['id' => $id, 'language_id' => request()->lang_id]);
+
+        $validate = new ProductCompatPartsValidate;
+        if (!$validate->scene('edit')->check($data)) {
+            return error($validate->getError());
+        }
+
+        $parts = ProductCompatPartsModel::bypk($id)->find();
+        if (empty($parts)) {
+            return error('请确认操作对象是否正确');
+        }
+
+        if (!$parts->save($put)) {
+            return error('操作失败');
+        }
+
+        return success('操作成功');
+    }
+
+    /**
+     * 兼容配件删除
+     */
+    public function delete()
+    {
+        $id    = request()->param('id');
+        $parts = ProductCompatPartsModel::bypk($id)->find();
+        if (empty($parts)) {
+            return error('请确认操作对象是否正确');
+        }
+
+        if (!$parts->delete()) {
+            return error("操作失败");
+        }
+
+        return success("操作成功");
+    }
+}

app/admin/controller/v1/VideoCategory.php

@@ -151,7 +151,7 @@ class VideoCategory
 
         $validate = new VideoCategoryValidate;
         if (!$validate->scene('sort')->check(['id' => $id,'sort' => $sort])) {
-            return error($validate::getError());
+            return error($validate->getError());
         }
 
         $category = VideoCategoryModel::bypk($id)->find();

app/admin/model/v1/ProductCompatModel.php

@@ -0,0 +1,55 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model\v1;
+
+use app\common\model\ProductCompatBaseModel;
+use think\model\concern\SoftDelete;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatModel extends ProductCompatBaseModel
+{
+    // 启用软件删除
+    use SoftDelete;
+    // 软件删除时间字段
+    protected $deleteTime = 'deleted_at';
+
+    // 关联配件类型
+    public function parts()
+    {
+        return $this->hasOne(ProductCompatPartsModel::class, 'id', 'part_id');
+    }
+
+    // 按所属语言查询
+    public function scopeLanguage(\think\db\Query $query, int $value)
+    {
+        $query->where('language_id', $value);
+    }
+
+    // 按型号查询
+    public function scopeModelName(\think\db\Query $query, string|array $value)
+    {
+        if (is_array($value)) {
+            $query->where('model', 'in', $value);
+            return;
+        }
+
+        $query->where('model', '=', $value);
+    }
+
+    // 按标签名称搜索
+    public function searchLabelNameAttr(\think\db\Query $query, string|null $value, array $data)
+    {
+        if (is_null($value)) return;
+        $query->where('label_name', 'like', '%' . $value . '%');
+    }
+
+    // 按型号搜索
+    public function searchModelAttr(\think\db\Query $query, string|null $value, array $data)
+    {
+        if (is_null($value)) return;
+        $query->where('model', 'like', '%' . $value . '%');
+    }
+}

app/admin/model/v1/ProductCompatPartsModel.php

@@ -0,0 +1,48 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model\v1;
+
+use app\common\model\ProductCompatPartsBaseModel;
+use think\model\concern\SoftDelete;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatPartsModel extends ProductCompatPartsBaseModel
+{
+    // 启用软件删除
+    use SoftDelete;
+    // 软件删除时间字段
+    protected $deleteTime = 'deleted_at';
+
+    // 状态获取器
+    public function getStatusTextAttr($value, array $data)
+    {
+        $status = ['启用', '禁用'];
+        return $status[$data['status']];
+    }
+
+    // 按所属语言查询
+    public function scopeLanguage(\think\db\Query $query, int $value)
+    {
+        $query->where('language_id', $value);
+    }
+
+    // 按类型名称查询
+    public function scopePartName(\think\db\Query $query, string|array $value)
+    {
+        if (is_array($value)) {
+            $query->where('name', 'in', $value);
+            return;
+        }
+        $query->where('name', '=', $value);
+    }
+
+    // 查询配件类型名称搜索
+    public function searchNameAttr(\think\db\Query $query, string|null $value, array $data)
+    {
+        if (is_null($value)) return;
+        $query->where('name', 'like', '%' . $value . '%');
+    }
+}

app/admin/model/v1/ProductCompatRelModel.php

@@ -0,0 +1,14 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\model\v1;
+
+use app\common\model\ProductCompatRelBaseModel;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatRelModel extends ProductCompatRelBaseModel
+{
+    //
+}

app/admin/route/v1.php

@@ -366,6 +366,45 @@ Route::group('v1', function () {
             // 产品回收站删除
             Route::delete('delete/:id', 'ProductTrash/delete');
         });
+
+        // 产品兼容性数据
+        Route::group('compat', function () {
+           // 兼容性数据列表
+           Route::get('index', 'ProductCompat/index');
+
+           // 兼容性数据详情
+           Route::get('read/:id', 'ProductCompat/read');
+
+           // 兼容性数据导入
+           Route::post('import', 'ProductCompat/import');
+
+           // 兼容性数据添加
+           Route::post('save', 'ProductCompat/save');
+
+           // 兼容性数据更新
+           Route::put('update/:id', 'ProductCompat/update');
+
+           // 兼容性数据删除
+           Route::delete('delete/:id', 'ProductCompat/delete');
+
+           // 配件类型管理
+           Route::group('parts', function () {
+               // 配件列表
+               Route::get('index', 'ProductCompatParts/index');
+
+               // 配件详情
+               Route::get('read/:id', 'ProductCompatParts/read');
+
+               // 配件添加
+               Route::post('save', 'ProductCompatParts/save');
+
+               // 配件更新
+               Route::put('update/:id', 'ProductCompatParts/update');
+
+               // 配件删除
+               Route::delete('delete/:id', 'ProductCompatParts/delete');
+           });
+        });
     });
 
     // 附件（下载管理）

app/admin/validate/v1/ProductCompatPartsValidate.php

@@ -0,0 +1,46 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\validate\v1;
+
+use think\Validate;
+
+class ProductCompatPartsValidate extends Validate
+{
+    /**
+     * 定义验证规则
+     * 格式：'字段名' =>  ['规则1','规则2'...]
+     *
+     * @var array
+     */
+    protected $rule = [
+        'language_id' => 'require|integer',
+        'name'        => 'max:128'
+    ];
+
+    /**
+     * 定义错误信息
+     * 格式：'字段名.规则名' =>  '错误信息'
+     *
+     * @var array
+     */
+    protected $message = [
+        'id.require'          => 'ID不能为空',
+        'id.integer'          => 'ID必须为整数',
+        'language_id.require' => '语言ID不能为空',
+        'language_id.integer' => '语言ID必须是整数',
+        'name.max'            => '类型名称不能超过:rule个字符'
+    ];
+
+    // 新增场景
+    protected function sceneAdd()
+    {
+        return $this->remove("id", "require|integer");
+    }
+
+    // 编辑场景
+    protected function sceneEdit()
+    {
+        return $this->append("id", "require|integer");
+    }
+}

app/admin/validate/v1/ProductCompatValidate.php

@@ -0,0 +1,66 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\admin\validate\v1;
+
+use think\Validate;
+
+class ProductCompatValidate extends Validate
+{
+    /**
+     * 定义验证规则
+     * 格式：'字段名' =>  ['规则1','规则2'...]
+     *
+     * @var array
+     */
+    protected $rule = [
+        'language_id'    => 'require|integer',
+        'part_id'        => 'require|integer',
+        'label_name'     =>'max: 128',
+        'brand_name'     => 'max:128',
+        'level_name'     => 'max:32',
+        'class_name'     => 'max:128',
+        'series_name'    => 'max:128',
+        'model'          => 'require|max:128',
+        'capacity'       => 'max:32',
+        'interface_type' => 'max:64',
+        'compat_status'  => 'max:64'
+    ];
+
+    /**
+     * 定义错误信息
+     * 格式：'字段名.规则名' =>  '错误信息'
+     *
+     * @var array
+     */
+    protected $message = [
+        'id.require'             => 'ID不能为空',
+        'id.integer'             => 'ID必须为整数',
+        'language_id.require'    => '语言ID必须',
+        'language_id.integer'    => '语言ID必须为整数',
+        'part_id.require'        => '零件ID必须',
+        'part_id.integer'        => '零件ID必须为整数',
+        'label_name.max'         => '标签名称不能超过:rule个字符',
+        'brand_name.max'         => '品牌名称不能超过:rule个字符',
+        'level_name.max'         => '等级名称不能超过:rule个字符',
+        'class_name.max'         => '类型名称不能超过:rule个字符',
+        'series_name.max'        => '系列名称不能超过:rule个字符',
+        'model.require'          => '型号必须',
+        'model.max'              => '型号不能超过:rule个字符',
+        'capacity.max'           => '容量不能超过:rule个字符',
+        'interface_type.max'     => '接口类型不能超过:rule个字符',
+        'compat_status.max'      => '兼容状态不能超过:rule个字符',
+    ];
+
+    // 新增场景
+    protected function sceneAdd()
+    {
+        return $this->remove("id", "require|integer");
+    }
+
+    // 编辑场景
+    protected function sceneEdit()
+    {
+        return $this->append("id", "require|integer");
+    }
+}

app/common/model/ProductCompatBaseModel.php

@@ -0,0 +1,37 @@
+<?php
+declare(strict_types=1);
+
+namespace app\common\model;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatBaseModel extends BaseModel
+{
+    // 表名
+    protected $name = "product_compat";
+
+    // 主键
+    protected $pk = "id";
+
+    // 字段信息
+    protected $schema = [
+        "id"              => "int",
+        "language_id"     => "int",
+        "part_id"         => "int",
+        "label_name"      => "string",
+        "brand_name"      => "string",
+        "level_name"      => "string",
+        "class_name"      => "string",
+        "series_name"     => "string",
+        "model"           => "string",
+        "capacity"        => "string",
+        "interface_type"  => "string",
+        "compat_status"   => "string",
+        "sort"            => "int",
+        "disabled"        => "int",
+        "created_at"      => "datetime",
+        "updated_at"      => "datetime",
+        "deleted_at"      => "datetime",
+    ];
+}

app/common/model/ProductCompatPartsBaseModel.php

@@ -0,0 +1,28 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\common\model;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatPartsBaseModel extends BaseModel
+{
+    // 表名
+    protected $name = "product_compat_parts";
+
+    // 主键
+    protected $pk = "id";
+
+    // 字段信息
+    protected $schema = [
+        "id"              => "int",
+        "language_id"     => "int",
+        "name"            => "string",
+        "sort"            => "int",
+        "disabled"        => "int",
+        "created_at"      => "datetime",
+        "updated_at"      => "datetime",
+        "deleted_at"      => "datetime",
+    ];
+}

app/common/model/ProductCompatRelBaseModel.php

@@ -0,0 +1,29 @@
+<?php
+declare (strict_types = 1);
+
+namespace app\common\model;
+
+/**
+ * @mixin \think\Model
+ */
+class ProductCompatRelBaseModel extends BaseModel
+{
+    // 表名
+    protected $name = "product_compat_rel";
+
+    // 主键
+    protected $pk = "id";
+
+    // 字段信息
+    protected $schema = [
+        "id"                => "int",
+        "language_id"       => "int",
+        "product_id"        => "int",
+        "compat_id"         => "int",
+        "series_name"       => "string",
+        "show_series_name"  => "int",
+        "remark"            => "int",
+        "created_at"        => "datetime",
+        "updated_at"        => "datetime",
+    ];
+}

database/migrations/20260328021117_create_sys_mall_store_entrance.php

@@ -3,7 +3,7 @@
 use think\migration\Migrator;
 use think\migration\db\Column;
 
-class SysMallStoreEntrance extends Migrator
+class CreateSysMallStoreEntrance extends Migrator
 {
     /**
      * Change Method.

database/migrations/20260707030708_create_product_compat.php

@@ -0,0 +1,56 @@
+<?php
+
+use think\migration\Migrator;
+use think\migration\db\Column;
+
+class CreateProductCompat extends Migrator
+{
+    /**
+     * Change Method.
+     *
+     * Write your reversible migrations using this method.
+     *
+     * More information on writing migrations is available here:
+     * http://docs.phinx.org/en/latest/migrations.html#the-abstractmigration-class
+     *
+     * The following commands can be used in this method and Phinx will
+     * automatically reverse them when rolling back:
+     *
+     *    createTable
+     *    renameTable
+     *    addColumn
+     *    renameColumn
+     *    addIndex
+     *    addForeignKey
+     *
+     * Remember to call "create()" or "update()" and NOT "save()" when working
+     * with the Table class.
+     */
+    public function change()
+    {
+        $table = $this->table('product_compat', [
+            'engine' => 'MyISAM',
+            'collation' => 'utf8mb4_general_ci',
+            'comment' => '产品兼容性表'
+        ]);
+
+        $table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID'])
+              ->addColumn('part_id', 'integer', ['null' => false, 'comment' => '配件id'])
+              ->addColumn('label_name', 'string', ['limit' => 128, 'null' => false, 'comment' => '标签名称'])
+              ->addColumn('brand_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '品牌'])
+              ->addColumn('level_name', 'string', ['limit' => 32 , 'null' => true, 'comment' => '级别'])
+              ->addColumn('class_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '类别'])
+              ->addColumn('series_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '系列'])
+              ->addColumn('model', 'string', ['limit' => 128, 'null' => false, 'comment' => '型号'])
+              ->addColumn('capacity', 'string', ['limit' => 32, 'null' => true, 'comment' => '容量'])
+              ->addColumn('interface_type', 'string', ['limit' => 64, 'null' => true, 'comment' => '接口类型'])
+              ->addColumn('compat_status', 'string', ['limit' => 64, 'null' => true, 'comment' => '兼容性状态'])
+              ->addColumn('sort', 'integer', ['default' => 0, 'comment' => '排序'])
+              ->addColumn('disabled', 'boolean', ['default' => 0, 'comment' => '是否禁用 0:启用 1:禁用'])
+              ->addColumn('created_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP', 'comment' => '创建时间'])
+              ->addColumn('updated_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 'comment' => '更新时间'])
+              ->addColumn('deleted_at', 'timestamp', ['null' => true, 'comment' => '删除时间'])
+              ->addIndex(['language_id'], ['name' => 'idx_language_id'])
+              ->create();
+    }
+}

database/migrations/20260707030713_create_product_compat_parts.php

@@ -0,0 +1,47 @@
+<?php
+
+use think\migration\Migrator;
+use think\migration\db\Column;
+
+class CreateProductCompatParts extends Migrator
+{
+    /**
+     * Change Method.
+     *
+     * Write your reversible migrations using this method.
+     *
+     * More information on writing migrations is available here:
+     * http://docs.phinx.org/en/latest/migrations.html#the-abstractmigration-class
+     *
+     * The following commands can be used in this method and Phinx will
+     * automatically reverse them when rolling back:
+     *
+     *    createTable
+     *    renameTable
+     *    addColumn
+     *    renameColumn
+     *    addIndex
+     *    addForeignKey
+     *
+     * Remember to call "create()" or "update()" and NOT "save()" when working
+     * with the Table class.
+     */
+    public function change()
+    {
+        $table = $this->table('product_compat_parts', [
+            'engine' => 'MyISAM',
+            'collation' => 'utf8mb4_general_ci',
+            'comment' => '产品兼容性-配件类型表'
+        ]);
+
+        $table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID'])
+              ->addColumn('name', 'string', ['limit' => 128, 'null' => false, 'comment' => '类型名称'])
+              ->addColumn('sort', 'integer', ['default' => 0, 'comment' => '排序'])
+              ->addColumn('disabled', 'boolean', ['default' => 0, 'comment' => '是否禁用 0:启用 1:禁用'])
+              ->addColumn('created_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP', 'comment' => '创建时间'])
+              ->addColumn('updated_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 'comment' => '更新时间'])
+              ->addColumn('deleted_at', 'timestamp', ['null' => true, 'comment' => '删除时间'])
+              ->addIndex(['language_id'], ['name' => 'idx_language_id'])
+              ->create();
+    }
+}

database/migrations/20260707034159_create_product_compat_rel.php

@@ -0,0 +1,48 @@
+<?php
+
+use think\migration\Migrator;
+use think\migration\db\Column;
+
+class CreateProductCompatRel extends Migrator
+{
+    /**
+     * Change Method.
+     *
+     * Write your reversible migrations using this method.
+     *
+     * More information on writing migrations is available here:
+     * http://docs.phinx.org/en/latest/migrations.html#the-abstractmigration-class
+     *
+     * The following commands can be used in this method and Phinx will
+     * automatically reverse them when rolling back:
+     *
+     *    createTable
+     *    renameTable
+     *    addColumn
+     *    renameColumn
+     *    addIndex
+     *    addForeignKey
+     *
+     * Remember to call "create()" or "update()" and NOT "save()" when working
+     * with the Table class.
+     */
+    public function change()
+    {
+        $table = $this->table('product_compat_rel', [
+            'engine' => 'InnoDB',
+            'collation' => 'utf8mb4_general_ci',
+            'comment' => '产品兼容性关联表'
+        ]);
+
+        $table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID'])
+              ->addColumn('product_id', 'integer', ['null' => false, 'comment' => '产品id'])
+              ->addColumn('compat_id', 'json', ['null' => false, 'comment' => '关联的兼容性数据id'])
+              ->addColumn('series_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '产品系列名'])
+              ->addColumn('show_series_name', 'boolean', ['null' => false, 'default' => 0, 'comment' => '是否显示系列名：0=否，1=是'])
+              ->addColumn('remark', 'string', ['limit' => 512, 'null' => true, 'comment' => '兼容性说明'])
+              ->addColumn('created_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP', 'comment' => '创建时间'])
+              ->addColumn('updated_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 'comment' => '更新时间'])
+              ->addIndex(['language_id'], ['name' => 'idx_language_id'])
+              ->create();
+    }
+}