钱包导入

api/controllers/PlatformCoinsController.php

+<?php
+
+namespace api\controllers;
+
+use api\base\BaseController;
+use common\models\psources\CoinPlatformCoins;
+use Yii;
+
+class PlatformCoinsController extends BaseController
+{
+    /**
+     * 新增空投钱包
+     *
+     * @param  string $platform_id
+     * @param  string $platform_coins
+     * @return array
+     */
+
+    public function actionIndex()
+    {
+        $platform_id = Yii::$app->request->post('platform_id', '');
+        $coins_address = Yii::$app->request->post('platform_coins', '');
+        $type = Yii::$app->request->post('type', '');
+
+        if(empty($platform_id) || empty($coins_address) || empty($type)){
+            return ['code' => -1,'data' => [], 'msg' => '缺少必要的参数'];
+        }
+
+        $item_array = [];
+        foreach($coins_address as $item){
+            $isExistModel = CoinPlatformCoins::find()->where(['coins_address' => $item['coinAddress'], 'platform_id' => $platform_id])->one();
+            if($isExistModel) continue;
+            $item_array[] = [
+                $item['coinName'],
+                $item['coinAddress'],
+                $type,
+                $platform_id,
+            ] ;
+        }
+
+        $result = CoinPlatformCoins::batchImport($item_array);
+        if(!$result){
+            return ['code' => -1,'data' => [], 'msg' => '数据导入失败'];
+        }
+        return ['code' => 0,'data' => [], 'msg' => '数据导入成功'];
+    }
+
+}
\ No newline at end of file

common/models/psources/CoinPlatformCoins.php

+<?php
+
+namespace common\models\psources;
+
+use Yii;
+use common\core\BaseActiveRecord;
+
+
+class CoinPlatformCoins extends BaseActiveRecord
+{
+    //定义场景
+    const SCENARIOS_CREATE = 'create';
+    const SCENARIOS_UPDATE = 'update';
+
+    public static function getDb()
+    {
+        return Yii::$app->get('p_sources');
+    }
+
+    public static function tableName()
+    {
+        return '{{%coin_platform_coins}}';
+    }
+
+    public function rules() {
+        return [
+            [['coins_name','coins_address', 'type', 'platform_id'], 'required'],
+        ];
+    }
+
+    public function scenarios() {
+        $scenarios = [
+            self:: SCENARIOS_CREATE => ['coins_name','coins_address', 'type', 'platform_id'],
+        ];
+        return array_merge( parent:: scenarios(), $scenarios);
+    }
+
+    /**
+     * 导入数据
+     *
+     * @param  array    $datas
+     * @return boolean
+     */
+    public static function batchImport(array $datas)
+    {
+        if (!is_array($datas)) {
+            return false;
+        }
+        try {
+            $result = self::getDb()->createCommand()->batchInsert(self::tableName(), ['coins_name', 'coins_address', 'type', 'platform_id'], $datas)->execute();
+            return $result;
+        } catch (\Exception $e) {
+        }
+        return false;
+    }
+}