From c08900c6942aaa7e1ce19fbb44961a2c14a76d83 Mon Sep 17 00:00:00 2001 From: jsasg <735273025@qq.com> Date: Wed, 2 Jul 2025 10:42:48 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BB=8E=E4=BA=A7=E5=93=81=E7=9B=AE?= =?UTF-8?q?=E5=BD=95=E5=90=8C=E6=AD=A5=E4=BA=A7=E5=93=81=E7=9B=B8=E5=85=B3?= =?UTF-8?q?=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/admin/controller/ReceiveProductSync.php | 217 ++++++++++++++++++ app/admin/controller/ReceiveSync.php | 71 ------ app/admin/model/v1/ProductCategoryModel.php | 6 + app/admin/model/v1/ProductModel.php | 6 + .../model/v1/ProductTcoCategoryModel.php | 6 + 5 files changed, 235 insertions(+), 71 deletions(-) create mode 100644 app/admin/controller/ReceiveProductSync.php delete mode 100644 app/admin/controller/ReceiveSync.php 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/controller/ReceiveSync.php b/app/admin/controller/ReceiveSync.php deleted file mode 100644 index 368e6694..00000000 --- a/app/admin/controller/ReceiveSync.php +++ /dev/null @@ -1,71 +0,0 @@ -post(); - if (empty($data)) return error('请确认同步数据'); - - $lang_id = LanguageModel::where('code', $data['lang'])->value('id'); - $record = [ - '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' => 0, - 'sync_time' => strtotime($data['created_at']) - ]; - - if (Operate_Of_ReceiveSync::Disable == $data['operate']) { - $record['disabled'] = 1; - } - - $validate = validate([ - 'name|分类名称' => 'require', - 'erp_code|分类ERP编码' => 'require', - ]); - if (!$validate->check($record)) { - throw new \Exception((string)$validate->getError()); - } - - $category = ProductTcoCategoryModel::language($lang_id)->erpCode($record['erp_code'])->find(); - Db::startTrans(); - try { - if (empty($category)) { - ProductTcoCategoryModel::create($record); - ProductCategoryModel::where - } else { - $category->save($record); - } - } catch (\Throwable $th) { - Db::rollback(); - throw $th; - } - - } -} 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 d68be9b2..ea6cb328 100644 --- a/app/admin/model/v1/ProductTcoCategoryModel.php +++ b/app/admin/model/v1/ProductTcoCategoryModel.php @@ -23,6 +23,12 @@ 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) {