add - 导入外部产品

app/adminapi/controller/external/ExternalPlatformGoodsController.php

@@ -105,4 +105,13 @@ class ExternalPlatformGoodsController extends BaseAdminController
     }
 
 
+    public function goodsImport()
+    {
+        $params = $this->request->post();
+        $result = ExternalPlatformGoodsLogic::goodsImport($params);
+        if (true === $result) {
+            return $this->success('导入成功', [], 1, 1);
+        }
+        return $this->fail(ExternalPlatformGoodsLogic::getError());
+    }
 }

app/adminapi/logic/external/ExternalPlatformGoodsLogic.php

@@ -111,4 +111,34 @@ class ExternalPlatformGoodsLogic extends BaseLogic
     {
         return ExternalPlatformGoods::findOrEmpty($params['id'])->toArray();
     }
+
+    public static function goodsImport($datas)
+    {
+        $newArray = [];
+        $time = time();
+        foreach ($datas as $key => $data) {
+            $newArray[$key]['service_fee'] = $data['service_fee']?:0;
+            $newArray[$key]['goods_status'] = 1;
+            $newArray[$key]['create_time'] = $time;
+            $newArray[$key]['update_time'] = $time;
+            $newArray[$key]['goods_id'] = $data['goods_id'];
+            $newArray[$key]['external_goods_sn'] = $data['external_goods_sn'];
+            $newArray[$key]['external_platform_id'] = $data['external_platform_id'];
+        }
+
+        Db::startTrans();
+        try {
+
+            ExternalPlatformGoods::insertAll($newArray);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
 }