218 lines
8.9 KiB
PHP
218 lines
8.9 KiB
PHP
<?php
|
|
declare (strict_types = 1);
|
|
|
|
namespace app\admin\controller;
|
|
|
|
use app\admin\model\v1\LanguageModel;
|
|
use app\admin\model\v1\ProductCategoryModel;
|
|
use app\admin\model\v1\ProductModel;
|
|
use app\admin\model\v1\ProductTcoCategoryModel;
|
|
use think\facade\Db;
|
|
|
|
class Operate_Of_ReceiveSync
|
|
{
|
|
const Add = 'add';
|
|
const Update = 'update';
|
|
const Enable = 'enable';
|
|
const Disable = 'disable';
|
|
}
|
|
|
|
/**
|
|
* 接收产品相关同步数据
|
|
*/
|
|
class ReceiveProductSync
|
|
{
|
|
// 接收产品目录分类同步数据
|
|
public function category()
|
|
{
|
|
$data = request()->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('同步成功');
|
|
}
|
|
}
|