feat: 同步数据接收

2025-07-01 17:15:40 +08:00
parent 77706e5bcb
commit 8e78f95002
2 changed files with 77 additions and 0 deletions
--- a/app/admin/controller/ReceiveSync.php
+++ b/app/admin/controller/ReceiveSync.php
@@ -0,0 +1,71 @@
+<?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\ProductTcoCategoryModel;
+use think\facade\Db;
+
+class Operate_Of_ReceiveSync
+{
+    const Add     = 'add';
+    const Update  = 'update';
+    const Enable  = 'enable';
+    const Disable = 'disable';
+}
+
+/**
+ * 接收同步数据
+ */
+class ReceiveSync
+{
+    public function product_category()
+    {
+        $data = request()->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;
+        }
+        
+    }
+}