diff --git a/app/admin/controller/ReceiveProductSync.php b/app/admin/controller/ReceiveProductSync.php new file mode 100644 index 00000000..8b3c8c02 --- /dev/null +++ b/app/admin/controller/ReceiveProductSync.php @@ -0,0 +1,217 @@ +post(); + if (empty($data)) return error('请确认同步数据'); + + $validate = validate([ + 'name|分类名称' => 'require', + 'erp_code|分类ERP编码' => 'require', + ]); + if (!$validate->check($data)) { + return error((string)$validate->getError()); + } + + // 获取对应语言ID + $lang_id = LanguageModel::where('code', $data['lang'])->value('id'); + if (empty($lang_id)) { + return error('语言不存在'); + } + + Db::startTrans(); + try { + $tco_category_data = [ + 'language_id' => $lang_id, + 'name' => $data['name'], + 'tco_id' => $data['tco_id'], + 'tco_pid' => $data['tco_pid'], + 'tco_path' => $data['tco_path'], + 'erp_id' => $data['erp_id'], + 'erp_pid' => $data['erp_pid'], + 'erp_code' => $data['erp_code'], + 'erp_path' => $data['erp_path'], + 'disabled' => Operate_Of_ReceiveSync::Disable == $data['operate'] ? 1 : 0, + 'sync_time' => strtotime($data['created_at']) + ]; + $tco_category = ProductTcoCategoryModel::language($lang_id)->erpCode($tco_category_data['erp_code'])->find(); + if (empty($tco_category)) { + $tco_category = ProductTcoCategoryModel::create($tco_category_data); + if ($tco_category->isEmpty()) { + throw new \Exception('产品目录分类创建失败'); + } + + $category_data = [ + 'language_id' => $lang_id, + 'unique_id' => uniqid('PRO_CATE_'), + 'pid' => 0, + 'path' => '', + 'name' => $tco_category_data['name'], + 'icon' => '', + 'desc' => '', + 'related_tco_category' => $tco_category['id'], + 'sort' => 0, + 'level' => 1, + 'is_show' => 1, + ]; + $tco_parent = ProductTcoCategoryModel::language($lang_id)->tcoId($tco_category['tco_pid'])->find(); + if (!empty($tco_parent)) { + $parent = ProductCategoryModel::language($lang_id)->tcoId($tco_parent['id'])->find(); + if ($parent->isEmpty()) { + throw new \Exception('产品分类父级不存在'); + } + $category_data['pid'] = $parent['id']; + $category_data['path'] = $parent['path'] . $parent['pid']; + $category_data['level'] = $parent['level'] + 1; + } + $category = ProductCategoryModel::create($category_data); + if ($category->isEmpty()) { + throw new \Exception('产品分类创建失败'); + } + } + else if ($tco_category['sync_time'] < $tco_category_data['sync_time']) { + $success = $tco_category->save($tco_category_data); + if (!$success) { + throw new \Exception('产品目录分类更新失败'); + } + + $category = ProductCategoryModel::language($lang_id)->tcoId($tco_category['id'])->find(); + $tco_parent = ProductTcoCategoryModel::language($lang_id)->tcoId($tco_category['tco_pid'])->find(); + if (!empty($tco_parent)) { + $parent = ProductCategoryModel::language($lang_id)->tcoId($tco_parent['id'])->find(); + if ($parent->isEmpty()) { + throw new \Exception('产品分类父级不存在'); + } + $category['pid'] = $parent['id']; + $category['path'] = $parent['path'] . $parent['pid']; + $category['level'] = $parent['level'] + 1; + } + if (!$category->save($category)) { + throw new \Exception('产品分类更新失败'); + } + } + + Db::commit(); + } catch (\Throwable $th) { + Db::rollback(); + return error(sprintf('%s %s:%d', $th->getMessage(), $th->getFile(), $th->getLine())); + } + + return success('同步成功'); + } + + // 接收产品同步数据 + public function product() + { + $data = request()->post(); + if (empty($data)) { + return error('请确认同步数据'); + } + + $validate = validate([ + 'spu' => 'require', + 'name' => 'require', + 'category_erp_code' => 'require', + 'lang' => 'require', + 'created_at' => 'require', + ]); + if (!$validate->check($data)) { + return error((string)$validate->getError()); + } + + // 获取对应语言ID + $lang_id = LanguageModel::where('code', $data['lang'])->value('id'); + if (empty($lang_id)) { + return error('语言不存在'); + } + + // 如果 spu_before_modification 存在则根据 spu_before_modification 更新型号 + $product = null; + if (!empty($data['spu_before_modification'])) { + $product = ProductModel::language($lang_id)->spu($data['spu_before_modification'])->find(); + } + if ( + (empty($data['spu_before_modification']) && !empty($data['spu'])) + // 避免 spu_before_modification 更新型号时,人为删除了旧型号导致的新增,从而出现重复型号问题,而进行再次验证 + || (!empty($data['spu_before_modification']) && empty($product)) + ) { + $product = ProductModel::language($lang_id)->spu($data['spu'])->find(); + } + + try { + $product_tco_category = ProductTcoCategoryModel::language($lang_id)->erpCade($data['category_erp_code'])->find(); + if (empty($product_tco_category)) { + throw new \Exception('官网未找到产品目录同步分类'); + } + + $product_category = ProductCategoryModel::language($lang_id)->tcoId($product_tco_category['id'])->find(); + if (empty($product_category)) { + throw new \Exception('官网未找到产品目录同步分类关联的分类'); + } + + if (empty($product)) { + $product = ProductModel::create([ + 'language_id' => $lang_id, + 'category_id' => $product_category['id'], + 'spu' => $data['spu'], + 'name' => $data['name'], + 'short_name' => '', + 'cover_image' => '', + 'desc' => '', + 'video_img' => '', + 'video_url' => '', + 'is_sale' => 0, + 'is_new' => 0, + 'is_hot' => 0, + 'is_show' => Operate_Of_ReceiveSync::Disable == $data['operate'] ? 0 : 1, + 'sort' => 0, + 'detail' => '', + 'status' => 1, + 'seo_title' => '', + 'seo_keywords' => '', + 'seo_desc' => '', + 'updated_at' => $data['created_at'], + ]); + if ($product->isEmpty()) { + throw new \Exception('产品创建失败'); + } + } + else if (strtotime($product['updated_at']) < strtotime($data['created_at'])) { + $product->spu = $data['spu']; + $product->name = $data['name']; + $product->category_id = $product_category['id']; + $product->is_show = Operate_Of_ReceiveSync::Disable == $data['operate'] ? 0 : 1; + if (!$product->save()) { + throw new \Exception('产品更新失败'); + } + } + } catch (\Throwable $th) { + return error(sprintf('%s %s:%d', $th->getMessage(), $th->getFile(), $th->getLine())); + } + + return success('同步成功'); + } +} diff --git a/app/admin/model/v1/ProductCategoryModel.php b/app/admin/model/v1/ProductCategoryModel.php index f993f1c0..eb4dabaf 100644 --- a/app/admin/model/v1/ProductCategoryModel.php +++ b/app/admin/model/v1/ProductCategoryModel.php @@ -29,6 +29,12 @@ class ProductCategoryModel extends ProductCategoryBaseModel $query->where('language_id', '=', $value); } + // 所属产品目录分类id查询 + public function scopeTcoId($query, $value) + { + $query->where('related_tco_category', '=', $value); + } + /** * 根据是否显示查询 * @param $query diff --git a/app/admin/model/v1/ProductModel.php b/app/admin/model/v1/ProductModel.php index 8f970687..2b3456ad 100644 --- a/app/admin/model/v1/ProductModel.php +++ b/app/admin/model/v1/ProductModel.php @@ -80,6 +80,12 @@ class ProductModel extends ProductBaseModel $query->where('category_id', '=', $value); } + // 规格型号查询 + public function scopeSpu($query, $spu) + { + $query->where('spu', '=', $spu); + } + // 启用状态查询 public function scopeEnabled($query) { diff --git a/app/admin/model/v1/ProductTcoCategoryModel.php b/app/admin/model/v1/ProductTcoCategoryModel.php index 596fcb37..ea6cb328 100644 --- a/app/admin/model/v1/ProductTcoCategoryModel.php +++ b/app/admin/model/v1/ProductTcoCategoryModel.php @@ -23,6 +23,18 @@ class ProductTcoCategoryModel extends ProductTcoCategoryBaseModel $query->where('language_id', '=', $value); } + // 根据 tco_id 查询 + public function scopeTcoId($query, $value) + { + $query->where('tco_id', '=', $value); + } + + // 根据ERP Code查询 + public function scopeErpCode($query, $value) + { + $query->where('erp_code', '=', $value); + } + // 按分类名称搜索 public function searchNameAttr($query, $value, $data) { diff --git a/app/index/common.php b/app/index/common.php index de61e023..81d3df13 100644 --- a/app/index/common.php +++ b/app/index/common.php @@ -222,3 +222,22 @@ if (!function_exists('get_platform')) { return $platform; } } + +if (!function_exists('highlight_keywords')) { + /** + * 高亮关键词 + * @param string $item + * @param string $keywords + * @param array $class + * @return string + */ + function highlight_keywords(string $text, string $keywords, array $class=[]): string + { + return preg_replace_callback('/' . preg_quote($keywords, '/') . '+/i', function($match) use($text, $class) { + if (empty($match)) { + return $text; + } + return '' . $match[0] . ''; + }, $text); + } +} diff --git a/app/index/controller/Product.php b/app/index/controller/Product.php index 74510312..b16ded89 100644 --- a/app/index/controller/Product.php +++ b/app/index/controller/Product.php @@ -299,9 +299,9 @@ class Product extends Common 'query' => request()->param() ]) ->each(function ($item) use($keywords) { - $item['spu'] = str_replace($keywords, ''.$keywords.'', $item['spu']); - $item['name'] = str_replace($keywords, ''.$keywords.'', $item['name']); - $item['short_name'] = str_replace($keywords, ''.$keywords.'', $item['short_name']); + $item['spu'] = highlight_keywords($item['spu'], $keywords, ['redpoint']); + $item['name'] = highlight_keywords($item['name'], $keywords, ['redpoint']); + $item['short_name'] = highlight_keywords($item['short_name'], $keywords, ['redpoint']); return $item; }); View::assign('products', $products); diff --git a/app/index/model/ProductModel.php b/app/index/model/ProductModel.php index 5b8a74f3..a4be17ef 100644 --- a/app/index/model/ProductModel.php +++ b/app/index/model/ProductModel.php @@ -79,6 +79,6 @@ class ProductModel extends ProductBaseModel // 关键词搜索 public function searchKeywordsAttr($query, string $keywords) { - $query->whereRaw('BINARY spu LIKE "%' . $keywords . '%" OR BINARY name LIKE "%' . $keywords . '%" OR BINARY short_name LIKE "%' . $keywords . '%"'); + $query->whereRaw('spu LIKE "%' . $keywords . '%" OR name LIKE "%' . $keywords . '%" OR short_name LIKE "%' . $keywords . '%"'); } } diff --git a/app/index/view/pc/topic_nas/help.html b/app/index/view/pc/topic_nas/help.html index e0752832..12c373e3 100644 --- a/app/index/view/pc/topic_nas/help.html +++ b/app/index/view/pc/topic_nas/help.html @@ -136,7 +136,7 @@ $('#dropdown').hide(); } }); - $('.nhlplxwmit:not(:first)').hover(function () { + $('.nhlplxwmit').hover(function () { // 当鼠标移入时,显示.lxewmimg 并隐藏.lximg var lxe = $(this).find('.lxewmimg'); var lxi = $(this).find('.lximg');