refactor: 产品兼容性相关功能
All checks were successful
Gitea Actions Official-website / deploy-dev (push) Successful in 3s

This commit is contained in:
2026-08-11 17:00:26 +08:00
parent 751828be48
commit 6c43f4e3f2
18 changed files with 569 additions and 217 deletions

View File

@@ -4,7 +4,9 @@ declare (strict_types = 1);
namespace app\admin\controller\v1; namespace app\admin\controller\v1;
use app\admin\model\v1\ProductCompatModel; use app\admin\model\v1\ProductCompatModel;
use app\admin\model\v1\ProductCompatModelsModel;
use app\admin\model\v1\ProductCompatPartsModel; use app\admin\model\v1\ProductCompatPartsModel;
use app\admin\model\v1\ProductCompatTypesModel;
use app\admin\validate\v1\ProductCompatValidate; use app\admin\validate\v1\ProductCompatValidate;
class ProductCompat class ProductCompat
@@ -15,8 +17,11 @@ class ProductCompat
public function index() public function index()
{ {
$params = request()->param([ $params = request()->param([
'label_name', 'compatible_model',
'model', 'model',
'type_id',
'part_id',
'brand_name',
'page/d' => 1, 'page/d' => 1,
'size/d' => 10 'size/d' => 10
]); ]);
@@ -25,21 +30,46 @@ class ProductCompat
'language_id', 'language_id',
'deleted_at' 'deleted_at'
]) ])
->with(['parts' => function ($query) { ->with([
$query->field(['id', 'name']); 'types' => function ($query) {
}]) $query->field(['id', 'name']);
},
'parts' => function ($query) {
$query->field(['id', 'name']);
},
'compatible_models' => function ($query) {
$query->field(['compat_id', 'compatible_model']);
}
])
->language(request()->lang_id) ->language(request()->lang_id)
->withSearch(['label_name', 'model'], [ ->where(function ($query) use($params) {
'label_name' => $params['label_name'] ?? null, if (!empty($params['type_id'])) {
'model' => $params['model'] ?? null, $query->typeId($params['type_id']);
}
if (!empty($params['part_id'])) {
$query->partId($params['part_id']);
}
})
->withSearch(['model', 'brand_name', 'compatible_model'], [
'model' => $params['model'] ?? null,
'brand_name' => $params['brand_name'] ?? null,
'compatible_model' => $params['compatible_model'] ?? null,
]) ])
->order(['updated_at' => 'desc']) ->order(['updated_at' => 'desc'])
->paginate([ ->paginate([
'list_rows' => $params['size'], 'list_rows' => $params['size'],
'page' => $params['page'], 'page' => $params['page'],
]) ])
?->bindAttr('types', ['type_name' => 'name'])
?->bindAttr('parts', ['part_name' => 'name']) ?->bindAttr('parts', ['part_name' => 'name'])
?->hidden(['parts']); ?->hidden(['types', 'parts'])
?->each(function ($item) {
$compatible_models = [];
foreach ($item['compatible_models'] as $model) {
$compatible_models[] = $model['compatible_model'];
}
$item['compatible_models'] = implode(',', $compatible_models);
});
return success("获取成功", $list); return success("获取成功", $list);
} }
@@ -58,16 +88,16 @@ class ProductCompat
// 读取文件 // 读取文件
$keys_map = [ $keys_map = [
'A' => 'label_name', 'A' => 'type_name',
'B' => 'part_name', 'B' => 'part_name',
'C' => 'brand_name', 'C' => 'brand_name',
'D' => 'level_name', 'D' => 'level_name',
'E' => 'class_name', 'E' => 'spec_name',
'F' => 'series_name', 'F' => 'series_name',
'G' => 'model', 'G' => 'model',
'H' => 'capacity', 'H' => 'frequency',
'I' => 'interface_type', 'I' => 'capacity',
'J' => 'compat_status', 'J' => 'compatible_models',
]; ];
$chunk = 500; // 每批次处理的条数 $chunk = 500; // 每批次处理的条数
@@ -96,41 +126,111 @@ class ProductCompat
\think\facade\Db::rollback(); \think\facade\Db::rollback();
return error($th->getMessage()); return error($th->getMessage());
} }
\think\facade\Db::commit();
\think\facade\Db::commit();
return success('操作成功'); return success('操作成功');
} }
private function handleImport(array $xlsx_data, int $lang_id): void private function handleImport(array $xlsx_data, int $lang_id): void
{ {
$compat_datas = $this->matchExistCompatData($xlsx_data, $lang_id); list(
$models,
$exists_compat_ids,
$compat_models,
$compat_datas
) = $this->matchExistsCompatData($xlsx_data, $lang_id);
// 校验数据并组装sql语句 // 校验数据并组装sql语句
$raw_sql = $this->validateAndBuildSql($compat_datas); $raw_sql = $this->validateAndBuildSql($compat_datas);
if (false === \think\facade\Db::execute($raw_sql)) { if (false === \think\facade\Db::execute($raw_sql)) {
throw new \Exception(sprintf('第【%s】行执行导入 SQL 失败', implode(',', array_column($xlsx_data, 'seq_no')))); throw new \Exception(sprintf('第【%s】行执行导入 SQL 失败', implode(',', array_column($xlsx_data, 'seq_no'))));
} }
// 清除旧兼容型号数据
if (!empty($exists_compat_ids)) {
ProductCompatModelsModel::destroy(function ($query) use($exists_compat_ids) {
$query->where('compat_id', 'in', $exists_compat_ids);
});
}
// 为不遗漏id重新查询
$compat_map = ProductCompatModel::language($lang_id)
->modelName($models)
->column('id', 'model');
// 插入兼容型号数据
$compatible_models = [];
foreach ($compat_models as $m) {
$compat_id = $compat_map[$m['model']];
foreach ($m['compatible_models'] as $compatible_model) {
$compatible_models[] = [
'compat_id' => $compat_id,
'compatible_model' => $compatible_model,
];
}
}
if (!empty($compatible_models)) {
ProductCompatModelsModel::insertAll($compatible_models);
}
} }
private function matchExistCompatData(array $datas, int $lang_id) private function matchExistsCompatData(array $datas, int $lang_id)
{ {
$models = array_column($datas, 'model'); $models = array_column($datas, 'model');
$compat_map = ProductCompatModel::language($lang_id) $compat_map = ProductCompatModel::language($lang_id)
->modelName($models) ->modelName($models)
->column('id', 'model'); ->column('id', 'model');
$type_names = array_unique(array_column($datas, 'type_name'));
$type_map = ProductCompatTypesModel::language($lang_id)
->typeName($type_names)
->column('id', 'name');
$part_names = array_unique(array_column($datas, 'part_name')); $part_names = array_unique(array_column($datas, 'part_name'));
$part_map = ProductCompatPartsModel::language($lang_id) $part_map = ProductCompatPartsModel::language($lang_id)
->partName($part_names) ->partName($part_names)
->column('id', 'name'); ->column('id', 'name');
// 匹配已存在数据的主键、配件id // 匹配已存在数据的主键、类型id及配件id
$exists_compat_ids = [];
$errors = [];
$compat_models = [];
foreach ($datas as &$d) { foreach ($datas as &$d) {
$d['id'] = $compat_map[$d['model']] ?? null; // 确认要更新的数据的主键
$d['id'] = null;
if (isset($compat_map[$d['model']])) {
$d['id'] = $compat_map[$d['model']];
$exists_compat_ids[] = $d['id'];
}
// 所属语言
$d['language_id'] = $lang_id; $d['language_id'] = $lang_id;
$d['part_id'] = $part_map[$d['part_name']] ?? 0;
// 确认产品类型id
if (empty($type_map[$d['type_name']])) {
$errors[] = "第【{$d['seq_no']}】行,产品类型【{$d['type_name']}】无效";
continue;
}
$d['type_id'] = $type_map[$d['type_name']];
// 确认配件类型id
if (empty($part_map[$d['part_name']])) {
$errors[] = "第【{$d['seq_no']}】行,配件类型【{$d['part_name']}】无效";
continue;
}
$d['part_id'] = $part_map[$d['part_name']];
// 处理兼容型号数据
$compatible_models_str = str_replace('', ',', $d['compatible_models']);
$compatible_models_arr = explode(',', $compatible_models_str);
if (!empty($compatible_models_arr)) {
$compat_models[] = [
'model' => $d['model'],
'compatible_models' => $compatible_models_arr,
];
}
} }
unset($d); unset($d);
if (!empty($errors)) {
throw new \Exception(implode("\n", $errors));
}
return $datas; return [$models, $exists_compat_ids, $compat_models, $datas];
} }
private function validateAndBuildSql(array $compat_datas) private function validateAndBuildSql(array $compat_datas)
{ {
@@ -153,19 +253,18 @@ class ProductCompat
{ {
$pdo = \think\facade\Db::connect()->getPdo(); $pdo = \think\facade\Db::connect()->getPdo();
return sprintf( return sprintf(
'(%d, %d, %d, %s, %s, %s, %s, %s, %s, %s, %s, %s)', '(%d, %d, %d, %d, %s, %s, %s, %s, %s, %s, %s)',
$compat['id'], $compat['id'],
$compat['language_id'], $compat['language_id'],
$compat['type_id'],
$compat['part_id'], $compat['part_id'],
is_string($compat['label_name']) ? $pdo->quote($compat['label_name']) : $compat['label_name'], is_string($compat['model']) ? $pdo->quote($compat['model']) : $compat['model'],
is_string($compat['brand_name']) ? $pdo->quote($compat['brand_name']) : $compat['brand_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['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['spec_name']) ? $pdo->quote($compat['spec_name']) : $compat['spec_name'],
is_string($compat['series_name']) ? $pdo->quote($compat['series_name']) : $compat['series_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['capacity']) ? $pdo->quote($compat['capacity']) : $compat['capacity'],
is_string($compat['interface_type']) ? $pdo->quote($compat['interface_type']) : $compat['interface_type'], is_string($compat['frequency']) ? $pdo->quote($compat['frequency']) : $compat['frequency']
is_string($compat['compat_status']) ? $pdo->quote($compat['compat_status']) : $compat['compat_status']
); );
} }
private function buildRawSql(array $values) private function buildRawSql(array $values)
@@ -174,28 +273,26 @@ class ProductCompat
'INSERT INTO %s ( 'INSERT INTO %s (
`id`, `id`,
`language_id`, `language_id`,
`type_id`,
`part_id`, `part_id`,
`label_name`, `model`,
`brand_name`, `brand_name`,
`level_name`, `level_name`,
`class_name`, `spec_name`,
`series_name`, `series_name`,
`model`,
`capacity`, `capacity`,
`interface_type`, `frequency`
`compat_status`
) VALUES %s ) VALUES %s
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
`type_id` = VALUES(`type_id`),
`part_id` = VALUES(`part_id`), `part_id` = VALUES(`part_id`),
`label_name` = VALUES(`label_name`), `model` = VALUES(`model`),
`brand_name` = VALUES(`brand_name`), `brand_name` = VALUES(`brand_name`),
`level_name` = VALUES(`level_name`), `level_name` = VALUES(`level_name`),
`class_name` = VALUES(`class_name`), `spec_name` = VALUES(`spec_name`),
`series_name` = VALUES(`series_name`), `series_name` = VALUES(`series_name`),
`model` = VALUES(`model`),
`capacity` = VALUES(`capacity`), `capacity` = VALUES(`capacity`),
`interface_type` = VALUES(`interface_type`), `frequency` = VALUES(`frequency`)
`compat_status` = VALUES(`compat_status`)
', ',
(new ProductCompatModel)->getTable(), (new ProductCompatModel)->getTable(),
implode(',', $values) implode(',', $values)
@@ -208,16 +305,16 @@ class ProductCompat
public function save() public function save()
{ {
$post = request()->post([ $post = request()->post([
'type_id',
'part_id', 'part_id',
'label_name', 'model',
'brand_name', 'brand_name',
'level_name', 'level_name',
'class_name', 'spec_name',
'series_name', 'series_name',
'model',
'capacity', 'capacity',
'interface_type', 'frequency',
'compat_status', 'compatible_models',
'sort', 'sort',
'disabled' 'disabled'
]); ]);
@@ -229,11 +326,31 @@ class ProductCompat
return error($validate->getError()); return error($validate->getError());
} }
$compat = ProductCompatModel::create($data); \think\facade\Db::startTrans();
if ($compat->isEmpty()) { try {
return error('操作失败'); $compat = ProductCompatModel::create($data);
if ($compat->isEmpty()) {
throw new \Exception('操作失败');
}
$compatible_models = [];
$models = explode(',', str_replace('', ',', $post['compatible_models']));
foreach ($models as $model) {
$compatible_models[] = [
'compat_id' => $compat->id,
'compatible_model' => trim($model),
];
}
if (empty($compatible_models)) {
throw new \Exception('请确认兼容型号数据为有效');
}
ProductCompatModelsModel::insertAll($compatible_models);
} catch (\Throwable $e) {
\think\facade\Db::rollback();
return error($e->getMessage());
} }
\think\facade\Db::commit();
return success('操作成功'); return success('操作成功');
} }
@@ -244,11 +361,23 @@ class ProductCompat
{ {
$id = request()->param('id'); $id = request()->param('id');
$data = ProductCompatModel::withoutField(['language_id', 'deleted_at']) $data = ProductCompatModel::withoutField(['language_id', 'deleted_at'])
->with([
'compatible_models' => function ($query) {
$query->field(['compat_id', 'compatible_model']);
}
])
->bypk($id) ->bypk($id)
->find(); ->find();
if (empty($data)) { if (empty($data)) {
return error('获取失败'); return error('获取失败');
} }
if (!empty($data->compatible_models)) {
$compatible_models = [];
foreach ($data->compatible_models as $model) {
$compatible_models[] = $model['compatible_model'];
}
$data->compatible_models = implode(',', $compatible_models);
}
return success("获取成功", $data); return success("获取成功", $data);
} }
@@ -260,16 +389,16 @@ class ProductCompat
{ {
$id = request()->param('id'); $id = request()->param('id');
$put = request()->put([ $put = request()->put([
'type_id',
'part_id', 'part_id',
'label_name', 'model',
'brand_name', 'brand_name',
'level_name', 'level_name',
'class_name', 'spec_name',
'series_name', 'series_name',
'model',
'capacity', 'capacity',
'interface_type', 'frequency',
'compat_status', 'compatible_models',
'sort', 'sort',
'disabled' 'disabled'
]); ]);
@@ -281,14 +410,41 @@ class ProductCompat
return error($validate->getError()); return error($validate->getError());
} }
$compat = ProductCompatModel::bypk($id)->find(); \think\facade\Db::startTrans();
if (empty($compat)) { try {
return error('请确认操作对象是否正确'); $compat = ProductCompatModel::bypk($id)->find();
} if (empty($compat)) {
if (!$compat->save($data)) { throw new \Exception('请确认操作对象是否正确');
return error('操作失败'); }
if (!$compat->save($data)) {
throw new \Exception('操作失败');
}
$compatible_models = [];
$models = explode(',', str_replace('', ',', $put['compatible_models']));
foreach ($models as $model) {
$compatible_models[] = [
'compat_id' => $compat->id,
'compatible_model' => trim($model),
];
}
if (empty($compatible_models)) {
throw new \Exception('请确认兼容型号数据为有效');
}
// 清除旧数据
$deleted = ProductCompatModelsModel::destroy(function($query) use ($compat) {
$query->where('compat_id', '=', $compat->id);
});
if (!$deleted) {
throw new \Exception('删除兼容型号数据失败');
}
ProductCompatModelsModel::insertAll($compatible_models);
} catch (\Throwable $e) {
\think\facade\Db::rollback();
return error($e->getMessage());
} }
\think\facade\Db::commit();
return success('操作成功'); return success('操作成功');
} }

View File

@@ -4,132 +4,34 @@ declare (strict_types = 1);
namespace app\admin\controller\v1; namespace app\admin\controller\v1;
use app\admin\model\v1\ProductCompatPartsModel; use app\admin\model\v1\ProductCompatPartsModel;
use app\admin\validate\v1\ProductCompatPartsValidate;
use think\Request;
class ProductCompatParts class ProductCompatParts
{ {
/** /**
* 兼容配件列表 * 兼容配件列表
*/ */
public function index() public function list()
{ {
$params = request()->param([ $params = request()->param([
'name', 'name',
'is_show' => null,
'page/d' => 1,
'size/d' => 10
]); ]);
$list = ProductCompatPartsModel::withoutField([ $list = ProductCompatPartsModel::withoutField([
'language_id', 'language_id',
'sort',
'disabled',
'created_at',
'updated_at',
'deleted_at' 'deleted_at'
]) ])
->language(request()->lang_id) ->language(request()->lang_id)
->disabled(is_null($params['is_show']) ? null : ($params['is_show'] == 1 ? 0 : 1)) ->disabled(false)
->withSearch('name', [ ->withSearch('name', [
'name' => $params['name']??null 'name' => $params['name']??null
]) ])
->order(['id' => 'desc']) ->order(['id' => 'desc'])
->paginate([ ->select();
'list_rows' => $params['size'],
'page' => $params['page'],
]);
return success('获取成功', $list); 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("操作成功");
}
} }

View File

@@ -0,0 +1,38 @@
<?php
declare (strict_types = 1);
namespace app\admin\controller\v1;
use app\admin\model\v1\ProductCompatTypesModel;
use think\Request;
class ProductCompatTypes
{
/**
* 兼容产品类型列表
*/
public function list()
{
$params = request()->param([
'name',
]);
$list = ProductCompatTypesModel::withoutField([
'language_id',
'sort',
'disabled',
'created_at',
'updated_at',
'deleted_at'
])
->language(request()->lang_id)
->disabled(false)
->withSearch('name', [
'name' => $params['name']??null
])
->order(['id' => 'desc'])
->select();
return success('获取成功', $list);
}
}

View File

@@ -16,18 +16,42 @@ class ProductCompatModel extends ProductCompatBaseModel
// 软件删除时间字段 // 软件删除时间字段
protected $deleteTime = 'deleted_at'; protected $deleteTime = 'deleted_at';
// 关联产品类型
public function types()
{
return $this->hasOne(ProductCompatTypesModel::class, 'id', 'type_id');
}
// 关联配件类型 // 关联配件类型
public function parts() public function parts()
{ {
return $this->hasOne(ProductCompatPartsModel::class, 'id', 'part_id'); return $this->hasOne(ProductCompatPartsModel::class, 'id', 'part_id');
} }
// 关联兼容型号
public function compatibleModels()
{
return $this->hasMany(ProductCompatModelsModel::class, 'compat_id');
}
// 按所属语言查询 // 按所属语言查询
public function scopeLanguage(\think\db\Query $query, int $value) public function scopeLanguage(\think\db\Query $query, int $value)
{ {
$query->where('language_id', $value); $query->where('language_id', $value);
} }
// 按类型查询
public function scopeTypeId(\think\db\Query $query, int $value)
{
$query->where('type_id', '=', $value);
}
// 按配件查询
public function scopePartId(\think\db\Query $query, int $value)
{
$query->where('part_id', '=', $value);
}
// 按型号查询 // 按型号查询
public function scopeModelName(\think\db\Query $query, string|array $value) public function scopeModelName(\think\db\Query $query, string|array $value)
{ {
@@ -39,11 +63,11 @@ class ProductCompatModel extends ProductCompatBaseModel
$query->where('model', '=', $value); $query->where('model', '=', $value);
} }
// 按标签名称搜索 // 按品牌名称搜索
public function searchLabelNameAttr(\think\db\Query $query, string|null $value, array $data) public function searchBrandNameAttr(\think\db\Query $query, string|null $value, array $data)
{ {
if (is_null($value)) return; if (is_null($value)) return;
$query->where('label_name', 'like', '%' . $value . '%'); $query->where('brand_name', 'like', '%' . $value . '%');
} }
// 按型号搜索 // 按型号搜索
@@ -52,4 +76,18 @@ class ProductCompatModel extends ProductCompatBaseModel
if (is_null($value)) return; if (is_null($value)) return;
$query->where('model', 'like', '%' . $value . '%'); $query->where('model', 'like', '%' . $value . '%');
} }
// 按兼容型号搜索
public function searchCompatibleModelAttr(\think\db\Query $query, string|null $value, array $data)
{
if (is_null($value)) return;
$table = $this->getTable();
$relation_table = ProductCompatModelsModel::getTable();
$where = ProductCompatModelsModel::where($relation_table . '.compatible_model', 'like', '%' . $value . '%')
->where('compat_id', '=', $table . '.id')
->fetchSql(true)
->select();
$query->whereExists($where);
}
} }

View File

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

View File

@@ -33,10 +33,10 @@ class ProductCompatPartsModel extends ProductCompatPartsBaseModel
} }
// 按状态查询 // 按状态查询
public function scopeDisabled(\think\db\Query $query, int|null $disabled) public function scopeDisabled(\think\db\Query $query, bool|null $disabled)
{ {
if (is_null($disabled)) return; if (is_null($disabled)) return;
$query->where('disabled', '=', $disabled); $query->where('disabled', '=', (int)$disabled);
} }
// 查询配件类型名称搜索 // 查询配件类型名称搜索

View File

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

View File

@@ -387,23 +387,11 @@ Route::group('v1', function () {
// 兼容性数据删除 // 兼容性数据删除
Route::delete('delete/:id', 'ProductCompat/delete'); Route::delete('delete/:id', 'ProductCompat/delete');
// 配件类型管理 // 产品兼容性 - 配件类型
Route::group('parts', function () { Route::get('parts/list', 'ProductCompatParts/list');
// 配件列表
Route::get('index', 'ProductCompatParts/index');
// 配件详情 // 产品兼容性 - 产品类型
Route::get('read/:id', 'ProductCompatParts/read'); Route::get('types/list', 'ProductCompatTypes/list');
// 配件添加
Route::post('save', 'ProductCompatParts/save');
// 配件更新
Route::put('update/:id', 'ProductCompatParts/update');
// 配件删除
Route::delete('delete/:id', 'ProductCompatParts/delete');
});
}); });
}); });

View File

@@ -14,17 +14,19 @@ class ProductCompatValidate extends Validate
* @var array * @var array
*/ */
protected $rule = [ protected $rule = [
'language_id' => 'require|integer', 'language_id' => 'require|integer',
'part_id' => 'require|integer', 'type_id' => 'require|integer',
'label_name' =>'max: 128', 'part_id' => 'require|integer',
'brand_name' => 'max:128', 'model' => 'require|max:128',
'level_name' => 'max:32', 'brand_name' => 'require|max:128',
'class_name' => 'max:128', 'level_name' => 'max:128',
'series_name' => 'max:128', 'spec_name' => 'max:128',
'model' => 'require|max:128', 'series_name' => 'max:128',
'capacity' => 'max:32', 'capacity' => 'max:32',
'interface_type' => 'max:64', 'frequency' => 'max:128',
'compat_status' => 'max:64' 'compatible_models' => 'require|max:512',
'sort' => 'integer',
'disabled' => 'in:0,1'
]; ];
/** /**
@@ -38,18 +40,23 @@ class ProductCompatValidate extends Validate
'id.integer' => 'ID必须为整数', 'id.integer' => 'ID必须为整数',
'language_id.require' => '语言ID必须', 'language_id.require' => '语言ID必须',
'language_id.integer' => '语言ID必须为整数', 'language_id.integer' => '语言ID必须为整数',
'part_id.require' => '零件ID必须', 'type_id.require' => '类型ID必须',
'part_id.integer' => '零件ID必须为整数', 'type_id.integer' => '类型ID必须为整数',
'label_name.max' => '标签名称不能超过:rule个字符', 'part_id.require' => '配件ID必须',
'brand_name.max' => '品牌名称不能超过:rule个字符', 'part_id.integer' => '配件ID必须为整数',
'level_name.max' => '等级名称不能超过:rule个字符',
'class_name.max' => '类型名称不能超过:rule个字符',
'series_name.max' => '系列名称不能超过:rule个字符',
'model.require' => '型号必须', 'model.require' => '型号必须',
'model.max' => '型号不能超过:rule个字符', 'model.max' => '型号不能超过:rule个字符',
'brand_name.require' => '品牌必须',
'brand_name.max' => '品牌不能超过:rule个字符',
'level_name.max' => '等级不能超过:rule个字符',
'spec_name.max' => '规格不能超过:rule个字符',
'series_name.max' => '系列不能超过:rule个字符',
'capacity.max' => '容量不能超过:rule个字符', 'capacity.max' => '容量不能超过:rule个字符',
'interface_type.max' => '接口类型不能超过:rule个字符', 'frequency.max' => '接口类型不能超过:rule个字符',
'compat_status.max' => '兼容状态不能超过:rule个字符', 'compatible_models.v' => '兼容型号必须',
'compatible_models.max' => '兼容型号不能超过:rule个字符',
'sort.integer' => '排序必须为整数',
'disabled.in' => '禁用状态必须为0或1',
]; ];
// 新增场景 // 新增场景

View File

@@ -4,6 +4,7 @@ declare(strict_types=1);
namespace app\common\model; namespace app\common\model;
/** /**
* 产品兼容性模型
* @mixin \think\Model * @mixin \think\Model
*/ */
class ProductCompatBaseModel extends BaseModel class ProductCompatBaseModel extends BaseModel
@@ -18,16 +19,15 @@ class ProductCompatBaseModel extends BaseModel
protected $schema = [ protected $schema = [
"id" => "int", "id" => "int",
"language_id" => "int", "language_id" => "int",
"type_id" => "int",
"part_id" => "int", "part_id" => "int",
"label_name" => "string", "model" => "string",
"brand_name" => "string", "brand_name" => "string",
"level_name" => "string", "level_name" => "string",
"class_name" => "string", "spec_name" => "string",
"series_name" => "string", "series_name" => "string",
"model" => "string",
"capacity" => "string", "capacity" => "string",
"interface_type" => "string", "frequency" => "string",
"compat_status" => "string",
"sort" => "int", "sort" => "int",
"disabled" => "int", "disabled" => "int",
"created_at" => "datetime", "created_at" => "datetime",

View File

@@ -0,0 +1,26 @@
<?php
declare (strict_types = 1);
namespace app\common\model;
use think\Model;
/**
* 产品兼容性 - 兼容型号模型
* @mixin \think\Model
*/
class ProductCompatModelsBaseModel extends Model
{
// 表名
protected $name = "product_compat_models";
// 主键
protected $pk = "id";
// 字段信息
protected $schema = [
"id" => "int",
"compat_id" => "int",
"compatible_model" => "string",
];
}

View File

@@ -4,6 +4,7 @@ declare (strict_types = 1);
namespace app\common\model; namespace app\common\model;
/** /**
* 产品兼容性 - 配件类型模型
* @mixin \think\Model * @mixin \think\Model
*/ */
class ProductCompatPartsBaseModel extends BaseModel class ProductCompatPartsBaseModel extends BaseModel

View File

@@ -0,0 +1,31 @@
<?php
declare (strict_types = 1);
namespace app\common\model;
use think\Model;
/**
* 产品兼容性 - 产品类型模型
* @mixin \think\Model
*/
class ProductCompatTypesBaseModel extends Model
{
// 表名
protected $name = "product_compat_types";
// 主键
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",
];
}

View File

@@ -29,28 +29,27 @@ class CreateProductCompat extends Migrator
public function change() public function change()
{ {
$table = $this->table('product_compat', [ $table = $this->table('product_compat', [
'engine' => 'MyISAM', 'engine' => 'InnoDB',
'collation' => 'utf8mb4_general_ci', 'collation' => 'utf8mb4_general_ci',
'comment' => '产品兼容性表' 'comment' => '产品兼容性表'
]); ]);
$table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID']) $table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID'])
->addColumn('part_id', 'integer', ['null' => false, 'comment' => '配件id']) ->addColumn('type_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '类型id'])
->addColumn('label_name', 'string', ['limit' => 128, 'null' => false, 'comment' => '标签名称']) ->addColumn('part_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '配件id'])
->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('model', 'string', ['limit' => 128, 'null' => false, 'comment' => '型号'])
->addColumn('brand_name', 'string', ['limit' => 128, 'null' => false, 'comment' => '品牌'])
->addColumn('level_name', 'string', ['limit' => 128 , 'null' => true, 'comment' => '级别'])
->addColumn('spec_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '规格'])
->addColumn('series_name', 'string', ['limit' => 128, 'null' => true, 'comment' => '系列'])
->addColumn('capacity', 'string', ['limit' => 32, 'null' => true, 'comment' => '容量']) ->addColumn('capacity', 'string', ['limit' => 32, 'null' => true, 'comment' => '容量'])
->addColumn('interface_type', 'string', ['limit' => 64, 'null' => true, 'comment' => '接口类型']) ->addColumn('frequency', 'string', ['limit' => 128, 'null' => true, 'comment' => '频率'])
->addColumn('compat_status', 'string', ['limit' => 64, 'null' => true, 'comment' => '兼容性状态'])
->addColumn('sort', 'integer', ['default' => 0, 'comment' => '排序']) ->addColumn('sort', 'integer', ['default' => 0, 'comment' => '排序'])
->addColumn('disabled', 'boolean', ['default' => 0, 'comment' => '是否禁用 0:启用 1:禁用']) ->addColumn('disabled', 'boolean', ['default' => 0, 'comment' => '是否禁用 0:启用 1:禁用'])
->addColumn('created_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP', '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' => '更新时间']) ->addColumn('updated_at', 'timestamp', ['null' => false, 'default' => 'CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP', 'comment' => '更新时间'])
->addColumn('deleted_at', 'timestamp', ['null' => true, 'comment' => '删除时间']) ->addColumn('deleted_at', 'timestamp', ['null' => true, 'comment' => '删除时间'])
->addIndex(['language_id'], ['name' => 'idx_language_id']) ->addIndex(['language_id', 'model'], ['unique' => true])
->create(); ->create();
} }
} }

View File

@@ -31,7 +31,7 @@ class CreateProductCompatTypes extends Migrator
$table = $this->table('product_compat_types', [ $table = $this->table('product_compat_types', [
'engine' => 'MyISAM', 'engine' => 'MyISAM',
'collation' => 'utf8mb4_general_ci', 'collation' => 'utf8mb4_general_ci',
'comment' => '产品兼容性-产品类型' 'comment' => '产品兼容性-产品类型'
]); ]);
$table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID']) $table->addColumn('language_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '语言ID'])

View File

@@ -0,0 +1,41 @@
<?php
use think\migration\Migrator;
use think\migration\db\Column;
class CreateProductCompatModels 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_models', [
'engine' => 'InnoDB',
'collation' => 'utf8mb4_general_ci',
'comment' => '产品兼容性-兼容型号表'
]);
$table->addColumn('compat_id', 'integer', ['signed' => false, 'null' => false, 'comment' => '产品兼容性id'])
->addColumn('compatible_model', 'string', ['limit' => 128, 'null' => true, 'comment' => '兼容型号'])
->create();
}
}

View File

@@ -0,0 +1,33 @@
<?php
use think\migration\Seeder;
class ProductCompatPartsInit extends Seeder
{
/**
* Run Method.
*
* Write your database seeder using this method.
*
* More information on writing seeders is available here:
* http://docs.phinx.org/en/latest/seeding.html
*/
public function run(): void
{
$data = [
['id' => 1, 'language_id' => 1, 'name' => '机械硬盘', 'sort' => 1, 'disabled' => 0],
['id' => 2, 'language_id' => 1, 'name' => '2.5 寸固态硬盘', 'sort' => 2, 'disabled' => 0],
['id' => 3, 'language_id' => 1, 'name' => 'M.2 固态硬盘', 'sort' => 3, 'disabled' => 0],
['id' => 4, 'language_id' => 1, 'name' => '内存条', 'sort' => 4, 'disabled' => 0],
['id' => 5, 'language_id' => 1, 'name' => 'UPS 不间断电源', 'sort' => 5, 'disabled' => 0]
];
$table = $this->table('product_compat_parts');
// empty the table
$table->truncate();
// insert data
$table->insert($data)->saveData();
}
}

View File

@@ -0,0 +1,30 @@
<?php
use think\migration\Seeder;
class ProductCompatTypesInit extends Seeder
{
/**
* Run Method.
*
* Write your database seeder using this method.
*
* More information on writing seeders is available here:
* http://docs.phinx.org/en/latest/seeding.html
*/
public function run(): void
{
$data = [
['id' => 1, 'language_id' => 1, 'name' => '私有云存储 NAS', 'sort' => 1, 'disabled' => 0],
['id' => 2, 'language_id' => 1, 'name' => '直连储存 DAS', 'sort' => 2, 'disabled' => 0]
];
$table = $this->table('product_compat_types');
// empty the table
$table->truncate();
// insert data
$table->insert($data)->saveData();
}
}