<?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' => null, 'msg' => '缺少必要的参数'];
        }

        $item_array = [];
        foreach($coins_address as $item){
            $platform_coins_arr = explode(',', $item);
            $coin_name = $platform_coins_arr[0];
            $coins_address = $platform_coins_arr[1];
            if(empty($coin_name) || empty($coins_address)) continue;
            $isExistModel = CoinPlatformCoins::find()->where(['coins_address' => $coins_address, 'platform_id' => $platform_id])->one();
            if($isExistModel) continue;
            $item_array[] = [
                $coin_name,
                $coins_address,
                $type,
                $platform_id,
            ] ;
        }
        if(empty($item_array)){
            return ['code' => -1,'data' => null, 'msg' => '数据重复插入'];
        }

        $result = CoinPlatformCoins::batchImport($item_array);
        if(!$result){
            return ['code' => -1,'data' => null, 'msg' => '数据导入失败'];
        }
        return ['code' => 0,'data' => null, 'msg' => '数据导入成功'];
    }

}